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

Interface CoBundleTrigger<IN1,IN2>

Type Parameters:

IN1 - The first input element type.

IN2 - The second input element type.

All Superinterfaces:

Serializable

All Known Implementing Classes:

CountCoBundleTrigger

@Internal
public interface CoBundleTrigger<IN1,IN2>
extends Serializable

A CoBundleTrigger is similar with BundleTrigger, and the only differences is CoBundleTrigger can handle two inputs.

Method Summary

Modifier and Type	Method and Description
String	explain()
void	onElement1(IN1 element) Called for every element that gets added to the bundle from the first input.
void	onElement2(IN2 element) Called for every element that gets added to the bundle from the second input.
void	registerCallback(BundleTriggerCallback callback) Register a callback which will be called once this trigger decides to finish this bundle.
void	reset() Reset the trigger to its initiate status.

Method Detail

registerCallback

void registerCallback(BundleTriggerCallback callback)

Register a callback which will be called once this trigger decides to finish this bundle.

onElement1

void onElement1(IN1 element)
         throws Exception

Called for every element that gets added to the bundle from the first input. If the trigger decides to start evaluate, BundleTriggerCallback.finishBundle() should be invoked.

Parameters:

element - The element that arrived from the first input.

Throws:

Exception

onElement2

void onElement2(IN2 element)
         throws Exception

Called for every element that gets added to the bundle from the second input. If the trigger decides to start evaluate, BundleTriggerCallback.finishBundle() should be invoked.

Parameters:

element - The element that arrived from the second input.

Throws:

Exception

reset

void reset()

Reset the trigger to its initiate status.

explain

String explain()