Skip to content

Commit

Permalink
update case
Browse files Browse the repository at this point in the history
  • Loading branch information
starocean999 committed Mar 29, 2024
1 parent 26cc152 commit d4992e1
Showing 1 changed file with 18 additions and 137 deletions.
155 changes: 18 additions & 137 deletions regression-test/suites/nereids_p0/test_mv_select.groovy
Original file line number Diff line number Diff line change
Expand Up @@ -45,60 +45,16 @@ suite("test_mv_select") {

sql """drop table if exists SkuUniqDailyCounter"""
sql """CREATE TABLE `SkuUniqDailyCounter` (
`ProductId` bigint(20) NOT NULL,
`DateCode` int(11) NOT NULL,
`BrandCid` bigint(20) NOT NULL,
`ShopId` varchar(30) NOT NULL,
`BigCid` int(11) REPLACE NULL,
`FirstCid` int(11) REPLACE NULL,
`SecondCid` int(11) REPLACE NULL,
`ThirdCid` int(11) REPLACE NULL,
`FourthCid` int(11) REPLACE NULL,
`Price` int(11) REPLACE NULL,
`CosRatio` int(11) REPLACE NULL,
`PmtOrders` int(11) REPLACE NULL,
`PmtViews` int(11) REPLACE NULL,
`PmtUsers` int(11) REPLACE NULL,
`VideoPrice` int(11) REPLACE NULL,
`LivePrice` int(11) REPLACE NULL,
`LiveSales` int(11) REPLACE NULL,
`LiveOrders` int(11) REPLACE NULL,
`LiveGmv` bigint(20) REPLACE NULL,
`VideoSales` int(11) REPLACE NULL,
`VideoGmv` bigint(20) REPLACE NULL,
`SubtractSales` int(11) REPLACE NULL,
`SubtractGmv` bigint(20) REPLACE NULL,
`FinalSales` int(11) REPLACE NULL,
`FinalGmv` bigint(20) REPLACE NULL,
`RoomIds` bitmap BITMAP_UNION NOT NULL,
`LiveUids` bitmap BITMAP_UNION NOT NULL,
`VideoAwemeIds` bitmap BITMAP_UNION NOT NULL,
`VideoUids` bitmap BITMAP_UNION NOT NULL,
`Uids` bitmap BITMAP_UNION NOT NULL,
`PlayCount` bigint(20) REPLACE NULL,
`LikeCount` bigint(20) REPLACE NULL,
`SelfViews` int(11) REPLACE NULL,
`FinalViews` int(11) REPLACE NULL,
`SelfSales` int(11) REPLACE NULL,
`LiveUsers` bigint(20) REPLACE NULL,
`LivePriceArray` bitmap BITMAP_UNION NOT NULL,
`VideoPriceArray` bitmap BITMAP_UNION NOT NULL,
`NearlyLivePrice` int(11) REPLACE NULL,
`NearlyVideoPrice` int(11) REPLACE NULL,
`NaturalSales` int(11) REPLACE NULL,
`NaturalGmv` bigint(20) REPLACE NULL,
INDEX idx_shopid (`ShopId`) USING BITMAP COMMENT ''
`Pd` bigint(20) NOT NULL,
`Dc` int(11) NOT NULL,
`Bc` bigint(20) NOT NULL,
`Fs` int(11) REPLACE NULL
) ENGINE=OLAP
AGGREGATE KEY(`ProductId`, `DateCode`, `BrandCid`, `ShopId`)
AGGREGATE KEY(`Pd`, `Dc`, `Bc`)
COMMENT 'OLAP'
DISTRIBUTED BY HASH(`ProductId`) BUCKETS 8
DISTRIBUTED BY HASH(`Dc`) BUCKETS 8
PROPERTIES (
"replication_allocation" = "tag.location.default: 1",
"is_being_synced" = "false",
"storage_format" = "V2",
"light_schema_change" = "true",
"disable_auto_compaction" = "false",
"enable_single_replica_compaction" = "false"
"replication_allocation" = "tag.location.default: 1"
);"""
def delta_time = 1000
def wait_for_latest_op_on_table_finish = { table_name, OpTimeout ->
Expand All @@ -116,99 +72,24 @@ suite("test_mv_select") {
assertTrue(useTime <= OpTimeout, "wait_for_latest_op_on_table_finish timeout")
}
sql """ALTER TABLE SkuUniqDailyCounter
ADD ROLLUP rollup_index_shopid(ShopId,
DateCode,
ProductId,
BrandCid,
BigCid,
FirstCid,
SecondCid,
ThirdCid,
FourthCid,
Price,
CosRatio,
PmtOrders,
PmtViews,
PmtUsers,
VideoPrice,
LivePrice,
LiveSales,
LiveOrders,
LiveGmv,
VideoSales,
VideoGmv,
SubtractSales,
SubtractGmv,
FinalSales,
FinalGmv,
RoomIds,
LiveUids,
VideoAwemeIds,
VideoUids,
Uids,
PlayCount,
LikeCount,
SelfViews,
FinalViews,
SelfSales,
LiveUsers,
LivePriceArray,
VideoPriceArray,
NearlyLivePrice,
NearlyVideoPrice,
NaturalSales,
NaturalGmv
ADD ROLLUP rollup_index_shopid(
Dc,
Bc,
Pd,
Fs
); """
wait_for_latest_op_on_table_finish("SkuUniqDailyCounter",60000);
sql """ALTER TABLE SkuUniqDailyCounter
ADD ROLLUP rollup_index_brandcid(BrandCid,
DateCode,
ProductId,
ShopId,
BigCid,
FirstCid,
SecondCid,
ThirdCid,
FourthCid,
Price,
CosRatio,
PmtOrders,
PmtViews,
PmtUsers,
VideoPrice,
LivePrice,
LiveSales,
LiveOrders,
LiveGmv,
VideoSales,
VideoGmv,
SubtractSales,
SubtractGmv,
FinalSales,
FinalGmv,
RoomIds,
LiveUids,
VideoAwemeIds,
VideoUids,
Uids,
PlayCount,
LikeCount,
SelfViews,
FinalViews,
SelfSales,
LiveUsers,
LivePriceArray,
VideoPriceArray,
NearlyLivePrice,
NearlyVideoPrice,
NaturalSales,
NaturalGmv
ADD ROLLUP rollup_index_brandcid(
Bc,
Dc,
Pd,
Fs
);"""
wait_for_latest_op_on_table_finish("SkuUniqDailyCounter",60000);

explain {
sql ("""select ProductId,sum(FinalSales) Sales,Sum(FinalGmv) Gmv ,SUM(NaturalSales) NaturalSales,sum(NaturalGmv) NaturalGmv ,BITMAP_UNION_COUNT(Uids) as Users from SkuUniqDailyCounter where BrandCid=742502946 and DateCode >=20240315 and DateCode <= 20240328 Group by ProductId order by Gmv DESC LIMIT 10;""")
sql ("""select sum(Fs) Sales from SkuUniqDailyCounter where Bc=742502946 and Dc >=20240315 and Dc <= 20240328;""")
contains "rollup_index_brandcid"
}

}

0 comments on commit d4992e1

Please sign in to comment.