com.blazegraph.gremlin.structure

Class BlazeGraph.GraphStreamer<E>

java.lang.Object

com.blazegraph.gremlin.structure.BlazeGraph.GraphStreamer<E>

Type Parameters:

E - the type of Sesame element (BindingSet or Statement)

Enclosing class:

BlazeGraph

protected class BlazeGraph.GraphStreamer<E>
extends Object

Convert a Sesame iteration into a Java 8 Stream. Backed by database resources so these streams must be closed when finished. (Does not close the connection but will close the Sesame iteration / Blaze iterators).

Author:

mikepersonick

Constructor Summary

Constructors

Constructor and Description
GraphStreamer(info.aduna.iteration.CloseableIteration<E,?> result, Optional<Runnable> onClose) Construct a streamer using the supplied Sesame iteration and optional onClose() behavior.

Method Summary

Modifier and Type	Method and Description
void	close() Close the Sesame iteration and run the custom onClose behavior if supplied.
Stream<E>	stream() Provide a one-time stream against the Sesame iteration with the appropriate onClose behavior.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GraphStreamer

public GraphStreamer(info.aduna.iteration.CloseableIteration<E,?> result,
                     Optional<Runnable> onClose)

Construct a streamer using the supplied Sesame iteration and optional onClose() behavior. The iteration will be closed automatically by this class, so the onClose code does not need to do it.

Method Detail

stream

public Stream<E> stream()

Provide a one-time stream against the Sesame iteration with the appropriate onClose behavior. You MUST close this stream to release database resources.

close

public void close()

Close the Sesame iteration and run the custom onClose behavior if supplied.