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

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

Public Member Functions
long	getVersion ()

	MapDTable (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	MAPDLOGGER = LoggerFactory.getLogger(MapDTable.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

Author: michael

Definition at line 37 of file MapDTable.java.

Constructor & Destructor Documentation

◆ MapDTable()

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

inline

Definition at line 49 of file MapDTable.java.

                                      {
     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

◆ createType()

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

inlineprivate

Definition at line 81 of file MapDTable.java.

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

Referenced by com.mapd.calcite.parser.MapDTable.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:

◆ getJdbcTableType()

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

inline

Definition at line 77 of file MapDTable.java.

                                              {
     return Schema.TableType.TABLE;
   }

◆ getRelDataType()

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

inlineprivate

Definition at line 102 of file MapDTable.java.

Referenced by com.mapd.calcite.parser.MapDTable.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.ANY);
         // return new PointSqlType();
       case LINESTRING:
         return typeFactory.createSqlType(SqlTypeName.ANY);
         // return new LinestringSqlType();
       case POLYGON:
         return typeFactory.createSqlType(SqlTypeName.ANY);
         // return new PolygonSqlType();
       case MULTIPOLYGON:
         return typeFactory.createSqlType(SqlTypeName.ANY);
       default:
         throw new AssertionError(dType.name());
     }
   }

Here is the caller graph for this function:

◆ getRowType()

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

inline

Definition at line 58 of file MapDTable.java.

References com.mapd.calcite.parser.MapDTable.createType().

                                                          {
     RelDataTypeFactory.FieldInfoBuilder builder = rdtf.builder();
     for (TColumnType tct : rowInfo.getRow_desc()) {
       MAPDLOGGER.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:

◆ getStatistic()

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

inline

Definition at line 72 of file MapDTable.java.

                                   {
     return Statistics.UNKNOWN;
   }

◆ getVersion()

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

inline

Definition at line 45 of file MapDTable.java.

References com.mapd.calcite.parser.MapDTable.version.

                            {
     return version;
   }

◆ isRolledUp()

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

inline

Definition at line 150 of file MapDTable.java.

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

◆ isSystemColumn()

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

inline

Definition at line 162 of file MapDTable.java.

Referenced by org.apache.calcite.prepare.CalciteSqlValidator.isSystemColumn().

                                                          {
     return systemColumnNames.contains(columnName);
   }

Here is the caller graph for this function:

◆ rolledUpColumnValidInsideAgg()

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

inline

Definition at line 156 of file MapDTable.java.

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

Member Data Documentation

◆ MAPDLOGGER

final Logger com.mapd.calcite.parser.MapDTable.MAPDLOGGER = LoggerFactory.getLogger(MapDTable.class)

staticpackage

Definition at line 40 of file MapDTable.java.

◆ rowInfo

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

private

Definition at line 41 of file MapDTable.java.

◆ systemColumnNames

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

private

Definition at line 43 of file MapDTable.java.

◆ version

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

private

Definition at line 42 of file MapDTable.java.

Referenced by com.mapd.calcite.parser.MapDTable.getVersion().

◆ VERSION_PROVIDER

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

staticprivate

Definition at line 38 of file MapDTable.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/MapDTable.java

Public Member Functions

Static Package Attributes

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ MapDTable()

Member Function Documentation

◆ createType()

◆ getJdbcTableType()

◆ getRelDataType()

◆ getRowType()

◆ getStatistic()

◆ getVersion()

◆ isRolledUp()

◆ isSystemColumn()

◆ rolledUpColumnValidInsideAgg()

Member Data Documentation

◆ MAPDLOGGER

◆ rowInfo

◆ systemColumnNames

◆ version

◆ VERSION_PROVIDER