[
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 [email protected] 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)
