参照方法はApache Flink 1.0.0でサポートされていますか？

Question

このコードは正常に動作します：

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

が、この

.keyBy(LogItem::getSessionUid) 

スロー例外：

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は、現在の参照方法をサポートしていません理解しています。右？

Answer 1

現在、Flinkは参照方法をサポートしていません。サポートを追加するJIRAは次のとおりです：https://issues.apache.org/jira/browse/FLINK-3138