This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/last_cache
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 7124d01e616 perfect impl of TableLastQueryOperator
new 883e7a276d9 fix error in template + sort + offset + limit + align by
device
add 067b0b35f51 Initialize compaction schedule even when compaction is not
enabled (#14479)
add 55b37e0d14a Pipe: Fix infinite loop when thread is interrupted in
invoking PipeMemoryBlock#close & Avoid throwing new InterruptedException in
conditions that can be self-restoring (#14471)
add 72c803fa981 Table model insertion auto-cast & Fix TVList not removed
when all data are deleted. (#14391)
add 2076bf6b86c Fix setting illegal default_storage_group_level does not
report an error (#14477)
add 2a26c6eb52b Pipe: Fixed the bug that auth plan with system privileges
can not be transferred (#14489)
add 0a8ad9751c6 Add format function in table model
add c5547b09d6e Pipe & Subscription: support synonym database and table
parameters for table model (#14487)
add 640a0c7ac1b Isolate Show-Queries of TableModel and TreeModel
new d4db7aca240 Merge branch 'master' into beyyes/last_cache
add 67cd48da3fb Modify the UDF Time Dimension
add 96f8c19a80b Subscription: fix NPE when building consumer with missing
id & add more checker for topic operations using session (#14493)
add 61fa8d6f004 Implement schema of 'information_schema' & Make
AddLocation plan immune readOnly state
add d34511a93f3 Fix error in template + sort + offset + limit + align by
device
add a877b82b819 Make the construction method of class
TableAggTableScanOperator tidy
add f013e975933 Remove redundant trim (#14502)
add a04c752bc24 fix compaction task comparator & fix the conflicts between
inner compaction selection conditions (#14495)
add f215c4225a1 Revert "[IOTDB-6353] replace cglib to byte-buddy (#14426)"
(#14497)
add 81db737e325 Add lock for insertSeparatorToWAL (#14478)
new 20e2bf87efb merge master
new 04ccdace529 add impl
The 4 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:
dependencies.json | 2 +-
.../it/env/cluster/config/MppCommonConfig.java | 6 +
.../env/cluster/config/MppSharedCommonConfig.java | 7 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 +
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 52 +
.../IoTDBAlignByDeviceWithTemplateIT.java | 28 +-
.../db/it/query/IoTDBEncryptionValueQueryIT.java | 2 +-
.../iotdb/pipe/it/manual/IoTDBPipeInclusionIT.java | 12 +-
.../pipe/it/manual/IoTDBPipeMetaHistoricalIT.java | 12 +-
.../it/tablemodel/IoTDBTablePatternFormatIT.java | 2 +-
.../it/query/old/IoTDBSimpleQueryTableIT.java | 20 +-
.../scalar/IoTDBFormatFunctionTableIT.java | 190 ++
.../relational/it/schema/IoTDBDatabaseIT.java | 100 +
.../it/session}/IoTDBSessionRelationalIT.java | 372 ++-
.../it/local/IoTDBSubscriptionBasicIT.java | 69 +
.../param/IoTDBTestParamPullConsumerIT.java | 8 +-
.../param/IoTDBTestParamPushConsumerIT.java | 8 +-
.../regression/param/IoTDBTestParamTopicIT.java | 11 +-
.../iotdb/rpc/subscription/config/TopicConfig.java | 9 +-
.../rpc/subscription/config/TopicConstant.java | 8 +-
.../session/subscription/SubscriptionSession.java | 9 +
.../consumer/SubscriptionConsumer.java | 25 +-
.../consumer/SubscriptionPullConsumer.java | 4 +-
.../session/subscription/util/IdentifierUtils.java | 10 +-
.../confignode/conf/ConfigNodeDescriptor.java | 600 ++---
.../read/ainode/GetAINodeConfigurationPlan.java | 15 -
.../request/read/model/GetModelInfoPlan.java | 16 -
.../request/read/model/ShowModelPlan.java | 20 -
.../manager/partition/PartitionMetrics.java | 3 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 12 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 14 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2495 ++++++--------------
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 92 +-
.../dataregion/DataExecutionVisitor.java | 4 +
.../exception/sql/StatementAnalyzeException.java | 4 +
.../deletion/persist/PageCacheDeletionBuffer.java | 2 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 17 +-
.../dataregion/IoTDBDataRegionExtractor.java | 6 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 3 +
.../resource/memory/InsertNodeMemoryEstimator.java | 3 +
.../db/pipe/resource/memory/PipeMemoryBlock.java | 14 +-
.../execution/executor/RegionWriteExecutor.java | 7 +-
.../operator/source/ShowQueriesOperator.java | 23 +-
.../InformationSchemaContentSupplierFactory.java | 33 +-
.../TableAggregationTableScanOperator.java | 1 -
.../source/relational/TableLastQueryOperator.java | 396 ++--
.../relational/aggregation/LastByAccumulator.java | 4 +
.../relational/aggregation/TableAggregator.java | 4 +
.../relational/ColumnTransformerBuilder.java | 9 +
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 10 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 11 +-
.../plan/analyze/TemplatedAggregationAnalyze.java | 6 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 7 +-
.../analyze/cache/partition/PartitionCache.java | 2 +-
.../plan/analyze/schema/SchemaValidator.java | 6 +-
.../plan/execution/IQueryExecution.java | 3 +-
.../queryengine/plan/execution/QueryExecution.java | 9 +-
.../plan/execution/config/ConfigExecution.java | 5 +-
.../execution/config/TableConfigTaskVisitor.java | 37 +-
.../config/executor/ClusterConfigTaskExecutor.java | 15 +-
.../config/executor/IConfigTaskExecutor.java | 4 +-
.../config/metadata/relational/ShowDBTask.java | 22 +-
.../db/queryengine/plan/planner/IPlanner.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 14 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 5 +-
.../plan/node/write/RelationalDeleteDataNode.java | 15 +-
.../plan/relational/analyzer/Analysis.java | 4 +-
.../relational/analyzer/StatementAnalyzer.java | 3 +
.../relational/metadata/TableMetadataImpl.java | 53 +-
.../plan/relational/metadata/TableSchema.java | 27 +-
.../fetcher/TableHeaderSchemaValidator.java | 3 +
.../plan/relational/planner/RelationPlanner.java | 4 +-
.../plan/relational/planner/TableModelPlanner.java | 5 +-
.../DataNodeLocationSupplierFactory.java | 12 +-
.../plan/relational/security/AccessControl.java | 2 +-
.../relational/sql/ast/AbstractTraverseDevice.java | 1 +
.../relational/sql/ast/WrappedInsertStatement.java | 20 +-
.../plan/relational/sql/parser/AstBuilder.java | 4 +-
.../plan/relational/sql/rewrite/ShowRewrite.java | 4 +-
.../plan/statement/crud/InsertBaseStatement.java | 2 +-
.../plan/statement/crud/InsertRowStatement.java | 4 +-
.../plan/statement/crud/InsertTabletStatement.java | 5 +-
.../statement/metadata/ShowDatabaseStatement.java | 6 +-
.../unary/scalar/FormatColumnTransformer.java | 119 +
.../schemaengine/schemaregion/utils/MetaUtils.java | 9 +-
.../db/schemaengine/table/DataNodeTableCache.java | 10 +-
.../schemaengine/table/InformationSchemaUtils.java | 185 ++
.../db/storageengine/dataregion/DataRegion.java | 38 +-
.../DefaultCompactionTaskComparatorImpl.java | 16 +-
.../impl/NewSizeTieredCompactionSelector.java | 2 +-
.../dataregion/memtable/AbstractMemTable.java | 4 +-
.../memtable/AlignedWritableMemChunk.java | 6 +-
.../memtable/AlignedWritableMemChunkGroup.java | 5 +
.../memtable/IWritableMemChunkGroup.java | 2 +
.../dataregion/memtable/WritableMemChunkGroup.java | 5 +
.../wal/allocation/FirstCreateStrategy.java | 1 +
.../storageengine/dataregion/wal/node/WALNode.java | 8 +-
.../response/SubscriptionEventTsFileResponse.java | 2 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 86 -
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 5 +
.../db/utils/datastructure/AlignedTVList.java | 26 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 9 +-
.../operator/MergeTreeSortOperatorTest.java | 4 +-
.../plan/relational/analyzer/ShowQueriesTest.java | 20 +-
.../plan/relational/analyzer/TestMatadata.java | 10 +-
.../planner/assertions/PlanMatchPattern.java | 12 +
.../plan/statement/InsertStatementTest.java | 2 +-
.../compaction/CompactionTaskComparatorTest.java | 2 +-
.../NewSizeTieredCompactionSelectorTest.java | 30 +
iotdb-core/node-commons/pom.xml | 4 +-
.../conf/iotdb-system.properties.template | 7 +-
.../commons/client/sync/ByteBuddyEnhancer.java | 75 -
.../sync/SyncThriftClientWithErrorHandler.java | 30 +-
.../config/constant/PipeExtractorConstant.java | 4 +
.../pipe/datastructure/pattern/TablePattern.java | 16 +-
.../schema/column/ColumnHeaderConstant.java | 10 +-
.../commons/schema/table/InformationSchema.java | 123 +
.../schema/table/InformationSchemaTable.java | 96 -
.../schema/table/column/IdColumnSchema.java | 9 +-
.../table/column/MeasurementColumnSchema.java | 48 +-
.../relational/TableBuiltinScalarFunction.java | 1 +
.../iotdb/library/dprofile/UDAFIntegral.java | 41 +-
.../iotdb/library/drepair/UDTFTimestampRepair.java | 47 +-
.../library/drepair/util/TimestampInterval.java | 22 +-
.../library/drepair/util/TimestampRepair.java | 2 +-
pom.xml | 8 +-
126 files changed, 3255 insertions(+), 3007 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/builtinfunction/scalar/IoTDBFormatFunctionTableIT.java
rename integration-test/src/test/java/org/apache/iotdb/{session/it =>
relational/it/session}/IoTDBSessionRelationalIT.java (74%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/FormatColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/InformationSchemaUtils.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/ByteBuddyEnhancer.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/InformationSchema.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/InformationSchemaTable.java
