[flink] branch master updated: [hotfix] [connectors] Remove unused BulkProcessorIndexer class

[tw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new d4129c5  [hotfix] [connectors] Remove unused BulkProcessorIndexer class
d4129c5 is described below

commit d4129c574d7f30fd5dec9e7745300a16e76fb0f9
Author: Timo Walther <tw...@apache.org>
AuthorDate: Mon Oct 1 11:02:05 2018 +0200

    [hotfix] [connectors] Remove unused BulkProcessorIndexer class
---
 .../elasticsearch/BulkProcessorIndexer.java        | 79 ----------------------
 1 file changed, 79 deletions(-)

diff --git a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BulkProcessorIndexer.java b/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BulkProcessorIndexer.java
deleted file mode 100644
index 33b42cb..0000000
--- a/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BulkProcessorIndexer.java
+++ /dev/null
@@ -1,79 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *    http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.flink.streaming.connectors.elasticsearch;
-
-import org.apache.flink.annotation.Internal;
-
-import org.elasticsearch.action.ActionRequest;
-import org.elasticsearch.action.bulk.BulkProcessor;
-import org.elasticsearch.action.delete.DeleteRequest;
-import org.elasticsearch.action.index.IndexRequest;
-import org.elasticsearch.action.update.UpdateRequest;
-
-import java.util.concurrent.atomic.AtomicLong;
-
-import static org.apache.flink.util.Preconditions.checkNotNull;
-
-/**
- * Implementation of a {@link RequestIndexer}, using a {@link BulkProcessor}.
- * {@link ActionRequest ActionRequests} will be buffered before sending a bulk request to the Elasticsearch cluster.
- */
-@Internal
-class BulkProcessorIndexer implements RequestIndexer {
-
-	private final BulkProcessor bulkProcessor;
-	private final boolean flushOnCheckpoint;
-	private final AtomicLong numPendingRequestsRef;
-
-	BulkProcessorIndexer(BulkProcessor bulkProcessor, boolean flushOnCheckpoint, AtomicLong numPendingRequestsRef) {
-		this.bulkProcessor = checkNotNull(bulkProcessor);
-		this.flushOnCheckpoint = flushOnCheckpoint;
-		this.numPendingRequestsRef = checkNotNull(numPendingRequestsRef);
-	}
-
-	@Override
-	public void add(DeleteRequest... deleteRequests) {
-		for (DeleteRequest deleteRequest : deleteRequests) {
-			if (flushOnCheckpoint) {
-				numPendingRequestsRef.getAndIncrement();
-			}
-			this.bulkProcessor.add(deleteRequest);
-		}
-	}
-
-	@Override
-	public void add(IndexRequest... indexRequests) {
-		for (IndexRequest indexRequest : indexRequests) {
-			if (flushOnCheckpoint) {
-				numPendingRequestsRef.getAndIncrement();
-			}
-			this.bulkProcessor.add(indexRequest);
-		}
-	}
-
-	@Override
-	public void add(UpdateRequest... updateRequests) {
-		for (UpdateRequest updateRequest : updateRequests) {
-			if (flushOnCheckpoint) {
-				numPendingRequestsRef.getAndIncrement();
-			}
-			this.bulkProcessor.add(updateRequest);
-		}
-	}
-}