Skip navigation links
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
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
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 
Skip navigation links

Copyright © 2018 Cask Data, Inc. Licensed under the Apache License, Version 2.0.