You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2022/01/12 03:46:03 UTC
[iotdb] branch client_manager_add_close updated (6da8f60 -> c244e1a)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch client_manager_add_close
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 6da8f60 fix exception type in tests
add 50a3bc7 [IOTDB-2334] Unreasonable debug log level of python client Session (#4751)
add ed93a7d [IOTDB-2222] bugs of Spark Connector (#4679)
add f42ff83 [IOTDB-2333] Python client: the todf method throws exception (#4754)
add fb77b02 Fix JenkinsCI (#4758)
add 45050cb [IOTDB-2274] TriggerExample: deadlock between trigger recovery and MQTT service starting (#4748)
add 18e0ae4 [IOTDB-2317] Deadlock between set ttl and create new TsFileProcessor (#4750)
add 6203966 [IOTDB-2262][Aligned timeseries] support in select ... into ... clauses (#4757)
add fc2889e [IOTDB-1801] Python APIs for aligned timeseries (#4747)
add d7360bc Fix JenkinsCI deploying error (#4761)
add 9baeae3 [IOTDB-2277] CQ: No warn message when aggregate function and timeseries types do not match (#4766)
add e6781b0 [IOTDB-1803] Support insert Tablet with null value in c++ client (#4755)
add 2d1e5d3 use default timeout of server (#4737)
add aa511e0 [IOTDB-2264] load tsfile with aligned timeseries failed (#4719)
add ce16e30 [IOTDB-2312] The SQL statement in the user manual does not match the legend (#4740)
add f1c167d [IOTDB-2335] Add isAligned column in ResultSet of SHOW DEVICES statement (#4759)
add 2173678 [IOTDB-2317] Avoid checking TTL when setting TTL (#4765)
add 04622bb [IOTDB-2346] Select INTO Reports NPE for time series containing binary values of NULL (#4767)
add a2dba1b [IOTDB-2347] Fix aligned timeseries auto create bug (#4770)
add 50f171b [IOTDB-2288] Modify serializing an empty page (#4723)
add 058a07c [IOTDB-2275] Don't compile grafana plugin when execute mvn clean package -pl distribution -am -DskipTests (#4779)
add c528332 [IOTDB-2142][IOTDB-2281][IOTDB-2286][IOTDB-2258] fix csv bugs and add a parm to use aligned interface (#4762)
add c244e1a Merge branch 'master' into client_manager_add_close
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 110 ++++++--
client-cpp/src/main/Session.cpp | 313 ++++++++++++---------
client-cpp/src/main/Session.h | 198 +++++++++----
...ample.py => SessionAlignedTimeseriesExample.py} | 94 ++++---
...sionTest.py => SessionAlignedTimeseriesTest.py} | 90 +++---
client-py/iotdb/Session.py | 211 +++++++++++++-
client-py/iotdb/utils/IoTDBConstants.py | 11 +-
docs/UserGuide/Advanced-Features/Select-Into.md | 19 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 39 +--
.../DDL-Data-Definition-Language.md | 60 ++--
.../DML-Data-Manipulation-Language.md | 61 ++--
docs/UserGuide/System-Tools/CSV-Tool.md | 10 +-
docs/zh/UserGuide/Advanced-Features/Select-Into.md | 20 +-
.../Ecosystem Integration/Grafana Plugin.md | 4 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 71 ++---
.../DDL-Data-Definition-Language.md | 60 ++--
.../DML-Data-Manipulation-Language.md | 62 ++--
docs/zh/UserGuide/System-Tools/CSV-Tool.md | 14 +-
.../src/AlignedTimeseriesSessionExample.cpp | 45 ++-
example/client-cpp-example/src/SessionExample.cpp | 48 +++-
.../org/apache/iotdb/trigger/TriggerExample.java | 28 +-
grafana-plugin/pom.xml | 125 ++++----
.../db/integration/IoTDBContinuousQueryIT.java | 8 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 43 ++-
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 63 ++++-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 10 +-
.../aligned/IOTDBInsertAlignedValuesIT.java | 115 ++++++++
.../IoTDBLoadExternalAlignedTsFileIT.java} | 113 ++++----
.../iotdb/session/IoTDBSessionIteratorIT.java | 6 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 19 +-
jenkins.pom | 1 +
pom.xml | 4 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 1 +
.../apache/iotdb/db/cq/ContinuousQueryService.java | 147 +++++-----
.../apache/iotdb/db/cq/ContinuousQueryTask.java | 73 ++---
.../db/cq/ContinuousQueryTaskPoolManager.java | 15 +-
.../selectinto/InsertTabletPlanGenerator.java | 9 +-
.../selectinto/InsertTabletPlansIterator.java | 8 +-
.../storagegroup/VirtualStorageGroupProcessor.java | 52 ++--
.../db/exception/ContinuousQueryException.java | 6 +
.../org/apache/iotdb/db/metadata/MManager.java | 4 +-
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 6 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 73 ++++-
.../db/qp/logical/crud/SelectIntoOperator.java | 10 +-
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 18 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 1 +
.../iotdb/db/qp/strategy/LogicalChecker.java | 5 +
.../iotdb/db/query/dataset/ShowDevicesDataSet.java | 16 +-
.../iotdb/db/query/dataset/ShowDevicesResult.java | 31 +-
.../db/service/thrift/impl/TSServiceImpl.java | 6 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 2 +
.../iotdb/db/metadata/MManagerBasicTest.java | 45 +++
.../iotdb/db/query/dataset/ListDataSetTest.java | 23 +-
.../db/query/dataset/ShowDevicesResultTest.java | 3 +-
.../apache/iotdb/session/util/SessionUtils.java | 15 +-
spark-iotdb-connector/pom.xml | 29 +-
.../org/apache/iotdb/spark/db/SQLConstant.java | 28 --
.../org/apache/iotdb/spark/db/DataFrameTools.scala | 131 +++++++++
.../org/apache/iotdb/spark/db/DefaultSource.scala | 4 +-
.../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 9 +-
.../org/apache/iotdb/spark/db/SQLConstant.scala | 9 +-
.../org/apache/iotdb/spark/db/Transformer.scala | 18 +-
.../iotdb/spark/db/tools/DataFrameTools.java | 162 -----------
.../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 30 +-
.../DataFrameToolsTest.scala} | 63 ++---
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 7 +-
.../iotdb/tsfile/write/page/ValuePageWriter.java | 3 +
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 9 +-
70 files changed, 2013 insertions(+), 1137 deletions(-)
copy client-py/{SessionExample.py => SessionAlignedTimeseriesExample.py} (67%)
copy client-py/{SessionTest.py => SessionAlignedTimeseriesTest.py} (75%)
copy integration/src/test/java/org/apache/iotdb/db/integration/{IoTDBLoadExternalTsfileIT.java => aligned/IoTDBLoadExternalAlignedTsFileIT.java} (86%)
delete mode 100644 spark-iotdb-connector/src/main/java/org/apache/iotdb/spark/db/SQLConstant.java
create mode 100644 spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/DataFrameTools.scala
copy cluster/src/test/java/org/apache/iotdb/cluster/utils/Constants.java => spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/SQLConstant.scala (83%)
delete mode 100644 spark-iotdb-connector/src/main/scala/org/apache/iotdb/spark/db/tools/DataFrameTools.java
copy spark-iotdb-connector/src/test/scala/org/apache/iotdb/spark/db/{IoTDBWriteTest.scala => unit/DataFrameToolsTest.scala} (61%)