Major Description
At the SortedKeyValueFile.java 539 lines like next:
mPreviousKey = key;
This class is same as Hadoop's MapFile, at the MapFile the same methon will keep a copy for this key, but not use "=".
If use "=" at here, when user append a reuse key object to this file. will cause key sorted not valid.
I think next code will fix it:
private DataInputBuffer inBuf = new DataInputBuffer();
private DataOutputBuffer outBuf = new DataOutputBuffer();
GenericDatumWriter<K> writer = new ReflectDatumWriter<K>(schema);
GenericDatumReader<K> reader = new ReflectDatumReader<K>(schema);
writer.write(key, encoder);
inBuf.reset(outBuf.getData(), outBuf.getLength());
BinaryDecoder decoder = DecoderFactory.get().directBinaryDecoder(inBuf,
null);
lastKey = reader.read(null, decoder);