@Test void propertyTableTest() { final Settings settings = new Settings.Builder("testingDB").build(); final DatabaseStatistics statistics = new DatabaseStatistics("testingDB"); final WidePropertyTableLoader pt_loader = new WidePropertyTableLoader(settings, spark, statistics); pt_loader.load(); final Dataset<Row> propertyTable = spark.sql("SELECT * FROM property_table"); final long ptNumberRows = propertyTable.count(); assert (ptNumberRows == numberSubjects); final long ptNumberColumns = propertyTable.columns().length - 1; assertEquals(numberPredicates, ptNumberColumns, "Number of columns must be " + 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();  }