flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "dengjie (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2755) Cluster Execution - /home/user/udfs.jar
Date Thu, 24 Sep 2015 09:52:35 GMT
dengjie created FLINK-2755:
------------------------------

             Summary: 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)

Mime
View raw message