You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2020/09/12 02:56:38 UTC
[beam] tag nightly-master updated (d52f545 -> e8395bf)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from d52f545 (commit)
to e8395bf (commit)
from d52f545 Merge pull request #12803 from ibzib/BEAM-10762
add 43b5c5c [Beam-9543] support MATCH_RECOGNIZE with NFA (#12532)
add 8846a15 Update Gradle Wrapper
add e925927 Merge pull request #12810: [BEAM-9456] Update Gradle Wrapper
add bb37b1a Merge pull request #12435: [BEAM-10616] Added Python Pardo load tests for streaming on Dataflow
add 1a5f9ab [BEAM-10874] Support v2 Go protos. (#12816)
add 995b7fe [BEAM-10824] [BEAM-7654] Use deterministic hash functions in ApproximateUniqueCombineFn (#12756)
add 738a910 [BEAM-9561] Fix issue with pickling in doctests. (#12560)
add 422e111 [BEAM-10009] Add beam:logical_type:micros_instant:v1 (#12764)
add 803efdd [BEAM-10868] Fix build (docker run) concurrency issue when building golang license dependencies
add 856cc22 Merge pull request #12829 from alanmyrvold/flaky-test
add 5ef04e9 [BEAM-9547] A couple trivial but common dataframe methods.
add cf2ecd3 Merge pull request #12814 [BEAM-9547] A couple trivial but common dataframe methods.
add 92fde98 [BEAM-10833] Fix type inference for BUILD_MAP.
add 3005421 Guard test for Python 3.
add 1a89550 Merge pull request #12798 [BEAM-10833] Fix type inference for BUILD_MAP.
add de309d2 [BEAM-10876] Fix TypeError in dataflow_metrics when distribution sum … (#12817)
add 224b1d4 [BEAM-7523] Enable KafkaCSVTableIT using KafkaContainer (#12826)
add 40cdaf6 [BEAM-9561] Improve WontImplement reporting.
add 8e7014d Merge pull request #12815 [BEAM-9561] Improve WontImplement reporting.
add b64a9e8 [BEAM-10670] Add support for bundle finalization to DoFnOperator for non-portable streaming pipelines.
add 126191d fixup! Address PR comments
add 87e4ff2 Merge pull request #12706 from lukecwik/beam10670.5
add 1947ab0 [BEAM-10670] Make Flink to be opt-out for SplittableDoFn powering the Read transform.
add 35dfe25 fixup! Fix translation issue where we should never be translating composite Read transforms.
add 80599ad Merge pull request #12708 from lukecwik/beam10670.6
add e76e599 Deprecate obsolete CombineFn.add_inputs. (#12802)
add e8395bf [BEAM-10678] Split up assertion for clarity (#12828)
No new revisions were added by this update.
Summary of changes:
.../job_LoadTests_ParDo_Flink_Python.groovy | 2 +
.../jenkins/job_LoadTests_ParDo_Python.groovy | 65 +-
CHANGES.md | 2 +-
build.gradle | 3 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +
gradle/wrapper/gradle-wrapper.jar | Bin 56177 -> 59203 bytes
gradle/wrapper/gradle-wrapper.properties | 17 -
gradlew | 65 +-
gradlew.bat | 59 +-
.../beam/model/fnexecution/v1/standard_coders.yaml | 9 +
release/go-licenses/common.gradle | 8 +-
.../runners/core/construction/CommonCoderTest.java | 8 +-
.../core/construction/SchemaTranslationTest.java | 6 +-
runners/flink/flink_runner.gradle | 36 +-
.../flink/FlinkBatchPipelineTranslator.java | 9 +
.../org/apache/beam/runners/flink/FlinkRunner.java | 2 +
.../flink/FlinkStreamingPipelineTranslator.java | 7 +
.../flink/FlinkStreamingTransformTranslators.java | 27 +
.../runners/flink/FlinkTransformOverrides.java | 20 +-
.../wrappers/streaming/DoFnOperator.java | 44 ++
.../wrappers/streaming/SplittableDoFnOperator.java | 4 +-
.../control/DefaultJobBundleFactoryTest.java | 6 +-
sdks/go/pkg/beam/coder.go | 35 +-
.../src/main/java/org/apache/beam/sdk/io/Read.java | 3 +-
.../java/org/apache/beam/sdk/schemas/Schema.java | 34 +-
.../apache/beam/sdk/schemas/SchemaTranslation.java | 76 +-
.../sdk/schemas/logicaltypes/MicrosInstant.java | 73 ++
.../beam/sdk/schemas/logicaltypes/NanosType.java | 1 +
.../beam/sdk/schemas/logicaltypes/SqlTypes.java | 4 +
sdks/java/extensions/sql/build.gradle | 3 +-
.../beam/sdk/extensions/sql/impl/cep/CEPKind.java | 5 +
.../sdk/extensions/sql/impl/cep/CEPLiteral.java | 197 ++++-
.../sdk/extensions/sql/impl/cep/CEPMeasure.java | 4 +-
.../sdk/extensions/sql/impl/cep/CEPOperator.java | 5 +
.../sdk/extensions/sql/impl/cep/CEPPattern.java | 83 +--
.../sql/impl/cep/{CEPUtil.java => CEPUtils.java} | 56 +-
.../sdk/extensions/sql/impl/cep/Quantifier.java | 22 +-
.../beam/sdk/extensions/sql/impl/nfa/NFA.java | 815 +++++++++++++++++++++
.../sdk/extensions/sql/impl/nfa}/package-info.java | 4 +-
.../sdk/extensions/sql/impl/rel/BeamMatchRel.java | 397 +++++-----
.../extensions/sql/impl/rel/BeamMatchRelTest.java | 40 +-
.../sql/meta/provider/kafka/KafkaCSVTableIT.java | 49 +-
sdks/python/apache_beam/coders/row_coder.py | 34 +
sdks/python/apache_beam/coders/row_coder_test.py | 49 +-
.../apache_beam/coders/standard_coders_test.py | 9 +
sdks/python/apache_beam/dataframe/doctests.py | 18 +-
sdks/python/apache_beam/dataframe/frame_base.py | 17 +
sdks/python/apache_beam/dataframe/frames.py | 6 +
.../runners/dataflow/dataflow_metrics.py | 12 +
.../apache_beam/testing/load_tests/pardo_test.py | 56 +-
sdks/python/apache_beam/transforms/combiners.py | 10 +-
.../apache_beam/transforms/combiners_test.py | 4 +-
sdks/python/apache_beam/transforms/core.py | 53 +-
sdks/python/apache_beam/transforms/stats.py | 78 +-
sdks/python/apache_beam/transforms/stats_test.py | 592 +++++----------
.../apache_beam/typehints/decorators_test.py | 3 +-
sdks/python/apache_beam/typehints/opcodes.py | 24 +-
sdks/python/apache_beam/typehints/schemas.py | 207 +++++-
sdks/python/apache_beam/typehints/schemas_test.py | 3 +
.../typehints/trivial_inference_test.py | 25 +
sdks/python/container/base_image_requirements.txt | 1 +
.../container/license_scripts/dep_urls_py.yaml | 2 +
62 files changed, 2402 insertions(+), 1108 deletions(-)
create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/MicrosInstant.java
rename sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/{CEPUtil.java => CEPUtils.java} (81%)
create mode 100644 sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/nfa/NFA.java
copy {runners/core-construction-java/src/main/java/org/apache/beam/runners/core/construction/resources => sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/nfa}/package-info.java (85%)