Documentation ¶
Index ¶
- Variables
- func AppendAnyToStringVector(proc *process.Process, val any, vec *vector.Vector) error
- func BinaryToInt(b string) (uint64, error)
- func BuildCompositeClusterByColumnName(s []string) string
- func BuildIndexTableName(ctx context.Context, unique bool) (string, error)
- func BuildMoColumnsFilter(curAccountId uint64) tree.Expr
- func BuildMoDataBaseFilter(curAccountId uint64) tree.Expr
- func BuildMoTablesFilter(curAccountId uint64) tree.Expr
- func BuildSysMetricFilter(acctName string) tree.Expr
- func BuildSysStatementInfoFilter(acctName string) tree.Expr
- func BuildUniqueKeyBatch(vecs []*vector.Vector, attrs []string, parts []string, ...) (*batch.Batch, int, error)
- func CopyBatch(bat *batch.Batch, proc *process.Process) (*batch.Batch, error)
- func DbIsSystemDb(dbName string) bool
- func DecodeBinaryString(s string) ([]byte, error)
- func FillCompositeClusterByBatch(bat *batch.Batch, cbName string, proc *process.Process) error
- func FillCompositeKeyBatch(bat *batch.Batch, ckeyName string, keyParts []string, proc *process.Process) error
- func GenVectorByVarValue(proc *process.Process, typ types.Type, val any) (*vector.Vector, error)
- func GetClusterByColumnOrder(cbName, colName string) int
- func GetClusterByFirstColumn(cbName string) string
- func GetClusterTableAttributeName() string
- func GetClusterTableAttributeType() *tree.T
- func HexToInt(hex string) (uint64, error)
- func InitPredefinedTables(tables []string)
- func IsClusterTableAttribute(name string) bool
- func IsValidNameForPartitionTable(name string) bool
- func JudgeIsCompositeClusterByColumn(s string) bool
- func MakeNameOfPartitionTable(partitionName, tableName string) (bool, string)
- func ScoreBinaryToInt(s string) (uint64, error)
- func SetAnyToStringVector(proc *process.Process, val any, vec *vector.Vector, idx int) error
- func SetBytesToAnyVector(ctx context.Context, val string, row int, isNull bool, vec *vector.Vector, ...) error
- func SetInsertValue(proc *process.Process, numVal *tree.NumVal, vec *vector.Vector) (bool, error)
- func SplitCompositeClusterByColumnName(s string) []string
- func SplitNameOfPartitionTable(name string) (bool, string, string)
- func SplitTableAndColumn(name string) (string, string)
- func TableIsClusterTable(tableType string) bool
- func TableIsLoggingTable(dbName string, tableName string) bool
- type PackerList
Constants ¶
This section is empty.
Variables ¶
var CompactPrimaryCol = compactPrimaryCol
var CompactSingleIndexCol = compactSingleIndexCol
var SerialWithCompacted = serialWithCompacted
var SerialWithoutCompacted = serialWithoutCompacted
Functions ¶
func AppendAnyToStringVector ¶ added in v0.8.0
func BinaryToInt ¶ added in v1.1.1
func BuildCompositeClusterByColumnName ¶ added in v0.7.0
func BuildIndexTableName ¶ added in v0.6.0
func BuildMoColumnsFilter ¶ added in v0.7.0
Build the filter condition AST expression for mo_columns, as follows: account_id = current_id or (account_id = 0 and attr_databse in mo_catalog and att_relname not in other tables)
func BuildMoDataBaseFilter ¶ added in v0.7.0
Build the filter condition AST expression for mo_database, as follows: account_id = cur_accountId or (account_id = 0 and datname in ('mo_catalog'))
func BuildMoTablesFilter ¶ added in v0.7.0
Build the filter condition AST expression for mo_tables, as follows: account_id = cur_account_id or (account_id = 0 and (relname in ('mo_tables','mo_database','mo_columns') or relkind = 'cluster'))
func BuildSysMetricFilter ¶ added in v0.8.0
func BuildSysStatementInfoFilter ¶ added in v0.8.0
func BuildUniqueKeyBatch ¶ added in v0.6.0
func BuildUniqueKeyBatch(vecs []*vector.Vector, attrs []string, parts []string, originTablePrimaryKey string, proc *process.Process, packers *PackerList) (*batch.Batch, int, error)
BuildUniqueKeyBatch used in test to validate serialWithCompacted(), compactSingleIndexCol() and compactPrimaryCol()
func DbIsSystemDb ¶ added in v0.8.0
func DecodeBinaryString ¶ added in v1.1.1
func FillCompositeClusterByBatch ¶ added in v0.7.0
build the clusterBy key's vector of the cluster table according to the composite column name, and append the result vector to batch cbName: column name of composite column
func FillCompositeKeyBatch ¶ added in v0.8.0
func FillCompositeKeyBatch(bat *batch.Batch, ckeyName string, keyParts []string, proc *process.Process) error
build the vector of the composite key, and append the result vector to batch ckeyName: column name of composite column keyParts: parts of the composite column
func GenVectorByVarValue ¶ added in v0.8.0
func GetClusterByColumnOrder ¶ added in v0.7.0
func GetClusterByFirstColumn ¶ added in v1.1.0
func GetClusterTableAttributeName ¶ added in v0.7.0
func GetClusterTableAttributeName() string
func GetClusterTableAttributeType ¶ added in v0.7.0
func InitPredefinedTables ¶ added in v1.2.1
func InitPredefinedTables(tables []string)
func IsClusterTableAttribute ¶ added in v0.7.0
func IsValidNameForPartitionTable ¶ added in v0.8.0
IsValidNameForPartitionTable the name forms the partition table does not have the partitionDelimiter
func JudgeIsCompositeClusterByColumn ¶ added in v0.7.0
func MakeNameOfPartitionTable ¶ added in v0.8.0
MakeNameOfPartitionTable !!!NOTE!!! With assumption: the partition name and the table name does not have partitionDelimiter. partition table name format : %!%partition_name%!%table_name
func ScoreBinaryToInt ¶ added in v1.2.0
func SetAnyToStringVector ¶ added in v0.8.0
func SetBytesToAnyVector ¶ added in v0.8.0
func SetInsertValue ¶ added in v0.8.0
func SplitCompositeClusterByColumnName ¶ added in v0.7.0
func SplitNameOfPartitionTable ¶ added in v0.8.0
SplitNameOfPartitionTable splits the partition table name into partition name and origin table name
func SplitTableAndColumn ¶
func TableIsClusterTable ¶ added in v0.7.0
TableIsClusterTable check the table type is cluster table
func TableIsLoggingTable ¶ added in v0.8.0
Types ¶
type PackerList ¶ added in v1.2.0
type PackerList struct {
// contains filtered or unexported fields
}
func (*PackerList) Free ¶ added in v1.2.0
func (list *PackerList) Free()