org.apache.flink.streaming.runtime.streamrecord

类 RecordAttributesBuilder

java.lang.Object

org.apache.flink.streaming.runtime.streamrecord.RecordAttributesBuilder

@Experimental
public class RecordAttributesBuilder
extends Object

The builder class for RecordAttributes.

构造器概要

构造器

构造器和说明
RecordAttributesBuilder(List<RecordAttributes> lastRecordAttributesOfInputs) This constructor takes a list of the last RecordAttributes received from each of the operator's inputs.

方法概要

限定符和类型	方法和说明
RecordAttributes	build() If any operator attribute is null, we will log it at DEBUG level and determine a non-null default value as described below.
RecordAttributesBuilder	setBacklog(boolean isBacklog)

从类继承的方法 java.lang.Object

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

构造器详细资料

RecordAttributesBuilder

public RecordAttributesBuilder(List<RecordAttributes> lastRecordAttributesOfInputs)

This constructor takes a list of the last RecordAttributes received from each of the operator's inputs. Each input is corresponding to an input edge of the job graph. When this list is not empty, it will be used to determine the default values for those attributes that have not been explicitly set by caller.

方法详细资料

setBacklog

public RecordAttributesBuilder setBacklog(boolean isBacklog)

build

public RecordAttributes build()

If any operator attribute is null, we will log it at DEBUG level and determine a non-null default value as described below.

Default value for backlog: if any element in lastRecordAttributesOfInputs has backlog=true, use true. Otherwise, use false.