Package org.apache.kafka.streams.processor

Class To

java.lang.Object
org.apache.kafka.streams.processor.To
public class To extends Object
This class is used to provide the optional parameters when sending output records to downstream processor using ProcessorContext.forward(Object, Object, To).

  • Method Summary

    Modifier and Type
    Method
    Description
    static To
    all()
    Forward the key/value pair to all downstream processors
    static To
    child(String childName)
    Forward the key/value pair to one of the downstream processors designated by the downstream processor name.
    boolean
    equals(Object o)
     
    int
    hashCode()
    Equality is implemented in support of tests, *not* for use in Hash collections, since this class is mutable.
    String
    toString()
     
    To
    withTimestamp(long timestamp)
    Set the timestamp of the output record.

    Methods inherited from class java.lang.Object

    getClass, notify, notifyAll, wait, wait, wait

  • Method Details

    • 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