[jira] [Closed] (FLINK-2755) Cluster Execution - /home/user/udfs.jar

["Till Rohrmann (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-2755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Till Rohrmann closed FLINK-2755.
--------------------------------
    Resolution: Incomplete

Your question should rather go to the user@flink.apache.org mailing list. Plus, could you elaborate on your problem a little bit more (in the mail to the mailing list).

> Cluster Execution - /home/user/udfs.jar
> ---------------------------------------
>
>                 Key: FLINK-2755
>                 URL: https://issues.apache.org/jira/browse/FLINK-2755
>             Project: Flink
>          Issue Type: Wish
>            Reporter: dengjie
>
> public static void main(String[] args) throws Exception {
>     ExecutionEnvironment env = ExecutionEnvironment
>         .createRemoteEnvironment("flink-master", 6123, "/home/user/udfs.jar");
>     DataSet<String> data = env.readTextFile("hdfs://path/to/file");
>     data
>         .filter(new FilterFunction<String>() {
>             public boolean filter(String value) {
>                 return value.startsWith("http://");
>             }
>         })
>         .writeAsText("hdfs://path/to/result");
>     env.execute();
> }
> How to write the file(udfs.jar),can you give an example?In addition,can this parameter as an option?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)