public class DefaultSchemaPersistenceManager extends Object implements SchemaPersistenceManager, SchemaUpdatesReceiver
SchemaPersistenceManager
implementationConstructor and Description |
---|
DefaultSchemaPersistenceManager() |
DefaultSchemaPersistenceManager(SchemaProcessor processor) |
Modifier and Type | Method and Description |
---|---|
void |
onSchemaUpdated(org.apache.avro.Schema schema)
Called on each schema update
|
void |
setSchemaProcessor(SchemaProcessor processor) |
void |
setSchemaStorage(SchemaStorage storage)
Provide storage object which is able to persist configuration schema.
|
public DefaultSchemaPersistenceManager()
public DefaultSchemaPersistenceManager(SchemaProcessor processor)
public void onSchemaUpdated(org.apache.avro.Schema schema)
SchemaUpdatesReceiver
onSchemaUpdated
in interface SchemaUpdatesReceiver
schema
- new schemapublic void setSchemaStorage(SchemaStorage storage) throws IOException
SchemaPersistenceManager
setSchemaStorage
in interface SchemaPersistenceManager
storage
- object that saves and loads schema dataIOException
SchemaStorage
public void setSchemaProcessor(SchemaProcessor processor)
Copyright © 2015. All rights reserved.