本文整理了Java中org.apache.flink.api.common.operators.Operator.createUnionCascade()方法的一些代码示例，展示了Operator.createUnionCascade()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Operator.createUnionCascade()方法的具体详情如下：
包路径：org.apache.flink.api.common.operators.Operator
类名称：Operator
方法名：createUnionCascade

Operator.createUnionCascade介绍

[英]Takes a list of operators and creates a cascade of unions of this inputs, if needed. If not needed (there was only one operator in the list), then that operator is returned.
[中]如果需要，获取运算符列表并创建此输入的并集级联。如果不需要（列表中只有一个运算符），则返回该运算符。

代码示例

代码示例来源：origin: apache/flink

/**
 * Takes a list of operators and creates a cascade of unions of this inputs, if needed.
 * If not needed (there was only one operator in the list), then that operator is returned.
 * 
 * @param operators The operators.
 * @return The single operator or a cascade of unions of the operators.
 */
public static <T> Operator<T> createUnionCascade(Operator<T>... operators) {
  return createUnionCascade(null, operators);
}

代码示例来源：origin: apache/flink

/**
 * Adds to the input the union of the given operators.
 * 
 * @param input The operator(s) that form the input.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
public void addInput(Operator<IN>... input) {
  this.input = Operator.createUnionCascade(this.input, input);
}

代码示例来源：origin: apache/flink

/**
 * Add to the first input the union of the given operators.
 * 
 * @param input The operator(s) to be unioned with the first input.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
public void addFirstInput(Operator<IN1>... input) {
  this.input1 = Operator.createUnionCascade(this.input1, input);
}

代码示例来源：origin: apache/flink

/**
 * Sets the second input to the union of the given operators.
 * 
 * @param inputs The operator(s) that form the second inputs.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
public void setSecondInputs(List<Operator<IN2>> inputs) {
  this.input2 = Operator.createUnionCascade(inputs);
}

代码示例来源：origin: apache/flink

/**
 * Sets the input to the union of the given operators.
 * 
 * @param input The operator(s) that form the input.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
public void setInput(Operator<IN>... input) {
  this.input = Operator.createUnionCascade(null, input);
}

代码示例来源：origin: apache/flink

/**
 * Sets the first input to the union of the given operators.
 * 
 * @param inputs The operator(s) that form the first input.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
public void setFirstInput(Operator<IN1>... inputs) {
  this.input1 = Operator.createUnionCascade(inputs);
}

代码示例来源：origin: apache/flink

/**
 * Sets the second input to the union of the given operators.
 * 
 * @param inputs The operator(s) that form the second input.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
public void setSecondInput(Operator<IN2>... inputs) {
  this.input2 = Operator.createUnionCascade(inputs);
}

代码示例来源：origin: apache/flink

/**
 * Sets the first input to the union of the given operators.
 * 
 * @param inputs The operator(s) that form the first inputs.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
public void setFirstInputs(List<Operator<IN1>> inputs) {
  this.input1 = Operator.createUnionCascade(inputs);
}

代码示例来源：origin: apache/flink

/**
 * Add to the second input the union of the given operators.
 * 
 * @param input The operator(s) to be unioned with the second input.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
public void addSecondInput(Operator<IN2>... input) {
  this.input2 = Operator.createUnionCascade(this.input2, input);
}

代码示例来源：origin: apache/flink

/**
 * Takes a list of operators and creates a cascade of unions of this inputs, if needed.
 * If not needed (there was only one operator in the list), then that operator is returned.
 * 
 * @param operators The operators.
 * @return The single operator or a cascade of unions of the operators.
 */
@SuppressWarnings("unchecked")
public static <T> Operator<T> createUnionCascade(List<? extends Operator<T>> operators) {
  return createUnionCascade((Operator<T>[]) operators.toArray(new Operator[operators.size()]));
}

代码示例来源：origin: apache/flink

