|
||||||||||
| 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.TextOutputFormat for
writing to Avro Data Files with a "bytes" schema.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 ByteBuffers.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.DataFileWriter.append(Object) when an exception occurs while writing a
datum to the buffer.Transceiver implementation.Decoders.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.
CallFuture.get() or CallFuture.get(long, TimeUnit).
CallFuture.get()
or CallFuture.get(long, TimeUnit).
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.Schema.Parser instead.
Schema.Parser instead.
Schema.Parser instead.
Schema.Parser instead.
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.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.request(String,Object,Callback) for two-way messages using callbacks.
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 | |||||||||