This is an automated email from the ASF dual-hosted git repository.
tgroh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from eb979a0 Merge pull request #5347: [BEAM-4201][SQL] Add integration
test for PubsubIO JSON -> SQL
add 09f313a Migrate ImpulseEvaluatorFactory
add a34f9b0 Migrate FlattenEvaluatorFactoryTest
add be7a539 Migrate GroupByKeyOnly to the RR
add 8007954 Use ModelCoders in LengthPrefixUnknownCoders
new 15b788d Merge pull request #5271: Migrate DirectRunner Evaluators to
use Portable Graph Components
The 1 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:
.../runners/core/construction/ModelCoders.java | 9 +-
runners/direct-java/build.gradle | 1 +
runners/direct-java/pom.xml | 5 +
.../direct/portable/FlattenEvaluatorFactory.java | 37 +++--
.../portable/GroupByKeyOnlyEvaluatorFactory.java | 110 ++++++++-----
.../direct/portable/ImpulseEvaluatorFactory.java | 44 +++---
.../direct/portable/RootProviderRegistry.java | 6 +-
.../portable/FlattenEvaluatorFactoryTest.java | 64 ++++----
.../GroupByKeyOnlyEvaluatorFactoryTest.java | 170 +++++++++++++--------
.../portable/ImpulseEvaluatorFactoryTest.java | 30 ++--
.../wire/LengthPrefixUnknownCoders.java | 18 +--
11 files changed, 297 insertions(+), 197 deletions(-)
--
To stop receiving notification emails like this one, please contact
[email protected].
