A C D F G M N R S T V

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.format - package co.cask.cdap.format

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

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

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

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(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(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

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

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

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

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.

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

A C D F G M N R S T V