AccumuloEventStorageBolt extends AccumuloBaseBolt { @Override void configureAccumuloBolt(Configuration conf) { eventTable = conf.getString(EVENT_TABLE); uuidPrefix = conf.getString(UUID_PREFIX, UUID_PREFIX_DEFAULT); splits = conf.getInt(SPLITS, SPLITS_DEFAULT); visibility = conf.getString(VISIBILITY); visibilityByField = conf.getString(VISIBILITY_BY_FIELD); Validate.notBlank(eventTable); }  @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 testConfigureAccumuloBolt(@Injectable Configuration conf) { new Expectations() {{ conf.getString(EVENT_TABLE); result = "eventTable"; conf.getString(UUID_PREFIX, UUID_PREFIX_DEFAULT); result = UUID_PREFIX_DEFAULT; conf.getInt(SPLITS, SPLITS_DEFAULT); result = SPLITS_DEFAULT; conf.getString(VISIBILITY); result = ""; conf.getString(VISIBILITY_BY_FIELD); result = ""; }}; bolt.configureAccumuloBolt(conf); }