Skip to content

Commit 32ee1ea

Browse files
committed
Remove Timechart AST object in favor of Chart
Signed-off-by: Yuanchun Shen <[email protected]>
1 parent 2527522 commit 32ee1ea

File tree

5 files changed

+2
-255
lines changed

5 files changed

+2
-255
lines changed

core/src/main/java/org/opensearch/sql/analysis/Analyzer.java

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,6 @@
9696
import org.opensearch.sql.ast.tree.StreamWindow;
9797
import org.opensearch.sql.ast.tree.SubqueryAlias;
9898
import org.opensearch.sql.ast.tree.TableFunction;
99-
import org.opensearch.sql.ast.tree.Timechart;
10099
import org.opensearch.sql.ast.tree.Trendline;
101100
import org.opensearch.sql.ast.tree.UnresolvedPlan;
102101
import org.opensearch.sql.ast.tree.Values;
@@ -775,11 +774,6 @@ public LogicalPlan visitChart(Chart node, AnalysisContext context) {
775774
throw getOnlyForCalciteException("Chart");
776775
}
777776

778-
@Override
779-
public LogicalPlan visitTimechart(Timechart node, AnalysisContext context) {
780-
throw getOnlyForCalciteException("Timechart");
781-
}
782-
783777
@Override
784778
public LogicalPlan visitWindow(Window node, AnalysisContext context) {
785779
throw getOnlyForCalciteException("Window");

core/src/main/java/org/opensearch/sql/ast/AbstractNodeVisitor.java

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,6 @@
8383
import org.opensearch.sql.ast.tree.StreamWindow;
8484
import org.opensearch.sql.ast.tree.SubqueryAlias;
8585
import org.opensearch.sql.ast.tree.TableFunction;
86-
import org.opensearch.sql.ast.tree.Timechart;
8786
import org.opensearch.sql.ast.tree.Trendline;
8887
import org.opensearch.sql.ast.tree.Values;
8988
import org.opensearch.sql.ast.tree.Window;
@@ -280,10 +279,6 @@ public T visitChart(Chart node, C context) {
280279
return visitChildren(node, context);
281280
}
282281

283-
public T visitTimechart(Timechart node, C context) {
284-
return visitChildren(node, context);
285-
}
286-
287282
public T visitRegex(Regex node, C context) {
288283
return visitChildren(node, context);
289284
}

core/src/main/java/org/opensearch/sql/ast/tree/Timechart.java

Lines changed: 0 additions & 209 deletions
This file was deleted.

integ-test/build.gradle

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -480,8 +480,8 @@ integTest {
480480

481481
dependsOn ':opensearch-sql-plugin:bundlePlugin'
482482
if(!ignorePrometheus && getOSFamilyType() != "windows") {
483-
// dependsOn startPrometheus
484-
// finalizedBy stopPrometheus
483+
dependsOn startPrometheus
484+
finalizedBy stopPrometheus
485485
}
486486

487487
// enable calcite codegen in IT

ppl/src/main/java/org/opensearch/sql/ppl/utils/PPLQueryDataAnonymizer.java

Lines changed: 0 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,6 @@
8989
import org.opensearch.sql.ast.tree.StreamWindow;
9090
import org.opensearch.sql.ast.tree.SubqueryAlias;
9191
import org.opensearch.sql.ast.tree.TableFunction;
92-
import org.opensearch.sql.ast.tree.Timechart;
9392
import org.opensearch.sql.ast.tree.Trendline;
9493
import org.opensearch.sql.ast.tree.UnresolvedPlan;
9594
import org.opensearch.sql.ast.tree.Values;
@@ -500,38 +499,6 @@ public String visitReverse(Reverse node, String context) {
500499
return StringUtils.format("%s | reverse", child);
501500
}
502501

503-
@Override
504-
public String visitTimechart(Timechart node, String context) {
505-
String child = node.getChild().get(0).accept(this, context);
506-
StringBuilder timechartCommand = new StringBuilder();
507-
timechartCommand.append(" | timechart");
508-
509-
// Add span if present
510-
if (node.getBinExpression() != null) {
511-
timechartCommand.append(" span=").append(visitExpression(node.getBinExpression()));
512-
}
513-
514-
// Add limit if present
515-
if (node.getLimit() != null) {
516-
timechartCommand.append(" limit=").append(node.getLimit());
517-
}
518-
519-
// Add useother if present
520-
if (node.getUseOther() != null) {
521-
timechartCommand.append(" useother=").append(node.getUseOther());
522-
}
523-
524-
// Add aggregation function
525-
timechartCommand.append(" ").append(visitExpression(node.getAggregateFunction()));
526-
527-
// Add by clause if present
528-
if (node.getByField() != null) {
529-
timechartCommand.append(" by ").append(visitExpression(node.getByField()));
530-
}
531-
532-
return StringUtils.format("%s%s", child, timechartCommand.toString());
533-
}
534-
535502
@Override
536503
public String visitChart(Chart node, String context) {
537504
String child = node.getChild().get(0).accept(this, context);

0 commit comments

Comments
 (0)