| Package | Description | 
|---|---|
| org.apache.avro | 
 Avro kernel classes. 
 | 
| org.apache.avro.compiler.idl | |
| org.apache.avro.compiler.specific | |
| org.apache.avro.data | 
 Interfaces and base classes shared by generic, specific and reflect. 
 | 
| org.apache.avro.file | 
 A container file for Avro data. 
 | 
| org.apache.avro.generic | 
 A generic representation for Avro data. 
 | 
| org.apache.avro.hadoop.file | |
| org.apache.avro.hadoop.io | |
| org.apache.avro.io | 
 Utilities for Encoding and Decoding Avro data. 
 | 
| org.apache.avro.io.parsing | 
 Implementation of Avro schemas as LL(1) grammars. 
 | 
| org.apache.avro.ipc | 
 Support for inter-process calls. 
 | 
| org.apache.avro.ipc.generic | |
| org.apache.avro.ipc.reflect | |
| org.apache.avro.ipc.specific | |
| org.apache.avro.ipc.trace | |
| org.apache.avro.mapred | 
 Run Hadoop MapReduce jobs over
Avro data, with map and reduce functions written in Java. 
 | 
| org.apache.avro.mapred.tether | 
 Run Hadoop MapReduce jobs over
Avro data, with map and reduce functions run in a sub-process. 
 | 
| org.apache.avro.mapreduce | |
| org.apache.avro.protobuf | 
 Protocol Buffer
  compatibility. 
 | 
| org.apache.avro.reflect | 
 Use Java reflection to generate schemas and protocols for existing
classes. 
 | 
| org.apache.avro.specific | 
 Generate specific Java classes for schemas and protocols. 
 | 
| org.apache.avro.thrift | 
 Thrift compatibility. 
 | 
| org.apache.trevni.avro | 
 Read and write Avro data
in Trevni column files. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static Schema | 
Protocol.SYSTEM_ERROR
An error that can be thrown by any message. 
 | 
static Schema | 
Protocol.SYSTEM_ERRORS
Union type for generating system errors. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Schema | 
Schema.applyAliases(Schema writer,
            Schema reader)
Rewrite a writer's schema using the aliases from a reader's schema. 
 | 
static Schema | 
Schema.create(Schema.Type type)
Create a schema for a primitive type. 
 | 
static Schema | 
Schema.createArray(Schema elementType)
Create an array schema. 
 | 
static Schema | 
Schema.createEnum(String name,
          String doc,
          String namespace,
          List<String> values)
Create an enum schema. 
 | 
static Schema | 
Schema.createFixed(String name,
           String doc,
           String space,
           int size)
Create a union schema. 
 | 
static Schema | 
Schema.createMap(Schema valueType)
Create a map schema. 
 | 
static Schema | 
Schema.createRecord(List<Schema.Field> fields)
Create an anonymous record schema. 
 | 
static Schema | 
Schema.createRecord(String name,
            String doc,
            String namespace,
            boolean isError)
Create a named record schema. 
 | 
static Schema | 
Schema.createUnion(List<Schema> types)
Create a union schema. 
 | 
Schema | 
Schema.getElementType()
If this is an array, returns its element type. 
 | 
Schema | 
Protocol.Message.getErrors()
Errors that might be thrown. 
 | 
Schema | 
Protocol.Message.getRequest()
The parameters of this message. 
 | 
Schema | 
Protocol.Message.getResponse()
The returned data. 
 | 
Schema | 
Protocol.getType(String name)
Returns the named type. 
 | 
Schema | 
UnresolvedUnionException.getUnionSchema()  | 
Schema | 
Schema.getValueType()
If this is a map, returns its value type. 
 | 
static Schema | 
Schema.parse(File file)
Deprecated. 
 
use  
Schema.Parser instead. | 
Schema | 
Schema.Parser.parse(File file)
Parse a schema from the provided file. 
 | 
static Schema | 
Schema.parse(InputStream in)
Deprecated. 
 
use  
Schema.Parser instead. | 
Schema | 
Schema.Parser.parse(InputStream in)
Parse a schema from the provided stream. 
 | 
static Schema | 
Schema.parse(String jsonSchema)
Deprecated. 
 
use  
Schema.Parser instead. | 
Schema | 
Schema.Parser.parse(String s)
Parse a schema from the provided string. 
 | 
static Schema | 
Schema.parse(String jsonSchema,
     boolean validate)
Deprecated. 
 
use  
Schema.Parser instead. | 
Schema | 
Schema.Field.schema()
This field's  
Schema. | 
| Modifier and Type | Method and Description | 
|---|---|
List<Schema> | 
Schema.getTypes()
If this is a union, returns its types. 
 | 
Map<String,Schema> | 
Schema.Parser.getTypes()
Returns the set of defined, named types known to this parser. 
 | 
Collection<Schema> | 
Protocol.getTypes()
The types of this protocol. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Schema | 
Schema.applyAliases(Schema writer,
            Schema reader)
Rewrite a writer's schema using the aliases from a reader's schema. 
 | 
static Schema | 
Schema.createArray(Schema elementType)
Create an array schema. 
 | 
static Schema | 
Schema.createMap(Schema valueType)
Create a map schema. 
 | 
Protocol.Message | 
Protocol.createMessage(String name,
             String doc,
             Map<String,String> propMap,
             Schema request)
Create a one-way message. 
 | 
Protocol.Message | 
Protocol.createMessage(String name,
             String doc,
             Map<String,String> propMap,
             Schema request,
             Schema response,
             Schema errors)
Create a two-way message. 
 | 
Protocol.Message | 
Protocol.createMessage(String name,
             String doc,
             Schema request)
Deprecated.  
 | 
Protocol.Message | 
Protocol.createMessage(String name,
             String doc,
             Schema request,
             Schema response,
             Schema errors)
