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

AllWindowedStream.minBy介绍

[英]Applies an aggregation that gives the minimum element of every window of the data stream by the given position. If more elements have the same minimum value the operator returns the first element by default.
[中]应用聚合，该聚合按给定位置给出数据流每个窗口的最小元素。如果多个元素具有相同的最小值，则默认情况下，运算符返回第一个元素。

代码示例

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

/**
 * Applies an aggregation that gives the minimum element of every window of
 * the data stream by the given position. If more elements have the same
 * minimum value the operator returns the first element by default.
 *
 * @param positionToMinBy
 *            The position to minimize by
 * @return The transformed DataStream.
 */
public SingleOutputStreamOperator<T> minBy(int positionToMinBy) {
  return this.minBy(positionToMinBy, true);
}

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

/**
 * Applies an aggregation that gives the minimum element of every window of
 * the data stream by the given position. If more elements have the same
 * minimum value the operator returns the first element by default.
 *
 * @param positionToMinBy The position to minimize by
 * @return The transformed DataStream.
 */
public SingleOutputStreamOperator<T> minBy(String positionToMinBy) {
  return this.minBy(positionToMinBy, true);
}

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

/**
 * Applies an aggregation that gives the minimum element of every window of
 * the data stream by the given position. If more elements have the same
 * minimum value the operator returns the first element by default.
 *
 * @param positionToMinBy The position to minimize by
 * @return The transformed DataStream.
 */
public SingleOutputStreamOperator<T> minBy(String positionToMinBy) {
  return this.minBy(positionToMinBy, true);
}

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

/**
 * Applies an aggregation that gives the minimum element of every window of
 * the data stream by the given position. If more elements have the same
 * minimum value the operator returns the first element by default.
 *
 * @param positionToMinBy The position to minimize by
 * @return The transformed DataStream.
 */
public SingleOutputStreamOperator<T> minBy(String positionToMinBy) {
  return this.minBy(positionToMinBy, true);
}

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

/**
 * Applies an aggregation that gives the minimum element of every window of
 * the data stream by the given position. If more elements have the same
 * minimum value the operator returns the first element by default.
 *
 * @param positionToMinBy
 *            The position to minimize by
 * @return The transformed DataStream.
 */
public SingleOutputStreamOperator<T> minBy(int positionToMinBy) {
  return this.minBy(positionToMinBy, true);
}

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

/**
 * Applies an aggregation that gives the minimum element of every window of
 * the data stream by the given position. If more elements have the same
 * minimum value the operator returns the first element by default.
 *
 * @param positionToMinBy
 *            The position to minimize by
 * @return The transformed DataStream.
 */
public SingleOutputStreamOperator<T> minBy(int positionToMinBy) {
  return this.minBy(positionToMinBy, true);
}

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

/**
 * Applies an aggregation that gives the minimum element of every window of
 * the data stream by the given position. If more elements have the same
 * minimum value the operator returns the first element by default.
 *
 * @param positionToMinBy
 *            The position to minimize by
 * @return The transformed DataStream.
 */
public SingleOutputStreamOperator<T> minBy(int positionToMinBy) {
  return this.minBy(positionToMinBy, true);
}

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

/**
 * Applies an aggregation that gives the minimum element of every window of
 * the data stream by the given position. If more elements have the same
 * minimum value the operator returns the first element by default.
 *
 * @param positionToMinBy The position to minimize by
 * @return The transformed DataStream.
 */
public SingleOutputStreamOperator<T> minBy(String positionToMinBy) {
  return this.minBy(positionToMinBy, true);
}