Touch trigger files to test WindowedValueReceiver in runners

Author: kennknowles

.github/trigger_files/beam_PostCommit_Java_DataflowV1.json

@@ -1,4 +1,5 @@
 {
+  "https://github.com/apache/beam/pull/35177": "Introducing WindowedValueReceiver to runners",
     "comment": "Modify this file in a trivial way to cause this test suite to run",
     "modification": 1,
   "https://github.com/apache/beam/pull/35159": "moving WindowedValue and making an interface"

.github/trigger_files/beam_PostCommit_Java_DataflowV2.json

@@ -1,4 +1,5 @@
 {
+  "https://github.com/apache/beam/pull/35177": "Introducing WindowedValueReceiver to runners",
     "comment": "Modify this file in a trivial way to cause this test suite to run",
     "modification": 3,
   "https://github.com/apache/beam/pull/35159": "moving WindowedValue and making an interface"

.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Direct.json

@@ -1,4 +1,5 @@
 {
+  "https://github.com/apache/beam/pull/35177": "Introducing WindowedValueReceiver to runners",
   "comment": "Modify this file in a trivial way to cause this test suite to run",
   "https://github.com/apache/beam/pull/31761": "noting that PR #31761 should run this test",
   "https://github.com/apache/beam/pull/35159": "moving WindowedValue and making an interface"

.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Flink.json

@@ -1,4 +1,5 @@
 {
+  "https://github.com/apache/beam/pull/35177": "Introducing WindowedValueReceiver to runners",
   "comment": "Modify this file in a trivial way to cause this test suite to run",
   "https://github.com/apache/beam/pull/32440": "testing datastream optimizations",
   "runFor": "#33606",

.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Samza.json

@@ -1,4 +1,5 @@
 {
+  "https://github.com/apache/beam/pull/35177": "Introducing WindowedValueReceiver to runners",
   "comment": "Modify this file in a trivial way to cause this test suite to run",
   "https://github.com/apache/beam/pull/31156": "noting that PR #31156 should run this test",
   "https://github.com/apache/beam/pull/31270": "re-add specialized Samza translation of Redistribute",

.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_Spark.json

@@ -1,4 +1,5 @@
 {
+  "https://github.com/apache/beam/pull/35177": "Introducing WindowedValueReceiver to runners",
   "comment": "Modify this file in a trivial way to cause this test suite to run",
   "https://github.com/apache/beam/pull/31156": "noting that PR #31156 should run this test",
   "https://github.com/apache/beam/pull/31798": "noting that PR #31798 should run this test",

.github/trigger_files/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming.json

@@ -1,4 +1,5 @@
 {
+  "https://github.com/apache/beam/pull/35177": "Introducing WindowedValueReceiver to runners",
   "comment": "Modify this file in a trivial way to cause this test suite to run",
   "https://github.com/apache/beam/pull/31156": "noting that PR #31156 should run this test",
   "https://github.com/apache/beam/pull/31798": "noting that PR #31798 should run this test",

runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/io/BoundedDatasetFactory.java

@@ -37,7 +37,6 @@
 import org.apache.beam.sdk.io.BoundedSource.BoundedReader;
 import org.apache.beam.sdk.options.PipelineOptions;
 import org.apache.beam.sdk.values.WindowedValue;
-import org.apache.beam.sdk.values.WindowedValues;
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.AbstractIterator;
 import org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.ImmutableSet;
 import org.apache.spark.InterruptibleIterator;
@@ -110,7 +109,7 @@ private static class BoundedRDD<T> extends RDD<WindowedValue<T>> {
     final Params<T> params;
 
     public BoundedRDD(SparkContext sc, BoundedSource<T> source, Params<T> params) {
-      super(sc, emptyList(), ClassTag.apply(WindowedValues.class));
+      super(sc, emptyList(), ClassTag.apply(WindowedValue.class));
       this.source = source;
       this.params = params;
     }

runners/spark/3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers/EncoderHelpers.java

@@ -94,7 +94,7 @@
 public class EncoderHelpers {
   private static final DataType OBJECT_TYPE = new ObjectType(Object.class);
   private static final DataType TUPLE2_TYPE = new ObjectType(Tuple2.class);
-  private static final DataType WINDOWED_VALUE = new ObjectType(WindowedValues.class);
+  private static final DataType WINDOWED_VALUE = new ObjectType(WindowedValue.class);
   private static final DataType KV_TYPE = new ObjectType(KV.class);
   private static final DataType MUTABLE_PAIR_TYPE = new ObjectType(MutablePair.class);
   private static final DataType LIST_TYPE = new ObjectType(List.class);

runners/spark/src/main/java/org/apache/beam/runners/spark/coders/SparkRunnerKryoRegistrator.java

@@ -65,7 +65,7 @@ public void registerClasses(Kryo kryo) {
 
     try {
       kryo.register(
-          Class.forName("org.apache.beam.sdk.values.WindowedValue$TimestampedValueInGlobalWindow"));
+          Class.forName("org.apache.beam.sdk.values.WindowedValues$TimestampedValueInGlobalWindow"));
       kryo.register(
           Class.forName(
               "org.apache.beam.vendor.guava.v32_1_2_jre.com.google.common.collect.HashBasedTable$Factory"));