Collaboration diagram for com.mapd.metadata.MetaConnect:

Public Member Functions
	MetaConnect (int dbPort, String dataDir, HeavyDBUser currentHeavyDBUser, HeavyDBParser parser, SockTransportProperties skT, String db)

	MetaConnect (int dbPort, String dataDir, HeavyDBUser currentHeavyDBUser, HeavyDBParser parser, SockTransportProperties skT)

List< String >	getDatabases ()

Table	getTable (String tableName)

Set< String >	getTables ()

TTableDetails	get_table_details (String tableName)

void	updateMetaData (String schema, String table)

Static Public Member Functions
static final int	get_physical_cols (int type)

static final boolean	is_geometry (int type)

Package Functions
String	getCatalogFileName (String catalog)

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

Private Member Functions
void	connectToCatalog (String catalog)

void	disconnectFromCatalog ()

void	connectToDBCatalog ()

Set< String >	getTables_SQL ()

TTableDetails	get_table_detail_SQL (String tableName)

TTableDetails	get_table_detail_JSON (String tableName) throws IOException, RuntimeException

int	getTableId (String tableName)

boolean	isView (String tableName)

String	getViewSql (String tableName)

String	getViewSqlViaSql (int tableId)

TDatumType	typeToThrift (int type)

TEncodingType	encodingToThrift (int comp)

void	populateDatabases ()

Set< String >	getDatabases_SQL ()

Private Attributes
final String	dataDir

final String	default_db

final HeavyDBUser	currentUser

final int	dbPort

Connection	catConn

final HeavyDBParser	parser

final SockTransportProperties	sock_transport_properties

Static Private Attributes
static final int	KBOOLEAN = 1

static final int	KCHAR = 2

static final int	KVARCHAR = 3

static final int	KNUMERIC = 4

static final int	KDECIMAL = 5

static final int	KINT = 6

static final int	KSMALLINT = 7

static final int	KFLOAT = 8

static final int	KDOUBLE = 9

static final int	KTIME = 10

static final int	KTIMESTAMP = 11

static final int	KBIGINT = 12

static final int	KTEXT = 13

static final int	KDATE = 14

static final int	KARRAY = 15

static final int	KINTERVAL_DAY_TIME = 16

static final int	KINTERVAL_YEAR_MONTH = 17

static final int	KPOINT = 18

static final int	KLINESTRING = 19

static final int	KPOLYGON = 20

static final int	KMULTIPOLYGON = 21

static final int	KTINYINT = 22

static final int	KMULTILINESTRING = 30

static final int	KMULTIPOINT = 31

static final String	CATALOG_DIR_NAME = "catalogs"

static volatile Map< String, Set< String > >	DATABASE_TO_TABLES

static volatile Map< List < String >, Table >	DB_TABLE_DETAILS

Detailed Description

Definition at line 66 of file MetaConnect.java.

Constructor & Destructor Documentation

com.mapd.metadata.MetaConnect.MetaConnect	(	int	dbPort,
		String	dataDir,
		HeavyDBUser	currentHeavyDBUser,
		HeavyDBParser	parser,
		SockTransportProperties	skT,
		String	db
	)

inline

Definition at line 107 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.currentUser, com.mapd.metadata.MetaConnect.DATABASE_TO_TABLES, com.mapd.metadata.MetaConnect.dataDir, com.mapd.metadata.MetaConnect.dbPort, com.mapd.metadata.MetaConnect.parser, and com.mapd.metadata.MetaConnect.populateDatabases().

                      {
     this.dataDir = dataDir;
     if (db != null) {
       this.default_db = db;
     } else {
       if (currentHeavyDBUser != null) {
         this.default_db = currentHeavyDBUser.getDB();
       } else {
         this.default_db = null;
       }
     }
     this.currentUser = currentHeavyDBUser;
     this.dbPort = dbPort;
     this.parser = parser;
     this.sock_transport_properties = skT;
 
     // check to see if we have a populated DATABASE_TO_TABLES structure
     // first time in we need to make sure this gets populated
     // It is OK to use a MetaConnect without a user
     // but it should not attempt to populate the DB
     if (currentUser != null && DATABASE_TO_TABLES.size() == 0) {
       // get all databases
       populateDatabases();
     }
   }

Here is the call graph for this function:

com.mapd.metadata.MetaConnect.MetaConnect	(	int	dbPort,
		String	dataDir,
		HeavyDBUser	currentHeavyDBUser,
		HeavyDBParser	parser,
		SockTransportProperties	skT
	)

inline

Definition at line 138 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.dataDir, com.mapd.metadata.MetaConnect.dbPort, and com.mapd.metadata.MetaConnect.parser.

                                        {
     this(dbPort, dataDir, currentHeavyDBUser, parser, skT, null);
   }

Member Function Documentation

void com.mapd.metadata.MetaConnect.connectToCatalog ( String catalog )

inlineprivate

Definition at line 154 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.CATALOG_DIR_NAME, com.mapd.metadata.MetaConnect.catConn, com.mapd.metadata.MetaConnect.dataDir, and com.mapd.metadata.MetaConnect.getCatalogFileName().

Referenced by com.mapd.metadata.MetaConnect.connectToDBCatalog(), and com.mapd.metadata.MetaConnect.populateDatabases().

                                                 {
     try {
       // try {
       Class.forName("org.sqlite.JDBC");
     } catch (ClassNotFoundException ex) {
       String err = "Could not find class for metadata connection; DB: '" + catalog
               + "' data dir '" + dataDir + "', error was " + ex.getMessage();
       HEAVYDBLOGGER.error(err);
       throw new RuntimeException(err);
     }
     String connectURL = "jdbc:sqlite:" + dataDir + "/" + CATALOG_DIR_NAME + "/"
             + getCatalogFileName(catalog);
     try {
       catConn = DriverManager.getConnection(connectURL);
     } catch (SQLException ex) {
       String err = "Could not establish a connection for metadata; DB: '" + catalog
               + "' data dir '" + dataDir + "', error was " + ex.getMessage();
       HEAVYDBLOGGER.error(err);
       throw new RuntimeException(err);
     }
     HEAVYDBLOGGER.debug("Opened database successfully");
   }

Here is the call graph for this function:

