com.oracle.cep.api.adapter.sink

Interface SinkConnector

All Superinterfaces:

ContextAware<AdapterContext>, java.io.Serializable

public interface SinkConnector
extends ContextAware<AdapterContext>

SinkConnectors represent the sink connector that receives the data and send it to an external system. They are responsible for transporting the data from Oracle Stream Analytics to the external system. The arriving data should already be converted to external data format that the external system understands. The conversion from Oracle Stream Analytics Event format is done by SinkConverters.

Since:

18.1.0.0.1

See Also:

SinkConverter

Method Summary

Modifier and Type	Method and Description
void	flush() Flushes the outputs to the external system if required.
void	put(java.util.Iterator<java.lang.Object> objects) Put the data into the external system.

Methods inherited from interface com.oracle.cep.api.adapter.ContextAware

close, init

Method Detail

put

void put(java.util.Iterator<java.lang.Object> objects)

Put the data into the external system.

Parameters:

objects - - iterator of objects of external data format

flush

void flush()

Flushes the outputs to the external system if required.