Deprecated.  
 | 
static byte[] | 
SchemaNormalization.parsingFingerprint(String fpName,
                  Schema s)
Returns  
SchemaNormalization.fingerprint(java.lang.String, byte[]) applied to the parsing canonical form
 of the supplied schema. | 
static long | 
SchemaNormalization.parsingFingerprint64(Schema s)
Returns  
SchemaNormalization.fingerprint64(byte[]) applied to the parsing canonical form
 of the supplied schema. | 
static String | 
SchemaNormalization.toParsingForm(Schema s)
Returns "Parsing Canonical Form" of a schema as defined by Avro
 spec. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Schema.Parser | 
Schema.Parser.addTypes(Map<String,Schema> types)
Adds the provided types to the set of defined, named types known to
 this parser. 
 | 
static Schema | 
Schema.createUnion(List<Schema> types)
Create a union schema. 
 | 
void | 
Protocol.setTypes(Collection<Schema> newTypes)
Set the types of this protocol. 
 | 
| Constructor and Description | 
|---|
Schema.Field(String name,
            Schema schema,
            String doc,
            JsonNode defaultValue)  | 
Schema.Field(String name,
            Schema schema,
            String doc,
            JsonNode defaultValue,
            Schema.Field.Order order)  | 
UnresolvedUnionException(Schema unionSchema,
                        Object unresolvedDatum)  | 
| Modifier and Type | Method and Description | 
|---|---|
Schema | 
Idl.ArrayType()  | 
Schema | 
Idl.EnumDeclaration()  | 
Schema | 
Idl.FixedDeclaration()  | 
Schema | 
Idl.FormalParameters()  | 
Schema | 
Idl.ImportSchema()  | 
Schema | 
Idl.MapType()  | 
Schema | 
Idl.NamedSchemaDeclaration(Map<String,JsonNode> props)  | 
Schema | 
Idl.PrimitiveType()  | 
Schema | 
Idl.RecordDeclaration()  | 
Schema | 
Idl.ReferenceType()
A reference to some other existing type 
 | 
Schema | 
Idl.ResultType()
Result types are like other types, except we provide "void" as
 an alias of "null" 
 | 
Schema | 
Idl.Type()  | 
Schema | 
Idl.UnionDefinition()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Idl.VariableDeclarator(Schema type,
                  List<Schema.Field> fields)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Idl.ErrorList(List<Schema> errors)  | 
| Modifier and Type | Method and Description | 
|---|---|
static String | 
SpecificCompiler.generateClearMethod(Schema schema,
                   Schema.Field field)
Generates the name of a field "clear" method. 
 | 
static String | 
SpecificCompiler.generateGetMethod(Schema schema,
                 Schema.Field field)
Generates the name of a field accessor method. 
 | 
static String | 
SpecificCompiler.generateHasMethod(Schema schema,
                 Schema.Field field)
Generates the name of a field "has" method. 
 | 
static String | 
SpecificCompiler.generateSetMethod(Schema schema,
                 Schema.Field field)
Generates the name of a field mutator method. 
 | 
static boolean | 
SpecificCompiler.isUnboxedJavaTypeNullable(Schema schema)
Tests whether an unboxed Java type can be set to null 
 | 
String | 
SpecificCompiler.javaType(Schema schema)
Utility for template use. 
 | 
String | 
SpecificCompiler.javaUnbox(Schema schema)
Utility for template use. 
 | 
| Constructor and Description | 
|---|
SpecificCompiler(Schema schema)  | 
| Modifier and Type | Field and Description | 
|---|---|
static Schema | 
Json.SCHEMA
The schema for Json data. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected Schema | 
RecordBuilderBase.schema()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Json.Writer.setSchema(Schema schema)  | 
void | 
Json.Reader.setSchema(Schema schema)  | 
| Constructor and Description | 
|---|
RecordBuilderBase(Schema schema,
                 GenericData data)
Creates a RecordBuilderBase for building records of the given type. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Schema | 
DataFileReader12.getSchema()
Return the schema used in this file. 
 | 
Schema | 
FileReader.getSchema()
Return the schema for data in this file. 
 | 
Schema | 
DataFileStream.getSchema()
Return the schema used in this file. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
DataFileWriter<D> | 
DataFileWriter.create(Schema schema,
      File file)
Open a new file for data matching a schema. 
 | 
DataFileWriter<D> | 
DataFileWriter.create(Schema schema,
      OutputStream outs)
Open a new file for data matching a schema. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected Schema | 
GenericData.getEnumSchema(Object enu)
Called to obtain the schema of a enum. 
 | 
Schema | 
GenericDatumReader.getExpected()
Get the reader's schema. 
 | 
protected Schema | 
GenericData.getFixedSchema(Object fixed)
Called to obtain the schema of a fixed. 
 | 
protected Schema | 
GenericData.getRecordSchema(Object record)
Called to obtain the schema of a record. 
 | 
Schema | 
GenericDatumReader.getSchema()
Return the writer's schema. 
 | 
Schema | 
GenericContainer.getSchema()
The schema of this instance. 
 | 
Schema | 
GenericData.Record.getSchema()  | 
Schema | 
GenericData.Array.getSchema()  | 
Schema | 
GenericData.Fixed.getSchema()  | 
Schema | 
GenericData.EnumSymbol.getSchema()  | 
Schema | 
GenericData.induce(Object datum)
Create a schema given an example datum. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
GenericData.compare(Object o1,
       Object o2,
       Schema s)
Compare objects according to their schema. 
 | 
protected int | 
GenericData.compare(Object o1,
       Object o2,
       Schema s,
       boolean equals)
Comparison implementation. 
 | 
DatumReader | 
GenericData.createDatumReader(Schema schema)
Returns a  
DatumReader for this kind of data. | 
protected Object | 
GenericDatumReader.createEnum(String symbol,
          Schema schema)
