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).

  • Field Summary

    Fields
    Modifier and Type Field Description
    protected String childName  
    protected long timestamp  

  • Constructor Summary

    Constructors
    Modifier Constructor Description
    protected To​(To 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()  
    protected void update​(To to)  
    To withTimestamp​(long timestamp)
    Set the timestamp of the output record.

    Methods inherited from class java.lang.Object

    clone, finalize, getClass, notify, notifyAll, wait, wait, wait

  • Field Details

    • childName

      protected String childName

    • timestamp

      protected long timestamp

  • Constructor Details

    • To

      protected To​(To to)

  • Method Details

    • 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