test_class.declarator: DB_NAME = "test_hive"
test_class.modifier: private static final
test_class.original_string: private static final String DB_NAME = "test_hive";
test_class.type: String
test_class.var_name: DB_NAME
test_class.declarator: CUSTOMER = "customer"
test_class.modifier: private static final
test_class.original_string: private static final String CUSTOMER = "customer";
test_class.type: String
test_class.var_name: CUSTOMER
test_class.declarator: NATION = "nation"
test_class.modifier: private static final
test_class.original_string: private static final String NATION = "nation";
test_class.type: String
test_class.var_name: NATION
test_class.declarator: REGION = "region"
test_class.modifier: private static final
test_class.original_string: private static final String REGION = "region";
test_class.type: String
test_class.var_name: REGION
test_class.declarator: SUPPLIER = "supplier"
test_class.modifier: private static final
test_class.original_string: private static final String SUPPLIER = "supplier";
test_class.type: String
test_class.var_name: SUPPLIER
test_class.declarator: store
test_class.modifier: private static
test_class.original_string: private static HCatalogStore store;
test_class.type: HCatalogStore
test_class.var_name: store
test_class.declarator: warehousePath
test_class.modifier: private static
test_class.original_string: private static Path warehousePath;
test_class.type: Path
test_class.var_name: warehousePath
test_class.file: tajo-catalog/tajo-catalog-drivers/tajo-hcatalog/src/test/java/org/apache/tajo/catalog/store/TestHCatalogStore.java
test_class.identifier: TestHCatalogStore
test_case.body: @Test
    public void testGetAllTableNames() throws Exception{
      TableMeta meta = new TableMeta(CatalogProtos.StoreType.CSV, new Options());
      org.apache.tajo.catalog.Schema schema = new org.apache.tajo.catalog.Schema();
      schema.addColumn("n_name", TajoDataTypes.Type.TEXT);
      schema.addColumn("n_regionkey", TajoDataTypes.Type.INT4);
      schema.addColumn("n_comment", TajoDataTypes.Type.TEXT);
  
      String[] tableNames = new String[]{"table1", "table2", "table3"};
  
      for(String tableName : tableNames){
        TableDesc table = new TableDesc(CatalogUtil.buildFQName("default", tableName), schema, meta,
            new Path(warehousePath, new Path(DB_NAME, tableName)));
        store.createTable(table.getProto());
      }
  
      List<String> tables = store.getAllTableNames("default");
      assertEquals(tableNames.length, tables.size());
  
      for(String tableName : tableNames){
        assertTrue(tables.contains(tableName));
      }
  
      for(String tableName : tableNames){
        store.dropTable("default", tableName);
      }
    }
