Package | Description |
---|---|
org.apache.flink.iteration.datacache.nonkeyed |
Modifier and Type | Method and Description |
---|---|
List<Segment> |
DataCacheWriter.finish()
Finishes adding records and closes resources occupied for adding records.
|
List<Segment> |
DataCacheWriter.getSegments()
Flushes all added records to segments and returns a list of segments containing all cached
records.
|
List<Segment> |
DataCacheSnapshot.getSegments() |
Constructor and Description |
---|
DataCacheReader(org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer,
List<Segment> segments) |
DataCacheReader(org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer,
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) |
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,
org.apache.flink.table.runtime.util.MemorySegmentPool segmentPool,
List<Segment> priorFinishedSegments) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.