Package | Description |
---|---|
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.io | |
org.apache.avro.io |
Utilities for Encoding and Decoding Avro data.
|
org.apache.avro.ipc.generic | |
org.apache.avro.ipc.reflect | |
org.apache.avro.ipc.specific | |
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.
|
Modifier and Type | Class and Description |
---|---|
static class |
Json.ObjectReader
DatumReader for arbitrary Json data using the object model described
in JsonProperties . |
Modifier and Type | Method and Description |
---|---|
static <D> FileReader<D> |
DataFileReader.openReader(File file,
DatumReader<D> reader)
Open a reader for a file.
|
static <D> FileReader<D> |
DataFileReader.openReader(SeekableInput in,
DatumReader<D> reader)
Open a reader for a file.
|
static <D> DataFileReader<D> |
DataFileReader.openReader(SeekableInput in,
DatumReader<D> reader,
DataFileStream.Header header,
boolean sync)
Construct a reader for a file at the current position of the input, without
reading the header.
|
Constructor and Description |
---|
DataFileReader(File file,
DatumReader<D> reader)
Construct a reader for a file.
|
DataFileReader(SeekableInput sin,
DatumReader<D> reader)
Construct a reader for a file.
|
DataFileReader(SeekableInput sin,
DatumReader<D> reader,
boolean closeOnError,
byte[] magic)
Construct a reader for a file.
|
DataFileReader(SeekableInput sin,
DatumReader<D> reader,
DataFileStream.Header header)
Construct using a
DataFileStream.Header . |
DataFileReader12(SeekableInput sin,
DatumReader<D> reader)
Construct a reader for a file.
|
DataFileStream(DatumReader<D> reader)
create an uninitialized DataFileStream
|
DataFileStream(InputStream in,
DatumReader<D> reader)
Construct a reader for an input stream.
|
Modifier and Type | Class and Description |
---|---|
class |
GenericDatumReader<D>
DatumReader for generic Java objects. |
Modifier and Type | Method and Description |
---|---|
DatumReader |
GenericData.createDatumReader(Schema schema)
Returns a
DatumReader for this kind of data. |
DatumReader |
GenericData.createDatumReader(Schema writer,
Schema reader)
Returns a
DatumReader for this kind of data. |
Constructor and Description |
---|
AvroDeserializer(Schema writerSchema,
Schema readerSchema,
DatumReader<D> datumReader)
Constructor.
|
AvroKeyDeserializer(Schema writerSchema,
Schema readerSchema,
DatumReader<D> datumReader)
Constructor.
|
AvroValueDeserializer(Schema writerSchema,
Schema readerSchema,
DatumReader<D> datumReader)
Constructor.
|
Modifier and Type | Interface and Description |
---|---|
static interface |
FastReaderBuilder.FieldReader |
static interface |
FastReaderBuilder.ReusingFieldReader |
Modifier and Type | Class and Description |
---|---|
static class |
FastReaderBuilder.MapReader |
static class |
FastReaderBuilder.RecordReader |
Modifier and Type | Method and Description |
---|---|
<D> DatumReader<D> |
FastReaderBuilder.createDatumReader(Schema schema) |
<D> DatumReader<D> |
FastReaderBuilder.createDatumReader(Schema writerSchema,
Schema readerSchema) |
Modifier and Type | Method and Description |
---|---|
protected DatumReader<Object> |
GenericResponder.getDatumReader(Schema actual,
Schema expected) |
Modifier and Type | Method and Description |
---|---|
protected DatumReader<Object> |
ReflectResponder.getDatumReader(Schema actual,
Schema expected) |
protected DatumReader<Object> |
ReflectRequestor.getDatumReader(Schema writer,
Schema reader) |
Modifier and Type | Method and Description |
---|---|
protected DatumReader<Object> |
SpecificRequestor.getDatumReader(Schema schema)
Deprecated.
|
protected DatumReader<Object> |
SpecificResponder.getDatumReader(Schema actual,
Schema expected) |
protected DatumReader<Object> |
SpecificRequestor.getDatumReader(Schema writer,
Schema reader) |
Modifier and Type | Method and Description |
---|---|
protected DataFileReader<T> |
AvroRecordReaderBase.createAvroFileReader(SeekableInput input,
DatumReader<T> datumReader)
Creates an Avro container file reader from a seekable input stream.
|
Modifier and Type | Class and Description |
---|---|
class |
ProtobufDatumReader<T>
DatumReader for generated Protobuf
classes. |
Modifier and Type | Method and Description |
---|---|
DatumReader |
ProtobufData.createDatumReader(Schema schema) |
Modifier and Type | Class and Description |
---|---|
class |
ReflectDatumReader<T>
DatumReader for existing classes via
Java reflection. |
Modifier and Type | Method and Description |
---|---|
DatumReader |
ReflectData.createDatumReader(Schema schema) |
DatumReader |
ReflectData.createDatumReader(Schema writer,
Schema reader) |
Modifier and Type | Class and Description |
---|---|
class |
SpecificDatumReader<T>
DatumReader for generated Java
classes. |
Modifier and Type | Method and Description |
---|---|
DatumReader |
SpecificData.createDatumReader(Schema schema) |
DatumReader |
SpecificData.createDatumReader(Schema writer,
Schema reader) |
Modifier and Type | Class and Description |
---|---|
class |
ThriftDatumReader<T>
DatumReader for generated Thrift
classes. |
Modifier and Type | Method and Description |
---|---|
DatumReader |
ThriftData.createDatumReader(Schema schema) |
Copyright © 2009–2022 The Apache Software Foundation. All rights reserved.