public interface StreamsPersistWriter extends StreamsOperation
Modifier and Type | Method and Description |
---|---|
void |
write(StreamsDatum entry)
Persist the StreamsDatum to the corresponding data store.
|
cleanUp, getId, prepare
void write(StreamsDatum entry)
entry
- to be stored.Copyright © 2017 The Apache Software Foundation. All rights reserved.