Class FinalResultsSuppressionBuilder<K extends Windowed>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.suppress.FinalResultsSuppressionBuilder<K>
-
- All Implemented Interfaces:
NamedSuppressed<K>
,Suppressed<K>
public class FinalResultsSuppressionBuilder<K extends Windowed> extends java.lang.Object implements Suppressed<K>, NamedSuppressed<K>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.kafka.streams.kstream.Suppressed
Suppressed.BufferConfig<BC extends Suppressed.BufferConfig<BC>>, Suppressed.EagerBufferConfig, Suppressed.StrictBufferConfig
-
-
Constructor Summary
Constructors Constructor Description FinalResultsSuppressionBuilder(java.lang.String name, Suppressed.StrictBufferConfig bufferConfig)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SuppressedInternal<K>
buildFinalResultsSuppression(java.time.Duration gracePeriod)
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.
-
-
-
Constructor Detail
-
FinalResultsSuppressionBuilder
public FinalResultsSuppressionBuilder(java.lang.String name, Suppressed.StrictBufferConfig bufferConfig)
-
-
Method Detail
-
buildFinalResultsSuppression
public SuppressedInternal<K> buildFinalResultsSuppression(java.time.Duration gracePeriod)
-
withName
public Suppressed<K> withName(java.lang.String name)
Description copied from interface:Suppressed
Use the specified name for the suppression node in the topology.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, ...
.- Specified by:
withName
in interfaceSuppressed<K extends Windowed>
- Parameters:
name
- The name to be used for the suppression node and changelog topic- Returns:
- The same configuration with the addition of the given
name
.
-
equals
public boolean equals(java.lang.Object o)
- Overrides:
equals
in classjava.lang.Object
-
name
public java.lang.String name()
- Specified by:
name
in interfaceNamedSuppressed<K extends Windowed>
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-