NoMessageTuple extends EmptyTuple { public static byte[] getSerializedTuple() { return EmptyTuple.getSerializedTuple(MessageType.NO_MESSAGE_VALUE); } NoMessageTuple(byte[] buffer, int offset, int length); static byte[] getSerializedTuple();  }
@Test public void testSerDe() { logger.info("testSerDe"); byte[] serialized = NoMessageTuple.getSerializedTuple(); Tuple t = Tuple.getTuple(serialized, 0, serialized.length); assert t.getType() == MessageType.NO_MESSAGE; }