org.neo4j.talend

Class Neo4jBatchInserterNode

java.lang.Object

org.neo4j.talend.Neo4jBatchInserterNode

public class Neo4jBatchInserterNode
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Neo4jBatchDatabase	batchDb Neo4jBatchDatabase.

Constructor Summary

Constructors

Constructor and Description
Neo4jBatchInserterNode(Neo4jBatchDatabase batchDb, String labelsField, String batchIndexName, String batchIndexFieldName, Boolean insertIndexFieldName, Integer indexCacheSize) Constructor

Method Summary

Modifier and Type	Method and Description
protected org.neo4j.graphdb.Label[]	computeLabels(Object incoming)
protected Map<String,Object>	constructMapFromObject(Object obj, List<String> columnList) Convert a Talend object to a map of attributes.
void	create(Object incoming, List<String> columnList) Insert a node.
void	finish() Finish the process.
protected Object	getObjectProperty(Object obj, String property) Retrieve the value of a field on an object

Methods inherited from class java.lang.Object

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

Field Detail

batchDb

protected Neo4jBatchDatabase batchDb

Neo4jBatchDatabase.

Constructor Detail

Neo4jBatchInserterNode

public Neo4jBatchInserterNode(Neo4jBatchDatabase batchDb,
                              String labelsField,
                              String batchIndexName,
                              String batchIndexFieldName,
                              Boolean insertIndexFieldName,
                              Integer indexCacheSize)
                       throws IOException

Constructor

Parameters:

batchDb - Batch inserter database

labelsField - Field name where to find labels

batchIndexName - Batch index name

batchIndexFieldName - Batch index field name

insertIndexFieldName - If we have to save the index field

indexCacheSize - Size of the cache index

Throws:

IOException

Method Detail

create

public void create(Object incoming,
                   List<String> columnList)

Insert a node.

Parameters:

incoming - Talend object

columnList - Attributes list of the Talend object

finish

public void finish()

Finish the process.

computeLabels

protected org.neo4j.graphdb.Label[] computeLabels(Object incoming)
                                           throws IllegalAccessException

Throws:

IllegalAccessException

getObjectProperty

protected Object getObjectProperty(Object obj,
                                   String property)
                            throws IllegalAccessException

Retrieve the value of a field on an object

Parameters:

obj - the object

property - the property to retrieve

Returns:

The property value, or null if not found

Throws:

IllegalAccessException

constructMapFromObject

protected Map<String,Object> constructMapFromObject(Object obj,
                                                    List<String> columnList)
                                             throws IllegalAccessException

Convert a Talend object to a map of attributes.

Parameters:

obj - The talend object

columnList - List of object properties

Returns:

Map of attributes

Throws:

IllegalAccessException