com.ibm.streams.flow.handlers

Class StreamDiscarder<T>

  • java.lang.Object
    • com.ibm.streams.flow.handlers.StreamDiscarder<T>
  • Type Parameters:
    T - Type for the tuples on the stream
    All Implemented Interfaces:
    StreamHandler<T>

    public final class StreamDiscarder<T>
extends java.lang.Object
implements StreamHandler<T>
    Discards all tuples and marks.
    Since:
    InfoSphere® Streams Version 3.1

    • Field Summary

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

    • Constructor Summary

      Constructors 
      Constructor and Description
      StreamDiscarder() 

    • Method Summary

      Methods 
      Modifier and Type Method and Description
      void mark(StreamingData.Punctuation mark)
      Do nothing with the mark.
      void tuple(T tuple)
      Do nothing with the tuple.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • StreamDiscarder

        public StreamDiscarder()

    • Method Detail

      • tuple

        public final void tuple(T tuple)
                 throws java.lang.Exception
        Do nothing with the tuple.
        Specified by:
        tuple in interface StreamHandler<T>
        Parameters:
        tuple - The tuple.
        Throws:
        java.lang.Exception - Failure to process the tuple.

      • mark

        public final void mark(StreamingData.Punctuation mark)
                throws java.lang.Exception
        Do nothing with the mark.
        Specified by:
        mark in interface StreamHandler<T>
        Parameters:
        mark - The punctuation mark.
        Throws:
        java.lang.Exception - Failure to process the punctuation mark.