File tree 2 files changed +5
-5
lines changed
main/java/org/opensearch/sql/spark/utils
test/java/org/opensearch/sql/spark/utils
2 files changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -318,23 +318,23 @@ public Void visitAlterMaterializedViewStatement(
318
318
319
319
@ Override
320
320
public Void visitVacuumCoveringIndexStatement (
321
- FlintSparkSqlExtensionsParser .VacuumCoveringIndexStatementContext ctx ) {
321
+ FlintSparkSqlExtensionsParser .VacuumCoveringIndexStatementContext ctx ) {
322
322
indexQueryDetailsBuilder .indexQueryActionType (IndexQueryActionType .VACUUM );
323
323
indexQueryDetailsBuilder .indexType (FlintIndexType .COVERING );
324
324
return super .visitVacuumCoveringIndexStatement (ctx );
325
325
}
326
326
327
327
@ Override
328
328
public Void visitVacuumSkippingIndexStatement (
329
- FlintSparkSqlExtensionsParser .VacuumSkippingIndexStatementContext ctx ) {
329
+ FlintSparkSqlExtensionsParser .VacuumSkippingIndexStatementContext ctx ) {
330
330
indexQueryDetailsBuilder .indexQueryActionType (IndexQueryActionType .VACUUM );
331
331
indexQueryDetailsBuilder .indexType (FlintIndexType .SKIPPING );
332
332
return super .visitVacuumSkippingIndexStatement (ctx );
333
333
}
334
334
335
335
@ Override
336
336
public Void visitVacuumMaterializedViewStatement (
337
- FlintSparkSqlExtensionsParser .VacuumMaterializedViewStatementContext ctx ) {
337
+ FlintSparkSqlExtensionsParser .VacuumMaterializedViewStatementContext ctx ) {
338
338
indexQueryDetailsBuilder .indexQueryActionType (IndexQueryActionType .VACUUM );
339
339
indexQueryDetailsBuilder .indexType (FlintIndexType .MATERIALIZED_VIEW );
340
340
indexQueryDetailsBuilder .mvName (ctx .mvName .getText ());
Original file line number Diff line number Diff line change @@ -140,7 +140,7 @@ void testExtractionFromFlintSkippingIndexQueries() {
140
140
+ " WHERE elb_status_code = 500 "
141
141
+ " WITH (auto_refresh = true)" ,
142
142
"DROP SKIPPING INDEX ON myS3.default.alb_logs" ,
143
- "VACUUM SKIPPING INDEX ON myS3.default.alb_logs" ,
143
+ "VACUUM SKIPPING INDEX ON myS3.default.alb_logs" ,
144
144
"ALTER SKIPPING INDEX ON myS3.default.alb_logs WITH (auto_refresh = false)" ,
145
145
};
146
146
@@ -171,7 +171,7 @@ void testExtractionFromFlintCoveringIndexQueries() {
171
171
+ " WHERE elb_status_code = 500 "
172
172
+ " WITH (auto_refresh = true)" ,
173
173
"DROP INDEX elb_and_requestUri ON myS3.default.alb_logs" ,
174
- "VACUUM INDEX elb_and_requestUri ON myS3.default.alb_logs" ,
174
+ "VACUUM INDEX elb_and_requestUri ON myS3.default.alb_logs" ,
175
175
"ALTER INDEX elb_and_requestUri ON myS3.default.alb_logs WITH (auto_refresh = false)"
176
176
};
177
177
You can’t perform that action at this time.
0 commit comments