Inheritance diagram for com.mapd.calcite.parser.HeavyDBTable:

Collaboration diagram for com.mapd.calcite.parser.HeavyDBTable:

Public Member Functions
long	getVersion ()

	HeavyDBTable (TTableDetails ri)

RelDataType	getRowType (RelDataTypeFactory rdtf)

Statistic	getStatistic ()

Schema.TableType	getJdbcTableType ()

boolean	isRolledUp (String string)

boolean	rolledUpColumnValidInsideAgg (String string, SqlCall sc, SqlNode sn, CalciteConnectionConfig ccc)

boolean	isSystemColumn (final String columnName)

Static Package Attributes
static final Logger	HEAVYDBLOGGER = LoggerFactory.getLogger(HeavyDBTable.class)

Private Member Functions
RelDataType	createType (TColumnType value, RelDataTypeFactory typeFactory)

RelDataType	getRelDataType (TDatumType dType, int precision, int scale, RelDataTypeFactory typeFactory)

Private Attributes
final TTableDetails	rowInfo

final long	version = VERSION_PROVIDER.incrementAndGet()

final HashSet< String >	systemColumnNames

Static Private Attributes
static final AtomicLong	VERSION_PROVIDER = new AtomicLong()

Detailed Description

Definition at line 45 of file HeavyDBTable.java.

Constructor & Destructor Documentation

com.mapd.calcite.parser.HeavyDBTable.HeavyDBTable ( TTableDetails ri )

inline

Definition at line 57 of file HeavyDBTable.java.

References com.mapd.calcite.parser.HeavyDBTable.rowInfo, and com.mapd.calcite.parser.HeavyDBTable.systemColumnNames.

                                         {
     rowInfo = ri;
     systemColumnNames = rowInfo.row_desc.stream()
                                 .filter(row_desc -> row_desc.is_system)
                                 .map(row_desc -> row_desc.col_name)
                                 .collect(Collectors.toCollection(HashSet::new));
   }

Member Function Documentation

RelDataType com.mapd.calcite.parser.HeavyDBTable.createType	(	TColumnType	value,
		RelDataTypeFactory	typeFactory
	)

inlineprivate

Definition at line 89 of file HeavyDBTable.java.

References com.mapd.calcite.parser.HeavyDBTable.getRelDataType().

Referenced by com.mapd.calcite.parser.HeavyDBTable.getRowType().

                                                                                     {
     RelDataType cType = getRelDataType(value.col_type.type,
             value.col_type.precision,
             value.col_type.scale,
             typeFactory);
 
     if (value.col_type.is_array) {
       cType = typeFactory.createArrayType(
               typeFactory.createTypeWithNullability(cType, true), -1);
     }
 
     if (value.col_type.isNullable()) {
       return typeFactory.createTypeWithNullability(cType, true);
     } else {
       return cType;
     }
   }

Here is the call graph for this function:

Here is the caller graph for this function:

Schema.TableType com.mapd.calcite.parser.HeavyDBTable.getJdbcTableType ( )

inline

Definition at line 85 of file HeavyDBTable.java.

                                              {
     return Schema.TableType.TABLE;
   }

RelDataType com.mapd.calcite.parser.HeavyDBTable.getRelDataType	(	TDatumType	dType,
		int	precision,
		int	scale,
		RelDataTypeFactory	typeFactory
	)

inlineprivate

Definition at line 110 of file HeavyDBTable.java.

Referenced by com.mapd.calcite.parser.HeavyDBTable.createType().

                                                                                       {
     switch (dType) {
       case TINYINT:
         return typeFactory.createSqlType(SqlTypeName.TINYINT);
       case SMALLINT:
         return typeFactory.createSqlType(SqlTypeName.SMALLINT);
       case INT:
         return typeFactory.createSqlType(SqlTypeName.INTEGER);
       case BIGINT:
         return typeFactory.createSqlType(SqlTypeName.BIGINT);
       case FLOAT:
         return typeFactory.createSqlType(SqlTypeName.FLOAT);
       case DECIMAL:
         return typeFactory.createSqlType(SqlTypeName.DECIMAL, precision, scale);
       case DOUBLE:
         return typeFactory.createSqlType(SqlTypeName.DOUBLE);
       case STR:
         return typeFactory.createSqlType(SqlTypeName.VARCHAR, 50);
       case TIME:
         return typeFactory.createSqlType(SqlTypeName.TIME);
       case TIMESTAMP:
         return typeFactory.createSqlType(SqlTypeName.TIMESTAMP, precision);
       case DATE:
         return typeFactory.createSqlType(SqlTypeName.DATE);
       case BOOL:
         return typeFactory.createSqlType(SqlTypeName.BOOLEAN);
       case INTERVAL_DAY_TIME:
         return typeFactory.createSqlType(SqlTypeName.INTERVAL_DAY);
       case INTERVAL_YEAR_MONTH:
         return typeFactory.createSqlType(SqlTypeName.INTERVAL_YEAR_MONTH);
       case POINT:
         return typeFactory.createSqlType(SqlTypeName.GEOMETRY);
       // return new PointSqlType();
       case MULTIPOINT:
         return typeFactory.createSqlType(SqlTypeName.GEOMETRY);
       // return new MultipointSqlType();
       case LINESTRING:
         return typeFactory.createSqlType(SqlTypeName.GEOMETRY);
       // return new LinestringSqlType();
       case MULTILINESTRING:
         return typeFactory.createSqlType(SqlTypeName.GEOMETRY);
       // return new MultilinestringSqlType();
       case POLYGON:
         return typeFactory.createSqlType(SqlTypeName.GEOMETRY);
       // return new PolygonSqlType();
       case MULTIPOLYGON:
         return typeFactory.createSqlType(SqlTypeName.GEOMETRY);
       // return new MultipolygonSqlType();
       default:
         throw new AssertionError(dType.name());
     }
   }

