Hi,
sorry for asking such a simple question but I have troubles when using *
ml.writable.VectorWritable* as OutputValueClass.
The output file is always empty!
$ hama seqdumper -seqFile
> output/hama/rootbeer/examples/matrixmultiplication/CPU-1377026544751/MatrixC.seq
> 13/08/20 21:22:50 INFO util.SequenceFileDumper: DEBUG: Hama
> SequenceFileDumper started!
> 13/08/20 21:22:50 DEBUG util.SequenceFileDumper: DEBUG: Arguments:
> [Ljava.lang.String;@48d6c16c
> Input Path:
> output/hama/rootbeer/examples/matrixmultiplication/CPU-1377026544751/MatrixC.seq
> Key class: class org.apache.hadoop.io.IntWritable Value Class: class
> org.apache.hama.ml.writable.VectorWritable
> Count: 0
>
I had no problems with the mahout VectorWritable before.
Of course I have set the OutputFormat [1] to
job.setOutputFormat(SequenceFileOutputFormat.class);
> job.setOutputKeyClass(IntWritable.class);
> job.setOutputValueClass(VectorWritable.class);
> job.setOutputPath(outPath);
>
The source [2] within the bsp task looks like that
DenseDoubleVector rowValues = new DenseDoubleVector(new
double[]{1,2,3,4,5});
> if (isDebuggingEnabled) {
> logger.writeChars("bsp,write,key=" + rowIndex + ",value="
> + rowValues.toString() + "\n");
> }
> peer.write(new IntWritable(rowIndex), new VectorWritable(rowValues));
>
I hope, someone could help me with this strange behavior!
Thank you very much!
Martin
[1]
https://github.com/millecker/applications/blob/master/hama/rootbeer/matrixmultiplication/src/at/illecker/hama/rootbeer/examples/matrixmultiplication/cpu/MatrixMultiplicationBSPCpu.java#L219-222
[2]
https://github.com/millecker/applications/blob/master/hama/rootbeer/matrixmultiplication/src/at/illecker/hama/rootbeer/examples/matrixmultiplication/cpu/MatrixMultiplicationBSPCpu.java#L166-178
