Toggle navigation
Home
scala.concurrent.Future to org.apache.flink.api.java.tuple.Tuple2
No. of Instances - 1
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Different)
Future<byte[]>
to
Future<Tuple2<Integer,Long>>
Update argument list (Method invocation)
getKvStateWithRetries
to
getKvStateWithRetries
Rename Variable
serializedResult
to
result
serializedResult
to
result