Here is the caller graph for this function:

RelDataType com.mapd.calcite.parser.HeavyDBTable.getRowType ( RelDataTypeFactory rdtf )

inline

Definition at line 66 of file HeavyDBTable.java.

References com.mapd.calcite.parser.HeavyDBTable.createType(), anonymous_namespace{DBETypes.cpp}.getFieldValue(), and com.mapd.calcite.parser.HeavyDBTable.rowInfo.

                                                          {
     RelDataTypeFactory.Builder builder = rdtf.builder();
     for (TColumnType tct : rowInfo.getRow_desc()) {
       HEAVYDBLOGGER.debug("'" + tct.col_name + "'"
               + " \t" + tct.getCol_type().getEncoding() + " \t"
               + tct.getCol_type().getFieldValue(TTypeInfo._Fields.TYPE) + " \t"
               + tct.getCol_type().nullable + " \t" + tct.getCol_type().is_array + " \t"
               + tct.getCol_type().precision + " \t" + tct.getCol_type().scale);
       builder.add(tct.col_name, createType(tct, rdtf));
     }
     return builder.build();
   }

Here is the call graph for this function:

Statistic com.mapd.calcite.parser.HeavyDBTable.getStatistic ( )

inline

Definition at line 80 of file HeavyDBTable.java.

                                   {
     return Statistics.UNKNOWN;
   }

long com.mapd.calcite.parser.HeavyDBTable.getVersion ( )

inline

Definition at line 53 of file HeavyDBTable.java.

References com.mapd.calcite.parser.HeavyDBTable.version.

                            {
     return version;
   }

boolean com.mapd.calcite.parser.HeavyDBTable.isRolledUp ( String string )

inline

Definition at line 165 of file HeavyDBTable.java.

                                            {
     // will set to false by default
     return false;
   }

boolean com.mapd.calcite.parser.HeavyDBTable.isSystemColumn ( final String columnName )

inline

Definition at line 177 of file HeavyDBTable.java.

                                                          {
     return systemColumnNames.contains(columnName);
   }

boolean com.mapd.calcite.parser.HeavyDBTable.rolledUpColumnValidInsideAgg	(	String	string,
		SqlCall	sc,
		SqlNode	sn,
		CalciteConnectionConfig	ccc
	)

inline

Definition at line 171 of file HeavyDBTable.java.

                                                                               {
     throw new UnsupportedOperationException(
             "rolledUpColumnValidInsideAgg Not supported yet.");
   }

Member Data Documentation

final Logger com.mapd.calcite.parser.HeavyDBTable.HEAVYDBLOGGER = LoggerFactory.getLogger(HeavyDBTable.class)

staticpackage

Definition at line 48 of file HeavyDBTable.java.

final TTableDetails com.mapd.calcite.parser.HeavyDBTable.rowInfo

private

Definition at line 49 of file HeavyDBTable.java.

Referenced by com.mapd.calcite.parser.HeavyDBTable.getRowType(), and com.mapd.calcite.parser.HeavyDBTable.HeavyDBTable().

final HashSet<String> com.mapd.calcite.parser.HeavyDBTable.systemColumnNames

private

Definition at line 51 of file HeavyDBTable.java.

Referenced by com.mapd.calcite.parser.HeavyDBTable.HeavyDBTable().

final long com.mapd.calcite.parser.HeavyDBTable.version = VERSION_PROVIDER.incrementAndGet()

private

Definition at line 50 of file HeavyDBTable.java.

Referenced by com.mapd.calcite.parser.HeavyDBTable.getVersion(), heavydb.thrift.ttypes.TServerStatus.read(), and heavydb.thrift.ttypes.TServerStatus.write().

final AtomicLong com.mapd.calcite.parser.HeavyDBTable.VERSION_PROVIDER = new AtomicLong()

staticprivate

Definition at line 46 of file HeavyDBTable.java.

The documentation for this class was generated from the following file:

/home/jenkins-slave/workspace/core-os-doxygen/java/calcite/src/main/java/com/mapd/calcite/parser/HeavyDBTable.java

Public Member Functions

Static Package Attributes

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation