gistfile1.java

//CREATE INDEX is called the beginning of framework startup

private void createIndex(){
		
		System.out.println("ElasticStore : preparing index " + globalIndexName);
		
		boolean exists = getClient().admin().indices().prepareExists(globalIndexName).execute().actionGet().exists();
		if( !exists){
			
			Map<String,Object> settings = new HashMap<String, Object>();
			settings.put(NUMBER_OF_REPLICAS_PROP_KEY, this.numberOfReplicas);
			settings.put(NUMBER_OF_SHARDS_PROP_KEY, this.numberOfShards);
			
			
			System.out.println(" >> Index did not exist , creating it ");
			getClient().admin().indices().prepareCreate(globalIndexName)
					.setSettings(settings)
					.execute().actionGet();
			getClient().admin().cluster().prepareHealth().setWaitForGreenStatus().execute().actionGet();
			System.out.println(" >> index should have been created ");
		}
	}