com.mapd.tests.HeavyDBTestClient Class Reference

Collaboration diagram for com.mapd.tests.HeavyDBTestClient:

Public Member Functions
TServerStatus	get_server_status () throws TDBException, TException
List< TServerStatus >	get_status () throws TDBException, TException
TClusterHardwareInfo	get_hardware_info () throws TDBException, TException
List< TNodeMemoryInfo >	get_memory (String memory_level) throws TDBException, TException
TTableDetails	get_table_details (String table_name) throws Exception
TTableDetails	get_table_details_for_database (String tableName, String databaseName) throws Exception
List< TTableMeta >	get_tables_meta () throws TDBException, Exception
TQueryResult	runSql (String sql) throws Exception
List< TColumnType >	sqlValidate (String sql) throws Exception
int	create_dashboard (String name) throws Exception
void	replace_dashboard (int dashboard_id, java.lang.String name, java.lang.String new_owner) throws Exception
TDashboard	get_dashboard (int id) throws Exception
void	delete_dashboard (int id) throws Exception
List< TDashboard >	get_dashboards () throws Exception
void	import_table (String table_name, String file_name, TCopyParams copy_params) throws Exception
void	import_geo_table (String table_name, String file_name, TCopyParams copy_params, java.util.List< TColumnType > row_desc, TCreateParams create_params) throws Exception
List< String >	get_users () throws Exception
List< String >	get_roles () throws Exception
List< TDBObject >	get_db_object_privs (String objectName, TDBObjectType type) throws Exception
void	disconnect () throws Exception
Collection< String >	get_all_roles_for_user (String username) throws Exception
List< TQueryInfo >	get_queries_info () throws Exception
void	load_table (String tableName, List< List< String >> rows, List< String > columnNames) throws Exception
void	load_table_binary (String tableName, List< List< Object >> rows, List< String > columnNames) throws Exception
void	load_table_binary_columnar (String tableName, List< List< Object >> columns, List< String > columnNames) throws Exception

Static Public Member Functions
static HeavyDBTestClient	getClient (String host, int port, String db, String user, String password) throws Exception

Package Attributes
Heavy.Client	client
String	sessionId

Private Member Functions
TDatum	convertToTDatum (Object value)
List< TColumn >	convertToTColumns (List< List< Object >> columns)
TColumn	convertToTColumn (List< Object > column)

Detailed Description

Definition at line 31 of file HeavyDBTestClient.java.

Member Function Documentation

TColumn com.mapd.tests.HeavyDBTestClient.convertToTColumn ( List< Object >  column )

inlineprivate

Definition at line 205 of file HeavyDBTestClient.java.

References Double.

Referenced by com.mapd.tests.HeavyDBTestClient.convertToTColumns().

                                                        {
    TColumn tColumn = new TColumn();
    tColumn.data = new TColumnData(
            new ArrayList<>(), new ArrayList<>(), new ArrayList<>(), new ArrayList<>());
    tColumn.nulls = new ArrayList<>();
    for (Object value : column) {
      if (value instanceof Long) {
        tColumn.data.int_col.add((Long) value);
      } else if (value instanceof Double) {
        tColumn.data.real_col.add((Double) value);
      } else if (value instanceof String) {
        tColumn.data.str_col.add((String) value);
      } else if (value instanceof List) {
        tColumn.data.arr_col.add(convertToTColumn((List<Object>) value));
      } else {
        throw new RuntimeException("Unexpected value type. Value: " + value);
      }
      tColumn.nulls.add(false);
    }
    return tColumn;
  }

Here is the caller graph for this function:

List<TColumn> com.mapd.tests.HeavyDBTestClient.convertToTColumns ( List< List< Object >>  columns )

inlineprivate

Definition at line 197 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.convertToTColumn().

Referenced by com.mapd.tests.HeavyDBTestClient.load_table_binary_columnar().

                                                                      {
    List<TColumn> load_columns = new ArrayList<>();
    for (List<Object> column : columns) {
      load_columns.add(convertToTColumn(column));
    }
    return load_columns;
  }

