AccumuloEventStorageBolt extends AccumuloBaseBolt { @Override protected void process(LogRecord record) { Mutation event = getEventMutation(record); try { eventWriter.addMutation(event); } catch (MutationsRejectedException e) { logger.error("Failed to store row. Reseting Writer", e); resetEventWriter(); throw new FailedException(e); } }  @Override void cleanup(); static final String EVENT_TABLE; static final String UUID_PREFIX; static final String UUID_PREFIX_DEFAULT; static final String VISIBILITY; static final String VISIBILITY_BY_FIELD; static final String SPLITS; static final int SPLITS_DEFAULT; }
@Test public void testProcess( @Injectable LogRecord record, @Injectable BatchWriter eventWriter, @Injectable Mutation event) throws Exception { bolt.eventWriter = eventWriter; new Expectations(bolt) {{ bolt.getEventMutation(record); result = event; eventWriter.addMutation(event); }}; bolt.process(record); }