@Test void testDatasetCollectorFinisher() throws Exception { try (final Dataset dataset = generate(() -> rdf.createQuad(getIRI(), getIRI(), getIRI(), getIRI())) .parallel().limit(size).collect(toDataset())) { final TrellisUtils.DatasetCollector collector = toDataset(); assertEquals(dataset, collector.finisher().apply(dataset), "Dataset finisher returns the wrong object!"); } }
public static DatasetCollector toDataset() { return new DatasetCollector(); }
TrellisUtils { public static DatasetCollector toDataset() { return new DatasetCollector(); } }
TrellisUtils { public static DatasetCollector toDataset() { return new DatasetCollector(); } private  TrellisUtils(); }
TrellisUtils { public static DatasetCollector toDataset() { return new DatasetCollector(); } private  TrellisUtils(); static Optional<IRI> getContainer(final IRI identifier); static IRI normalizeIdentifier(final IRI identifier); static IRI buildTrellisIdentifier(final String path); static String normalizePath(final String path); static Collector<Triple, ?, Graph> toGraph(); static DatasetCollector toDataset(); }
TrellisUtils { public static DatasetCollector toDataset() { return new DatasetCollector(); } private  TrellisUtils(); static Optional<IRI> getContainer(final IRI identifier); static IRI normalizeIdentifier(final IRI identifier); static IRI buildTrellisIdentifier(final String path); static String normalizePath(final String path); static Collector<Triple, ?, Graph> toGraph(); static DatasetCollector toDataset(); static final String TRELLIS_SCHEME; static final String TRELLIS_DATA_PREFIX; static final String TRELLIS_BNODE_PREFIX; static final String TRELLIS_SESSION_PREFIX; static final String TRELLIS_ADMIN_ROLE; }