public class FileAvroSchemaStore extends Object implements AvroSchemaStore
Modifier and Type | Field and Description |
---|---|
protected static String |
AVRO_SCHEMA_EXT |
protected Path |
schemaDirectoryPath |
protected Map<Long,org.apache.avro.Schema> |
schemas |
Constructor and Description |
---|
FileAvroSchemaStore(Path schemaDirectoryPath) |
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.
|
protected static final String AVRO_SCHEMA_EXT
protected final Path schemaDirectoryPath
public FileAvroSchemaStore(Path schemaDirectoryPath)
public void loadSchemas(Path directory)
public void loadSchema(Path schemaPath)
public long addSchema(org.apache.avro.Schema schema)
AvroSchemaStore
addSchema
in interface AvroSchemaStore
public org.apache.avro.Schema findByFingerprint(long fingerprint)
findByFingerprint
in interface org.apache.avro.message.SchemaStore
Copyright © 2019 Nuxeo. All rights reserved.