Here is the caller graph for this function:

void com.mapd.metadata.MetaConnect.connectToDBCatalog ( )

inlineprivate

Definition at line 202 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.connectToCatalog(), and com.mapd.metadata.MetaConnect.default_db.

Referenced by com.mapd.metadata.MetaConnect.get_table_details(), com.mapd.metadata.MetaConnect.getTables(), com.mapd.metadata.MetaConnect.getTables_SQL(), and com.mapd.metadata.MetaConnect.getViewSql().

                                     {
     connectToCatalog(default_db);
   }

Here is the call graph for this function:

Here is the caller graph for this function:

void com.mapd.metadata.MetaConnect.disconnectFromCatalog ( )

inlineprivate

Definition at line 191 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.dataDir.

Referenced by com.mapd.metadata.MetaConnect.get_table_details(), com.mapd.metadata.MetaConnect.getTables(), com.mapd.metadata.MetaConnect.getTables_SQL(), com.mapd.metadata.MetaConnect.getViewSql(), and com.mapd.metadata.MetaConnect.populateDatabases().

                                        {
     try {
       catConn.close();
     } catch (SQLException ex) {
       String err = "Could not disconnect from metadata "
               + " data dir '" + dataDir + "', error was " + ex.getMessage();
       HEAVYDBLOGGER.error(err);
       throw new RuntimeException(err);
     }
   }

Here is the caller graph for this function:

TEncodingType com.mapd.metadata.MetaConnect.encodingToThrift ( int comp )

inlineprivate

Definition at line 823 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_table_detail_JSON(), and com.mapd.metadata.MetaConnect.get_table_detail_SQL().

                                                    {
     switch (comp) {
       case 0:
         return TEncodingType.NONE;
       case 1:
         return TEncodingType.FIXED;
       case 2:
         return TEncodingType.RL;
       case 3:
         return TEncodingType.DIFF;
       case 4:
         return TEncodingType.DICT;
       case 5:
         return TEncodingType.SPARSE;
       case 6:
         return TEncodingType.GEOINT;
       case 7:
         return TEncodingType.DATE_IN_DAYS;
       default:
         return null;
     }
   }

Here is the caller graph for this function:

static final int com.mapd.metadata.MetaConnect.get_physical_cols ( int type )

inlinestatic

Definition at line 385 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.KLINESTRING, com.mapd.metadata.MetaConnect.KMULTILINESTRING, com.mapd.metadata.MetaConnect.KMULTIPOINT, com.mapd.metadata.MetaConnect.KMULTIPOLYGON, com.mapd.metadata.MetaConnect.KPOINT, and com.mapd.metadata.MetaConnect.KPOLYGON.

Referenced by com.mapd.metadata.MetaConnect.get_table_detail_JSON(), and com.mapd.metadata.MetaConnect.get_table_detail_SQL().

                                                       {
     switch (type) {
       case KPOINT:
         return 1; // coords
       case KMULTIPOINT:
       case KLINESTRING:
         return 2; // coords, bounds
       case KMULTILINESTRING:
         return 3; // coords, linestring_sizes, bounds
       case KPOLYGON:
         return 3; // coords, ring_sizes, bounds
       case KMULTIPOLYGON:
         return 4; // coords, ring_sizes, poly_rings, bounds
       default:
         break;
     }
     return 0;
   }

Here is the caller graph for this function:

TTableDetails com.mapd.metadata.MetaConnect.get_table_detail_JSON ( String tableName ) throws IOException, RuntimeException

inlineprivate

Definition at line 522 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.CATALOG_DIR_NAME, com.mapd.metadata.MetaConnect.dataDir, com.mapd.metadata.MetaConnect.default_db, com.mapd.metadata.MetaConnect.encodingToThrift(), com.mapd.metadata.MetaConnect.get_physical_cols(), com.mapd.metadata.MetaConnect.is_geometry(), com.mapd.metadata.MetaConnect.KARRAY, and com.mapd.metadata.MetaConnect.typeToThrift().

