Package org.apache.kafka.streams.kstream.internals

Class PrintedInternal<K,V>

java.lang.Object

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

org.apache.kafka.streams.kstream.internals.PrintedInternal<K,V>

public class PrintedInternal<K,V>
extends Printed<K,V>

Field Summary

Fields inherited from class org.apache.kafka.streams.kstream.Printed

label, mapper, outputStream, processorName

Constructor Summary

Constructors

Constructor	Description
PrintedInternal(Printed<K,V> printed)

Method Summary

Modifier and Type	Method	Description
ProcessorSupplier<K,V>	build(String processorName)
String	name()

Methods inherited from class org.apache.kafka.streams.kstream.Printed

toFile, toSysOut, withKeyValueMapper, withLabel, withName

Methods inherited from class java.lang.Object

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

Constructor Detail

PrintedInternal

public PrintedInternal(Printed<K,V> printed)

Method Detail

build

public ProcessorSupplier<K,V> build(String processorName)

name

public String name()