org.apache.samza.operators.triggers

Class CountTrigger<M>

java.lang.Object

org.apache.samza.operators.triggers.CountTrigger<M>

All Implemented Interfaces:

Trigger<M>

public class CountTrigger<M>
extends java.lang.Object
implements Trigger<M>

A Trigger that fires when the number of messages in the WindowPane reaches the specified count.

Method Summary

Modifier and Type	Method and Description
long	getCount()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getCount

public long getCount()