Referenced by com.mapd.metadata.MetaConnect.get_table_detail_SQL().

                                                {
     TTableDetails td = new TTableDetails();
     td.getRow_descIterator();
 
     // open table json file
     final String filePath =
             dataDir + "/" + CATALOG_DIR_NAME + "/" + default_db + "_temp_tables.json";
     HEAVYDBLOGGER.debug("Opening temp table file at " + filePath);
 
     String tempTablesJsonStr;
     try {
       File tempTablesFile = new File(filePath);
       FileInputStream tempTablesStream = new FileInputStream(tempTablesFile);
       byte[] data = new byte[(int) tempTablesFile.length()];
       tempTablesStream.read(data);
       tempTablesStream.close();
 
       tempTablesJsonStr = new String(data, "UTF-8");
     } catch (java.io.FileNotFoundException e) {
       throw new RuntimeException("Failed to read temporary tables file.");
     }
 
     Gson gson = new Gson();
     JsonObject fileParentObject = gson.fromJson(tempTablesJsonStr, JsonObject.class);
     if (fileParentObject == null) {
       throw new IOException("Malformed temporary tables file.");
     }
 
     JsonObject tableObject = fileParentObject.getAsJsonObject(tableName);
     if (tableObject == null) {
       throw new RuntimeException(
               "Failed to find table " + tableName + " in temporary tables file.");
     }
 
     String jsonTableName = tableObject.get("name").getAsString();
     assert (tableName == jsonTableName);
     int id = tableObject.get("id").getAsInt();
     HEAVYDBLOGGER.debug("table id is " + id);
     HEAVYDBLOGGER.debug("table name is " + tableName);
 
     JsonArray jsonColumns = tableObject.getAsJsonArray("columns");
     assert (jsonColumns != null);
 
     int skip_physical_cols = 0;
     for (JsonElement columnElement : jsonColumns) {
       JsonObject columnObject = columnElement.getAsJsonObject();
 
       String colName = columnObject.get("name").getAsString();
       HEAVYDBLOGGER.debug("name = " + colName);
       int colType = columnObject.get("coltype").getAsInt();
       HEAVYDBLOGGER.debug("coltype = " + colType);
       int colSubType = columnObject.get("colsubtype").getAsInt();
       HEAVYDBLOGGER.debug("colsubtype = " + colSubType);
       int compression = columnObject.get("compression").getAsInt();
       HEAVYDBLOGGER.debug("compression = " + compression);
       int compression_param = columnObject.get("comp_param").getAsInt();
       HEAVYDBLOGGER.debug("comp_param = " + compression_param);
       int size = columnObject.get("size").getAsInt();
       HEAVYDBLOGGER.debug("size = " + size);
       int colDim = columnObject.get("coldim").getAsInt();
       HEAVYDBLOGGER.debug("coldim = " + colDim);
       int colScale = columnObject.get("colscale").getAsInt();
       HEAVYDBLOGGER.debug("colscale = " + colScale);
       boolean isNotNull = columnObject.get("is_notnull").getAsBoolean();
       HEAVYDBLOGGER.debug("is_notnull = " + isNotNull);
       boolean isSystemCol = columnObject.get("is_systemcol").getAsBoolean();
       HEAVYDBLOGGER.debug("is_systemcol = " + isSystemCol);
       boolean isVirtualCol = columnObject.get("is_virtualcol").getAsBoolean();
       HEAVYDBLOGGER.debug("is_vitrualcol = " + isVirtualCol);
       boolean isDeletedCol = columnObject.get("is_deletedcol").getAsBoolean();
       HEAVYDBLOGGER.debug("is_deletedcol = " + isDeletedCol);
       HEAVYDBLOGGER.debug("");
 
       if (isDeletedCol) {
         HEAVYDBLOGGER.debug("Skipping delete column.");
         continue;
       }
 
       TColumnType tct = new TColumnType();
       TTypeInfo tti = new TTypeInfo();
       TDatumType tdt;
 
       if (colType == KARRAY) {
         tti.is_array = true;
         tdt = typeToThrift(colSubType);
       } else {
         tti.is_array = false;
         tdt = typeToThrift(colType);
       }
 
       tti.nullable = !isNotNull;
       tti.encoding = encodingToThrift(compression);
       tti.comp_param = compression_param;
       tti.size = size;
       tti.type = tdt;
       tti.scale = colScale;
       tti.precision = colDim;
 
       tct.col_name = colName;
       tct.col_type = tti;
       tct.is_system = isSystemCol;
 
       if (skip_physical_cols <= 0) skip_physical_cols = get_physical_cols(colType);
       if (is_geometry(colType) || skip_physical_cols-- <= 0) td.addToRow_desc(tct);
     }
 
     return td;
   }

Here is the call graph for this function:

Here is the caller graph for this function:

TTableDetails com.mapd.metadata.MetaConnect.get_table_detail_SQL ( String tableName )

inlineprivate

Definition at line 409 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.default_db, com.mapd.metadata.MetaConnect.encodingToThrift(), com.mapd.metadata.MetaConnect.get_physical_cols(), com.mapd.metadata.MetaConnect.get_table_detail_JSON(), com.mapd.metadata.MetaConnect.getTableId(), com.mapd.metadata.MetaConnect.getViewSqlViaSql(), com.mapd.metadata.MetaConnect.is_geometry(), com.mapd.metadata.MetaConnect.isView(), com.mapd.metadata.MetaConnect.KARRAY, and com.mapd.metadata.MetaConnect.typeToThrift().

Referenced by com.mapd.metadata.MetaConnect.get_table_details().

                                                                {
     TTableDetails td = new TTableDetails();
     td.getRow_descIterator();
     int id = getTableId(tableName);
     if (id == -1) {
       try {
         // need to mark it as temporary table
         TTableDetails tempTableTd = get_table_detail_JSON(tableName);
         tempTableTd.is_temporary = true;
         return tempTableTd;
       } catch (Exception e) {
         String err =
                 "Table '" + tableName + "' does not exist for DB '" + default_db + "'";
         HEAVYDBLOGGER.error(err);
         throw new RuntimeException(err);
       }
     }
 
     // read data from table
     Statement stmt = null;
     ResultSet rs = null;
     try {
       stmt = catConn.createStatement();
       HEAVYDBLOGGER.debug("table id is " + id);
       HEAVYDBLOGGER.debug("table name is " + tableName);
       String query = String.format(
               "SELECT * FROM mapd_columns where tableid = %d and not is_deletedcol order by columnid;",
               id);
       HEAVYDBLOGGER.debug(query);
       rs = stmt.executeQuery(query);
       int skip_physical_cols = 0;
       while (rs.next()) {
         String colName = rs.getString("name");
         HEAVYDBLOGGER.debug("name = " + colName);
         int colType = rs.getInt("coltype");
         HEAVYDBLOGGER.debug("coltype = " + colType);
         int colSubType = rs.getInt("colsubtype");
         HEAVYDBLOGGER.debug("colsubtype = " + colSubType);
         int compression = rs.getInt("compression");
         HEAVYDBLOGGER.debug("compression = " + compression);
         int compression_param = rs.getInt("comp_param");
         HEAVYDBLOGGER.debug("comp_param = " + compression_param);
         int size = rs.getInt("size");
         HEAVYDBLOGGER.debug("size = " + size);
         int colDim = rs.getInt("coldim");
         HEAVYDBLOGGER.debug("coldim = " + colDim);
         int colScale = rs.getInt("colscale");
         HEAVYDBLOGGER.debug("colscale = " + colScale);
         boolean isNotNull = rs.getBoolean("is_notnull");
         HEAVYDBLOGGER.debug("is_notnull = " + isNotNull);
         boolean isSystemCol = rs.getBoolean("is_systemcol");
         HEAVYDBLOGGER.debug("is_systemcol = " + isSystemCol);
         boolean isVirtualCol = rs.getBoolean("is_virtualcol");
         HEAVYDBLOGGER.debug("is_vitrualcol = " + isVirtualCol);
         HEAVYDBLOGGER.debug("");
         TColumnType tct = new TColumnType();
         TTypeInfo tti = new TTypeInfo();
         TDatumType tdt;
 
         if (colType == KARRAY) {
           tti.is_array = true;
           tdt = typeToThrift(colSubType);
         } else {
           tti.is_array = false;
           tdt = typeToThrift(colType);
         }
 
         tti.nullable = !isNotNull;
         tti.encoding = encodingToThrift(compression);
         tti.comp_param = compression_param;
         tti.size = size;
         tti.type = tdt;
         tti.scale = colScale;
         tti.precision = colDim;
 
         tct.col_name = colName;
         tct.col_type = tti;
         tct.is_system = isSystemCol;
 
         if (skip_physical_cols <= 0) skip_physical_cols = get_physical_cols(colType);
         if (is_geometry(colType) || skip_physical_cols-- <= 0) td.addToRow_desc(tct);
       }
     } catch (Exception e) {
       String err = "error trying to read from mapd_columns, error was " + e.getMessage();
       HEAVYDBLOGGER.error(err);
       throw new RuntimeException(err);
     } finally {
       if (rs != null) {
         try {
           rs.close();
         } catch (SQLException ex) {
           String err = "Could not close resultset, error was " + ex.getMessage();
           HEAVYDBLOGGER.error(err);
           throw new RuntimeException(err);
         }
       }
       if (stmt != null) {
         try {
           stmt.close();
         } catch (SQLException ex) {
           String err = "Could not close stmt, error was " + ex.getMessage();
           HEAVYDBLOGGER.error(err);
           throw new RuntimeException(err);
         }
       }
     }
     if (isView(tableName)) {
       td.setView_sqlIsSet(true);
       td.setView_sql(getViewSqlViaSql(id));
     }
     return td;
   }

