This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/count_time_fe
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 182abcfda6e reimpl count_time align by time
add f0f168249b2 [IOTDB-6097] Pipe: Avoid subscrption running with the
pattern option causing OOM & Fix de/ser of RecoverProgressIndex (#10767)
add 9fb01f5674e [IOTDB-6096] Make M4 Function do the nullable judgement
add b4442b64aae [IOTDB-6098] Fix a possible flush error when using aligned
timeseries (#10766)
add 400da3bc089 Use JDK 17 for sonar check (#10777)
add 445fc6d98d9 Add compression and encoding type check for
FastCompactionPerformer (#10692)
add 09f9bcfedf6 Cleaned up in the projects maven configuration (#10742)
add 3def1f80976 [IOTDB-6100] Pipe: Fix running in hybrid mode will cause
wal cannot be deleted & some pipe data lost due to wrong ProducerType of
Disruptor (#10790)
add ebc95a772b6 [IOTDB-6094] Load: Fix error in if/else judgment of
tsfileResource exists or not & Reduce warn log when timeseries exist (#10762)
add 038b7f45e94 build: Changed the build to build a statically linked
thrift executable for Linux (Also fixed the problem also enabling uinx profiles
on Macs) (#10788)
add b3a4bdf813f [IOTDB-6101] Pipe: Support tsfile cascade transport
(#10795)
add 6e8fc9be257 Merge branch 'master' into beyyes/count_time_fe
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-cpp.yml | 29 +-
.github/workflows/cluster-it-1c1d.yml | 3 +-
.github/workflows/cluster-it-1c3d.yml | 4 +-
.github/workflows/sonar-coveralls.yml | 15 +-
.github/workflows/unit-test.yml | 6 +-
.mvn/wrapper/maven-wrapper.properties | 4 +-
Jenkinsfile | 4 +-
README.md | 116 ++++
code-coverage/README.md | 2 +-
code-coverage/pom.xml | 75 +--
distribution/pom.xml | 61 +-
example/client-cpp-example/pom.xml | 278 ++++-----
example/client-cpp-example/src/CMakeLists.txt | 13 +-
example/flink/pom.xml | 4 +-
example/hadoop/pom.xml | 3 +-
example/jdbc/pom.xml | 4 +-
example/kafka/pom.xml | 9 +-
example/mqtt-customize/pom.xml | 4 +-
example/mqtt/pom.xml | 4 +-
example/pom.xml | 13 +-
example/pulsar/pom.xml | 6 +-
example/rabbitmq/pom.xml | 4 +-
example/rest-java-example/pom.xml | 3 +-
example/rocketmq/pom.xml | 4 +-
example/session/pom.xml | 4 +-
example/trigger/pom.xml | 72 +--
example/tsfile/pom.xml | 3 +-
example/udf/pom.xml | 71 +--
integration-test/pom.xml | 226 +++----
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 12 +
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 58 ++
iotdb-api/external-api/pom.xml | 6 +-
iotdb-api/pipe-api/pom.xml | 22 +-
{iotdb-client/isession => iotdb-api}/pom.xml | 22 +-
iotdb-api/trigger-api/pom.xml | 32 +-
iotdb-api/udf-api/pom.xml | 6 +-
iotdb-client/cli/pom.xml | 147 +++--
iotdb-client/client-cpp/pom.xml | 678 ++++++++++----------
iotdb-client/client-cpp/src/main/CMakeLists.txt | 17 +-
iotdb-client/client-cpp/src/test/CMakeLists.txt | 9 +-
iotdb-client/client-py/pom.xml | 29 +-
iotdb-client/compile-tools/pom.xml | 146 -----
iotdb-client/compile-tools/thrift/pom.xml | 205 -------
iotdb-client/isession/pom.xml | 6 +-
iotdb-client/jdbc/pom.xml | 59 +-
iotdb-client/{isession => }/pom.xml | 32 +-
iotdb-client/service-rpc/pom.xml | 77 ++-
iotdb-client/session/pom.xml | 7 +-
iotdb-connector/flink-iotdb-connector/pom.xml | 5 +-
iotdb-connector/flink-tsfile-connector/pom.xml | 5 +-
iotdb-connector/grafana-connector/pom.xml | 101 ++-
iotdb-connector/grafana-plugin/pom.xml | 30 +-
iotdb-connector/hadoop/pom.xml | 89 ++-
iotdb-connector/hive-connector/pom.xml | 141 +++--
{iotdb-client/isession => iotdb-connector}/pom.xml | 27 +-
iotdb-connector/spark-iotdb-connector/pom.xml | 71 ++-
.../spark-iotdb-connector/scala_2.11/pom.xml | 70 +--
.../spark-iotdb-connector/scala_2.12/pom.xml | 78 +--
iotdb-connector/spark-tsfile/pom.xml | 46 +-
iotdb-connector/zeppelin-interpreter/pom.xml | 30 +-
iotdb-core/antlr/pom.xml | 17 +-
iotdb-core/confignode/pom.xml | 77 ++-
iotdb-core/consensus/pom.xml | 61 +-
iotdb-core/datanode/pom.xml | 281 +++++----
.../PipeRealtimeDataRegionHybridExtractor.java | 90 ++-
.../PipeRealtimeDataRegionLogExtractor.java | 24 +-
.../PipeRealtimeDataRegionTsFileExtractor.java | 26 +-
.../realtime/assigner/DisruptorQueue.java | 85 +--
.../realtime/assigner/PipeDataRegionAssigner.java | 10 +-
.../listener/PipeInsertionDataNodeListener.java | 9 +-
.../db/pipe/resource/wal/PipeWALResource.java | 4 +
.../pipe/resource/wal/PipeWALResourceManager.java | 12 +-
.../pipe/task/connection/BlockingPendingQueue.java | 22 +-
.../pipe/task/connection/PipeEventCollector.java | 48 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 91 +--
.../config/executor/ClusterConfigTaskExecutor.java | 27 +-
.../plan/node/load/LoadSingleTsFileNode.java | 11 +-
.../metadata/DatabaseSchemaStatement.java | 9 +
...ticSerializableTVListBackedSingleColumnRow.java | 2 +-
.../LayerPointReaderBackedSingleColumnRow.java | 6 +-
.../db/storageengine/dataregion/DataRegion.java | 5 +
.../fast/AlignedSeriesCompactionExecutor.java | 20 +
.../fast/NonAlignedSeriesCompactionExecutor.java | 14 +
.../executor/fast/SeriesCompactionExecutor.java | 16 +-
.../fast/element/ChunkMetadataElement.java | 2 +
.../utils/executor/fast/element/PageElement.java | 4 +
.../dataregion/memtable/TsFileProcessor.java | 2 +
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +
.../TsFileResourceProgressIndexTest.java | 18 +
...InconsistentCompressionTypeAndEncodingTest.java | 681 +++++++++++++++++++++
.../compaction/utils/CompactionTestFileWriter.java | 238 +++++++
.../utils/CompactionTestFileWriterTest.java | 199 ++++++
iotdb-core/metrics/dropwizard-metrics/pom.xml | 13 +-
iotdb-core/metrics/interface/pom.xml | 36 +-
iotdb-core/metrics/micrometer-metrics/pom.xml | 5 +-
iotdb-core/metrics/pom.xml | 8 +-
iotdb-core/mlnode/pom.xml | 49 +-
iotdb-core/node-commons/pom.xml | 211 ++++---
.../resources/conf/iotdb-common.properties | 8 +-
.../iotdb/commons/concurrent/ThreadName.java | 2 +
.../apache/iotdb/commons/conf/CommonConfig.java | 6 +-
.../consensus/index/impl/RecoverProgressIndex.java | 5 +-
.../iotdb/commons/file/SystemFileFactory.java | 19 +-
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 338 ++++++----
.../iotdb/commons/pipe/PipeMetaDeSerTest.java | 22 +-
{iotdb-client/isession => iotdb-core}/pom.xml | 26 +-
iotdb-core/tsfile/pom.xml | 146 +++--
.../iotdb/tsfile/write/page/TimePageWriter.java | 4 +-
.../tsfile/write/writer/TimeChunkWriterTest.java | 55 ++
iotdb-protocol/openapi/pom.xml | 190 +++---
{iotdb-client/isession => iotdb-protocol}/pom.xml | 24 +-
iotdb-protocol/thrift-commons/pom.xml | 17 +-
iotdb-protocol/thrift-confignode/pom.xml | 27 +-
iotdb-protocol/thrift-iot-consensus/pom.xml | 27 +-
iotdb-protocol/thrift-mlnode/pom.xml | 27 +-
iotdb-protocol/thrift/pom.xml | 31 +-
library-udf/pom.xml | 4 +-
pom.xml | 331 ++++++----
{iotdb-client/compile-tools => tools}/README.md | 0
tools/pom.xml | 33 +
tools/thrift/pom.xml | 312 ++++++++++
.../thrift/src/main/assembly/thrift.xml | 39 +-
122 files changed, 4415 insertions(+), 3020 deletions(-)
copy {iotdb-client/isession => iotdb-api}/pom.xml (80%)
delete mode 100644 iotdb-client/compile-tools/pom.xml
delete mode 100644 iotdb-client/compile-tools/thrift/pom.xml
copy iotdb-client/{isession => }/pom.xml (71%)
copy {iotdb-client/isession => iotdb-connector}/pom.xml (71%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/FastCompactionPerformerWithInconsistentCompressionTypeAndEncodingTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionTestFileWriter.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionTestFileWriterTest.java
copy {iotdb-client/isession => iotdb-core}/pom.xml (76%)
copy {iotdb-client/isession => iotdb-protocol}/pom.xml (77%)
rename {iotdb-client/compile-tools => tools}/README.md (100%)
create mode 100644 tools/pom.xml
create mode 100644 tools/thrift/pom.xml
copy iotdb-client/client-cpp/src/assembly/client-cpp.xml =>
tools/thrift/src/main/assembly/thrift.xml (52%)
