com.northconcepts.datapipeline.foundations.schema

Class SchemaFilter

java.lang.Object

com.northconcepts.datapipeline.filter.Filter

com.northconcepts.datapipeline.foundations.schema.SchemaFilter

public class SchemaFilter
extends Filter

A filter that matches a record against an entity definition.

Constructor Summary

Constructors

Constructor and Description
SchemaFilter(EntityDef entity)

Method Summary

Modifier and Type	Method and Description
DataException	addExceptionProperties(DataException exception)
boolean	allow(Record record) Tests whether a record passes this filter.
boolean	equals(Object obj)
EntityDef	getEntity()
Record	getLastRecord()
int	hashCode()
String	toString()

Methods inherited from class com.northconcepts.datapipeline.filter.Filter

close, of, open

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SchemaFilter

public SchemaFilter(EntityDef entity)

Method Detail

allow

public boolean allow(Record record)

Description copied from class: Filter

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.

Specified by:

allow in class Filter

toString

public String toString()

Overrides:

toString in class Object

addExceptionProperties

public DataException addExceptionProperties(DataException exception)

Overrides:

addExceptionProperties in class Filter

getEntity

public EntityDef getEntity()

getLastRecord

public Record getLastRecord()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object