KStreamFilter — ProcessorSupplier of KStreamFilterProcessors for filter and filterNot Streaming Operators

KStreamFilter is a ProcessorSupplier of KStreamFilterProcessors.

KStreamFilter is created when KStreamImpl is requested to execute the following streaming operators:

KStreamFilter takes the following when created:

  • Predicate (of K keys and V values)

  • filterNot flag

KStreamFilter creates a new KStreamFilterProcessor whenever requested to supply one.

KStreamFilterProcessor is an AbstractProcessor that requests the ProcessorContext to forward a record (to downstream processors) only when the Predicate is met.

results matching ""

    No results matching ""