Table of Contents |
---|
Status
Current state: Under discussionAdopted
Discussion thread: here [Change the link from the KIP proposal email archive to your own email thread]
Vote thread: here
JIRA:
Jira | ||||||
---|---|---|---|---|---|---|
|
...
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();
} |
...