Here is the call graph for this function:

Here is the caller graph for this function:

TDatum com.mapd.tests.HeavyDBTestClient.convertToTDatum ( Object  value )

inlineprivate

Definition at line 171 of file HeavyDBTestClient.java.

References Double.

Referenced by com.mapd.tests.HeavyDBTestClient.load_table_binary().

                                               {
    TDatumVal tDatumVal = new TDatumVal();
    if (value instanceof Long) {
      tDatumVal.int_val = ((Long) value);
    } else if (value instanceof Double) {
      tDatumVal.real_val = ((Double) value);
    } else if (value instanceof String) {
      tDatumVal.str_val = ((String) value);
    } else if (value instanceof List) {
      tDatumVal.arr_val = new ArrayList<>();
      for (Object arrayValue : ((List<Object>) value)) {
        tDatumVal.arr_val.add(convertToTDatum(arrayValue));
      }
    } else {
      throw new RuntimeException("Unexpected value type. Value: " + value);
    }
    return new TDatum(tDatumVal, false);
  }

Here is the caller graph for this function:

int com.mapd.tests.HeavyDBTestClient.create_dashboard ( String  name ) throws Exception

inline

Definition at line 73 of file HeavyDBTestClient.java.

References setup.name, and com.mapd.tests.HeavyDBTestClient.sessionId.

                                                            {
    return client.create_dashboard(
            sessionId, name, "STATE", name + "_hash", name + "_meta");
  }

void com.mapd.tests.HeavyDBTestClient.delete_dashboard ( int  id ) throws Exception

inline

Definition at line 95 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                        {
    client.delete_dashboard(sessionId, id);
  }

void com.mapd.tests.HeavyDBTestClient.disconnect ( ) throws Exception

inline

Definition at line 130 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                            {
    client.disconnect(sessionId);
  }

Collection<String> com.mapd.tests.HeavyDBTestClient.get_all_roles_for_user ( String  username ) throws Exception

inline

Definition at line 134 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                                                     {
    List<String> roles = client.get_all_roles_for_user(sessionId, username);
    return new HashSet<String>(roles);
  }

TDashboard com.mapd.tests.HeavyDBTestClient.get_dashboard ( int  id ) throws Exception

inline

Definition at line 90 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                           {
    TDashboard dashboard = client.get_dashboard(sessionId, id);
    return dashboard;
  }

List<TDashboard> com.mapd.tests.HeavyDBTestClient.get_dashboards ( ) throws Exception

inline

Definition at line 99 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                            {
    return client.get_dashboards(sessionId);
  }

List<TDBObject> com.mapd.tests.HeavyDBTestClient.get_db_object_privs ( String  objectName, TDBObjectType  type  ) throws Exception

inline

Definition at line 125 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId, and run_benchmark_import.type.

                           {
    return client.get_db_object_privs(sessionId, objectName, type);
  }

TClusterHardwareInfo com.mapd.tests.HeavyDBTestClient.get_hardware_info ( ) throws TDBException, TException

inline

Definition at line 43 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                                                  {
    return client.get_hardware_info(sessionId);
  }

List<TNodeMemoryInfo> com.mapd.tests.HeavyDBTestClient.get_memory ( String  memory_level ) throws TDBException, TException

inline

Definition at line 47 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                          {
    return client.get_memory(sessionId, memory_level);
  }

List<TQueryInfo> com.mapd.tests.HeavyDBTestClient.get_queries_info ( ) throws Exception

inline

Definition at line 139 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                              {
    return client.get_queries_info(sessionId);
  }

List<String> com.mapd.tests.HeavyDBTestClient.get_roles ( ) throws Exception

inline

Definition at line 121 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                   {
    return client.get_roles(sessionId);
  }

