@PublicEvolving public final class OperatorStateCheckpointOutputStream extends NonClosingCheckpointOutputStream<OperatorStateHandle>
delegate
Constructor and Description |
---|
OperatorStateCheckpointOutputStream(CheckpointStateOutputStream delegate) |
Modifier and Type | Method and Description |
---|---|
int |
getNumberOfPartitions() |
void |
startNewPartition()
User code can call this method to signal that it begins to write a new partition of operator
state.
|
acquireLease, close, flush, write, write, write
public OperatorStateCheckpointOutputStream(CheckpointStateOutputStream delegate) throws IOException
IOException
public void startNewPartition() throws IOException
IOException
public int getNumberOfPartitions()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.