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

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


    from 16ac4a0  Address minor review notes
     new ff89da2  Clean
     new 88b9db0  Add GroupByKeyTest
     new 1439d92  Add comments and TODO to GroupByKeyTranslatorBatch
     new 6a03541  Fix type checking with Encoder of WindowedValue<T>
     new 89c3a04  Port latest changes of ReadSourceTranslatorBatch to 
ReadSourceTranslatorStreaming
     new 7b6bc5d  Remove no more needed putDatasetRaw

The 19399 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../translation/TranslationContext.java            |  9 ------
 .../batch/GroupByKeyTranslatorBatch.java           |  6 +++-
 .../batch/ReadSourceTranslatorBatch.java           | 11 ++++---
 .../streaming/DatasetSourceStreaming.java          |  4 +++
 .../streaming/ReadSourceTranslatorStreaming.java   | 34 +++++++++++++++-------
 .../batch/{ParDoTest.java => GroupByKeyTest.java}  | 30 ++++++++++++-------
 6 files changed, 58 insertions(+), 36 deletions(-)
 copy 
runners/spark-structured-streaming/src/test/java/org/apache/beam/runners/spark/structuredstreaming/translation/batch/{ParDoTest.java
 => GroupByKeyTest.java} (58%)

Reply via email to