TServerStatus com.mapd.tests.HeavyDBTestClient.get_server_status ( ) throws TDBException, TException

inline

Definition at line 35 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                                           {
    return client.get_server_status(sessionId);
  }

List<TServerStatus> com.mapd.tests.HeavyDBTestClient.get_status ( ) throws TDBException, TException

inline

Definition at line 39 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                                          {
    return client.get_status(sessionId);
  }

TTableDetails com.mapd.tests.HeavyDBTestClient.get_table_details ( String  table_name ) throws Exception

inline

Definition at line 52 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                                             {
    return client.get_table_details(sessionId, table_name);
  }

TTableDetails com.mapd.tests.HeavyDBTestClient.get_table_details_for_database ( String  tableName, String  databaseName  ) throws Exception

inline

Definition at line 56 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                                  {
    return client.get_table_details_for_database(sessionId, tableName, databaseName);
  }

List<TTableMeta> com.mapd.tests.HeavyDBTestClient.get_tables_meta ( ) throws TDBException, Exception

inline

Definition at line 61 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                                           {
    return client.get_tables_meta(sessionId);
  }

List<String> com.mapd.tests.HeavyDBTestClient.get_users ( ) throws Exception

inline

Definition at line 117 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                   {
    return client.get_users(sessionId);
  }

static HeavyDBTestClient com.mapd.tests.HeavyDBTestClient.getClient ( String  host, int  port, String  db, String  user, String  password  ) throws Exception

inlinestatic

Definition at line 227 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.client.

                           {
    TSocket transport = new TSocket(host, port);
    transport.open();
    TProtocol protocol = new TBinaryProtocol(transport);
    Heavy.Client client = new Heavy.Client(protocol);
    HeavyDBTestClient session = new HeavyDBTestClient();
    session.client = client;
    session.sessionId = client.connect(user, password, db);
    return session;
  }

void com.mapd.tests.HeavyDBTestClient.import_geo_table ( String  table_name, String  file_name, TCopyParams  copy_params, java.util.List< TColumnType >  row_desc, TCreateParams  create_params  ) throws Exception

inline

Definition at line 108 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                        {
    client.import_geo_table(
            sessionId, table_name, file_name, copy_params, row_desc, create_params);
  }

void com.mapd.tests.HeavyDBTestClient.import_table ( String  table_name, String  file_name, TCopyParams  copy_params  ) throws Exception

inline

Definition at line 103 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                           {
    client.import_table(sessionId, table_name, file_name, copy_params);
  }

void com.mapd.tests.HeavyDBTestClient.load_table ( String  tableName, List< List< String >>  rows, List< String >  columnNames  ) throws Exception

inline

Definition at line 143 of file HeavyDBTestClient.java.

References report.rows, and com.mapd.tests.HeavyDBTestClient.sessionId.

                           {
    List<TStringRow> load_rows = new ArrayList<>();
    for (List<String> row : rows) {
      TStringRow tStringRow = new TStringRow(new ArrayList<>());
      for (String value : row) {
        tStringRow.cols.add(new TStringValue(value, false));
      }
      load_rows.add(tStringRow);
    }
    client.load_table(sessionId, tableName, load_rows, columnNames);
  }

void com.mapd.tests.HeavyDBTestClient.load_table_binary ( String  tableName, List< List< Object >>  rows, List< String >  columnNames  ) throws Exception

inline

Definition at line 157 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.convertToTDatum(), report.rows, and com.mapd.tests.HeavyDBTestClient.sessionId.

                           {
    List<TRow> load_rows = new ArrayList<>();
    for (List<Object> row : rows) {
      TRow tRow = new TRow(new ArrayList<>());
      for (Object value : row) {
        tRow.cols.add(convertToTDatum(value));
      }
      load_rows.add(tRow);
    }
    client.load_table_binary(sessionId, tableName, load_rows, columnNames);
  }

Here is the call graph for this function:

