org.apache.samza.operators.triggers

Class CountTrigger<M extends MessageEnvelope>

java.lang.Object

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

All Implemented Interfaces:

Trigger

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

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()