Re: /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-tp2940p2942.html

Dear Chiwan,

However, 'createRemoteEnvironment' method must specify this parameter.

2015-09-25 13:42 GMT+08:00 Chiwan Park <[hidden email]>:

Hi Deng,

The jarFiles parameter of `createRemoteEnvironment` means that the path of your custom library jar. If you don’t need custom library, you can omit the parameter.

Regards,
Chiwan Park

> On Sep 25, 2015, at 10:48 AM, Deng Jie <[hidden email]> wrote:
>
> 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