Called to create an enum value. 
 | 
protected Object | 
GenericDatumReader.createFixed(Object old,
           byte[] bytes,
           Schema schema)
Deprecated. 
 
As of Avro 1.6.0 this method has been moved to 
  
GenericData.createFixed(Object, byte[], Schema) | 
Object | 
GenericData.createFixed(Object old,
           byte[] bytes,
           Schema schema)
Called to create an fixed value. 
 | 
protected Object | 
GenericDatumReader.createFixed(Object old,
           Schema schema)
Deprecated. 
 
As of Avro 1.6.0 this method has been moved to 
  
GenericData.createFixed(Object, Schema) | 
Object | 
GenericData.createFixed(Object old,
           Schema schema)
Called to create an fixed value. 
 | 
Object | 
GenericData.deepCopy(Schema schema,
        Object value)
Makes a deep copy of a value given its schema. 
 | 
protected Object | 
GenericData.getRecordState(Object record,
              Schema schema)
Produce state for repeated calls to  
GenericData.getField(Object,String,int,Object) and GenericData.setField(Object,String,int,Object,Object) on the same record. | 
protected ResolvingDecoder | 
GenericDatumReader.getResolver(Schema actual,
           Schema expected)
Gets a resolving decoder for use by this GenericDatumReader. 
 | 
int | 
GenericData.hashCode(Object o,
        Schema s)
Compute a hash code according to a schema, consistent with  
GenericData.compare(Object,Object,Schema). | 
protected int | 
GenericData.hashCodeAdd(int hashCode,
           Object o,
           Schema s)
Add the hash code for an object into an accumulated hash code. 
 | 
protected boolean | 
GenericData.instanceOf(Schema schema,
          Object datum)
Called by  
GenericData.resolveUnion(Schema,Object). | 
protected Object | 
GenericDatumReader.newArray(Object old,
        int size,
        Schema schema)
Called to create new array instances. 
 | 
protected Object | 
GenericDatumReader.newRecord(Object old,
         Schema schema)
Deprecated. 
 
As of Avro 1.6.0 this method has been moved to 
  
GenericData.newRecord(Object, Schema) | 
Object | 
GenericData.newRecord(Object old,
         Schema schema)
Called to create new record instances. 
 | 
protected Object | 
GenericDatumReader.read(Object old,
    Schema expected,
    ResolvingDecoder in)
Called to read data. 
 | 
protected Object | 
GenericDatumReader.readArray(Object old,
         Schema expected,
         ResolvingDecoder in)
Called to read an array instance. 
 | 
protected Object | 
GenericDatumReader.readBytes(Object old,
         Schema s,
         Decoder in)
Called to read byte arrays. 
 | 
protected Object | 
GenericDatumReader.readEnum(Schema expected,
        Decoder in)
Called to read an enum value. 
 | 
protected Object | 
GenericDatumReader.readFixed(Object old,
         Schema expected,
         Decoder in)
Called to read a fixed value. 
 | 
protected Object | 
GenericDatumReader.readInt(Object old,
       Schema expected,
       Decoder in)
Called to read integers. 
 | 
protected Object | 
GenericDatumReader.readMap(Object old,
       Schema expected,
       ResolvingDecoder in)
Called to read a map instance. 
 | 
protected Object | 
GenericDatumReader.readMapKey(Object old,
          Schema expected,
          Decoder in)
Called by the default implementation of  
GenericDatumReader.readMap(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder) to read a
 key value. | 
protected Object | 
GenericDatumReader.readRecord(Object old,
          Schema expected,
          ResolvingDecoder in)
Called to read a record instance. 
 | 
protected Object | 
GenericDatumReader.readString(Object old,
          Schema expected,
          Decoder in)
Called to read strings. 
 | 
int | 
GenericData.resolveUnion(Schema union,
            Object datum)
Return the index for a datum within a union. 
 | 
protected int | 
GenericDatumWriter.resolveUnion(Schema union,
            Object datum)
Called to find the index for a datum within a union. 
 | 
void | 
GenericDatumReader.setExpected(Schema reader)
Set the reader's schema. 
 | 
void | 
GenericDatumReader.setSchema(Schema writer)  | 
protected void | 
GenericData.Fixed.setSchema(Schema schema)  | 
void | 
GenericDatumWriter.setSchema(Schema root)  | 
static void | 
GenericData.setStringType(Schema s,
             GenericData.StringType stringType)
Set the Java type to be used when reading this schema. 
 | 
static void | 
GenericDatumReader.skip(Schema schema,
    Decoder in)
Skip an instance of a schema. 
 | 
boolean | 
GenericData.validate(Schema schema,
        Object datum)
Returns true if a Java datum matches a schema. 
 | 
protected void | 
GenericDatumWriter.write(Schema schema,
     Object datum,
     Encoder out)
Called to write data. 
 | 
protected void | 
GenericDatumWriter.writeArray(Schema schema,
          Object datum,
          Encoder out)
Called to write a array. 
 | 
protected void | 
GenericDatumWriter.writeEnum(Schema schema,
         Object datum,
         Encoder out)
Called to write an enum value. 
 | 
protected void | 
GenericDatumWriter.writeFixed(Schema schema,
          Object datum,
          Encoder out)
Called to write a fixed value. 
 | 
protected void | 
GenericDatumWriter.writeMap(Schema schema,
        Object datum,
        Encoder out)
Called to write a map. 
 | 
protected void | 
GenericDatumWriter.writeRecord(Schema schema,
           Object datum,
           Encoder out)
Called to write a record. 
 | 
protected void | 
GenericDatumWriter.writeString(Schema schema,
           Object datum,
           Encoder out)
Called to write a string. 
 | 
| Constructor and Description | 
|---|
GenericData.Array(int capacity,
                 Schema schema)  | 