test_case.class_method_signature: TestHCatalogStore.testGetAllTableNames()
test_case.full_signature: @Test public void testGetAllTableNames()
test_case.identifier: testGetAllTableNames
test_case.invocations: addColumn addColumn addColumn buildFQName createTable getProto getAllTableNames assertEquals size assertTrue contains dropTable
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testGetAllTableNames()
focal_class.declarator: LOG = LogFactory.getLog(getClass())
focal_class.modifier: protected final
focal_class.original_string: protected final Log LOG = LogFactory.getLog(getClass());
focal_class.type: Log
focal_class.var_name: LOG
focal_class.declarator: HIVE_WAREHOUSE_DIR_CONF_KEY = "hive.metastore.warehouse.dir"
focal_class.modifier: private static
focal_class.original_string: private static String HIVE_WAREHOUSE_DIR_CONF_KEY = "hive.metastore.warehouse.dir";
focal_class.type: String
focal_class.var_name: HIVE_WAREHOUSE_DIR_CONF_KEY
focal_class.declarator: conf
focal_class.modifier: protected
focal_class.original_string: protected Configuration conf;
focal_class.type: Configuration
focal_class.var_name: conf
focal_class.declarator: CLIENT_POOL_SIZE = 2
focal_class.modifier: private static final
focal_class.original_string: private static final int CLIENT_POOL_SIZE = 2;
focal_class.type: int
focal_class.var_name: CLIENT_POOL_SIZE
focal_class.declarator: clientPool
focal_class.modifier: private final
focal_class.original_string: private final HCatalogStoreClientPool clientPool;
focal_class.type: HCatalogStoreClientPool
focal_class.var_name: clientPool
focal_class.declarator: defaultTableSpaceUri
focal_class.modifier: private final
focal_class.original_string: private final String defaultTableSpaceUri;
focal_class.type: String
focal_class.var_name: defaultTableSpaceUri
focal_class.file: tajo-catalog/tajo-catalog-drivers/tajo-hcatalog/src/main/java/org/apache/tajo/catalog/store/HCatalogStore.java
focal_class.identifier: HCatalogStore
focal_class.interfaces: implements CatalogStore
focal_class.class_method_signature: HCatalogStore.HCatalogStore(final Configuration conf)
focal_class.full_signature: public  HCatalogStore(final Configuration conf)
focal_class.identifier: HCatalogStore
focal_class.modifiers: public
focal_class.parameters: (final Configuration conf)
focal_class.signature:  HCatalogStore(final Configuration conf)
focal_class.class_method_signature: HCatalogStore.existTable(final String databaseName, final String tableName)
focal_class.full_signature: @Override public boolean existTable(final String databaseName, final String tableName)
focal_class.identifier: existTable
focal_class.modifiers: @Override public
focal_class.parameters: (final String databaseName, final String tableName)
focal_class.return: boolean
focal_class.signature: boolean existTable(final String databaseName, final String tableName)
focal_class.class_method_signature: HCatalogStore.getTable(String databaseName, final String tableName)
focal_class.full_signature: @Override public final CatalogProtos.TableDescProto getTable(String databaseName, final String tableName)
focal_class.identifier: getTable
focal_class.modifiers: @Override public final
focal_class.parameters: (String databaseName, final String tableName)
focal_class.return: CatalogProtos.TableDescProto
focal_class.signature: CatalogProtos.TableDescProto getTable(String databaseName, final String tableName)
focal_class.class_method_signature: HCatalogStore.getDataType(final String typeStr)
focal_class.full_signature: private TajoDataTypes.Type getDataType(final String typeStr)
focal_class.identifier: getDataType
focal_class.modifiers: private
focal_class.parameters: (final String typeStr)
focal_class.return: TajoDataTypes.Type
focal_class.signature: TajoDataTypes.Type getDataType(final String typeStr)
focal_class.class_method_signature: HCatalogStore.getAllTableNames(String databaseName)
focal_class.full_signature: @Override public final List<String> getAllTableNames(String databaseName)
focal_class.identifier: getAllTableNames
focal_class.modifiers: @Override public final
focal_class.parameters: (String databaseName)
focal_class.return: List<String>
focal_class.signature: List<String> getAllTableNames(String databaseName)
focal_class.class_method_signature: HCatalogStore.createTablespace(String spaceName, String spaceUri)
focal_class.full_signature: @Override public void createTablespace(String spaceName, String spaceUri)
focal_class.identifier: createTablespace
focal_class.modifiers: @Override public
focal_class.parameters: (String spaceName, String spaceUri)
focal_class.return: void
focal_class.signature: void createTablespace(String spaceName, String spaceUri)
focal_class.class_method_signature: HCatalogStore.existTablespace(String spaceName)
focal_class.full_signature: @Override public boolean existTablespace(String spaceName)
focal_class.identifier: existTablespace
focal_class.modifiers: @Override public
focal_class.parameters: (String spaceName)
focal_class.return: boolean
focal_class.signature: boolean existTablespace(String spaceName)
focal_class.class_method_signature: HCatalogStore.dropTablespace(String spaceName)
focal_class.full_signature: @Override public void dropTablespace(String spaceName)
focal_class.identifier: dropTablespace
focal_class.modifiers: @Override public
focal_class.parameters: (String spaceName)
focal_class.return: void
focal_class.signature: void dropTablespace(String spaceName)
focal_class.class_method_signature: HCatalogStore.getAllTablespaceNames()
focal_class.full_signature: @Override public Collection<String> getAllTablespaceNames()
focal_class.identifier: getAllTablespaceNames
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Collection<String>
focal_class.signature: Collection<String> getAllTablespaceNames()
focal_class.class_method_signature: HCatalogStore.getTablespace(String spaceName)
focal_class.full_signature: @Override public TablespaceProto getTablespace(String spaceName)
focal_class.identifier: getTablespace
focal_class.modifiers: @Override public
focal_class.parameters: (String spaceName)
focal_class.return: TablespaceProto
focal_class.signature: TablespaceProto getTablespace(String spaceName)
focal_class.class_method_signature: HCatalogStore.alterTablespace(CatalogProtos.AlterTablespaceProto alterProto)
focal_class.full_signature: @Override public void alterTablespace(CatalogProtos.AlterTablespaceProto alterProto)
focal_class.identifier: alterTablespace
focal_class.modifiers: @Override public
focal_class.parameters: (CatalogProtos.AlterTablespaceProto alterProto)
focal_class.return: void
focal_class.signature: void alterTablespace(CatalogProtos.AlterTablespaceProto alterProto)
focal_class.class_method_signature: HCatalogStore.createDatabase(String databaseName, String tablespaceName)
focal_class.full_signature: @Override public void createDatabase(String databaseName, String tablespaceName)
focal_class.identifier: createDatabase
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName, String tablespaceName)
focal_class.return: void
focal_class.signature: void createDatabase(String databaseName, String tablespaceName)
focal_class.class_method_signature: HCatalogStore.existDatabase(String databaseName)
focal_class.full_signature: @Override public boolean existDatabase(String databaseName)
focal_class.identifier: existDatabase
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName)
focal_class.return: boolean
focal_class.signature: boolean existDatabase(String databaseName)
focal_class.class_method_signature: HCatalogStore.dropDatabase(String databaseName)
focal_class.full_signature: @Override public void dropDatabase(String databaseName)
focal_class.identifier: dropDatabase
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName)
focal_class.return: void
focal_class.signature: void dropDatabase(String databaseName)
focal_class.class_method_signature: HCatalogStore.getAllDatabaseNames()
focal_class.full_signature: @Override public Collection<String> getAllDatabaseNames()
focal_class.identifier: getAllDatabaseNames
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Collection<String>
focal_class.signature: Collection<String> getAllDatabaseNames()
focal_class.class_method_signature: HCatalogStore.createTable(final CatalogProtos.TableDescProto tableDescProto)
focal_class.full_signature: @Override public final void createTable(final CatalogProtos.TableDescProto tableDescProto)
focal_class.identifier: createTable
focal_class.modifiers: @Override public final
focal_class.parameters: (final CatalogProtos.TableDescProto tableDescProto)
focal_class.return: void
focal_class.signature: void createTable(final CatalogProtos.TableDescProto tableDescProto)
focal_class.class_method_signature: HCatalogStore.dropTable(String databaseName, final String tableName)
focal_class.full_signature: @Override public final void dropTable(String databaseName, final String tableName)
focal_class.identifier: dropTable
focal_class.modifiers: @Override public final
focal_class.parameters: (String databaseName, final String tableName)
focal_class.return: void
focal_class.signature: void dropTable(String databaseName, final String tableName)
focal_class.class_method_signature: HCatalogStore.alterTable(final CatalogProtos.AlterTableDescProto alterTableDescProto)
focal_class.full_signature: @Override public void alterTable(final CatalogProtos.AlterTableDescProto alterTableDescProto)
focal_class.identifier: alterTable
focal_class.modifiers: @Override public
focal_class.parameters: (final CatalogProtos.AlterTableDescProto alterTableDescProto)
focal_class.return: void
focal_class.signature: void alterTable(final CatalogProtos.AlterTableDescProto alterTableDescProto)
focal_class.class_method_signature: HCatalogStore.renameTable(String databaseName, String tableName, String newTableName)
focal_class.full_signature: private void renameTable(String databaseName, String tableName, String newTableName)
focal_class.identifier: renameTable
focal_class.modifiers: private
focal_class.parameters: (String databaseName, String tableName, String newTableName)
focal_class.return: void
focal_class.signature: void renameTable(String databaseName, String tableName, String newTableName)
focal_class.class_method_signature: HCatalogStore.renameColumn(String databaseName, String tableName, CatalogProtos.AlterColumnProto alterColumnProto)
focal_class.full_signature: private void renameColumn(String databaseName, String tableName, CatalogProtos.AlterColumnProto alterColumnProto)
focal_class.identifier: renameColumn
focal_class.modifiers: private
focal_class.parameters: (String databaseName, String tableName, CatalogProtos.AlterColumnProto alterColumnProto)
focal_class.return: void
focal_class.signature: void renameColumn(String databaseName, String tableName, CatalogProtos.AlterColumnProto alterColumnProto)
focal_class.class_method_signature: HCatalogStore.addNewColumn(String databaseName, String tableName, CatalogProtos.ColumnProto columnProto)
focal_class.full_signature: private void addNewColumn(String databaseName, String tableName, CatalogProtos.ColumnProto columnProto)
focal_class.identifier: addNewColumn
focal_class.modifiers: private
focal_class.parameters: (String databaseName, String tableName, CatalogProtos.ColumnProto columnProto)
focal_class.return: void
focal_class.signature: void addNewColumn(String databaseName, String tableName, CatalogProtos.ColumnProto columnProto)
focal_class.class_method_signature: HCatalogStore.addPartitionMethod(CatalogProtos.PartitionMethodProto partitionMethodProto)
focal_class.full_signature: @Override public void addPartitionMethod(CatalogProtos.PartitionMethodProto partitionMethodProto)
focal_class.identifier: addPartitionMethod
focal_class.modifiers: @Override public
focal_class.parameters: (CatalogProtos.PartitionMethodProto partitionMethodProto)
focal_class.return: void
focal_class.signature: void addPartitionMethod(CatalogProtos.PartitionMethodProto partitionMethodProto)
focal_class.class_method_signature: HCatalogStore.getPartitionMethod(String databaseName, String tableName)
focal_class.full_signature: @Override public CatalogProtos.PartitionMethodProto getPartitionMethod(String databaseName, String tableName)
focal_class.identifier: getPartitionMethod
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName, String tableName)
focal_class.return: CatalogProtos.PartitionMethodProto
focal_class.signature: CatalogProtos.PartitionMethodProto getPartitionMethod(String databaseName, String tableName)
focal_class.class_method_signature: HCatalogStore.existPartitionMethod(String databaseName, String tableName)
focal_class.full_signature: @Override public boolean existPartitionMethod(String databaseName, String tableName)
focal_class.identifier: existPartitionMethod
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName, String tableName)
focal_class.return: boolean
focal_class.signature: boolean existPartitionMethod(String databaseName, String tableName)
focal_class.class_method_signature: HCatalogStore.dropPartitionMethod(String databaseName, String tableName)
focal_class.full_signature: @Override public void dropPartitionMethod(String databaseName, String tableName)
focal_class.identifier: dropPartitionMethod
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName, String tableName)
focal_class.return: void
focal_class.signature: void dropPartitionMethod(String databaseName, String tableName)
focal_class.class_method_signature: HCatalogStore.addPartitions(CatalogProtos.PartitionsProto partitionsProto)
focal_class.full_signature: @Override public void addPartitions(CatalogProtos.PartitionsProto partitionsProto)
focal_class.identifier: addPartitions
focal_class.modifiers: @Override public
focal_class.parameters: (CatalogProtos.PartitionsProto partitionsProto)
focal_class.return: void
focal_class.signature: void addPartitions(CatalogProtos.PartitionsProto partitionsProto)
focal_class.class_method_signature: HCatalogStore.addPartition(String databaseName, String tableName, CatalogProtos.PartitionDescProto partitionDescProto)
focal_class.full_signature: @Override public void addPartition(String databaseName, String tableName, CatalogProtos.PartitionDescProto partitionDescProto)
focal_class.identifier: addPartition
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName, String tableName, CatalogProtos.PartitionDescProto partitionDescProto)
focal_class.return: void
focal_class.signature: void addPartition(String databaseName, String tableName, CatalogProtos.PartitionDescProto partitionDescProto)
focal_class.class_method_signature: HCatalogStore.getPartitions(String tableName)
focal_class.full_signature: @Override public CatalogProtos.PartitionsProto getPartitions(String tableName)
focal_class.identifier: getPartitions
focal_class.modifiers: @Override public
focal_class.parameters: (String tableName)
focal_class.return: CatalogProtos.PartitionsProto
focal_class.signature: CatalogProtos.PartitionsProto getPartitions(String tableName)
focal_class.class_method_signature: HCatalogStore.getPartition(String partitionName)
focal_class.full_signature: @Override public CatalogProtos.PartitionDescProto getPartition(String partitionName)
focal_class.identifier: getPartition
focal_class.modifiers: @Override public
focal_class.parameters: (String partitionName)
focal_class.return: CatalogProtos.PartitionDescProto
focal_class.signature: CatalogProtos.PartitionDescProto getPartition(String partitionName)
focal_class.class_method_signature: HCatalogStore.delPartition(String partitionName)
focal_class.full_signature: @Override public void delPartition(String partitionName)
focal_class.identifier: delPartition
focal_class.modifiers: @Override public
focal_class.parameters: (String partitionName)
focal_class.return: void
focal_class.signature: void delPartition(String partitionName)
focal_class.class_method_signature: HCatalogStore.dropPartitions(String tableName)
focal_class.full_signature: @Override public void dropPartitions(String tableName)
focal_class.identifier: dropPartitions
focal_class.modifiers: @Override public
focal_class.parameters: (String tableName)
focal_class.return: void
focal_class.signature: void dropPartitions(String tableName)
focal_class.class_method_signature: HCatalogStore.addFunction(final FunctionDesc func)
focal_class.full_signature: @Override public final void addFunction(final FunctionDesc func)
focal_class.identifier: addFunction
focal_class.modifiers: @Override public final
focal_class.parameters: (final FunctionDesc func)
focal_class.return: void
focal_class.signature: void addFunction(final FunctionDesc func)
focal_class.class_method_signature: HCatalogStore.deleteFunction(final FunctionDesc func)
focal_class.full_signature: @Override public final void deleteFunction(final FunctionDesc func)
focal_class.identifier: deleteFunction
focal_class.modifiers: @Override public final
focal_class.parameters: (final FunctionDesc func)
focal_class.return: void
focal_class.signature: void deleteFunction(final FunctionDesc func)
focal_class.class_method_signature: HCatalogStore.existFunction(final FunctionDesc func)
focal_class.full_signature: @Override public final void existFunction(final FunctionDesc func)
focal_class.identifier: existFunction
focal_class.modifiers: @Override public final
focal_class.parameters: (final FunctionDesc func)
focal_class.return: void
focal_class.signature: void existFunction(final FunctionDesc func)
focal_class.class_method_signature: HCatalogStore.getAllFunctionNames()
focal_class.full_signature: @Override public final List<String> getAllFunctionNames()
focal_class.identifier: getAllFunctionNames
focal_class.modifiers: @Override public final
focal_class.parameters: ()
focal_class.return: List<String>
focal_class.signature: List<String> getAllFunctionNames()
focal_class.class_method_signature: HCatalogStore.dropIndex(String databaseName, String indexName)
focal_class.full_signature: @Override public void dropIndex(String databaseName, String indexName)
focal_class.identifier: dropIndex
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName, String indexName)
focal_class.return: void
focal_class.signature: void dropIndex(String databaseName, String indexName)
focal_class.class_method_signature: HCatalogStore.existIndexByName(String databaseName, String indexName)
focal_class.full_signature: @Override public boolean existIndexByName(String databaseName, String indexName)
focal_class.identifier: existIndexByName
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName, String indexName)
focal_class.return: boolean
focal_class.signature: boolean existIndexByName(String databaseName, String indexName)
focal_class.class_method_signature: HCatalogStore.getIndexes(String databaseName, String tableName)
focal_class.full_signature: @Override public CatalogProtos.IndexDescProto[] getIndexes(String databaseName, String tableName)
focal_class.identifier: getIndexes
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName, String tableName)
focal_class.return: CatalogProtos.IndexDescProto[]
focal_class.signature: CatalogProtos.IndexDescProto[] getIndexes(String databaseName, String tableName)
focal_class.class_method_signature: HCatalogStore.createIndex(CatalogProtos.IndexDescProto proto)
focal_class.full_signature: @Override public void createIndex(CatalogProtos.IndexDescProto proto)
focal_class.identifier: createIndex
focal_class.modifiers: @Override public
focal_class.parameters: (CatalogProtos.IndexDescProto proto)
focal_class.return: void
focal_class.signature: void createIndex(CatalogProtos.IndexDescProto proto)
focal_class.class_method_signature: HCatalogStore.getIndexByName(String databaseName, String indexName)
focal_class.full_signature: @Override public CatalogProtos.IndexDescProto getIndexByName(String databaseName, String indexName)
focal_class.identifier: getIndexByName
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName, String indexName)
focal_class.return: CatalogProtos.IndexDescProto
focal_class.signature: CatalogProtos.IndexDescProto getIndexByName(String databaseName, String indexName)
focal_class.class_method_signature: HCatalogStore.getIndexByColumn(String databaseName, String tableName, String columnName)
focal_class.full_signature: @Override public CatalogProtos.IndexDescProto getIndexByColumn(String databaseName, String tableName, String columnName)
focal_class.identifier: getIndexByColumn
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName, String tableName, String columnName)
focal_class.return: CatalogProtos.IndexDescProto
focal_class.signature: CatalogProtos.IndexDescProto getIndexByColumn(String databaseName, String tableName, String columnName)
focal_class.class_method_signature: HCatalogStore.existIndexByColumn(String databaseName, String tableName, String columnName)
focal_class.full_signature: @Override public boolean existIndexByColumn(String databaseName, String tableName, String columnName)
focal_class.identifier: existIndexByColumn
focal_class.modifiers: @Override public
focal_class.parameters: (String databaseName, String tableName, String columnName)
focal_class.return: boolean
focal_class.signature: boolean existIndexByColumn(String databaseName, String tableName, String columnName)
focal_class.class_method_signature: HCatalogStore.close()
focal_class.full_signature: @Override public final void close()
focal_class.identifier: close
focal_class.modifiers: @Override public final
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void close()
focal_class.class_method_signature: HCatalogStore.existColumn(final String databaseName ,final String tableName , final String columnName)
focal_class.full_signature: private boolean existColumn(final String databaseName ,final String tableName , final String columnName)
focal_class.identifier: existColumn
focal_class.modifiers: private
focal_class.parameters: (final String databaseName ,final String tableName , final String columnName)
focal_class.return: boolean
focal_class.signature: boolean existColumn(final String databaseName ,final String tableName , final String columnName)
focal_class.superclass: extends CatalogConstants
focal_method.body: @Override
    public final List<String> getAllTableNames(String databaseName) throws CatalogException {
      HCatalogStoreClientPool.HCatalogStoreClient client = null;
  
      try {
        client = clientPool.getClient();
        return client.getHiveClient().getAllTables(databaseName);
      } catch (MetaException e) {
        throw new CatalogException(e);
      } finally {
        if(client != null) client.release();
      }
    }
focal_method.class_method_signature: HCatalogStore.getAllTableNames(String databaseName)
focal_method.full_signature: @Override public final List<String> getAllTableNames(String databaseName)
focal_method.identifier: getAllTableNames
focal_method.invocations: getClient getAllTables getHiveClient release
focal_method.modifiers: @Override public final
focal_method.parameters: (String databaseName)
focal_method.return: List<String>
focal_method.signature: List<String> getAllTableNames(String databaseName)