@Test public void getTransformPlan() throws Exception { String dbName = "testdb"; TestDatabase.genTable(1, 1, false); mCatalog.attachDatabase(NoopJournalContext.INSTANCE, TestUdbFactory.TYPE, "connect_URI", TestDatabase.TEST_UDB_NAME, dbName, Collections.emptyMap(), false); assertEquals(1, mCatalog.getAllDatabases().size()); assertEquals(1, mCatalog.getAllTables(dbName).size()); String tableName = TestDatabase.getTableName(0); ServerConfiguration.set(PropertyKey.MASTER_HOSTNAME, "localhost"); List<TransformPlan> plans = mCatalog.getTransformPlan(dbName, tableName, TRANSFORM_DEFINITION); assertEquals(1, plans.size()); Table table = mCatalog.getTable(dbName, tableName); assertEquals(1, table.getPartitions().size()); assertEquals(table.getPartitions().get(0).getLayout(), plans.get(0).getBaseLayout()); }
public List<TransformPlan> getTransformPlan(String dbName, String tableName, TransformDefinition definition) throws IOException { return getTableInternal(dbName, tableName).getTransformPlans(definition); }
AlluxioCatalog implements Journaled { public List<TransformPlan> getTransformPlan(String dbName, String tableName, TransformDefinition definition) throws IOException { return getTableInternal(dbName, tableName).getTransformPlans(definition); } }
AlluxioCatalog implements Journaled { public List<TransformPlan> getTransformPlan(String dbName, String tableName, TransformDefinition definition) throws IOException { return getTableInternal(dbName, tableName).getTransformPlans(definition); } AlluxioCatalog(); }
AlluxioCatalog implements Journaled { public List<TransformPlan> getTransformPlan(String dbName, String tableName, TransformDefinition definition) throws IOException { return getTableInternal(dbName, tableName).getTransformPlans(definition); } AlluxioCatalog(); LayoutRegistry getLayoutRegistry(); SyncStatus attachDatabase(JournalContext journalContext, String udbType,
      String udbConnectionUri, String udbDbName, String dbName, Map<String, String> map,
      boolean ignoreSyncErrors); SyncStatus syncDatabase(JournalContext journalContext, String dbName); boolean detachDatabase(JournalContext journalContext, String dbName); Table getTable(String dbName, String tableName); List<String> getAllDatabases(); alluxio.grpc.table.Database getDatabase(String dbName); List<String> getAllTables(String dbName); List<ColumnStatisticsInfo> getTableColumnStatistics(String dbName, String tableName,
      List<String> colNames); Map<String, ColumnStatisticsList> getPartitionColumnStatistics(String dbName,
      String tableName, List<String> partNames, List<String> colNames); List<alluxio.grpc.table.Partition> readTable(String dbName, String tableName,
      Constraint constraint); void completeTransformTable(JournalContext journalContext, String dbName, String tableName,
      String definition, Map<String, Layout> transformedLayouts); List<TransformPlan> getTransformPlan(String dbName, String tableName,
      TransformDefinition definition); @Override boolean processJournalEntry(Journal.JournalEntry entry); @Override void resetState(); @Override Iterator<Journal.JournalEntry> getJournalEntryIterator(); @Override CheckpointName getCheckpointName(); }
AlluxioCatalog implements Journaled { public List<TransformPlan> getTransformPlan(String dbName, String tableName, TransformDefinition definition) throws IOException { return getTableInternal(dbName, tableName).getTransformPlans(definition); } AlluxioCatalog(); LayoutRegistry getLayoutRegistry(); SyncStatus attachDatabase(JournalContext journalContext, String udbType,
      String udbConnectionUri, String udbDbName, String dbName, Map<String, String> map,
      boolean ignoreSyncErrors); SyncStatus syncDatabase(JournalContext journalContext, String dbName); boolean detachDatabase(JournalContext journalContext, String dbName); Table getTable(String dbName, String tableName); List<String> getAllDatabases(); alluxio.grpc.table.Database getDatabase(String dbName); List<String> getAllTables(String dbName); List<ColumnStatisticsInfo> getTableColumnStatistics(String dbName, String tableName,
      List<String> colNames); Map<String, ColumnStatisticsList> getPartitionColumnStatistics(String dbName,
      String tableName, List<String> partNames, List<String> colNames); List<alluxio.grpc.table.Partition> readTable(String dbName, String tableName,
      Constraint constraint); void completeTransformTable(JournalContext journalContext, String dbName, String tableName,
      String definition, Map<String, Layout> transformedLayouts); List<TransformPlan> getTransformPlan(String dbName, String tableName,
      TransformDefinition definition); @Override boolean processJournalEntry(Journal.JournalEntry entry); @Override void resetState(); @Override Iterator<Journal.JournalEntry> getJournalEntryIterator(); @Override CheckpointName getCheckpointName();  }