138138 * .get();
139139 * }</pre>
140140 */
141- @ BetaApi
142141public final class Pipeline {
143142 /**
144143 * A Snapshot contains the results of a pipeline execution. It can be used to access the
145144 * documents, execution time, and explain stats.
146145 */
147- @ BetaApi
148146 public static final class Snapshot {
149147
150148 private final Pipeline pipeline ;
@@ -269,7 +267,6 @@ public Pipeline search(Search searchStage) {
269267 * Selectable} expressions.
270268 * @return A new Pipeline object with this stage appended to the stage list.
271269 */
272- @ BetaApi
273270 public Pipeline addFields (Selectable field , Selectable ... additionalFields ) {
274271 return append (
275272 new AddFields (
@@ -503,7 +500,6 @@ public Expression toScalarExpression() {
503500 * @param additionalFields The additional fields to remove.
504501 * @return A new Pipeline object with this stage appended to the stage list.
505502 */
506- @ BetaApi
507503 public Pipeline removeFields (String field , String ... additionalFields ) {
508504 return append (
509505 new RemoveFields (
@@ -528,7 +524,6 @@ public Pipeline removeFields(String field, String... additionalFields) {
528524 * @param additionalFields The additional fields to remove.
529525 * @return A new Pipeline object with this stage appended to the stage list.
530526 */
531- @ BetaApi
532527 public Pipeline removeFields (Field field , Field ... additionalFields ) {
533528 return append (
534529 new RemoveFields (
@@ -568,7 +563,6 @@ public Pipeline removeFields(Field field, Field... additionalFields) {
568563 * @param additionalSelections The additional fields to include in the output documents,
569564 * @return A new Pipeline object with this stage appended to the stage list.
570565 */
571- @ BetaApi
572566 public Pipeline select (Selectable selection , Selectable ... additionalSelections ) {
573567 return append (
574568 new Select (
@@ -602,7 +596,6 @@ public Pipeline select(Selectable selection, Selectable... additionalSelections)
602596 * @param additionalFields The additional fields to include in the output documents.
603597 * @return A new Pipeline object with this stage appended to the stage list.
604598 */
605- @ BetaApi
606599 public Pipeline select (String field , String ... additionalFields ) {
607600 return append (
608601 new Select (
@@ -646,7 +639,6 @@ public Pipeline select(String field, String... additionalFields) {
646639 * @param condition The {@link BooleanExpression} to apply.
647640 * @return A new Pipeline object with this stage appended to the stage list.
648641 */
649- @ BetaApi
650642 public Pipeline where (BooleanExpression condition ) {
651643 return append (new Where (condition ));
652644 }
@@ -671,7 +663,6 @@ public Pipeline where(BooleanExpression condition) {
671663 * @param offset The number of documents to skip.
672664 * @return A new Pipeline object with this stage appended to the stage list.
673665 */
674- @ BetaApi
675666 public Pipeline offset (int offset ) {
676667 return append (new Offset (offset ));
677668 }
@@ -701,7 +692,6 @@ public Pipeline offset(int offset) {
701692 * @param limit The maximum number of documents to return.
702693 * @return A new Pipeline object with this stage appended to the stage list.
703694 */
704- @ BetaApi
705695 public Pipeline limit (int limit ) {
706696 return append (new Limit (limit ));
707697 }
@@ -727,7 +717,6 @@ public Pipeline limit(int limit) {
727717 * AggregateFunction} and provide a name for the accumulated results.
728718 * @return A new Pipeline object with this stage appended to the stage list.
729719 */
730- @ BetaApi
731720 public Pipeline aggregate (AliasedAggregate ... accumulators ) {
732721 return append (Aggregate .withAccumulators (accumulators ));
733722 }
@@ -765,12 +754,10 @@ public Pipeline aggregate(AliasedAggregate... accumulators) {
765754 * the aggregation operations to perform.
766755 * @return A new {@code Pipeline} object with this stage appended to the stage list.
767756 */
768- @ BetaApi
769757 public Pipeline aggregate (Aggregate aggregate ) {
770758 return append (aggregate );
771759 }
772760
773- @ BetaApi
774761 public Pipeline aggregate (Aggregate aggregate , AggregateOptions options ) {
775762 return append (aggregate .withOptions (options ));
776763 }
@@ -792,7 +779,6 @@ public Pipeline aggregate(Aggregate aggregate, AggregateOptions options) {
792779 * @param fields The fields to consider when determining distinct values.
793780 * @return A new {@code Pipeline} object with this stage appended to the stage list.
794781 */
795- @ BetaApi
796782 public Pipeline distinct (String ... fields ) {
797783 return append (new Distinct (PipelineUtils .fieldNamesToMap (fields )));
798784 }
@@ -824,7 +810,6 @@ public Pipeline distinct(String... fields) {
824810 * value combinations.
825811 * @return A new {@code Pipeline} object with this stage appended to the stage list.
826812 */
827- @ BetaApi
828813 public Pipeline distinct (Selectable ... selectables ) {
829814 return append (new Distinct (PipelineUtils .selectablesToMap (selectables )));
830815 }
@@ -855,7 +840,6 @@ public Pipeline distinct(Selectable... selectables) {
855840 * distance field name.
856841 * @return A new {@code Pipeline} object with this stage appended to the stage list.
857842 */
858- @ BetaApi
859843 public Pipeline findNearest (
860844 String fieldName ,
861845 double [] vector ,
@@ -893,7 +877,6 @@ public Pipeline findNearest(
893877 * distance field name.
894878 * @return A new {@code Pipeline} object with this stage appended to the stage list.
895879 */
896- @ BetaApi
897880 public Pipeline findNearest (
898881 Expression property ,
899882 double [] vector ,
@@ -926,7 +909,6 @@ public Pipeline findNearest(
926909 * @param orders One or more {@link Ordering} instances specifying the sorting criteria.
927910 * @return A new {@code Pipeline} object with this stage appended to the stage list.
928911 */
929- @ BetaApi
930912 public Pipeline sort (Ordering ... orders ) {
931913 return append (new Sort (ImmutableList .copyOf (orders )));
932914 }
@@ -962,7 +944,6 @@ public Pipeline sort(Ordering... orders) {
962944 * @param fieldName The name of the field containing the nested map.
963945 * @return A new {@code Pipeline} object with this stage appended to the stage list.
964946 */
965- @ BetaApi
966947 public Pipeline replaceWith (String fieldName ) {
967948 return replaceWith (field (fieldName ));
968949 }
@@ -998,7 +979,6 @@ public Pipeline replaceWith(String fieldName) {
998979 * @param expr The {@link Expression} field containing the nested map.
999980 * @return A new {@code Pipeline} object with this stage appended to the stage list.
1000981 */
1001- @ BetaApi
1002982 public Pipeline replaceWith (Expression expr ) {
1003983 return append (new ReplaceWith (expr ));
1004984 }
@@ -1021,7 +1001,6 @@ public Pipeline replaceWith(Expression expr) {
10211001 * @param limit The number of documents to emit, if possible.
10221002 * @return A new {@code Pipeline} object with this stage appended to the stage list.
10231003 */
1024- @ BetaApi
10251004 public Pipeline sample (int limit ) {
10261005 return sample (Sample .withDocLimit (limit ));
10271006 }
@@ -1047,7 +1026,6 @@ public Pipeline sample(int limit) {
10471026 * @param sample The {@code Sample} specifies how sampling is performed.
10481027 * @return A new {@code Pipeline} object with this stage appended to the stage list.
10491028 */
1050- @ BetaApi
10511029 public Pipeline sample (Sample sample ) {
10521030 return append (sample );
10531031 }
@@ -1110,7 +1088,6 @@ public Pipeline union(Pipeline other) {
11101088 * @param fieldName The name of the field containing the array.
11111089 * @return A new {@code Pipeline} object with this stage appended to the stage list.
11121090 */
1113- @ BetaApi
11141091 public Pipeline unnest (String fieldName , String alias ) {
11151092 // return unnest(field(fieldName));
11161093 return append (new Unnest (field (fieldName ), alias ));
@@ -1148,7 +1125,6 @@ public Pipeline unnest(String fieldName, String alias) {
11481125 * @param options The {@code UnnestOptions} options.
11491126 * @return A new {@code Pipeline} object with this stage appended to the stage list.
11501127 */
1151- @ BetaApi
11521128 public Pipeline unnest (String fieldName , String alias , UnnestOptions options ) {
11531129 return append (new Unnest (field (fieldName ), alias , options ));
11541130 }
@@ -1184,7 +1160,6 @@ public Pipeline unnest(String fieldName, String alias, UnnestOptions options) {
11841160 * @param expr The name of the expression containing the array.
11851161 * @return A new {@code Pipeline} object with this stage appended to the stage list.
11861162 */
1187- @ BetaApi
11881163 public Pipeline unnest (Selectable expr ) {
11891164 return append (new Unnest (expr ));
11901165 }
@@ -1221,7 +1196,6 @@ public Pipeline unnest(Selectable expr) {
12211196 * @param options The {@code UnnestOptions} options.
12221197 * @return A new {@code Pipeline} object with this stage appended to the stage list.
12231198 */
1224- @ BetaApi
12251199 public Pipeline unnest (Selectable field , UnnestOptions options ) {
12261200 return append (new Unnest (field , options ));
12271201 }
@@ -1359,7 +1333,6 @@ public Pipeline update(Update update) {
13591333 *
13601334 * @return A new {@code Pipeline} object with this stage appended to the stage list.
13611335 */
1362- @ BetaApi
13631336 public Pipeline rawStage (RawStage stage ) {
13641337 return append (stage );
13651338 }
@@ -1395,12 +1368,10 @@ public Pipeline rawStage(RawStage stage) {
13951368 *
13961369 * @return An {@link ApiFuture} representing the asynchronous pipeline execution.
13971370 */
1398- @ BetaApi
13991371 public ApiFuture <Snapshot > execute () {
14001372 return execute (new PipelineExecuteOptions (), null , null );
14011373 }
14021374
1403- @ BetaApi
14041375 public ApiFuture <Snapshot > execute (PipelineExecuteOptions options ) {
14051376 return execute (options , null , null );
14061377 }
@@ -1454,7 +1425,6 @@ MetricsContext createMetricsContext(String methodName) {
14541425 *
14551426 * @param observer The {@link ApiStreamObserver} to receive pipeline results and events.
14561427 */
1457- @ BetaApi
14581428 public void execute (ApiStreamObserver <PipelineResult > observer ) {
14591429 if (this .rpcContext == null ) {
14601430 throw new IllegalStateException (
0 commit comments