From 17f74150f43fc3766e78e2a566c6a4b8d2150d5b Mon Sep 17 00:00:00 2001 From: Luc Perkins Date: Tue, 8 May 2018 12:21:15 -0700 Subject: [PATCH] Pulsar IO rename (#1747) * begin renaming process * more class and directory renames * move Record classes into pulsar-io * apply rename to Maven configs * rename java imports * update versions in maven configs * add missing imports * remove Message class from pulsar-io * add missing import * add Reflections util import * add Utils import * add missing Record import * supply missing Record imports --- pom.xml | 6 ++-- .../pom.xml | 4 +-- pulsar-client-admin-shaded/pom.xml | 4 +-- pulsar-client-shaded/pom.xml | 4 +-- .../org/apache/pulsar/admin/cli/CmdSinks.java | 9 ++++-- .../apache/pulsar/admin/cli/CmdSources.java | 9 ++++-- pulsar-client/pom.xml | 2 +- .../pulsar/client/impl/MessageRecordImpl.java | 2 +- pulsar-functions/instance/pom.xml | 4 +-- .../functions/instance/JavaInstance.java | 2 +- .../instance/JavaInstanceRunnable.java | 6 ++-- .../functions/sink/DefaultRuntimeSink.java | 2 +- .../pulsar/functions/sink/PulsarSink.java | 2 +- .../functions/sink/PulsarSinkConfig.java | 2 -- .../pulsar/functions/sink/RuntimeSink.java | 4 +-- .../pulsar/functions/source/PulsarRecord.java | 2 +- .../pulsar/functions/source/PulsarSource.java | 4 +-- .../sink/DefaultRuntimeSinkTest.java | 4 +-- pulsar-functions/utils/pom.xml | 2 +- .../aerospike/pom.xml | 8 ++--- .../pulsar/io}/aerospike/AerospikeSink.java | 23 +++++++++------ .../io}/aerospike/AerospikeSinkConfig.java | 2 +- .../cassandra/pom.xml | 8 ++--- .../pulsar/io}/cassandra/CassandraSink.java | 11 +++++-- .../io}/cassandra/CassandraSinkConfig.java | 2 +- {pulsar-connect => pulsar-io}/core/pom.xml | 6 ++-- .../apache/pulsar/io}/core/PushSource.java | 2 +- .../org/apache/pulsar/io}/core/Record.java | 2 +- .../apache/pulsar/io}/core/RecordContext.java | 2 +- .../java/org/apache/pulsar/io}/core/Sink.java | 2 +- .../org/apache/pulsar/io}/core/Source.java | 2 +- {pulsar-connect => pulsar-io}/kafka/pom.xml | 8 ++--- .../apache/pulsar/io}/kafka/KafkaSink.java | 4 +-- .../pulsar/io}/kafka/KafkaSinkConfig.java | 2 +- .../apache/pulsar/io}/kafka/KafkaSource.java | 10 ++++--- .../pulsar/io}/kafka/KafkaSourceConfig.java | 2 +- {pulsar-connect => pulsar-io}/pom.xml | 4 +-- .../rabbitmq/pom.xml | 8 ++--- .../pulsar/io}/rabbitmq/RabbitMQConfig.java | 2 +- .../pulsar/io}/rabbitmq/RabbitMQSource.java | 13 ++++++--- {pulsar-connect => pulsar-io}/twitter/pom.xml | 8 ++--- .../pulsar/io}/twitter/TwitterFireHose.java | 29 +++++++++---------- .../io}/twitter/TwitterFireHoseConfig.java | 2 +- 43 files changed, 128 insertions(+), 108 deletions(-) rename {pulsar-connect => pulsar-io}/aerospike/pom.xml (91%) rename {pulsar-connect/aerospike/src/main/java/org/apache/pulsar/connect => pulsar-io/aerospike/src/main/java/org/apache/pulsar/io}/aerospike/AerospikeSink.java (94%) rename {pulsar-connect/aerospike/src/main/java/org/apache/pulsar/connect => pulsar-io/aerospike/src/main/java/org/apache/pulsar/io}/aerospike/AerospikeSinkConfig.java (97%) rename {pulsar-connect => pulsar-io}/cassandra/pom.xml (91%) rename {pulsar-connect/cassandra/src/main/java/org/apache/pulsar/connect => pulsar-io/cassandra/src/main/java/org/apache/pulsar/io}/cassandra/CassandraSink.java (91%) rename {pulsar-connect/cassandra/src/main/java/org/apache/pulsar/connect => pulsar-io/cassandra/src/main/java/org/apache/pulsar/io}/cassandra/CassandraSinkConfig.java (97%) rename {pulsar-connect => pulsar-io}/core/pom.xml (90%) rename {pulsar-connect/core/src/main/java/org/apache/pulsar/connect => pulsar-io/core/src/main/java/org/apache/pulsar/io}/core/PushSource.java (98%) rename {pulsar-connect/core/src/main/java/org/apache/pulsar/connect => pulsar-io/core/src/main/java/org/apache/pulsar/io}/core/Record.java (96%) rename {pulsar-connect/core/src/main/java/org/apache/pulsar/connect => pulsar-io/core/src/main/java/org/apache/pulsar/io}/core/RecordContext.java (97%) rename {pulsar-connect/core/src/main/java/org/apache/pulsar/connect => pulsar-io/core/src/main/java/org/apache/pulsar/io}/core/Sink.java (97%) rename {pulsar-connect/core/src/main/java/org/apache/pulsar/connect => pulsar-io/core/src/main/java/org/apache/pulsar/io}/core/Source.java (97%) rename {pulsar-connect => pulsar-io}/kafka/pom.xml (91%) rename {pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect => pulsar-io/kafka/src/main/java/org/apache/pulsar/io}/kafka/KafkaSink.java (97%) rename {pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect => pulsar-io/kafka/src/main/java/org/apache/pulsar/io}/kafka/KafkaSinkConfig.java (98%) rename {pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect => pulsar-io/kafka/src/main/java/org/apache/pulsar/io}/kafka/KafkaSource.java (96%) rename {pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect => pulsar-io/kafka/src/main/java/org/apache/pulsar/io}/kafka/KafkaSourceConfig.java (98%) rename {pulsar-connect => pulsar-io}/pom.xml (94%) rename {pulsar-connect => pulsar-io}/rabbitmq/pom.xml (91%) rename {pulsar-connect/rabbitmq/src/main/java/org/apache/pulsar/connect => pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io}/rabbitmq/RabbitMQConfig.java (97%) rename {pulsar-connect/rabbitmq/src/main/java/org/apache/pulsar/connect => pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io}/rabbitmq/RabbitMQSource.java (91%) rename {pulsar-connect => pulsar-io}/twitter/pom.xml (91%) rename {pulsar-connect/twitter/src/main/java/org/apache/pulsar/connect => pulsar-io/twitter/src/main/java/org/apache/pulsar/io}/twitter/TwitterFireHose.java (97%) rename {pulsar-connect/twitter/src/main/java/org/apache/pulsar/connect => pulsar-io/twitter/src/main/java/org/apache/pulsar/io}/twitter/TwitterFireHoseConfig.java (98%) diff --git a/pom.xml b/pom.xml index e3205ea8e01ee..08acb3aaa9880 100644 --- a/pom.xml +++ b/pom.xml @@ -101,10 +101,10 @@ flexible messaging model and an intuitive client API. docker tests pulsar-log4j2-appender - + pulsar-functions - - pulsar-connect + + pulsar-io diff --git a/pulsar-client-admin-shaded-for-functions/pom.xml b/pulsar-client-admin-shaded-for-functions/pom.xml index d2507f38c55c9..e36681c572373 100644 --- a/pulsar-client-admin-shaded-for-functions/pom.xml +++ b/pulsar-client-admin-shaded-for-functions/pom.xml @@ -61,7 +61,7 @@ org.apache.pulsar:pulsar-common org.apache.bookkeeper:circe-checksum - org.apache.pulsar:pulsar-connect-core + org.apache.pulsar:pulsar-io-core org.apache.pulsar:pulsar-client-original org.apache.pulsar:pulsar-client-admin-original @@ -109,7 +109,7 @@ - org.apache.pulsar:pulsar-connect-core + org.apache.pulsar:pulsar-io-core ** diff --git a/pulsar-client-admin-shaded/pom.xml b/pulsar-client-admin-shaded/pom.xml index ba8da011966d9..18e1ba914a6f2 100644 --- a/pulsar-client-admin-shaded/pom.xml +++ b/pulsar-client-admin-shaded/pom.xml @@ -57,7 +57,7 @@ - org.apache.pulsar:pulsar-connect-core + org.apache.pulsar:pulsar-io-core org.apache.pulsar:pulsar-client-original org.apache.pulsar:pulsar-client-admin-original org.apache.commons:commons-lang3 @@ -94,7 +94,7 @@ - org.apache.pulsar:pulsar-connect-core + org.apache.pulsar:pulsar-io-core ** diff --git a/pulsar-client-shaded/pom.xml b/pulsar-client-shaded/pom.xml index 9369081dde78b..e1e6abf400839 100644 --- a/pulsar-client-shaded/pom.xml +++ b/pulsar-client-shaded/pom.xml @@ -59,7 +59,7 @@ - org.apache.pulsar:pulsar-connect-core + org.apache.pulsar:pulsar-io-core org.apache.pulsar:pulsar-client-original org.apache.commons:commons-lang3 commons-codec:commons-codec @@ -96,7 +96,7 @@ - org.apache.pulsar:pulsar-connect-core + org.apache.pulsar:pulsar-io-core ** diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java index 01ec16ce67e94..a6319c1a27461 100644 --- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java +++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java @@ -31,8 +31,6 @@ import org.apache.pulsar.client.admin.PulsarAdmin; import org.apache.pulsar.client.admin.internal.FunctionsImpl; import org.apache.pulsar.common.naming.TopicName; -import org.apache.pulsar.connect.core.Sink; -import org.apache.pulsar.connect.core.Source; import org.apache.pulsar.functions.api.utils.IdentityFunction; import org.apache.pulsar.functions.shaded.proto.Function; import org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails; @@ -41,7 +39,12 @@ import org.apache.pulsar.functions.shaded.proto.Function.SourceSpec; import org.apache.pulsar.functions.sink.PulsarSink; import org.apache.pulsar.functions.source.PulsarSource; -import org.apache.pulsar.functions.utils.*; +import org.apache.pulsar.functions.utils.FunctionConfig; +import org.apache.pulsar.functions.utils.Reflections; +import org.apache.pulsar.functions.utils.SinkConfig; +import org.apache.pulsar.functions.utils.Utils; +import org.apache.pulsar.io.core.Sink; +import org.apache.pulsar.io.core.Source; import java.io.File; import java.io.IOException; diff --git a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java index c651e373b1614..7ff908a923ba8 100644 --- a/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java +++ b/pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java @@ -31,8 +31,6 @@ import org.apache.pulsar.client.admin.PulsarAdmin; import org.apache.pulsar.client.admin.internal.FunctionsImpl; import org.apache.pulsar.common.naming.TopicName; -import org.apache.pulsar.connect.core.Sink; -import org.apache.pulsar.connect.core.Source; import org.apache.pulsar.functions.api.utils.IdentityFunction; import org.apache.pulsar.functions.shaded.proto.Function; import org.apache.pulsar.functions.shaded.proto.Function.FunctionDetails; @@ -41,7 +39,12 @@ import org.apache.pulsar.functions.shaded.proto.Function.SourceSpec; import org.apache.pulsar.functions.sink.PulsarSink; import org.apache.pulsar.functions.source.PulsarSource; -import org.apache.pulsar.functions.utils.*; +import org.apache.pulsar.functions.utils.FunctionConfig; +import org.apache.pulsar.functions.utils.Reflections; +import org.apache.pulsar.functions.utils.SourceConfig; +import org.apache.pulsar.functions.utils.Utils; +import org.apache.pulsar.io.core.Sink; +import org.apache.pulsar.io.core.Source; import java.io.File; import java.io.IOException; diff --git a/pulsar-client/pom.xml b/pulsar-client/pom.xml index 8fbb19687b4a8..653c17d88ecd9 100644 --- a/pulsar-client/pom.xml +++ b/pulsar-client/pom.xml @@ -41,7 +41,7 @@ ${project.groupId} - pulsar-connect-core + pulsar-io-core ${project.parent.version} diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageRecordImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageRecordImpl.java index 5e8128ac3e3a9..a27ac134c6370 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageRecordImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageRecordImpl.java @@ -20,7 +20,7 @@ import org.apache.pulsar.client.api.Message; import org.apache.pulsar.client.api.MessageId; -import org.apache.pulsar.connect.core.Record; +import org.apache.pulsar.io.core.Record; /** * Abstract class that implements message api and connect record api. diff --git a/pulsar-functions/instance/pom.xml b/pulsar-functions/instance/pom.xml index 2934e554185c8..bcdf780dc4e08 100644 --- a/pulsar-functions/instance/pom.xml +++ b/pulsar-functions/instance/pom.xml @@ -54,8 +54,8 @@ - org.apache.pulsar - pulsar-connect-core + ${project.groupId} + pulsar-io-core ${project.version} diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java index da6771a749b1f..5ab8d8548c272 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstance.java @@ -23,9 +23,9 @@ import lombok.extern.slf4j.Slf4j; import org.apache.pulsar.client.api.MessageId; import org.apache.pulsar.client.api.PulsarClient; -import org.apache.pulsar.connect.core.Source; import org.apache.pulsar.functions.api.Function; import org.apache.pulsar.functions.proto.InstanceCommunication; +import org.apache.pulsar.io.core.Source; import org.apache.pulsar.functions.source.PulsarSource; import org.slf4j.Logger; diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java index 3910c1edba8b8..36d6521e7f55a 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java @@ -50,9 +50,6 @@ import org.apache.pulsar.client.api.MessageId; import org.apache.pulsar.client.api.PulsarClient; import org.apache.pulsar.client.impl.PulsarClientImpl; -import org.apache.pulsar.connect.core.Record; -import org.apache.pulsar.connect.core.Sink; -import org.apache.pulsar.connect.core.Source; import org.apache.pulsar.functions.api.Function; import org.apache.pulsar.functions.api.utils.IdentityFunction; import org.apache.pulsar.functions.proto.InstanceCommunication; @@ -70,6 +67,9 @@ import org.apache.pulsar.functions.instance.state.StateContextImpl; import org.apache.pulsar.functions.utils.FunctionDetailsUtils; import org.apache.pulsar.functions.utils.Reflections; +import org.apache.pulsar.io.core.Record; +import org.apache.pulsar.io.core.Sink; +import org.apache.pulsar.io.core.Source; /** * A function container implemented using java thread. diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/DefaultRuntimeSink.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/DefaultRuntimeSink.java index 54e34c32274cb..86cd5b53b5f9f 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/DefaultRuntimeSink.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/DefaultRuntimeSink.java @@ -20,7 +20,7 @@ import java.util.Map; import java.util.concurrent.CompletableFuture; -import org.apache.pulsar.connect.core.Sink; +import org.apache.pulsar.io.core.Sink; /** * The default implementation of runtime sink. diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java index 84db3b245d4fa..61deeff9e4978 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java @@ -30,7 +30,6 @@ import org.apache.pulsar.client.api.Producer; import org.apache.pulsar.client.api.PulsarClient; import org.apache.pulsar.client.api.PulsarClientException; -import org.apache.pulsar.connect.core.RecordContext; import org.apache.pulsar.functions.api.SerDe; import org.apache.pulsar.functions.api.utils.DefaultSerDe; import org.apache.pulsar.functions.instance.InstanceUtils; @@ -39,6 +38,7 @@ import org.apache.pulsar.functions.instance.producers.Producers; import org.apache.pulsar.functions.source.PulsarRecord; import org.apache.pulsar.functions.utils.FunctionConfig; +import org.apache.pulsar.io.core.RecordContext; import java.util.Base64; import java.util.Map; diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSinkConfig.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSinkConfig.java index 1def3f1d2f98b..60baa1a5b1c63 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSinkConfig.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSinkConfig.java @@ -23,8 +23,6 @@ import lombok.ToString; import org.apache.pulsar.functions.utils.FunctionConfig; -import java.util.Map; - @Getter @Setter @ToString diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/RuntimeSink.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/RuntimeSink.java index fe47705be05f6..e9c8dc5b43e3a 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/RuntimeSink.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/RuntimeSink.java @@ -18,8 +18,8 @@ */ package org.apache.pulsar.functions.sink; -import org.apache.pulsar.connect.core.RecordContext; -import org.apache.pulsar.connect.core.Sink; +import org.apache.pulsar.io.core.RecordContext; +import org.apache.pulsar.io.core.Sink; /** * This class extends connect sink. diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarRecord.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarRecord.java index 7211db1ca8f11..d1d89da98b540 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarRecord.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarRecord.java @@ -24,7 +24,7 @@ import lombok.Getter; import lombok.ToString; import org.apache.pulsar.client.api.MessageId; -import org.apache.pulsar.connect.core.Record; +import org.apache.pulsar.io.core.Record; @Data @Builder diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java index a4a0485bd41b8..5cae9022365de 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSource.java @@ -26,12 +26,12 @@ import org.apache.pulsar.client.impl.MessageIdImpl; import org.apache.pulsar.client.impl.TopicMessageIdImpl; import org.apache.pulsar.client.impl.TopicMessageImpl; -import org.apache.pulsar.connect.core.Record; -import org.apache.pulsar.connect.core.Source; import org.apache.pulsar.functions.api.SerDe; import org.apache.pulsar.functions.api.utils.DefaultSerDe; import org.apache.pulsar.functions.instance.InstanceUtils; import org.apache.pulsar.functions.utils.FunctionConfig; +import org.apache.pulsar.io.core.Record; +import org.apache.pulsar.io.core.Source; import java.util.ArrayList; import java.util.HashMap; diff --git a/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/sink/DefaultRuntimeSinkTest.java b/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/sink/DefaultRuntimeSinkTest.java index 2ba4e3f8350b3..018a9686329eb 100644 --- a/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/sink/DefaultRuntimeSinkTest.java +++ b/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/sink/DefaultRuntimeSinkTest.java @@ -29,8 +29,8 @@ import java.util.Collections; import java.util.Map; import java.util.concurrent.CompletableFuture; -import org.apache.pulsar.connect.core.RecordContext; -import org.apache.pulsar.connect.core.Sink; +import org.apache.pulsar.io.core.RecordContext; +import org.apache.pulsar.io.core.Sink; import org.testng.annotations.BeforeMethod; import org.testng.annotations.Test; diff --git a/pulsar-functions/utils/pom.xml b/pulsar-functions/utils/pom.xml index 029979b95799c..6c8032cb48275 100644 --- a/pulsar-functions/utils/pom.xml +++ b/pulsar-functions/utils/pom.xml @@ -49,7 +49,7 @@ org.apache.pulsar - pulsar-connect-core + pulsar-io-core org.apache.pulsar diff --git a/pulsar-connect/aerospike/pom.xml b/pulsar-io/aerospike/pom.xml similarity index 91% rename from pulsar-connect/aerospike/pom.xml rename to pulsar-io/aerospike/pom.xml index f1e2147710ac7..63aa761131224 100644 --- a/pulsar-connect/aerospike/pom.xml +++ b/pulsar-io/aerospike/pom.xml @@ -23,18 +23,18 @@ 4.0.0 org.apache.pulsar - pulsar-connect + pulsar-io 2.1.0-incubating-SNAPSHOT - pulsar-connect-aerospike - Pulsar Connect :: Aerospike + pulsar-io-aerospike + Pulsar IO :: Aerospike ${project.groupId} - pulsar-connect-core + pulsar-io-core ${project.version} diff --git a/pulsar-connect/aerospike/src/main/java/org/apache/pulsar/connect/aerospike/AerospikeSink.java b/pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeSink.java similarity index 94% rename from pulsar-connect/aerospike/src/main/java/org/apache/pulsar/connect/aerospike/AerospikeSink.java rename to pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeSink.java index daab7667fdbb4..34df2aacae976 100644 --- a/pulsar-connect/aerospike/src/main/java/org/apache/pulsar/connect/aerospike/AerospikeSink.java +++ b/pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeSink.java @@ -17,14 +17,14 @@ * under the License. */ -package org.apache.pulsar.connect.aerospike; - -import java.util.Map; -import java.util.concurrent.BlockingQueue; -import java.util.concurrent.CompletableFuture; -import java.util.concurrent.LinkedBlockingDeque; - -import com.aerospike.client.*; +package org.apache.pulsar.io.aerospike; + +import com.aerospike.client.AerospikeClient; +import com.aerospike.client.AerospikeException; +import com.aerospike.client.Bin; +import com.aerospike.client.Host; +import com.aerospike.client.Key; +import com.aerospike.client.Value; import com.aerospike.client.async.EventLoop; import com.aerospike.client.async.EventPolicy; import com.aerospike.client.async.NioEventLoops; @@ -32,10 +32,15 @@ import com.aerospike.client.policy.ClientPolicy; import com.aerospike.client.policy.WritePolicy; import org.apache.pulsar.common.util.KeyValue; -import org.apache.pulsar.connect.core.Sink; +import org.apache.pulsar.io.core.Sink; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import java.util.Map; +import java.util.concurrent.BlockingQueue; +import java.util.concurrent.CompletableFuture; +import java.util.concurrent.LinkedBlockingDeque; + /** * Simple AeroSpike sink */ diff --git a/pulsar-connect/aerospike/src/main/java/org/apache/pulsar/connect/aerospike/AerospikeSinkConfig.java b/pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeSinkConfig.java similarity index 97% rename from pulsar-connect/aerospike/src/main/java/org/apache/pulsar/connect/aerospike/AerospikeSinkConfig.java rename to pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeSinkConfig.java index ef02c80ef3f4b..931d28031db11 100644 --- a/pulsar-connect/aerospike/src/main/java/org/apache/pulsar/connect/aerospike/AerospikeSinkConfig.java +++ b/pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike/AerospikeSinkConfig.java @@ -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; diff --git a/pulsar-connect/cassandra/pom.xml b/pulsar-io/cassandra/pom.xml similarity index 91% rename from pulsar-connect/cassandra/pom.xml rename to pulsar-io/cassandra/pom.xml index 4da66ecb2266b..d997f06f0d390 100644 --- a/pulsar-connect/cassandra/pom.xml +++ b/pulsar-io/cassandra/pom.xml @@ -23,18 +23,18 @@ 4.0.0 org.apache.pulsar - pulsar-connect + pulsar-io 2.1.0-incubating-SNAPSHOT - pulsar-connect-cassandra - Pulsar Connect :: Cassandra + pulsar-io-cassandra + Pulsar IO :: Cassandra ${project.groupId} - pulsar-connect-core + pulsar-io-core ${project.version} diff --git a/pulsar-connect/cassandra/src/main/java/org/apache/pulsar/connect/cassandra/CassandraSink.java b/pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraSink.java similarity index 91% rename from pulsar-connect/cassandra/src/main/java/org/apache/pulsar/connect/cassandra/CassandraSink.java rename to pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraSink.java index bc87ec6b55011..14abc9bd64299 100644 --- a/pulsar-connect/cassandra/src/main/java/org/apache/pulsar/connect/cassandra/CassandraSink.java +++ b/pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraSink.java @@ -17,13 +17,18 @@ * under the License. */ -package org.apache.pulsar.connect.cassandra; +package org.apache.pulsar.io.cassandra; -import com.datastax.driver.core.*; +import com.datastax.driver.core.BoundStatement; +import com.datastax.driver.core.Cluster; +import com.datastax.driver.core.PreparedStatement; +import com.datastax.driver.core.ResultSet; +import com.datastax.driver.core.ResultSetFuture; +import com.datastax.driver.core.Session; import com.google.common.util.concurrent.FutureCallback; import com.google.common.util.concurrent.Futures; import org.apache.pulsar.common.util.KeyValue; -import org.apache.pulsar.connect.core.Sink; +import org.apache.pulsar.io.core.Sink; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/pulsar-connect/cassandra/src/main/java/org/apache/pulsar/connect/cassandra/CassandraSinkConfig.java b/pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraSinkConfig.java similarity index 97% rename from pulsar-connect/cassandra/src/main/java/org/apache/pulsar/connect/cassandra/CassandraSinkConfig.java rename to pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraSinkConfig.java index 5bcfb52b76bbd..c3f6587e0669f 100644 --- a/pulsar-connect/cassandra/src/main/java/org/apache/pulsar/connect/cassandra/CassandraSinkConfig.java +++ b/pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra/CassandraSinkConfig.java @@ -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; diff --git a/pulsar-connect/core/pom.xml b/pulsar-io/core/pom.xml similarity index 90% rename from pulsar-connect/core/pom.xml rename to pulsar-io/core/pom.xml index e2f9f58be179e..4bf1439eb493b 100644 --- a/pulsar-connect/core/pom.xml +++ b/pulsar-io/core/pom.xml @@ -23,11 +23,11 @@ 4.0.0 org.apache.pulsar - pulsar-connect + pulsar-io 2.1.0-incubating-SNAPSHOT - pulsar-connect-core - Pulsar Connect :: Connect + pulsar-io-core + Pulsar IO :: IO diff --git a/pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/PushSource.java b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/PushSource.java similarity index 98% rename from pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/PushSource.java rename to pulsar-io/core/src/main/java/org/apache/pulsar/io/core/PushSource.java index 4e6f64bba3100..811148872f5ce 100644 --- a/pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/PushSource.java +++ b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/PushSource.java @@ -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; diff --git a/pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/Record.java b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Record.java similarity index 96% rename from pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/Record.java rename to pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Record.java index c5137ea386186..08c78bfdeffaf 100644 --- a/pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/Record.java +++ b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Record.java @@ -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; /** * Pulsar Connect's Record interface. Record encapsulates the diff --git a/pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/RecordContext.java b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/RecordContext.java similarity index 97% rename from pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/RecordContext.java rename to pulsar-io/core/src/main/java/org/apache/pulsar/io/core/RecordContext.java index 094ca8c3e7b63..09ce8d10aba41 100644 --- a/pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/RecordContext.java +++ b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/RecordContext.java @@ -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; /** * A source context that can be used by the runtime to interact with source. diff --git a/pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/Sink.java b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java similarity index 97% rename from pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/Sink.java rename to pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java index cd2d63d242209..48a58e7146a8c 100644 --- a/pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/Sink.java +++ b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Sink.java @@ -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; diff --git a/pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/Source.java b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Source.java similarity index 97% rename from pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/Source.java rename to pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Source.java index 2a4133632eb61..e9ef0447e0890 100644 --- a/pulsar-connect/core/src/main/java/org/apache/pulsar/connect/core/Source.java +++ b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/Source.java @@ -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; diff --git a/pulsar-connect/kafka/pom.xml b/pulsar-io/kafka/pom.xml similarity index 91% rename from pulsar-connect/kafka/pom.xml rename to pulsar-io/kafka/pom.xml index 2c3b4fae80b15..f5a52509fbbb4 100644 --- a/pulsar-connect/kafka/pom.xml +++ b/pulsar-io/kafka/pom.xml @@ -23,18 +23,18 @@ 4.0.0 org.apache.pulsar - pulsar-connect + pulsar-io 2.1.0-incubating-SNAPSHOT - pulsar-connect-kafka - Pulsar Connect :: Kafka + pulsar-io-kafka + Pulsar IO :: Kafka ${project.groupId} - pulsar-connect-core + pulsar-io-core ${project.version} diff --git a/pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSink.java b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSink.java similarity index 97% rename from pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSink.java rename to pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSink.java index fc8e2afddf1eb..13d65ab94da0b 100644 --- a/pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSink.java +++ b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSink.java @@ -17,14 +17,14 @@ * under the License. */ -package org.apache.pulsar.connect.kafka; +package org.apache.pulsar.io.kafka; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.clients.producer.ProducerRecord; import org.apache.pulsar.common.util.KeyValue; -import org.apache.pulsar.connect.core.Sink; +import org.apache.pulsar.io.core.Sink; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSinkConfig.java b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSinkConfig.java similarity index 98% rename from pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSinkConfig.java rename to pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSinkConfig.java index 6da494ea97e93..23a23edc01863 100644 --- a/pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSinkConfig.java +++ b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSinkConfig.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.pulsar.connect.kafka; +package org.apache.pulsar.io.kafka; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.dataformat.yaml.YAMLFactory; diff --git a/pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSource.java b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSource.java similarity index 96% rename from pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSource.java rename to pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSource.java index 7520ee6ff7f77..a1579557078df 100644 --- a/pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSource.java +++ b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSource.java @@ -17,19 +17,21 @@ * under the License. */ -package org.apache.pulsar.connect.kafka; +package org.apache.pulsar.io.kafka; import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.clients.consumer.KafkaConsumer; -import org.apache.pulsar.connect.core.Record; -import org.apache.pulsar.connect.core.PushSource; +import org.apache.pulsar.io.core.PushSource; +import org.apache.pulsar.io.core.Record; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.util.*; +import java.util.Arrays; +import java.util.Map; +import java.util.Properties; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; diff --git a/pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSourceConfig.java b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java similarity index 98% rename from pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSourceConfig.java rename to pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java index 0d41b1b8ba80e..62f6bd584729a 100644 --- a/pulsar-connect/kafka/src/main/java/org/apache/pulsar/connect/kafka/KafkaSourceConfig.java +++ b/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaSourceConfig.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.pulsar.connect.kafka; +package org.apache.pulsar.io.kafka; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.dataformat.yaml.YAMLFactory; diff --git a/pulsar-connect/pom.xml b/pulsar-io/pom.xml similarity index 94% rename from pulsar-connect/pom.xml rename to pulsar-io/pom.xml index 1e7d4be7a79c8..fb63146b9c2f3 100644 --- a/pulsar-connect/pom.xml +++ b/pulsar-io/pom.xml @@ -28,8 +28,8 @@ 2.1.0-incubating-SNAPSHOT - pulsar-connect - Pulsar Connect :: Parent + pulsar-io + Pulsar IO :: Parent core diff --git a/pulsar-connect/rabbitmq/pom.xml b/pulsar-io/rabbitmq/pom.xml similarity index 91% rename from pulsar-connect/rabbitmq/pom.xml rename to pulsar-io/rabbitmq/pom.xml index 97b27f6962f2f..ff7111f35d71d 100644 --- a/pulsar-connect/rabbitmq/pom.xml +++ b/pulsar-io/rabbitmq/pom.xml @@ -23,18 +23,18 @@ 4.0.0 org.apache.pulsar - pulsar-connect + pulsar-io 2.1.0-incubating-SNAPSHOT - pulsar-connect-rabbitmq - Pulsar Connect :: RabbitMQ + pulsar-io-rabbitmq + Pulsar IO :: RabbitMQ ${project.groupId} - pulsar-connect-core + pulsar-io-core ${project.version} diff --git a/pulsar-connect/rabbitmq/src/main/java/org/apache/pulsar/connect/rabbitmq/RabbitMQConfig.java b/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQConfig.java similarity index 97% rename from pulsar-connect/rabbitmq/src/main/java/org/apache/pulsar/connect/rabbitmq/RabbitMQConfig.java rename to pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQConfig.java index e76b03f8c077b..33bc9c12cfe22 100644 --- a/pulsar-connect/rabbitmq/src/main/java/org/apache/pulsar/connect/rabbitmq/RabbitMQConfig.java +++ b/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQConfig.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.pulsar.connect.rabbitmq; +package org.apache.pulsar.io.rabbitmq; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.dataformat.yaml.YAMLFactory; diff --git a/pulsar-connect/rabbitmq/src/main/java/org/apache/pulsar/connect/rabbitmq/RabbitMQSource.java b/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java similarity index 91% rename from pulsar-connect/rabbitmq/src/main/java/org/apache/pulsar/connect/rabbitmq/RabbitMQSource.java rename to pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java index c548f998cf250..4b9ca98e1eb69 100644 --- a/pulsar-connect/rabbitmq/src/main/java/org/apache/pulsar/connect/rabbitmq/RabbitMQSource.java +++ b/pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq/RabbitMQSource.java @@ -17,11 +17,16 @@ * under the License. */ -package org.apache.pulsar.connect.rabbitmq; +package org.apache.pulsar.io.rabbitmq; -import com.rabbitmq.client.*; -import org.apache.pulsar.connect.core.Record; -import org.apache.pulsar.connect.core.PushSource; +import com.rabbitmq.client.AMQP; +import com.rabbitmq.client.Channel; +import com.rabbitmq.client.Connection; +import com.rabbitmq.client.ConnectionFactory; +import com.rabbitmq.client.DefaultConsumer; +import com.rabbitmq.client.Envelope; +import org.apache.pulsar.io.core.PushSource; +import org.apache.pulsar.io.core.Record; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/pulsar-connect/twitter/pom.xml b/pulsar-io/twitter/pom.xml similarity index 91% rename from pulsar-connect/twitter/pom.xml rename to pulsar-io/twitter/pom.xml index 36b0bd825efff..15ee16336258e 100644 --- a/pulsar-connect/twitter/pom.xml +++ b/pulsar-io/twitter/pom.xml @@ -23,18 +23,18 @@ 4.0.0 org.apache.pulsar - pulsar-connect + pulsar-io 2.1.0-incubating-SNAPSHOT - pulsar-connect-twitter - Pulsar Connect :: Twitter + pulsar-io-twitter + Pulsar IO :: Twitter ${project.groupId} - pulsar-connect-core + pulsar-io-core ${project.version} diff --git a/pulsar-connect/twitter/src/main/java/org/apache/pulsar/connect/twitter/TwitterFireHose.java b/pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java similarity index 97% rename from pulsar-connect/twitter/src/main/java/org/apache/pulsar/connect/twitter/TwitterFireHose.java rename to pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java index 1dcbb171047e2..05e2b08a5f4b1 100644 --- a/pulsar-connect/twitter/src/main/java/org/apache/pulsar/connect/twitter/TwitterFireHose.java +++ b/pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHose.java @@ -17,29 +17,28 @@ * under the License. */ -package org.apache.pulsar.connect.twitter; +package org.apache.pulsar.io.twitter; -import java.io.IOException; -import java.io.InputStream; -import java.io.Serializable; -import java.util.Map; -import java.util.concurrent.CompletableFuture; -import java.util.function.Function; - -import org.apache.pulsar.connect.core.Record; -import org.apache.pulsar.connect.core.PushSource; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.twitter.hbc.core.endpoint.StatusesSampleEndpoint; -import com.twitter.hbc.core.endpoint.StreamingEndpoint; import com.twitter.hbc.ClientBuilder; import com.twitter.hbc.common.DelimitedStreamReader; import com.twitter.hbc.core.Constants; +import com.twitter.hbc.core.endpoint.StatusesSampleEndpoint; +import com.twitter.hbc.core.endpoint.StreamingEndpoint; import com.twitter.hbc.core.processor.HosebirdMessageProcessor; import com.twitter.hbc.httpclient.BasicClient; import com.twitter.hbc.httpclient.auth.Authentication; import com.twitter.hbc.httpclient.auth.OAuth1; +import org.apache.pulsar.io.core.PushSource; +import org.apache.pulsar.io.core.Record; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.io.IOException; +import java.io.InputStream; +import java.io.Serializable; +import java.util.Map; +import java.util.concurrent.CompletableFuture; +import java.util.function.Function; /** * Simple Push based Twitter FireHose Source diff --git a/pulsar-connect/twitter/src/main/java/org/apache/pulsar/connect/twitter/TwitterFireHoseConfig.java b/pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHoseConfig.java similarity index 98% rename from pulsar-connect/twitter/src/main/java/org/apache/pulsar/connect/twitter/TwitterFireHoseConfig.java rename to pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHoseConfig.java index 57782e2e08d6a..83f1bafdf4b8f 100644 --- a/pulsar-connect/twitter/src/main/java/org/apache/pulsar/connect/twitter/TwitterFireHoseConfig.java +++ b/pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/TwitterFireHoseConfig.java @@ -17,7 +17,7 @@ * under the License. */ -package org.apache.pulsar.connect.twitter; +package org.apache.pulsar.io.twitter; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;