/home/user/udfs.jar same question
Posted by
Deng Jie on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/home-user-udfs-jar-same-question-tp2940.html
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?