Class To

    • Field Summary

      Fields 
      Modifier and Type Field Description
      protected java.lang.String childName  
      protected long timestamp  
    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected To​(To to)  
    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static To all()
      Forward the key/value pair to all downstream processors
      static To child​(java.lang.String childName)
      Forward the key/value pair to one of the downstream processors designated by the downstream processor name.
      protected void update​(To to)  
      To withTimestamp​(long timestamp)
      Set the timestamp of the output record.
      • Methods inherited from class java.lang.Object

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

      • childName

        protected java.lang.String childName
      • timestamp

        protected long timestamp
    • Constructor Detail

      • To

        protected To​(To to)
    • Method Detail

      • update

        protected void update​(To to)
      • child

        public static To child​(java.lang.String childName)
        Forward the key/value pair to one of the downstream processors designated by the downstream processor name.
        Parameters:
        childName - name of downstream processor
        Returns:
        a new To instance configured with childName
      • all

        public static To all()
        Forward the key/value pair to all downstream processors
        Returns:
        a new To instance configured for all downstream processor
      • withTimestamp

        public To withTimestamp​(long timestamp)
        Set the timestamp of the output record.
        Parameters:
        timestamp - the output record timestamp
        Returns:
        itself (i.e., this)