This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 25770e3 [BEAM-4028] Address cleanup TODOs (#15652)
add 0cddc44 [BEAM-13052] Restructure pubsublite folder to move non-user
interface classes to internal folder (#15724)
No new revisions were added by this update.
Summary of changes:
.../sdk/io/gcp/pubsublite/PublisherOptions.java | 28 +---
.../beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java | 4 +
.../pubsublite/SerializableSubscriberFactory.java | 33 -----
.../sdk/io/gcp/pubsublite/SubscriberOptions.java | 145 +--------------------
.../gcp/pubsublite/UuidDeduplicationOptions.java | 5 +-
.../{ => internal}/AddUuidsTransform.java | 5 +-
.../gcp/pubsublite/{ => internal}/DlqProvider.java | 4 +-
.../{ => internal}/InitialOffsetReader.java | 2 +-
.../{ => internal}/InitialOffsetReaderImpl.java | 2 +-
.../{ => internal}/LimitingTopicBacklogReader.java | 2 +-
.../ManagedBacklogReaderFactory.java | 2 +-
.../ManagedBacklogReaderFactoryImpl.java | 2 +-
.../{ => internal}/OffsetByteProgress.java | 2 +-
.../pubsublite/{ => internal}/OffsetByteRange.java | 2 +-
.../{ => internal}/OffsetByteRangeCoder.java | 2 +-
.../{ => internal}/OffsetByteRangeTracker.java | 2 +-
.../{ => internal}/PerServerPublisherCache.java | 2 +-
.../PerSubscriptionPartitionSdf.java | 2 +-
.../PublisherAssembler.java} | 31 ++---
.../pubsublite/{ => internal}/PublisherCache.java | 8 +-
.../{ => internal}/PublisherOrError.java | 2 +-
.../pubsublite/{ => internal}/PubsubLiteSink.java | 18 +--
.../{ => internal}/SubscribeTransform.java | 18 +--
.../pubsublite/internal/SubscriberAssembler.java | 121 +++++++++++++++++
.../{ => internal}/SubscriptionPartition.java | 2 +-
.../{ => internal}/SubscriptionPartitionCoder.java | 2 +-
.../SubscriptionPartitionLoader.java | 2 +-
.../SubscriptionPartitionProcessor.java | 2 +-
.../SubscriptionPartitionProcessorFactory.java | 2 +-
.../SubscriptionPartitionProcessorImpl.java | 2 +-
.../{ => internal}/TopicBacklogReader.java | 2 +-
.../{ => internal}/TopicBacklogReaderImpl.java | 2 +-
.../{ => internal}/TopicBacklogReaderSettings.java | 2 +-
.../{ => internal}/TrackerWithProgress.java | 2 +-
.../sdk/io/gcp/pubsublite/{ => internal}/Uuid.java | 2 +-
.../gcp/pubsublite/{ => internal}/UuidCoder.java | 2 +-
.../{ => internal}/UuidDeduplicationTransform.java | 7 +-
.../package-info.java} | 13 +-
.../{ => internal}/AddUuidsTransformTest.java | 2 +-
.../{ => internal}/FakeSerializable.java | 3 +-
.../{ => internal}/OffsetByteRangeTrackerTest.java | 2 +-
.../PerSubscriptionPartitionSdfTest.java | 2 +-
.../{ => internal}/PubsubLiteSinkTest.java | 3 +-
.../SubscriptionPartitionLoaderTest.java | 2 +-
.../SubscriptionPartitionProcessorImplTest.java | 2 +-
.../{ => internal}/TopicBacklogReaderImplTest.java | 2 +-
.../UuidDeduplicationTransformTest.java | 3 +-
47 files changed, 216 insertions(+), 293 deletions(-)
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SerializableSubscriberFactory.java
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/AddUuidsTransform.java (92%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/DlqProvider.java (94%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/InitialOffsetReader.java (94%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/InitialOffsetReaderImpl.java (97%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/LimitingTopicBacklogReader.java (98%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/ManagedBacklogReaderFactory.java (95%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/ManagedBacklogReaderFactoryImpl.java (97%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/OffsetByteProgress.java (95%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/OffsetByteRange.java (95%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/OffsetByteRangeCoder.java (97%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/OffsetByteRangeTracker.java (99%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/PerServerPublisherCache.java (95%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/PerSubscriptionPartitionSdf.java (98%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{Publishers.java
=> internal/PublisherAssembler.java} (77%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/PublisherCache.java (91%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/PublisherOrError.java (96%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/PubsubLiteSink.java (91%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/SubscribeTransform.java (88%)
create mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/internal/SubscriberAssembler.java
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/SubscriptionPartition.java (96%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/SubscriptionPartitionCoder.java (97%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/SubscriptionPartitionLoader.java (98%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/SubscriptionPartitionProcessor.java (95%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/SubscriptionPartitionProcessorFactory.java (96%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/SubscriptionPartitionProcessorImpl.java (99%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/TopicBacklogReader.java (96%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/TopicBacklogReaderImpl.java (97%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/TopicBacklogReaderSettings.java (98%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/TrackerWithProgress.java (95%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/Uuid.java (97%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/UuidCoder.java (97%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/UuidDeduplicationTransform.java (89%)
rename
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/{SerializableSupplier.java
=> internal/package-info.java} (72%)
rename
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/AddUuidsTransformTest.java (98%)
rename
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/FakeSerializable.java (93%)
rename
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/OffsetByteRangeTrackerTest.java (99%)
rename
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/PerSubscriptionPartitionSdfTest.java (99%)
rename
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/PubsubLiteSinkTest.java (98%)
rename
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/SubscriptionPartitionLoaderTest.java (98%)
rename
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/SubscriptionPartitionProcessorImplTest.java (99%)
rename
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/TopicBacklogReaderImplTest.java (98%)
rename
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/pubsublite/{
=> internal}/UuidDeduplicationTransformTest.java (97%)
