org.apache.kafka.streams.kstream

Class PrintForeachAction<K,V>

java.lang.Object

org.apache.kafka.streams.kstream.PrintForeachAction<K,V>

All Implemented Interfaces:

ForeachAction<K,V>

public class PrintForeachAction<K,V>
extends Object
implements ForeachAction<K,V>

Constructor Summary

Constructors

Constructor and Description
PrintForeachAction(PrintWriter printWriter, KeyValueMapper<? super K,? super V,String> mapper, String label) Print customized output with given writer.

Method Summary

Modifier and Type	Method and Description
void	apply(K key, V value) Perform an action for each record of a stream.
void	close()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PrintForeachAction

public PrintForeachAction(PrintWriter printWriter,
                          KeyValueMapper<? super K,? super V,String> mapper,
                          String label)

Print customized output with given writer. The PrintWriter can be null in order to distinguish between System.out and the others. If the PrintWriter is PrintWriter(System.out), then it would close System.out output stream.

Afterall, not to pass in PrintWriter(System.out) but null instead.

Parameters:

printWriter - Use System.out.println if null.

mapper - The mapper which can allow user to customize output will be printed.

label - The given name will be printed.

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 interface ForeachAction<K,V>

Parameters:

key - the key of the record

value - the value of the record

close

public void close()