public class DefaultSchemaProcessor extends Object implements SchemaProcessor, SchemaObservable
Constructor and Description |
---|
DefaultSchemaProcessor() |
Modifier and Type | Method and Description |
---|---|
org.apache.avro.Schema |
getSchema()
Retrieves current schema object.
|
void |
loadSchema(ByteBuffer buffer)
Loads new schema from the buffer.
|
void |
subscribeForSchemaUpdates(SchemaUpdatesReceiver receiver)
Subscribes new receiver for schema updates
|
void |
unsubscribeFromSchemaUpdates(SchemaUpdatesReceiver receiver)
Unsubscribes receiver from schema updates
|
public org.apache.avro.Schema getSchema()
SchemaProcessor
getSchema
in interface SchemaProcessor
Schema
public void loadSchema(ByteBuffer buffer) throws IOException
SchemaProcessor
loadSchema
in interface SchemaProcessor
buffer
- schema bufferIOException
- in case of loading schema failurepublic void subscribeForSchemaUpdates(SchemaUpdatesReceiver receiver)
SchemaObservable
subscribeForSchemaUpdates
in interface SchemaObservable
receiver
- receiver to get schema updatespublic void unsubscribeFromSchemaUpdates(SchemaUpdatesReceiver receiver)
SchemaObservable
unsubscribeFromSchemaUpdates
in interface SchemaObservable
receiver
- receiver to be unsubscribed from schema updatesCopyright © 2014. All rights reserved.