final DataMap dataMap = runtime.getDataDomain().getDataMap("qualified");
// clear out the table
ObjectContext context = runtime.newContext();
List<Qualified1> qualified1s = context.select(SelectQuery.query(Qualified1.class, null));
context.deleteObjects(qualified1s);
context.commitChanges();
// perform concurrent inserts
int numThreads = 2;
ExecutorService executor = Executors.newFixedThreadPool(numThreads);