A C D E F G J M N R S T V W

A

addPattern(Grok, String) - Method in class co.cask.cdap.format.GrokRecordFormat

addPatterns(Grok) - Method in class co.cask.cdap.format.GrokRecordFormat

AvroRecordFormat - Class in co.cask.cdap.format

Stream record format that interprets the body as avro encoded binary data.

AvroRecordFormat() - Constructor for class co.cask.cdap.format.AvroRecordFormat

C

CHARSET - Static variable in class co.cask.cdap.format.DelimitedStringsRecordFormat

CHARSET - Static variable in class co.cask.cdap.format.TextRecordFormat

co.cask.cdap.common.io - package co.cask.cdap.common.io

co.cask.cdap.format - package co.cask.cdap.format

co.cask.cdap.format.io - package co.cask.cdap.format.io

CombinedLogRecordFormat - Class in co.cask.cdap.format

Stream record format that interprets stream body as data in Combined Log Format.

CombinedLogRecordFormat() - Constructor for class co.cask.cdap.format.CombinedLogRecordFormat

configure(Map<String, String>) - Method in class co.cask.cdap.format.AvroRecordFormat

configure(Map<String, String>) - Method in class co.cask.cdap.format.DelimitedStringsRecordFormat

configure(Map<String, String>) - Method in class co.cask.cdap.format.GrokRecordFormat

configure(Map<String, String>) - Method in class co.cask.cdap.format.TextRecordFormat

createEnum(String, Schema) - Method in class co.cask.cdap.format.StructuredRecordDatumReader

createInitializedFormat(FormatSpecification) - Static method in class co.cask.cdap.format.RecordFormats

Create an initialized record format for the given format specification.

D

DatumReader<T> - Interface in co.cask.cdap.common.io

Represents reader for decoding object.

DatumWriter<T> - Interface in co.cask.cdap.common.io

Represents writer for encoding object.

decode(Decoder, Schema) - Method in class co.cask.cdap.format.io.StructuredRecordDatumReader

Decodes a value based on the Schema.

decodeArray(Decoder, Schema) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumReader

decodeArray(Decoder, Schema) - Method in class co.cask.cdap.format.io.StructuredRecordDatumReader

Decodes an array with array element of a given Schema.

decodeEnum(Decoder, Schema) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumReader

decodeEnum(Decoder, Schema) - Method in class co.cask.cdap.format.io.StructuredRecordDatumReader

Decodes a enum value based on the given Schema.

decodeMap(Decoder, Schema, Schema) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumReader

decodeMap(Decoder, Schema, Schema) - Method in class co.cask.cdap.format.io.StructuredRecordDatumReader

Decodes a map.

Decoder - Interface in co.cask.cdap.common.io

Interface for decoding data.

decodeRecord(Decoder, Schema) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumReader

decodeRecord(Decoder, Schema) - Method in class co.cask.cdap.format.io.StructuredRecordDatumReader

Decodes a record.

decodeUnion(Decoder, Schema) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumReader

decodeUnion(Decoder, Schema) - Method in class co.cask.cdap.format.io.StructuredRecordDatumReader

Decodes a value from a union.

DelimitedStringsRecordFormat - Class in co.cask.cdap.format

Stream record format that interprets the body as string of delimited fields.

DelimitedStringsRecordFormat() - Constructor for class co.cask.cdap.format.DelimitedStringsRecordFormat

DELIMITER - Static variable in class co.cask.cdap.format.DelimitedStringsRecordFormat

determinePattern(Map<String, String>) - Method in class co.cask.cdap.format.GrokRecordFormat

E

encode(T, Encoder) - Method in interface co.cask.cdap.common.io.DatumWriter

encode(StructuredRecord, Encoder) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

encode(StructuredRecord, Encoder) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

encode(Encoder, Schema, Object) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes a value based on a Schema

encodeArrayBegin(Encoder, Schema, int) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

encodeArrayBegin(Encoder, Schema, int) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes the beginning of an array.

