CoBundleTrigger (Flink : 2.0-SNAPSHOT API)

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

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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()
```