com.hazelcast.jet.datamodel

Class TimestampedItem<T>

java.lang.Object

com.hazelcast.jet.datamodel.TimestampedItem<T>

Type Parameters:

T - type of the item

All Implemented Interfaces:

Serializable

public final class TimestampedItem<T>
extends Object
implements Serializable

Represents a data item with the event timestamp added to it. Used in the Pipeline API as the default data type to emit from global windowed aggregation stages (those that aggregate all the data in a window, without grouping).

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TimestampedItem(long ignored, long timestamp, T item) This constructor exists in order to match the shape of the functional interface WindowResultFunction.
TimestampedItem(long timestamp, T item) Constructs a timestamped item with the supplied field values.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
int	hashCode()
T	item() Returns the item.
long	timestamp() Returns the timestamp associated with the item.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

TimestampedItem

public TimestampedItem(long timestamp,
                       @Nonnull
                       T item)

Constructs a timestamped item with the supplied field values.

TimestampedItem

public TimestampedItem(long ignored,
                       long timestamp,
                       @Nonnull
                       T item)

This constructor exists in order to match the shape of the functional interface WindowResultFunction.

Constructs a timestamped item with the supplied field values. Ignores the first argument.

Method Detail

timestamp

public long timestamp()

Returns the timestamp associated with the item.

item

public T item()

Returns the item.

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object