A C D E F G I O P R S V

A

AnnotatedDataSetCallback - Class in org.apache.camel.component.flink.annotations

Provides facade for working with annotated DataSet callbacks i.e.

AnnotatedDataSetCallback(Object, CamelContext) - Constructor for class org.apache.camel.component.flink.annotations.AnnotatedDataSetCallback

AnnotatedDataSetCallback(Object) - Constructor for class org.apache.camel.component.flink.annotations.AnnotatedDataSetCallback

C

collectResults(Exchange, Object) - Method in class org.apache.camel.component.flink.DataSetFlinkProducer

collectResults(Exchange, Object) - Method in class org.apache.camel.component.flink.DataStreamFlinkProducer

ConvertingDataSetCallback<T> - Class in org.apache.camel.component.flink

ConvertingDataSetCallback(CamelContext, Class...) - Constructor for class org.apache.camel.component.flink.ConvertingDataSetCallback

createConsumer(Processor) - Method in class org.apache.camel.component.flink.FlinkEndpoint

createEndpoint(String, String, Map<String, Object>) - Method in class org.apache.camel.component.flink.FlinkComponent

createExecutionEnvironment() - Static method in class org.apache.camel.component.flink.Flinks

createProducer() - Method in class org.apache.camel.component.flink.FlinkEndpoint

createStreamExecutionEnvironment() - Static method in class org.apache.camel.component.flink.Flinks

D

DataSetCallback - Annotation Type in org.apache.camel.component.flink.annotations

DataSetCallback<T> - Interface in org.apache.camel.component.flink

Generic block of code with parameters which can be executed against DataSet and return results.

DataSetFlinkProducer - Class in org.apache.camel.component.flink

DataSetFlinkProducer(FlinkEndpoint) - Constructor for class org.apache.camel.component.flink.DataSetFlinkProducer

DataStreamCallback<T> - Interface in org.apache.camel.component.flink

Generic block of code with parameters which can be executed against DataStream and return results.

DataStreamFlinkProducer - Class in org.apache.camel.component.flink

DataStreamFlinkProducer(FlinkEndpoint) - Constructor for class org.apache.camel.component.flink.DataStreamFlinkProducer

doOnDataSet(DataSet, Object...) - Method in class org.apache.camel.component.flink.ConvertingDataSetCallback

doOnDataSet(DataSet, Object...) - Method in class org.apache.camel.component.flink.VoidDataSetCallback

doOnDataStream(DataStream, Object...) - Method in class org.apache.camel.component.flink.VoidDataStreamCallback

doStart() - Method in class org.apache.camel.component.flink.FlinkEndpoint

E

EndpointType - Enum in org.apache.camel.component.flink

F

FLINK_DATASET_CALLBACK_HEADER - Static variable in class org.apache.camel.component.flink.FlinkConstants

FLINK_DATASET_HEADER - Static variable in class org.apache.camel.component.flink.FlinkConstants

FLINK_DATASTREAM_CALLBACK_HEADER - Static variable in class org.apache.camel.component.flink.FlinkConstants

FLINK_DATASTREAM_HEADER - Static variable in class org.apache.camel.component.flink.FlinkConstants

FlinkComponent - Class in org.apache.camel.component.flink

The flink component can be used to send DataSet or DataStream jobs to Apache Flink cluster.

FlinkComponent() - Constructor for class org.apache.camel.component.flink.FlinkComponent

FlinkConstants - Class in org.apache.camel.component.flink

FlinkEndpoint - Class in org.apache.camel.component.flink

The flink component can be used to send DataSet jobs to Apache Flink cluster.

FlinkEndpoint(String, FlinkComponent, EndpointType) - Constructor for class org.apache.camel.component.flink.FlinkEndpoint

Flinks - Class in org.apache.camel.component.flink

G

getComponent() - Method in class org.apache.camel.component.flink.FlinkEndpoint

getDataSet() - Method in class org.apache.camel.component.flink.FlinkComponent

getDataSet() - Method in class org.apache.camel.component.flink.FlinkEndpoint

getDataSetCallback() - Method in class org.apache.camel.component.flink.FlinkComponent

getDataSetCallback() - Method in class org.apache.camel.component.flink.FlinkEndpoint

