Address review comments

apache · Jun 26, 2023 · 940a6c2 · 940a6c2
1 parent 12df08a
commit 940a6c2
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 7 deletions.
diff --git a/...e/metrics/InMemoryReadMetricReporter.java → ...g/metrics/InMemoryReadMetricReporter.java b/...e/metrics/InMemoryReadMetricReporter.java → ...g/metrics/InMemoryReadMetricReporter.java
@@ -16,11 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.iceberg.spark.source.metrics;
-
-import org.apache.iceberg.metrics.MetricsReport;
-import org.apache.iceberg.metrics.MetricsReporter;
-import org.apache.iceberg.metrics.ScanReport;
+package org.apache.iceberg.metrics;
 
 public class InMemoryReadMetricReporter implements MetricsReporter {
 

diff --git a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkScanBuilder.java b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkScanBuilder.java
@@ -43,6 +43,7 @@
 import org.apache.iceberg.expressions.ExpressionUtil;
 import org.apache.iceberg.expressions.Expressions;
 import org.apache.iceberg.io.CloseableIterable;
+import org.apache.iceberg.metrics.InMemoryReadMetricReporter;
 import org.apache.iceberg.relocated.com.google.common.base.Preconditions;
 import org.apache.iceberg.relocated.com.google.common.collect.ImmutableList;
 import org.apache.iceberg.relocated.com.google.common.collect.Lists;
@@ -52,7 +53,6 @@
 import org.apache.iceberg.spark.SparkReadConf;
 import org.apache.iceberg.spark.SparkReadOptions;
 import org.apache.iceberg.spark.SparkSchemaUtil;
-import org.apache.iceberg.spark.source.metrics.InMemoryReadMetricReporter;
 import org.apache.iceberg.types.Type;
 import org.apache.iceberg.types.TypeUtil;
 import org.apache.iceberg.types.Types;

diff --git a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkStagedScanBuilder.java b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkStagedScanBuilder.java
@@ -19,8 +19,8 @@
 package org.apache.iceberg.spark.source;
 
 import org.apache.iceberg.Table;
+import org.apache.iceberg.metrics.InMemoryReadMetricReporter;
 import org.apache.iceberg.spark.SparkReadConf;
-import org.apache.iceberg.spark.source.metrics.InMemoryReadMetricReporter;
 import org.apache.spark.sql.SparkSession;
 import org.apache.spark.sql.connector.read.Scan;
 import org.apache.spark.sql.connector.read.ScanBuilder;