package org.apache.flink.streaming.connectors.elasticsearch2;

import org.elasticsearch.action.bulk.BulkProcessor;
import org.elasticsearch.action.ActionRequest;

public class BulkProcessorIndexer implements Elasticsearch2Indexer {
  private final BulkProcessor bulkProcessor;

  public BulkProcessorIndexer(BulkProcessor bulkProcessor) {
    this.bulkProcessor = bulkProcessor;
  }

  @Override
  public void add(ActionRequest... requests) {
    for (ActionRequest request : requests) {
      bulkProcessor.add(request);
    }
  }
}