Package org.apache.kafka.streams.processor.api

Class MockProcessorContext.CapturedForward<K,V>

java.lang.Object

org.apache.kafka.streams.processor.api.MockProcessorContext.CapturedForward<K,V>

Enclosing class:

MockProcessorContext<KForward,VForward>

public static final class MockProcessorContext.CapturedForward<K,V>
extends Object

Constructor Summary

Constructors

Constructor	Description
CapturedForward(Record<K,V> record)
CapturedForward(Record<K,V> record, Optional<String> childName)

Method Summary

Modifier and Type	Method	Description
Optional<String>	childName()	The child this data was forwarded to.
boolean	equals(Object o)
int	hashCode()
Record<K,V>	record()	The record that was forwarded.
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

CapturedForward

public CapturedForward(Record<K,V> record)

CapturedForward

public CapturedForward(Record<K,V> record,
 Optional<String> childName)

Method Details

childName

public Optional<String> childName()

The child this data was forwarded to.

Returns:

If present, the child name the record was forwarded to. If empty, the forward was a broadcast.

record

public Record<K,V> record()

The record that was forwarded.

Returns:

The forwarded record. Not null.

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object