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 e748846 (commit)
to 2781342 (commit)
from e748846 Fix typo in universal.go (#13766)
add 334020f [BEAM-9615] Add Schema Logical Type Provider support (#13760)
add 0f71eb2 [BEAM-11032] Use metric for Java BigQuery streaming insert API latency logging
add 0f574ef fix checkstyle error, rename equalsMetricName
add cf77f03 Merge pull request #13491 from ihji/BEAM-11032
add 5a360a8 BEAM-10095: Add Runner and SDK links to Beam overview page
add cdc7226 Merge pull request #13774 from pcoet/BEAM-10095
add 9f4ed60 [BEAM-10961] Enabled strict dependency on Spark (#13668)
add 4f32816 Enabled strict dependency on Local Java
add b538b59 set enableStrictDependencies: true
add cd1f664 Merge pull request #13665 from sonam-vend/local-java-runner
add 7450ca3 Remove redundant & detatched package comment
add e7d8fdb Merge pull request #13772: Remove redundant & detatched dataflowlib
package comment
add 5cd3130 [BEAM-9615] Disable schema registration.
add e6fa3bd Merge pull request #13777: [BEAM-9615] Disable schema registration.
add 53f2757 Fix broken link to signature for 2.21.0
add ff503e8 Merge pull request #13768 from pcoet/patch-2
add 2781342 [BEAM-11461] update tox and simplify tox.ini (#13692)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../{DistributionCell.java => HistogramCell.java} | 53 ++---
.../beam/runners/core/metrics/LabeledMetrics.java | 14 ++
.../runners/core/metrics/MetricsContainerImpl.java | 101 +++++++-
.../core/metrics/MonitoringInfoConstants.java | 4 +
.../core/metrics/MonitoringInfoMetricName.java | 2 +-
.../dataflow/worker/StreamingDataflowWorker.java | 4 +
runners/local-java/build.gradle | 3 +-
runners/spark/build.gradle | 7 +-
runners/spark/job-server/build.gradle | 4 +-
sdks/go/pkg/beam/coder.go | 22 ++
sdks/go/pkg/beam/core/graph/coder/iterable.go | 36 +++
sdks/go/pkg/beam/core/graph/coder/registry_test.go | 1 -
sdks/go/pkg/beam/core/graph/coder/row.go | 64 +++++-
sdks/go/pkg/beam/core/graph/coder/row_decoder.go | 50 +++-
sdks/go/pkg/beam/core/graph/coder/row_encoder.go | 40 +++-
sdks/go/pkg/beam/core/graph/coder/row_test.go | 121 ++++++++--
sdks/go/pkg/beam/core/runtime/genx/genx.go | 2 +
sdks/go/pkg/beam/core/runtime/graphx/coder.go | 15 +-
.../core/runtime/graphx/schema/logicaltypes.go | 162 ++++++++-----
.../pkg/beam/core/runtime/graphx/schema/schema.go | 201 +++++++++++-----
.../beam/core/runtime/graphx/schema/schema_test.go | 121 +++++++++-
sdks/go/pkg/beam/encoding.go | 131 +++++++++++
sdks/go/pkg/beam/encoding_test.go | 127 +++++++++++
sdks/go/pkg/beam/example_schema_test.go | 254 +++++++++++++++++++++
sdks/go/pkg/beam/forward.go | 4 +
.../beam/runners/dataflow/dataflowlib/metrics.go | 3 -
sdks/go/pkg/beam/schema.go | 72 ++++++
sdks/go/pkg/beam/transforms/top/top.go | 73 ++++--
sdks/go/pkg/beam/transforms/top/top_test.go | 18 +-
.../apache/beam/sdk/metrics/DelegatingCounter.java | 11 +-
...gatingCounter.java => DelegatingHistogram.java} | 40 ++--
.../metrics/{MetricsSink.java => Histogram.java} | 11 +-
.../apache/beam/sdk/metrics/MetricsContainer.java | 9 +
.../beam/sdk/metrics/MetricsEnvironment.java | 19 ++
.../org/apache/beam/sdk/metrics/MetricsLogger.java | 66 ++++++
.../util/{Histogram.java => HistogramData.java} | 33 ++-
.../apache/beam/sdk/util/HistogramDataTest.java | 152 ++++++++++++
.../org/apache/beam/sdk/util/HistogramTest.java | 152 ------------
.../google-cloud-platform-core/build.gradle | 1 +
.../LatencyRecordingHttpRequestInitializer.java | 23 +-
...LatencyRecordingHttpRequestInitializerTest.java | 6 +-
.../beam/sdk/io/gcp/bigquery/BigQueryOptions.java | 8 +-
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 4 -
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 33 ++-
.../beam/sdk/io/gcp/bigquery/StreamingWriteFn.java | 59 ++---
.../sdk/io/gcp/testing/FakeBigQueryServices.java | 6 -
sdks/python/tox.ini | 92 +-------
.../site/content/en/get-started/beam-overview.md | 24 +-
.../www/site/content/en/get-started/downloads.md | 2 +-
50 files changed, 1871 insertions(+), 591 deletions(-)
copy runners/core-java/src/main/java/org/apache/beam/runners/core/metrics/{DistributionCell.java
=> HistogramCell.java} (60%)
create mode 100644 sdks/go/pkg/beam/encoding_test.go
create mode 100644 sdks/go/pkg/beam/example_schema_test.go
create mode 100644 sdks/go/pkg/beam/schema.go
copy sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/{DelegatingCounter.java =>
DelegatingHistogram.java} (57%)
copy sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/{MetricsSink.java => Histogram.java}
(76%)
create mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsLogger.java
rename sdks/java/core/src/main/java/org/apache/beam/sdk/util/{Histogram.java => HistogramData.java}
(87%)
create mode 100644 sdks/java/core/src/test/java/org/apache/beam/sdk/util/HistogramDataTest.java
delete mode 100644 sdks/java/core/src/test/java/org/apache/beam/sdk/util/HistogramTest.java
|