Apache Flink 1.0.0'da referans yöntemleri destekleniyor mu?

Question

Bu kod çalışıyor:

.keyBy(value -> value.getSessionUid()) 

ama bu

.keyBy(LogItem::getSessionUid) 

atmak istisna:

Exception in thread "main" java.lang.ArrayIndexOutOfBoundsException: -1 
    at org.apache.flink.api.java.typeutils.TypeExtractor.getUnaryOperatorReturnType(TypeExtractor.java:294) 
    at org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelectorTypes(TypeExtractor.java:253) 
    at org.apache.flink.api.java.typeutils.TypeExtractor.getKeySelectorTypes(TypeExtractor.java:246) 
    at org.apache.flink.streaming.api.datastream.KeyedStream.<init>(KeyedStream.java:87) 
    at org.apache.flink.streaming.api.datastream.DataStream.keyBy(DataStream.java:241) 
    at streamer_sessions_aggregator.StreamerSessionAggregator.runFlow(StreamerSessionAggregator.java:40) 
    at streamer_sessions_aggregator.Main.main(Main.java:10) 
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) 
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) 
    at java.lang.reflect.Method.invoke(Method.java:497) 
    at com.intellij.rt.execution.application.AppMain.main(AppMain.java:144) 

Apache Flink 1.0.0 şimdi referans yöntemleri desteklemez anlamak gibi. Sağ?

Answer 1

Flink, şu anda referans yöntemlerini desteklemiyor. İşte bunun için destek eklemek için JIRA: https://issues.apache.org/jira/browse/FLINK-3138