@Test public void testSerializeKey() throws IOException, ClassNotFoundException { Integer l = 1; Object d = serialization.deserialize(serialization.serializeKey(l)); Assert.assertEquals(d, l); }
public byte[] serializeKey(Object key) throws IOException { if (key == null) { throw new NullPointerException(); } serializeObject(key, dataInputOutput.reset(), false); return dataInputOutput.toByteArray(); }
StorageSerialization { public byte[] serializeKey(Object key) throws IOException { if (key == null) { throw new NullPointerException(); } serializeObject(key, dataInputOutput.reset(), false); return dataInputOutput.toByteArray(); } }
StorageSerialization { public byte[] serializeKey(Object key) throws IOException { if (key == null) { throw new NullPointerException(); } serializeObject(key, dataInputOutput.reset(), false); return dataInputOutput.toByteArray(); } StorageSerialization(Configuration config); }
StorageSerialization { public byte[] serializeKey(Object key) throws IOException { if (key == null) { throw new NullPointerException(); } serializeObject(key, dataInputOutput.reset(), false); return dataInputOutput.toByteArray(); } StorageSerialization(Configuration config); byte[] serializeKey(Object key); void serializeKey(Object key, DataOutput dataOutput); byte[] serializeValue(Object value); void serializeValue(Object value, DataOutput dataOutput); boolean isCompressionEnabled(); Object deserialize(byte[] buf); Object deserialize(DataInput is); }
StorageSerialization { public byte[] serializeKey(Object key) throws IOException { if (key == null) { throw new NullPointerException(); } serializeObject(key, dataInputOutput.reset(), false); return dataInputOutput.toByteArray(); } StorageSerialization(Configuration config); byte[] serializeKey(Object key); void serializeKey(Object key, DataOutput dataOutput); byte[] serializeValue(Object value); void serializeValue(Object value, DataOutput dataOutput); boolean isCompressionEnabled(); Object deserialize(byte[] buf); Object deserialize(DataInput is);  }