This is an automated email from the ASF dual-hosted git repository.
xuekaifeng pushed a change to branch virtual_partition_2_merge
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from e0b2d16 Merge branch 'master' of https://github.com/apache/iotdb into
virtual_partition_2_merge
add 3496136 fix
add 346da56 fix fix
add 10ae899 Merge pull request #2362 from
LebronAl/fix_serialToParallelPool_init_bug
add 3e24aef [IOTDB-1086] Improve document of Zeppelin installation (#2354)
add 8ffc98d [IOTDB-1090] Unable to update UDF (#2361)
add 7c2628e [IOTDB-1065] Fix deletion bug while trying to delete data
from a timeseries which contains comma (#2306)
add 83e2722 fix some typo & make code more understandable (#2360)
add a71204e fix concurrent bug of mlogWriter (#2335)
add a93f3c1 Fix the spelling of DEFAULT in connection params
add 4218a96 Merge switch branchs in the authority checker
add ffab403 Use TimeUnit instead of plain number to improve readability
add bf19c0e Using system arraycopy instead of manual for loop
add 4968b7b Fix the condition of logger with the right level for merging
file task
add c125df3 Fix the input resource leak when deserializing device owner
(#2374)
add 4c16060 [IOTDB-1070] Add interface `terminate` for UDTF (#2366)
add 91db5fa Compaction not block flush (#2341)
new e731d90 Merge branch 'master' of https://github.com/apache/iotdb into
virtual_partition_2_merge
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:
.../apache/iotdb/cluster/config/ClusterConfig.java | 14 +-
.../apache/iotdb/cluster/server/ClientServer.java | 2 +-
.../iotdb/cluster/server/member/RaftMember.java | 8 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 9 +-
.../Operation Manual/UDF User Defined Function.md | 68 +++++++-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 9 +-
.../Operation Manual/UDF User Defined Function.md | 70 +++++++-
.../main/java/org/apache/iotdb/jdbc/Config.java | 2 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 5 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 31 +++-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 2 +
.../compaction/CompactionMergeTaskPoolManager.java | 32 +++-
.../db/engine/compaction/TsFileManagement.java | 22 ++-
.../level/LevelCompactionTsFileManagement.java | 190 +++++++++++----------
.../no/NoCompactionTsFileManagement.java | 5 -
.../engine/compaction/utils/CompactionUtils.java | 12 +-
.../iotdb/db/engine/merge/task/MergeFileTask.java | 2 +-
.../io/LocalTextModificationAccessor.java | 61 +++++--
.../engine/storagegroup/StorageGroupProcessor.java | 90 +++++-----
.../iotdb/db/metadata/logfile/MLogWriter.java | 22 +--
.../apache/iotdb/db/qp/physical/crud/UDFPlan.java | 17 +-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 27 ++-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 4 +-
.../org/apache/iotdb/db/query/udf/api/UDTF.java | 12 ++
.../db/query/udf/api/collector/PointCollector.java | 4 +-
.../api/customizer/config/UDTFConfigurations.java | 3 +-
.../db/query/udf/core/executor/UDTFExecutor.java | 33 ++--
.../udf/core/transformer/UDFQueryTransformer.java | 18 +-
.../iotdb/db/query/udf/service/UDFClassLoader.java | 53 ++++--
.../query/udf/service/UDFClassLoaderManager.java | 122 +++++++++++++
.../udf/service/UDFRegistrationInformation.java | 17 +-
.../query/udf/service/UDFRegistrationService.java | 62 ++++---
.../java/org/apache/iotdb/db/service/IoTDB.java | 6 +-
.../org/apache/iotdb/db/service/ServiceType.java | 5 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 13 +-
.../db/sync/receiver/load/FileLoaderManager.java | 4 +-
.../compaction/LevelCompactionMergeTest.java | 4 +-
.../LevelCompactionTsFileManagementTest.java | 1 -
.../NoCompactionTsFileManagementTest.java | 1 -
.../iotdb/db/integration/IoTDBDeletionIT.java | 35 ++++
.../db/integration/IoTDBLevelCompactionIT.java | 3 +
.../iotdb/db/integration/IoTDBRestartIT.java | 40 ++---
.../db/integration/IoTDBRpcCompressionIT.java | 1 -
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 169 ++++++++++++++++++
...gSizeWindowConstructorTester1.java => Max.java} | 118 +++++++------
...onstructorTester1.java => TerminateTester.java} | 118 +++++++------
.../apache/iotdb/db/utils/EnvironmentUtils.java | 3 +
.../tsfile/encoding/bitpacking/IntPacker.java | 4 +-
.../tsfile/encoding/bitpacking/LongPacker.java | 4 +-
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 4 +-
51 files changed, 1131 insertions(+), 432 deletions(-)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/udf/service/UDFClassLoaderManager.java
copy
server/src/test/java/org/apache/iotdb/db/query/udf/example/{SlidingSizeWindowConstructorTester1.java
=> Max.java} (74%)
copy
server/src/test/java/org/apache/iotdb/db/query/udf/example/{SlidingSizeWindowConstructorTester1.java
=> TerminateTester.java} (78%)
