code: public static ElasticSearch getElasticSearchSink(String elasticSearch){
  		init();
  		if(elasticSearch == null || elasticSearch.equals("")) {
  
  			return elasticSearchSink;
  		}
  		ElasticSearch elasticSearchSink = elasticSearchMap.get(elasticSearch);
  		if(elasticSearchSink == null) {
  			synchronized (elasticSearchMap) {
  				elasticSearchSink = elasticSearchMap.get(elasticSearch);
  				if(elasticSearchSink != null)
  					return elasticSearchSink;
  				context = DefaultApplicationContext.getApplicationContext("conf/elasticsearch.xml");
  				elasticSearchSink = context.getTBeanObject(elasticSearch, ElasticSearch.class);
  				if (elasticSearchSink != null) {
  					elasticSearchMap.put(elasticSearch, elasticSearchSink);
  				}
  			}
  		}
  		return elasticSearchSink;
  	}
docs: 获取elasticSearch对应的elasticSearch服务器对象
  @param elasticSearch
  @return