public class SuppressedInternal<K> extends java.lang.Object implements Suppressed<K>
Suppressed.BufferConfig<BC extends Suppressed.BufferConfig<BC>>, Suppressed.StrictBufferConfig
Constructor and Description |
---|
SuppressedInternal(java.lang.String name,
java.time.Duration suppressionTime,
Suppressed.BufferConfig bufferConfig,
org.apache.kafka.streams.kstream.internals.suppress.TimeDefinitions.TimeDefinition<K> timeDefinition,
boolean suppressTombstones) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object o) |
int |
hashCode() |
java.lang.String |
name() |
java.lang.String |
toString() |
Suppressed<K> |
withName(java.lang.String name)
Use the specified name for the suppression node in the topology.
|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
untilTimeLimit, untilWindowCloses
public SuppressedInternal(java.lang.String name, java.time.Duration suppressionTime, Suppressed.BufferConfig bufferConfig, org.apache.kafka.streams.kstream.internals.suppress.TimeDefinitions.TimeDefinition<K> timeDefinition, boolean suppressTombstones)
public Suppressed<K> withName(java.lang.String name)
Suppressed
This can be used to insert a suppression without changing the rest of the topology names (and therefore not requiring an application reset).
Note however, that once a suppression has buffered some records, removing it from the topology would cause the loss of those records.
A suppression can be "disabled" with the configuration untilTimeLimit(Duration.ZERO, ...
.
withName
in interface Suppressed<K>
name
- The name to be used for the suppression node and changelog topicname
.public java.lang.String name()
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object