Hi all,
I'm attempting to carry out the multiplication of two
DistributedRowMatrix objects. It's similar to a SVD multiplication in
that I have a matrix A and a matrix B, and the operation looks like BAB, or:
B.times(A.times(B))
When I run it, I get a FileAlreadyExistsException from Hadoop, since for
both A and B the result of outputTmpBasePath.getParent() is the same (A
is read from input, and B is calculated from A). Which would be a better
approach:
-Modify DistributedRowMatrix.times() so "productWith" is instead
"productWith" + (System.nanoTime() & 0xFF) .
-Change how the matrices are initialized and avoid the problem from
within the Driver.
I only ask because transpose() employs the first technique, and I don't
know how common (or uncommon) this particular situation is that might
warrant the first change I mentioned.
Thank you!
Regards,
Shannon