Revert "[8.19] Backport ES|QL sample processing command (#129617)" (#129797)

* Revert "[8.19] Backport ES|QL sample processing command (#129617)"

This reverts commit 1d05947.

Author: nik9000

docs/changelog/125570.yaml

@@ -0,0 +1,5 @@
+pr: 129797
+summary: "Revert \"[8.19] Backport ES|QL sample processing command\""
+area: ES|QL
+type: bug
+issues: []

docs/changelog/129797.yaml

@@ -46,7 +46,6 @@ endif::[]
 * experimental:[] <<esql-lookup-join>>
 * experimental:[] <<esql-mv_expand>>
 * <<esql-rename>>
-* experimental:[] <<esql-sample>>
 * <<esql-sort>>
 * <<esql-stats-by>>
 * <<esql-where>>
@@ -71,7 +70,6 @@ include::processing-commands/limit.asciidoc[]
 include::processing-commands/lookup.asciidoc[]
 include::processing-commands/mv_expand.asciidoc[]
 include::processing-commands/rename.asciidoc[]
-include::processing-commands/sample.asciidoc[]
 include::processing-commands/sort.asciidoc[]
 include::processing-commands/stats.asciidoc[]
 include::processing-commands/where.asciidoc[]

docs/reference/esql/esql-commands.asciidoc

@@ -249,8 +249,7 @@ GET /_xpack/usage
       "lookup_join" : 0,
       "change_point" : 0,
       "completion": 0,
-      "rerank": 0,
-      "sample": 0
+      "rerank": 0
     },
     "queries" : {
       "rest" : {

docs/reference/esql/functions/description/date_trunc.asciidoc

@@ -244,7 +244,6 @@ static TransportVersion def(int id) {
     public static final TransportVersion SETTINGS_IN_DATA_STREAMS_8_19 = def(8_841_0_51);
     public static final TransportVersion ML_INFERENCE_CUSTOM_SERVICE_REMOVE_ERROR_PARSING_8_19 = def(8_841_0_52);
     public static final TransportVersion ML_INFERENCE_CUSTOM_SERVICE_EMBEDDING_BATCH_SIZE_8_19 = def(8_841_0_53);
-    public static final TransportVersion RANDOM_SAMPLER_QUERY_BUILDER_8_19 = def(8_841_0_54);
 
     /*
      * STOP! READ THIS FIRST! No, really,

docs/reference/esql/functions/kibana/docs/date_trunc.md

@@ -137,7 +137,6 @@
 import org.elasticsearch.search.aggregations.bucket.sampler.UnmappedSampler;
 import org.elasticsearch.search.aggregations.bucket.sampler.random.InternalRandomSampler;
 import org.elasticsearch.search.aggregations.bucket.sampler.random.RandomSamplerAggregationBuilder;
-import org.elasticsearch.search.aggregations.bucket.sampler.random.RandomSamplingQueryBuilder;
 import org.elasticsearch.search.aggregations.bucket.terms.DoubleTerms;
 import org.elasticsearch.search.aggregations.bucket.terms.LongRareTerms;
 import org.elasticsearch.search.aggregations.bucket.terms.LongTerms;
@@ -1210,9 +1209,6 @@ private void registerQueryParsers(List<SearchPlugin> plugins) {
         registerQuery(new QuerySpec<>(ExactKnnQueryBuilder.NAME, ExactKnnQueryBuilder::new, parser -> {
             throw new IllegalArgumentException("[exact_knn] queries cannot be provided directly");
         }));
-        registerQuery(
-            new QuerySpec<>(RandomSamplingQueryBuilder.NAME, RandomSamplingQueryBuilder::new, RandomSamplingQueryBuilder::fromXContent)
-        );
 
         registerFromPlugin(plugins, SearchPlugin::getQueries, this::registerQuery);
 

docs/reference/esql/functions/kibana/docs/sample.md

@@ -43,34 +43,14 @@ public final class RandomSamplingQuery extends Query {
      *                  can be generated
      */
     public RandomSamplingQuery(double p, int seed, int hash) {
-        checkProbabilityRange(p);
+        if (p <= 0.0 || p >= 1.0) {
+            throw new IllegalArgumentException("RandomSampling probability must be between 0.0 and 1.0, was [" + p + "]");
+        }
         this.p = p;
         this.seed = seed;
         this.hash = hash;
     }
 
-    /**
-     * Verifies that the probability is within the (0.0, 1.0) range.
-     * @throws IllegalArgumentException in case of an invalid probability.
-     */
-    public static void checkProbabilityRange(double p) throws IllegalArgumentException {
-        if (p <= 0.0 || p >= 1.0) {
-            throw new IllegalArgumentException("RandomSampling probability must be strictly between 0.0 and 1.0, was [" + p + "]");
-        }
-    }
-
-    public double probability() {
-        return p;
-    }
-
-    public int seed() {
-        return seed;
-    }
-
-    public int hash() {
-        return hash;
-    }
-
     @Override
     public String toString(String field) {
         return "RandomSamplingQuery{" + "p=" + p + ", seed=" + seed + ", hash=" + hash + '}';
@@ -117,13 +97,13 @@ public void visit(QueryVisitor visitor) {
     /**
      * A DocIDSetIter that skips a geometrically random number of documents
      */
-    public static class RandomSamplingIterator extends DocIdSetIterator {
+    static class RandomSamplingIterator extends DocIdSetIterator {
         private final int maxDoc;
         private final double p;
         private final FastGeometric distribution;
         private int doc = -1;
 
-        public RandomSamplingIterator(int maxDoc, double p, IntSupplier rng) {
+        RandomSamplingIterator(int maxDoc, double p, IntSupplier rng) {
             this.maxDoc = maxDoc;
             this.p = p;
             this.distribution = new FastGeometric(rng, p);

docs/reference/esql/functions/types/to_ip.asciidoc

@@ -449,7 +449,6 @@ public CheckedBiConsumer<ShardSearchRequest, StreamOutput, IOException> getReque
         "range",
         "regexp",
         "knn_score_doc",
-        "random_sampling",
         "script",
         "script_score",
         "simple_query_string",