org.nuxeo.lib.stream.codec

Class FileAvroSchemaStore

java.lang.Object

org.nuxeo.lib.stream.codec.FileAvroSchemaStore

All Implemented Interfaces:

org.apache.avro.message.SchemaStore, AvroSchemaStore

public class FileAvroSchemaStore
extends Object
implements AvroSchemaStore

Very simple SchemaStore that uses a file storage to persists its schemas.

Since:

10.3

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.avro.message.SchemaStore

org.apache.avro.message.SchemaStore.Cache

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	AVRO_SCHEMA_EXT
protected Path	schemaDirectoryPath
protected Map<Long,org.apache.avro.Schema>	schemas

Constructor Summary

Constructors

Constructor and Description
FileAvroSchemaStore(Path schemaDirectoryPath)

Method Summary

Modifier and Type	Method and Description
long	addSchema(org.apache.avro.Schema schema) Adds a schema to the store and returns its fingerprint.
org.apache.avro.Schema	findByFingerprint(long fingerprint)
void	loadSchema(Path schemaPath) Load the avro schema from this file.
void	loadSchemas(Path directory) Load all avro schema files from this directory.

Methods inherited from class java.lang.Object

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

Field Detail

AVRO_SCHEMA_EXT

protected static final String AVRO_SCHEMA_EXT

See Also:

Constant Field Values

schemaDirectoryPath

protected final Path schemaDirectoryPath

schemas

protected final Map<Long,org.apache.avro.Schema> schemas

Constructor Detail

FileAvroSchemaStore

public FileAvroSchemaStore(Path schemaDirectoryPath)

Method Detail

loadSchemas

public void loadSchemas(Path directory)

Load all avro schema files from this directory. Files must have the .avsc extention.

loadSchema

public void loadSchema(Path schemaPath)

Load the avro schema from this file.

addSchema

public long addSchema(org.apache.avro.Schema schema)

Description copied from interface: AvroSchemaStore

Adds a schema to the store and returns its fingerprint.

Specified by:

addSchema in interface AvroSchemaStore

findByFingerprint

public org.apache.avro.Schema findByFingerprint(long fingerprint)

Specified by:

findByFingerprint in interface org.apache.avro.message.SchemaStore