Page History

public class DataStream<T> {
  
  ...
  
  /**
   * Collect records in each partition of this data stream separately into a full 
   * window. The window emission will be triggered at the end of inputs. A partition
   * contains all records of a subtask for non-keyed DataStream and contains all records
   * of a key for keyed{@link DataStreamKeyedStream}.
   *
   * @return The data stream full windowed on each partition.
   */
  public PartitionWindowedStream<T> fullWindowPartition() {
    ...
  }
}

/**
 * {@link PartitionWindowedStream} represents a data stream that collects all 
 * records of each partition separately into a full window. Window emission will 
 * be triggered at the end of inputs. A partition contains all records of a subtask 
 * for non-keyed DataStream and contains all records of a key for keyed{@link DataStreamKeyedStream}.  
 *
 * @param <T> The type of the elements in this stream.
 */
public class PartitionWindowedStream<T> extends DataStream<T> {
  ...
}