You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yu...@apache.org on 2021/07/15 06:27:04 UTC
[iotdb] branch IoTDB-1499-0.12 created (now e5b8502)
This is an automated email from the ASF dual-hosted git repository.
yuyuankang pushed a change to branch IoTDB-1499-0.12
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at e5b8502 remve series registeration
This branch includes the following new commits:
new 3689874 *.md
new e5b8502 remve series registeration
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/02: *.md
Posted by yu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
yuyuankang pushed a commit to branch IoTDB-1499-0.12
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 36898744ad03251b81a62e3a406ad1bac13f9c0f
Author: Ring-k <yu...@hotmail.com>
AuthorDate: Thu Jul 15 14:25:22 2021 +0800
*.md
---
.../java/org/apache/iotdb/flink/FlinkIoTDBSink.java | 1 -
.../src/main/java/org/apache/iotdb/flink/IoTDBSink.java | 17 -----------------
.../apache/iotdb/flink/options/IoTDBSinkOptions.java | 11 -----------
3 files changed, 29 deletions(-)
diff --git a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java
index 5620949..b061ad2 100644
--- a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java
+++ b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java
@@ -41,7 +41,6 @@ public class FlinkIoTDBSink {
options.setPort(6667);
options.setUser("root");
options.setPassword("root");
- options.setStorageGroup("root.sg");
// If the server enables auto_create_schema, then we do not need to register all timeseries
// here.
diff --git a/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java b/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
index eaba61d..ce51e25 100644
--- a/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
+++ b/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
@@ -19,8 +19,6 @@
package org.apache.iotdb.flink;
import org.apache.iotdb.flink.options.IoTDBSinkOptions;
-import org.apache.iotdb.rpc.StatementExecutionException;
-import org.apache.iotdb.rpc.TSStatusCode;
import org.apache.iotdb.session.pool.SessionPool;
import org.apache.iotdb.tsfile.common.constant.TsFileConstant;
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
@@ -86,21 +84,6 @@ public class IoTDBSink<IN> extends RichSinkFunction<IN> {
options.getUser(),
options.getPassword(),
sessionPoolSize);
-
- try {
- pool.setStorageGroup(options.getStorageGroup());
- } catch (StatementExecutionException e) {
- if (e.getStatusCode() != TSStatusCode.PATH_ALREADY_EXIST_ERROR.getStatusCode()) {
- throw e;
- }
- }
-
- for (IoTDBSinkOptions.TimeseriesOption option : options.getTimeseriesOptionList()) {
- if (!pool.checkTimeseriesExists(option.getPath())) {
- pool.createTimeseries(
- option.getPath(), option.getDataType(), option.getEncoding(), option.getCompressor());
- }
- }
}
void initScheduler() {
diff --git a/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSinkOptions.java b/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSinkOptions.java
index 60bab60..1a709b0 100644
--- a/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSinkOptions.java
+++ b/flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/options/IoTDBSinkOptions.java
@@ -28,7 +28,6 @@ import java.util.List;
/** IoTDBOptions describes the configuration related information for IoTDB and timeseries. */
public class IoTDBSinkOptions extends IoTDBOptions {
- private String storageGroup;
private List<TimeseriesOption> timeseriesOptionList;
public IoTDBSinkOptions() {}
@@ -38,21 +37,11 @@ public class IoTDBSinkOptions extends IoTDBOptions {
int port,
String user,
String password,
- String storageGroup,
List<TimeseriesOption> timeseriesOptionList) {
super(host, port, user, password);
- this.storageGroup = storageGroup;
this.timeseriesOptionList = timeseriesOptionList;
}
- public String getStorageGroup() {
- return storageGroup;
- }
-
- public void setStorageGroup(String storageGroup) {
- this.storageGroup = storageGroup;
- }
-
public List<TimeseriesOption> getTimeseriesOptionList() {
return timeseriesOptionList;
}
[iotdb] 02/02: remve series registeration
Posted by yu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
yuyuankang pushed a commit to branch IoTDB-1499-0.12
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e5b8502fc5cfa9206453b6e774c82b19e4110cc5
Author: Ring-k <yu...@hotmail.com>
AuthorDate: Thu Jul 15 14:26:18 2021 +0800
remve series registeration
---
docs/UserGuide/Ecosystem Integration/Flink IoTDB.md | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/docs/UserGuide/Ecosystem Integration/Flink IoTDB.md b/docs/UserGuide/Ecosystem Integration/Flink IoTDB.md
index 41cfbce..5a5520a 100644
--- a/docs/UserGuide/Ecosystem Integration/Flink IoTDB.md
+++ b/docs/UserGuide/Ecosystem Integration/Flink IoTDB.md
@@ -35,6 +35,8 @@ This example shows a case that sends data to a IoTDB server from a Flink job:
- A simulated Source `SensorSource` generates data points per 1 second.
- Flink uses `IoTDBSink` to consume the generated data points and write the data into IoTDB.
+It is noteworthy that to use IoTDBSink, schema auto-creation in IoTDB should be enabled.
+
```java
import org.apache.iotdb.tsfile.file.metadata.enums.CompressionType;
import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
@@ -59,7 +61,6 @@ public class FlinkIoTDBSink {
options.setPort(6667);
options.setUser("root");
options.setPassword("root");
- options.setStorageGroup("root.sg");
// If the server enables auto_create_schema, then we do not need to register all timeseries
// here.