org.apache.flink.streaming.api.operators

Class InputSelection.Builder

java.lang.Object

org.apache.flink.streaming.api.operators.InputSelection.Builder

Enclosing class:

InputSelection

public static final class InputSelection.Builder
extends Object

Utility class for creating InputSelection.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
InputSelection	build()
InputSelection	build(int inputCount) Build normalized mask, if all inputs were manually selected, inputMask will be normalized to -1.
static InputSelection.Builder	from(InputSelection selection) Returns a Builder that uses the input mask of the specified selection as the initial mask.
InputSelection.Builder	select(int inputId) Selects an input identified by the given inputId.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

from

public static InputSelection.Builder from(InputSelection selection)

Returns a Builder that uses the input mask of the specified selection as the initial mask.

select

public InputSelection.Builder select(int inputId)

Selects an input identified by the given inputId.

Parameters:

inputId - the input id numbered starting from 1 to 64, and `1` indicates the first input. Specially, `-1` indicates all inputs.

Returns:

a reference to this object.

build

public InputSelection build(int inputCount)

Build normalized mask, if all inputs were manually selected, inputMask will be normalized to -1.

build

public InputSelection build()