Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Pulsar IO rename #1747

Merged
merged 16 commits into from
May 8, 2018
Merged

Pulsar IO rename #1747

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
16 commits
Select commit Hold shift + click to select a range
d2c31e9
begin renaming process
lucperkins Apr 23, 2018
52c5a28
more class and directory renames
lucperkins Apr 23, 2018
b7e3881
fix merge conflicts
lucperkins May 7, 2018
5ef005d
move Record classes into pulsar-io
lucperkins May 7, 2018
a51aa0c
apply rename to Maven configs
lucperkins May 7, 2018
daa8322
rename java imports
lucperkins May 7, 2018
d72304f
fix merge conflicts
lucperkins May 7, 2018
f217df5
fix merge conflict
lucperkins May 8, 2018
81d6af0
update versions in maven configs
lucperkins May 8, 2018
2cdf985
add missing imports
lucperkins May 8, 2018
230727a
remove Message class from pulsar-io
lucperkins May 8, 2018
71f799c
add missing import
lucperkins May 8, 2018
ee3f225
add Reflections util import
lucperkins May 8, 2018
25505d0
add Utils import
lucperkins May 8, 2018
635ad0a
add missing Record import
lucperkins May 8, 2018
9cc6697
supply missing Record imports
lucperkins May 8, 2018
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
begin renaming process
  • Loading branch information
@lucperkins
lucperkins committed Apr 23, 2018
commit d2c31e9c7dc6930c00dfa4ed99419c364be4cb1b
8 changes: 4 additions & 4 deletions pulsar-connect/aerospike/pom.xml → pulsar-io/aerospike/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,18 +23,18 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-connect</artifactId>
<artifactId>pulsar-io</artifactId>
<version>2.0.0-incubating-SNAPSHOT</version>
</parent>

<artifactId>pulsar-connect-aerospike</artifactId>
<name>Pulsar Connect :: Aerospike</name>
<artifactId>pulsar-io-aerospike</artifactId>
<name>Pulsar IO :: Aerospike</name>

<dependencies>

<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>pulsar-connect-core</artifactId>
<artifactId>pulsar-io-core</artifactId>
<version>${project.version}</version>
</dependency>

Expand Down
2 changes: 1 addition & 1 deletion ...lsar/connect/aerospike/AerospikeSink.java → ...he/pulsar/io/aerospike/AerospikeSink.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
* under the License.
*/

package org.apache.pulsar.connect.aerospike;
package org.apache.pulsar.io.aerospike;

import java.util.Map;
import java.util.concurrent.BlockingQueue;
Expand Down
2 changes: 1 addition & 1 deletion ...onnect/aerospike/AerospikeSinkConfig.java → ...sar/io/aerospike/AerospikeSinkConfig.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
* under the License.
*/

package org.apache.pulsar.connect.aerospike;
package org.apache.pulsar.io.aerospike;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
Expand Down
8 changes: 4 additions & 4 deletions pulsar-connect/cassandra/pom.xml → pulsar-io/cassandra/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,18 +23,18 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-connect</artifactId>
<artifactId>pulsar-io</artifactId>
<version>2.0.0-incubating-SNAPSHOT</version>
</parent>

<artifactId>pulsar-connect-cassandra</artifactId>
<name>Pulsar Connect :: Cassandra</name>
<artifactId>pulsar-io-cassandra</artifactId>
<name>Pulsar IO :: Cassandra</name>

<dependencies>

<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>pulsar-connect-core</artifactId>
<artifactId>pulsar-io-core</artifactId>
<version>${project.version}</version>
</dependency>

Expand Down
2 changes: 1 addition & 1 deletion ...lsar/connect/cassandra/CassandraSink.java → ...he/pulsar/io/cassandra/CassandraSink.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
* under the License.
*/

package org.apache.pulsar.connect.cassandra;
package org.apache.pulsar.io.cassandra;

import com.datastax.driver.core.*;
import com.google.common.util.concurrent.FutureCallback;
Expand Down
2 changes: 1 addition & 1 deletion ...onnect/cassandra/CassandraSinkConfig.java → ...sar/io/cassandra/CassandraSinkConfig.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
* under the License.
*/

package org.apache.pulsar.connect.cassandra;
package org.apache.pulsar.io.cassandra;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
Expand Down
6 changes: 3 additions & 3 deletions pulsar-connect/core/pom.xml → pulsar-io/core/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,11 +23,11 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-connect</artifactId>
<artifactId>pulsar-io</artifactId>
<version>2.0.0-incubating-SNAPSHOT</version>
</parent>

<artifactId>pulsar-connect-core</artifactId>
<name>Pulsar Connect :: Connect</name>
<artifactId>pulsar-io-core</artifactId>
<name>Pulsar IO :: IO</name>

</project>
4 changes: 2 additions & 2 deletions ...g/apache/pulsar/connect/core/Message.java → ...va/org/apache/pulsar/io/core/Message.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,10 +16,10 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.pulsar.connect.core;
package org.apache.pulsar.io.core;

