@Test void verticalPartitioningTest() { final Settings settings = new Settings.Builder("testingDB").build(); final DatabaseStatistics statistics = new DatabaseStatistics("testingDB"); final VerticalPartitioningLoader vp_loader = new VerticalPartitioningLoader(settings, spark, statistics); vp_loader.load(); final Dataset<Row> tables_list = spark.sql("SHOW tables"); final long tables_count = tables_list.count(); assert (tables_count > numberPredicates); }
public abstract void load() throws Exception;
Loader { public abstract void load() throws Exception; }
Loader { public abstract void load() throws Exception; Loader(final String databaseName, final SparkSession spark, final DatabaseStatistics statistics); }
Loader { public abstract void load() throws Exception; Loader(final String databaseName, final SparkSession spark, final DatabaseStatistics statistics); abstract void load(); }
Loader { public abstract void load() throws Exception; Loader(final String databaseName, final SparkSession spark, final DatabaseStatistics statistics); abstract void load();  }