[beam] branch spark-runner_structured-streaming updated: Rename SparkOutputManager for consistency

[echauchot]

This is an automated email from the ASF dual-hosted git repository.

echauchot pushed a commit to branch spark-runner_structured-streaming
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to 
refs/heads/spark-runner_structured-streaming by this push:
     new 77cb3d4  Rename SparkOutputManager for consistency
77cb3d4 is described below

commit 77cb3d4d4062cee6527aac5afbff120cd775e1b8
Author: Etienne Chauchot <echauc...@apache.org>
AuthorDate: Fri Feb 8 16:07:15 2019 +0100

    Rename SparkOutputManager for consistency
---
 .../spark/structuredstreaming/translation/batch/DoFnFunction.java   | 2 +-
 .../spark/structuredstreaming/translation/batch/ProcessContext.java | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DoFnFunction.java
 
b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DoFnFunction.java
index 2989d0d..d3d8269 100644
--- 
a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DoFnFunction.java
+++ 
b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/DoFnFunction.java
@@ -111,7 +111,7 @@ public class DoFnFunction<InputT, OutputT>
   }
 
   private class DoFnOutputManager
-      implements ProcessContext.SparkOutputManager<Tuple2<TupleTag<?>, 
WindowedValue<?>>> {
+      implements ProcessContext.ProcessOutputManager<Tuple2<TupleTag<?>, 
WindowedValue<?>>> {
 
     private final Multimap<TupleTag<?>, WindowedValue<?>> outputs = 
LinkedListMultimap.create();
 
diff --git 
a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ProcessContext.java
 
b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ProcessContext.java
index b955e20..59ea017 100644
--- 
a/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ProcessContext.java
+++ 
b/runners/spark-structured-streaming/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/ProcessContext.java
@@ -31,13 +31,13 @@ class ProcessContext<FnInputT, FnOutputT, OutputT> {
 
   private final DoFn<FnInputT, FnOutputT> doFn;
   private final DoFnRunner<FnInputT, FnOutputT> doFnRunner;
-  private final SparkOutputManager<OutputT> outputManager;
+  private final ProcessOutputManager<OutputT> outputManager;
   private Iterator<TimerInternals.TimerData> timerDataIterator;
 
   ProcessContext(
       DoFn<FnInputT, FnOutputT> doFn,
       DoFnRunner<FnInputT, FnOutputT> doFnRunner,
-      SparkOutputManager<OutputT> outputManager,
+      ProcessOutputManager<OutputT> outputManager,
       Iterator<TimerInternals.TimerData> timerDataIterator) {
 
     this.doFn = doFn;
@@ -71,7 +71,7 @@ class ProcessContext<FnInputT, FnOutputT, OutputT> {
     return () -> new ProcCtxtIterator(iter, doFnRunner);
   }
 
-  interface SparkOutputManager<T> extends OutputManager, Iterable<T> {
+  interface ProcessOutputManager<T> extends OutputManager, Iterable<T> {
     void clear();
   }