GenericData.Array(Schema schema,
                 Collection<T> c)  | 
GenericData.EnumSymbol(Schema schema,
                      String symbol)  | 
GenericData.Fixed(Schema schema)  | 
GenericData.Fixed(Schema schema,
                 byte[] bytes)  | 
GenericData.Record(Schema schema)  | 
GenericDatumReader(Schema schema)
Construct where the writer's and reader's schemas are the same. 
 | 
GenericDatumReader(Schema writer,
                  Schema reader)
Construct given writer's and reader's schema. 
 | 
GenericDatumReader(Schema writer,
                  Schema reader,
                  GenericData data)  | 
GenericDatumWriter(Schema root)  | 
GenericDatumWriter(Schema root,
                  GenericData data)  | 
GenericRecordBuilder(Schema schema)
Creates a GenericRecordBuilder for building Record instances. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Schema | 
SortedKeyValueFile.Reader.Options.getKeySchema()
Gets the reader schema for the key. 
 | 
Schema | 
SortedKeyValueFile.Writer.Options.getKeySchema()
Gets the key schema. 
 | 
Schema | 
SortedKeyValueFile.Reader.Options.getValueSchema()
Gets the reader schema for the value. 
 | 
Schema | 
SortedKeyValueFile.Writer.Options.getValueSchema()
Gets the value schema. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
SortedKeyValueFile.Reader.Options | 
SortedKeyValueFile.Reader.Options.withKeySchema(Schema keySchema)
Sets the reader schema for the key. 
 | 
SortedKeyValueFile.Writer.Options | 
SortedKeyValueFile.Writer.Options.withKeySchema(Schema keySchema)
Sets the key schema. 
 | 
SortedKeyValueFile.Reader.Options | 
SortedKeyValueFile.Reader.Options.withValueSchema(Schema valueSchema)
Sets the reader schema for the value. 
 | 
SortedKeyValueFile.Writer.Options | 
SortedKeyValueFile.Writer.Options.withValueSchema(Schema valueSchema)
Sets the value schema. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Schema | 
AvroSerialization.getKeyReaderSchema(Configuration conf)
Gets the reader schema of the AvroKey datum that is being serialized/deserialized. 
 | 
static Schema | 
AvroSerialization.getKeyWriterSchema(Configuration conf)
Gets the writer schema of the AvroKey datum that is being serialized/deserialized. 
 | 
Schema | 
AvroDeserializer.getReaderSchema()
Gets the reader schema used for deserializing. 
 | 
static Schema | 
AvroKeyValue.getSchema(Schema keySchema,
         Schema valueSchema)
Creates a KeyValuePair generic record schema. 
 | 
static Schema | 
AvroSerialization.getValueReaderSchema(Configuration conf)
Gets the reader schema of the AvroValue datum that is being serialized/deserialized. 
 | 
static Schema | 
AvroSerialization.getValueWriterSchema(Configuration conf)
Gets the writer schema of the AvroValue datum that is being serialized/deserialized. 
 | 
Schema | 
AvroDeserializer.getWriterSchema()
Gets the writer schema used for deserializing. 
 | 
Schema | 
AvroSerializer.getWriterSchema()
Gets the writer schema being used for serialization. 
 | 
Schema | 
AvroDatumConverterFactory.AvroWrapperConverter.getWriterSchema()
Gets the writer schema that should be used to serialize the output Avro datum. 
 | 
Schema | 
AvroDatumConverterFactory.BooleanWritableConverter.getWriterSchema()
Gets the writer schema that should be used to serialize the output Avro datum. 
 | 
Schema | 
AvroDatumConverterFactory.BytesWritableConverter.getWriterSchema()
Gets the writer schema that should be used to serialize the output Avro datum. 
 | 
Schema | 
AvroDatumConverterFactory.ByteWritableConverter.getWriterSchema()
Gets the writer schema that should be used to serialize the output Avro datum. 
 | 
Schema | 
AvroDatumConverterFactory.DoubleWritableConverter.getWriterSchema()
Gets the writer schema that should be used to serialize the output Avro datum. 
 | 
Schema | 
AvroDatumConverterFactory.FloatWritableConverter.getWriterSchema()
Gets the writer schema that should be used to serialize the output Avro datum. 
 | 
Schema | 
AvroDatumConverterFactory.IntWritableConverter.getWriterSchema()
Gets the writer schema that should be used to serialize the output Avro datum. 
 | 
Schema | 
AvroDatumConverterFactory.LongWritableConverter.getWriterSchema()
Gets the writer schema that should be used to serialize the output Avro datum. 
 | 
Schema | 
AvroDatumConverterFactory.NullWritableConverter.getWriterSchema()
Gets the writer schema that should be used to serialize the output Avro datum. 
 | 
Schema | 
AvroDatumConverterFactory.TextConverter.getWriterSchema()
Gets the writer schema that should be used to serialize the output Avro datum. 
 | 
abstract Schema | 
AvroDatumConverter.getWriterSchema()
Gets the writer schema that should be used to serialize the output Avro datum. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static Schema | 
AvroKeyValue.getSchema(Schema keySchema,
         Schema valueSchema)
Creates a KeyValuePair generic record schema. 
 | 
static void | 
AvroSerialization.setKeyReaderSchema(Configuration conf,
                  Schema schema)
Sets the reader schema of the AvroKey datum that is being serialized/deserialized. 
 | 
static void | 
AvroSerialization.setKeyWriterSchema(Configuration conf,
                  Schema schema)
Sets the writer schema of the AvroKey datum that is being serialized/deserialized. 
 | 
static void | 
AvroSerialization.setValueReaderSchema(Configuration conf,
                    Schema schema)
Sets the reader schema of the AvroValue datum that is being serialized/deserialized. 
 | 