encodeArrayElement(Encoder, Schema, Object) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes an element of an array.

encodeArrayEnd(Encoder, Schema, int) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

encodeArrayEnd(Encoder, Schema, int) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes the ending of an array.

encodeEnum(Encoder, Schema, Object) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

encodeEnum(Encoder, Schema, Object) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes a enum value.

encodeMapBegin(Encoder, Schema, Schema, int) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

encodeMapBegin(Encoder, Schema, Schema, int) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes the beginning of a Map.

encodeMapEnd(Encoder, Schema, Schema, int) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

encodeMapEnd(Encoder, Schema, Schema, int) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes the ending of a Map.

encodeMapEntry(Encoder, Schema, Schema, Map.Entry<?, ?>) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

encodeMapEntry(Encoder, Schema, Schema, Map.Entry<?, ?>) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes a map entry.

Encoder - Interface in co.cask.cdap.common.io

Interface for encoding data.

encodeRecordBegin(Encoder, Schema) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

encodeRecordBegin(Encoder, Schema) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes the beginning of record.

encodeRecordEnd(Encoder, Schema) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

encodeRecordEnd(Encoder, Schema) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes the ending of record.

encodeRecordField(Encoder, Schema.Field, Object) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

encodeRecordField(Encoder, Schema.Field, Object) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes a record field.

encodeUnion(Encoder, Schema, int, Object) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

encodeUnion(Encoder, Schema, int, Object) - Method in class co.cask.cdap.format.io.StructuredRecordDatumWriter

Encodes a union value.

F

fromDelimitedString(String, String, Schema) - Static method in class co.cask.cdap.format.StructuredRecordStringConverter

Converts a delimited string to a StructuredRecord based on the schema.

fromJsonString(String, Schema) - Static method in class co.cask.cdap.format.StructuredRecordStringConverter

Converts a json string to a StructuredRecord based on the schema.

G

getDefaultSchema() - Method in class co.cask.cdap.format.AvroRecordFormat

getDefaultSchema() - Method in class co.cask.cdap.format.CombinedLogRecordFormat

getDefaultSchema() - Method in class co.cask.cdap.format.DelimitedStringsRecordFormat

getDefaultSchema() - Method in class co.cask.cdap.format.GrokRecordFormat

getDefaultSchema() - Method in class co.cask.cdap.format.TextRecordFormat

getPattern() - Method in class co.cask.cdap.format.GrokRecordFormat

GrokRecordFormat - Class in co.cask.cdap.format

GrokRecordFormat.

GrokRecordFormat() - Constructor for class co.cask.cdap.format.GrokRecordFormat

J

JsonDecoder - Class in co.cask.cdap.format.io

A Decoder that decodes from json using JsonReader.

JsonDecoder(JsonReader) - Constructor for class co.cask.cdap.format.io.JsonDecoder

JsonEncoder - Class in co.cask.cdap.format.io

An Encoder that encodes using JsonWriter.

JsonEncoder(JsonWriter) - Constructor for class co.cask.cdap.format.io.JsonEncoder

JsonStructuredRecordDatumReader - Class in co.cask.cdap.format.io

A StructuredRecordDatumReader that decodes from Json.

JsonStructuredRecordDatumReader() - Constructor for class co.cask.cdap.format.io.JsonStructuredRecordDatumReader

Constructor that treats field names case sensitive.

JsonStructuredRecordDatumReader(boolean) - Constructor for class co.cask.cdap.format.io.JsonStructuredRecordDatumReader

Constructor.

JsonStructuredRecordDatumWriter - Class in co.cask.cdap.format.io

A StructuredRecordDatumWriter for encoding StructuredRecord to json.

JsonStructuredRecordDatumWriter() - Constructor for class co.cask.cdap.format.io.JsonStructuredRecordDatumWriter

M

MAPPING - Static variable in class co.cask.cdap.format.DelimitedStringsRecordFormat

N

newArray(Object, int, Schema) - Method in class co.cask.cdap.format.StructuredRecordDatumReader

