|
||||||||||
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 files, which
converts each datum to string form in the input key.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.BinaryDecoder
with the input stream
provided as the source of data.
BinaryDecoder
with the byte array
provided as the source of data.
Encoder
for Avro's binary encoding.BinaryEncoder
with the OutputStream
provided as the destination for written data.
BinaryEncoder
implementation that writes large arrays and maps as a
sequence of blocks.BinaryEncoder
with the OutputStream
provided as the destination for written data.
Encoder
for Avro's binary encoding.ByteBuffer
data as an InputStream
.OutputStream
in ByteBuffer
s.DecoderFactory.binaryDecoder(InputStream, BinaryDecoder)
instead
DecoderFactory.binaryDecoder(byte[], int, int, BinaryDecoder)
instead
DecoderFactory.binaryDecoder(byte[], BinaryDecoder)
instead
Server
listening at the named URI using the provided
responder.
Transceiver
connecting to the provided URI.
DataFileWriter
.DataFileStream.Header
.
DataFileWriter
.Transceiver
implementation.Decoder
s.DecoderFactory.get()
instead
BinaryDecoder
with the input stream
provided as the source of data.
Encoder
for Avro's binary encoding that does not buffer output.BinaryEncoder
with the OutputStream
provided as the destination for written data.
Encoder
instances.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.
GenericData
implementation.
GenericData
implementation.
GenericDatumReader.readRecord(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder)
to retrieve a record
field value from a reused instance.
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.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)
.
JsonDecoder
using the InputStrim provided for reading
data that conforms to the Schema provided.
JsonDecoder
using the String provided for reading data
that conforms to the Schema provided.
Decoder
for Avro's JSON data encoding.JsonEncoder
using the OutputStream provided for writing
data conforming to the Schema provided.
JsonEncoder
using the JsonGenerator
provided for
output of data conforming to the Schema provided.
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.ResolvingDecoder.ResolvingDecoder(Object, Decoder)
.
ResolvingDecoder
wrapping the Decoder provided.
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.
DataFileWriter.sync()
.
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
DataFileWriter
.
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.
SaslSocketServer
instead.SaslSocketTransceiver
instead.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
.ValidatingDecoder
wrapping the Decoder provided.
Decoder
that ensures that the sequence
of operations conforms to a schema.ValidatingEncoder
that wraps the Encoder provided.
Encoder
that wraps another Encoder and
ensures that the sequence of operations conforms to the provided schema.Requestor.request(String,Object)
for one-way messages.
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |