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

AllWindowedStream.<init>介绍

暂无

代码示例

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

/**
 * Windows this data stream to a {@code KeyedTriggerWindowDataStream}, which evaluates windows
 * over a key grouped stream. Elements are put into windows by a
 * {@link org.apache.flink.streaming.api.windowing.assigners.WindowAssigner}. The grouping of
 * elements is done both by key and by window.
 *
 * <p>A {@link org.apache.flink.streaming.api.windowing.triggers.Trigger} can be defined to specify
 * when windows are evaluated. However, {@code WindowAssigners} have a default {@code Trigger}
 * that is used if a {@code Trigger} is not specified.
 *
 * <p>Note: This operation is inherently non-parallel since all elements have to pass through
 * the same operator instance.
 *
 * @param assigner The {@code WindowAssigner} that assigns elements to windows.
 * @return The trigger windows data stream.
 */
@PublicEvolving
public <W extends Window> AllWindowedStream<T, W> windowAll(WindowAssigner<? super T, W> assigner) {
  return new AllWindowedStream<>(this, assigner);
}

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

/**
 * Windows this data stream to a {@code KeyedTriggerWindowDataStream}, which evaluates windows
 * over a key grouped stream. Elements are put into windows by a
 * {@link org.apache.flink.streaming.api.windowing.assigners.WindowAssigner}. The grouping of
 * elements is done both by key and by window.
 *
 * <p>A {@link org.apache.flink.streaming.api.windowing.triggers.Trigger} can be defined to specify
 * when windows are evaluated. However, {@code WindowAssigners} have a default {@code Trigger}
 * that is used if a {@code Trigger} is not specified.
 *
 * <p>Note: This operation is inherently non-parallel since all elements have to pass through
 * the same operator instance.
 *
 * @param assigner The {@code WindowAssigner} that assigns elements to windows.
 * @return The trigger windows data stream.
 */
@PublicEvolving
public <W extends Window> AllWindowedStream<T, W> windowAll(WindowAssigner<? super T, W> assigner) {
  return new AllWindowedStream<>(this, assigner);
}

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

/**
 * Windows this data stream to a {@code KeyedTriggerWindowDataStream}, which evaluates windows
 * over a key grouped stream. Elements are put into windows by a
 * {@link org.apache.flink.streaming.api.windowing.assigners.WindowAssigner}. The grouping of
 * elements is done both by key and by window.
 *
 * <p>A {@link org.apache.flink.streaming.api.windowing.triggers.Trigger} can be defined to specify
 * when windows are evaluated. However, {@code WindowAssigners} have a default {@code Trigger}
 * that is used if a {@code Trigger} is not specified.
 *
 * <p>Note: This operation is inherently non-parallel since all elements have to pass through
 * the same operator instance.
 *
 * @param assigner The {@code WindowAssigner} that assigns elements to windows.
 * @return The trigger windows data stream.
 */
@PublicEvolving
public <W extends Window> AllWindowedStream<T, W> windowAll(WindowAssigner<? super T, W> assigner) {
  return new AllWindowedStream<>(this, assigner);
}

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

/**
 * Windows this data stream to a {@code KeyedTriggerWindowDataStream}, which evaluates windows
 * over a key grouped stream. Elements are put into windows by a
 * {@link org.apache.flink.streaming.api.windowing.assigners.WindowAssigner}. The grouping of
 * elements is done both by key and by window.
 *
 * <p>A {@link org.apache.flink.streaming.api.windowing.triggers.Trigger} can be defined to specify
 * when windows are evaluated. However, {@code WindowAssigners} have a default {@code Trigger}
 * that is used if a {@code Trigger} is not specified.
 *
 * <p>Note: This operation can be inherently non-parallel since all elements have to pass through
 * the same operator instance. (Only for special cases, such as aligned time windows is
 * it possible to perform this operation in parallel).
 *
 * @param assigner The {@code WindowAssigner} that assigns elements to windows.
 * @return The trigger windows data stream.
 */
@PublicEvolving
public <W extends Window> AllWindowedStream<T, W> windowAll(WindowAssigner<? super T, W> assigner) {
  return new AllWindowedStream<>(this, assigner);
}