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

Class GryoPool

java.lang.Object

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

public final class GryoPool
extends Object

Gryo objects are somewhat expensive to construct (given the dependency on Kryo), therefore this pool helps re-use those objects.

Author:

Marko A. Rodriguez (http://markorodriguez.com), Stephen Mallette (http://stephen.genoprime.com)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GryoPool.Type

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONFIG_IO_GRYO_POOL_SIZE
static String	CONFIG_IO_REGISTRY

Constructor Summary

Constructors

Constructor and Description
GryoPool(Configuration conf) Create a pool of readers and writers from a Configuration object.
GryoPool(int poolSize, GryoPool.Type type, List<IoRegistry> registries) Create a pool of a readers, writers or both of the specified size with an optional IoRegistry object which would allow custom serializers to be registered to the pool.

Method Summary

Modifier and Type	Method and Description
<A> A	doWithReader(Function<GryoReader,A> readerFunction)
void	doWithWriter(Consumer<GryoWriter> writerFunction)
void	offerReader(GryoReader gryoReader)
void	offerWriter(GryoWriter gryoWriter)
GryoReader	takeReader()
GryoWriter	takeWriter()

Methods inherited from class java.lang.Object

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

Field Detail

CONFIG_IO_REGISTRY

public static final String CONFIG_IO_REGISTRY

See Also:

Constant Field Values

CONFIG_IO_GRYO_POOL_SIZE

public static final String CONFIG_IO_GRYO_POOL_SIZE

See Also:

Constant Field Values

Constructor Detail

GryoPool

public GryoPool(Configuration conf)

Create a pool of readers and writers from a Configuration object. There are two configuration keys expected: "gremlin.io.registry" which defines comma separated list of the fully qualified class names of IoRegistry implementations to use and the "gremlin.io.gryo.poolSize" which defines the initial size of the GryoPool. As with usage of GryoMapper.Builder.addRegistry(IoRegistry), the order in which these items are added matters greatly. The order used for writing should be the order used for reading.

GryoPool

public GryoPool(int poolSize,
                GryoPool.Type type,
                List<IoRegistry> registries)

Create a pool of a readers, writers or both of the specified size with an optional IoRegistry object which would allow custom serializers to be registered to the pool.

Parameters:

poolSize - initial size of the pool.

type - the type of pool.

registries - a list of registries to assign to each GryoReader and GryoWriter instances.

Method Detail

takeReader

public GryoReader takeReader()

takeWriter

public GryoWriter takeWriter()

offerReader

public void offerReader(GryoReader gryoReader)

offerWriter

public void offerWriter(GryoWriter gryoWriter)

doWithReader

public <A> A doWithReader(Function<GryoReader,A> readerFunction)

doWithWriter

public void doWithWriter(Consumer<GryoWriter> writerFunction)