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 d4d2e7e Fix various type checking issues in Combine.Globally
new 18494a1 Update test with Long
new a6e49b8 Fix combine. For unknown reason GenericRowWithSchema is used
as input of combine so extract its content to be able to proceed
The 19431 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/batch/AggregatorCombinerGlobally.java | 8 ++++++--
.../batch/CombineGloballyTranslatorBatch.java | 1 -
.../translation/helpers/EncoderHelpers.java | 6 +++---
.../translation/helpers/RowHelpers.java | 16 +++++++++++++---
.../translation/batch/CombineTest.java | 18 +++++++-----------
5 files changed, 29 insertions(+), 20 deletions(-)
