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
QueryPlanException
public 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
QueryPlanException
public QueryOperator getDestination() throws QueryPlanException
QueryPlanException
public void setSource(QueryOperator source) throws QueryPlanException
QueryPlanException
public void setDestination(QueryOperator destination) throws QueryPlanException
QueryPlanException
public Schema getOutputSchema()
protected void setOutputSchema(Schema schema)
protected abstract Schema computeSchema() throws QueryPlanException
QueryPlanException
public abstract Iterator<Record> execute() throws QueryPlanException, DatabaseException
QueryPlanException
DatabaseException
public 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
- QueryPlanException
Copyright © 2017. All rights reserved.