Package nz.org.riskscape.engine.restriction

Class DefaultRestrictor

java.lang.Object

nz.org.riskscape.engine.restriction.DefaultRestrictor

All Implemented Interfaces:

AutoCloseable, Predicate<Tuple>, Realized, Restrictor

public class DefaultRestrictor
extends Object
implements Restrictor

Constructor Summary

Constructors

Constructor	Description
DefaultRestrictor(Struct sourceType, Predicate<Tuple> predicate)
DefaultRestrictor(Struct sourceType, Predicate<Tuple> predicate, Runnable closeFunction)

Method Summary

Modifier and Type	Method	Description
void	close()	Clean up any resources allocated to this Realized thing.
Predicate<Tuple>	getPredicate()
Struct	getSourceType()	The exact Struct that Tuple's passed to Predicate.test(java.lang.Object) should be of.
boolean	test(Tuple t)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Predicate

and, negate, or

Constructor Details

DefaultRestrictor

public DefaultRestrictor(Struct sourceType,
 Predicate<Tuple> predicate)

DefaultRestrictor

public DefaultRestrictor(Struct sourceType,
 Predicate<Tuple> predicate,
 Runnable closeFunction)

Method Details

test

public boolean test(Tuple t)

Specified by:

test in interface Predicate<Tuple>

close

public void close()

Description copied from interface: Realized

Clean up any resources allocated to this Realized thing. This might involve removing temporary files, closing or flushing a network connection to some external service, or terminating some child processes. Note that it's expected that this object won't be used again after being closed.

In some instances, implementations may want to remove references to large (in terms of memory) objects so that they can be garbage collected even if references to the pipeline continue to keep them 'live' in the JVM's object graph

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Realized

getSourceType

public Struct getSourceType()

Description copied from interface: Restrictor

The exact Struct that Tuple's passed to Predicate.test(java.lang.Object) should be of.

Specified by:

getSourceType in interface Restrictor

getPredicate

public Predicate<Tuple> getPredicate()