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/07/14 02:44:44 UTC
[beam] tag nightly-master updated (e6fa90a -> 10a1bbb)
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 e6fa90a (commit)
to 10a1bbb (commit)
from e6fa90a Merge pull request #12020: [BEAM-9066] Add javax.annotation-api dependency.
add 452723e [BEAM-10455] Provide an example of how to memoize the DataSource provider. (#12220)
add 66bcc9a [BEAM-10450] [BEAM-10449] Fix empty flatten bundle processing. (#12226)
add 8aa898e Copy Pub/Sub Lite IO from Pub/Sub Lite github to beam.
add 0498102 Restructure IO to expose proto types instead of client library wrapper types, as the wrapper types expose guava in the api surface.
add 0359f90 Merge pull request #11919: [BEAM-10114] Copy Pub/Sub Lite IO from Pub/Sub Lite github to beam.
add 424bc6d [BEAM-10407] Revamped SchemaCapableIOProvider interface to SchemaIOProvider (#12237)
add c39d339 [BEAM-9178] Support more EXTRACT functions (#12231)
add a7289fc Migrate ApiSurface back to recent Guava
add 32a6c70 Exclude jdk.internal.HotSpotIntrinsicCandidate from ApiSurface
add 1ad90b9 Merge pull request #12227: [BEAM-10081] Fix ApiSurface to work with Java 11
add 40c46be [BEAM-10080] Fix LocalFileSystemsTest to work with Java 11
add c522239 Merge pull request #12225: [BEAM-10080] Fix LocalFileSystemsTest to work with Java 11
add be8bc57 Fix deps for Java container license report
add 5b9336d Re-enable checker in Samza job server
add 34a9af8 Merge pull request #12216: For Java container, generate license report only for container modules
add 8272c03 add direct runner xlang test badge
add 0d05e41 Merge pull request #12244 from ihji/add_fnapi_xlang_badge
add a1fc92b Adding precommit job that builds javadoc
add afb3e2f Adding issues recording for javadoc CI job
add dcf268b changeing Javadoc PreCommit to PostCommit job
add 10a1bbb Merge pull request #12238: [BEAM-4709] Adding PostCommit jenkins job that builds Javadoc
No new revisions were added by this update.
Summary of changes:
.github/PULL_REQUEST_TEMPLATE.md | 2 +-
.test-infra/jenkins/README.md | 1 +
.test-infra/jenkins/job_PostCommit_Javadoc.groovy | 50 ++
README.md | 2 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 8 +-
runners/samza/job-server/build.gradle | 2 +-
.../src/main/resources/beam/suppressions.xml | 1 +
sdks/java/container/build.gradle | 4 +-
.../container/license_scripts/dep_urls_java.yaml | 155 ------
.../org/apache/beam/sdk/io/LocalFileSystem.java | 34 +-
.../org/apache/beam/sdk/schemas/io/SchemaIO.java | 2 +-
...apableIOProvider.java => SchemaIOProvider.java} | 8 +-
.../org/apache/beam/sdk/transforms/Reshuffle.java | 23 +-
.../java/org/apache/beam/sdk/util/ApiSurface.java | 2 +
.../java/org/apache/beam/sdk/util/ClassPath.java | 530 ---------------------
.../apache/beam/sdk/io/LocalFileSystemTest.java | 15 +-
.../provider/bigquery/BeamBigQuerySqlDialect.java | 163 +++----
.../SqlExtractTimestampOperatorRewriter.java | 47 --
.../sdk/extensions/sql/zetasql/SqlOperators.java | 2 +-
.../sql/zetasql/SqlStdOperatorMappingTable.java | 6 +-
.../sql/zetasql/ZetaSqlTimeFunctionsTest.java | 156 ++++--
.../fn/harness/control/ProcessBundleHandler.java | 5 +-
sdks/java/io/google-cloud-platform/build.gradle | 3 +
.../gcp/pubsub/PubsubSchemaCapableIOProvider.java | 24 +-
.../sdk/io/gcp/pubsublite/AddUuidsTransform.java | 49 ++
.../io/gcp/pubsublite/BufferingPullSubscriber.java | 116 +++++
.../sdk/io/gcp/pubsublite/CloudPubsubChecks.java | 56 +++
.../io/gcp/pubsublite/OffsetCheckpointMark.java | 78 +++
.../sdk/io/gcp/pubsublite/OffsetFinalizer.java | 28 ++
.../io/gcp/pubsublite/PerServerPublisherCache.java | 30 ++
.../beam/sdk/io/gcp/pubsublite/PublisherCache.java | 74 +++
.../sdk/io/gcp/pubsublite/PublisherOptions.java | 84 ++++
.../sdk/io/gcp/pubsublite/PublisherOrError.java | 46 ++
.../beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java | 127 +++++
.../beam/sdk/io/gcp/pubsublite/PubsubLiteSink.java | 150 ++++++
.../gcp/pubsublite/PubsubLiteUnboundedReader.java | 268 +++++++++++
.../gcp/pubsublite/PubsubLiteUnboundedSource.java | 117 +++++
.../beam/sdk/io/gcp/pubsublite/PullSubscriber.java | 28 ++
.../gcp/pubsublite/SerializableStatusFunction.java | 26 +
.../io/gcp/pubsublite/SerializableSupplier.java | 26 +
.../sdk/io/gcp/pubsublite/SubscriberOptions.java | 165 +++++++
.../apache/beam/sdk/io/gcp/pubsublite/Uuid.java | 51 ++
.../beam/sdk/io/gcp/pubsublite/UuidCoder.java | 48 ++
.../gcp/pubsublite/UuidDeduplicationOptions.java | 93 ++++
.../gcp/pubsublite/UuidDeduplicationTransform.java | 52 ++
.../beam/sdk/io/gcp/pubsublite/package-info.java | 24 +
.../apache/beam/sdk/io/gcp/GcpApiSurfaceTest.java | 1 +
.../io/gcp/pubsublite/AddUuidsTransformTest.java | 97 ++++
.../pubsublite/BufferingPullSubscriberTest.java | 183 +++++++
.../sdk/io/gcp/pubsublite/FakeSerializable.java | 58 +++
.../gcp/pubsublite/OffsetCheckpointMarkTest.java | 78 +++
.../sdk/io/gcp/pubsublite/PubsubLiteSinkTest.java | 240 ++++++++++
.../pubsublite/PubsubLiteUnboundedReaderTest.java | 227 +++++++++
.../pubsublite/UuidDeduplicationTransformTest.java | 155 ++++++
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 21 +-
55 files changed, 3116 insertions(+), 925 deletions(-)
create mode 100644 .test-infra/jenkins/job_PostCommit_Javadoc.groovy
rename sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/{SchemaCapableIOProvider.java => SchemaIOProvider.java} (89%)
delete mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/util/ClassPath.java
delete mode 100644 sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlExtractTimestampOperatorRewriter.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/AddUuidsTransform.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/BufferingPullSubscriber.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/CloudPubsubChecks.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/OffsetCheckpointMark.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/OffsetFinalizer.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PerServerPublisherCache.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PublisherCache.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PublisherOptions.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PublisherOrError.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteSink.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteUnboundedReader.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteUnboundedSource.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PullSubscriber.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SerializableStatusFunction.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SerializableSupplier.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriberOptions.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/Uuid.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/UuidCoder.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/UuidDeduplicationOptions.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/UuidDeduplicationTransform.java
create mode 100644 sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/package-info.java
create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/AddUuidsTransformTest.java
create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/BufferingPullSubscriberTest.java
create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/FakeSerializable.java
create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/OffsetCheckpointMarkTest.java
create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteSinkTest.java
create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteUnboundedReaderTest.java
create mode 100644 sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/UuidDeduplicationTransformTest.java