public interface CheckpointedStreamOperations
Modifier and Type | Method and Description |
---|---|
java.io.Closeable |
acquireLease(java.io.OutputStream keyedStateCheckpointOutputStream) |
void |
requireKeyedStateCheckpointed(java.io.OutputStream keyedStateCheckpointOutputStream) |
void |
startNewKeyGroup(java.io.OutputStream stream,
int keyGroup) |
void requireKeyedStateCheckpointed(java.io.OutputStream keyedStateCheckpointOutputStream)
void startNewKeyGroup(java.io.OutputStream stream, int keyGroup) throws java.io.IOException
java.io.IOException
java.io.Closeable acquireLease(java.io.OutputStream keyedStateCheckpointOutputStream)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.