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 @@ -317,23 +317,23 @@ public Void visitAlterMaterializedViewStatement(
317
317
318
318
@ Override
319
319
public Void visitVacuumCoveringIndexStatement (
320
- FlintSparkSqlExtensionsParser .VacuumCoveringIndexStatementContext ctx ) {
320
+ FlintSparkSqlExtensionsParser .VacuumCoveringIndexStatementContext ctx ) {
321
321
indexQueryDetailsBuilder .indexQueryActionType (IndexQueryActionType .VACUUM );
322
322
indexQueryDetailsBuilder .indexType (FlintIndexType .COVERING );
323
323
return super .visitVacuumCoveringIndexStatement (ctx );
324
324
}
325
325
326
326
@ Override
327
327
public Void visitVacuumSkippingIndexStatement (
328
- FlintSparkSqlExtensionsParser .VacuumSkippingIndexStatementContext ctx ) {
328
+ FlintSparkSqlExtensionsParser .VacuumSkippingIndexStatementContext ctx ) {
329
329
indexQueryDetailsBuilder .indexQueryActionType (IndexQueryActionType .VACUUM );
330
330
indexQueryDetailsBuilder .indexType (FlintIndexType .SKIPPING );
331
331
return super .visitVacuumSkippingIndexStatement (ctx );
332
332
}
333
333
334
334
@ Override
335
335
public Void visitVacuumMaterializedViewStatement (
336
- FlintSparkSqlExtensionsParser .VacuumMaterializedViewStatementContext ctx ) {
336
+ FlintSparkSqlExtensionsParser .VacuumMaterializedViewStatementContext ctx ) {
337
337
indexQueryDetailsBuilder .indexQueryActionType (IndexQueryActionType .VACUUM );
338
338
indexQueryDetailsBuilder .indexType (FlintIndexType .MATERIALIZED_VIEW );
339
339
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