A B C D E F G H I J K L M N O P R S T U V W

A

add(T) - Method in interface org.apache.avro.generic.GenericArray

Add an element to this array.

add(T) - Method in class org.apache.avro.generic.GenericData.Array

addField(Object, String, int, Object) - Method in class org.apache.avro.generic.GenericDatumReader

Called by the default implementation of GenericDatumReader.readRecord(java.lang.Object, org.apache.avro.Schema, org.apache.avro.Schema, org.apache.avro.io.Decoder) to add a record fields value to a record instance.

addField(Object, String, int, Object) - Method in class org.apache.avro.reflect.ReflectDatumReader

addField(Object, String, int, Object) - Method in class org.apache.avro.specific.SpecificDatumReader

addFileset(FileSet) - Method in class org.apache.avro.specific.ProtocolTask

Add a fileset.

addRPCPlugin(RPCPlugin) - Method in class org.apache.avro.ipc.Requestor

Adds a new plugin to manipulate RPC metadata.

addRPCPlugin(RPCPlugin) - Method in class org.apache.avro.ipc.Responder

Adds a new plugin to manipulate per-call metadata.

addSchema(Schema) - Method in class org.apache.avro.file.DataFileWriter

If the schema for this file is a union, add a branch to it.

addToArray(Object, Object) - Method in class org.apache.avro.generic.GenericDatumReader

Called by the default implementation of GenericDatumReader.readArray(java.lang.Object, org.apache.avro.Schema, org.apache.avro.Schema, org.apache.avro.io.Decoder) to add a value.

addToMap(Object, Object, Object) - Method in class org.apache.avro.generic.GenericDatumReader

Called by the default implementation of GenericDatumReader.readMap(java.lang.Object, org.apache.avro.Schema, org.apache.avro.Schema, org.apache.avro.io.Decoder) to add a key/value pair.

adjustments - Variable in class org.apache.avro.io.parsing.Symbol.EnumAdjustAction

advance(Symbol) - Method in class org.apache.avro.io.parsing.Parser

Recursively replaces the symbol at the top of the stack with its production, until the top is a terminal.

append(D) - Method in class org.apache.avro.file.DataFileWriter

Append a datum to the file.

ARRAY_END - Static variable in class org.apache.avro.io.parsing.Symbol

ARRAY_START - Static variable in class org.apache.avro.io.parsing.Symbol

arrayNext() - Method in class org.apache.avro.io.BinaryDecoder

arrayNext() - Method in class org.apache.avro.io.Decoder

Processes the next block of an array andreturns the number of items in the block and let's the caller read those items.

arrayNext() - Method in class org.apache.avro.io.JsonDecoder

arrayNext() - Method in class org.apache.avro.io.ValidatingDecoder

AvroRemoteException - Exception in org.apache.avro.ipc

Base class for exceptions thrown to client by server.

AvroRemoteException() - Constructor for exception org.apache.avro.ipc.AvroRemoteException

AvroRemoteException(Throwable) - Constructor for exception org.apache.avro.ipc.AvroRemoteException

AvroRemoteException(Object) - Constructor for exception org.apache.avro.ipc.AvroRemoteException

AvroRuntimeException - Exception in org.apache.avro

Base Avro exception.

AvroRuntimeException(Throwable) - Constructor for exception org.apache.avro.AvroRuntimeException

AvroRuntimeException(String) - Constructor for exception org.apache.avro.AvroRuntimeException

AvroTypeException - Exception in org.apache.avro

Thrown when an illegal type is used.

AvroTypeException(String) - Constructor for exception org.apache.avro.AvroTypeException

B

BinaryData - Class in org.apache.avro.io

Utilities for binary-encoded data.

BinaryDecoder - Class in org.apache.avro.io

Low-level support for de-serializing Avro values.

BinaryDecoder(InputStream) - Constructor for class org.apache.avro.io.BinaryDecoder

BinaryEncoder - Class in org.apache.avro.io

Low-level support for serializing Avro values.

BinaryEncoder(OutputStream) - Constructor for class org.apache.avro.io.BinaryEncoder

Create a writer that sends its output to the underlying stream out.

BlockingBinaryEncoder - Class in org.apache.avro.io

A Encoder that writes large arrays and maps as a sequence of blocks.

BlockingBinaryEncoder(OutputStream) - Constructor for class org.apache.avro.io.BlockingBinaryEncoder

BlockingBinaryEncoder(OutputStream, int) - Constructor for class org.apache.avro.io.BlockingBinaryEncoder

BOOLEAN - Static variable in class org.apache.avro.io.parsing.Symbol

BUFFER_SIZE - Static variable in class org.apache.avro.ipc.ByteBufferOutputStream

ByteBufferInputStream - Class in org.apache.avro.ipc

Utility to present ByteBuffer data as an InputStream.

ByteBufferInputStream(List<ByteBuffer>) - Constructor for class org.apache.avro.ipc.ByteBufferInputStream

ByteBufferOutputStream - Class in org.apache.avro.ipc

Utility to collect data written to an OutputStream in ByteBuffers.

ByteBufferOutputStream() - Constructor for class org.apache.avro.ipc.ByteBufferOutputStream

bytes(byte[]) - Method in class org.apache.avro.generic.GenericData.Fixed

bytes() - Method in class org.apache.avro.generic.GenericData.Fixed

bytes() - Method in interface org.apache.avro.generic.GenericFixed

Return the data.

BYTES - Static variable in class org.apache.avro.io.parsing.Symbol

C

clear() - Method in interface org.apache.avro.generic.GenericArray

Reset the size of the array to zero.

clear() - Method in class org.apache.avro.generic.GenericData.Array

