com.ibm.streamsx.topology.streams

Class CollectionStreams.FlattenCollection<C extends java.util.Collection<T>,T>

  • java.lang.Object
    • com.ibm.streamsx.topology.streams.CollectionStreams.FlattenCollection<C,T>
  • Type Parameters:
    C - Type of the collection.
    T - Type of the elements.
    All Implemented Interfaces:
    Function<C,java.lang.Iterable<T>>, java.io.Serializable
    Enclosing class:
    CollectionStreams


    public static class CollectionStreams.FlattenCollection<C extends java.util.Collection<T>,T>
    extends java.lang.Object
    implements Function<C,java.lang.Iterable<T>>
    Function that flattens a collection when passed to TStream.multiTransform(Function).
    See Also:
    Serialized Form
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method and Description
      java.lang.Iterable<T> apply(C v)
      Just returns the collection, TStream.multiTransform(Function) will actually perform the flattening.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • FlattenCollection

        public FlattenCollection()
    • Method Detail

      • apply

        public java.lang.Iterable<T> apply(C v)
        Just returns the collection, TStream.multiTransform(Function) will actually perform the flattening.
        Specified by:
        apply in interface Function<C extends java.util.Collection<T>,java.lang.Iterable<T>>
streamsx.topology 2.1 @ IBMStreams GitHub