edu.yale.cs.hadoopdb.sms
Class SQLQuery

java.lang.Object
  extended by edu.yale.cs.hadoopdb.sms.SQLQuery

public class SQLQuery
extends java.lang.Object

Maintains a SQL query information and related structures during Hive plan analysis in SMS Planner


Field Summary
(package private)  java.util.HashMap<java.lang.String,java.lang.String> columnAliasMap
           
(package private)  java.util.List<java.lang.String> columnList
           
(package private)  java.util.HashMap<java.lang.String,java.lang.String> columnTypeMap
           
(package private)  java.util.HashMap<java.lang.String,java.lang.String> fields
           
(package private)  java.lang.String sqlQuery
           
private  java.lang.String tableAlias
           
private  java.lang.String tableName
           
 
Constructor Summary
SQLQuery(java.lang.String tableName, java.lang.String tableAlias)
           
 
Method Summary
 void addColumn(java.lang.String name, java.lang.String type)
           
 java.lang.String getColumnAlias(java.lang.String columnName)
           
 java.lang.String getDBQuerySchema()
           
 java.lang.String getDDLColumns()
           
 java.lang.String getDDLColumnTypes()
           
 java.lang.String getField(java.lang.String name)
           
 java.lang.String getSerializationDDL()
           
 java.lang.String getSqlQuery()
           
 java.util.Vector<org.apache.hadoop.hive.ql.exec.ColumnInfo> getTableRowSchema()
           
 void putColumnAlias(java.lang.String name, java.lang.String alias)
           
 void putField(java.lang.String name, java.lang.String type)
           
 void removeColumn(java.lang.String name, java.lang.String type)
           
 void retainColumns(java.util.Collection<java.lang.String> cols)
           
private  java.lang.String typeDLL(java.lang.String type)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

columnAliasMap

java.util.HashMap<java.lang.String,java.lang.String> columnAliasMap

columnList

java.util.List<java.lang.String> columnList

columnTypeMap

java.util.HashMap<java.lang.String,java.lang.String> columnTypeMap

fields

java.util.HashMap<java.lang.String,java.lang.String> fields

sqlQuery

java.lang.String sqlQuery

tableAlias

private java.lang.String tableAlias

tableName

private java.lang.String tableName
Constructor Detail

SQLQuery

public SQLQuery(java.lang.String tableName,
                java.lang.String tableAlias)
Method Detail

addColumn

public void addColumn(java.lang.String name,
                      java.lang.String type)

getColumnAlias

public java.lang.String getColumnAlias(java.lang.String columnName)

getDBQuerySchema

public java.lang.String getDBQuerySchema()

getDDLColumns

public java.lang.String getDDLColumns()

getDDLColumnTypes

public java.lang.String getDDLColumnTypes()

getField

public java.lang.String getField(java.lang.String name)

getSerializationDDL

public java.lang.String getSerializationDDL()

getSqlQuery

public java.lang.String getSqlQuery()

getTableRowSchema

public java.util.Vector<org.apache.hadoop.hive.ql.exec.ColumnInfo> getTableRowSchema()

putColumnAlias

public void putColumnAlias(java.lang.String name,
                           java.lang.String alias)

putField

public void putField(java.lang.String name,
                     java.lang.String type)

removeColumn

public void removeColumn(java.lang.String name,
                         java.lang.String type)

retainColumns

public void retainColumns(java.util.Collection<java.lang.String> cols)

typeDLL

private java.lang.String typeDLL(java.lang.String type)