[ https://issues.apache.org/jira/browse/CAMEL-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258950#comment-15258950 ]
ASF GitHub Bot commented on CAMEL-9869: --------------------------------------- GitHub user sbcd90 opened a pull request: https://github.com/apache/camel/pull/962 [CAMEL-9869] Create Apache Flink Component Hello @davsclaus , I have enhanced the `camel-flink` producer implementation to support `Flink datastream`. Please review. You can merge this pull request into a Git repository by running: $ git pull https://github.com/sbcd90/camel CAMEL-9869 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/camel/pull/962.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #962 ---- commit 1bf04cffab70006f8763c2ec4a847708904a7959 Author: Subhobrata Dey <sbc...@gmail.com> Date: 2016-04-26T20:30:52Z [CAMEL-9869] Create Apache Flink Component ---- > Create Apache Flink Component > ----------------------------- > > Key: CAMEL-9869 > URL: https://issues.apache.org/jira/browse/CAMEL-9869 > Project: Camel > Issue Type: New Feature > Components: camel-flink > Reporter: Subhobrata Dey > Assignee: Claus Ibsen > Fix For: 2.18.0 > > > 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 > {noformat} > @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; > } > {noformat} > The results can be accessed like > {noformat} > Long count = > template.requestBody("flink:dataSet?dataSet=#myDataSet&dataSetCallback=#countLinesContaining", > pattern, Long.class); > {noformat} > Please review & accept my contribution. -- This message was sent by Atlassian JIRA (v6.3.4#6332)