Package 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	Description
protected static final String	AVRO_SCHEMA_EXT
protected final Path	schemaDirectoryPath
protected final Map<Long,org.apache.avro.Schema>	schemas

Constructor Summary

Constructors

Constructor	Description
FileAvroSchemaStore(Path schemaDirectoryPath)

Method Summary

Modifier and Type	Method	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)
protected String	getFilename(String prefix, 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.
protected void	loadSchemasEndingWith(Path directory, String pattern)	Loads all avro schema files from this directory that end with the pattern.

Methods inherited from class java.lang.Object

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

Field Details

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 Details

FileAvroSchemaStore

public FileAvroSchemaStore(Path schemaDirectoryPath)

Method Details

loadSchemas

public void loadSchemas(Path directory)

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

loadSchemasEndingWith

protected void loadSchemasEndingWith(Path directory,
 String pattern)

Loads all avro schema files from this directory that end with the pattern.

Since:

11.5

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

getFilename

protected String getFilename(String prefix,
 long fingerprint)

findByFingerprint

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

Specified by:

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