diff --git a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/CastStep.java b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/CastStep.java similarity index 97% rename from pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/CastStep.java rename to pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/CastStep.java index 417e062c..83ff6f87 100644 --- a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/CastStep.java +++ b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/CastStep.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; import lombok.extern.slf4j.Slf4j; import org.apache.pulsar.client.api.Schema; diff --git a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/DropFieldStep.java b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/DropFieldStep.java similarity index 98% rename from pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/DropFieldStep.java rename to pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/DropFieldStep.java index 3dbd698a..fd8d2688 100644 --- a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/DropFieldStep.java +++ b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/DropFieldStep.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; import java.util.List; import java.util.Map; diff --git a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/MergeKeyValueStep.java b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/MergeKeyValueStep.java similarity index 98% rename from pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/MergeKeyValueStep.java rename to pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/MergeKeyValueStep.java index 0aa1d20a..6f0217c3 100644 --- a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/MergeKeyValueStep.java +++ b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/MergeKeyValueStep.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; import java.util.List; import java.util.Map; diff --git a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/TransformContext.java b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/TransformContext.java similarity index 99% rename from pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/TransformContext.java rename to pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/TransformContext.java index 4be983ce..c5521722 100644 --- a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/TransformContext.java +++ b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/TransformContext.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; import java.io.ByteArrayOutputStream; import java.io.IOException; diff --git a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/TransformFunction.java b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/TransformFunction.java similarity index 99% rename from pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/TransformFunction.java rename to pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/TransformFunction.java index 1690ff27..cb62e8ec 100644 --- a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/TransformFunction.java +++ b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/TransformFunction.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; import com.google.gson.Gson; import com.google.gson.reflect.TypeToken; diff --git a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/TransformStep.java b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/TransformStep.java similarity index 92% rename from pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/TransformStep.java rename to pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/TransformStep.java index 9b57fffd..4818fe1e 100644 --- a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/TransformStep.java +++ b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/TransformStep.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; public interface TransformStep { void process(TransformContext transformContext) throws Exception; diff --git a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/UnwrapKeyValueStep.java b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/UnwrapKeyValueStep.java similarity index 96% rename from pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/UnwrapKeyValueStep.java rename to pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/UnwrapKeyValueStep.java index cc1f911c..56d74ce7 100644 --- a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/UnwrapKeyValueStep.java +++ b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/UnwrapKeyValueStep.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; public class UnwrapKeyValueStep implements TransformStep { diff --git a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/package-info.java b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/package-info.java similarity index 91% rename from pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/package-info.java rename to pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/package-info.java index 3ce15751..67cfe578 100644 --- a/pulsar-transformations/src/main/java/com/datastax/pulsar/functions/transforms/package-info.java +++ b/pulsar-transformations/src/main/java/com/datastax/oss/pulsar/functions/transforms/package-info.java @@ -13,4 +13,4 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; diff --git a/pulsar-transformations/src/main/resources/META-INF/services/pulsar-io.yaml b/pulsar-transformations/src/main/resources/META-INF/services/pulsar-io.yaml index 85ee9c90..1bfaf9d5 100644 --- a/pulsar-transformations/src/main/resources/META-INF/services/pulsar-io.yaml +++ b/pulsar-transformations/src/main/resources/META-INF/services/pulsar-io.yaml @@ -19,4 +19,4 @@ name: transforms description: Transformation function -functionClass: com.datastax.pulsar.functions.transforms.TransformFunction +functionClass: com.datastax.oss.pulsar.functions.transforms.TransformFunction diff --git a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/CastStepTest.java b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/CastStepTest.java similarity index 97% rename from pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/CastStepTest.java rename to pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/CastStepTest.java index ca31f01f..8543a794 100644 --- a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/CastStepTest.java +++ b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/CastStepTest.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; import static org.testng.Assert.assertEquals; import static org.testng.Assert.assertSame; diff --git a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/DropFieldStepTest.java b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/DropFieldStepTest.java similarity index 99% rename from pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/DropFieldStepTest.java rename to pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/DropFieldStepTest.java index 0730d17b..bcf6cdcc 100644 --- a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/DropFieldStepTest.java +++ b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/DropFieldStepTest.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; import static org.testng.Assert.assertEquals; import static org.testng.Assert.assertNotSame; diff --git a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/MergeKeyValueStepTest.java b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/MergeKeyValueStepTest.java similarity index 98% rename from pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/MergeKeyValueStepTest.java rename to pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/MergeKeyValueStepTest.java index def67357..2e35f765 100644 --- a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/MergeKeyValueStepTest.java +++ b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/MergeKeyValueStepTest.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; import static org.testng.Assert.assertEquals; import static org.testng.Assert.assertNotSame; diff --git a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/TransformFunctionTest.java b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/TransformFunctionTest.java similarity index 99% rename from pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/TransformFunctionTest.java rename to pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/TransformFunctionTest.java index 12419d7a..af53c866 100644 --- a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/TransformFunctionTest.java +++ b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/TransformFunctionTest.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; import static org.testng.Assert.assertEquals; import static org.testng.Assert.assertThrows; diff --git a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/UnwrapKeyValueStepTest.java b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/UnwrapKeyValueStepTest.java similarity index 97% rename from pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/UnwrapKeyValueStepTest.java rename to pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/UnwrapKeyValueStepTest.java index 358ee2a7..1355c6d5 100644 --- a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/UnwrapKeyValueStepTest.java +++ b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/UnwrapKeyValueStepTest.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; import static org.junit.Assert.assertSame; import static org.testng.Assert.assertEquals; diff --git a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/Utils.java b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/Utils.java similarity index 99% rename from pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/Utils.java rename to pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/Utils.java index 6c7c229f..f31ed3b4 100644 --- a/pulsar-transformations/src/test/java/com/datastax/pulsar/functions/transforms/Utils.java +++ b/pulsar-transformations/src/test/java/com/datastax/oss/pulsar/functions/transforms/Utils.java @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package com.datastax.pulsar.functions.transforms; +package com.datastax.oss.pulsar.functions.transforms; import java.io.IOException; import java.nio.ByteBuffer;