Package org.spf4j.avro.calcite

Class SqlRowPredicate<T extends org.apache.avro.generic.IndexedRecord>

java.lang.Object

org.spf4j.avro.calcite.SqlRowPredicate<T>

All Implemented Interfaces:

Predicate<T>, SqlPredicate<T>

public final class SqlRowPredicate<T extends org.apache.avro.generic.IndexedRecord>
extends Object
implements SqlPredicate<T>

Author:

Zoltan Farkas

Constructor Summary

Constructors

Constructor	Description
SqlRowPredicate(String sqlExpr, org.apache.avro.Schema rowSchema)
SqlRowPredicate(List<org.apache.calcite.rex.RexNode> filter, org.apache.calcite.rel.type.RelDataType rowType)

Method Summary

Modifier and Type	Method	Description
String	getSqlString()
boolean	test(org.apache.avro.generic.IndexedRecord t)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Predicate

and, negate, or

Constructor Detail

SqlRowPredicate

public SqlRowPredicate(String sqlExpr,
                       org.apache.avro.Schema rowSchema)
                throws org.apache.calcite.sql.parser.SqlParseException,
                       org.apache.calcite.tools.ValidationException,
                       org.apache.calcite.tools.RelConversionException

Throws:

org.apache.calcite.sql.parser.SqlParseException

org.apache.calcite.tools.ValidationException

org.apache.calcite.tools.RelConversionException

SqlRowPredicate

public SqlRowPredicate(List<org.apache.calcite.rex.RexNode> filter,
                       org.apache.calcite.rel.type.RelDataType rowType)

Method Detail

test

public boolean test(org.apache.avro.generic.IndexedRecord t)

Specified by:

test in interface Predicate<T extends org.apache.avro.generic.IndexedRecord>

toString

public String toString()

Overrides:

toString in class Object

getSqlString

public String getSqlString()

Specified by:

getSqlString in interface SqlPredicate<T extends org.apache.avro.generic.IndexedRecord>