in modules/accumulo/src/main/java/org/apache/fluo/recipes/accumulo/export/function/AccumuloWriter.java [111:125]
private AccumuloWriter(String instanceName, String zookeepers, String user, String password,
String table) {
// TODO: fix this write to static and remove findbugs max rank override in pom.xml
exportQueue = new LinkedBlockingQueue<>(10000);
try {
Thread queueProcessingTask =
new Thread(new ExportTask(instanceName, zookeepers, user, password, table));
queueProcessingTask.setDaemon(true);
queueProcessingTask.start();
} catch (Exception e) {
throw new IllegalStateException(e);
}
}