Here is the call graph for this function:

Here is the caller graph for this function:

TTableDetails com.mapd.metadata.MetaConnect.get_table_details ( String tableName )

inline

Definition at line 350 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.connectToDBCatalog(), com.mapd.metadata.MetaConnect.dbPort, com.mapd.metadata.MetaConnect.default_db, com.mapd.metadata.MetaConnect.disconnectFromCatalog(), and com.mapd.metadata.MetaConnect.get_table_detail_SQL().

Referenced by com.mapd.metadata.MetaConnect.getTable().

                                                            {
     if (dbPort == -1) {
       // use sql
       connectToDBCatalog();
       TTableDetails td = get_table_detail_SQL(tableName);
       disconnectFromCatalog();
       return td;
     }
     try {
       // use thrift direct to local server
       TProtocol protocol = null;
 
       TTransport transport =
               sock_transport_properties.openClientTransport("localhost", dbPort);
       if (!transport.isOpen()) transport.open();
       protocol = new TBinaryProtocol(transport);
 
       Heavy.Client client = new Heavy.Client(protocol);
       TTableDetails td = client.get_internal_table_details_for_database(
               currentUser.getSession(), tableName, default_db);
       transport.close();
 
       return td;
     } catch (TTransportException ex) {
       HEAVYDBLOGGER.error(ex.toString());
       throw new RuntimeException(ex.toString());
     } catch (TDBException ex) {
       HEAVYDBLOGGER.error(ex.getError_msg());
       throw new RuntimeException(ex.getError_msg());
     } catch (TException ex) {
       HEAVYDBLOGGER.error(ex.toString());
       throw new RuntimeException(ex.toString());
     }
   }

Here is the call graph for this function:

Here is the caller graph for this function:

String com.mapd.metadata.MetaConnect.getCatalogFileName ( String catalog )

inlinepackage

Definition at line 177 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.CATALOG_DIR_NAME, and com.mapd.metadata.MetaConnect.dataDir.

Referenced by com.mapd.metadata.MetaConnect.connectToCatalog().

                                             {
     String path = dataDir + "/" + CATALOG_DIR_NAME;
     File directory = new File(path);
     if (!directory.isDirectory()) {
       throw new RuntimeException("Catalog directory not found at: " + path);
     }
     for (File file : directory.listFiles()) {
       if (file.getName().equalsIgnoreCase(catalog)) {
         return file.getName();
       }
     }
     throw new RuntimeException("Database file not found for: " + catalog);
   }

Here is the caller graph for this function:

List<String> com.mapd.metadata.MetaConnect.getDatabases ( )

inline

Definition at line 146 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.DATABASE_TO_TABLES.

Referenced by com.mapd.calcite.parser.HeavyDBParser.getPlanner().

                                      {
     List<String> dbList = new ArrayList<String>(DATABASE_TO_TABLES.size());
     for (String db : DATABASE_TO_TABLES.keySet()) {
       dbList.add(db);
     }
     return dbList;
   }

Here is the caller graph for this function:

Set<String> com.mapd.metadata.MetaConnect.getDatabases_SQL ( )

inlineprivate

Definition at line 899 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.populateDatabases().

                                          {
     Set<String> dbSet = new HashSet<String>();
     Statement stmt = null;
     ResultSet rs = null;
     String sqlText = "";
     try {
       stmt = catConn.createStatement();
 
       // get the tables
       rs = stmt.executeQuery("SELECT name FROM mapd_databases ");
       while (rs.next()) {
         dbSet.add(rs.getString("name"));
         /*--*/
         HEAVYDBLOGGER.debug("Object name = " + rs.getString("name"));
       }
       rs.close();
       stmt.close();
 
     } catch (Exception e) {
       String err = "error trying to get all the databases, error was " + e.getMessage();
       HEAVYDBLOGGER.error(err);
       throw new RuntimeException(err);
     }
     return dbSet;
   }

Here is the caller graph for this function:

Table com.mapd.metadata.MetaConnect.getTable ( String tableName )

inline

Definition at line 206 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.default_db, com.mapd.metadata.MetaConnect.get_table_details(), com.mapd.metadata.MetaConnect.getViewSql(), and com.mapd.metadata.MetaConnect.parser.

                                           {
     List<String> dbTable =
             ImmutableList.of(default_db.toUpperCase(), tableName.toUpperCase());
     Table cTable = DB_TABLE_DETAILS.get(dbTable);
     if (cTable != null) {
       HEAVYDBLOGGER.debug("Metaconnect DB " + default_db + " get table " + tableName
               + " details " + cTable);
       return cTable;
     }
 
     TTableDetails td = get_table_details(tableName);
 
     if (td.getView_sql() == null || td.getView_sql().isEmpty()) {
       HEAVYDBLOGGER.debug("Processing a table");
       Table rTable = new HeavyDBTable(td);
       DB_TABLE_DETAILS.putIfAbsent(dbTable, rTable);
       HEAVYDBLOGGER.debug("Metaconnect DB " + default_db + " get table " + tableName
               + " details " + rTable + " Not in buffer");
       return rTable;
     } else {
       HEAVYDBLOGGER.debug("Processing a view");
       Table rTable = new HeavyDBView(getViewSql(tableName), td, parser);
       DB_TABLE_DETAILS.putIfAbsent(dbTable, rTable);
       HEAVYDBLOGGER.debug("Metaconnect DB " + default_db + " get view " + tableName
               + " details " + rTable + " Not in buffer");
       return rTable;
     }
   }

