public class ForeachActionDispatcher<K,V> extends Object implements org.apache.kafka.streams.kstream.ForeachAction<K,V>
ForeachAction
implementation that dispatches ForeachAction.apply(Object, Object)
invocation to registered
actions.Constructor and Description |
---|
ForeachActionDispatcher() |
Modifier and Type | Method and Description |
---|---|
void |
apply(K key,
V value) |
void |
deregister(org.apache.kafka.streams.kstream.ForeachAction<? super K,? super V> action) |
void |
register(org.apache.kafka.streams.kstream.ForeachAction<? super K,? super V> action) |
Copyright © 2020 Red Hat. All rights reserved.