Skip to content

Latest commit

 

History

History
20 lines (13 loc) · 871 Bytes

kafka-streams-internals-KStreamTransformValues.adoc

File metadata and controls

20 lines (13 loc) · 871 Bytes

KStreamTransformValues — Supplier of KStreamTransformValuesProcessors

KStreamTransformValues is created exclusively when KStreamImpl is requested to transform values with optional state (aka stateful record-by-record value transformation).

KStreamTransformValues takes a InternalValueTransformerWithKeySupplier when created.

get Method

Processor<K, V> get()
Note
get is part of ProcessorSupplier Contract to supply a stream processor.

get…​FIXME