Note that this will only work when running the the application in the
IDE; specifically it will not work when running on an actual cluster,
since your function isn't executed on the same machine as your
(presumably) main[] function.
We can give you better advice if you tell us what exactly you're trying
to achieve.
On 24/07/2019 14:53, Caizhi Weng wrote:
Hi Andres,
Just define a variable outside and modify it in the anonymous class.
Andres Angel <ingenieroandresan...@gmail.com
<mailto:ingenieroandresan...@gmail.com>> 于2019年7月24日周三
下午8:44写道：
Hello everyone,
I was wondering if there is a way how to read the content of a
varible build within a map/flatmap function out of the DS method.
example:
DataStream<String> dsString =
env.fromElements("1,a,1.1|2,b,2.2,-2", "3,c|4,d,4.4");
DataStream<Object> dsTuple = dsString.flatMap(new
FlatMapFunction<String, Object>() {
@Override
public void flatMap(String value, Collector<Object> out)
throws Exception {
String var1 = "dummy";
}
});
System.out.print(var1);
thanks so much
