This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch NewTsFile
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 0b153b2 fix bug
add 891d8b6 Change listener to visitor in antlr in order to improve prase
speed. (#2034)
add bf03882 [IOTDB-23] providing some statistics info about the writing
operations (#1725)
add 1bd93f1 format document. (#2118)
add ae9a4ab fix issue-2110
add 53e7143 [Issue-2110] Update start-client to start-cli
add b0812c0 add mods file changelist
add 7f36819 [IOTDB-1027] add mods file changelist
add 1491050 Fix python path (#2127)
add afa6ecd The existing timePartitionId variable should be passed to the
`insertToTsFileProcessor` method in the logic of inserting tsfile (#2111)
add 2735fa1 unlock mutil locks sequential (#2117)
add f9a972d fix import errors in Session.py and SessionExample.py
add abc6999 catch NullPointerException and log error (#2129)
add 875817b fix grafana value-time position bug (#2016)
add de4536a Declare the type of result of Future in StorageEngine (#2097)
add 093bd9b Remove the useless `public` keyword due to these methods in
interface are (#2140)
add 7ebdf9a Fix compaction add list bug when last level exceeds max file
num (#2141)
add 66d86b3 fix typo in userguide
add ff104e9 add MAX_POINT_NUMBER format check (#2148)
add 8657b13 Add Apache Pulsar to IoTDB example (#2122)
add d242932 Update compaction level list delete (#2152)
add 18bb46a [IOTDB-890] SDT implementation (#2087)
add 467897e add charset UTF-8 (#2155)
add f6cd1f9 [IOTDB-1035] Fix bug in getDeviceTimeseriesMetadata when
querying non-exist device (#2150)
new a9bed89 resolve conflicts
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:
antlr/pom.xml | 4 +
.../iotdb/db/qp/{strategy => sql}/SqlBase.g4 | 50 +-
client-py/compile.bat | 29 -
client-py/compile.sh | 28 -
client-py/pom.xml | 4 +-
client-py/pypi/README.md | 34 +-
client-py/readme.md | 46 +-
client-py/src/SessionExample.py | 10 +-
client-py/src/{ => iotdb}/Session.py | 28 +-
client-py/src/{utils => iotdb}/__init__.py | 0
client-py/src/{ => iotdb}/utils/Field.py | 5 +-
client-py/src/{ => iotdb}/utils/IoTDBConstants.py | 0
client-py/src/{ => iotdb}/utils/IoTDBRpcDataSet.py | 13 +-
client-py/src/{ => iotdb}/utils/RowRecord.py | 8 +-
client-py/src/{ => iotdb}/utils/SessionDataSet.py | 16 +-
client-py/src/{ => iotdb}/utils/Tablet.py | 7 +-
client-py/src/{ => iotdb/utils}/__init__.py | 0
docker/ReadMe.md | 10 +-
docs/Development/ContributeGuide.md | 6 +-
docs/UserGuide/Concept/SDT.md | 45 +
docs/UserGuide/Operation Manual/SQL Reference.md | 8 +
docs/UserGuide/Server/Config Manual.md | 27 -
.../System Tools/Monitor and Log Tools.md | 321 +--
docs/UserGuide/System Tools/Watermark Tool.md | 8 +-
docs/zh/Development/ContributeGuide.md | 2 +-
docs/zh/UserGuide/Concept/Data Type.md | 2 +-
.../zh/UserGuide/Concept/SDT.md | 24 +-
docs/zh/UserGuide/Get Started/Publication.md | 2 +-
.../zh/UserGuide/Operation Manual/SQL Reference.md | 8 +
docs/zh/UserGuide/Server/Config Manual.md | 29 -
.../System Tools/Monitor and Log Tools.md | 305 +--
docs/zh/UserGuide/System Tools/Watermark Tool.md | 8 +-
.../main/java/org/apache/iotdb/kafka/Constant.java | 2 +
example/pom.xml | 1 +
example/{tsfile => pulsar}/pom.xml | 16 +-
.../java/org/apache/iotdb/pulsar}/Constant.java | 18 +-
.../org/apache/iotdb/pulsar/PulsarConsumer.java | 108 +
.../apache/iotdb/pulsar/PulsarConsumerThread.java | 70 +
.../org/apache/iotdb/pulsar/PulsarProducer.java | 82 +
.../main/java/org/apache/iotdb/SessionExample.java | 14 +
.../controller/DatabaseConnectController.java | 4 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 29 +-
.../web/grafana/dao/impl/BasicDaoImplTest.java | 55 +
pom.xml | 2 +-
...mlog-changelist.md => TsFileMods-changelist.md} | 6 +-
.../resources/conf/iotdb-engine.properties | 19 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 47 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 25 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 26 +-
.../db/engine/compaction/TsFileManagement.java | 21 +
.../level/LevelCompactionTsFileManagement.java | 42 +-
.../no/NoCompactionTsFileManagement.java | 22 +-
.../engine/compaction/utils/CompactionUtils.java | 2 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 14 +
.../iotdb/db/engine/flush/FlushManagerMBean.java | 8 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 16 +-
.../engine/storagegroup/StorageGroupProcessor.java | 49 +-
.../db/engine/storagegroup/TsFileProcessor.java | 2 +
.../org/apache/iotdb/db/metadata/MManager.java | 7 +-
.../org/apache/iotdb/db/metadata/PartialPath.java | 4 +
.../org/apache/iotdb/db/metrics/sink/Sink.java | 6 +-
.../org/apache/iotdb/db/metrics/source/Source.java | 2 +-
.../apache/iotdb/db/monitor/MonitorConstants.java | 94 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 448 ++--
.../StatMonitorMBean.java} | 29 +-
.../iotdb/db/monitor/collector/FileSize.java | 162 --
.../monitor/collector/MemTableWriteTimeCost.java | 85 -
.../main/java/org/apache/iotdb/db/qp/Planner.java | 8 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 22 +-
.../db/qp/logical/crud/QueryIndexOperator.java | 53 -
.../iotdb/db/qp/logical/crud/QueryOperator.java | 21 +
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 6 +-
.../IoTDBSqlVisitor.java} | 2629 ++++++++++----------
.../iotdb/db/qp/strategy/LogicalGenerator.java | 1950 +--------------
.../apache/iotdb/db/qp/strategy/ParseDriver.java | 69 -
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 14 +-
...gicalGeneratorError.java => SQLParseError.java} | 4 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 3 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 11 +-
.../java/org/apache/iotdb/db/service/Monitor.java | 150 --
.../org/apache/iotdb/db/service/TSServiceImpl.java | 147 +-
.../iotdb/db/integration/IoTDBCompactionIT.java | 99 +
.../iotdb/db/integration/IoTDBRestartIT.java | 61 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 422 +++-
.../iotdb/db/monitor/collector/FileSizeTest.java | 93 -
.../iotdb/db/qp/plan/IndexLogicalPlanTest.java | 32 +-
.../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 110 +-
.../sql/DatetimeQueryDataSetUtilsTest.java | 2 +-
.../iotdb/db/qp/strategy/LogicalGeneratorTest.java | 26 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 7 +-
site/src/main/.vuepress/config.js | 2 +
thrift/src/main/thrift/cluster.thrift | 1 +
thrift/src/main/thrift/rpc.thrift | 1 +
thrift/src/main/thrift/sync.thrift | 1 +
.../iotdb/tsfile/compress/IUnCompressor.java | 2 +-
.../iotdb/tsfile/encoding/encoder/SDTEncoder.java | 448 ++++
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 14 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 18 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 124 +-
.../iotdb/tsfile/encoding/SDTEncoderTest.java | 176 ++
101 files changed, 4027 insertions(+), 5325 deletions(-)
rename antlr/src/main/antlr4/org/apache/iotdb/db/qp/{strategy =>
sql}/SqlBase.g4 (94%)
delete mode 100644 client-py/compile.bat
delete mode 100644 client-py/compile.sh
rename client-py/src/{ => iotdb}/Session.py (95%)
rename client-py/src/{utils => iotdb}/__init__.py (100%)
rename client-py/src/{ => iotdb}/utils/Field.py (98%)
rename client-py/src/{ => iotdb}/utils/IoTDBConstants.py (100%)
rename client-py/src/{ => iotdb}/utils/IoTDBRpcDataSet.py (97%)
rename client-py/src/{ => iotdb}/utils/RowRecord.py (91%)
rename client-py/src/{ => iotdb}/utils/SessionDataSet.py (92%)
rename client-py/src/{ => iotdb}/utils/Tablet.py (98%)
rename client-py/src/{ => iotdb/utils}/__init__.py (100%)
create mode 100644 docs/UserGuide/Concept/SDT.md
copy server/file-changelists/role-changelist.md =>
docs/zh/UserGuide/Concept/SDT.md (53%)
copy example/{tsfile => pulsar}/pom.xml (81%)
copy example/{tsfile/src/main/java/org/apache/iotdb/tsfile =>
pulsar/src/main/java/org/apache/iotdb/pulsar}/Constant.java (66%)
create mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumer.java
create mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumerThread.java
create mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarProducer.java
create mode 100644
grafana/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java
copy server/file-changelists/{mlog-changelist.md => TsFileMods-changelist.md}
(93%)
rename server/src/main/java/org/apache/iotdb/db/{service/MonitorMBean.java =>
monitor/StatMonitorMBean.java} (69%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/monitor/collector/FileSize.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/monitor/collector/MemTableWriteTimeCost.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/QueryIndexOperator.java
copy
server/src/main/java/org/apache/iotdb/db/qp/{strategy/LogicalGenerator.java =>
sql/IoTDBSqlVisitor.java} (61%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/qp/strategy/ParseDriver.java
rename
server/src/main/java/org/apache/iotdb/db/qp/strategy/{LogicalGeneratorError.java
=> SQLParseError.java} (89%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/service/Monitor.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompactionIT.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/monitor/collector/FileSizeTest.java
rename server/src/test/java/org/apache/iotdb/db/{ =>
qp}/sql/DatetimeQueryDataSetUtilsTest.java (99%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/SDTEncoder.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/SDTEncoderTest.java
