Modifier and Type | Method and Description |
---|---|
static <OUT,OP extends StreamOperator<OUT>> |
snapshot(OP operator,
int index,
long timestamp,
boolean isExactlyOnceMode,
boolean isUnalignedCheckpoint,
CheckpointStorageWorkerView checkpointStorage,
Path savepointPath) |
public static <OUT,OP extends StreamOperator<OUT>> TaggedOperatorSubtaskState snapshot(OP operator, int index, long timestamp, boolean isExactlyOnceMode, boolean isUnalignedCheckpoint, CheckpointStorageWorkerView checkpointStorage, Path savepointPath) throws Exception
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.