Delete Spark datasource

Signed-off-by: Tomoyuki Morita <[email protected]>
opensearch-project · Apr 26, 2024 · 0287f62 · 0287f62
1 parent 204c7da
commit 0287f62
Show file tree

Hide file tree

Showing 20 changed files with 0 additions and 1,519 deletions.
diff --git a/plugin/src/main/java/org/opensearch/sql/plugin/SQLPlugin.java b/plugin/src/main/java/org/opensearch/sql/plugin/SQLPlugin.java
@@ -84,7 +84,6 @@
 import org.opensearch.sql.spark.execution.statestore.StateStore;
 import org.opensearch.sql.spark.flint.FlintIndexMetadataServiceImpl;
 import org.opensearch.sql.spark.rest.RestAsyncQueryManagementAction;
-import org.opensearch.sql.spark.storage.SparkStorageFactory;
 import org.opensearch.sql.spark.transport.TransportCancelAsyncQueryRequestAction;
 import org.opensearch.sql.spark.transport.TransportCreateAsyncQueryRequestAction;
 import org.opensearch.sql.spark.transport.TransportGetAsyncQueryResultAction;
@@ -285,7 +284,6 @@ private DataSourceServiceImpl createDataSourceService() {
                 new OpenSearchDataSourceFactory(
                     new OpenSearchNodeClient(this.client), pluginSettings))
             .add(new PrometheusStorageFactory(pluginSettings))
-            .add(new SparkStorageFactory(this.client, pluginSettings))
             .add(new GlueDataSourceFactory(pluginSettings))
             .build(),
         dataSourceMetadataStorage,

diff --git a/...ava/org/opensearch/sql/spark/functions/implementation/SparkSqlFunctionImplementation.java b/...ava/org/opensearch/sql/spark/functions/implementation/SparkSqlFunctionImplementation.java
diff --git a/.../main/java/org/opensearch/sql/spark/functions/resolver/SparkSqlTableFunctionResolver.java b/.../main/java/org/opensearch/sql/spark/functions/resolver/SparkSqlTableFunctionResolver.java
diff --git a/...c/main/java/org/opensearch/sql/spark/functions/scan/SparkSqlFunctionTableScanBuilder.java b/...c/main/java/org/opensearch/sql/spark/functions/scan/SparkSqlFunctionTableScanBuilder.java
diff --git a/.../main/java/org/opensearch/sql/spark/functions/scan/SparkSqlFunctionTableScanOperator.java b/.../main/java/org/opensearch/sql/spark/functions/scan/SparkSqlFunctionTableScanOperator.java
diff --git a/spark/src/main/java/org/opensearch/sql/spark/storage/SparkScan.java b/spark/src/main/java/org/opensearch/sql/spark/storage/SparkScan.java
diff --git a/spark/src/main/java/org/opensearch/sql/spark/storage/SparkStorageEngine.java b/spark/src/main/java/org/opensearch/sql/spark/storage/SparkStorageEngine.java