public interface SourceConverter extends ContextAware<AdapterContext>
EventFactory
, AdapterContext
Modifier and Type | Method and Description |
---|---|
boolean |
canHandleAcknowledges()
Can pass through acknowledges from the reliable source connector?
|
java.util.Iterator<Event> |
process(java.util.Iterator<java.lang.Object> data)
Processes the input data in external data format and converts to Oracle Stream Analytics Event format.
|
close, init
boolean canHandleAcknowledges()
java.util.Iterator<Event> process(java.util.Iterator<java.lang.Object> data)
data
- - iterator of data in external data format