public class DataCacheSnapshot extends Object
Constructor and Description |
---|
DataCacheSnapshot(org.apache.flink.core.fs.FileSystem fileSystem,
org.apache.flink.api.java.tuple.Tuple2<Integer,Integer> readerPosition,
List<Segment> segments) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.core.fs.FileSystem |
getFileSystem() |
org.apache.flink.api.java.tuple.Tuple2<Integer,Integer> |
getReaderPosition() |
List<Segment> |
getSegments() |
static DataCacheSnapshot |
recover(InputStream checkpointInputStream,
org.apache.flink.core.fs.FileSystem fileSystem,
org.apache.flink.util.function.SupplierWithException<org.apache.flink.core.fs.Path,IOException> pathGenerator) |
static <T> void |
replay(InputStream checkpointInputStream,
org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer,
org.apache.flink.core.fs.FileSystem fileSystem,
org.apache.flink.statefun.flink.core.feedback.FeedbackConsumer<T> feedbackConsumer) |
void |
writeTo(OutputStream checkpointOutputStream) |
public org.apache.flink.core.fs.FileSystem getFileSystem()
@Nullable public org.apache.flink.api.java.tuple.Tuple2<Integer,Integer> getReaderPosition()
public void writeTo(OutputStream checkpointOutputStream) throws IOException
IOException
public static <T> void replay(InputStream checkpointInputStream, org.apache.flink.api.common.typeutils.TypeSerializer<T> serializer, org.apache.flink.core.fs.FileSystem fileSystem, org.apache.flink.statefun.flink.core.feedback.FeedbackConsumer<T> feedbackConsumer) throws Exception
Exception
public static DataCacheSnapshot recover(InputStream checkpointInputStream, org.apache.flink.core.fs.FileSystem fileSystem, org.apache.flink.util.function.SupplierWithException<org.apache.flink.core.fs.Path,IOException> pathGenerator) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.