public class DataCacheWriter<T> extends Object
Constructor and Description |
---|
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) |
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) |
Modifier and Type | Method and Description |
---|---|
void |
addRecord(T record) |
void |
cleanup() |
List<Segment> |
finish() |
void |
finishCurrentSegment() |
org.apache.flink.core.fs.FileSystem |
getFileSystem() |
List<Segment> |
getFinishSegments() |
public 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) throws IOException
IOException
public 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) throws IOException
IOException
public void addRecord(T record) throws IOException
IOException
public void finishCurrentSegment() throws IOException
IOException
public List<Segment> finish() throws IOException
IOException
public org.apache.flink.core.fs.FileSystem getFileSystem()
public void cleanup() throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.