org.apache.samza.operators.windows

Class WindowPane<K,V>

java.lang.Object

org.apache.samza.operators.windows.WindowPane<K,V>

Type Parameters:

K - the type of key in the window pane

V - the type of value in the window pane.

All Implemented Interfaces:

MessageEnvelope<WindowKey<K>,V>

public final class WindowPane<K,V>
extends java.lang.Object
implements MessageEnvelope<WindowKey<K>,V>

Specifies the result emitted from a Window.

Method Summary

Modifier and Type	Method and Description
WindowKey<K>	getKey() Get the key for this MessageEnvelope.
V	getMessage() Get the message in this MessageEnvelope.
static <K,M> WindowPane<K,M>	of(WindowKey<K> key, M result)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.samza.operators.data.MessageEnvelope

isDelete

Method Detail

getMessage

public V getMessage()

Description copied from interface: MessageEnvelope

Get the message in this MessageEnvelope.

Specified by:

getMessage in interface MessageEnvelope<WindowKey<K>,V>

Returns:

the message in this MessageEnvelope

getKey

public WindowKey<K> getKey()

Description copied from interface: MessageEnvelope

Get the key for this MessageEnvelope.

Specified by:

getKey in interface MessageEnvelope<WindowKey<K>,V>

Returns:

the key for this MessageEnvelope

of

public static <K,M> WindowPane<K,M> of(WindowKey<K> key,
                                       M result)