static void | 
AvroSerialization.setValueWriterSchema(Configuration conf,
                    Schema schema)
Sets the writer schema of the AvroValue datum that is being serialized/deserialized. 
 | 
AvroSequenceFile.Writer.Options | 
AvroSequenceFile.Writer.Options.withKeySchema(Schema keyWriterSchema)
Sets the writer schema of the key records when using Avro data. 
 | 
AvroSequenceFile.Reader.Options | 
AvroSequenceFile.Reader.Options.withKeySchema(Schema keyReaderSchema)
Sets the reader schema of the key records when using Avro data. 
 | 
AvroSequenceFile.Writer.Options | 
AvroSequenceFile.Writer.Options.withValueSchema(Schema valueWriterSchema)
Sets the writer schema of the value records when using Avro data. 
 | 
AvroSequenceFile.Reader.Options | 
AvroSequenceFile.Reader.Options.withValueSchema(Schema valueReaderSchema)
Sets the reader schema of the value records when using Avro data. 
 | 
| Constructor and Description | 
|---|
AvroDatumConverterFactory.AvroWrapperConverter(Schema schema)  | 
AvroDeserializer(Schema writerSchema,
                Schema readerSchema,
                ClassLoader classLoader)
Constructor. 
 | 
AvroKeyDeserializer(Schema writerSchema,
                   Schema readerSchema,
                   ClassLoader classLoader)
Constructor. 
 | 
AvroSerializer(Schema writerSchema)
Constructor. 
 | 
AvroValueDeserializer(Schema writerSchema,
                     Schema readerSchema,
                     ClassLoader classLoader)
Constructor. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static int | 
BinaryData.compare(byte[] b1,
       int s1,
       byte[] b2,
       int s2,
       Schema schema)
Compare binary encoded data. 
 | 
static int | 
BinaryData.compare(byte[] b1,
       int s1,
       int l1,
       byte[] b2,
       int s2,
       int l2,
       Schema schema)
Compare binary encoded data. 
 | 
static int | 
BinaryData.hashCode(byte[] bytes,
        int start,
        int length,
        Schema schema)
Hash binary encoded data. 
 | 
JsonDecoder | 
DecoderFactory.jsonDecoder(Schema schema,
           InputStream input)
Creates a  
JsonDecoder using the InputStrim provided for reading
 data that conforms to the Schema provided. | 
JsonDecoder | 
DecoderFactory.jsonDecoder(Schema schema,
           String input)
Creates a  
JsonDecoder using the String provided for reading data
 that conforms to the Schema provided. | 
JsonEncoder | 
EncoderFactory.jsonEncoder(Schema schema,
           JsonGenerator gen)
Creates a  
JsonEncoder using the JsonGenerator provided for
 output of data conforming to the Schema provided. | 
JsonEncoder | 
EncoderFactory.jsonEncoder(Schema schema,
           OutputStream out)
Creates a  
JsonEncoder using the OutputStream provided for writing
 data conforming to the Schema provided. | 
static Object | 
ResolvingDecoder.resolve(Schema writer,
       Schema reader)
Produces an opaque resolver that can be used to construct a new
  
ResolvingDecoder.ResolvingDecoder(Object, Decoder). | 
ResolvingDecoder | 
DecoderFactory.resolvingDecoder(Schema writer,
                Schema reader,
                Decoder wrapped)
Creates a  
ResolvingDecoder wrapping the Decoder provided. | 
void | 
DatumWriter.setSchema(Schema schema)
Set the schema. 
 | 
void | 
DatumReader.setSchema(Schema schema)
Set the writer's schema. 
 | 
ValidatingDecoder | 
DecoderFactory.validatingDecoder(Schema schema,
                 Decoder wrapped)
Creates a  
ValidatingDecoder wrapping the Decoder provided. | 
ValidatingEncoder | 
EncoderFactory.validatingEncoder(Schema schema,
                 Encoder encoder)
Creates a  
ValidatingEncoder that wraps the Encoder provided. | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
ResolvingGrammarGenerator.encode(Encoder e,
      Schema s,
      JsonNode n)
Encodes the given Json node n on to the encoder e
 according to the schema s. 
 | 
Symbol | 
ValidatingGrammarGenerator.generate(Schema schema)
Returns the non-terminal that is the start symbol
 for the grammar for the given schema sc. 
 | 
Symbol | 
JsonGrammarGenerator.generate(Schema schema)
Returns the non-terminal that is the start symbol
 for the grammar for the grammar for the given schema sc. 
 | 
Symbol | 
ValidatingGrammarGenerator.generate(Schema sc,
        Map<org.apache.avro.io.parsing.ValidatingGrammarGenerator.LitS,Symbol> seen)
Returns the non-terminal that is the start symbol
 for the grammar for the given schema sc. 
 | 
Symbol | 
JsonGrammarGenerator.generate(Schema sc,
        Map<org.apache.avro.io.parsing.ValidatingGrammarGenerator.LitS,Symbol> seen)
Returns the non-terminal that is the start symbol
 for grammar of the given schema sc. 
 | 
Symbol | 
ResolvingGrammarGenerator.generate(Schema writer,
        Schema reader)
Resolves the writer schema writer and the reader schema
 reader and returns the start symbol for the grammar generated. 
 | 
Symbol | 
ResolvingGrammarGenerator.generate(Schema writer,
        Schema reader,
        Map<org.apache.avro.io.parsing.ValidatingGrammarGenerator.LitS,Symbol> seen)
Resolves the writer schema writer and the reader schema
 reader and returns the start symbol for the grammar generated. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static Schema | 
