Well as I mentioned the code does not fail anywhere, it runs it full course
and just skips the writing to the graph part.
I have just one graph and I pass just 1 instance of the batchInserter to
the map function.
My code is in Scala, sample code attached below
class ExportReducer extends Reducer[Text,MapWritable,LongWritable,Text]{
type Context = org.apache.hadoop.mapreduce.Reducer[Text, MapWritable,
LongWritable, Text]#Context
@throws(classOf[Exception])
override def reduce(key: Text, value: java.lang.Iterable[MapWritable],
context: Context) {
var keys: Array[String] = key.toString.split(":")
var uri1 = "first" + keys(0)
var uri2 = "last" + keys(1)
ExportReducerObject.propertiesUID.put("ID",uri1);
var node1 =
ExportReducerObject.batchInserter.createNode(ExportReducerObject.propertiesUID);
ExportReducerObject.indexService.add(node1,ExportReducerObject.propertiesUID)
ExportReducerObject.propertiesCID.put("ID",uri2);
var node2 =
ExportReducerObject.batchInserter.createNode(ExportReducerObject.propertiesCID);
ExportReducerObject.indexService.add(node2,ExportReducerObject.propertiesCID);
ExportReducerObject.propertiesEdges.put("fullName","1.0");
ExportReducerObject.batchInserter.createRelationship(node1,node2,DynamicRelationshipType.withName("
fullName"),ExportReducerObject.propertiesEdges)
}
My graph properties are defined as below :-
val batchInserter = new BatchInserterImpl("graph",
BatchInserterImpl.loadProperties("neo4j.props"))
val indexProvider = new LuceneBatchInserterIndexProvider(batchInserter)
val indexService =
indexProvider.nodeIndex("ID",MapUtil.stringMap("type","exact"))
Mind it that the code works perfectly( writes to the graph) when running in
local mode.
On Fri, Jun 17, 2011 at 11:32 AM, sulabh choudhury <[email protected]>wrote:
> I am trying to write MapReduce job to do Neo4j Batchinserters.
> It works fine when I just run it like a java file(runs in local mode) and
> does the insert, but when I try to run it in the distributed mode it does
> not write to the graph.
> Is it issue related to permissions?
> I have no clue where to look.
>
--
--
Thanks and Regards,
Sulabh Choudhury
_______________________________________________
Neo4j mailing list
[email protected]
https://lists.neo4j.org/mailman/listinfo/user
