| Package | Description |
|---|---|
| co.cask.cdap.common.io | |
| co.cask.cdap.format.io |
| Modifier and Type | Method and Description |
|---|---|
Encoder |
Encoder.writeBool(boolean b)
Writes out a boolean value.
|
Encoder |
Encoder.writeBytes(byte[] bytes)
Writes out a byte array.
|
Encoder |
Encoder.writeBytes(byte[] bytes,
int off,
int len)
Writes out a byte array.
|
Encoder |
Encoder.writeBytes(ByteBuffer bytes)
Writes out the remaining bytes in
ByteBuffer. |
Encoder |
Encoder.writeDouble(double d)
Writes out a double value.
|
Encoder |
Encoder.writeFloat(float f)
Writes out a float value.
|
Encoder |
Encoder.writeInt(int i)
Writes out a int value.
|
Encoder |
Encoder.writeLong(long l)
Writes out a long value.
|
Encoder |
Encoder.writeNull()
Writes out a null value.
|
Encoder |
Encoder.writeString(String s)
Writes out a string value.
|
| Modifier and Type | Method and Description |
|---|---|
void |
DatumWriter.encode(T data,
Encoder encoder) |
| Modifier and Type | Class and Description |
|---|---|
class |
JsonEncoder
An
Encoder that encodes using JsonWriter. |
| Modifier and Type | Method and Description |
|---|---|
Encoder |
JsonEncoder.writeBool(boolean b) |
Encoder |
JsonEncoder.writeBytes(byte[] bytes) |
Encoder |
JsonEncoder.writeBytes(byte[] bytes,
int off,
int len) |
Encoder |
JsonEncoder.writeBytes(ByteBuffer bytes) |
Encoder |
JsonEncoder.writeDouble(double d) |
Encoder |
JsonEncoder.writeFloat(float f) |
Encoder |
JsonEncoder.writeInt(int i) |
Encoder |
JsonEncoder.writeLong(long l) |
Encoder |
JsonEncoder.writeNull() |
Encoder |
JsonEncoder.writeString(String s) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
StructuredRecordDatumWriter.encode(Encoder encoder,
co.cask.cdap.api.data.schema.Schema schema,
Object value)
Encodes a value based on a
Schema |
void |
JsonStructuredRecordDatumWriter.encode(co.cask.cdap.api.data.format.StructuredRecord data,
Encoder encoder) |
void |
StructuredRecordDatumWriter.encode(co.cask.cdap.api.data.format.StructuredRecord data,
Encoder encoder) |
protected void |
JsonStructuredRecordDatumWriter.encodeArrayBegin(Encoder encoder,
co.cask.cdap.api.data.schema.Schema elementSchema,
int size) |
protected void |
StructuredRecordDatumWriter.encodeArrayBegin(Encoder encoder,
co.cask.cdap.api.data.schema.Schema elementSchema,
int size)
Encodes the beginning of an array.
|
protected void |
StructuredRecordDatumWriter.encodeArrayElement(Encoder encoder,
co.cask.cdap.api.data.schema.Schema elementSchema,
Object element)
Encodes an element of an array.
|
protected void |
JsonStructuredRecordDatumWriter.encodeArrayEnd(Encoder encoder,
co.cask.cdap.api.data.schema.Schema elementSchema,
int size) |
protected void |
StructuredRecordDatumWriter.encodeArrayEnd(Encoder encoder,
co.cask.cdap.api.data.schema.Schema elementSchema,
int size)
Encodes the ending of an array.
|
protected void |
JsonStructuredRecordDatumWriter.encodeEnum(Encoder encoder,
co.cask.cdap.api.data.schema.Schema enumSchema,
Object value) |
protected void |
StructuredRecordDatumWriter.encodeEnum(Encoder encoder,
co.cask.cdap.api.data.schema.Schema enumSchema,
Object value)
Encodes a enum value.
|
protected void |
JsonStructuredRecordDatumWriter.encodeMapBegin(Encoder encoder,
co.cask.cdap.api.data.schema.Schema keySchema,
co.cask.cdap.api.data.schema.Schema valueSchema,
int size) |
protected void |
StructuredRecordDatumWriter.encodeMapBegin(Encoder encoder,
co.cask.cdap.api.data.schema.Schema keySchema,
co.cask.cdap.api.data.schema.Schema valueSchema,
int size)
Encodes the beginning of a
Map. |
protected void |
JsonStructuredRecordDatumWriter.encodeMapEnd(Encoder encoder,
co.cask.cdap.api.data.schema.Schema keySchema,
co.cask.cdap.api.data.schema.Schema valueSchema,
int size) |
protected void |
StructuredRecordDatumWriter.encodeMapEnd(Encoder encoder,
co.cask.cdap.api.data.schema.Schema keySchema,
co.cask.cdap.api.data.schema.Schema valueSchema,
int size)
Encodes the ending of a
Map. |
protected void |
JsonStructuredRecordDatumWriter.encodeMapEntry(Encoder encoder,
co.cask.cdap.api.data.schema.Schema keySchema,
co.cask.cdap.api.data.schema.Schema valueSchema,
Map.Entry<?,?> entry) |
protected void |
StructuredRecordDatumWriter.encodeMapEntry(Encoder encoder,
co.cask.cdap.api.data.schema.Schema keySchema,
co.cask.cdap.api.data.schema.Schema valueSchema,
Map.Entry<?,?> entry)
Encodes a map entry.
|
protected void |
JsonStructuredRecordDatumWriter.encodeRecordBegin(Encoder encoder,
co.cask.cdap.api.data.schema.Schema schema) |
protected void |
StructuredRecordDatumWriter.encodeRecordBegin(Encoder encoder,
co.cask.cdap.api.data.schema.Schema schema)
Encodes the beginning of record.
|
protected void |
JsonStructuredRecordDatumWriter.encodeRecordEnd(Encoder encoder,
co.cask.cdap.api.data.schema.Schema schema) |
protected void |
StructuredRecordDatumWriter.encodeRecordEnd(Encoder encoder,
co.cask.cdap.api.data.schema.Schema schema)
Encodes the ending of record.
|
protected void |
JsonStructuredRecordDatumWriter.encodeRecordField(Encoder encoder,
co.cask.cdap.api.data.schema.Schema.Field field,
Object value) |
protected void |
StructuredRecordDatumWriter.encodeRecordField(Encoder encoder,
co.cask.cdap.api.data.schema.Schema.Field field,
Object value)
Encodes a record field.
|
protected void |
JsonStructuredRecordDatumWriter.encodeUnion(Encoder encoder,
co.cask.cdap.api.data.schema.Schema schema,
int matchingIdx,
Object value) |
protected void |
StructuredRecordDatumWriter.encodeUnion(Encoder encoder,
co.cask.cdap.api.data.schema.Schema schema,
int matchingIdx,
Object value)
Encodes a union value.
|
Copyright © 2018 Cask Data, Inc. Licensed under the Apache License, Version 2.0.