HandshakeMatch.SCHEMA$  | 
static Schema | 
HandshakeResponse.SCHEMA$  | 
static Schema | 
MD5.SCHEMA$  | 
static Schema | 
HandshakeRequest.SCHEMA$  | 
| Modifier and Type | Method and Description | 
|---|---|
Schema | 
HandshakeResponse.getSchema()  | 
Schema | 
HandshakeRequest.getSchema()  | 
| Modifier and Type | Method and Description | 
|---|---|
Object | 
Requestor.readError(Schema schema,
         Decoder in)
Deprecated.  
 | 
abstract Exception | 
Requestor.readError(Schema writer,
         Schema reader,
         Decoder in)
Reads an error message. 
 | 
abstract Object | 
Responder.readRequest(Schema actual,
           Schema expected,
           Decoder in)
Reads a request message. 
 | 
Object | 
Requestor.readResponse(Schema schema,
            Decoder in)
Deprecated.  
 | 
abstract Object | 
Requestor.readResponse(Schema writer,
            Schema reader,
            Decoder in)
Reads a response message. 
 | 
abstract void | 
Responder.writeError(Schema schema,
          Object error,
          Encoder out)
Writes an error message. 
 | 
abstract void | 
Requestor.writeRequest(Schema schema,
            Object request,
            Encoder out)
Writes a request message. 
 | 
abstract void | 
Responder.writeResponse(Schema schema,
             Object response,
             Encoder out)
Writes a response message. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected DatumReader<Object> | 
GenericResponder.getDatumReader(Schema actual,
              Schema expected)  | 
protected DatumWriter<Object> | 
GenericResponder.getDatumWriter(Schema schema)  | 
Exception | 
GenericRequestor.readError(Schema writer,
         Schema reader,
         Decoder in)  | 
Object | 
GenericResponder.readRequest(Schema actual,
           Schema expected,
           Decoder in)  | 
Object | 
GenericRequestor.readResponse(Schema writer,
            Schema reader,
            Decoder in)  | 
void | 
GenericResponder.writeError(Schema schema,
          Object error,
          Encoder out)  | 
void | 
GenericRequestor.writeRequest(Schema schema,
            Object request,
            Encoder out)  | 
void | 
GenericResponder.writeResponse(Schema schema,
             Object response,
             Encoder out)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected DatumReader<Object> | 
ReflectRequestor.getDatumReader(Schema writer,
              Schema reader)  | 
protected DatumReader<Object> | 
ReflectResponder.getDatumReader(Schema actual,
              Schema expected)  | 
protected DatumWriter<Object> | 
ReflectRequestor.getDatumWriter(Schema schema)  | 
protected DatumWriter<Object> | 
ReflectResponder.getDatumWriter(Schema schema)  | 
void | 
ReflectResponder.writeError(Schema schema,
          Object error,
          Encoder out)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected DatumReader<Object> | 
SpecificRequestor.getDatumReader(Schema schema)
Deprecated.  
 | 
protected DatumReader<Object> | 
SpecificRequestor.getDatumReader(Schema writer,
              Schema reader)  | 
protected DatumReader<Object> | 
SpecificResponder.getDatumReader(Schema actual,
              Schema expected)  | 
protected DatumWriter<Object> | 
SpecificRequestor.getDatumWriter(Schema schema)  | 
protected DatumWriter<Object> | 
SpecificResponder.getDatumWriter(Schema schema)  | 
Exception | 
SpecificRequestor.readError(Schema writer,
         Schema reader,
         Decoder in)  | 
Object | 
SpecificRequestor.readResponse(Schema writer,
            Schema reader,
            Decoder in)  | 
void | 
SpecificResponder.writeError(Schema schema,
          Object error,
          Encoder out)  | 
void | 
SpecificRequestor.writeRequest(Schema schema,
            Object request,
            Encoder out)  | 
| Modifier and Type | Field and Description | 
|---|---|
static Schema | 
Span.SCHEMA$  | 
static Schema | 
ID.SCHEMA$  | 
static Schema | 
TimestampedEvent.SCHEMA$  | 
static Schema | 
SpanEvent.SCHEMA$  | 
| Modifier and Type | Method and Description | 
|---|---|
Schema | 
Span.getSchema()  | 
Schema | 
TimestampedEvent.getSchema()  | 
| Modifier and Type | Method and Description | 
|---|---|
static Schema | 
AvroJob.getInputSchema(Configuration job)
Return a job's map input schema. 
 | 
static Schema | 
Pair.getKeySchema(Schema pair)
Return a pair's key schema. 
 | 
static Schema | 
AvroJob.getMapOutputSchema(Configuration job)
Return a job's map output key schema. 
 | 
static Schema | 
AvroJob.getOutputSchema(Configuration job)
Return a job's output key schema. 
 | 
static Schema | 
Pair.getPairSchema(Schema key,
             Schema value)
Get a pair schema. 
 | 
Schema | 
SequenceFileReader.getSchema()  | 
Schema | 
Pair.getSchema()  | 
static Schema | 
Pair.getValueSchema(Schema pair)
Return a pair's value schema. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
AvroMultipleOutputs.addMultiNamedOutput(JobConf conf,
                   String namedOutput,
                   Class<? extends OutputFormat> outputFormatClass,
                   Schema schema)
Adds a multi named output for the job. 
 | 
static void | 
AvroMultipleOutputs.addNamedOutput(JobConf conf,
              String namedOutput,
              Class<? extends OutputFormat> outputFormatClass,
              Schema schema)
Adds a named output for the job. 
 | 
static Schema | 
Pair.getKeySchema(Schema pair)
Return a pair's key schema. 
 | 
static Schema | 
Pair.getPairSchema(Schema key,
             Schema value)
Get a pair schema. 
 | 
static Schema | 
Pair.getValueSchema(Schema pair)
Return a pair's value schema. 
 | 
static void | 
AvroJob.setInputSchema(JobConf job,
              Schema s)
Configure a job's map input schema. 
 | 
