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)

• equals

  public boolean equals(Object o)

  Overrides:

  equals in class Object

• 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

• toString

  public String toString()

  Overrides:

  toString in class Object