org.apache.samza.operators.data

Interface MessageEnvelope<K,M>

All Known Implementing Classes:

InputMessageEnvelope

@InterfaceStability.Unstable
public interface MessageEnvelope<K,M>

An entry in the input/output MessageStreams

Method Summary

Modifier and Type	Method and Description
K	getKey() Get the key for this MessageEnvelope.
M	getMessage() Get the message in this MessageEnvelope.
default boolean	isDelete() Whether this MessageEnvelope indicates deletion of a previous message with this key.

Method Detail

getKey

K getKey()

Get the key for this MessageEnvelope.

Returns:

the key for this MessageEnvelope

getMessage

M getMessage()

Get the message in this MessageEnvelope.

Returns:

the message in this MessageEnvelope

isDelete

default boolean isDelete()

Whether this MessageEnvelope indicates deletion of a previous message with this key.

Returns:

true if the current MessageEnvelope indicates deletion of a previous message with this key