public class FinalResultsSuppressionBuilder<K extends Windowed> extends java.lang.Object implements Suppressed<K>
Suppressed.BufferConfig<BC extends Suppressed.BufferConfig<BC>>, Suppressed.StrictBufferConfig
Constructor and Description |
---|
FinalResultsSuppressionBuilder(java.lang.String name,
Suppressed.StrictBufferConfig bufferConfig) |
Modifier and Type | Method and Description |
---|---|
SuppressedInternal<K> |
buildFinalResultsSuppression(java.time.Duration gracePeriod) |
boolean |
equals(java.lang.Object o) |
int |
hashCode() |
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 FinalResultsSuppressionBuilder(java.lang.String name, Suppressed.StrictBufferConfig bufferConfig)
public SuppressedInternal<K> buildFinalResultsSuppression(java.time.Duration gracePeriod)
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 extends Windowed>
name
- The name to be used for the suppression node and changelog topicname
.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