[
https://issues.apache.org/jira/browse/CAMEL-9869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15255965#comment-15255965
]
Claus Ibsen commented on CAMEL-9869:
------------------------------------
Thanks for the PR. The code has been merged.
Are you working on the datastream mode as well for the producer?
And we would need some documentation to go along with it when its more ready.
We can talk about this later when we get the other bits finished first.
> 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)