void com.mapd.tests.HeavyDBTestClient.load_table_binary_columnar ( String  tableName, List< List< Object >>  columns, List< String >  columnNames  ) throws Exception

inline

Definition at line 190 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.convertToTColumns(), and com.mapd.tests.HeavyDBTestClient.sessionId.

                           {
    List<TColumn> load_columns = convertToTColumns(columns);
    client.load_table_binary_columnar(sessionId, tableName, load_columns, columnNames);
  }

Here is the call graph for this function:

void com.mapd.tests.HeavyDBTestClient.replace_dashboard ( int  dashboard_id, java.lang.String  name, java.lang.String  new_owner  ) throws Exception

inline

Definition at line 78 of file HeavyDBTestClient.java.

References setup.name, and com.mapd.tests.HeavyDBTestClient.sessionId.

                           {
    client.replace_dashboard(sessionId,
            dashboard_id,
            name,
            new_owner,
            "STATE",
            name + "_hash",
            name + "_meta");
  }

TQueryResult com.mapd.tests.HeavyDBTestClient.runSql ( String  sql ) throws Exception

inline

Definition at line 65 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                          {
    return client.sql_execute(sessionId, sql, true, null, -1, -1);
  }

List<TColumnType> com.mapd.tests.HeavyDBTestClient.sqlValidate ( String  sql ) throws Exception

inline

Definition at line 69 of file HeavyDBTestClient.java.

References com.mapd.tests.HeavyDBTestClient.sessionId.

                                                                    {
    return client.sql_validate(sessionId, sql);
  }

Member Data Documentation

Heavy.Client com.mapd.tests.HeavyDBTestClient.client

package

Definition at line 32 of file HeavyDBTestClient.java.

Referenced by com.mapd.tests.HeavyDBTestClient.getClient().

String com.mapd.tests.HeavyDBTestClient.sessionId

package

Definition at line 33 of file HeavyDBTestClient.java.

Referenced by com.mapd.tests.HeavyDBTestClient.create_dashboard(), com.mapd.tests.HeavyDBTestClient.delete_dashboard(), com.mapd.tests.HeavyDBTestClient.disconnect(), com.mapd.tests.HeavyDBTestClient.get_all_roles_for_user(), com.mapd.tests.HeavyDBTestClient.get_dashboard(), com.mapd.tests.HeavyDBTestClient.get_dashboards(), com.mapd.tests.HeavyDBTestClient.get_db_object_privs(), com.mapd.tests.HeavyDBTestClient.get_hardware_info(), com.mapd.tests.HeavyDBTestClient.get_memory(), com.mapd.tests.HeavyDBTestClient.get_queries_info(), com.mapd.tests.HeavyDBTestClient.get_roles(), com.mapd.tests.HeavyDBTestClient.get_server_status(), com.mapd.tests.HeavyDBTestClient.get_status(), com.mapd.tests.HeavyDBTestClient.get_table_details(), com.mapd.tests.HeavyDBTestClient.get_table_details_for_database(), com.mapd.tests.HeavyDBTestClient.get_tables_meta(), com.mapd.tests.HeavyDBTestClient.get_users(), com.mapd.tests.HeavyDBTestClient.import_geo_table(), com.mapd.tests.HeavyDBTestClient.import_table(), com.mapd.tests.HeavyDBTestClient.load_table(), com.mapd.tests.HeavyDBTestClient.load_table_binary(), com.mapd.tests.HeavyDBTestClient.load_table_binary_columnar(), heavydb.thrift.ttypes.TKrb5Session.read(), com.mapd.tests.HeavyDBTestClient.replace_dashboard(), com.mapd.tests.HeavyDBTestClient.runSql(), com.mapd.tests.HeavyDBTestClient.sqlValidate(), and heavydb.thrift.ttypes.TKrb5Session.write().

---

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

• /home/jenkins-slave/workspace/core-os-doxygen/java/utility/src/main/java/com/mapd/tests/HeavyDBTestClient.java