A C D F G L M N O R S T V W

A

arrayNext() - Method in class org.apache.flink.api.avro.DataInputDecoder

AvroInputFormat<E> - Class in org.apache.flink.api.java.io

Provides a FileInputFormat for Avro records.

AvroInputFormat(Path, Class<E>) - Constructor for class org.apache.flink.api.java.io.AvroInputFormat

AvroOutputFormat<E> - Class in org.apache.flink.api.java.io

AvroOutputFormat(Path, Class<E>) - Constructor for class org.apache.flink.api.java.io.AvroOutputFormat

AvroOutputFormat(Class<E>) - Constructor for class org.apache.flink.api.java.io.AvroOutputFormat

AvroOutputFormat.Codec - Enum in org.apache.flink.api.java.io

Wrapper which encapsulates the supported codec and a related serialization byte.

C

close() - Method in class org.apache.flink.api.avro.FSDataInputStreamWrapper

close() - Method in class org.apache.flink.api.java.io.AvroOutputFormat

D

DataInputDecoder - Class in org.apache.flink.api.avro

DataInputDecoder() - Constructor for class org.apache.flink.api.avro.DataInputDecoder

DataOutputEncoder - Class in org.apache.flink.api.avro

DataOutputEncoder() - Constructor for class org.apache.flink.api.avro.DataOutputEncoder

F

flush() - Method in class org.apache.flink.api.avro.DataOutputEncoder

FSDataInputStreamWrapper - Class in org.apache.flink.api.avro

Code copy pasted from org.apache.avro.mapred.FSInput (which is Apache licensed as well) The wrapper keeps track of the position in the data stream.

FSDataInputStreamWrapper(FSDataInputStream, long) - Constructor for class org.apache.flink.api.avro.FSDataInputStreamWrapper

G

getCurrentState() - Method in class org.apache.flink.api.java.io.AvroInputFormat

getDirectoryFileName(int) - Method in class org.apache.flink.api.java.io.AvroOutputFormat

getProducedType() - Method in class org.apache.flink.api.java.io.AvroInputFormat

getRecordsReadFromBlock() - Method in class org.apache.flink.api.java.io.AvroInputFormat

L

length() - Method in class org.apache.flink.api.avro.FSDataInputStreamWrapper

M

mapNext() - Method in class org.apache.flink.api.avro.DataInputDecoder

N

nextRecord(E) - Method in class org.apache.flink.api.java.io.AvroInputFormat

O

open(FileInputSplit) - Method in class org.apache.flink.api.java.io.AvroInputFormat

open(int, int) - Method in class org.apache.flink.api.java.io.AvroOutputFormat

org.apache.flink.api.avro - package org.apache.flink.api.avro

org.apache.flink.api.java.io - package org.apache.flink.api.java.io

R

reachedEnd() - Method in class org.apache.flink.api.java.io.AvroInputFormat

read(byte[], int, int) - Method in class org.apache.flink.api.avro.FSDataInputStreamWrapper

readArrayStart() - Method in class org.apache.flink.api.avro.DataInputDecoder

readBoolean() - Method in class org.apache.flink.api.avro.DataInputDecoder

readBytes(ByteBuffer) - Method in class org.apache.flink.api.avro.DataInputDecoder

readDouble() - Method in class org.apache.flink.api.avro.DataInputDecoder

readEnum() - Method in class org.apache.flink.api.avro.DataInputDecoder

readFixed(byte[], int, int) - Method in class org.apache.flink.api.avro.DataInputDecoder

readFloat() - Method in class org.apache.flink.api.avro.DataInputDecoder

readIndex() - Method in class org.apache.flink.api.avro.DataInputDecoder

readInt() - Method in class org.apache.flink.api.avro.DataInputDecoder

readLong() - Method in class org.apache.flink.api.avro.DataInputDecoder

readMapStart() - Method in class org.apache.flink.api.avro.DataInputDecoder

readNull() - Method in class org.apache.flink.api.avro.DataInputDecoder

readString(Utf8) - Method in class org.apache.flink.api.avro.DataInputDecoder

readString() - Method in class org.apache.flink.api.avro.DataInputDecoder

readVarLongCount(DataInput) - Static method in class org.apache.flink.api.avro.DataInputDecoder

reopen(FileInputSplit, Tuple2<Long, Long>) - Method in class org.apache.flink.api.java.io.AvroInputFormat

S

seek(long) - Method in class org.apache.flink.api.avro.FSDataInputStreamWrapper

setCodec(AvroOutputFormat.Codec) - Method in class org.apache.flink.api.java.io.AvroOutputFormat

Set avro codec for compression.

setIn(DataInput) - Method in class org.apache.flink.api.avro.DataInputDecoder

setItemCount(long) - Method in class org.apache.flink.api.avro.DataOutputEncoder

setOut(DataOutput) - Method in class org.apache.flink.api.avro.DataOutputEncoder

setReuseAvroValue(boolean) - Method in class org.apache.flink.api.java.io.AvroInputFormat

Sets the flag whether to reuse the Avro value instance for all records.

setSchema(Schema) - Method in class org.apache.flink.api.java.io.AvroOutputFormat

setUnsplittable(boolean) - Method in class org.apache.flink.api.java.io.AvroInputFormat

If set, the InputFormat will only read entire files.

skipArray() - Method in class org.apache.flink.api.avro.DataInputDecoder

skipBytes() - Method in class org.apache.flink.api.avro.DataInputDecoder

skipFixed(int) - Method in class org.apache.flink.api.avro.DataInputDecoder

skipMap() - Method in class org.apache.flink.api.avro.DataInputDecoder

skipString() - Method in class org.apache.flink.api.avro.DataInputDecoder

startItem() - Method in class org.apache.flink.api.avro.DataOutputEncoder

T

tell() - Method in class org.apache.flink.api.avro.FSDataInputStreamWrapper

V

valueOf(String) - Static method in enum org.apache.flink.api.java.io.AvroOutputFormat.Codec

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flink.api.java.io.AvroOutputFormat.Codec

Returns an array containing the constants of this enum type, in the order they are declared.

W

writeArrayEnd() - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeArrayStart() - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeBoolean(boolean) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeBytes(byte[], int, int) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeBytes(ByteBuffer) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeDouble(double) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeEnum(int) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeFixed(byte[], int, int) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeFloat(float) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeIndex(int) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeInt(int) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeLong(long) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeMapEnd() - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeMapStart() - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeNull() - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeRecord(E) - Method in class org.apache.flink.api.java.io.AvroOutputFormat

writeString(String) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeString(Utf8) - Method in class org.apache.flink.api.avro.DataOutputEncoder

writeVarLongCount(DataOutput, long) - Static method in class org.apache.flink.api.avro.DataOutputEncoder

A C D F G L M N O R S T V W