getDataStream() - Method in class org.apache.camel.component.flink.FlinkComponent

getDataStream() - Method in class org.apache.camel.component.flink.FlinkEndpoint

getDataStreamCallback() - Method in class org.apache.camel.component.flink.FlinkComponent

getDataStreamCallback() - Method in class org.apache.camel.component.flink.FlinkEndpoint

getEndpoint() - Method in class org.apache.camel.component.flink.DataSetFlinkProducer

getEndpoint() - Method in class org.apache.camel.component.flink.DataStreamFlinkProducer

I

isCollect() - Method in class org.apache.camel.component.flink.FlinkEndpoint

isSingleton() - Method in class org.apache.camel.component.flink.FlinkEndpoint

O

onDataSet(DataSet, Object...) - Method in class org.apache.camel.component.flink.annotations.AnnotatedDataSetCallback

onDataSet(DataSet, Object...) - Method in class org.apache.camel.component.flink.ConvertingDataSetCallback

onDataSet(DataSet, Object...) - Method in interface org.apache.camel.component.flink.DataSetCallback

onDataSet(DataSet, Object...) - Method in class org.apache.camel.component.flink.VoidDataSetCallback

onDataStream(DataStream, Object...) - Method in interface org.apache.camel.component.flink.DataStreamCallback

onDataStream(DataStream, Object...) - Method in class org.apache.camel.component.flink.VoidDataStreamCallback

org.apache.camel.component.flink - package org.apache.camel.component.flink

org.apache.camel.component.flink.annotations - package org.apache.camel.component.flink.annotations

P

process(Exchange) - Method in class org.apache.camel.component.flink.DataSetFlinkProducer

process(Exchange) - Method in class org.apache.camel.component.flink.DataStreamFlinkProducer

R

resolveDataSet(Exchange) - Method in class org.apache.camel.component.flink.DataSetFlinkProducer

resolveDataSetCallback(Exchange) - Method in class org.apache.camel.component.flink.DataSetFlinkProducer

resolveDataStream(Exchange) - Method in class org.apache.camel.component.flink.DataStreamFlinkProducer

resolveDataStreamCallback(Exchange) - Method in class org.apache.camel.component.flink.DataStreamFlinkProducer

S

setCollect(boolean) - Method in class org.apache.camel.component.flink.FlinkEndpoint

Indicates if results should be collected or counted.

setDataSet(DataSet) - Method in class org.apache.camel.component.flink.FlinkComponent

DataSet to compute against.

setDataSet(DataSet) - Method in class org.apache.camel.component.flink.FlinkEndpoint

DataSet to compute against.

setDataSetCallback(DataSetCallback) - Method in class org.apache.camel.component.flink.FlinkComponent

Function performing action against a DataSet.

setDataSetCallback(DataSetCallback) - Method in class org.apache.camel.component.flink.FlinkEndpoint

Function performing action against a DataSet.

setDataStream(DataStream) - Method in class org.apache.camel.component.flink.FlinkComponent

DataStream to compute against.

setDataStream(DataStream) - Method in class org.apache.camel.component.flink.FlinkEndpoint

DataStream to compute against.

setDataStreamCallback(DataStreamCallback) - Method in class org.apache.camel.component.flink.FlinkComponent

Function performing action against a DataStream.

setDataStreamCallback(DataStreamCallback) - Method in class org.apache.camel.component.flink.FlinkEndpoint

Function performing action against a DataStream.

setEndpointType(EndpointType) - Method in class org.apache.camel.component.flink.FlinkEndpoint

Type of the endpoint (dataset, datastream).

V

valueOf(String) - Static method in enum org.apache.camel.component.flink.EndpointType

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.camel.component.flink.EndpointType

Returns an array containing the constants of this enum type, in the order they are declared.

VoidDataSetCallback - Class in org.apache.camel.component.flink

VoidDataSetCallback() - Constructor for class org.apache.camel.component.flink.VoidDataSetCallback

VoidDataStreamCallback - Class in org.apache.camel.component.flink

VoidDataStreamCallback() - Constructor for class org.apache.camel.component.flink.VoidDataStreamCallback

A C D E F G I O P R S V