@Test public void testGetTableNameFromVariable_whenVariableValueExists() { String expectedTableName = "hbweblogs"; transMeta.setVariable( "hb_weblogs", "hbweblogs" ); String tableName = MappingAdmin.getTableNameFromVariable( stepMeta, "${hb_weblogs}" ); assertEquals( expectedTableName, tableName ); }
public static String getTableNameFromVariable( BaseStepMeta stepMeta, String mappedTableName ) { TransMeta parentTransMeta = stepMeta.getParentStepMeta().getParentTransMeta(); return parentTransMeta.environmentSubstitute( mappedTableName ); }
MappingAdmin implements Closeable { public static String getTableNameFromVariable( BaseStepMeta stepMeta, String mappedTableName ) { TransMeta parentTransMeta = stepMeta.getParentStepMeta().getParentTransMeta(); return parentTransMeta.environmentSubstitute( mappedTableName ); } }
MappingAdmin implements Closeable { public static String getTableNameFromVariable( BaseStepMeta stepMeta, String mappedTableName ) { TransMeta parentTransMeta = stepMeta.getParentStepMeta().getParentTransMeta(); return parentTransMeta.environmentSubstitute( mappedTableName ); } MappingAdmin( HBaseConnection hBaseConnection ); }
MappingAdmin implements Closeable { public static String getTableNameFromVariable( BaseStepMeta stepMeta, String mappedTableName ) { TransMeta parentTransMeta = stepMeta.getParentStepMeta().getParentTransMeta(); return parentTransMeta.environmentSubstitute( mappedTableName ); } MappingAdmin( HBaseConnection hBaseConnection ); void setMappingTableName( String tableName ); String getMappingTableName(); void createTestMapping(); void createTestTupleMapping(); void createTupleTestTable(); void createTestTable(); void createMappingTable(); boolean mappingExists( String tableName, String mappingName ); Set<String> getMappedTables(); List<String> getMappingNames( String tableName ); boolean deleteMapping( String tableName, String mappingName ); boolean deleteMapping( Mapping theMapping ); void putMapping( Mapping theMapping, boolean overwrite ); String describeMapping( String tableName, String mappingName ); String describeMapping( Mapping aMapping ); Mapping getMapping( String tableName, String mappingName ); @Override void close(); HBaseConnection getConnection(); static String getTableNameFromVariable( BaseStepMeta stepMeta, String mappedTableName ); }
MappingAdmin implements Closeable { public static String getTableNameFromVariable( BaseStepMeta stepMeta, String mappedTableName ) { TransMeta parentTransMeta = stepMeta.getParentStepMeta().getParentTransMeta(); return parentTransMeta.environmentSubstitute( mappedTableName ); } MappingAdmin( HBaseConnection hBaseConnection ); void setMappingTableName( String tableName ); String getMappingTableName(); void createTestMapping(); void createTestTupleMapping(); void createTupleTestTable(); void createTestTable(); void createMappingTable(); boolean mappingExists( String tableName, String mappingName ); Set<String> getMappedTables(); List<String> getMappingNames( String tableName ); boolean deleteMapping( String tableName, String mappingName ); boolean deleteMapping( Mapping theMapping ); void putMapping( Mapping theMapping, boolean overwrite ); String describeMapping( String tableName, String mappingName ); String describeMapping( Mapping aMapping ); Mapping getMapping( String tableName, String mappingName ); @Override void close(); HBaseConnection getConnection(); static String getTableNameFromVariable( BaseStepMeta stepMeta, String mappedTableName ); static final String COLUMNS_FAMILY_NAME; static final String KEY_FAMILY_NAME; }