|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
GenericDatumReader.readArray(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder) to add a
value.
GenericDatumReader.readMap(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder) to add a
key/value pair.
InputFormat for Avro data filesAvroJob .RawComparator used by jobs configured with AvroJob.OutputFormat for Avro data files.RecordReader for Avro data files.Serialization used by jobs configured with AvroJob.InputFormat for text files.AvroJob .AvroJob .Decoder for binary-format data.DecoderFactory to create BinaryDecoder instances and
reinitialize them
out.
Encoder that writes large arrays and maps as a sequence of
blocks.ByteBuffer data as an InputStream.OutputStream in ByteBuffers.BinaryDecoder with the input stream
provided as the source of data.
BinaryDecoder with the byte array
provided as the source of data.
DataFileWriter.DataFileWriter.Transceiver implementation.Decoders.GenericFixed.FSDataInputStream to SeekableInput.GenericEnumSymbol.GenericFixed.GenericRecord.DatumReader for generic Java objects.DatumWriter for generic Java objects.Requestor implementation for generic Java data.Responder implementation for generic Java data.GenericDatumWriter.writeArray(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to enumerate
array elements.
GenericDatumWriter.writeArray(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to get the
size of an array.
GenericDatumReader.readRecord(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder) to retrieve a
record field value from a reused instance.
GenericDatumWriter.writeRecord(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to retrieve
a record field value.
Utf8.getByteLength() instead.
GenericDatumWriter.writeMap(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to enumerate
map elements.
GenericDatumWriter.writeMap(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to get the size
of a map.
Protocol.Message corresponding to this RPC
Transceiver.setRemote(Protocol).
GenericData.compare(Object,Object,Schema).
Server.Transceiver implementation.DecoderFactory to create BinaryDecoder instances and
reinitialize them
InputStream that is aware of any buffering that
may occur in this BinaryDecoder.
GenericData.resolveUnion(Schema,Object).
GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).
GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).
GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).
GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).
GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).
GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).
GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).
Decoder for Avro's JSON data encoding.Encoder for Avro's JSON data encoding.Server implementation.Transceiver implementation.Decoders.Encoders.List.add(Object) would next
store an element, if any.
GenericDatumReader.readArray(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder) to retrieve a
value from a reused instance.
InputStream.read(byte[],int,int).
Encoder.writeBoolean(boolean).
Transceiver.transceive(List).
Encoder.writeBytes(java.nio.ByteBuffer).
Encoder.writeDouble(double).
Encoder.writeFloat(float).
Encoder.writeIndex(int).
Encoder.writeInt(int).
Encoder.writeLong(long).
Encoder.writeString(org.apache.avro.util.Utf8).
ReflectData implementation that permits null field values.DatumReader for existing classes via
Java reflection.DatumWriter for existing classes
via Java reflection.Requestor for existing interfaces.Responder for existing interfaces.GenericDatumReader.readRecord(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder) to remove a
record field value from a reused instance.
ResolvingDecoder.ResolvingDecoder(Object, Decoder).
Decoder that performs type-resolution between the reader's and
writer's schemas.HttpServlet that responds to Avro RPC requests.Schema.
DataFileWriter.sync() while writing.
read().
FileInputStream that implements SeekableInput.GenericDatumReader.readRecord(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder) to set a
record fields value to a record instance.
Utf8.setByteLength(int) instead.
Protocol.Message corresponding to this RPC
Encoder.writeBytes(java.nio.ByteBuffer).
Decoder.skipArray().
Encoder.writeString(org.apache.avro.util.Utf8).
skipXyz or
readXyz methods on this, until the
parser stack reaches the target level.
Transceiver implementation.Span to which corresponds to this node in the call tree.
DatumReader for generated Java classes.DatumWriter for generated Java classes.Requestor for generated interfaces.Responder for generated interfaces.DataFileReader.seek(long).
read().
Main.Trace's
which share the same execution path.Trace.TracePlugin.Requestor.request(String,Object) for two-way messages.
Requestor.Decoder that ensures that the sequence
of operations conforms to a schema.Encoder that ensures that the sequence
of operations conforms to a schema.Requestor.request(String,Object) for one-way messages.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||