Here is the call graph for this function:

int com.mapd.metadata.MetaConnect.getTableId ( String tableName )

inlineprivate

Definition at line 632 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.dataDir, and com.mapd.metadata.MetaConnect.default_db.

Referenced by com.mapd.metadata.MetaConnect.get_table_detail_SQL(), and com.mapd.metadata.MetaConnect.getViewSql().

                                            {
     Statement stmt = null;
     ResultSet rs = null;
     int tableId = -1;
     try {
       stmt = catConn.createStatement();
       rs = stmt.executeQuery(String.format(
               "SELECT tableid FROM mapd_tables where name = '%s' COLLATE NOCASE;",
               tableName));
       while (rs.next()) {
         tableId = rs.getInt("tableid");
         HEAVYDBLOGGER.debug("tableId = " + tableId);
         HEAVYDBLOGGER.debug("");
       }
       rs.close();
       stmt.close();
     } catch (Exception e) {
       String err = "Error trying to read from metadata table mapd_tables;DB: "
               + default_db + " data dir " + dataDir + ", error was " + e.getMessage();
       HEAVYDBLOGGER.error(err);
       throw new RuntimeException(err);
     } finally {
       if (rs != null) {
         try {
           rs.close();
         } catch (SQLException ex) {
           String err = "Could not close resultset, error was " + ex.getMessage();
           HEAVYDBLOGGER.error(err);
           throw new RuntimeException(err);
         }
       }
       if (stmt != null) {
         try {
           stmt.close();
         } catch (SQLException ex) {
           String err = "Could not close stmt, error was " + ex.getMessage();
           HEAVYDBLOGGER.error(err);
           throw new RuntimeException(err);
         }
       }
     }
     return (tableId);
   }

Here is the caller graph for this function:

Set<String> com.mapd.metadata.MetaConnect.getTables ( )

inline

Definition at line 235 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.connectToDBCatalog(), com.mapd.metadata.MetaConnect.dbPort, com.mapd.metadata.MetaConnect.default_db, com.mapd.metadata.MetaConnect.disconnectFromCatalog(), and com.mapd.metadata.MetaConnect.getTables_SQL().

                                  {
     Set<String> mSet = DATABASE_TO_TABLES.get(default_db.toUpperCase());
     if (mSet != null && mSet.size() > 0) {
       HEAVYDBLOGGER.debug("Metaconnect DB getTables " + default_db + " tables " + mSet);
       return mSet;
     }
 
     if (dbPort == -1) {
       // use sql
       connectToDBCatalog();
       Set<String> ts = getTables_SQL();
       disconnectFromCatalog();
       DATABASE_TO_TABLES.put(default_db.toUpperCase(), ts);
       HEAVYDBLOGGER.debug(
               "Metaconnect DB getTables " + default_db + " tables " + ts + " from catDB");
       return ts;
     }
     // use thrift direct to local server
     try {
       TProtocol protocol = null;
       TTransport transport =
               sock_transport_properties.openClientTransport("localhost", dbPort);
       if (!transport.isOpen()) transport.open();
       protocol = new TBinaryProtocol(transport);
 
       Heavy.Client client = new Heavy.Client(protocol);
       List<String> tablesList =
               client.get_tables_for_database(currentUser.getSession(), default_db);
       Set<String> ts = new HashSet<String>(tablesList.size());
       for (String tableName : tablesList) {
         ts.add(tableName);
       }
 
       transport.close();
       DATABASE_TO_TABLES.put(default_db.toUpperCase(), ts);
       HEAVYDBLOGGER.debug("Metaconnect DB getTables " + default_db + " tables " + ts
               + " from server");
       return ts;
 
     } catch (TTransportException ex) {
       HEAVYDBLOGGER.error("TTransportException on port [" + dbPort + "]");
       HEAVYDBLOGGER.error(ex.toString());
       throw new RuntimeException(ex.toString());
     } catch (TDBException ex) {
       HEAVYDBLOGGER.error(ex.getError_msg());
       throw new RuntimeException(ex.getError_msg());
     } catch (TException ex) {
       HEAVYDBLOGGER.error(ex.toString());
       throw new RuntimeException(ex.toString());
     }
   }

Here is the call graph for this function:

Set<String> com.mapd.metadata.MetaConnect.getTables_SQL ( )

inlineprivate

Definition at line 287 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.CATALOG_DIR_NAME, com.mapd.metadata.MetaConnect.connectToDBCatalog(), com.mapd.metadata.MetaConnect.dataDir, com.mapd.metadata.MetaConnect.default_db, and com.mapd.metadata.MetaConnect.disconnectFromCatalog().

