org.apache.flink.streaming.runtime.streamrecord

Class StreamElement

java.lang.Object

org.apache.flink.streaming.runtime.streamrecord.StreamElement

Direct Known Subclasses:

StreamRecord, Watermark

@Internal
public abstract class StreamElement
extends Object

An element in a data stream. Can be a record or a Watermark.

Constructor Summary

Constructors

Constructor and Description
StreamElement()

Method Summary

Modifier and Type	Method and Description
<E> StreamRecord<E>	asRecord() Casts this element into a StreamRecord.
Watermark	asWatermark() Casts this element into a Watermark.
boolean	isRecord() Checks whether this element is a record.
boolean	isWatermark() Checks whether this element is a watermark.

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamElement

public StreamElement()

Method Detail

isWatermark

public final boolean isWatermark()

Checks whether this element is a watermark.

Returns:

True, if this element is a watermark, false otherwise.

isRecord

public final boolean isRecord()

Checks whether this element is a record.

Returns:

True, if this element is a record, false otherwise.

asRecord

public final <E> StreamRecord<E> asRecord()

Casts this element into a StreamRecord.

Returns:

This element as a stream record.

Throws:

ClassCastException - Thrown, if this element is actually not a stream record.

asWatermark

public final Watermark asWatermark()

Casts this element into a Watermark.

Returns:

This element as a Watermark.

Throws:

ClassCastException - Thrown, if this element is actually not a Watermark.