nolint:all.

Copyright 2023 Matrix Origin Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License.

Copyright 2021 Matrix Origin Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License.

AllocPartitionS3Writer Alloc S3 writers for partitioned table.

FixProjectionResult set result vector for rbat.

GroupByPartitionForDeleteS3: Group data based on partition and return batch array with the same length as the number of partitions.

GroupByPartitionForInsert: Group data based on partition and return batch array with the same length as the number of partitions.

InsertIndexMetadata :Synchronize the index metadata information of the table to the index metadata table.

InsertOneIndexMetadata :Synchronize the single index metadata information into the index metadata table.

RewriteFilterExprList will convert an expression list to be an AndExpr.

'mo_indexes' table.

MO_INDEX_TYPE can have values : unique, primary or multiple.

WriteS3Threshold when batches' size of table reaches this, we will trigger write s3.

Column type mapping of table 'mo_indexes'.

FixedVectorExpressionExecutor the content of its vector is fixed.

we will sort by primary key or clusterby key, so we just need one vector of every batch.

ReceiveInfo used to spec which node, and which registers you need.

ReceiverOperator need to receive batch from proc.Reg.MergeReceivers.

RunningPipelineMapForRemoteNode is a map to record which pipeline was built for a remote node.

S3Writer is used to write table data to S3 and package a series of `BlockWriter` write operations Currently there are two scenarios will let cn write s3 directly scenario 1 is insert operator directly go s3, when a one-time insert/load data volume is relatively large will trigger the scenario scenario 2 is txn.workspace exceeds the threshold value, in the txn.dumpBatch function trigger a write s3.

ExpressionExecutor generated from plan.Expr, can evaluate the result from vectors directly.