Skip to content

Commit b68927f

Browse files
authored
Revert "Update transform catalogue docs (#38457)"
This reverts commit 0c9b272.
1 parent 0302bf5 commit b68927f

5 files changed

Lines changed: 1 addition & 122 deletions

File tree

examples/java/src/main/java/org/apache/beam/examples/BatchElementsExample.java

Lines changed: 0 additions & 81 deletions
This file was deleted.

sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/BatchElements.java

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,6 @@
1717
*/
1818
package org.apache.beam.sdk.transforms;
1919

20-
import static java.util.Collections.singleton;
21-
2220
import java.io.Serializable;
2321
import java.util.ArrayList;
2422
import java.util.Comparator;
@@ -29,7 +27,6 @@
2927
import javax.annotation.Nullable;
3028
import org.apache.beam.sdk.transforms.windowing.BoundedWindow;
3129
import org.apache.beam.sdk.transforms.windowing.GlobalWindow;
32-
import org.apache.beam.sdk.transforms.windowing.PaneInfo;
3330
import org.apache.beam.sdk.values.PCollection;
3431
import org.apache.beam.sdk.values.WindowingStrategy;
3532

@@ -571,11 +568,7 @@ public void processElement(
571568

572569
try (BatchSizeEstimator.Stopwatch sw = estimator.recordTime(targetBatch.size)) {
573570

574-
receiver.outputWindowedValue(
575-
targetBatch.elements,
576-
targetWindow.maxTimestamp(),
577-
singleton(targetWindow),
578-
PaneInfo.NO_FIRING);
571+
receiver.outputWithTimestamp(targetBatch.elements, targetWindow.maxTimestamp());
579572
}
580573

581574
batches.remove(targetWindow);

website/www/site/content/en/documentation/transforms/java/aggregation/batchelements.md

Lines changed: 0 additions & 31 deletions
This file was deleted.

website/www/site/content/en/documentation/transforms/java/overview.md

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,6 @@ limitations under the License.
5555
<tr><td><a href="/documentation/transforms/java/aggregation/groupbykey">GroupByKey</a></td><td>Takes a keyed collection of elements and produces a collection where each element
5656
consists of a key and all values associated with that key.</td></tr>
5757
<tr><td><a href="/documentation/transforms/java/aggregation/groupintobatches">GroupIntoBatches</a></td><td>Batches values associated with keys into <code>Iterable</code> batches of some size. Each batch contains elements associated with a specific key.</td></tr>
58-
<tr><td><a href="/documentation/transforms/java/aggregation/batchelements">BatchElements</a></td><td>Groups individual elements into batches to amortize fixed processing costs, using dynamically estimated batch sizes.</td></tr>
5958
<tr><td><a href="/documentation/transforms/java/aggregation/hllcount">HllCount</a></td><td>Estimates the number of distinct elements and creates re-aggregatable sketches using the HyperLogLog++ algorithm.</td></tr>
6059
<tr><td><a href="/documentation/transforms/java/aggregation/latest">Latest</a></td><td>Selects the latest element within each aggregation according to the implicit timestamp.</td></tr>
6160
<tr><td><a href="/documentation/transforms/java/aggregation/max">Max</a></td><td>Outputs the maximum element within each aggregation.</td></tr>

website/www/site/layouts/partials/section-menu/en/documentation.html

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -404,7 +404,6 @@
404404
<li><a href="/documentation/transforms/java/aggregation/distinct/">Distinct</a></li>
405405
<li><a href="/documentation/transforms/java/aggregation/groupbykey/">GroupByKey</a></li>
406406
<li><a href="/documentation/transforms/java/aggregation/groupintobatches/">GroupIntoBatches</a></li>
407-
<li><a href="/documentation/transforms/java/aggregation/batchelements/">BatchElements</a></li>
408407
<li><a href="/documentation/transforms/java/aggregation/hllcount/">HllCount</a></li>
409408
<li><a href="/documentation/transforms/java/aggregation/latest/">Latest</a></li>
410409
<li><a href="/documentation/transforms/java/aggregation/max/">Max</a></li>

0 commit comments

Comments
 (0)