static void | 
AvroJob.setMapOutputSchema(JobConf job,
                  Schema s)
Configure a job's map output schema. 
 | 
static void | 
AvroJob.setOutputSchema(JobConf job,
               Schema s)
Configure a job's output schema. 
 | 
| Constructor and Description | 
|---|
Pair(K key,
    Schema keySchema,
    V value,
    Schema valueSchema)  | 
Pair(Schema schema)  | 
| Modifier and Type | Field and Description | 
|---|---|
static Schema | 
TaskType.SCHEMA$  | 
| Modifier and Type | Method and Description | 
|---|---|
static Schema | 
AvroJob.getInputKeySchema(Configuration conf)
Gets the job input key schema. 
 | 
static Schema | 
AvroJob.getInputValueSchema(Configuration conf)
Gets the job input value schema. 
 | 
static Schema | 
AvroJob.getMapOutputKeySchema(Configuration conf)
Gets the map output key schema. 
 | 
static Schema | 
AvroJob.getMapOutputValueSchema(Configuration conf)
Gets the map output value schema. 
 | 
static Schema | 
AvroJob.getOutputKeySchema(Configuration conf)
Gets the job output key schema. 
 | 
static Schema | 
AvroJob.getOutputValueSchema(Configuration conf)
Gets the job output value schema. 
 | 
Schema | 
AvroKeyValueRecordWriter.getWriterSchema()
Gets the writer schema for the key/value pair generic record. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
AvroMultipleOutputs.addNamedOutput(Job job,
              String namedOutput,
              Class<? extends OutputFormat> outputFormatClass,
              Schema keySchema)
Adds a named output for the job. 
 | 
static void | 
AvroMultipleOutputs.addNamedOutput(Job job,
              String namedOutput,
              Class<? extends OutputFormat> outputFormatClass,
              Schema keySchema,
              Schema valueSchema)
Adds a named output for the job. 
 | 
protected RecordWriter<AvroKey<T>,NullWritable> | 
AvroKeyOutputFormat.RecordWriterFactory.create(Schema writerSchema,
      CodecFactory compressionCodec,
      OutputStream outputStream)
Creates a new record writer instance. 
 | 
static void | 
AvroJob.setInputKeySchema(Job job,
                 Schema schema)
Sets the job input key schema. 
 | 
static void | 
AvroJob.setInputValueSchema(Job job,
                   Schema schema)
Sets the job input value schema. 
 | 
static void | 
AvroJob.setMapOutputKeySchema(Job job,
                     Schema schema)
Sets the map output key schema. 
 | 
static void | 
AvroJob.setMapOutputValueSchema(Job job,
                       Schema schema)
Sets the map output value schema. 
 | 
static void | 
AvroJob.setOutputKeySchema(Job job,
                  Schema schema)
Sets the job output key schema. 
 | 
static void | 
AvroJob.setOutputValueSchema(Job job,
                    Schema schema)
Sets the job output value schema. 
 | 
| Constructor and Description | 
|---|
AvroKeyRecordReader(Schema readerSchema)
Constructor. 
 | 
AvroKeyRecordWriter(Schema writerSchema,
                   CodecFactory compressionCodec,
                   OutputStream outputStream)
Constructor. 
 | 
AvroKeyValueRecordReader(Schema keyReaderSchema,
                        Schema valueReaderSchema)
Constructor. 
 | 
AvroRecordReaderBase(Schema readerSchema)
Constructor. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected Schema | 
ProtobufData.getRecordSchema(Object record)  | 
Schema | 
ProtobufData.getSchema(Class c)
Return a record schema given a protobuf message class. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
DatumReader | 
ProtobufData.createDatumReader(Schema schema)  | 
protected Object | 
ProtobufDatumReader.createEnum(String symbol,
          Schema schema)  | 
protected Object | 
ProtobufData.getRecordState(Object r,
              Schema s)  | 
Object | 
ProtobufData.newRecord(Object old,
         Schema schema)  | 
protected Object | 
ProtobufDatumReader.readRecord(Object old,
          Schema expected,
          ResolvingDecoder in)  | 
protected void | 
ProtobufDatumWriter.writeEnum(Schema schema,
         Object datum,
         Encoder out)  | 
| Constructor and Description | 
|---|
ProtobufDatumReader(Schema schema)
Construct where the writer's and reader's schemas are the same. 
 | 
ProtobufDatumReader(Schema writer,
                   Schema reader)
Construct given writer's and reader's schema. 
 | 
ProtobufDatumReader(Schema writer,
                   Schema reader,
                   ProtobufData data)  | 
ProtobufDatumWriter(Schema schema)  | 
ProtobufDatumWriter(Schema root,
                   ProtobufData protobufData)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected Schema | 
ReflectData.createFieldSchema(Field field,
                 Map<String,Schema> names)
Create a schema for a field. 
 | 
protected Schema | 
ReflectData.AllowNull.createFieldSchema(Field field,
                 Map<String,Schema> names)  | 
protected Schema | 
ReflectData.createSchema(Type type,
            Map<String,Schema> names)  | 
protected Schema | 
ReflectData.getRecordSchema(Object record)  | 
static Schema | 
ReflectData.makeNullable(Schema schema)
Create and return a union of the null schema and the provided schema. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected int | 
ReflectData.compare(Object o1,
       Object o2,
       Schema s,
       boolean equals)  | 
DatumReader | 
ReflectData.createDatumReader(Schema schema)  | 
Class | 
ReflectData.getClass(Schema schema)  | 
static Schema | 
ReflectData.makeNullable(Schema schema)
Create and return a union of the null schema and the provided schema. 
 | 
protected Object | 
ReflectDatumReader.newArray(Object old,
        int size,
        Schema schema)  | 
protected Object | 
ReflectDatumReader.readBytes(Object old,
         Schema s,
         Decoder in)  | 
