@Test public void testImportGraphCollection() throws Exception { String csvPath = MinimalCSVImporterTest.class.getResource("/csv/input.csv").getPath(); DataSource importVertexImporter = new MinimalCSVImporter(csvPath, DELIMITER, getConfig(), true); DataSet<EPGMVertex> importVertex = importVertexImporter.getGraphCollection().getVertices(); List<EPGMVertex> lv = new ArrayList<>(); importVertex.output(new LocalCollectionOutputFormat<>(lv)); getExecutionEnvironment().execute(); checkImportedVertices(lv); }
@Override public GraphCollection getGraphCollection() throws IOException { LogicalGraph logicalGraph = getLogicalGraph(); return logicalGraph.getCollectionFactory().fromGraph(logicalGraph); }
MinimalCSVImporter implements DataSource { @Override public GraphCollection getGraphCollection() throws IOException { LogicalGraph logicalGraph = getLogicalGraph(); return logicalGraph.getCollectionFactory().fromGraph(logicalGraph); } }
MinimalCSVImporter implements DataSource { @Override public GraphCollection getGraphCollection() throws IOException { LogicalGraph logicalGraph = getLogicalGraph(); return logicalGraph.getCollectionFactory().fromGraph(logicalGraph); } 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 GraphCollection getGraphCollection() throws IOException { LogicalGraph logicalGraph = getLogicalGraph(); return logicalGraph.getCollectionFactory().fromGraph(logicalGraph); } 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 GraphCollection getGraphCollection() throws IOException { LogicalGraph logicalGraph = getLogicalGraph(); return logicalGraph.getCollectionFactory().fromGraph(logicalGraph); } 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();  }