org.apache.flink.statefun.flink.core.logger

Interface CheckpointedStreamOperations

public interface CheckpointedStreamOperations

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	acquireLease(java.io.OutputStream keyedStateCheckpointOutputStream)
java.lang.Iterable<java.lang.Integer>	keyGroupList(java.io.OutputStream stream)
void	requireKeyedStateCheckpointed(java.io.OutputStream keyedStateCheckpointOutputStream)
void	startNewKeyGroup(java.io.OutputStream stream, int keyGroup)

Method Detail

requireKeyedStateCheckpointed

void requireKeyedStateCheckpointed(java.io.OutputStream keyedStateCheckpointOutputStream)

keyGroupList

java.lang.Iterable<java.lang.Integer> keyGroupList(java.io.OutputStream stream)

startNewKeyGroup

void startNewKeyGroup(java.io.OutputStream stream,
                      int keyGroup)
               throws java.io.IOException

Throws:

java.io.IOException

acquireLease

java.io.Closeable acquireLease(java.io.OutputStream keyedStateCheckpointOutputStream)