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

Class KStreamFlatTransform.KStreamFlatTransformProcessor<KIn,VIn,KOut,VOut>

java.lang.Object

org.apache.kafka.streams.processor.AbstractProcessor<KIn,VIn>

org.apache.kafka.streams.kstream.internals.KStreamFlatTransform.KStreamFlatTransformProcessor<KIn,VIn,KOut,VOut>

All Implemented Interfaces:

Processor<KIn,VIn>

Enclosing class:

KStreamFlatTransform<KIn,VIn,KOut,VOut>

public static class KStreamFlatTransform.KStreamFlatTransformProcessor<KIn,VIn,KOut,VOut>
extends AbstractProcessor<KIn,VIn>

Constructor Summary

Constructors

Constructor	Description
KStreamFlatTransformProcessor(Transformer<? super KIn,? super VIn,Iterable<KeyValue<KOut,VOut>>> transformer)

Method Summary

Modifier and Type	Method	Description
void	close()	Close this processor and clean up any resources.
void	init(ProcessorContext context)	Initialize this processor with the given context.
void	process(KIn key, VIn value)	Process the record with the given key and value.

Methods inherited from class org.apache.kafka.streams.processor.AbstractProcessor

context

Methods inherited from class java.lang.Object

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

Constructor Detail

KStreamFlatTransformProcessor

public KStreamFlatTransformProcessor(Transformer<? super KIn,? super VIn,Iterable<KeyValue<KOut,VOut>>> transformer)

Method Detail

init

public void init(ProcessorContext context)

Description copied from interface: Processor

Initialize this processor with the given context. The framework ensures this is called once per processor when the topology that contains it is initialized. When the framework is done with the processor, Processor.close() will be called on it; the framework may later re-use the processor by calling #init() again.

The provided context can be used to access topology and record meta data, to schedule a method to be called periodically and to access attached StateStores.

Specified by:

init in interface Processor<KIn,VIn>

Overrides:

init in class AbstractProcessor<KIn,VIn>

Parameters:

context - the context; may not be null

process

public void process(KIn key,
                    VIn value)

Description copied from interface: Processor

Process the record with the given key and value.

Parameters:

key - the key for the record

value - the value for the record

close

public void close()

Description copied from class: AbstractProcessor

Close this processor and clean up any resources.

This method does nothing by default; if desired, subclasses should override it with custom functionality.

Specified by:

close in interface Processor<KIn,VIn>

Overrides:

close in class AbstractProcessor<KIn,VIn>