com.northconcepts.datapipeline.filter

Class Filter

java.lang.Object

com.northconcepts.datapipeline.filter.Filter

Direct Known Subclasses:

FieldCount, FieldExists, FieldFilter, FieldNotExists, FilterExpression, SchemaFilter

public abstract class Filter
extends Object

Constructor Summary

Constructors

Constructor and Description
Filter()

Method Summary

Modifier and Type	Method and Description
DataException	addExceptionProperties(DataException exception)
abstract boolean	allow(Record record) Tests whether a record passes this filter.
protected void	close() Called by FilteringReader when FilteringReader.close() is called (after reading ends).
static Filter	of(Predicate<Record> predicate) Creates a Filter from a Java Predicate.
protected void	open() Called by FilteringReader when FilteringReader.open() is called (before reading starts).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Filter

public Filter()

Method Detail

addExceptionProperties

public DataException addExceptionProperties(DataException exception)

open

protected void open()

Called by FilteringReader when FilteringReader.open() is called (before reading starts).

close

protected void close()

Called by FilteringReader when FilteringReader.close() is called (after reading ends).

allow

public abstract boolean allow(Record record)

Tests whether a record passes this filter.

Contract for subclasses (see also docs/authoring/Filter.md):

• Return true to keep the record.
• Return false to discard the record (routed to a discard writer if the host FilteringReader is configured with one).
• Must be a pure decision — do not mutate the record here.
• Throw DataException only for unrecoverable filter failures; for ordinary "data fails predicate" cases, return false.

of

public static Filter of(Predicate<Record> predicate)

Creates a Filter from a Java Predicate. This allows creation of filters using lambda expressions or method references.

Parameters:

predicate - the predicate that tests records

Returns:

a Filter that delegates to the predicate