@Test public void testEmptyLines() throws Exception { String csvPath = MinimalCSVImporterTest.class .getResource("/csv/inputEmptyLines.csv").getPath(); String gdlPath = MinimalCSVImporterTest.class.getResource("/csv/expected.gdl").getPath(); FlinkAsciiGraphLoader loader = getLoaderFromFile(gdlPath); DataSource importer = new MinimalCSVImporter(csvPath, DELIMITER, getConfig(), true); LogicalGraph result = importer.getLogicalGraph(); LogicalGraph expected = loader.getLogicalGraphByVariable("expected"); collectAndAssertTrue(expected.equalsByElementData(result)); }
@Override public LogicalGraph getLogicalGraph() throws IOException { DataSet<EPGMVertex> vertices; if (columnNames == null) { vertices = readCSVFile(readHeaderRow(), checkReoccurringHeader); } else { vertices = readCSVFile(columnNames, checkReoccurringHeader); } return config.getLogicalGraphFactory().fromDataSets(vertices); }
MinimalCSVImporter implements DataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { DataSet<EPGMVertex> vertices; if (columnNames == null) { vertices = readCSVFile(readHeaderRow(), checkReoccurringHeader); } else { vertices = readCSVFile(columnNames, checkReoccurringHeader); } return config.getLogicalGraphFactory().fromDataSets(vertices); } }
MinimalCSVImporter implements DataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { DataSet<EPGMVertex> vertices; if (columnNames == null) { vertices = readCSVFile(readHeaderRow(), checkReoccurringHeader); } else { vertices = readCSVFile(columnNames, checkReoccurringHeader); } return config.getLogicalGraphFactory().fromDataSets(vertices); } MinimalCSVImporter(String path, String tokenSeparator, GradoopFlinkConfig config,
                            List<String> columnNames, boolean checkReoccurringHeader);  MinimalCSVImporter(String path, String tokenSeparator, GradoopFlinkConfig config,
                            boolean checkReoccurringHeader);  MinimalCSVImporter(String path, String tokenSeparator, GradoopFlinkConfig config,
                            String charset, boolean checkReoccurringHeader); }
MinimalCSVImporter implements DataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { DataSet<EPGMVertex> vertices; if (columnNames == null) { vertices = readCSVFile(readHeaderRow(), checkReoccurringHeader); } else { vertices = readCSVFile(columnNames, checkReoccurringHeader); } return config.getLogicalGraphFactory().fromDataSets(vertices); } MinimalCSVImporter(String path, String tokenSeparator, GradoopFlinkConfig config,
                            List<String> columnNames, boolean checkReoccurringHeader);  MinimalCSVImporter(String path, String tokenSeparator, GradoopFlinkConfig config,
                            boolean checkReoccurringHeader);  MinimalCSVImporter(String path, String tokenSeparator, GradoopFlinkConfig config,
                            String charset, boolean checkReoccurringHeader); @Override LogicalGraph getLogicalGraph(); @Override GraphCollection getGraphCollection(); }
MinimalCSVImporter implements DataSource { @Override public LogicalGraph getLogicalGraph() throws IOException { DataSet<EPGMVertex> vertices; if (columnNames == null) { vertices = readCSVFile(readHeaderRow(), checkReoccurringHeader); } else { vertices = readCSVFile(columnNames, checkReoccurringHeader); } return config.getLogicalGraphFactory().fromDataSets(vertices); } MinimalCSVImporter(String path, String tokenSeparator, GradoopFlinkConfig config,
                            List<String> columnNames, boolean checkReoccurringHeader);  MinimalCSVImporter(String path, String tokenSeparator, GradoopFlinkConfig config,
                            boolean checkReoccurringHeader);  MinimalCSVImporter(String path, String tokenSeparator, GradoopFlinkConfig config,
                            String charset, boolean checkReoccurringHeader); @Override LogicalGraph getLogicalGraph(); @Override GraphCollection getGraphCollection();  }