Update package name

Author: LJW21-02

examples/kafka/src/main/java/org/apache/iotdb/kafka/relational/RelationalConstant.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.example.relational;
+package org.apache.iotdb.kafka.relational;
 
 public class RelationalConstant {
 

examples/kafka/src/main/java/org/apache/iotdb/kafka/relational/RelationalConsumer.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.example.relational;
+package org.apache.iotdb.kafka.relational;
 
 import org.apache.iotdb.isession.ITableSession;
 import org.apache.iotdb.isession.pool.ITableSessionPool;

examples/kafka/src/main/java/org/apache/iotdb/kafka/relational/RelationalConsumerThread.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.example.relational;
+package org.apache.iotdb.kafka.relational;
 
 import org.apache.iotdb.isession.ITableSession;
 import org.apache.iotdb.isession.pool.ITableSessionPool;

examples/kafka/src/main/java/org/apache/iotdb/kafka/relational/RelationalProducer.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.example.relational;
+package org.apache.iotdb.kafka.relational;
 
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerConfig;

examples/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/relational/RelationalConstant.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.example.relational;
+package org.apache.iotdb.rabbitmq.relational;
 
 public class RelationalConstant {
 

examples/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/relational/RelationalRabbitMQConsumer.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.example.relational;
+package org.apache.iotdb.rabbitmq.relational;
 
 import com.rabbitmq.client.*;
 import org.apache.iotdb.isession.ITableSession;

examples/rabbitmq/src/main/java/org/apache/iotdb/rabbitmq/relational/RelationalRabbitMQProducer.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.example.relational;
+package org.apache.iotdb.rabbitmq.relational;
 
 import com.rabbitmq.client.*;
 import org.example.RabbitMQChannelUtils;

examples/rocketmq/src/main/java/org/apache/iotdb/rocketmq/relational/RelationalConstant.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.example.relational;
+package org.apache.iotdb.rocketmq.relational;
 
 public class RelationalConstant {
 

examples/rocketmq/src/main/java/org/apache/iotdb/rocketmq/relational/RelationalRocketMQConsumer.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.example.relational;
+package org.apache.iotdb.rocketmq.relational;
 
 import org.apache.iotdb.isession.ITableSession;
 import org.apache.iotdb.rpc.IoTDBConnectionException;

examples/rocketmq/src/main/java/org/apache/iotdb/rocketmq/relational/RelationalRocketMQProducer.java

@@ -17,7 +17,7 @@
  * under the License.
  */
 
-package org.example.relational;
+package org.apache.iotdb.rocketmq.relational;
 
 import org.apache.rocketmq.client.exception.MQBrokerException;
 import org.apache.rocketmq.client.exception.MQClientException;