public abstract class QueryOperator extends Object
| Modifier and Type | Class and Description |
|---|---|
static class |
QueryOperator.OperatorType |
| Modifier | Constructor and Description |
|---|---|
|
QueryOperator(QueryOperator.OperatorType type) |
protected |
QueryOperator(QueryOperator.OperatorType type,
QueryOperator source) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
checkColumnNameEquality(String fromSchema,
String specified)
Utility method that checks to see if a column is found in a schema using dot notation.
|
String |
checkSchemaForColumn(Schema schema,
String columnName)
Utility method to determine whether or not a specified column name is valid with a given schema.
|
protected abstract Schema |
computeSchema() |
abstract Iterator<Record> |
execute() |
QueryOperator |
getDestination() |
Schema |
getOutputSchema() |
QueryOperator |
getSource() |
QueryOperator.OperatorType |
getType() |
boolean |
isGroupBy() |
boolean |
isIndexScan() |
boolean |
isJoin() |
boolean |
isSelect() |
boolean |
isSequentialScan() |
boolean |
isWhere() |
void |
setDestination(QueryOperator destination) |
protected void |
setOutputSchema(Schema schema) |
void |
setSource(QueryOperator source) |
public QueryOperator(QueryOperator.OperatorType type)
protected QueryOperator(QueryOperator.OperatorType type, QueryOperator source) throws QueryPlanException
QueryPlanExceptionpublic QueryOperator.OperatorType getType()
public boolean isJoin()
public boolean isWhere()
public boolean isSelect()
public boolean isGroupBy()
public boolean isSequentialScan()
public boolean isIndexScan()
public QueryOperator getSource() throws QueryPlanException
QueryPlanExceptionpublic QueryOperator getDestination() throws QueryPlanException
QueryPlanExceptionpublic void setSource(QueryOperator source) throws QueryPlanException
QueryPlanExceptionpublic void setDestination(QueryOperator destination) throws QueryPlanException
QueryPlanExceptionpublic Schema getOutputSchema()
protected void setOutputSchema(Schema schema)
protected abstract Schema computeSchema() throws QueryPlanException
QueryPlanExceptionpublic abstract Iterator<Record> execute() throws QueryPlanException, DatabaseException
QueryPlanExceptionDatabaseExceptionpublic boolean checkColumnNameEquality(String fromSchema, String specified)
fromSchema - the schema to search inspecified - the column name to search forpublic String checkSchemaForColumn(Schema schema, String columnName) throws QueryPlanException
schema - columnName - QueryPlanExceptionCopyright © 2017. All rights reserved.