Package org.apache.flink.streaming.runtime.streamrecord

Class RecordAttributes

java.lang.Object

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

org.apache.flink.streaming.runtime.streamrecord.RecordAttributes

@Experimental
public class RecordAttributes
extends StreamElement

A RecordAttributes describes the attributes of records from the current RecordAttributes until the next one is received. It provides stream task with information that can be used to optimize the stream task's performance.

Field Summary

Fields

Modifier and Type	Field	Description
static RecordAttributes	EMPTY_RECORD_ATTRIBUTES

Constructor Summary

Constructors

Constructor	Description
RecordAttributes(boolean isBacklog)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
boolean	isBacklog()	If it returns true, then the records received after this element are stale and an operator can optionally buffer records until isBacklog=false.
String	toString()

Methods inherited from class org.apache.flink.streaming.runtime.streamrecord.StreamElement

asLatencyMarker, asRecord, asRecordAttributes, asWatermark, asWatermarkStatus, isLatencyMarker, isRecord, isRecordAttributes, isWatermark, isWatermarkStatus

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_RECORD_ATTRIBUTES

public static final RecordAttributes EMPTY_RECORD_ATTRIBUTES

Constructor Detail

RecordAttributes

public RecordAttributes(boolean isBacklog)

Method Detail

isBacklog

public boolean isBacklog()

If it returns true, then the records received after this element are stale and an operator can optionally buffer records until isBacklog=false. This allows an operator to optimize throughput at the cost of processing latency.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object