DataCacheReader(org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer,
org.apache.flink.core.fs.FileSystem fileSystem,
List<Segment> segments) |
DataCacheReader(org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer,
org.apache.flink.core.fs.FileSystem fileSystem,
List<Segment> segments,
org.apache.flink.api.java.tuple.Tuple2<Integer,Integer> readerPosition) |
DataCacheSnapshot(org.apache.flink.core.fs.FileSystem fileSystem,
org.apache.flink.api.java.tuple.Tuple2<Integer,Integer> readerPosition,
List<Segment> segments) |
DataCacheWriter(org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer,
org.apache.flink.core.fs.FileSystem fileSystem,
org.apache.flink.util.function.SupplierWithException<org.apache.flink.core.fs.Path,IOException> pathGenerator,
List<Segment> priorFinishedSegments) |