public interface GenericDeltaReceiver
Modifier and Type | Method and Description |
---|---|
void |
onDeltaReceived(int index,
org.apache.avro.generic.GenericRecord data,
boolean fullResync)
Called on each deserialized delta
|
void onDeltaReceived(int index, org.apache.avro.generic.GenericRecord data, boolean fullResync)
index
- Index of the current delta in the union listdata
- Avro generic object with deserialized deltafullResync
- Tells if current delta is a full resyncCopyright © 2014. All rights reserved.