/**
 * Sets the input to the union of the given operators.
 * 
 * @param inputs The operator(s) that form the input.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
@SuppressWarnings("unchecked")
public void setInputs(List<Operator<IN>> inputs) {
  this.input = Operator.createUnionCascade(null, inputs.toArray(new Operator[inputs.size()]));
}

代码示例来源：origin: apache/flink

/**
 * Add to the first input the union of the given operators.
 * 
 * @param inputs The operator(s) to be unioned with the first input.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
@SuppressWarnings("unchecked")
public void addFirstInputs(List<Operator<IN1>> inputs) {
  this.input1 = Operator.createUnionCascade(this.input1, inputs.toArray(new Operator[inputs.size()]));
}

代码示例来源：origin: apache/flink

/**
 * Adds to the input the union of the given operators.
 * 
 * @param inputs The operator(s) that form the input.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
@SuppressWarnings("unchecked")
public void addInput(List<Operator<IN>> inputs) {
  this.input = Operator.createUnionCascade(this.input, inputs.toArray(new Operator[inputs.size()]));
}

代码示例来源：origin: apache/flink

/**
 * Add to the second input the union of the given operators.
 * 
 * @param inputs The operator(s) to be unioned with the second input.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
@SuppressWarnings("unchecked")
public void addSecondInputs(List<Operator<IN2>> inputs) {
  this.input2 = Operator.createUnionCascade(this.input2, inputs.toArray(new Operator[inputs.size()]));
}

代码示例来源：origin: apache/flink

/**
 * Sets the input to the union of the given operators.
 *
 * @param inputs The operator(s) that form the input.
 * @deprecated This method will be removed in future versions. Use the {@link org.apache.flink.api.common.operators.Union} operator instead.
 */
@Deprecated
public void setInputs(List<Operator<IN>> inputs) {
  checkNotNull(inputs, "The inputs may not be null.");
  this.input = Operator.createUnionCascade(inputs);
}

代码示例来源：origin: apache/flink

/**
 * Sets the input to the union of the given operators.
 *
 * @param inputs The operator(s) that form the input.
 * @deprecated This method will be removed in future versions. Use the {@link org.apache.flink.api.common.operators.Union} operator instead.
 */
@Deprecated
public void setInputs(Operator<IN>... inputs) {
  checkNotNull(inputs, "The inputs may not be null.");
  this.input = Operator.createUnionCascade(inputs);
}

代码示例来源：origin: apache/flink

/**
 * Adds to the input the union of the given operators.
 *
 * @param inputs The operator(s) to be unioned with the input.
 * @deprecated This method will be removed in future versions. Use the {@link org.apache.flink.api.common.operators.Union} operator instead.
 */
@Deprecated
public void addInput(Operator<IN>... inputs) {
  checkNotNull(inputs, "The input may not be null.");
  this.input = Operator.createUnionCascade(this.input, inputs);
}

代码示例来源：origin: org.apache.flink/flink-core

/**
 * Takes a list of operators and creates a cascade of unions of this inputs, if needed.
 * If not needed (there was only one operator in the list), then that operator is returned.
 * 
 * @param operators The operators.
 * @return The single operator or a cascade of unions of the operators.
 */
public static <T> Operator<T> createUnionCascade(Operator<T>... operators) {
  return createUnionCascade(null, operators);
}

代码示例来源：origin: org.apache.flink/flink-core

/**
 * Sets the first input to the union of the given operators.
 * 
 * @param inputs The operator(s) that form the first inputs.
 * @deprecated This method will be removed in future versions. Use the {@link Union} operator instead.
 */
@Deprecated
public void setFirstInputs(List<Operator<IN1>> inputs) {
  this.input1 = Operator.createUnionCascade(inputs);
}

代码示例来源：origin: org.apache.flink/flink-core

/**
 * Sets the input to the union of the given operators.
 *
 * @param inputs The operator(s) that form the input.
 * @deprecated This method will be removed in future versions. Use the {@link org.apache.flink.api.common.operators.Union} operator instead.
 */
@Deprecated
public void setInputs(List<Operator<IN>> inputs) {
  checkNotNull(inputs, "The inputs may not be null.");
  this.input = Operator.createUnionCascade(inputs);
}