Interface Predicate<R extends ConnectRecord<R>>
-
- Type Parameters:
R- The type of record.
- All Superinterfaces:
AutoCloseable,Configurable
public interface Predicate<R extends ConnectRecord<R>> extends Configurable, AutoCloseable
A predicate on records. Predicates can be used to conditionally apply a
Transformationby configuring the transformation'spredicate(andnegate) configuration parameters. In particular, theFiltertransformation can be conditionally applied in order to filter certain records from further processing.Implementations of this interface must be public and have a public constructor with no parameters.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidclose()ConfigDefconfig()Configuration specification for this predicate.booleantest(R record)Returns whether the given record satisfies this predicate.-
Methods inherited from interface org.apache.kafka.common.Configurable
configure
-
-
-
-
Method Detail
-
config
ConfigDef config()
Configuration specification for this predicate.- Returns:
- the configuration definition for this predicate; never null
-
test
boolean test(R record)
Returns whether the given record satisfies this predicate.- Parameters:
record- the record to evaluate; may not be null- Returns:
- true if the predicate matches, or false otherwise
-
close
void close()
- Specified by:
closein interfaceAutoCloseable
-
-