clientFinishConnect(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin

Called on the client after the initial RPC handshake

clientReceiveResponse(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin

This method is invoked at the client after the call is executed, and after the client receives the response

clientSendRequest(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin

This method is invoked at the client before it issues the RPC call.

clientStartConnect(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin

Called on the client before the initial RPC handshake to setup any handshake metadata for this plugin

close() - Method in class org.apache.avro.file.DataFileReader

Close this reader.

close() - Method in class org.apache.avro.file.DataFileWriter

Close the file.

close() - Method in class org.apache.avro.ipc.DatagramServer

close() - Method in class org.apache.avro.ipc.HttpServer

close() - Method in interface org.apache.avro.ipc.Server

Stop this server.

close() - Method in class org.apache.avro.ipc.SocketServer

close() - Method in class org.apache.avro.ipc.SocketTransceiver

close() - Method in class org.apache.avro.ipc.Transceiver

compare(Object, Object, Schema) - Method in class org.apache.avro.generic.GenericData

Compare objects according to their schema.

compare(byte[], int, byte[], int, Schema) - Static method in class org.apache.avro.io.BinaryData

Compare binary encoded data.

compare(Object, Object, Schema) - Method in class org.apache.avro.specific.SpecificData

compareBytes(byte[], int, int, byte[], int, int) - Static method in class org.apache.avro.io.BinaryData

Lexicographically compare bytes.

compareTo(GenericData.Array<T>) - Method in class org.apache.avro.generic.GenericData.Array

compareTo(GenericData.Fixed) - Method in class org.apache.avro.generic.GenericData.Fixed

compareTo(GenericData.Record) - Method in class org.apache.avro.generic.GenericData.Record

compareTo(SpecificRecord) - Method in class org.apache.avro.specific.SpecificRecordBase

compareTo(Utf8) - Method in class org.apache.avro.util.Utf8

compileProtocol(File, File) - Static method in class org.apache.avro.specific.SpecificCompiler

Generates Java interface and classes for a protocol.

compileSchema(File, File) - Static method in class org.apache.avro.specific.SpecificCompiler

Generates Java classes for a schema.

contents - Variable in class org.apache.avro.io.parsing.Symbol.DefaultStartAction

CONTINUE - Static variable in class org.apache.avro.io.parsing.Symbol

create(Schema.Type) - Static method in class org.apache.avro.Schema

Create a schema for a primitive type.

createArray(Schema) - Static method in class org.apache.avro.Schema

Create an array schema.

createBytes(byte[]) - Method in class org.apache.avro.generic.GenericDatumReader

Called to create byte arrays from default values.

createEnum(String, Schema) - Method in class org.apache.avro.generic.GenericDatumReader

Called to create an enum value.

createEnum(String, Schema) - Method in class org.apache.avro.reflect.ReflectDatumReader

createEnum(String, String, List<String>) - Static method in class org.apache.avro.Schema

Create an enum schema.

createFieldSchema(Field, Map<String, Schema>) - Method in class org.apache.avro.reflect.ReflectData.AllowNull

createFieldSchema(Field, Map<String, Schema>) - Method in class org.apache.avro.reflect.ReflectData

Create a schema for a field.

createFixed(Object, Schema) - Method in class org.apache.avro.generic.GenericDatumReader

Called to create an fixed value.

createFixed(Object, byte[], Schema) - Method in class org.apache.avro.generic.GenericDatumReader

Called to create an fixed value.

createFixed(Object, Schema) - Method in class org.apache.avro.reflect.ReflectDatumReader

createFixed(String, String, int) - Static method in class org.apache.avro.Schema

Create a union schema.

createMap(Schema) - Static method in class org.apache.avro.Schema

Create a map schema.

createMessage(String, Schema, Schema, Schema) - Method in class org.apache.avro.Protocol

createRecord(LinkedHashMap<String, Schema.Field>) - Static method in class org.apache.avro.Schema

Create an anonymous record schema.

createRecord(String, String, boolean) - Static method in class org.apache.avro.Schema

Create a named record schema.

createSchema(Type, Map<String, Schema>) - Method in class org.apache.avro.reflect.ReflectData

Create a schema for a type and it's fields.

createSchema(Type, Map<String, Schema>) - Method in class org.apache.avro.specific.SpecificData

createString(String) - Method in class org.apache.avro.generic.GenericDatumReader

Called to create a string from a default value.

createUnion(List<Schema>) - Static method in class org.apache.avro.Schema

Create a union schema.

D

DataFileReader<D> - Class in org.apache.avro.file

Read files written by DataFileWriter.

DataFileReader(SeekableInput, DatumReader<D>) - Constructor for class org.apache.avro.file.DataFileReader

Construct a reader for a file.

DataFileWriter<D> - Class in org.apache.avro.file

Stores in a file a sequence of data conforming to a schema.

DataFileWriter(Schema, OutputStream, DatumWriter<D>) - Constructor for class org.apache.avro.file.DataFileWriter

Construct a writer to a file for data matching a schema.

DatagramServer - Class in org.apache.avro.ipc

A simple datagram-based server implementation.

DatagramServer(Responder, SocketAddress) - Constructor for class org.apache.avro.ipc.DatagramServer

DatagramTransceiver - Class in org.apache.avro.ipc

A datagram-based Transceiver implementation.

DatagramTransceiver(SocketAddress) - Constructor for class org.apache.avro.ipc.DatagramTransceiver

DatagramTransceiver(DatagramChannel) - Constructor for class org.apache.avro.ipc.DatagramTransceiver

DatumReader<D> - Interface in org.apache.avro.io

Read data of a schema.

DatumWriter<D> - Interface in org.apache.avro.io

Write data of a schema.

Decoder - Class in org.apache.avro.io

Low-level support for de-serializing Avro values.

Decoder() - Constructor for class org.apache.avro.io.Decoder

DEFAULT_END_ACTION - Static variable in class org.apache.avro.io.parsing.Symbol

defaultFieldValue(Object, Schema, JsonNode) - Method in class org.apache.avro.generic.GenericDatumReader

Called by the default implementation of GenericDatumReader.readRecord(java.lang.Object, org.apache.avro.Schema, org.apache.avro.Schema, org.apache.avro.io.Decoder) to construct a default value for a field.

defaultValue() - Method in class org.apache.avro.Schema.Field

depth() - Method in class org.apache.avro.io.parsing.Parser

Returns the depth of the stack.

depth() - Method in class org.apache.avro.io.ParsingEncoder

doAction(Symbol, Symbol) - Method in class org.apache.avro.io.JsonDecoder

doAction(Symbol, Symbol) - Method in class org.apache.avro.io.JsonEncoder

doAction(Symbol, Symbol) - Method in interface org.apache.avro.io.parsing.Parser.ActionHandler

doAction(Symbol, Symbol) - Method in class org.apache.avro.io.ResolvingDecoder

doAction(Symbol, Symbol) - Method in class org.apache.avro.io.ValidatingDecoder

doAction(Symbol, Symbol) - Method in class org.apache.avro.io.ValidatingEncoder

doCompile(File, File) - Method in class org.apache.avro.specific.ProtocolTask

doCompile(File, File) - Method in class org.apache.avro.specific.SchemaTask

doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.avro.ipc.ResponderServlet

DOUBLE - Static variable in class org.apache.avro.io.parsing.Symbol

E

encodeDouble(double, OutputStream) - Static method in class org.apache.avro.io.BinaryEncoder

encodeDouble(double, byte[], int) - Static method in class org.apache.avro.io.BinaryEncoder

encodeFloat(float, OutputStream) - Static method in class org.apache.avro.io.BinaryEncoder

encodeFloat(float, byte[], int) - Static method in class org.apache.avro.io.BinaryEncoder

encodeLong(long, OutputStream) - Static method in class org.apache.avro.io.BinaryEncoder

encodeLong(long, byte[], int) - Static method in class org.apache.avro.io.BinaryEncoder

Encoder - Class in org.apache.avro.io

Low-level support for serializing Avro values.

Encoder() - Constructor for class org.apache.avro.io.Encoder

end - Variable in class org.apache.avro.io.parsing.Symbol.Repeater

ENUM - Static variable in class org.apache.avro.io.parsing.Symbol

equals(Object) - Method in class org.apache.avro.generic.GenericData.Array

equals(Object) - Method in class org.apache.avro.generic.GenericData.Fixed

equals(Object) - Method in class org.apache.avro.Protocol

equals(Object) - Method in class org.apache.avro.Protocol.Message

equals(Object) - Method in class org.apache.avro.Schema

equals(Object) - Method in class org.apache.avro.Schema.Field

equals(Object) - Method in exception org.apache.avro.specific.SpecificExceptionBase

equals(Object) - Method in class org.apache.avro.specific.SpecificRecordBase

equals(Object) - Method in class org.apache.avro.util.Utf8

error - Variable in class org.apache.avro.ipc.RPCContext

error() - Method in class org.apache.avro.ipc.RPCContext

The exception generated at the server, or null if no such exception has occured

execute() - Method in class org.apache.avro.specific.ProtocolTask

Run the compiler.

F

FIELD_ACTION - Static variable in class org.apache.avro.io.parsing.Symbol

findLabel(String) - Method in class org.apache.avro.io.parsing.Symbol.Alternative

findLabel(String) - Method in class org.apache.avro.io.parsing.Symbol.EnumLabelsAction

FIXED - Static variable in class org.apache.avro.io.parsing.Symbol

FixedSize - Annotation Type in org.apache.avro.reflect

Declares the size of implementations of GenericFixed.

FLOAT - Static variable in class org.apache.avro.io.parsing.Symbol

flush() - Method in class org.apache.avro.file.DataFileWriter

Flush the current state of the file, including metadata.

flush() - Method in class org.apache.avro.io.BinaryEncoder

flush() - Method in class org.apache.avro.io.BlockingBinaryEncoder

flush() - Method in class org.apache.avro.io.Encoder

Writes any buffered output to the underlying stream.

flush() - Method in class org.apache.avro.io.JsonEncoder

flush() - Method in class org.apache.avro.io.ValidatingEncoder

fname - Variable in class org.apache.avro.io.parsing.Symbol.FieldAdjustAction

G

generate(Schema) - Method in class org.apache.avro.io.parsing.JsonGrammarGenerator

Returns the non-terminal that is the start symbol for the grammar for the grammar for the given schema sc.

generate(Schema, Map<ValidatingGrammarGenerator.LitS, Symbol>) - Method in class org.apache.avro.io.parsing.JsonGrammarGenerator

Returns the non-terminal that is the start symbol for grammar of the given schema sc.

generate(Schema, Schema) - Method in class org.apache.avro.io.parsing.ResolvingGrammarGenerator

Resolves the writer schema writer and the reader schema reader and returns the start symbol for the grammar generated.

generate(Schema, Schema, Map<ValidatingGrammarGenerator.LitS, Symbol>) - Method in class org.apache.avro.io.parsing.ResolvingGrammarGenerator

Resolves the writer schema writer and the reader schema reader and returns the start symbol for the grammar generated.

generate(Schema) - Method in class org.apache.avro.io.parsing.ValidatingGrammarGenerator

Returns the non-terminal that is the start symbol for the grammar for the given schema sc.

generate(Schema, Map<ValidatingGrammarGenerator.LitS, Symbol>) - Method in class org.apache.avro.io.parsing.ValidatingGrammarGenerator

Returns the non-terminal that is the start symbol for the grammar for the given schema sc.

GenericArray<T> - Interface in org.apache.avro.generic

An array of objects.

GenericContainer - Interface in org.apache.avro.generic

Contains data of other types.

GenericData - Class in org.apache.avro.generic

Utilities for generic Java data.

GenericData() - Constructor for class org.apache.avro.generic.GenericData

GenericData.Array<T> - Class in org.apache.avro.generic

Default implementation of GenericArray.

GenericData.Array(int, Schema) - Constructor for class org.apache.avro.generic.GenericData.Array

GenericData.Fixed - Class in org.apache.avro.generic

Default implementation of GenericFixed.

GenericData.Fixed(Schema) - Constructor for class org.apache.avro.generic.GenericData.Fixed

GenericData.Fixed(byte[]) - Constructor for class org.apache.avro.generic.GenericData.Fixed

GenericData.Fixed() - Constructor for class org.apache.avro.generic.GenericData.Fixed

GenericData.Record - Class in org.apache.avro.generic

Default implementation of GenericRecord.

GenericData.Record(Schema) - Constructor for class org.apache.avro.generic.GenericData.Record

GenericDatumReader<D> - Class in org.apache.avro.generic

DatumReader for generic Java objects.

GenericDatumReader() - Constructor for class org.apache.avro.generic.GenericDatumReader

GenericDatumReader(Schema) - Constructor for class org.apache.avro.generic.GenericDatumReader

GenericDatumReader(Schema, Schema) - Constructor for class org.apache.avro.generic.GenericDatumReader

GenericDatumWriter<D> - Class in org.apache.avro.generic

DatumWriter for generic Java objects.

GenericDatumWriter() - Constructor for class org.apache.avro.generic.GenericDatumWriter

GenericDatumWriter(GenericData) - Constructor for class org.apache.avro.generic.GenericDatumWriter

GenericDatumWriter(Schema) - Constructor for class org.apache.avro.generic.GenericDatumWriter

GenericDatumWriter(Schema, GenericData) - Constructor for class org.apache.avro.generic.GenericDatumWriter

GenericFixed - Interface in org.apache.avro.generic

Fixed-size data.

GenericRecord - Interface in org.apache.avro.generic

A set of fields, each a name/value pair.

GenericRequestor - Class in org.apache.avro.generic

Requestor implementation for generic Java data.

GenericRequestor(Protocol, Transceiver) - Constructor for class org.apache.avro.generic.GenericRequestor

GenericResponder - Class in org.apache.avro.generic

Responder implementation for generic Java data.

GenericResponder(Protocol) - Constructor for class org.apache.avro.generic.GenericResponder

get() - Static method in class org.apache.avro.generic.GenericData

Return the singleton instance.

get(int) - Method in class org.apache.avro.io.parsing.Symbol.Sequence

get() - Static method in class org.apache.avro.reflect.ReflectData.AllowNull

Return the singleton instance.

get() - Static method in class org.apache.avro.reflect.ReflectData

Return the singleton instance.

get() - Static method in class org.apache.avro.specific.SpecificData

Return the singleton instance.

get(int) - Method in exception org.apache.avro.specific.SpecificExceptionBase

get(int) - Method in interface org.apache.avro.specific.SpecificRecord

get(int) - Method in class org.apache.avro.specific.SpecificRecordBase

getArrayElements(Object) - Method in class org.apache.avro.generic.GenericDatumWriter

Called by the default implementation of GenericDatumWriter.writeArray(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to enumerate array elements.

getArraySize(Object) - Method in class org.apache.avro.generic.GenericDatumWriter

Called by the default implementation of GenericDatumWriter.writeArray(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to get the size of an array.

getBufferList() - Method in class org.apache.avro.ipc.ByteBufferOutputStream

Returns all data written and resets the stream to be empty.

getBytes() - Method in class org.apache.avro.util.Utf8

getClass(Schema) - Method in class org.apache.avro.reflect.ReflectData

Return the class that implements this schema.

getClassName(Schema) - Method in class org.apache.avro.reflect.ReflectData

Returns the Java class name indicated by a schema's name and namespace.

getClient(Class<?>, Transceiver) - Static method in class org.apache.avro.reflect.ReflectRequestor

Create a proxy instance whose methods invoke RPCs.

getClient(Class<?>, Transceiver, ReflectData) - Static method in class org.apache.avro.reflect.ReflectRequestor

Create a proxy instance whose methods invoke RPCs.

getClient(Class<?>, ReflectRequestor) - Static method in class org.apache.avro.reflect.ReflectRequestor

Create a proxy instance whose methods invoke RPCs.

getClient(Class<?>, Transceiver) - Static method in class org.apache.avro.specific.SpecificRequestor

Create a proxy instance whose methods invoke RPCs.

getClient(Class<?>, Transceiver, SpecificData) - Static method in class org.apache.avro.specific.SpecificRequestor

Create a proxy instance whose methods invoke RPCs.

getClient(Class<?>, SpecificRequestor) - Static method in class org.apache.avro.specific.SpecificRequestor

Create a proxy instance whose methods invoke RPCs.

getDatumReader(Schema) - Method in class org.apache.avro.reflect.ReflectRequestor

getDatumReader(Schema) - Method in class org.apache.avro.reflect.ReflectResponder

getDatumReader(Schema) - Method in class org.apache.avro.specific.SpecificRequestor

getDatumReader(Schema) - Method in class org.apache.avro.specific.SpecificResponder

getDatumWriter(Schema) - Method in class org.apache.avro.reflect.ReflectRequestor

getDatumWriter(Schema) - Method in class org.apache.avro.reflect.ReflectResponder

getDatumWriter(Schema) - Method in class org.apache.avro.specific.SpecificRequestor

getDatumWriter(Schema) - Method in class org.apache.avro.specific.SpecificResponder

getElementType() - Method in class org.apache.avro.Schema

If this is an array, returns its element type.

getEnumOrdinal(String) - Method in class org.apache.avro.Schema

If this is an enum, return a symbol's ordinal value.

getEnumSymbols() - Method in class org.apache.avro.Schema

If this is an enum, return its symbols.

getErrors() - Method in class org.apache.avro.Protocol.Message

Errors that might be thrown.

getField(Object, String, int) - Method in class org.apache.avro.generic.GenericDatumReader

Called by the default implementation of GenericDatumReader.readRecord(java.lang.Object, org.apache.avro.Schema, org.apache.avro.Schema, org.apache.avro.io.Decoder) to retrieve a record field value from a reused instance.

getField(Object, String, int) - Method in class org.apache.avro.generic.GenericDatumWriter

Called by the default implementation of GenericDatumWriter.writeRecord(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to retrieve a record field value.

getField(Object, String, int) - Method in class org.apache.avro.reflect.ReflectDatumReader

getField(Object, String, int) - Method in class org.apache.avro.reflect.ReflectDatumWriter

getField(Object, String, int) - Method in class org.apache.avro.specific.SpecificDatumReader

getField(Object, String, int) - Method in class org.apache.avro.specific.SpecificDatumWriter

getFields() - Method in class org.apache.avro.Schema

If this is a record, returns its fields.

getFieldSchemas() - Method in class org.apache.avro.Schema

If this is a record, enumerate its field names and their schemas.

getFixedSize() - Method in class org.apache.avro.Schema

If this is fixed, returns its size.

getLabel(int) - Method in class org.apache.avro.io.parsing.Symbol.Alternative

getLabel(int) - Method in class org.apache.avro.io.parsing.Symbol.EnumLabelsAction

getLength() - Method in class org.apache.avro.util.Utf8

getLocal() - Method in class org.apache.avro.ipc.Requestor

getLocal() - Method in class org.apache.avro.ipc.Responder

getMapEntries(Object) - Method in class org.apache.avro.generic.GenericDatumWriter

Called by the default implementation of GenericDatumWriter.writeMap(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to enumerate map elements.

getMapSize(Object) - Method in class org.apache.avro.generic.GenericDatumWriter

Called by the default implementation of GenericDatumWriter.writeMap(org.apache.avro.Schema, java.lang.Object, org.apache.avro.io.Encoder) to get the size of a map.

getMD5() - Method in class org.apache.avro.Protocol

Return the MD5 hash of the text of this protocol.

getMessages() - Method in class org.apache.avro.Protocol

The messages of this protocol.

getMeta(String) - Method in class org.apache.avro.file.DataFileReader

Return the value of a metadata property.

getMetaLong(String) - Method in class org.apache.avro.file.DataFileReader

Return the value of a metadata property.

getMetaString(String) - Method in class org.apache.avro.file.DataFileReader

Return the value of a metadata property.

getName() - Method in class org.apache.avro.Protocol

The name of this protocol.

getName() - Method in class org.apache.avro.Protocol.Message

The name of this message.

getName() - Method in class org.apache.avro.Schema

If this is a record, enum or fixed, returns its name, otherwise the name of the primitive type.

getNamespace() - Method in class org.apache.avro.Protocol

The namespace of this protocol.

getNamespace() - Method in class org.apache.avro.Schema

If this is a record, enum or fixed, returns its namespace, if any.

getPort() - Method in class org.apache.avro.ipc.DatagramServer

getPort() - Method in class org.apache.avro.ipc.HttpServer

getPort() - Method in interface org.apache.avro.ipc.Server

The port this server runs on.

getPort() - Method in class org.apache.avro.ipc.SocketServer

getProtocol(Class) - Method in class org.apache.avro.reflect.ReflectData

Generate a protocol for a Java interface.

getRecordSchema(Object) - Method in class org.apache.avro.generic.GenericData

Called to obtain the schema of a record.

getRecordSchema(Object) - Method in class org.apache.avro.reflect.ReflectData

getRecordSchema(Object) - Method in class org.apache.avro.specific.SpecificData

getRemote() - Method in class org.apache.avro.ipc.Requestor

getRemoteName() - Method in class org.apache.avro.ipc.DatagramTransceiver

getRemoteName() - Method in class org.apache.avro.ipc.HttpTransceiver

getRemoteName() - Method in class org.apache.avro.ipc.SocketTransceiver

getRemoteName() - Method in class org.apache.avro.ipc.Transceiver

getRequest() - Method in class org.apache.avro.Protocol.Message

The parameters of this message.

getResponse() - Method in class org.apache.avro.Protocol.Message

The returned data.

getSchema() - Method in interface org.apache.avro.generic.GenericContainer

The schema of this instance.

getSchema() - Method in class org.apache.avro.generic.GenericData.Array

getSchema() - Method in class org.apache.avro.generic.GenericData.Record

getSchema(Type) - Method in class org.apache.avro.reflect.ReflectData

Generate a schema for a Java type.

getSchema() - Method in exception org.apache.avro.specific.SpecificExceptionBase

getSchema() - Method in class org.apache.avro.specific.SpecificRecordBase

getSymbol(int) - Method in class org.apache.avro.io.parsing.Symbol.Alternative

getTransceiver() - Method in class org.apache.avro.ipc.Requestor

getType(String) - Method in class org.apache.avro.Protocol

Returns the named type.

getType() - Method in class org.apache.avro.Schema

Return the type of this schema.

getTypes() - Method in class org.apache.avro.Protocol

The types of this protocol.

getTypes() - Method in class org.apache.avro.Schema

If this is a union, returns its types.

getValue() - Method in exception org.apache.avro.ipc.AvroRemoteException

getValueType() - Method in class org.apache.avro.Schema

If this is a map, returns its value type.

H

hashCode() - Method in class org.apache.avro.generic.GenericData.Array

hashCode() - Method in class org.apache.avro.generic.GenericData.Fixed

hashCode() - Method in class org.apache.avro.Protocol

hashCode() - Method in class org.apache.avro.Protocol.Message

hashCode() - Method in class org.apache.avro.Schema.Field

hashCode() - Method in class org.apache.avro.Schema

hashCode() - Method in exception org.apache.avro.specific.SpecificExceptionBase

hashCode() - Method in class org.apache.avro.specific.SpecificRecordBase

hashCode() - Method in class org.apache.avro.util.Utf8

HttpServer - Class in org.apache.avro.ipc

An HTTP-based RPC Server.

HttpServer(Responder, int) - Constructor for class org.apache.avro.ipc.HttpServer

Starts a server on the named port.

HttpServer(ResponderServlet, int) - Constructor for class org.apache.avro.ipc.HttpServer

Starts a server on the named port.

HttpTransceiver - Class in org.apache.avro.ipc

An HTTP-based Transceiver implementation.

HttpTransceiver(URL) - Constructor for class org.apache.avro.ipc.HttpTransceiver

I

in - Variable in class org.apache.avro.io.ValidatingDecoder

induce(Object) - Method in class org.apache.avro.generic.GenericData

Create a schema given an example datum.

init(InputStream) - Method in class org.apache.avro.io.BinaryDecoder

init(OutputStream) - Method in class org.apache.avro.io.BinaryEncoder

init(OutputStream) - Method in class org.apache.avro.io.BlockingBinaryEncoder

Redirect output (and reset the parser state if we're checking).

init(InputStream) - Method in class org.apache.avro.io.Decoder

Start reading against a different input stream.

init(OutputStream) - Method in class org.apache.avro.io.Encoder

Redirect output (and reset the parser state if we're checking).

init(InputStream) - Method in class org.apache.avro.io.JsonDecoder

init(OutputStream) - Method in class org.apache.avro.io.JsonEncoder

init(InputStream) - Method in class org.apache.avro.io.ValidatingDecoder

init(OutputStream) - Method in class org.apache.avro.io.ValidatingEncoder

instanceOf(Schema, Object) - Method in class org.apache.avro.generic.GenericData

Called by GenericData.resolveUnion(Schema,Object).

INT - Static variable in class org.apache.avro.io.parsing.Symbol

invoke(Object, Method, Object[]) - Method in class org.apache.avro.reflect.ReflectRequestor

isArray(Object) - Method in class org.apache.avro.generic.GenericData

Called by the default implementation of GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).

isBytes(Object) - Method in class org.apache.avro.generic.GenericData

Called by the default implementation of GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).

isEmpty - Variable in class org.apache.avro.io.JsonEncoder

Has anything been written into the collections?

isEmpty - Variable in class org.apache.avro.io.ValidatingEncoder

Has anything been written into the collections?

isEnum(Object) - Method in class org.apache.avro.generic.GenericData

Called by the default implementation of GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).

isEnum(Object) - Method in class org.apache.avro.reflect.ReflectData

isEnum(Object) - Method in class org.apache.avro.reflect.ReflectDatumWriter

isError() - Method in class org.apache.avro.ipc.RPCContext

Indicates whether an exception was generated at the server

isError() - Method in class org.apache.avro.Schema

Returns true if this record is an error type.

isFixed(Object) - Method in class org.apache.avro.generic.GenericData

Called by the default implementation of GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).

isMap(Object) - Method in class org.apache.avro.generic.GenericData

Called by the default implementation of GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).

isRecord(Object) - Method in class org.apache.avro.generic.GenericData

Called by the default implementation of GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).

isRecord(Object) - Method in class org.apache.avro.reflect.ReflectData

isRecord(Object) - Method in class org.apache.avro.specific.SpecificData

isString(Object) - Method in class org.apache.avro.generic.GenericData

Called by the default implementation of GenericData.instanceOf(org.apache.avro.Schema, java.lang.Object).

isTopEmpty() - Method in class org.apache.avro.io.ValidatingEncoder

Have we written at least one item into the current collection?

ITEM_END - Static variable in class org.apache.avro.io.parsing.Symbol

iterator() - Method in class org.apache.avro.generic.GenericData.Array

iterator() - Method in class org.apache.avro.io.parsing.Symbol.Sequence

J

JsonDecoder - Class in org.apache.avro.io

A Decoder for Avro's JSON data encoding.

JsonDecoder(Schema, InputStream) - Constructor for class org.apache.avro.io.JsonDecoder

JsonEncoder - Class in org.apache.avro.io

An Encoder for Avro's JSON data encoding.

JsonEncoder(Schema, OutputStream) - Constructor for class org.apache.avro.io.JsonEncoder

JsonEncoder(Schema, JsonGenerator) - Constructor for class org.apache.avro.io.JsonEncoder

JsonGrammarGenerator - Class in org.apache.avro.io.parsing

The class that generates a grammar suitable to parse Avro data in JSON format.

JsonGrammarGenerator() - Constructor for class org.apache.avro.io.parsing.JsonGrammarGenerator

K

kind - Variable in class org.apache.avro.io.parsing.Symbol

L

labels - Variable in class org.apache.avro.io.parsing.Symbol.Alternative

length() - Method in class org.apache.avro.file.SeekableFileInput

length() - Method in interface org.apache.avro.file.SeekableInput

Return the length of the file.

LONG - Static variable in class org.apache.avro.io.parsing.Symbol

M

main(String[]) - Static method in class org.apache.avro.ipc.DatagramServer

main(String[]) - Static method in class org.apache.avro.ipc.SocketServer

main(String[]) - Static method in class org.apache.avro.Protocol

main(String[]) - Static method in class org.apache.avro.specific.SpecificCompiler

MAP_END - Static variable in class org.apache.avro.io.parsing.Symbol

MAP_KEY_MARKER - Static variable in class org.apache.avro.io.parsing.Symbol

MAP_START - Static variable in class org.apache.avro.io.parsing.Symbol

mapNext() - Method in class org.apache.avro.io.BinaryDecoder

mapNext() - Method in class org.apache.avro.io.Decoder

Processes the next block of map entries and returns the count of them.

mapNext() - Method in class org.apache.avro.io.JsonDecoder

mapNext() - Method in class org.apache.avro.io.ValidatingDecoder

msg - Variable in class org.apache.avro.io.parsing.Symbol.ErrorAction

N

newArray(Object, int, Schema) - Method in class org.apache.avro.generic.GenericDatumReader

Called to create new array instances.

newInstance(Class) - Static method in class org.apache.avro.reflect.ReflectDatumReader

Create a new instance of the named class.

newMap(Object, int) - Method in class org.apache.avro.generic.GenericDatumReader

Called to create new array instances.

newRecord(Object, Schema) - Method in class org.apache.avro.generic.GenericDatumReader

Called to create new record instances.

newRecord(Object, Schema) - Method in class org.apache.avro.reflect.ReflectDatumReader

next(D) - Method in class org.apache.avro.file.DataFileReader

Return the next datum in the file.

NULL - Static variable in class org.apache.avro.io.parsing.Symbol

The terminal symbols for the grammar.

O

order() - Method in class org.apache.avro.Schema.Field

org.apache.avro - package org.apache.avro

Avro kernel classes.

org.apache.avro.file - package org.apache.avro.file

A container file for Avro data.

org.apache.avro.generic - package org.apache.avro.generic

A generic representation for Avro data.

org.apache.avro.io - package org.apache.avro.io

Input/output utilities.

org.apache.avro.io.parsing - package org.apache.avro.io.parsing

Implementation of Avro schemas as LL(1) grammars.

org.apache.avro.ipc - package org.apache.avro.ipc

Support for inter-process calls.

org.apache.avro.reflect - package org.apache.avro.reflect

Use Java reflection to generate schemas and protocols for existing classes.

org.apache.avro.specific - package org.apache.avro.specific

Generate specific Java classes for schemas and protocols.

org.apache.avro.util - package org.apache.avro.util

Common utility classes.

out - Variable in class org.apache.avro.io.BinaryEncoder

out - Variable in class org.apache.avro.io.ValidatingEncoder

P

parse(File) - Static method in class org.apache.avro.Protocol

Read a protocol from a Json file.

parse(String) - Static method in class org.apache.avro.Protocol

Read a protocol from a Json string.

parse(File) - Static method in class org.apache.avro.Schema

parse(String) - Static method in class org.apache.avro.Schema

Construct a schema from JSON text.

Parser - Class in org.apache.avro.io.parsing

Parser is the class that maintains the stack for parsing.

Parser(Symbol, Parser.ActionHandler) - Constructor for class org.apache.avro.io.parsing.Parser

parser - Variable in class org.apache.avro.io.ParsingDecoder

parser - Variable in class org.apache.avro.io.ValidatingEncoder

Parser.ActionHandler - Interface in org.apache.avro.io.parsing

The parser knows how to handle the terminal and non-terminal symbols.

ParsingDecoder - Class in org.apache.avro.io

Base class for parser-based Decoders.

ParsingDecoder(Symbol) - Constructor for class org.apache.avro.io.ParsingDecoder

ParsingEncoder - Class in org.apache.avro.io

Base class for parser-based Encoders.

ParsingEncoder() - Constructor for class org.apache.avro.io.ParsingEncoder

peek() - Method in interface org.apache.avro.generic.GenericArray

The current content of the location where GenericArray.add(Object) would next store an element, if any.

peek() - Method in class org.apache.avro.generic.GenericData.Array

peekArray(Object) - Method in class org.apache.avro.generic.GenericDatumReader

Called by the default implementation of GenericDatumReader.readArray(java.lang.Object, org.apache.avro.Schema, org.apache.avro.Schema, org.apache.avro.io.Decoder) to retrieve a value from a reused instance.

pop() - Method in class org.apache.avro.io.ParsingEncoder

popSymbol() - Method in class org.apache.avro.io.parsing.Parser

Pops and returns the top symbol from the stack.

pos - Variable in class org.apache.avro.io.parsing.Parser

pos - Variable in class org.apache.avro.io.ParsingEncoder

pos() - Method in class org.apache.avro.Schema.Field

The position of this field within the record.

processImplicitActions() - Method in class org.apache.avro.io.parsing.Parser

Performs any implicit actions at the top the stack, expanding any production (other than the root) that may be encountered.

production - Variable in class org.apache.avro.io.parsing.Symbol

The production for this symbol.

Protocol - Class in org.apache.avro

A set of messages forming an application protocol.

Protocol(String, String) - Constructor for class org.apache.avro.Protocol

Protocol.Message - Class in org.apache.avro

A protocol message.

ProtocolTask - Class in org.apache.avro.specific

Ant task to generate Java interface and classes for a protocol.

ProtocolTask() - Constructor for class org.apache.avro.specific.ProtocolTask

push() - Method in class org.apache.avro.io.ParsingEncoder

Push a new collection on to the stack.

pushProduction(Symbol, Symbol) - Method in class org.apache.avro.io.parsing.Parser

Pushes the production for the given symbol sym.

pushSymbol(Symbol) - Method in class org.apache.avro.io.parsing.Parser

Pushes sym on to the stack.

R

read(byte[], int, int) - Method in interface org.apache.avro.file.SeekableInput

Equivalent to InputStream.read(byte[],int,int).

read(D, Decoder) - Method in class org.apache.avro.generic.GenericDatumReader

read(Object, Schema, Schema, Decoder) - Method in class org.apache.avro.generic.GenericDatumReader

Called to read data.

read(D, Decoder) - Method in interface org.apache.avro.io.DatumReader

Read a datum.

read() - Method in class org.apache.avro.ipc.ByteBufferInputStream

read(byte[], int, int) - Method in class org.apache.avro.ipc.ByteBufferInputStream

readArray(Object, Schema, Schema, Decoder) - Method in class org.apache.avro.generic.GenericDatumReader

Called to read an array instance.

readArrayStart() - Method in class org.apache.avro.io.BinaryDecoder

readArrayStart() - Method in class org.apache.avro.io.Decoder

Reads and returns the size of the first block of an array.

readArrayStart() - Method in class org.apache.avro.io.JsonDecoder

readArrayStart() - Method in class org.apache.avro.io.ValidatingDecoder

readBoolean() - Method in class org.apache.avro.io.BinaryDecoder

readBoolean() - Method in class org.apache.avro.io.Decoder

Reads a boolean value written by Encoder.writeBoolean(boolean).

readBoolean() - Method in class org.apache.avro.io.JsonDecoder

readBoolean() - Method in class org.apache.avro.io.ValidatingDecoder

readBuffer(int) - Method in class org.apache.avro.ipc.ByteBufferInputStream

Read a buffer from the input without copying, if possible.

readBuffers() - Method in class org.apache.avro.ipc.DatagramTransceiver

readBuffers() - Method in class org.apache.avro.ipc.HttpTransceiver

readBuffers() - Method in class org.apache.avro.ipc.SocketTransceiver

readBuffers() - Method in class org.apache.avro.ipc.Transceiver

readBytes(Object, Decoder) - Method in class org.apache.avro.generic.GenericDatumReader

Called to read byte arrays.

readBytes(ByteBuffer) - Method in class org.apache.avro.io.BinaryDecoder

readBytes(ByteBuffer) - Method in class org.apache.avro.io.Decoder

Reads a byte-string written by Encoder.writeBytes(java.nio.ByteBuffer).

readBytes(ByteBuffer) - Method in class org.apache.avro.io.JsonDecoder

readBytes(ByteBuffer) - Method in class org.apache.avro.io.ValidatingDecoder

readDouble() - Method in class org.apache.avro.io.BinaryDecoder

readDouble() - Method in class org.apache.avro.io.Decoder

Reads a double written by Encoder.writeDouble(double).

readDouble() - Method in class org.apache.avro.io.JsonDecoder

readDouble() - Method in class org.apache.avro.io.ResolvingDecoder

readDouble() - Method in class org.apache.avro.io.ValidatingDecoder

readEnum(Schema, Schema, Decoder) - Method in class org.apache.avro.generic.GenericDatumReader

Called to read an enum value.

readEnum() - Method in class org.apache.avro.io.BinaryDecoder

readEnum() - Method in class org.apache.avro.io.Decoder

Reads an enumeration.

readEnum() - Method in class org.apache.avro.io.JsonDecoder

readEnum() - Method in class org.apache.avro.io.ResolvingDecoder

readEnum() - Method in class org.apache.avro.io.ValidatingDecoder

reader - Variable in class org.apache.avro.io.parsing.Symbol.ResolvingAction

readError(Schema, Decoder) - Method in class org.apache.avro.generic.GenericRequestor

readError(Schema, Decoder) - Method in class org.apache.avro.ipc.Requestor

Reads an error message.

readError(Schema, Decoder) - Method in class org.apache.avro.reflect.ReflectRequestor

readFieldIndex() - Method in class org.apache.avro.io.ResolvingDecoder

Returns the (zero-based) index of the next field of the record we're reading.

readFieldName() - Method in class org.apache.avro.io.ResolvingDecoder

Returns the name of the next field of the record we're reading.

readFixed(Object, Schema, Schema, Decoder) - Method in class org.apache.avro.generic.GenericDatumReader

Called to read a fixed value.

readFixed(byte[], int, int) - Method in class org.apache.avro.io.BinaryDecoder

readFixed(byte[], int, int) - Method in class org.apache.avro.io.Decoder

Reads fixed sized binary object.

readFixed(byte[]) - Method in class org.apache.avro.io.Decoder

A shorthand for readFixed(bytes, 0, bytes.length).

readFixed(byte[], int, int) - Method in class org.apache.avro.io.JsonDecoder

readFixed(byte[], int, int) - Method in class org.apache.avro.io.ValidatingDecoder

readFloat() - Method in class org.apache.avro.io.BinaryDecoder

readFloat() - Method in class org.apache.avro.io.Decoder

Reads a float written by Encoder.writeFloat(float).

readFloat() - Method in class org.apache.avro.io.JsonDecoder

readFloat() - Method in class org.apache.avro.io.ValidatingDecoder

readIndex() - Method in class org.apache.avro.io.BinaryDecoder

readIndex() - Method in class org.apache.avro.io.Decoder

Reads the tag of a union written by Encoder.writeIndex(int).

readIndex() - Method in class org.apache.avro.io.JsonDecoder

readIndex() - Method in class org.apache.avro.io.ResolvingDecoder

readIndex() - Method in class org.apache.avro.io.ValidatingDecoder

readInt() - Method in class org.apache.avro.io.BinaryDecoder

readInt() - Method in class org.apache.avro.io.Decoder

Reads an integer written by Encoder.writeInt(int).

readInt() - Method in class org.apache.avro.io.JsonDecoder

readInt() - Method in class org.apache.avro.io.ValidatingDecoder

readLong() - Method in class org.apache.avro.io.BinaryDecoder

readLong() - Method in class org.apache.avro.io.Decoder

Reads a long written by Encoder.writeLong(long).

readLong() - Method in class org.apache.avro.io.JsonDecoder

readLong() - Method in class org.apache.avro.io.ResolvingDecoder

readLong() - Method in class org.apache.avro.io.ValidatingDecoder

readMap(Object, Schema, Schema, Decoder) - Method in class org.apache.avro.generic.GenericDatumReader

Called to read a map instance.

readMapStart() - Method in class org.apache.avro.io.BinaryDecoder

readMapStart() - Method in class org.apache.avro.io.Decoder

Reads and returns the size of the next block of map-entries.

readMapStart() - Method in class org.apache.avro.io.JsonDecoder

readMapStart() - Method in class org.apache.avro.io.ValidatingDecoder

readNull() - Method in class org.apache.avro.io.BinaryDecoder

readNull() - Method in class org.apache.avro.io.Decoder

"Reads" a null value.

readNull() - Method in class org.apache.avro.io.JsonDecoder

readNull() - Method in class org.apache.avro.io.ValidatingDecoder

readRecord(Object, Schema, Schema, Decoder) - Method in class org.apache.avro.generic.GenericDatumReader

Called to read a record instance.

readRequest(Schema, Decoder) - Method in class org.apache.avro.generic.GenericResponder

Reads a request message.

readRequest(Schema, Decoder) - Method in class org.apache.avro.ipc.Responder

Reads a request message.

readRequest(Schema, Decoder) - Method in class org.apache.avro.reflect.ReflectResponder

Reads a request message.

readResponse(Schema, Decoder) - Method in class org.apache.avro.generic.GenericRequestor

readResponse(Schema, Decoder) - Method in class org.apache.avro.ipc.Requestor

Reads a response message.

readResponse(Schema, Decoder) - Method in class org.apache.avro.reflect.ReflectRequestor

readString(Object, Decoder) - Method in class org.apache.avro.generic.GenericDatumReader

Called to read strings.

readString(Utf8) - Method in class org.apache.avro.io.BinaryDecoder

readString(Utf8) - Method in class org.apache.avro.io.Decoder

Reads a char-string written by Encoder.writeString(org.apache.avro.util.Utf8).

readString(Utf8) - Method in class org.apache.avro.io.JsonDecoder

readString(Utf8) - Method in class org.apache.avro.io.ValidatingDecoder

RECORD_END - Static variable in class org.apache.avro.io.parsing.Symbol

RECORD_START - Static variable in class org.apache.avro.io.parsing.Symbol

ReflectData - Class in org.apache.avro.reflect

Utilities to use existing Java classes and interfaces via reflection.

ReflectData() - Constructor for class org.apache.avro.reflect.ReflectData

ReflectData.AllowNull - Class in org.apache.avro.reflect

ReflectData implementation that permits null field values.

ReflectData.AllowNull() - Constructor for class org.apache.avro.reflect.ReflectData.AllowNull

ReflectDatumReader - Class in org.apache.avro.reflect

DatumReader for existing classes via Java reflection.

ReflectDatumReader() - Constructor for class org.apache.avro.reflect.ReflectDatumReader

ReflectDatumReader(Class) - Constructor for class org.apache.avro.reflect.ReflectDatumReader

ReflectDatumReader(Schema) - Constructor for class org.apache.avro.reflect.ReflectDatumReader

ReflectDatumWriter - Class in org.apache.avro.reflect

DatumWriter for existing classes via Java reflection.

ReflectDatumWriter() - Constructor for class org.apache.avro.reflect.ReflectDatumWriter

ReflectDatumWriter(Class) - Constructor for class org.apache.avro.reflect.ReflectDatumWriter

ReflectDatumWriter(Class, ReflectData) - Constructor for class org.apache.avro.reflect.ReflectDatumWriter

ReflectDatumWriter(Schema) - Constructor for class org.apache.avro.reflect.ReflectDatumWriter

ReflectDatumWriter(Schema, ReflectData) - Constructor for class org.apache.avro.reflect.ReflectDatumWriter

ReflectDatumWriter(ReflectData) - Constructor for class org.apache.avro.reflect.ReflectDatumWriter

ReflectRequestor - Class in org.apache.avro.reflect

A Requestor for existing interfaces via Java reflection.

ReflectRequestor(Class<?>, Transceiver) - Constructor for class org.apache.avro.reflect.ReflectRequestor

ReflectRequestor(Protocol, Transceiver) - Constructor for class org.apache.avro.reflect.ReflectRequestor

ReflectRequestor(Class<?>, Transceiver, ReflectData) - Constructor for class org.apache.avro.reflect.ReflectRequestor

ReflectRequestor(Protocol, Transceiver, ReflectData) - Constructor for class org.apache.avro.reflect.ReflectRequestor

ReflectResponder - Class in org.apache.avro.reflect

Responder for existing interfaces via Java reflection.

ReflectResponder(Class, Object) - Constructor for class org.apache.avro.reflect.ReflectResponder

ReflectResponder(Class, Object, ReflectData) - Constructor for class org.apache.avro.reflect.ReflectResponder

removeField(Object, String, int) - Method in class org.apache.avro.generic.GenericDatumReader

Called by the default implementation of GenericDatumReader.readRecord(java.lang.Object, org.apache.avro.Schema, org.apache.avro.Schema, org.apache.avro.io.Decoder) to remove a record field value from a reused instance.

removeField(Object, String, int) - Method in class org.apache.avro.reflect.ReflectDatumReader

removeField(Object, String, int) - Method in class org.apache.avro.specific.SpecificDatumReader

request(String, Object) - Method in class org.apache.avro.ipc.Requestor

Writes a request message and reads a response or error message.

requestCallMeta - Variable in class org.apache.avro.ipc.RPCContext

requestCallMeta() - Method in class org.apache.avro.ipc.RPCContext

This is an access method for the per-call state provided by the client to the server.

requestHandshakeMeta - Variable in class org.apache.avro.ipc.RPCContext

requestHandshakeMeta() - Method in class org.apache.avro.ipc.RPCContext

This is an access method for the handshake state provided by the client to the server.

Requestor - Class in org.apache.avro.ipc

Base class for the client side of a protocol interaction.

Requestor(Protocol, Transceiver) - Constructor for class org.apache.avro.ipc.Requestor

reset() - Method in class org.apache.avro.io.parsing.Parser

reset() - Method in class org.apache.avro.ipc.ByteBufferOutputStream

resolveUnion(Schema, Object) - Method in class org.apache.avro.generic.GenericData

Return the index for a datum within a union.

ResolvingDecoder - Class in org.apache.avro.io

Decoder that peforms type-resolution between the reader's and writer's schemas.

ResolvingDecoder(Schema, Schema, Decoder) - Constructor for class org.apache.avro.io.ResolvingDecoder

ResolvingGrammarGenerator - Class in org.apache.avro.io.parsing

The class that generates a resolving grammar to resolve between two schemas.

ResolvingGrammarGenerator() - Constructor for class org.apache.avro.io.parsing.ResolvingGrammarGenerator

respond(List<ByteBuffer>) - Method in class org.apache.avro.ipc.Responder

Called by a server to deserialize a request, compute and serialize a response or error.

respond(Protocol.Message, Object) - Method in class org.apache.avro.ipc.Responder

Computes the response for a message.

respond(Protocol.Message, Object) - Method in class org.apache.avro.reflect.ReflectResponder

Responder - Class in org.apache.avro.ipc

Base class for the server side of a protocol interaction.

Responder(Protocol) - Constructor for class org.apache.avro.ipc.Responder

ResponderServlet - Class in org.apache.avro.ipc

An HttpServlet that responds to Avro RPC requests.

ResponderServlet(Responder) - Constructor for class org.apache.avro.ipc.ResponderServlet

response - Variable in class org.apache.avro.ipc.RPCContext

response() - Method in class org.apache.avro.ipc.RPCContext

The response object generated at the server, if it exists.

responseCallMeta - Variable in class org.apache.avro.ipc.RPCContext

responseCallMeta() - Method in class org.apache.avro.ipc.RPCContext

This is an access method for the per-call state provided by the server back to the client.

responseHandshakeMeta - Variable in class org.apache.avro.ipc.RPCContext

responseHandshakeMeta() - Method in class org.apache.avro.ipc.RPCContext

This is an access method for the handshake state provided by the server back to the client

rindex - Variable in class org.apache.avro.io.parsing.Symbol.FieldAdjustAction

rindex - Variable in class org.apache.avro.io.parsing.Symbol.UnionAdjustAction

root - Variable in class org.apache.avro.io.parsing.Symbol.DefaultStartAction

RPCContext - Class in org.apache.avro.ipc

This class represents the context of an RPC call or RPC handshake.

RPCContext() - Constructor for class org.apache.avro.ipc.RPCContext

rpcMetaPlugins - Variable in class org.apache.avro.ipc.Requestor

rpcMetaPlugins - Variable in class org.apache.avro.ipc.Responder

RPCPlugin - Class in org.apache.avro.ipc

An instrumentation API for RPC metadata.

RPCPlugin() - Constructor for class org.apache.avro.ipc.RPCPlugin

run() - Method in class org.apache.avro.ipc.DatagramServer

run() - Method in class org.apache.avro.ipc.SocketServer

S

Schema - Class in org.apache.avro

An abstract data type.

schema() - Method in class org.apache.avro.Schema.Field

This field's Schema.

Schema.Field - Class in org.apache.avro

A field within a record.

Schema.Field(Schema, JsonNode) - Constructor for class org.apache.avro.Schema.Field

Schema.Field(Schema, JsonNode, Schema.Field.Order) - Constructor for class org.apache.avro.Schema.Field

Schema.Field.Order - Enum in org.apache.avro

How values of this field should be ordered when sorting records.

Schema.Type - Enum in org.apache.avro

The type of a schema.

SchemaParseException - Exception in org.apache.avro

Thrown for errors parsing schemas and protocols.

SchemaParseException(Throwable) - Constructor for exception org.apache.avro.SchemaParseException

SchemaParseException(String) - Constructor for exception org.apache.avro.SchemaParseException

SchemaTask - Class in org.apache.avro.specific

Ant task to generate Java interface and classes for a protocol.

SchemaTask() - Constructor for class org.apache.avro.specific.SchemaTask

seek(long) - Method in class org.apache.avro.file.DataFileReader

Move to the specified synchronization point, as returned by DataFileWriter.sync().

seek(long) - Method in class org.apache.avro.file.SeekableFileInput

seek(long) - Method in interface org.apache.avro.file.SeekableInput

Set the position for the next read().

SeekableFileInput - Class in org.apache.avro.file

A FileInputStream that implements SeekableInput.

SeekableFileInput(File) - Constructor for class org.apache.avro.file.SeekableFileInput

SeekableInput - Interface in org.apache.avro.file

An InputStream that supports seek and tell.

Server - Interface in org.apache.avro.ipc

A server listening on a port.

serverConnecting(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin

Called on the server during the RPC handshake

serverReceiveRequest(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin

This method is invoked at the RPC server when the request is received, but before the call itself is executed

serverSendResponse(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin

This method is invoked at the server after the call is executed, but before the response is returned to the client

set(int, Object) - Method in exception org.apache.avro.specific.SpecificExceptionBase

set(int, Object) - Method in interface org.apache.avro.specific.SpecificRecord

set(int, Object) - Method in class org.apache.avro.specific.SpecificRecordBase

setDestdir(File) - Method in class org.apache.avro.specific.ProtocolTask

Set the output directory

setExpected(Schema) - Method in class org.apache.avro.generic.GenericDatumReader

setFields(LinkedHashMap<String, Schema.Field>) - Method in class org.apache.avro.Schema

If this is a record, set its fields.

setFile(File) - Method in class org.apache.avro.specific.ProtocolTask

Set the schema file.

setItemCount(long) - Method in class org.apache.avro.io.BinaryEncoder

setItemCount(long) - Method in class org.apache.avro.io.BlockingBinaryEncoder

setItemCount(long) - Method in class org.apache.avro.io.Encoder

Call this method before writing a batch of items in an array or a map.

setItemCount(long) - Method in class org.apache.avro.io.JsonDecoder

setItemCount(long) - Method in class org.apache.avro.io.ParsingEncoder

setItemCount(long) - Method in class org.apache.avro.io.ValidatingEncoder

setLength(int) - Method in class org.apache.avro.util.Utf8

setMeta(String, byte[]) - Method in class org.apache.avro.file.DataFileWriter

Set a metadata property.

setMeta(String, String) - Method in class org.apache.avro.file.DataFileWriter

Set a metadata property.

setMeta(String, long) - Method in class org.apache.avro.file.DataFileWriter

Set a metadata property.

setSchema(Schema) - Method in class org.apache.avro.generic.GenericDatumReader

setSchema(Schema) - Method in class org.apache.avro.generic.GenericDatumWriter

setSchema(Schema) - Method in interface org.apache.avro.io.DatumReader

Set the schema.

setSchema(Schema) - Method in interface org.apache.avro.io.DatumWriter

Set the schema.

setTypes(Collection<Schema>) - Method in class org.apache.avro.Protocol

Set the types of this protocol.

size() - Method in interface org.apache.avro.generic.GenericArray

The number of elements contained in this array.

size() - Method in class org.apache.avro.generic.GenericData.Array

size() - Method in class org.apache.avro.io.parsing.Symbol.Alternative

size - Variable in class org.apache.avro.io.parsing.Symbol.IntCheckAction

size() - Method in class org.apache.avro.io.parsing.Symbol.Sequence

skip(Schema, Decoder) - Static method in class org.apache.avro.generic.GenericDatumReader

Skip an instance of a schema.

skipAction() - Method in interface org.apache.avro.io.parsing.SkipParser.SkipHandler

Skips the action at the top of the stack.

skipAction() - Method in class org.apache.avro.io.ParsingDecoder

skipAction() - Method in class org.apache.avro.io.ResolvingDecoder

skipArray() - Method in class org.apache.avro.io.BinaryDecoder

skipArray() - Method in class org.apache.avro.io.Decoder

Used for quickly skipping through an array.

skipArray() - Method in class org.apache.avro.io.JsonDecoder

skipArray() - Method in class org.apache.avro.io.ValidatingDecoder

skipBytes() - Method in class org.apache.avro.io.BinaryDecoder

skipBytes() - Method in class org.apache.avro.io.Decoder

Discards a byte-string written by Encoder.writeBytes(java.nio.ByteBuffer).

skipBytes() - Method in class org.apache.avro.io.JsonDecoder

skipBytes() - Method in class org.apache.avro.io.ValidatingDecoder

skipFixed(int) - Method in class org.apache.avro.io.BinaryDecoder

skipFixed(int) - Method in class org.apache.avro.io.Decoder

Discards fixed sized binary object.

skipFixed(int) - Method in class org.apache.avro.io.JsonDecoder

skipFixed() - Method in class org.apache.avro.io.JsonDecoder

skipFixed() - Method in class org.apache.avro.io.ParsingDecoder

skipFixed(int) - Method in class org.apache.avro.io.ValidatingDecoder

skipFixed() - Method in class org.apache.avro.io.ValidatingDecoder

skipMap() - Method in class org.apache.avro.io.BinaryDecoder

skipMap() - Method in class org.apache.avro.io.Decoder

Support for quickly skipping through a map similar to Decoder.skipArray().

skipMap() - Method in class org.apache.avro.io.JsonDecoder

skipMap() - Method in class org.apache.avro.io.ValidatingDecoder

SkipParser - Class in org.apache.avro.io.parsing

A parser that capable of skipping as well read and write.

SkipParser(Symbol, Parser.ActionHandler, SkipParser.SkipHandler) - Constructor for class org.apache.avro.io.parsing.SkipParser

SkipParser.SkipHandler - Interface in org.apache.avro.io.parsing

The clients implement this interface to skip symbols and actions.

skipRepeater() - Method in class org.apache.avro.io.parsing.SkipParser

Skips the repeater at the top the stack.

skipString() - Method in class org.apache.avro.io.BinaryDecoder

skipString() - Method in class org.apache.avro.io.Decoder

Discards a char-string written by Encoder.writeString(org.apache.avro.util.Utf8).

skipString() - Method in class org.apache.avro.io.JsonDecoder

skipString() - Method in class org.apache.avro.io.ValidatingDecoder

skipSymbol(Symbol) - Method in class org.apache.avro.io.parsing.SkipParser

Pushes the given symbol on to the skip and skips it.

skipTo(int) - Method in class org.apache.avro.io.parsing.SkipParser

Skips data by calling skipXyz or readXyz methods on this, until the parser stack reaches the target level.

skipTopSymbol() - Method in interface org.apache.avro.io.parsing.SkipParser.SkipHandler

Skips the symbol at the top of the stack.

skipTopSymbol() - Method in class org.apache.avro.io.ParsingDecoder

SocketServer - Class in org.apache.avro.ipc

A simple socket-based server implementation.

SocketServer(Responder, SocketAddress) - Constructor for class org.apache.avro.ipc.SocketServer

SocketTransceiver - Class in org.apache.avro.ipc

A simple socket-based Transceiver implementation.

SocketTransceiver(SocketAddress) - Constructor for class org.apache.avro.ipc.SocketTransceiver

SocketTransceiver(SocketChannel) - Constructor for class org.apache.avro.ipc.SocketTransceiver

SpecificCompiler - Class in org.apache.avro.specific

Generate specific Java interfaces and classes for protocols and schemas.

SpecificData - Class in org.apache.avro.specific

Utilities for generated Java classes and interfaces.

SpecificData() - Constructor for class org.apache.avro.specific.SpecificData

SpecificDatumReader - Class in org.apache.avro.specific

DatumReader for generated Java classes.

SpecificDatumReader() - Constructor for class org.apache.avro.specific.SpecificDatumReader

SpecificDatumReader(Class) - Constructor for class org.apache.avro.specific.SpecificDatumReader

SpecificDatumReader(Schema) - Constructor for class org.apache.avro.specific.SpecificDatumReader

SpecificDatumWriter - Class in org.apache.avro.specific

DatumWriter for generated Java classes.

SpecificDatumWriter() - Constructor for class org.apache.avro.specific.SpecificDatumWriter

SpecificDatumWriter(Class) - Constructor for class org.apache.avro.specific.SpecificDatumWriter

SpecificDatumWriter(Schema) - Constructor for class org.apache.avro.specific.SpecificDatumWriter

SpecificExceptionBase - Exception in org.apache.avro.specific

Base class for specific exceptions.

SpecificExceptionBase() - Constructor for exception org.apache.avro.specific.SpecificExceptionBase

SpecificFixed - Class in org.apache.avro.specific

Base class for generated fixed-sized data classes.

SpecificFixed() - Constructor for class org.apache.avro.specific.SpecificFixed

SpecificRecord - Interface in org.apache.avro.specific

Implemented by generated record classes.

SpecificRecordBase - Class in org.apache.avro.specific

Base class for generated record classes.

SpecificRecordBase() - Constructor for class org.apache.avro.specific.SpecificRecordBase

SpecificRequestor - Class in org.apache.avro.specific

Requestor for generated interfaces.

SpecificRequestor(Class<?>, Transceiver) - Constructor for class org.apache.avro.specific.SpecificRequestor

SpecificRequestor(Class<?>, Transceiver, SpecificData) - Constructor for class org.apache.avro.specific.SpecificRequestor

SpecificResponder - Class in org.apache.avro.specific

Responder for generated interfaces.

SpecificResponder(Class, Object) - Constructor for class org.apache.avro.specific.SpecificResponder

stack - Variable in class org.apache.avro.io.parsing.Parser

startItem() - Method in class org.apache.avro.io.BinaryEncoder

startItem() - Method in class org.apache.avro.io.BlockingBinaryEncoder

startItem() - Method in class org.apache.avro.io.Encoder

Start a new item of an array or map.

startItem() - Method in class org.apache.avro.io.JsonEncoder

startItem() - Method in class org.apache.avro.io.ParsingEncoder

startItem() - Method in class org.apache.avro.io.ValidatingEncoder

STRING - Static variable in class org.apache.avro.io.parsing.Symbol

Symbol - Class in org.apache.avro.io.parsing

Symbol is the base of all symbols (terminals and non-terminals) of the grammar.

Symbol(Symbol.Kind) - Constructor for class org.apache.avro.io.parsing.Symbol

Constructs a new symbol of the given kind kind.

Symbol(Symbol.Kind, Symbol[]) - Constructor for class org.apache.avro.io.parsing.Symbol

Symbol.Alternative - Class in org.apache.avro.io.parsing

Symbol.DefaultStartAction - Class in org.apache.avro.io.parsing

Symbol.DefaultStartAction(Symbol, JsonNode) - Constructor for class org.apache.avro.io.parsing.Symbol.DefaultStartAction

Symbol.EnumAdjustAction - Class in org.apache.avro.io.parsing

Symbol.EnumAdjustAction(int, Object[]) - Constructor for class org.apache.avro.io.parsing.Symbol.EnumAdjustAction

Symbol.EnumLabelsAction - Class in org.apache.avro.io.parsing

For JSON.

Symbol.EnumLabelsAction(List<String>) - Constructor for class org.apache.avro.io.parsing.Symbol.EnumLabelsAction

Symbol.ErrorAction - Class in org.apache.avro.io.parsing

Symbol.FieldAdjustAction - Class in org.apache.avro.io.parsing

Symbol.FieldAdjustAction(int, String) - Constructor for class org.apache.avro.io.parsing.Symbol.FieldAdjustAction

Symbol.IntCheckAction - Class in org.apache.avro.io.parsing

Symbol.IntCheckAction(int) - Constructor for class org.apache.avro.io.parsing.Symbol.IntCheckAction

Symbol.Kind - Enum in org.apache.avro.io.parsing

Symbol.Repeater - Class in org.apache.avro.io.parsing

Symbol.ResolvingAction - Class in org.apache.avro.io.parsing

Symbol.Root - Class in org.apache.avro.io.parsing

Symbol.Sequence - Class in org.apache.avro.io.parsing

Symbol.SkipAction - Class in org.apache.avro.io.parsing

Symbol.SkipAction(Symbol) - Constructor for class org.apache.avro.io.parsing.Symbol.SkipAction

Symbol.UnionAdjustAction - Class in org.apache.avro.io.parsing

Symbol.UnionAdjustAction(int, Symbol) - Constructor for class org.apache.avro.io.parsing.Symbol.UnionAdjustAction

Symbol.WriterUnionAction - Class in org.apache.avro.io.parsing

Symbol.WriterUnionAction() - Constructor for class org.apache.avro.io.parsing.Symbol.WriterUnionAction

symbolHandler - Variable in class org.apache.avro.io.parsing.Parser

symbols - Variable in class org.apache.avro.io.parsing.Symbol.Alternative

symbols - Variable in class org.apache.avro.io.parsing.Symbol.EnumLabelsAction

symToParse - Variable in class org.apache.avro.io.parsing.Symbol.UnionAdjustAction

symToSkip - Variable in class org.apache.avro.io.parsing.Symbol.SkipAction

sync(long) - Method in class org.apache.avro.file.DataFileReader

Move to the next synchronization point after a position.

sync() - Method in class org.apache.avro.file.DataFileWriter

Return the current position as a value that may be passed to DataFileReader.seek(long).

SYSTEM_ERROR - Static variable in class org.apache.avro.Protocol

An error that can be thrown by any message.

SYSTEM_ERRORS - Static variable in class org.apache.avro.Protocol

Union type for generating system errors.

T

tell() - Method in class org.apache.avro.file.SeekableFileInput

tell() - Method in interface org.apache.avro.file.SeekableInput

Return the position of the next read().

topSymbol() - Method in class org.apache.avro.io.parsing.Parser

Returns the top symbol from the stack.

toString() - Method in class org.apache.avro.generic.GenericData.Array

toString() - Method in class org.apache.avro.generic.GenericData.Fixed

toString(Object) - Method in class org.apache.avro.generic.GenericData

Renders a Java datum as JSON.

toString() - Method in class org.apache.avro.Protocol.Message

toString() - Method in class org.apache.avro.Protocol

toString() - Method in class org.apache.avro.Schema

Render this as JSON.

toString() - Method in class org.apache.avro.util.Utf8

transceive(List<ByteBuffer>) - Method in class org.apache.avro.ipc.HttpTransceiver

transceive(List<ByteBuffer>) - Method in class org.apache.avro.ipc.Transceiver

Transceiver - Class in org.apache.avro.ipc

Base class for transmitters and recievers of raw binary messages.

Transceiver() - Constructor for class org.apache.avro.ipc.Transceiver

U

UNION - Static variable in class org.apache.avro.io.parsing.Symbol

UNION_END - Static variable in class org.apache.avro.io.parsing.Symbol

Utf8 - Class in org.apache.avro.util

A Utf8 string.

Utf8() - Constructor for class org.apache.avro.util.Utf8

Utf8(String) - Constructor for class org.apache.avro.util.Utf8

V

validate(Schema, Object) - Method in class org.apache.avro.generic.GenericData

Returns true if a Java datum matches a schema.

validate(Schema, Object) - Method in class org.apache.avro.reflect.ReflectData

Returns true if an object matches a schema.

ValidatingDecoder - Class in org.apache.avro.io

An implementation of Decoder that ensures that the sequence of operations conforms to a schema.

ValidatingDecoder(Schema, Decoder) - Constructor for class org.apache.avro.io.ValidatingDecoder

ValidatingEncoder - Class in org.apache.avro.io

An implementation of Encoder that ensures that the sequence of operations conforms to a schema.

ValidatingEncoder(Schema, Encoder) - Constructor for class org.apache.avro.io.ValidatingEncoder

ValidatingGrammarGenerator - Class in org.apache.avro.io.parsing

The class that generates validating grammar.

ValidatingGrammarGenerator() - Constructor for class org.apache.avro.io.parsing.ValidatingGrammarGenerator

valueOf(String) - Static method in enum org.apache.avro.io.parsing.Symbol.Kind

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

valueOf(String) - Static method in enum org.apache.avro.Schema.Field.Order

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

valueOf(String) - Static method in enum org.apache.avro.Schema.Type

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

values() - Static method in enum org.apache.avro.io.parsing.Symbol.Kind

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

values() - Static method in enum org.apache.avro.Schema.Field.Order

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

values() - Static method in enum org.apache.avro.Schema.Type

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

VERSION - Static variable in class org.apache.avro.Protocol

The version of the protocol specification implemented here.

W

write(D, Encoder) - Method in class org.apache.avro.generic.GenericDatumWriter

write(Schema, Object, Encoder) - Method in class org.apache.avro.generic.GenericDatumWriter

Called to write data.

write(D, Encoder) - Method in interface org.apache.avro.io.DatumWriter

Write a datum.

write(ByteBuffer) - Method in class org.apache.avro.ipc.ByteBufferOutputStream

write(int) - Method in class org.apache.avro.ipc.ByteBufferOutputStream

write(byte[], int, int) - Method in class org.apache.avro.ipc.ByteBufferOutputStream

writeArray(Schema, Object, Encoder) - Method in class org.apache.avro.generic.GenericDatumWriter

Called to write a array.

writeArrayEnd() - Method in class org.apache.avro.io.BinaryEncoder

writeArrayEnd() - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeArrayEnd() - Method in class org.apache.avro.io.Encoder

Call this method to finish writing an array.

writeArrayEnd() - Method in class org.apache.avro.io.JsonEncoder

writeArrayEnd() - Method in class org.apache.avro.io.ValidatingEncoder

writeArrayStart() - Method in class org.apache.avro.io.BinaryEncoder

writeArrayStart() - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeArrayStart() - Method in class org.apache.avro.io.Encoder

Call this method to start writing an array.

writeArrayStart() - Method in class org.apache.avro.io.JsonEncoder

writeArrayStart() - Method in class org.apache.avro.io.ValidatingEncoder

writeBoolean(boolean) - Method in class org.apache.avro.io.BinaryEncoder

writeBoolean(boolean) - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeBoolean(boolean) - Method in class org.apache.avro.io.Encoder

Write a boolean value.

writeBoolean(boolean) - Method in class org.apache.avro.io.JsonEncoder

writeBoolean(boolean) - Method in class org.apache.avro.io.ValidatingEncoder

writeBuffer(ByteBuffer) - Method in class org.apache.avro.ipc.ByteBufferOutputStream

Add a buffer to the output without copying, if possible.

writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.DatagramTransceiver

writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.HttpTransceiver

writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.SocketTransceiver

writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.Transceiver

writeBytes(Object, Encoder) - Method in class org.apache.avro.generic.GenericDatumWriter

Called to write a bytes.

writeBytes(ByteBuffer) - Method in class org.apache.avro.io.BinaryEncoder

writeBytes(byte[], int, int) - Method in class org.apache.avro.io.BinaryEncoder

writeBytes(ByteBuffer) - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeBytes(byte[], int, int) - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeBytes(ByteBuffer) - Method in class org.apache.avro.io.Encoder

Write a byte string.

writeBytes(byte[], int, int) - Method in class org.apache.avro.io.Encoder

Write a byte string.

writeBytes(byte[]) - Method in class org.apache.avro.io.Encoder

Writes a byte string.

writeBytes(ByteBuffer) - Method in class org.apache.avro.io.JsonEncoder

writeBytes(byte[], int, int) - Method in class org.apache.avro.io.JsonEncoder

writeBytes(ByteBuffer) - Method in class org.apache.avro.io.ValidatingEncoder

writeBytes(byte[], int, int) - Method in class org.apache.avro.io.ValidatingEncoder

writeDouble(double) - Method in class org.apache.avro.io.BinaryEncoder

writeDouble(double) - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeDouble(double) - Method in class org.apache.avro.io.Encoder

Write a double.

writeDouble(double) - Method in class org.apache.avro.io.JsonEncoder

writeDouble(double) - Method in class org.apache.avro.io.ValidatingEncoder

writeEnum(Schema, Object, Encoder) - Method in class org.apache.avro.generic.GenericDatumWriter

Called to write an enum value.

writeEnum(int) - Method in class org.apache.avro.io.BinaryEncoder

writeEnum(int) - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeEnum(int) - Method in class org.apache.avro.io.Encoder

Writes an enumeration.

writeEnum(int) - Method in class org.apache.avro.io.JsonEncoder

writeEnum(int) - Method in class org.apache.avro.io.ValidatingEncoder

writeEnum(Schema, Object, Encoder) - Method in class org.apache.avro.reflect.ReflectDatumWriter

writeError(Schema, AvroRemoteException, Encoder) - Method in class org.apache.avro.generic.GenericResponder

Writes an error message.

writeError(Schema, AvroRemoteException, Encoder) - Method in class org.apache.avro.ipc.Responder

Writes an error message.

writeError(Schema, AvroRemoteException, Encoder) - Method in class org.apache.avro.reflect.ReflectResponder

Writes an error message.

writeFixed(Schema, Object, Encoder) - Method in class org.apache.avro.generic.GenericDatumWriter

Called to write a fixed value.

writeFixed(byte[], int, int) - Method in class org.apache.avro.io.BinaryEncoder

writeFixed(byte[], int, int) - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeFixed(byte[], int, int) - Method in class org.apache.avro.io.Encoder

Writes a fixed size binary object.

writeFixed(byte[]) - Method in class org.apache.avro.io.Encoder

A shorthand for writeFixed(bytes, 0, bytes.length)

writeFixed(byte[], int, int) - Method in class org.apache.avro.io.JsonEncoder

writeFixed(byte[], int, int) - Method in class org.apache.avro.io.ValidatingEncoder

writeFloat(float) - Method in class org.apache.avro.io.BinaryEncoder

writeFloat(float) - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeFloat(float) - Method in class org.apache.avro.io.Encoder

Write a float.

writeFloat(float) - Method in class org.apache.avro.io.JsonEncoder

writeFloat(float) - Method in class org.apache.avro.io.ValidatingEncoder

writeIndex(int) - Method in class org.apache.avro.io.BinaryEncoder

writeIndex(int) - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeIndex(int) - Method in class org.apache.avro.io.Encoder

Call this method to write the tag of a union.

writeIndex(int) - Method in class org.apache.avro.io.JsonEncoder

writeIndex(int) - Method in class org.apache.avro.io.ValidatingEncoder

writeInt(int) - Method in class org.apache.avro.io.BinaryEncoder

writeInt(int) - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeInt(int) - Method in class org.apache.avro.io.Encoder

Writes a 32-bit integer.

writeInt(int) - Method in class org.apache.avro.io.JsonEncoder

writeInt(int) - Method in class org.apache.avro.io.ValidatingEncoder

writeLong(long) - Method in class org.apache.avro.io.BinaryEncoder

writeLong(long) - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeLong(long) - Method in class org.apache.avro.io.Encoder

Write a 64-bit integer.

writeLong(long) - Method in class org.apache.avro.io.JsonEncoder

writeLong(long) - Method in class org.apache.avro.io.ValidatingEncoder

writeMap(Schema, Object, Encoder) - Method in class org.apache.avro.generic.GenericDatumWriter

Called to write a map.

writeMapEnd() - Method in class org.apache.avro.io.BinaryEncoder

writeMapEnd() - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeMapEnd() - Method in class org.apache.avro.io.Encoder

Call this method to terminate the inner-most, currently-opened map.

writeMapEnd() - Method in class org.apache.avro.io.JsonEncoder

writeMapEnd() - Method in class org.apache.avro.io.ValidatingEncoder

writeMapStart() - Method in class org.apache.avro.io.BinaryEncoder

writeMapStart() - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeMapStart() - Method in class org.apache.avro.io.Encoder

Call this to start a new map.

writeMapStart() - Method in class org.apache.avro.io.JsonEncoder

writeMapStart() - Method in class org.apache.avro.io.ValidatingEncoder

writeNull() - Method in class org.apache.avro.io.BinaryEncoder

writeNull() - Method in class org.apache.avro.io.Encoder

"Writes" a null value.

writeNull() - Method in class org.apache.avro.io.JsonEncoder

writeNull() - Method in class org.apache.avro.io.ValidatingEncoder

writer - Variable in class org.apache.avro.io.parsing.Symbol.ResolvingAction

writeRecord(Schema, Object, Encoder) - Method in class org.apache.avro.generic.GenericDatumWriter

Called to write a record.

writeRequest(Schema, Object, Encoder) - Method in class org.apache.avro.generic.GenericRequestor

writeRequest(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.Requestor

Writes a request message.

writeRequest(Schema, Object, Encoder) - Method in class org.apache.avro.reflect.ReflectRequestor

writeResponse(Schema, Object, Encoder) - Method in class org.apache.avro.generic.GenericResponder

Writes a response message.

writeResponse(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.Responder

Writes a response message.

writeResponse(Schema, Object, Encoder) - Method in class org.apache.avro.reflect.ReflectResponder

Writes a response message.

writeString(Object, Encoder) - Method in class org.apache.avro.generic.GenericDatumWriter

Called to write a string.

writeString(Utf8) - Method in class org.apache.avro.io.BinaryEncoder

writeString(Utf8) - Method in class org.apache.avro.io.BlockingBinaryEncoder

writeString(Utf8) - Method in class org.apache.avro.io.Encoder

Write a Unicode character string.

writeString(String) - Method in class org.apache.avro.io.Encoder

Write a Unicode character string.

writeString(Utf8) - Method in class org.apache.avro.io.JsonEncoder

writeString(Utf8) - Method in class org.apache.avro.io.ValidatingEncoder

A B C D E F G H I J K L M N O P R S T U V W