R

read(Decoder, Schema) - Method in interface co.cask.cdap.common.io.DatumReader

read(StreamEvent) - Method in class co.cask.cdap.format.AvroRecordFormat

read(StreamEvent) - Method in class co.cask.cdap.format.CombinedLogRecordFormat

read(StreamEvent) - Method in class co.cask.cdap.format.DelimitedStringsRecordFormat

read(StreamEvent) - Method in class co.cask.cdap.format.GrokRecordFormat

read(Decoder, Schema) - Method in class co.cask.cdap.format.io.JsonStructuredRecordDatumReader

read(Decoder, Schema) - Method in class co.cask.cdap.format.io.StructuredRecordDatumReader

read(Object, Schema, ResolvingDecoder) - Method in class co.cask.cdap.format.StructuredRecordDatumReader

read(StreamEvent) - Method in class co.cask.cdap.format.TextRecordFormat

readArray(Object, Schema, ResolvingDecoder) - Method in class co.cask.cdap.format.StructuredRecordDatumReader

readBool() - Method in interface co.cask.cdap.common.io.Decoder

Decodes and return a boolean value

readBool() - Method in class co.cask.cdap.format.io.JsonDecoder

readBytes() - Method in interface co.cask.cdap.common.io.Decoder

Decodes and return bytes

readBytes() - Method in class co.cask.cdap.format.io.JsonDecoder

readDouble() - Method in interface co.cask.cdap.common.io.Decoder

Decodes and return a double value

readDouble() - Method in class co.cask.cdap.format.io.JsonDecoder

readFloat() - Method in interface co.cask.cdap.common.io.Decoder

Decodes and return a float value

readFloat() - Method in class co.cask.cdap.format.io.JsonDecoder

readInt() - Method in interface co.cask.cdap.common.io.Decoder

Decodes and return a int value

readInt() - Method in class co.cask.cdap.format.io.JsonDecoder

readLong() - Method in interface co.cask.cdap.common.io.Decoder

Decodes and return a long value

readLong() - Method in class co.cask.cdap.format.io.JsonDecoder

readMap(Object, Schema, ResolvingDecoder) - Method in class co.cask.cdap.format.StructuredRecordDatumReader

readNull() - Method in interface co.cask.cdap.common.io.Decoder

Decodes and return a null value.

readNull() - Method in class co.cask.cdap.format.io.JsonDecoder

readRecord(Object, Schema, ResolvingDecoder) - Method in class co.cask.cdap.format.StructuredRecordDatumReader

readString() - Method in interface co.cask.cdap.common.io.Decoder

Decodes and return a string value

readString() - Method in class co.cask.cdap.format.io.JsonDecoder

readString(Object, Decoder) - Method in class co.cask.cdap.format.StructuredRecordDatumReader

RecordFormats - Class in co.cask.cdap.format

Creates RecordFormat objects given the name of a format.

RecordFormats() - Constructor for class co.cask.cdap.format.RecordFormats

RecordPutTransformer - Class in co.cask.cdap.format

Transforms records into Puts.

RecordPutTransformer(String, Schema) - Constructor for class co.cask.cdap.format.RecordPutTransformer

S

settings(String) - Static method in class co.cask.cdap.format.GrokRecordFormat

skipBytes() - Method in interface co.cask.cdap.common.io.Decoder

Skips a byte array.

skipBytes() - Method in class co.cask.cdap.format.io.JsonDecoder

skipDouble() - Method in interface co.cask.cdap.common.io.Decoder

Skips a double.

skipDouble() - Method in class co.cask.cdap.format.io.JsonDecoder

skipFloat() - Method in interface co.cask.cdap.common.io.Decoder

Skips a float.

skipFloat() - Method in class co.cask.cdap.format.io.JsonDecoder

skipString() - Method in interface co.cask.cdap.common.io.Decoder

Skips the a string.

skipString() - Method in class co.cask.cdap.format.io.JsonDecoder

