public interface Transformation<R extends ConnectRecord<R>> extends Configurable, Closeable
Modifier and Type | Method and Description |
---|---|
R |
apply(R record)
Apply transformation to the
record and return another record object (which may be record itself) or null ,
corresponding to a map or filter operation respectively. |
void |
close()
Signal that this transformation instance will no longer will be used.
|
ConfigDef |
config()
Configuration specification for this transformation.
|
configure
R apply(R record)
record
and return another record object (which may be record
itself) or null
,
corresponding to a map or filter operation respectively.
The implementation must be thread-safe.ConfigDef config()
void close()
close
in interface AutoCloseable
close
in interface Closeable