docs: private void checkForOrCreateIndex(Configuration config) {
          Preconditions.checkState(null != client);
  
          //Create index if it does not already exist
          IndicesExistsResponse response = client.admin().indices().exists(new IndicesExistsRequest(indexName)).actionGet();
          if (!response.isExists()) {
  
              ImmutableSettings.Builder settings = ImmutableSettings.settingsBuilder();
  
              ElasticSearchSetup.applySettingsFromTitanConf(settings, config, ES_CREATE_EXTRAS_NS);
  
              CreateIndexResponse create = client.admin().indices().prepareCreate(indexName)
                      .setSettings(settings.build()).execute().actionGet();
              try {
                  final long sleep = config.get(CREATE_SLEEP);
                  log.debug("Sleeping {} ms after {} index creation returned from actionGet()", sleep, indexName);
                  Thread.sleep(sleep);
              } catch (InterruptedException e) {
                  throw new TitanException("Interrupted while waiting for index to settle in", e);
              }
              if (!create.isAcknowledged()) throw new IllegalArgumentException("Could not create index: " + indexName);
          }
      }