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

SingleOutputStreamOperator.setChainingStrategy介绍

[英]Sets the ChainingStrategy for the given operator affecting the way operators will possibly be co-located on the same thread for increased performance.
[中]设置给定运算符的ChainingStrategy，该策略会影响运算符可能位于同一线程上以提高性能的方式。

代码示例

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

/**
 * Starts a new task chain beginning at this operator. This operator will
 * not be chained (thread co-located for increased performance) to any
 * previous tasks even if possible.
 *
 * @return The operator with chaining set.
 */
@PublicEvolving
public SingleOutputStreamOperator<T> startNewChain() {
  return setChainingStrategy(ChainingStrategy.HEAD);
}

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

/**
 * Turns off chaining for this operator so thread co-location will not be used as an
 * optimization.
 *
 * <p>Chaining can be turned off for the whole job by
 * {@link StreamExecutionEnvironment#disableOperatorChaining()} however it is not advised for
 * performance considerations.
 *
 * @return The operator with chaining disabled
 */
@PublicEvolving
public SingleOutputStreamOperator<T> disableChaining() {
  return setChainingStrategy(ChainingStrategy.NEVER);
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.11

/**
 * Starts a new task chain beginning at this operator. This operator will
 * not be chained (thread co-located for increased performance) to any
 * previous tasks even if possible.
 *
 * @return The operator with chaining set.
 */
@PublicEvolving
public SingleOutputStreamOperator<T> startNewChain() {
  return setChainingStrategy(ChainingStrategy.HEAD);
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.10

/**
 * Starts a new task chain beginning at this operator. This operator will
 * not be chained (thread co-located for increased performance) to any
 * previous tasks even if possible.
 *
 * @return The operator with chaining set.
 */
@PublicEvolving
public SingleOutputStreamOperator<T> startNewChain() {
  return setChainingStrategy(ChainingStrategy.HEAD);
}

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

/**
 * Starts a new task chain beginning at this operator. This operator will
 * not be chained (thread co-located for increased performance) to any
 * previous tasks even if possible.
 *
 * @return The operator with chaining set.
 */
@PublicEvolving
public SingleOutputStreamOperator<T> startNewChain() {
  return setChainingStrategy(ChainingStrategy.HEAD);
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.10

/**
 * Turns off chaining for this operator so thread co-location will not be used as an
 * optimization.
 *
 * <p>Chaining can be turned off for the whole job by
 * {@link StreamExecutionEnvironment#disableOperatorChaining()} however it is not advised for
 * performance considerations.
 *
 * @return The operator with chaining disabled
 */
@PublicEvolving
public SingleOutputStreamOperator<T> disableChaining() {
  return setChainingStrategy(ChainingStrategy.NEVER);
}

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

/**
 * Turns off chaining for this operator so thread co-location will not be used as an
 * optimization.
 *
 * <p>Chaining can be turned off for the whole job by
 * {@link StreamExecutionEnvironment#disableOperatorChaining()} however it is not advised for
 * performance considerations.
 *
 * @return The operator with chaining disabled
 */
@PublicEvolving
public SingleOutputStreamOperator<T> disableChaining() {
  return setChainingStrategy(ChainingStrategy.NEVER);
}

代码示例来源：origin: org.apache.flink/flink-streaming-java_2.11

/**
 * Turns off chaining for this operator so thread co-location will not be used as an
 * optimization.
 *
 * <p>Chaining can be turned off for the whole job by
 * {@link StreamExecutionEnvironment#disableOperatorChaining()} however it is not advised for
 * performance considerations.
 *
 * @return The operator with chaining disabled
 */
@PublicEvolving
public SingleOutputStreamOperator<T> disableChaining() {
  return setChainingStrategy(ChainingStrategy.NEVER);
}