This line always returns "0" because the key ByteBuffer has already been
read from.
startToken
=
partitioner.getTokenFactory().toString(partitioner.getToken(Iterables.getLast(rows).key));
I was able to get it to work by using .mark() and .reset() on the buffer.
I'll log a bug, but confused as to
Hey all,
I'm having an issue using ColumnFamilyInputFormat in an hadoop job. The
mappers spin out of control and just keep reading records over and over,
never getting to the end. I have CF with wide rows (although none is past
about 5 at the columns at the moment), I've tried setting wide rows