Package | Description |
---|---|
org.apache.avro.data |
Interfaces and base classes shared by generic, specific and reflect.
|
org.apache.avro.generic |
A generic representation for Avro data.
|
org.apache.avro.hadoop.file | |
org.apache.avro.hadoop.io | |
org.apache.avro.ipc.generic | |
org.apache.avro.mapred |
Run Hadoop MapReduce jobs over
Avro data, with map and reduce functions written in Java.
|
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 | Method and Description |
---|---|
protected GenericData |
RecordBuilderBase.data() |
Constructor and Description |
---|
RecordBuilderBase(RecordBuilderBase<T> other,
GenericData data)
RecordBuilderBase copy constructor.
|
RecordBuilderBase(Schema schema,
GenericData data)
Creates a RecordBuilderBase for building records of the given type.
|
Modifier and Type | Method and Description |
---|---|
static GenericData |
GenericData.get()
Return the singleton instance.
|
GenericData |
GenericDatumReader.getData()
Return the
GenericData implementation. |
GenericData |
GenericDatumWriter.getData()
Return the
GenericData implementation. |
Constructor and Description |
---|
GenericDatumReader(GenericData data) |
GenericDatumReader(Schema writer,
Schema reader,
GenericData data) |
GenericDatumWriter(GenericData data) |
GenericDatumWriter(Schema root,
GenericData data) |
Modifier and Type | Method and Description |
---|---|
GenericData |
SortedKeyValueFile.Reader.Options.getDataModel()
Return the data model.
|
GenericData |
SortedKeyValueFile.Writer.Options.getDataModel()
Return the data model.
|
Modifier and Type | Method and Description |
---|---|
SortedKeyValueFile.Reader.Options |
SortedKeyValueFile.Reader.Options.withDataModel(GenericData model)
Set the data model.
|
SortedKeyValueFile.Writer.Options |
SortedKeyValueFile.Writer.Options.withDataModel(GenericData model)
Set the data model.
|
Modifier and Type | Method and Description |
---|---|
static GenericData |
AvroSerialization.createDataModel(Configuration conf)
Gets an instance of data model implementation, defaulting to
ReflectData if not explicitly specified. |
Modifier and Type | Method and Description |
---|---|
static Class<? extends GenericData> |
AvroSerialization.getDataModelClass(Configuration conf)
Gets the data model class for de/seralization.
|
Modifier and Type | Method and Description |
---|---|
static void |
AvroSerialization.setDataModelClass(Configuration conf,
Class<? extends GenericData> modelClass)
Sets the data model class for de/seralization.
|
Modifier and Type | Method and Description |
---|---|
GenericData |
GenericRequestor.getGenericData() |
GenericData |
GenericResponder.getGenericData() |
Constructor and Description |
---|
GenericRequestor(Protocol protocol,
Transceiver transceiver,
GenericData data) |
GenericResponder(Protocol local,
GenericData data) |
Modifier and Type | Method and Description |
---|---|
static GenericData |
AvroJob.createDataModel(Configuration conf) |
static GenericData |
AvroJob.createInputDataModel(Configuration conf) |
static GenericData |
AvroJob.createMapOutputDataModel(Configuration conf) |
Modifier and Type | Method and Description |
---|---|
static Class<? extends GenericData> |
AvroJob.getDataModelClass(Configuration conf)
Return the job's data model implementation class.
|
Modifier and Type | Method and Description |
---|---|
static void |
AvroJob.setDataModelClass(JobConf job,
Class<? extends GenericData> modelClass)
Configure a job's data model implementation class.
|
Modifier and Type | Method and Description |
---|---|
protected RecordWriter<AvroKey<T>,NullWritable> |
AvroKeyOutputFormat.RecordWriterFactory.create(Schema writerSchema,
GenericData dataModel,
CodecFactory compressionCodec,
OutputStream outputStream,
int syncInterval)
Creates a new record writer instance.
|
Modifier and Type | Method and Description |
---|---|
static void |
AvroJob.setDataModelClass(Job job,
Class<? extends GenericData> modelClass)
Sets the job data model class.
|
Constructor and Description |
---|
AvroKeyRecordWriter(Schema writerSchema,
GenericData dataModel,
CodecFactory compressionCodec,
OutputStream outputStream)
Constructor.
|
AvroKeyRecordWriter(Schema writerSchema,
GenericData dataModel,
CodecFactory compressionCodec,
OutputStream outputStream,
int syncInterval)
Constructor.
|
AvroKeyValueRecordWriter(AvroDatumConverter<K,?> keyConverter,
AvroDatumConverter<V,?> valueConverter,
GenericData dataModel,
CodecFactory compressionCodec,
OutputStream outputStream)
Constructor.
|
AvroKeyValueRecordWriter(AvroDatumConverter<K,?> keyConverter,
AvroDatumConverter<V,?> valueConverter,
GenericData dataModel,
CodecFactory compressionCodec,
OutputStream outputStream,
int syncInterval)
Constructor.
|
Modifier and Type | Class and Description |
---|---|
class |
ProtobufData
Utilities for serializing Protobuf data in Avro format.
|
Modifier and Type | Class and Description |
---|---|
class |
ReflectData
Utilities to use existing Java classes and interfaces via reflection.
|
static class |
ReflectData.AllowNull
ReflectData implementation that permits null field values. |
Modifier and Type | Class and Description |
---|---|
class |
SpecificData
Utilities for generated Java classes and interfaces.
|
Modifier and Type | Class and Description |
---|---|
class |
ThriftData
Utilities for serializing Thrift data in Avro format.
|
Modifier and Type | Method and Description |
---|---|
AvroColumnReader.Params |
AvroColumnReader.Params.setModel(GenericData model)
Set data representation.
|
Constructor and Description |
---|
AvroColumnWriter(Schema s,
ColumnFileMetaData meta,
GenericData model) |
Copyright © 2009-2014 The Apache Software Foundation. All Rights Reserved.