org.apache.samza.operators

Class UpdateMessage<U,V>

java.lang.Object

org.apache.samza.operators.UpdateMessage<U,V>

Type Parameters:

U - type of the update record

V - type of the default record

public final class UpdateMessage<U,V>
extends java.lang.Object

Represents an update and an optional default record to be inserted for a key, if the update is applied to a non-existent record.

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object other)
V	getDefault()
U	getUpdate()
boolean	hasDefault()
int	hashCode()
static <U,V> UpdateMessage<U,V>	of(U update)
static <U,V> UpdateMessage<U,V>	of(U update, V defaultValue)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

of

public static <U,V> UpdateMessage<U,V> of(U update,
                                          @Nullable
                                          V defaultValue)

of

public static <U,V> UpdateMessage<U,V> of(U update)

getUpdate

public U getUpdate()

getDefault

public V getDefault()

hasDefault

public boolean hasDefault()

equals

public boolean equals(java.lang.Object other)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object