chore: add stream sorter example to ci

Signed-off-by: Yashash H L <[email protected]>

Author: yhl25

.github/workflows/build-push.yaml

@@ -19,7 +19,7 @@ jobs:
           "batch-map-flatmap", "mapt-event-time-filter-function", "flat-map-stream", "map-flatmap",
           "even-odd", "simple-sink", "reduce-sum", "reduce-stream-sum",
           "map-forward-message", "reduce-counter", "sideinput-example",
-          "udf-sideinput-example", "source-simple-source", "session-reduce-count"
+          "udf-sideinput-example", "source-simple-source", "session-reduce-count", "stream-sorter"
         ]
 
     steps:

examples/pom.xml

@@ -360,7 +360,7 @@
                         </configuration>
                     </execution>
                     <execution>
-                        <id>accumulator-stream-sorter</id>
+                        <id>stream-sorter</id>
                         <phase>package</phase>
                         <goals>
                             <goal>dockerBuild</goal>
@@ -376,7 +376,7 @@
                             </container>
                             <to>
                                 <image>
-                                    numaflow-java-examples/accumulator-stream-sorter:${docker.tag}
+                                    numaflow-java-examples/stream-sorter:${docker.tag}
                                 </image>
                             </to>
                         </configuration>

src/main/java/io/numaproj/numaflow/sourcer/Server.java

@@ -26,7 +26,7 @@ public class Server {
     /**
      * constructor to create gRPC server.
      *
-     * @param sourcer Sourcer interface
+     * @param sourcer {@link Sourcer} interface
      */
     public Server(Sourcer sourcer) {
         this(sourcer, GRPCConfig.defaultGrpcConfig());
@@ -35,8 +35,8 @@ public Server(Sourcer sourcer) {
     /**
      * constructor to create gRPC server with gRPC config.
      *
-     * @param grpcConfig to configure the max message size for grpc
-     * @param sourcer Sourcer interface
+     * @param grpcConfig {@link GRPCConfig} to configure the max message size for grpc
+     * @param sourcer {@link Sourcer} interface
      */
     public Server(Sourcer sourcer, GRPCConfig grpcConfig) {
         this.shutdownSignal = new CompletableFuture<>();