com.ibm.streams.operator.window

Class WindowUtilities

  • java.lang.Object
    • com.ibm.streams.operator.window.WindowUtilities

  • public abstract class WindowUtilities
extends java.lang.Object
    Utility methods for windowed input ports.
    Since:
    InfoSphere® Streams Version 2.0.0.3
    See Also:
    StreamWindow

    • Field Summary

      Fields 
      Modifier and Type Field and Description
      static java.lang.String IBM_COPYRIGHT 

    • Constructor Summary

      Constructors 
      Constructor and Description
      WindowUtilities() 

    • Method Summary

      Methods 
      Modifier and Type Method and Description
      static void registerAttributePartitioner(StreamWindow<Tuple> window, java.lang.String... attributeNames)
      Register a StreamWindowPartitioner for a StreamWindow where partitioning is defined by attributes of the input tuples.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • WindowUtilities

        public WindowUtilities()

    • Method Detail

      • registerAttributePartitioner

        public static void registerAttributePartitioner(StreamWindow<Tuple> window,
                                java.lang.String... attributeNames)
        Register a StreamWindowPartitioner for a StreamWindow where partitioning is defined by attributes of the input tuples.

        Any attribute used for partitioning must be one of the following types: Type.MetaType#BSTRING, Type.MetaType#RSTRING, Type.MetaType#USTRING, Type.MetaType#BOOLEAN, Type.MetaType#INT8, Type.MetaType#INT16, Type.MetaType#INT32, Type.MetaType#INT64, Type.MetaType#UINT8, Type.MetaType#UINT16, Type.MetaType#UINT32, Type.MetaType#UINT64.

        Parameters:
        window - Window being partitioned.
        attributeNames - Names of the attributes to partition by.
        Throws:
        java.lang.IllegalArgumentException - Invalid attributes names or types of attributes.
        Since:
        InfoSphere® Streams Version 2.0.0.3