You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@samza.apache.org by prateekm <gi...@git.apache.org> on 2018/10/12 18:17:33 UTC
[GitHub] samza pull request #720: Consolidating package names for System, Stream, App...
GitHub user prateekm opened a pull request:
https://github.com/apache/samza/pull/720
Consolidating package names for System, Stream, Application and Table descriptors.
Everything in this PR is either:
1. A package name change and a corresponding file move.
2. Javadoc changes to use FQN in link tags to fix checkstyle complaints about unused imports, and corresponding fixes to make them fit within line width. No change in contents.
3. In a couple of places, changing method visibility to public with VisibleForTesting annotations for accessing them from Tests (RemoteReadWriteTable.java, RemoteReadableTable.java)
If you notice any other kind of changes, please LMK.
A summary of what's changed (according to git):
```
Source:
org.apache.samza.application.{ => descriptors}.ApplicationDescriptor.java
org.apache.samza.application.{ => descriptors}.StreamApplicationDescriptor.java
org.apache.samza.application.{ => descriptors}.TaskApplicationDescriptor.java
org.apache.samza.{operators.descriptors.base.system => system.descriptors}.ExpandingInputDescriptorProvider.java
org.apache.samza.{operators => system}.descriptors.GenericInputDescriptor.java
org.apache.samza.{operators => system}.descriptors.GenericOutputDescriptor.java
org.apache.samza.{operators => system}.descriptors.GenericSystemDescriptor.java
org.apache.samza.{operators.descriptors.base.stream => system.descriptors}.InputDescriptor.java
org.apache.samza.{operators.functions => system.descriptors}.InputTransformer.java
org.apache.samza.{operators.descriptors.base.stream => system.descriptors}.OutputDescriptor.java
org.apache.samza.{operators.descriptors.base.system => system.descriptors}.OutputDescriptorProvider.java
org.apache.samza.{operators.descriptors.base.system => system.descriptors}.SimpleInputDescriptorProvider.java
org.apache.samza.{operators.descriptors.base.stream => system.descriptors}.StreamDescriptor.java
org.apache.samza.{operators.functions => system.descriptors}.StreamExpander.java
org.apache.samza.{operators.descriptors.base.system => system.descriptors}.SystemDescriptor.java
org.apache.samza.{operators.descriptors.base.system => system.descriptors}.TransformingInputDescriptorProvider.java
org.apache.samza.{operators => system}.descriptors.DelegatingSystemDescriptor.java
org.apache.samza.application.{ => descriptors}.ApplicationDescriptorImpl.java
org.apache.samza.application.{ => descriptors}.ApplicationDescriptorUtil.java
org.apache.samza.application.{ => descriptors}.StreamApplicationDescriptorImpl.java
org.apache.samza.application.{ => descriptors}.TaskApplicationDescriptorImpl.java
org.apache.samza.{operators => table.descriptors}.TableDescriptor.java
org.apache.samza.table.{ => descriptors}.TableProvider.java
org.apache.samza.table.{ => descriptors}.TableProviderFactory.java
org.apache.samza.{operators => table.descriptors}.BaseTableDescriptor.java
org.apache.samza.table.{ => descriptors}.caching.CachingTableDescriptor.java
org.apache.samza.table.{ => descriptors}.caching.CachingTableProvider.java
org.apache.samza.table.{ => descriptors}.caching.CachingTableProviderFactory.java
org.apache.samza.table.{ => descriptors}.caching.guava.GuavaCacheTableDescriptor.java
org.apache.samza.table.{ => descriptors}.caching.guava.GuavaCacheTableProvider.java
org.apache.samza.table.{ => descriptors}.caching.guava.GuavaCacheTableProviderFactory.java
org.apache.samza.table.{ => descriptors}.hybrid.BaseHybridTableDescriptor.java
org.apache.samza.table.{ => descriptors}.remote.RemoteTableDescriptor.java
org.apache.samza.table.{ => descriptors}.remote.RemoteTableProvider.java
org.apache.samza.table.{ => descriptors}.remote.RemoteTableProviderFactory.java
org.apache.samza.table.{ => descriptors}.utils.BaseTableProvider.java
org.apache.samza.system.eventhub.{ => descriptors}.EventHubsInputDescriptor.java
org.apache.samza.system.eventhub.{ => descriptors}.EventHubsOutputDescriptor.java
org.apache.samza.system.eventhub.{ => descriptors}.EventHubsSystemDescriptor.java
org.apache.samza.system.kafka.{ => descriptors}.KafkaInputDescriptor.java
org.apache.samza.system.kafka.{ => descriptors}.KafkaOutputDescriptor.java
org.apache.samza.system.kafka.{ => descriptors}.KafkaSystemDescriptor.java
org.apache.samza.storage.kv.{ => descriptors}.BaseLocalStoreBackedTableDescriptor.java
org.apache.samza.storage.kv.{ => descriptors}.BaseLocalStoreBackedTableProvider.java
org.apache.samza.storage.kv.{ => descriptors}.RocksDbTableDescriptor.java
org.apache.samza.storage.kv.{ => descriptors}.RocksDbTableProvider.java
org.apache.samza.storage.kv.{ => descriptors}.RocksDbTableProviderFactory.java
org.apache.samza.storage.kv.inmemory.{ => descriptors}.InMemoryTableDescriptor.java
org.apache.samza.storage.kv.inmemory.{ => descriptors}.InMemoryTableProvider.java
org.apache.samza.storage.kv.inmemory.{ => descriptors}.InMemoryTableProviderFactory.java
org.apache.samza.test.framework.system.{ => descriptors}.InMemoryInputDescriptor.java
org.apache.samza.test.framework.system.{ => descriptors}.InMemoryOutputDescriptor.java
org.apache.samza.test.framework.system.{ => descriptors}.InMemorySystemDescriptor.java
Test:
org.apache.samza.{operators => system}.descriptors.TestExpandingInputDescriptor.java
org.apache.samza.{operators => system}.descriptors.TestGenericInputDescriptor.java
org.apache.samza.{operators => system}.descriptors.TestGenericSystemDescriptor.java
org.apache.samza.{operators => system}.descriptors.TestSimpleInputDescriptor.java
org.apache.samza.{operators => system}.descriptors.TestTransformingInputDescriptor.java
org.apache.samza.{operators.descriptors => system.descriptors.examples}.expanding.ExampleExpandingInputDescriptor.java
org.apache.samza.{operators.descriptors => system.descriptors.examples}.expanding.ExampleExpandingOutputDescriptor.java
org.apache.samza.{operators.descriptors => system.descriptors.examples}.expanding.ExampleExpandingSystemDescriptor.java
org.apache.samza.{operators.descriptors => system.descriptors.examples}.serde.ExampleSimpleInputDescriptor.java
org.apache.samza.{operators.descriptors => system.descriptors.examples}.serde.ExampleSimpleOutputDescriptor.java
org.apache.samza.{operators.descriptors => system.descriptors.examples}.serde.ExampleSimpleSystemDescriptor.java
org.apache.samza.{operators.descriptors => system.descriptors.examples}.transforming.ExampleTransformingInputDescriptor.java
org.apache.samza.{operators.descriptors => system.descriptors.examples}.transforming.ExampleTransformingOutputDescriptor.java
org.apache.samza.{operators.descriptors => system.descriptors.examples}.transforming.ExampleTransformingSystemDescriptor.java
org.apache.samza.application.{ => descriptors}.TestStreamApplicationDescriptorImpl.java
org.apache.samza.application.{ => descriptors}.TestTaskApplicationDescriptorImpl.java
org.apache.samza.table.{ => descriptors}.remote.TestRemoteTableDescriptor.java
org.apache.samza.system.eventhub.{ => descriptors}.TestEventHubsInputDescriptor.java
org.apache.samza.system.eventhub.{ => descriptors}.TestEventHubsOutputDescriptor.java
org.apache.samza.system.eventhub.{ => descriptors}.TestEventHubsSystemDescriptor.java
org.apache.samza.system.kafka.{ => descriptors}.TestKafkaInputDescriptor.java
org.apache.samza.system.kafka.{ => descriptors}.TestKafkaSystemDescriptor.java
org.apache.samza.storage.kv.{ => descriptors}.TestBaseLocalStoreBackedTableProvider.java
org.apache.samza.storage.kv.{ => descriptors}.TestRocksDbTableDescriptor.java
org.apache.samza.storage.kv.{ => descriptors}.TestRocksDbTableProvider.java
org.apache.samza.storage.kv.inmemory.{ => descriptors}.TestInMemoryTableDescriptor.java
org.apache.samza.storage.kv.inmemory.{ => descriptors}.TestInMemoryTableProvider.java
```
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/prateekm/samza descriptor-package-cleanup
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/720.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #720
----
commit 296660dd8cf92d2adcbde743a6826b2a0ddd7ce7
Author: Prateek Maheshwari <pm...@...>
Date: 2018-10-12T18:02:12Z
Consolidating package names for System, Stream, Application and Table descriptors.
----
---
[GitHub] samza pull request #720: Consolidating package names for System, Stream, App...
Posted by asfgit <gi...@git.apache.org>.
Github user asfgit closed the pull request at:
https://github.com/apache/samza/pull/720
---