V
- Value type.R
- Return type.public interface ValueTransformer<V,R>
Modifier and Type | Method and Description |
---|---|
void |
close()
Close this processor and clean up any resources.
|
void |
init(ProcessorContext context)
Initialize this transformer with the given context.
|
void |
punctuate(long timestamp)
Perform any periodic operations, if this processor
schedule itself with the context
during initialization . |
R |
transform(V value)
Transform the message with the given key and value.
|
void init(ProcessorContext context)
If this tranformer is to be called periodically
by the framework, then this method should
schedule itself
with the provided context.
context
- the context; may not be nullR transform(V value)
value
- the value for the messagevoid punctuate(long timestamp)
schedule itself
with the context
during initialization
.timestamp
- the stream time when this method is being calledvoid close()