StructuredRecordDatumReader - Class in co.cask.cdap.format.io

A DatumReader for reading StructuredRecord.

StructuredRecordDatumReader() - Constructor for class co.cask.cdap.format.io.StructuredRecordDatumReader

StructuredRecordDatumReader - Class in co.cask.cdap.format

An Avro DatumReader that reads data into StructuredRecord.

StructuredRecordDatumReader(Schema, Schema) - Constructor for class co.cask.cdap.format.StructuredRecordDatumReader

Constructs a new instance.

StructuredRecordDatumWriter - Class in co.cask.cdap.format.io

A DatumWriter for writing out StructuredRecord to Encoder.

StructuredRecordDatumWriter() - Constructor for class co.cask.cdap.format.io.StructuredRecordDatumWriter

StructuredRecordStringConverter - Class in co.cask.cdap.format

Utility class for converting StructuredRecord to and from json.

T

TextRecordFormat - Class in co.cask.cdap.format

Stream record format that interprets the entire body as a single string.

TextRecordFormat() - Constructor for class co.cask.cdap.format.TextRecordFormat

toDelimitedString(StructuredRecord, String) - Static method in class co.cask.cdap.format.StructuredRecordStringConverter

Converts a StructuredRecord to a delimited string.

toJsonString(StructuredRecord) - Static method in class co.cask.cdap.format.StructuredRecordStringConverter

Converts a StructuredRecord to a json string.

toPut(StructuredRecord) - Method in class co.cask.cdap.format.RecordPutTransformer

V

validateSchema(Schema) - Method in class co.cask.cdap.format.AvroRecordFormat

validateSchema(Schema) - Method in class co.cask.cdap.format.CombinedLogRecordFormat

validateSchema(Schema) - Method in class co.cask.cdap.format.DelimitedStringsRecordFormat

validateSchema(Schema) - Method in class co.cask.cdap.format.GrokRecordFormat

validateSchema(Schema) - Method in class co.cask.cdap.format.TextRecordFormat

W

writeBool(boolean) - Method in interface co.cask.cdap.common.io.Encoder

Writes out a boolean value.

writeBool(boolean) - Method in class co.cask.cdap.format.io.JsonEncoder

writeBytes(byte[]) - Method in interface co.cask.cdap.common.io.Encoder

Writes out a byte array.

writeBytes(byte[], int, int) - Method in interface co.cask.cdap.common.io.Encoder

Writes out a byte array.

writeBytes(ByteBuffer) - Method in interface co.cask.cdap.common.io.Encoder

Writes out the remaining bytes in ByteBuffer.

writeBytes(byte[]) - Method in class co.cask.cdap.format.io.JsonEncoder

writeBytes(byte[], int, int) - Method in class co.cask.cdap.format.io.JsonEncoder

writeBytes(ByteBuffer) - Method in class co.cask.cdap.format.io.JsonEncoder

writeDouble(double) - Method in interface co.cask.cdap.common.io.Encoder

Writes out a double value.

writeDouble(double) - Method in class co.cask.cdap.format.io.JsonEncoder

writeFloat(float) - Method in interface co.cask.cdap.common.io.Encoder

Writes out a float value.

writeFloat(float) - Method in class co.cask.cdap.format.io.JsonEncoder

writeInt(int) - Method in interface co.cask.cdap.common.io.Encoder

Writes out a int value.

writeInt(int) - Method in class co.cask.cdap.format.io.JsonEncoder

writeLong(long) - Method in interface co.cask.cdap.common.io.Encoder

Writes out a long value.

writeLong(long) - Method in class co.cask.cdap.format.io.JsonEncoder

writeNull() - Method in interface co.cask.cdap.common.io.Encoder

Writes out a null value.

writeNull() - Method in class co.cask.cdap.format.io.JsonEncoder

writeString(String) - Method in interface co.cask.cdap.common.io.Encoder

Writes out a string value.

writeString(String) - Method in class co.cask.cdap.format.io.JsonEncoder

A C D E F G J M N R S T V W