Package org.apache.wayang.spark.compiler

Class PredicateAdapter<InputType>

java.lang.Object

org.apache.wayang.spark.compiler.PredicateAdapter<InputType>

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.function.Function<InputType,Boolean>

public class PredicateAdapter<InputType>
extends Object
implements org.apache.spark.api.java.function.Function<InputType,Boolean>

Wraps a Predicate as a Function.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
PredicateAdapter(Predicate<InputType> predicate)

Method Summary

Modifier and Type	Method	Description
Boolean	call(InputType dataQuantum)

Methods inherited from class java.lang.Object

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

Constructor Details

PredicateAdapter

public PredicateAdapter(Predicate<InputType> predicate)

Method Details

call

public Boolean call(InputType dataQuantum)
             throws Exception

Specified by:

call in interface org.apache.spark.api.java.function.Function<InputType,Boolean>

Throws:

Exception