Class To

    • Field Detail

      • childName

        protected 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​(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)
      • hashCode

        public int hashCode()
        Equality is implemented in support of tests, *not* for use in Hash collections, since this class is mutable.
        Overrides:
        hashCode in class Object