default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.collect(boolean collect) |
Indicates if results should be collected or counted.
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.collect(String collect) |
Indicates if results should be collected or counted.
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.dataSet(Object dataSet) |
DataSet to compute against.
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.dataSet(String dataSet) |
DataSet to compute against.
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.dataSetCallback(Object dataSetCallback) |
Function performing action against a DataSet.
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.dataSetCallback(String dataSetCallback) |
Function performing action against a DataSet.
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.dataStream(Object dataStream) |
DataStream to compute against.
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.dataStream(String dataStream) |
DataStream to compute against.
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.dataStreamCallback(Object dataStreamCallback) |
Function performing action against a DataStream.
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.dataStreamCallback(String dataStreamCallback) |
Function performing action against a DataStream.
|
static FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.endpointBuilder(String componentName,
String path) |
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkBuilders.flink(String path) |
Flink (camel-flink)
Send DataSet jobs to an Apache Flink cluster.
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkBuilders.flink(String componentName,
String path) |
Flink (camel-flink)
Send DataSet jobs to an Apache Flink cluster.
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default FlinkEndpointBuilderFactory.FlinkEndpointBuilder |
FlinkEndpointBuilderFactory.FlinkEndpointBuilder.lazyStartProducer(String lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|