org.apache.hadoop.hive.serde2.avro

Class AvroSchemaRetriever

java.lang.Object

org.apache.hadoop.hive.serde2.avro.AvroSchemaRetriever

public abstract class AvroSchemaRetriever
extends Object

Retrieves the avro schema from the given source. "Source" is a little loose term here in the sense it can range from being an HDFS url location pointing to the schema or it can be even as simple as a properties file with a simple key-value mapping to the schema. For cases where the schema is a part of the serialized data itself, "Source" would refer to the data bytes from which the schema has to retrieved.

Constructor Summary

Constructors

Constructor and Description
AvroSchemaRetriever()

Method Summary

Modifier and Type	Method and Description
int	getOffset() Possible offset associated with schema.
org.apache.avro.Schema	retrieveReaderSchema(Object source) Retrieve the reader avro schema from the given source
abstract org.apache.avro.Schema	retrieveWriterSchema(Object source) Retrieve the writer avro schema from the given source

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AvroSchemaRetriever

public AvroSchemaRetriever()

Method Detail

retrieveWriterSchema

public abstract org.apache.avro.Schema retrieveWriterSchema(Object source)

Retrieve the writer avro schema from the given source

Parameters:

source - source from which the schema has to retrieved

Returns:

the retrieved writer Schema

retrieveReaderSchema

public org.apache.avro.Schema retrieveReaderSchema(Object source)

Retrieve the reader avro schema from the given source

Parameters:

source - source from which the schema has to retrieved

Returns:

the retrieved reader Schema

getOffset

public int getOffset()

Possible offset associated with schema. This is useful when the schema is stored inline along with the data.

Defaulted to zero. Consumers can choose to override this value to provide a custom offset.