public class To extends Object
ProcessorContext.forward(Object, Object, To)
.Modifier and Type | Field and Description |
---|---|
protected String |
childName |
protected long |
timestamp |
Modifier and Type | Method and 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.
|
protected String childName
protected long timestamp
protected To(To to)
protected void update(To to)
public static To child(String childName)
childName
- name of downstream processorTo
instance configured with childName
public static To all()
To
instance configured for all downstream processorpublic To withTimestamp(long timestamp)
timestamp
- the output record timestampthis
)public int hashCode()