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 Transformation by configuring the transformation's predicate (and negate) configuration parameters. In particular, the Filter transformation 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 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