Bulk UDP: Removal.

This feature is rarely used. Removing it will help reduce the moving parts of Elasticsearch and focus on the core. Close #7595
elastic · Sep 11, 2014 · ccb3d21 · ccb3d21
1 parent 8bafb5f
commit ccb3d21
Show file tree

Hide file tree

Showing 5 changed files with 0 additions and 320 deletions.
diff --git a/docs/reference/docs.asciidoc b/docs/reference/docs.asciidoc
@@ -15,7 +15,6 @@ This section describes the following CRUD APIs:
 .Multi-document APIs
 * <<docs-multi-get>>
 * <<docs-bulk>>
-* <<docs-bulk-udp>>
 * <<docs-delete-by-query>>
 
 NOTE: All CRUD APIs are single-index APIs. The `index` parameter accepts a single
@@ -37,8 +36,6 @@ include::docs/bulk.asciidoc[]
 
 include::docs/delete-by-query.asciidoc[]
 
-include::docs/bulk-udp.asciidoc[]
-
 include::docs/termvectors.asciidoc[]
 
 include::docs/multi-termvectors.asciidoc[]
diff --git a/docs/reference/docs/bulk-udp.asciidoc b/docs/reference/docs/bulk-udp.asciidoc
diff --git a/src/main/java/org/elasticsearch/bulk/udp/BulkUdpModule.java b/src/main/java/org/elasticsearch/bulk/udp/BulkUdpModule.java
diff --git a/src/main/java/org/elasticsearch/bulk/udp/BulkUdpService.java b/src/main/java/org/elasticsearch/bulk/udp/BulkUdpService.java
diff --git a/src/main/java/org/elasticsearch/node/internal/InternalNode.java b/src/main/java/org/elasticsearch/node/internal/InternalNode.java
@@ -24,8 +24,6 @@
 import org.elasticsearch.Version;
 import org.elasticsearch.action.ActionModule;
 import org.elasticsearch.action.bench.BenchmarkModule;
-import org.elasticsearch.bulk.udp.BulkUdpModule;
-import org.elasticsearch.bulk.udp.BulkUdpService;
 import org.elasticsearch.cache.recycler.PageCacheRecycler;
 import org.elasticsearch.cache.recycler.PageCacheRecyclerModule;
 import org.elasticsearch.client.Client;
@@ -183,7 +181,6 @@ public InternalNode(Settings preparedSettings, boolean loadConfigSettings) throw
             modules.add(new MonitorModule(settings));
             modules.add(new GatewayModule(settings));
             modules.add(new NodeClientModule());
-            modules.add(new BulkUdpModule());
             modules.add(new ShapeModule());
             modules.add(new PercolatorModule());
             modules.add(new ResourceWatcherModule());
@@ -251,7 +248,6 @@ public Node start() {
         if (settings.getAsBoolean("http.enabled", true)) {
             injector.getInstance(HttpServer.class).start();
         }
-        injector.getInstance(BulkUdpService.class).start();
         injector.getInstance(ResourceWatcherService.class).start();
         injector.getInstance(TribeService.class).start();
 
@@ -269,7 +265,6 @@ public Node stop() {
         logger.info("stopping ...");
 
         injector.getInstance(TribeService.class).stop();
-        injector.getInstance(BulkUdpService.class).stop();
         injector.getInstance(ResourceWatcherService.class).stop();
         if (settings.getAsBoolean("http.enabled", true)) {
             injector.getInstance(HttpServer.class).stop();
@@ -323,8 +318,6 @@ public void close() {
         StopWatch stopWatch = new StopWatch("node_close");
         stopWatch.start("tribe");
         injector.getInstance(TribeService.class).close();
-        stopWatch.stop().start("bulk.udp");
-        injector.getInstance(BulkUdpService.class).close();
         stopWatch.stop().start("http");
         if (settings.getAsBoolean("http.enabled", true)) {
             injector.getInstance(HttpServer.class).close();