Referenced by com.mapd.metadata.MetaConnect.getTables().

                                       {
     connectToDBCatalog();
     Set<String> tableSet = new HashSet<String>();
     Statement stmt = null;
     ResultSet rs = null;
     String sqlText = "";
     try {
       stmt = catConn.createStatement();
 
       // get the tables
       rs = stmt.executeQuery("SELECT name FROM mapd_tables ");
       while (rs.next()) {
         tableSet.add(rs.getString("name"));
         /*--*/
         HEAVYDBLOGGER.debug("Object name = " + rs.getString("name"));
       }
       rs.close();
       stmt.close();
 
     } catch (Exception e) {
       String err = "error trying to get all the tables, error was " + e.getMessage();
       HEAVYDBLOGGER.error(err);
       throw new RuntimeException(err);
     }
     disconnectFromCatalog();
 
     try {
       // open temp table json file
       final String filePath =
               dataDir + "/" + CATALOG_DIR_NAME + "/" + default_db + "_temp_tables.json";
       HEAVYDBLOGGER.debug("Opening temp table file at " + filePath);
       String tempTablesJsonStr;
       try {
         File tempTablesFile = new File(filePath);
         FileInputStream tempTablesStream = new FileInputStream(tempTablesFile);
         byte[] data = new byte[(int) tempTablesFile.length()];
         tempTablesStream.read(data);
         tempTablesStream.close();
 
         tempTablesJsonStr = new String(data, "UTF-8");
       } catch (java.io.FileNotFoundException e) {
         return tableSet;
       }
 
       Gson gson = new Gson();
       JsonObject fileParentObject = gson.fromJson(tempTablesJsonStr, JsonObject.class);
       for (Entry<String, JsonElement> member : fileParentObject.entrySet()) {
         String tableName = member.getKey();
         tableSet.add(tableName);
         /*--*/
         HEAVYDBLOGGER.debug("Temp table object name = " + tableName);
       }
 
     } catch (Exception e) {
       String err = "error trying to load temporary tables from json file, error was "
               + e.getMessage();
       HEAVYDBLOGGER.error(err);
       throw new RuntimeException(err);
     }
 
     return tableSet;
   }

Here is the call graph for this function:

Here is the caller graph for this function:

String com.mapd.metadata.MetaConnect.getViewSql ( String tableName )

inlineprivate

Definition at line 700 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.connectToDBCatalog(), com.mapd.metadata.MetaConnect.dbPort, com.mapd.metadata.MetaConnect.default_db, com.mapd.metadata.MetaConnect.disconnectFromCatalog(), com.mapd.metadata.MetaConnect.getTableId(), and com.mapd.metadata.MetaConnect.getViewSqlViaSql().

Referenced by com.mapd.metadata.MetaConnect.getTable().

                                               {
     String sqlText;
     if (dbPort == -1) {
       // use sql
       connectToDBCatalog();
       sqlText = getViewSqlViaSql(getTableId(tableName));
       disconnectFromCatalog();
     } else {
       // use thrift direct to local server
       try {
         TProtocol protocol = null;
 
         TTransport transport =
                 sock_transport_properties.openClientTransport("localhost", dbPort);
         if (!transport.isOpen()) transport.open();
         protocol = new TBinaryProtocol(transport);
 
         Heavy.Client client = new Heavy.Client(protocol);
         TTableDetails td = client.get_table_details_for_database(
                 currentUser.getSession(), tableName, default_db);
         transport.close();
 
         sqlText = td.getView_sql();
 
       } catch (TTransportException ex) {
         HEAVYDBLOGGER.error(ex.toString());
         throw new RuntimeException(ex.toString());
       } catch (TDBException ex) {
         HEAVYDBLOGGER.error(ex.getError_msg());
         throw new RuntimeException(ex.getError_msg());
       } catch (TException ex) {
         HEAVYDBLOGGER.error(ex.toString());
         throw new RuntimeException(ex.toString());
       }
     }
     /* return string without the sqlite's trailing semicolon */
     if (sqlText.charAt(sqlText.length() - 1) == ';') {
       return (sqlText.substring(0, sqlText.length() - 1));
     } else {
       return (sqlText);
     }
   }

Here is the call graph for this function:

Here is the caller graph for this function:

String com.mapd.metadata.MetaConnect.getViewSqlViaSql ( int tableId )

inlineprivate

Definition at line 744 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_table_detail_SQL(), and com.mapd.metadata.MetaConnect.getViewSql().

                                                {
     Statement stmt;
     ResultSet rs;
     String sqlText = "";
     try {
       stmt = catConn.createStatement();
       rs = stmt.executeQuery(String.format(
               "SELECT sql FROM mapd_views where tableid = '%s' COLLATE NOCASE;",
               tableId));
       while (rs.next()) {
         sqlText = rs.getString("sql");
         HEAVYDBLOGGER.debug("View definition = " + sqlText);
         HEAVYDBLOGGER.debug("");
       }
       rs.close();
       stmt.close();
     } catch (Exception e) {
       String err = "error trying to read from mapd_views, error was " + e.getMessage();
       HEAVYDBLOGGER.error(err);
       throw new RuntimeException(err);
     }
     if (sqlText == null || sqlText.length() == 0) {
       String err = "No view text found";
       HEAVYDBLOGGER.error(err);
       throw new RuntimeException(err);
     }
     return sqlText;
   }

Here is the caller graph for this function:

static final boolean com.mapd.metadata.MetaConnect.is_geometry ( int type )

inlinestatic

Definition at line 404 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.KLINESTRING, com.mapd.metadata.MetaConnect.KMULTILINESTRING, com.mapd.metadata.MetaConnect.KMULTIPOINT, com.mapd.metadata.MetaConnect.KMULTIPOLYGON, com.mapd.metadata.MetaConnect.KPOINT, and com.mapd.metadata.MetaConnect.KPOLYGON.

Referenced by com.mapd.metadata.MetaConnect.get_table_detail_JSON(), and com.mapd.metadata.MetaConnect.get_table_detail_SQL().

                                                     {
     return type == KPOINT || type == KLINESTRING || type == KMULTILINESTRING
             || type == KPOLYGON || type == KMULTIPOLYGON || type == KMULTIPOINT;
   }

Here is the caller graph for this function:

boolean com.mapd.metadata.MetaConnect.isView ( String tableName )

inlineprivate

Definition at line 676 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_table_detail_SQL().

                                            {
     Statement stmt;
     ResultSet rs;
     int viewFlag = 0;
     try {
       stmt = catConn.createStatement();
       rs = stmt.executeQuery(String.format(
               "SELECT isview FROM mapd_tables where name = '%s' COLLATE NOCASE;",
               tableName));
       while (rs.next()) {
         viewFlag = rs.getInt("isview");
         HEAVYDBLOGGER.debug("viewFlag = " + viewFlag);
         HEAVYDBLOGGER.debug("");
       }
       rs.close();
       stmt.close();
     } catch (Exception e) {
       String err = "error trying to read from mapd_views, error was " + e.getMessage();
       HEAVYDBLOGGER.error(err);
       throw new RuntimeException(err);
     }
     return (viewFlag == 1);
   }