protected Object | 
ReflectDatumReader.readInt(Object old,
       Schema expected,
       Decoder in)  | 
protected Object | 
ReflectDatumReader.readMapKey(Object old,
          Schema s,
          Decoder in)  | 
protected Object | 
ReflectDatumReader.readString(Object old,
          Schema s,
          Decoder in)  | 
boolean | 
ReflectData.validate(Schema schema,
        Object datum)  | 
protected void | 
ReflectDatumWriter.write(Schema schema,
     Object datum,
     Encoder out)  | 
protected void | 
ReflectDatumWriter.writeString(Schema schema,
           Object datum,
           Encoder out)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected Schema | 
ReflectData.createFieldSchema(Field field,
                 Map<String,Schema> names)
Create a schema for a field. 
 | 
protected Schema | 
ReflectData.AllowNull.createFieldSchema(Field field,
                 Map<String,Schema> names)  | 
protected Schema | 
ReflectData.createSchema(Type type,
            Map<String,Schema> names)  | 
| Constructor and Description | 
|---|
ReflectDatumReader(Schema root)
Construct where the writer's and reader's schemas are the same. 
 | 
ReflectDatumReader(Schema writer,
                  Schema reader)
Construct given writer's and reader's schema. 
 | 
ReflectDatumReader(Schema writer,
                  Schema reader,
                  ReflectData data)
Construct given writer's and reader's schema and the data model. 
 | 
ReflectDatumWriter(Schema root)  | 
ReflectDatumWriter(Schema root,
                  ReflectData reflectData)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected Schema | 
SpecificData.createSchema(Type type,
            Map<String,Schema> names)
Create the schema for a Java type. 
 | 
protected Schema | 
SpecificData.getEnumSchema(Object datum)  | 
abstract Schema | 
SpecificRecordBase.getSchema()  | 
abstract Schema | 
SpecificExceptionBase.getSchema()  | 
Schema | 
SpecificData.getSchema(Type type)
Find the schema for a Java type. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected int | 
SpecificData.compare(Object o1,
       Object o2,
       Schema s,
       boolean eq)  | 
DatumReader | 
SpecificData.createDatumReader(Schema schema)  | 
protected Object | 
SpecificDatumReader.createEnum(String symbol,
          Schema schema)  | 
Object | 
SpecificData.createFixed(Object old,
           Schema schema)  | 
Class | 
SpecificData.getClass(Schema schema)
Return the class that implements a schema, or null if none exists. 
 | 
static String | 
SpecificData.getClassName(Schema schema)
Returns the Java class name indicated by a schema's name and namespace. 
 | 
static Object | 
SpecificData.newInstance(Class c,
           Schema s)
Create an instance of a class. 
 | 
Object | 
SpecificData.newRecord(Object old,
         Schema schema)  | 
void | 
SpecificDatumReader.setSchema(Schema actual)  | 
protected void | 
SpecificDatumWriter.writeEnum(Schema schema,
         Object datum,
         Encoder out)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected Schema | 
SpecificData.createSchema(Type type,
            Map<String,Schema> names)
Create the schema for a Java type. 
 | 
| Constructor and Description | 
|---|
SpecificDatumReader(Schema schema)
Construct where the writer's and reader's schemas are the same. 
 | 
SpecificDatumReader(Schema writer,
                   Schema reader)
Construct given writer's and reader's schema. 
 | 
SpecificDatumReader(Schema writer,
                   Schema reader,
                   SpecificData data)
Construct given writer's schema, reader's schema, and a  
SpecificData. | 
SpecificDatumWriter(Schema schema)  | 
SpecificDatumWriter(Schema root,
                   SpecificData specificData)  | 
SpecificErrorBuilderBase(Schema schema)
Creates a SpecificErrorBuilderBase for building errors of the given type. 
 | 
SpecificRecordBuilderBase(Schema schema)
Creates a SpecificRecordBuilderBase for building records of the given type. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected Schema | 
ThriftData.getEnumSchema(Object datum)  | 
protected Schema | 
ThriftData.getRecordSchema(Object record)  | 
Schema | 
ThriftData.getSchema(Class c)
Return a record schema given a thrift generated class. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
DatumReader | 
ThriftData.createDatumReader(Schema schema)  | 
protected Object | 
ThriftDatumReader.createEnum(String symbol,
          Schema schema)  | 
protected Object | 
ThriftData.getRecordState(Object r,
              Schema s)  | 
protected Object | 
ThriftDatumReader.newArray(Object old,
        int size,
        Schema schema)  | 
Object | 
ThriftData.newRecord(Object old,
         Schema schema)  | 
protected Object | 
ThriftDatumReader.readInt(Object old,
       Schema s,
       Decoder in)  | 
| Constructor and Description | 
|---|
ThriftDatumReader(Schema schema)
Construct where the writer's and reader's schemas are the same. 
 | 
ThriftDatumReader(Schema writer,
                 Schema reader)
Construct given writer's and reader's schema. 
 | 
ThriftDatumReader(Schema writer,
                 Schema reader,
                 ThriftData data)  | 
ThriftDatumWriter(Schema schema)  | 
ThriftDatumWriter(Schema root,
                 ThriftData thriftData)  | 
| Modifier and Type | Method and Description | 
|---|---|
Schema | 
AvroColumnReader.getFileSchema()
Return the schema for data in this file. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
AvroColumnReader.Params | 
AvroColumnReader.Params.setSchema(Schema schema)
Set subset schema to project data down to. 
 | 
| Constructor and Description | 
|---|
AvroColumnWriter(Schema s,
                ColumnFileMetaData meta)  | 
AvroColumnWriter(Schema s,
                ColumnFileMetaData meta,
                GenericData model)  | 
Copyright © 2009-2012 The Apache Software Foundation. All Rights Reserved.