camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Claus Ibsen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (CAMEL-9869) Create Apache Flink Component
Date Mon, 25 Apr 2016 06:42:13 GMT

    [ 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)

Mime
View raw message