org.neo4j.talend

Class Neo4jBatchDatabase

java.lang.Object

org.neo4j.talend.Neo4jBatchDatabase

public class Neo4jBatchDatabase
extends Object

Wrapper on a Neo4j batch inserter 'database'.

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,org.neo4j.unsafe.batchinsert.BatchInserterIndex>	batchInserterIndexes Store the list of index

Constructor Summary

Constructors

Constructor and Description
Neo4jBatchDatabase(String path, Map<String,String> configuration) Constructor that create an embedded database.

Method Summary

Modifier and Type	Method and Description
void	createBatchIndex(String indexName, Integer indexCacheSize) Create and store the index, if it doesn't exist.
void	createSchema(String type, String label, String property) Create schema.
Long	findNodeInBatchIndex(String indexName, Object value) Find a node in the index.
void	flushBatchIndex(String indexName) Flush the specified index on the disk, so it will be available after for search.
org.neo4j.unsafe.batchinsert.BatchInserter	getInserter() Getter for inserter
void	indexNodeInBatchIndex(String indexName, long node, Object importIdValue) Push a node importId into the batch index.
void	shutdown() Shutdown the graph database

Methods inherited from class java.lang.Object

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

Field Detail

batchInserterIndexes

protected Map<String,org.neo4j.unsafe.batchinsert.BatchInserterIndex> batchInserterIndexes

Store the list of index

Constructor Detail

Neo4jBatchDatabase

public Neo4jBatchDatabase(String path,
                          Map<String,String> configuration)

Constructor that create an embedded database.

Parameters:

path - Path of the graph database folder

configuration - Configuration map of database

Method Detail

getInserter

public org.neo4j.unsafe.batchinsert.BatchInserter getInserter()

Getter for inserter

Returns:

The batch inserter

createBatchIndex

public void createBatchIndex(String indexName,
                             Integer indexCacheSize)

Create and store the index, if it doesn't exist.

Parameters:

indexName - Name of the index

indexCacheSize - Number of element into the cache size for the index

flushBatchIndex

public void flushBatchIndex(String indexName)

Flush the specified index on the disk, so it will be available after for search.

Parameters:

indexName - Name of the index to flush

indexNodeInBatchIndex

public void indexNodeInBatchIndex(String indexName,
                                  long node,
                                  Object importIdValue)

Push a node importId into the batch index.

Parameters:

indexName - The batch index name

node - Neo4j identifier

importIdValue - Import identifier

findNodeInBatchIndex

public Long findNodeInBatchIndex(String indexName,
                                 Object value)

Find a node in the index.

Parameters:

indexName - Name of the batch index

value - Value to search in index

Returns:

Neo4j node identifier

createSchema

public void createSchema(String type,
                         String label,
                         String property)

Create schema.

Parameters:

type - Type of schema to create (ie. constraint or index on node property)

label - Node label

property - Node property

shutdown

public void shutdown()

Shutdown the graph database