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 To
all()
Forward the key/value pair to all downstream processorsstatic 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.protected void
update(To to)
To
withTimestamp(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
To
instance configured withchildName
-
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
)
-
-