/**
* Pulsar Connect's Message interface. Message encapsulates the
* Pulsar IO's Message interface. The Message interface encapsulates
* information about a message being read/written from/to a Source/Sink.
*/
public interface Message<T> {
Expand Down
2 changes: 1 addition & 1 deletion ...pache/pulsar/connect/core/PushSource.java → ...org/apache/pulsar/io/core/PushSource.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.pulsar.connect.core;
package org.apache.pulsar.io.core;

import java.util.Map;
import java.util.concurrent.CompletableFuture;
Expand Down
2 changes: 1 addition & 1 deletion .../org/apache/pulsar/connect/core/Sink.java → .../java/org/apache/pulsar/io/core/Sink.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.pulsar.connect.core;
package org.apache.pulsar.io.core;

import java.util.Map;
import java.util.concurrent.CompletableFuture;
Expand Down
2 changes: 1 addition & 1 deletion ...rg/apache/pulsar/connect/core/Source.java → ...ava/org/apache/pulsar/io/core/Source.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@
* specific language governing permissions and limitations
* under the License.
*/
package org.apache.pulsar.connect.core;
package org.apache.pulsar.io.core;

import java.util.Map;

Expand Down
6 changes: 3 additions & 3 deletions pulsar-connect/kafka/pom.xml → pulsar-io/kafka/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,12 +23,12 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-connect</artifactId>
<artifactId>pulsar-io</artifactId>
<version>2.0.0-incubating-SNAPSHOT</version>
</parent>

<artifactId>pulsar-connect-kafka</artifactId>
<name>Pulsar Connect :: Kafka</name>
<artifactId>pulsar-io-kafka</artifactId>
<name>Pulsar IO :: Kafka</name>

<dependencies>

Expand Down
0 ...pache/pulsar/connect/kafka/KafkaSink.java → ...pache/pulsar/connect/kafka/KafkaSink.java
View file
Open in desktop
File renamed without changes.
0 ...pulsar/connect/kafka/KafkaSinkConfig.java → ...pulsar/connect/kafka/KafkaSinkConfig.java
View file
Open in desktop
File renamed without changes.
0 ...che/pulsar/connect/kafka/KafkaSource.java → ...che/pulsar/connect/kafka/KafkaSource.java
View file
Open in desktop
File renamed without changes.
0 ...lsar/connect/kafka/KafkaSourceConfig.java → ...lsar/connect/kafka/KafkaSourceConfig.java
View file
Open in desktop
File renamed without changes.
4 changes: 2 additions & 2 deletions pulsar-connect/pom.xml → pulsar-io/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@
<version>2.0.0-incubating-SNAPSHOT</version>
</parent>

<artifactId>pulsar-connect</artifactId>
<name>Pulsar Connect :: Parent</name>
<artifactId>pulsar-io</artifactId>
<name>Pulsar IO :: Parent</name>

<modules>
<module>core</module>
Expand Down
8 changes: 4 additions & 4 deletions pulsar-connect/rabbitmq/pom.xml → pulsar-io/rabbitmq/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,18 +23,18 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-connect</artifactId>
<artifactId>pulsar-io</artifactId>
<version>2.0.0-incubating-SNAPSHOT</version>
</parent>

<artifactId>pulsar-connect-rabbitmq</artifactId>
<name>Pulsar Connect :: RabbitMQ</name>
<artifactId>pulsar-io-rabbitmq</artifactId>
<name>Pulsar IO :: RabbitMQ</name>

<dependencies>

<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>pulsar-connect-core</artifactId>
<artifactId>pulsar-io-core</artifactId>
<version>${project.version}</version>
</dependency>

Expand Down
0 ...lsar/connect/rabbitmq/RabbitMQConfig.java → ...lsar/connect/rabbitmq/RabbitMQConfig.java
View file
Open in desktop
File renamed without changes.
0 ...lsar/connect/rabbitmq/RabbitMQSource.java → ...lsar/connect/rabbitmq/RabbitMQSource.java
View file
Open in desktop
File renamed without changes.
8 changes: 4 additions & 4 deletions pulsar-connect/twitter/pom.xml → pulsar-io/twitter/pom.xml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -23,18 +23,18 @@
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-connect</artifactId>
<artifactId>pulsar-io</artifactId>
<version>2.0.0-incubating-SNAPSHOT</version>
</parent>

<artifactId>pulsar-connect-twitter</artifactId>
<name>Pulsar Connect :: Twitter</name>
<artifactId>pulsar-io-twitter</artifactId>
<name>Pulsar IO :: Twitter</name>

<dependencies>

<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>pulsar-connect-core</artifactId>
<artifactId>pulsar-io-core</artifactId>
<version>${project.version}</version>
</dependency>

Expand Down
0 ...lsar/connect/twitter/TwitterFireHose.java → ...lsar/connect/twitter/TwitterFireHose.java
View file
Open in desktop
File renamed without changes.
0 ...onnect/twitter/TwitterFireHoseConfig.java → ...onnect/twitter/TwitterFireHoseConfig.java
View file
Open in desktop
File renamed without changes.