com.mapd.calcite.parser.MapDTable Class Reference

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)

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()

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

Detailed Description

Author

michael

Definition at line 35 of file MapDTable.java.

Constructor & Destructor Documentation

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

inline

Definition at line 46 of file MapDTable.java.

References com.mapd.calcite.parser.MapDTable.rowInfo.

                                     {
    rowInfo = ri;
  }

Member Function Documentation

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

inlineprivate

Definition at line 74 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:

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

inline

Definition at line 70 of file MapDTable.java.

                                             {
    return Schema.TableType.TABLE;
  }

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

inlineprivate

Definition at line 95 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:

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

inline

Definition at line 51 of file MapDTable.java.

References com.mapd.calcite.parser.MapDTable.createType(), and com.mapd.calcite.parser.MapDTable.rowInfo.

                                                         {
    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:

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

inline

Definition at line 65 of file MapDTable.java.

                                  {
    return Statistics.UNKNOWN;
  }

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

inline

Definition at line 42 of file MapDTable.java.

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

                           {
    return version;
  }

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

inline

Definition at line 143 of file MapDTable.java.

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

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

inline

Definition at line 149 of file MapDTable.java.

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

Member Data Documentation

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

staticpackage

Definition at line 38 of file MapDTable.java.

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

private

Definition at line 39 of file MapDTable.java.

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

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

private

Definition at line 40 of file MapDTable.java.

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

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

staticprivate

Definition at line 36 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