flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Deng Jie <smartdeng...@gmail.com>
Subject /home/user/udfs.jar same question
Date Fri, 25 Sep 2015 01:48:04 GMT
Dear Flink org,i have same question,like:

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 me an example?In addition,can
this parameter as an option?

-- Best wishes for you

Mime
View raw message