@@ -70,9 +70,7 @@ public void testParseDeletePredicateWithRenamedTimeColumn() {
7070 new Identifier ("ts" ),
7171 new LongLiteral ("100" ));
7272
73- List <TableDeletionEntry > entries =
74- AnalyzeUtils .parseExpressions2ModEntries (
75- expression , table , "db" , new MPPQueryContext (new QueryId ("1" )));
73+ List <TableDeletionEntry > entries = parseExpressions2ModEntries (expression , table );
7674
7775 assertEquals (1 , entries .size ());
7876 assertEquals (Long .MIN_VALUE , entries .get (0 ).getStartTime ());
@@ -89,7 +87,7 @@ public void testParseDeleteTimePredicateWithBoundary() {
8987 ComparisonExpression .Operator .GREATER_THAN ,
9088 new Identifier ("time" ),
9189 new LongLiteral (String .valueOf (Long .MAX_VALUE - 1 )));
92- List <TableDeletionEntry > entries = AnalyzeUtils . parseExpressions2ModEntries (expression , table );
90+ List <TableDeletionEntry > entries = parseExpressions2ModEntries (expression , table );
9391 assertEquals (1 , entries .size ());
9492 assertEquals (Long .MAX_VALUE , entries .get (0 ).getStartTime ());
9593 assertEquals (Long .MAX_VALUE , entries .get (0 ).getEndTime ());
@@ -99,7 +97,7 @@ public void testParseDeleteTimePredicateWithBoundary() {
9997 ComparisonExpression .Operator .LESS_THAN ,
10098 new Identifier ("time" ),
10199 new LongLiteral (String .valueOf (Long .MIN_VALUE + 1 )));
102- entries = AnalyzeUtils . parseExpressions2ModEntries (expression , table );
100+ entries = parseExpressions2ModEntries (expression , table );
103101 assertEquals (1 , entries .size ());
104102 assertEquals (Long .MIN_VALUE , entries .get (0 ).getStartTime ());
105103 assertEquals (Long .MIN_VALUE , entries .get (0 ).getEndTime ());
@@ -113,7 +111,7 @@ public void testParseDeleteTimePredicateWithEmptyBoundary() {
113111 assertThrows (
114112 SemanticException .class ,
115113 () ->
116- AnalyzeUtils . parseExpressions2ModEntries (
114+ parseExpressions2ModEntries (
117115 new ComparisonExpression (
118116 ComparisonExpression .Operator .GREATER_THAN ,
119117 new Identifier ("time" ),
@@ -122,7 +120,7 @@ public void testParseDeleteTimePredicateWithEmptyBoundary() {
122120 assertThrows (
123121 SemanticException .class ,
124122 () ->
125- AnalyzeUtils . parseExpressions2ModEntries (
123+ parseExpressions2ModEntries (
126124 new ComparisonExpression (
127125 ComparisonExpression .Operator .LESS_THAN ,
128126 new Identifier ("time" ),
@@ -183,4 +181,10 @@ private static TRegionReplicaSet dataRegionReplicaSet(final int regionId) {
183181 return new TRegionReplicaSet (
184182 new TConsensusGroupId (TConsensusGroupType .DataRegion , regionId ), Collections .emptyList ());
185183 }
184+
185+ private static List <TableDeletionEntry > parseExpressions2ModEntries (
186+ final Expression expression , final TsTable table ) {
187+ return AnalyzeUtils .parseExpressions2ModEntries (
188+ expression , table , "db" , new MPPQueryContext (new QueryId ("test_query" )));
189+ }
186190}
0 commit comments