@Experimental public class RecordAttributesBuilder extends Object
RecordAttributes
.Constructor and Description |
---|
RecordAttributesBuilder(List<RecordAttributes> lastRecordAttributesOfInputs)
This constructor takes a list of the last RecordAttributes received from each of the
operator's inputs.
|
Modifier and Type | Method and Description |
---|---|
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) |
public RecordAttributesBuilder(List<RecordAttributes> lastRecordAttributesOfInputs)
public RecordAttributesBuilder setBacklog(boolean isBacklog)
public RecordAttributes build()
Default value for backlog: if any element in lastRecordAttributesOfInputs has backlog=true, use true. Otherwise, use false.
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.