public void initAccumuloIndexTable()

in webindex/modules/data/src/main/java/webindex/data/spark/IndexEnv.java [183:202]

• 19 lines of code
• 5 McCabe index (conditional complexity)

  public void initAccumuloIndexTable() {
    if (conn.tableOperations().exists(accumuloTable)) {
      try {
        conn.tableOperations().delete(accumuloTable);
      } catch (TableNotFoundException | AccumuloSecurityException | AccumuloException e) {
        throw new IllegalStateException("Failed to delete Accumulo table " + accumuloTable, e);
      }
    }
    try {
      conn.tableOperations().create(accumuloTable);
    } catch (AccumuloException | AccumuloSecurityException | TableExistsException e) {
      throw new IllegalStateException("Failed to create Accumulo table " + accumuloTable, e);
    }

    try {
      conn.tableOperations().addSplits(accumuloTable, IndexEnv.getAccumuloDefaultSplits());
    } catch (AccumuloException | AccumuloSecurityException | TableNotFoundException e) {
      throw new IllegalStateException("Failed to add splits to Accumulo table " + accumuloTable, e);
    }
  }