public class Checkpoints<T> extends Object implements AutoCloseable
Constructor and Description |
---|
Checkpoints(org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer,
org.apache.flink.core.fs.FileSystem fileSystem,
org.apache.flink.util.function.SupplierWithException<org.apache.flink.core.fs.Path,IOException> pathSupplier) |
Modifier and Type | Method and Description |
---|---|
void |
abort(long checkpointId) |
void |
append(T element) |
void |
close() |
void |
commitCheckpointsUntil(long checkpointId) |
org.apache.flink.core.fs.FileSystem |
getFileSystem() |
org.apache.flink.util.function.SupplierWithException<org.apache.flink.core.fs.Path,IOException> |
getPathSupplier() |
org.apache.flink.api.common.typeutils.TypeSerializer<T> |
getTypeSerializer() |
void |
startLogging(long checkpointId,
org.apache.flink.runtime.state.OperatorStateCheckpointOutputStream outputStream) |
public Checkpoints(org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer, org.apache.flink.core.fs.FileSystem fileSystem, org.apache.flink.util.function.SupplierWithException<org.apache.flink.core.fs.Path,IOException> pathSupplier)
public org.apache.flink.api.common.typeutils.TypeSerializer<T> getTypeSerializer()
public org.apache.flink.core.fs.FileSystem getFileSystem()
public org.apache.flink.util.function.SupplierWithException<org.apache.flink.core.fs.Path,IOException> getPathSupplier()
public void startLogging(long checkpointId, org.apache.flink.runtime.state.OperatorStateCheckpointOutputStream outputStream) throws IOException
IOException
public void abort(long checkpointId)
public void append(T element) throws IOException
IOException
public void commitCheckpointsUntil(long checkpointId)
public void close()
close
in interface AutoCloseable
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.