This is an automated email from the ASF dual-hosted git repository.
xuekaifeng pushed a change to branch xkf_id_table
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from a5c6a1e add test
add 45a6658 [IoTDB-1989] IoTDB support insert data from Spark (#4477)
add a583ead [IOTDB-1901] Compatibility of Apache IoTDB with InfluxDB -
Server-side InfluxDB Metadata Manager (#4460)
add 88f9a6b memory leak fix: replace RandomDeleteCache with LoadingCache
as its size can't limit in … (#4526)
add 7aabea4 [IOTDB-2102] Push down limit to ReadTask in
RawDataSetWithoutValueFilter (#4534)
new 233bd92 Merge branch 'master' of git://github.com/apache/iotdb into
xkf_id_table
The 1 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.
Summary of changes:
.../protocol/influxdb}/input/InfluxLineProtocol.g4 | 2 +-
.../iotdb/cluster/server/ClusterRPCService.java | 2 +-
.../iotdb/cluster/server/ClusterTSServiceImpl.java | 2 +-
docker/ReadMe.md | 1 +
docker/src/main/Dockerfile-single | 1 +
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 53 ++++-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 58 ++++-
influxdb-protocol/pom.xml | 85 ++++----
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 87 ++------
.../iotdb/influxdb/IoTDBInfluxDBFactory.java | 2 +-
.../iotdb/influxdb/example/InfluxDBExample.java | 36 +--
.../protocol/constant/InfluxDBConstant.java | 2 -
.../iotdb/influxdb/protocol/dto/IoTDBPoint.java | 65 ------
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 52 ++++-
.../protocol/impl/IoTDBInfluxDBService.java | 131 +++--------
.../influxdb/protocol/meta/MetaManagerHolder.java | 54 -----
.../influxdb/protocol/util/DataTypeUtils.java | 86 --------
.../iotdb/influxdb/session/InfluxDBSession.java | 242 +++++++++++++++++++++
.../influxdb/integration/IoTDBInfluxDBIT.java | 94 +-------
pom.xml | 2 +
server/pom.xml | 10 +
.../org/apache/iotdb/db/concurrent/ThreadName.java | 2 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 35 ++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 +
.../org/apache/iotdb/db/metadata/MManager.java | 68 +++---
.../apache/iotdb/db/metadata/id_table/IDTable.java | 16 +-
.../apache/iotdb/db/metrics/ui/MetricsPage.java | 2 +-
.../influxdb}/constant/InfluxDBConstant.java | 5 +-
.../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 128 ++++++-----
.../protocol/influxdb}/input/InfluxLineParser.java | 21 +-
.../db/protocol/influxdb}/meta/MetaManager.java | 127 +++++++----
.../db/protocol/influxdb}/meta/TagInfoRecords.java | 30 ++-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 40 +++-
.../iotdb/db/rest/impl/RestApiServiceImpl.java | 2 +-
.../{RPCService.java => InfluxDBRPCService.java} | 46 ++--
.../iotdb/db/service/InfluxDBRPCServiceMBean.java | 5 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 4 +
.../org/apache/iotdb/db/service/RPCService.java | 2 +
.../org/apache/iotdb/db/service/ServiceType.java | 1 +
.../org/apache/iotdb/db/service/StaticResps.java | 4 +-
.../db/service/basic/BasicServiceProvider.java | 2 +-
.../handler/InfluxDBServiceThriftHandler.java | 30 +--
.../handler}/RPCServiceThriftHandler.java | 4 +-
.../service/thrift/impl/InfluxDBServiceImpl.java | 155 +++++++++++++
.../service/{ => thrift/impl}/TSServiceImpl.java | 6 +-
.../org/apache/iotdb/db/utils/DataTypeUtils.java | 149 +++++++++++++
.../org/apache/iotdb/db/utils}/ParameterUtils.java | 3 +-
.../apache/iotdb/db/utils/RandomDeleteCache.java | 76 -------
.../iotdb/db/metadata/id_table/IDTableTest.java | 18 +-
.../influxdb}/input/InfluxLineParserTest.java | 3 +-
service-rpc/pom.xml | 5 +
...ndler.java => InfluxDBSynchronizedHandler.java} | 11 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 38 ++++
.../iotdb/rpc/StatementExecutionException.java | 7 +
.../java/org/apache/iotdb/session/Session.java | 88 +-------
.../apache/iotdb/session/util/SessionUtils.java | 90 ++++++++
spark-iotdb-connector/pom.xml | 36 +--
.../org/apache/iotdb/spark/db/Converter.scala | 6 +-
.../org/apache/iotdb/spark/db/DefaultSource.scala | 30 ++-
.../org/apache/iotdb/spark/db/IoTDBOptions.scala | 2 +-
.../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 7 +-
.../iotdb/spark/db/tools/DataFrameTools.java | 162 ++++++++++++++
.../org/apache/iotdb/spark/db/IoTDBTest.scala | 32 ++-
.../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 117 ++++++++++
{thrift-sync => thrift-influxdb}/README.md | 2 +-
{thrift => thrift-influxdb}/pom.xml | 6 +-
thrift-influxdb/src/main/thrift/influxdb.thrift | 92 ++++++++
67 files changed, 1775 insertions(+), 1012 deletions(-)
rename {influxdb-protocol/src/main/antlr4/org/apache/iotdb/influxdb/protocol
=>
antlr/src/main/antlr4/org/apache/iotdb/db/protocol/influxdb}/input/InfluxLineProtocol.g4
(99%)
delete mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/dto/IoTDBPoint.java
delete mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/meta/MetaManagerHolder.java
delete mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/util/DataTypeUtils.java
create mode 100644
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/session/InfluxDBSession.java
copy {influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol =>
server/src/main/java/org/apache/iotdb/db/protocol/influxdb}/constant/InfluxDBConstant.java
(87%)
copy
influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/impl/IoTDBInfluxDBService.java
=>
server/src/main/java/org/apache/iotdb/db/protocol/influxdb/dto/IoTDBPoint.java
(54%)
rename {influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol =>
server/src/main/java/org/apache/iotdb/db/protocol/influxdb}/input/InfluxLineParser.java
(87%)
rename {influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol =>
server/src/main/java/org/apache/iotdb/db/protocol/influxdb}/meta/MetaManager.java
(55%)
rename {influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol =>
server/src/main/java/org/apache/iotdb/db/protocol/influxdb}/meta/TagInfoRecords.java
(71%)
copy server/src/main/java/org/apache/iotdb/db/service/{RPCService.java =>
InfluxDBRPCService.java} (68%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServerMBean.java
=>
server/src/main/java/org/apache/iotdb/db/service/InfluxDBRPCServiceMBean.java
(88%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/clusterinfo/ClusterInfoServiceThriftHandler.java
=>
server/src/main/java/org/apache/iotdb/db/service/thrift/handler/InfluxDBServiceThriftHandler.java
(60%)
rename server/src/main/java/org/apache/iotdb/db/service/{ =>
thrift/handler}/RPCServiceThriftHandler.java (93%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/service/thrift/impl/InfluxDBServiceImpl.java
rename server/src/main/java/org/apache/iotdb/db/service/{ =>
thrift/impl}/TSServiceImpl.java (99%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/DataTypeUtils.java
copy {influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/util
=> server/src/main/java/org/apache/iotdb/db/utils}/ParameterUtils.java (96%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/utils/RandomDeleteCache.java
rename {influxdb-protocol/src/test/java/org/apache/iotdb/influxdb/protocol =>
server/src/test/java/org/apache/iotdb/db/protocol/influxdb}/input/InfluxLineParserTest.java
(97%)
copy service-rpc/src/main/java/org/apache/iotdb/rpc/{SynchronizedHandler.java
=> InfluxDBSynchronizedHandler.java} (84%)
create mode 100644
spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/tools/DataFrameTools.java
create mode 100644
spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db/IoTDBWriteTest.scala
copy {thrift-sync => thrift-influxdb}/README.md (89%)
copy {thrift => thrift-influxdb}/pom.xml (96%)
create mode 100644 thrift-influxdb/src/main/thrift/influxdb.thrift