Here is the caller graph for this function:

void com.mapd.metadata.MetaConnect.populateDatabases ( )

inlineprivate

Definition at line 846 of file MetaConnect.java.

References com.mapd.metadata.MetaConnect.connectToCatalog(), com.mapd.metadata.MetaConnect.dbPort, com.mapd.metadata.MetaConnect.disconnectFromCatalog(), and com.mapd.metadata.MetaConnect.getDatabases_SQL().

Referenced by com.mapd.metadata.MetaConnect.MetaConnect().

                                    {
     // TODO 13 Mar 2021 MAT
     // this probably has to come across from the server on first start up rather
     // than lazy instantiation here
     // as a user may not be able to see all schemas and this sets it for the life
     // of the server.
     // Proceeding this way as a WIP
     if (dbPort == 0) {
       // seems to be a condition that is expected
       // for FSI testing
       return;
     }
     if (dbPort == -1) {
       // use sql
       connectToCatalog("system_catalog"); // hardcoded sys catalog
       Set<String> dbNames = getDatabases_SQL();
       disconnectFromCatalog();
       for (String dbName : dbNames) {
         Set<String> ts = new HashSet<String>();
         DATABASE_TO_TABLES.putIfAbsent(dbName.toUpperCase(), ts);
       }
       return;
     }
     // use thrift direct to local server
     try {
       TProtocol protocol = null;
       TTransport transport =
               sock_transport_properties.openClientTransport("localhost", dbPort);
       if (!transport.isOpen()) transport.open();
       protocol = new TBinaryProtocol(transport);
 
       Heavy.Client client = new Heavy.Client(protocol);
 
       List<TDBInfo> dbList = client.get_databases(currentUser.getSession());
       for (TDBInfo dbInfo : dbList) {
         Set<String> ts = new HashSet<String>();
         DATABASE_TO_TABLES.putIfAbsent(dbInfo.db_name.toUpperCase(), ts);
       }
       transport.close();
 
     } catch (TTransportException ex) {
       HEAVYDBLOGGER.error("TTransportException on port [" + dbPort + "]");
       HEAVYDBLOGGER.error(ex.toString());
       throw new RuntimeException(ex.toString());
     } catch (TDBException ex) {
       HEAVYDBLOGGER.error(ex.getError_msg());
       throw new RuntimeException(ex.getError_msg());
     } catch (TException ex) {
       HEAVYDBLOGGER.error(ex.toString());
       throw new RuntimeException(ex.toString());
     }
   }

Here is the call graph for this function:

Here is the caller graph for this function:

TDatumType com.mapd.metadata.MetaConnect.typeToThrift ( int type )

inlineprivate

Definition at line 773 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_table_detail_JSON(), and com.mapd.metadata.MetaConnect.get_table_detail_SQL().

                                             {
     switch (type) {
       case KBOOLEAN:
         return TDatumType.BOOL;
       case KTINYINT:
         return TDatumType.TINYINT;
       case KSMALLINT:
         return TDatumType.SMALLINT;
       case KINT:
         return TDatumType.INT;
       case KBIGINT:
         return TDatumType.BIGINT;
       case KFLOAT:
         return TDatumType.FLOAT;
       case KNUMERIC:
       case KDECIMAL:
         return TDatumType.DECIMAL;
       case KDOUBLE:
         return TDatumType.DOUBLE;
       case KTEXT:
       case KVARCHAR:
       case KCHAR:
         return TDatumType.STR;
       case KTIME:
         return TDatumType.TIME;
       case KTIMESTAMP:
         return TDatumType.TIMESTAMP;
       case KDATE:
         return TDatumType.DATE;
       case KINTERVAL_DAY_TIME:
         return TDatumType.INTERVAL_DAY_TIME;
       case KINTERVAL_YEAR_MONTH:
         return TDatumType.INTERVAL_YEAR_MONTH;
       case KPOINT:
         return TDatumType.POINT;
       case KMULTIPOINT:
         return TDatumType.MULTIPOINT;
       case KLINESTRING:
         return TDatumType.LINESTRING;
       case KMULTILINESTRING:
         return TDatumType.MULTILINESTRING;
       case KPOLYGON:
         return TDatumType.POLYGON;
       case KMULTIPOLYGON:
         return TDatumType.MULTIPOLYGON;
       default:
         return null;
     }
   }

Here is the caller graph for this function:

void com.mapd.metadata.MetaConnect.updateMetaData	(	String	schema,
		String	table
	)

inline

Definition at line 925 of file MetaConnect.java.

                                                           {
     // Check if table is specified, if not we are dropping an entire DB so need to
     // remove all tables for that DB
     if (table.equals("")) {
       // Drop db and all tables
       // iterate through all and remove matching schema
       Set<List<String>> all = new HashSet<>(DB_TABLE_DETAILS.keySet());
       for (List<String> keys : all) {
         if (keys.get(0).equals(schema.toUpperCase())) {
           HEAVYDBLOGGER.debug(
                   "removing all for schema " + keys.get(0) + " table " + keys.get(1));
           DB_TABLE_DETAILS.remove(keys);
         }
       }
     } else {
       HEAVYDBLOGGER.debug("removing schema " + schema.toUpperCase() + " table "
               + table.toUpperCase());
       DB_TABLE_DETAILS.remove(
               ImmutableList.of(schema.toUpperCase(), table.toUpperCase()));
     }
     // Invalidate views
     Set<List<String>> all = new HashSet<>(DB_TABLE_DETAILS.keySet());
     for (List<String> keys : all) {
       if (keys.get(0).equals(schema.toUpperCase())) {
         Table ttable = DB_TABLE_DETAILS.get(keys);
         if (ttable instanceof HeavyDBView) {
           HEAVYDBLOGGER.debug(
                   "removing view in schema " + keys.get(0) + " view " + keys.get(1));
           DB_TABLE_DETAILS.remove(keys);
         }
       }
     }
     // Could be a removal or an add request for a DB
     Set<String> mSet = DATABASE_TO_TABLES.get(schema.toUpperCase());
     if (mSet != null) {
       if (table.isEmpty()) {
         // If table is not specified, then we are dropping an entire DB.
         HEAVYDBLOGGER.debug("removing schema " + schema.toUpperCase());
         DATABASE_TO_TABLES.remove(schema.toUpperCase());
       } else {
         mSet.clear();
       }
     } else {
       // add a empty database descriptor for new DB, it will be lazily populated when
       // required
       Set<String> ts = new HashSet<String>();
       DATABASE_TO_TABLES.putIfAbsent(schema.toUpperCase(), ts);
     }
   }

