Package org.apache.tinkerpop.gremlin.structure.io.gryo

Class VertexByteArrayInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

org.apache.tinkerpop.gremlin.structure.io.gryo.VertexByteArrayInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public final class VertexByteArrayInputStream
extends FilterInputStream

An InputStream implementation that can independently process a Gryo file written with GryoWriter.writeVertices(OutputStream, Iterator).

Author:

Stephen Mallette (http://stephen.genoprime.com)

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor	Description
VertexByteArrayInputStream(InputStream inputStream)

Method Summary

Modifier and Type	Method	Description
ByteArrayOutputStream	readVertexBytes()	Read the bytes of the next Vertex in the stream.

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, read, read, read, reset, skip

Methods inherited from class java.io.InputStream

nullInputStream, readAllBytes, readNBytes, readNBytes, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Constructor Details

VertexByteArrayInputStream

public VertexByteArrayInputStream(InputStream inputStream)

Method Details

readVertexBytes

public ByteArrayOutputStream readVertexBytes()
                                      throws IOException

Read the bytes of the next Vertex in the stream. The returned stream can then be passed to GryoReader.readVertex(java.io.InputStream, java.util.function.Function).

Throws:

IOException