@Test void testCollectGraph() throws Exception { try (final Graph graph = generate(() -> rdf.createTriple(getIRI(), getIRI(), getIRI())) .parallel().limit(size).collect(toGraph())) { assertTrue(size >= graph.size(), "Generated graph has too many triples!"); } }
public static Collector<Triple, ?, Graph> toGraph() { return Collector.of(rdf::createGraph, Graph::add, (left, right) -> { right.iterate().forEach(left::add); return left; }, UNORDERED); }
TrellisUtils { public static Collector<Triple, ?, Graph> toGraph() { return Collector.of(rdf::createGraph, Graph::add, (left, right) -> { right.iterate().forEach(left::add); return left; }, UNORDERED); } }
TrellisUtils { public static Collector<Triple, ?, Graph> toGraph() { return Collector.of(rdf::createGraph, Graph::add, (left, right) -> { right.iterate().forEach(left::add); return left; }, UNORDERED); } private  TrellisUtils(); }
TrellisUtils { public static Collector<Triple, ?, Graph> toGraph() { return Collector.of(rdf::createGraph, Graph::add, (left, right) -> { right.iterate().forEach(left::add); return left; }, UNORDERED); } 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 Collector<Triple, ?, Graph> toGraph() { return Collector.of(rdf::createGraph, Graph::add, (left, right) -> { right.iterate().forEach(left::add); return left; }, UNORDERED); } 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; }