Package org.apache.flink.table.runtime.operators.bundle.trigger

Interface BundleTriggerCallback

All Known Implementing Classes:

AbstractMapBundleOperator, KeyedMapBundleOperator, MapBundleOperator, MiniBatchStreamingJoinOperator

@Internal
public interface BundleTriggerCallback

Interface for bundle trigger callbacks that can be registered to a BundleTrigger.

Method Summary

Modifier and Type	Method	Description
void	finishBundle()	This method is invoked to finish current bundle and start a new one when the trigger was fired.

Method Detail

finishBundle

void finishBundle()
           throws Exception

This method is invoked to finish current bundle and start a new one when the trigger was fired.

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.