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 usingProcessorContext.forward(Object, Object, To).
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static Toall()Forward the key/value pair to all downstream processorsstatic Tochild(String childName)Forward the key/value pair to one of the downstream processors designated by the downstream processor name.booleanequals(Object o)inthashCode()Equality is implemented in support of tests, *not* for use in Hash collections, since this class is mutable.protected voidupdate(To to)TowithTimestamp(long timestamp)Set the timestamp of the output record.
-
-
-
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
Toinstance configured withchildName
-
all
public static To all()
Forward the key/value pair to all downstream processors- Returns:
- a new
Toinstance 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)
-
-