Skip to content

Commit

Permalink
code cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
abh1nay committed Oct 12, 2012
1 parent d919558 commit 5e00c76
Showing 1 changed file with 0 additions and 8 deletions.
Expand Up @@ -47,17 +47,9 @@ public int getPartition(AvroKey<ByteBuffer> key, AvroValue<ByteBuffer> value, in

byte[] keyBytes = null, valueBytes;

if(!key.datum().hasRemaining()) {
// System.out.println("empty key");
return 0;
}
keyBytes = new byte[key.datum().remaining()];
key.datum().get(keyBytes);

if(!value.datum().hasRemaining()) {
// System.out.println("empty value");
return 0;
}
valueBytes = new byte[value.datum().remaining()];
value.datum().get(valueBytes);

Expand Down

0 comments on commit 5e00c76

Please sign in to comment.