org.neo4j.talend

Class Neo4jBatchInserterRelationship

java.lang.Object

org.neo4j.talend.Neo4jBatchInserterRelationship

public class Neo4jBatchInserterRelationship
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Neo4jBatchDatabase	batchDb Neo4jBatchDatabase.

Constructor Summary

Constructors

Constructor and Description
Neo4jBatchInserterRelationship(Neo4jBatchDatabase graphDb, String relationshipTypeField, String direction, String startIndexName, String startIndexField, String endIndexName, String endIndexField, Boolean skipOnError) Constructor.

Method Summary

Modifier and Type	Method and Description
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) Create the relationship.
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

Neo4jBatchInserterRelationship

public Neo4jBatchInserterRelationship(Neo4jBatchDatabase graphDb,
                                      String relationshipTypeField,
                                      String direction,
                                      String startIndexName,
                                      String startIndexField,
                                      String endIndexName,
                                      String endIndexField,
                                      Boolean skipOnError)
                               throws IOException

Constructor.

Throws:

IOException

Method Detail

create

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

Create the relationship.

Parameters:

incoming - Talend incoming object

columnList - Attribute list of Talend object

finish

public void finish()

Finish the process.

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