Member Data Documentation

final String com.mapd.metadata.MetaConnect.CATALOG_DIR_NAME = "catalogs"

staticprivate

Definition at line 100 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.connectToCatalog(), com.mapd.metadata.MetaConnect.get_table_detail_JSON(), com.mapd.metadata.MetaConnect.getCatalogFileName(), and com.mapd.metadata.MetaConnect.getTables_SQL().

Connection com.mapd.metadata.MetaConnect.catConn

private

Definition at line 72 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.connectToCatalog().

final HeavyDBUser com.mapd.metadata.MetaConnect.currentUser

private

Definition at line 70 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.MetaConnect().

volatile Map<String, Set<String> > com.mapd.metadata.MetaConnect.DATABASE_TO_TABLES

staticprivate

Initial value:

=

new ConcurrentHashMap<>()

Definition at line 101 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.getDatabases(), and com.mapd.metadata.MetaConnect.MetaConnect().

final String com.mapd.metadata.MetaConnect.dataDir

private

Definition at line 68 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.connectToCatalog(), com.mapd.metadata.MetaConnect.disconnectFromCatalog(), com.mapd.metadata.MetaConnect.get_table_detail_JSON(), com.mapd.metadata.MetaConnect.getCatalogFileName(), com.mapd.metadata.MetaConnect.getTableId(), com.mapd.metadata.MetaConnect.getTables_SQL(), and com.mapd.metadata.MetaConnect.MetaConnect().

volatile Map<List<String>, Table> com.mapd.metadata.MetaConnect.DB_TABLE_DETAILS

staticprivate

Initial value:

=

new ConcurrentHashMap<>()

Definition at line 103 of file MetaConnect.java.

final int com.mapd.metadata.MetaConnect.dbPort

private

Definition at line 71 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_table_details(), com.mapd.metadata.MetaConnect.getTables(), com.mapd.metadata.MetaConnect.getViewSql(), com.mapd.metadata.MetaConnect.MetaConnect(), and com.mapd.metadata.MetaConnect.populateDatabases().

final String com.mapd.metadata.MetaConnect.default_db

private

Definition at line 69 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.connectToDBCatalog(), com.mapd.metadata.MetaConnect.get_table_detail_JSON(), com.mapd.metadata.MetaConnect.get_table_detail_SQL(), com.mapd.metadata.MetaConnect.get_table_details(), com.mapd.metadata.MetaConnect.getTable(), com.mapd.metadata.MetaConnect.getTableId(), com.mapd.metadata.MetaConnect.getTables(), com.mapd.metadata.MetaConnect.getTables_SQL(), and com.mapd.metadata.MetaConnect.getViewSql().

final Logger com.mapd.metadata.MetaConnect.HEAVYDBLOGGER = LoggerFactory.getLogger(MetaConnect.class)

staticpackage

Definition at line 67 of file MetaConnect.java.

final int com.mapd.metadata.MetaConnect.KARRAY = 15

staticprivate

Definition at line 89 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_table_detail_JSON(), and com.mapd.metadata.MetaConnect.get_table_detail_SQL().

final int com.mapd.metadata.MetaConnect.KBIGINT = 12

staticprivate

Definition at line 86 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KBOOLEAN = 1

staticprivate

Definition at line 75 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KCHAR = 2

staticprivate

Definition at line 76 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KDATE = 14

staticprivate

Definition at line 88 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KDECIMAL = 5

staticprivate

Definition at line 79 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KDOUBLE = 9

staticprivate

Definition at line 83 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KFLOAT = 8

staticprivate

Definition at line 82 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KINT = 6

staticprivate

Definition at line 80 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KINTERVAL_DAY_TIME = 16

staticprivate

Definition at line 90 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KINTERVAL_YEAR_MONTH = 17

staticprivate

Definition at line 91 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KLINESTRING = 19

staticprivate

Definition at line 93 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_physical_cols(), com.mapd.metadata.MetaConnect.is_geometry(), and com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KMULTILINESTRING = 30

staticprivate

Definition at line 97 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_physical_cols(), com.mapd.metadata.MetaConnect.is_geometry(), and com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KMULTIPOINT = 31

staticprivate

Definition at line 98 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_physical_cols(), com.mapd.metadata.MetaConnect.is_geometry(), and com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KMULTIPOLYGON = 21

staticprivate

Definition at line 95 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_physical_cols(), com.mapd.metadata.MetaConnect.is_geometry(), and com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KNUMERIC = 4

staticprivate

Definition at line 78 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KPOINT = 18

staticprivate

Definition at line 92 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_physical_cols(), com.mapd.metadata.MetaConnect.is_geometry(), and com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KPOLYGON = 20

staticprivate

Definition at line 94 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.get_physical_cols(), com.mapd.metadata.MetaConnect.is_geometry(), and com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KSMALLINT = 7

staticprivate

Definition at line 81 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KTEXT = 13

staticprivate

Definition at line 87 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KTIME = 10

staticprivate

Definition at line 84 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KTIMESTAMP = 11

staticprivate

Definition at line 85 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KTINYINT = 22

staticprivate

Definition at line 96 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final int com.mapd.metadata.MetaConnect.KVARCHAR = 3

staticprivate

Definition at line 77 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.typeToThrift().

final HeavyDBParser com.mapd.metadata.MetaConnect.parser

private

Definition at line 73 of file MetaConnect.java.

Referenced by com.mapd.metadata.MetaConnect.getTable(), and com.mapd.metadata.MetaConnect.MetaConnect().

final SockTransportProperties com.mapd.metadata.MetaConnect.sock_transport_properties

private

Definition at line 105 of file MetaConnect.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/metadata/MetaConnect.java

Public Member Functions

Static Public Member Functions

Package Functions

Static Package Attributes

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation