Change package to com.datastax.oss.pulsar.transforms

datastax · Jun 27, 2022 · 8eda3ac · 8eda3ac
1 parent 16b5c28
commit 8eda3ac
Show file tree

Hide file tree

Showing 15 changed files with 15 additions and 15 deletions.
diff --git a/...pulsar/functions/transforms/CastStep.java → ...pulsar/functions/transforms/CastStep.java b/...pulsar/functions/transforms/CastStep.java → ...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/...r/functions/transforms/DropFieldStep.java → ...r/functions/transforms/DropFieldStep.java b/...r/functions/transforms/DropFieldStep.java → ...r/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/...nctions/transforms/MergeKeyValueStep.java → ...nctions/transforms/MergeKeyValueStep.java b/...nctions/transforms/MergeKeyValueStep.java → ...nctions/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/...unctions/transforms/TransformContext.java → ...unctions/transforms/TransformContext.java b/...unctions/transforms/TransformContext.java → ...unctions/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/...nctions/transforms/TransformFunction.java → ...nctions/transforms/TransformFunction.java b/...nctions/transforms/TransformFunction.java → ...nctions/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/...r/functions/transforms/TransformStep.java → ...r/functions/transforms/TransformStep.java b/...r/functions/transforms/TransformStep.java → ...r/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/...ctions/transforms/UnwrapKeyValueStep.java → ...ctions/transforms/UnwrapKeyValueStep.java b/...ctions/transforms/UnwrapKeyValueStep.java → ...ctions/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/...ar/functions/transforms/package-info.java → ...ar/functions/transforms/package-info.java b/...ar/functions/transforms/package-info.java → ...ar/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
@@ -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/...ar/functions/transforms/CastStepTest.java → ...ar/functions/transforms/CastStepTest.java b/...ar/functions/transforms/CastStepTest.java → ...ar/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/...nctions/transforms/DropFieldStepTest.java → ...nctions/transforms/DropFieldStepTest.java b/...nctions/transforms/DropFieldStepTest.java → ...nctions/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/...ons/transforms/MergeKeyValueStepTest.java → ...ons/transforms/MergeKeyValueStepTest.java b/...ons/transforms/MergeKeyValueStepTest.java → ...ons/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/...ons/transforms/TransformFunctionTest.java → ...ons/transforms/TransformFunctionTest.java b/...ons/transforms/TransformFunctionTest.java → ...ons/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/...ns/transforms/UnwrapKeyValueStepTest.java → ...ns/transforms/UnwrapKeyValueStepTest.java b/...ns/transforms/UnwrapKeyValueStepTest.java → ...ns/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/...ax/pulsar/functions/transforms/Utils.java → ...ss/pulsar/functions/transforms/Utils.java b/...ax/pulsar/functions/transforms/Utils.java → ...ss/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;