code: @Override
    public void init(PlayerConfig config) throws InitializationFailedException {
      super.init(config);
      String bulkSize = config.get(ES_BATCH_SIZE_KEY);
      if (bulkSize != null && !"".equals(bulkSize.trim())) {
        this.bulkSize = Integer.parseInt(bulkSize);
      }
      events = new ArrayList<SimpleDataEvent>();
    }
docs: (non-Javadoc)
  
  @see com.sematext.ag.es.sink.SimpleJSONDataESSink#init(com.sematext.ag.PlayerConfig)