Package | Description |
---|---|
org.apache.camel.component.flink |
Modifier and Type | Class and Description |
---|---|
class |
VoidDataStreamCallback |
Modifier and Type | Method and Description |
---|---|
DataStreamCallback |
FlinkEndpoint.getDataStreamCallback() |
DataStreamCallback |
FlinkComponent.getDataStreamCallback() |
protected DataStreamCallback |
DataStreamFlinkProducer.resolveDataStreamCallback(org.apache.camel.Exchange exchange) |
Modifier and Type | Method and Description |
---|---|
void |
FlinkEndpoint.setDataStreamCallback(DataStreamCallback dataStreamCallback)
Function performing action against a DataStream.
|
void |
FlinkComponent.setDataStreamCallback(DataStreamCallback dataStreamCallback)
Function performing action against a DataStream.
|
Apache Camel