@Test public void testPutEvent() { FlumeEvent event = new FlumeEvent(null, new byte[5]); Put put = new Put(1L, 1L, event); Event returnEvent = EventUtils.getEventFromTransactionEvent(put); Assert.assertNotNull(returnEvent); Assert.assertEquals(5, returnEvent.getBody().length); }
public static Event getEventFromTransactionEvent(TransactionEventRecord transactionEventRecord) { if (transactionEventRecord instanceof Put) { return ((Put)transactionEventRecord).getEvent(); } return null; }
EventUtils { public static Event getEventFromTransactionEvent(TransactionEventRecord transactionEventRecord) { if (transactionEventRecord instanceof Put) { return ((Put)transactionEventRecord).getEvent(); } return null; } }
EventUtils { public static Event getEventFromTransactionEvent(TransactionEventRecord transactionEventRecord) { if (transactionEventRecord instanceof Put) { return ((Put)transactionEventRecord).getEvent(); } return null; }  }
EventUtils { public static Event getEventFromTransactionEvent(TransactionEventRecord transactionEventRecord) { if (transactionEventRecord instanceof Put) { return ((Put)transactionEventRecord).getEvent(); } return null; }  static Event getEventFromTransactionEvent(TransactionEventRecord transactionEventRecord); }
EventUtils { public static Event getEventFromTransactionEvent(TransactionEventRecord transactionEventRecord) { if (transactionEventRecord instanceof Put) { return ((Put)transactionEventRecord).getEvent(); } return null; }  static Event getEventFromTransactionEvent(TransactionEventRecord transactionEventRecord);  }