Class PrintForeachAction<K,V>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.PrintForeachAction<K,V>
-
- All Implemented Interfaces:
ForeachAction<K,V>
public class PrintForeachAction<K,V> extends Object implements ForeachAction<K,V>
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
apply(K key, V value)
Perform an action for each record of a stream.void
close()
-
-
-
Method Detail
-
apply
public void apply(K key, V value)
Description copied from interface:ForeachAction
Perform an action for each record of a stream.- Specified by:
apply
in interfaceForeachAction<K,V>
- Parameters:
key
- the key of the recordvalue
- the value of the record
-
close
public void close()
-
-