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

KeyedStream.countWindow介绍

[英]Windows this KeyedStream into tumbling count windows.
[中]Windows此键将流输入翻滚计数窗口。

代码示例

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

/**
 * A thin wrapper layer over {@link KeyedStream#countWindow(long, long)}.
 *
 * @param size The size of the windows in number of elements.
 * @param slide The slide interval in number of elements.
 * @return The python windowed stream {@link PythonWindowedStream}
 */
public PythonWindowedStream count_window(long size, long slide) {
  return new PythonWindowedStream<GlobalWindow>(this.stream.countWindow(size, slide));
}

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

public static SingleOutputStreamOperator<Integer> createWindowFunction(ExecutionMode mode, DataStream<Tuple2<Integer, Integer>> input) {
  return input
    .keyBy(0)
    .countWindow(1)
    .apply(new StatefulWindowFunction(mode))
    .setParallelism(4)
    .uid("window");
}

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

.countWindow(windowSize, slideSize)

代码示例来源：origin: com.alibaba.blink/flink-examples-streaming

.countWindow(windowSize, slideSize)