beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (e748846 -> 2781342)
Date Wed, 20 Jan 2021 04:18:53 GMT
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


Mime
View raw message