This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch TreeToTableView
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from af92ee2585d Add TreeAlignedDeviceViewAggregationScanOperator and
TreeAlignedDeviceViewScanOperator
add 876d8469515 fix checkNonAlignedDeviceSeries (#14461)
add 91b672da649 Allow hot reloading compaction from disabled status
(#14470)
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
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
new 6829a689d08 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:
.../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 +-
.../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 | 43 ++-
.../exception/sql/StatementAnalyzeException.java | 4 +
.../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 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 7 +-
.../execution/executor/RegionWriteExecutor.java | 7 +-
.../operator/source/ShowQueriesOperator.java | 23 +-
.../AbstractAggregationTableScanOperator.java | 171 +++++-----
.../InformationSchemaContentSupplierFactory.java | 33 +-
.../TableAggregationTableScanOperator.java | 23 +-
...eeAlignedDeviceViewAggregationScanOperator.java | 21 +-
.../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 | 23 +-
.../config/executor/IConfigTaskExecutor.java | 4 +-
.../config/metadata/relational/ShowDBTask.java | 22 +-
.../db/queryengine/plan/planner/IPlanner.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 259 +++++++-------
.../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 | 5 -
.../compaction/repair/RepairDataFileScanUtil.java | 2 +-
.../compaction/schedule/CompactionTaskManager.java | 11 +-
.../dataregion/memtable/AbstractMemTable.java | 4 +-
.../memtable/AlignedWritableMemChunk.java | 6 +-
.../memtable/AlignedWritableMemChunkGroup.java | 5 +
.../memtable/IWritableMemChunkGroup.java | 2 +
.../dataregion/memtable/WritableMemChunkGroup.java | 5 +
.../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 +-
.../conf/iotdb-system.properties.template | 7 +-
.../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 +-
113 files changed, 2119 insertions(+), 865 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
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
