[CAMEL-9869] Create Apache Flink Component

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.18.0
• Component/s: camel-flink
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Subhobrata Dey
• Created: 15/Apr/16 02:04
• Updated: 29/Apr/16 12:29
• Resolved: 29/Apr/16 12:29

Description

Hello,

I have created an Apache Flink component for Camel which makes it easier to use Flink for analytics. One can use DataSet callbacks with Spring beans/OSGI services.

Using Spring's application context, it can be accessed like

@Bean
public DataSetCallback<Long> countLinesContaining() {
    return new DataSetCallback<Long>() {
        public Long onDataSet(DataSet dataSet, Object... objects) {
            try {
                dataSet.print();
                return new Long(0);
            } catch (Exception e) {
                return new Long(-1);
            }
        }
    };
}

@Bean
public DataSet myDataSet() {
    final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

    DataSet<String> text = env.fromElements(
            "Who's there?",
            "I think I hear them. Stand ho! Who's there?");

    return text;
}

The results can be accessed like

Long count = template.requestBody("flink:dataSet?dataSet=#myDataSet&dataSetCallback=#countLinesContaining", pattern, Long.class);

Please review & accept my contribution.