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 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(String name, Suppressed.StrictBufferConfig bufferConfig)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SuppressedInternal<K>
buildFinalResultsSuppression(Duration gracePeriod)
boolean
equals(Object o)
int
hashCode()
String
name()
String
toString()
Suppressed<K>
withName(String name)
Use the specified name for the suppression node in the topology.
-
-
-
Constructor Detail
-
FinalResultsSuppressionBuilder
public FinalResultsSuppressionBuilder(String name, Suppressed.StrictBufferConfig bufferConfig)
-
-
Method Detail
-
buildFinalResultsSuppression
public SuppressedInternal<K> buildFinalResultsSuppression(Duration gracePeriod)
-
withName
public Suppressed<K> withName(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
.
-
name
public String name()
- Specified by:
name
in interfaceNamedSuppressed<K extends Windowed>
-
-