...
Code Block | ||||
---|---|---|---|---|
| ||||
/**
* A condition on ConnectRecords.
* Implementations of this interface can be used for filtering records and conditionally applying Transformations.
* Implementations must be public and have a public constructor with no parameters.
*/
public interface Predicate<R extends ConnectRecord<R>> extends Configurable, AutoCloseable {
/**
* Configuration specification for this predicate.
*/
ConfigDef config();
/**
* Returns whether the given record satisfies this predicate.
*/
boolean test(R record);
@Override
void close();
} |
...