org.apache.drill.exec.store.kafka

Class KafkaPartitionScanSpecBuilder

java.lang.Object

org.apache.drill.common.expression.visitors.AbstractExprVisitor<List<KafkaPartitionScanSpec>,Void,RuntimeException>

org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder

All Implemented Interfaces:

AutoCloseable, ExprVisitor<List<KafkaPartitionScanSpec>,Void,RuntimeException>

public class KafkaPartitionScanSpecBuilder
extends AbstractExprVisitor<List<KafkaPartitionScanSpec>,Void,RuntimeException>
implements AutoCloseable

Constructor Summary

Constructors

Constructor and Description
KafkaPartitionScanSpecBuilder(KafkaGroupScan groupScan, LogicalExpression conditionExp)

Method Summary

Modifier and Type	Method and Description
void	close()
List<KafkaPartitionScanSpec>	parseTree()
List<KafkaPartitionScanSpec>	visitBooleanOperator(BooleanOperator op, Void value)
List<KafkaPartitionScanSpec>	visitFunctionCall(FunctionCall call, Void value)
List<KafkaPartitionScanSpec>	visitUnknown(LogicalExpression e, Void value) Handles implementation-specific expressions not known to the visitor structure.

Methods inherited from class org.apache.drill.common.expression.visitors.AbstractExprVisitor

visitAnyValueExpression, visitBooleanConstant, visitCastExpression, visitConvertExpression, visitDateConstant, visitDecimal18Constant, visitDecimal28Constant, visitDecimal38Constant, visitDecimal9Constant, visitDoubleConstant, visitFloatConstant, visitFunctionHolderExpression, visitIfExpression, visitIntConstant, visitIntervalDayConstant, visitIntervalYearConstant, visitLongConstant, visitNullConstant, visitNullExpression, visitParameter, visitQuotedStringConstant, visitSchemaPath, visitTimeConstant, visitTimeStampConstant, visitTypedFieldExpr, visitVarDecimalConstant

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaPartitionScanSpecBuilder

public KafkaPartitionScanSpecBuilder(KafkaGroupScan groupScan,
                                     LogicalExpression conditionExp)

Method Detail

parseTree

public List<KafkaPartitionScanSpec> parseTree()

visitUnknown

public List<KafkaPartitionScanSpec> visitUnknown(LogicalExpression e,
                                                 Void value)

Description copied from class: AbstractExprVisitor

Handles implementation-specific expressions not known to the visitor structure. Since there are no "visitFoo" methods for these "unknown" expressions, subclassses should use the functionally-equivalent instanceof approach to parse out these "unknown" expressions.

Specified by:

visitUnknown in interface ExprVisitor<List<KafkaPartitionScanSpec>,Void,RuntimeException>

Overrides:

visitUnknown in class AbstractExprVisitor<List<KafkaPartitionScanSpec>,Void,RuntimeException>

visitBooleanOperator

public List<KafkaPartitionScanSpec> visitBooleanOperator(BooleanOperator op,
                                                         Void value)

Specified by:

visitBooleanOperator in interface ExprVisitor<List<KafkaPartitionScanSpec>,Void,RuntimeException>

Overrides:

visitBooleanOperator in class AbstractExprVisitor<List<KafkaPartitionScanSpec>,Void,RuntimeException>

visitFunctionCall

public List<KafkaPartitionScanSpec> visitFunctionCall(FunctionCall call,
                                                      Void value)

Specified by:

visitFunctionCall in interface ExprVisitor<List<KafkaPartitionScanSpec>,Void,RuntimeException>

Overrides:

visitFunctionCall in class AbstractExprVisitor<List<KafkaPartitionScanSpec>,Void,RuntimeException>

close

public void close()

Specified by:

close in interface AutoCloseable