|
||||||||||
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 ByteBuffer
s.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.Decoder
s.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)
.
Transceiver
for this server.
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.Decoder
s.Encoder
s.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.Server
that uses javax.security.sasl
for authentication
and encryption.SaslServer
parameters.
Transceiver
that uses javax.security.sasl
for
authentication and encryption.SaslClient
.
SaslServer
.
Schema
.
DataFileWriter.sync()
while writing.
read()
.
FileInputStream
that implements SeekableInput
.InputFormat
for sequence files.FileReader
for sequence files.RecordReader
for sequence files.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 |