This is an automated email from the ASF dual-hosted git repository.
zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 684fa1d3c0a Rename TableStatisticsCollector (#34439)
684fa1d3c0a is described below
commit 684fa1d3c0a11483ba3efe86df72cd186f430f3c
Author: Liang Zhang <[email protected]>
AuthorDate: Thu Jan 23 15:17:57 2025 +0800
Rename TableStatisticsCollector (#34439)
---
...sTableCollector.java => ShardingTableStatisticsCollector.java} | 6 +++---
....infra.metadata.statistics.collector.TableStatisticsCollector} | 2 +-
...llectorTest.java => ShardingTableStatisticsCollectorTest.java} | 8 ++++----
...orTest.java => MySQLShardingTableStatisticsCollectorTest.java} | 8 ++++----
...st.java => OpenGaussShardingTableStatisticsCollectorTest.java} | 8 ++++----
...t.java => PostgreSQLShardingTableStatisticsCollectorTest.java} | 8 ++++----
...hereStatisticsCollector.java => TableStatisticsCollector.java} | 6 +++---
...ssTableCollector.java => PgClassTableStatisticsCollector.java} | 6 +++---
...bleCollector.java => PgNamespaceTableStatisticsCollector.java} | 6 +++---
....infra.metadata.statistics.collector.TableStatisticsCollector} | 4 ++--
.../metadata/refresher/ShardingSphereStatisticsRefreshEngine.java | 4 ++--
...CollectorFixture.java => TableStatisticsCollectorFixture.java} | 6 +++---
....infra.metadata.statistics.collector.TableStatisticsCollector} | 2 +-
13 files changed, 37 insertions(+), 37 deletions(-)
diff --git
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/metadata/data/ShardingStatisticsTableCollector.java
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/metadata/data/ShardingTableStatisticsCollector.java
similarity index 97%
rename from
features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/metadata/data/ShardingStatisticsTableCollector.java
rename to
features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/metadata/data/ShardingTableStatisticsCollector.java
index c870c59a781..dd74c2b5d5a 100644
---
a/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/metadata/data/ShardingStatisticsTableCollector.java
+++
b/features/sharding/core/src/main/java/org/apache/shardingsphere/sharding/metadata/data/ShardingTableStatisticsCollector.java
@@ -29,7 +29,7 @@ import
org.apache.shardingsphere.infra.metadata.database.resource.unit.StorageUn
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import org.apache.shardingsphere.infra.metadata.statistics.RowStatistics;
import org.apache.shardingsphere.infra.metadata.statistics.TableStatistics;
-import
org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector;
+import
org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector;
import
org.apache.shardingsphere.infra.rule.attribute.datasource.aggregate.AggregatedDataSourceRuleAttribute;
import
org.apache.shardingsphere.sharding.metadata.data.dialect.DialectShardingStatisticsTableCollector;
import org.apache.shardingsphere.sharding.rule.ShardingRule;
@@ -45,9 +45,9 @@ import java.util.Map;
import java.util.Optional;
/**
- * Sharding statistics table data collector.
+ * Sharding table statistics collector.
*/
-public final class ShardingStatisticsTableCollector implements
ShardingSphereStatisticsCollector {
+public final class ShardingTableStatisticsCollector implements
TableStatisticsCollector {
private static final String SHARDING_TABLE_STATISTICS =
"sharding_table_statistics";
diff --git
a/features/sharding/core/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector
b/features/sharding/core/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector
similarity index 90%
rename from
features/sharding/core/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector
rename to
features/sharding/core/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector
index cf400ced718..62296c1f2bb 100644
---
a/features/sharding/core/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector
+++
b/features/sharding/core/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.sharding.metadata.data.ShardingStatisticsTableCollector
+org.apache.shardingsphere.sharding.metadata.data.ShardingTableStatisticsCollector
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/ShardingStatisticsTableCollectorTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/ShardingTableStatisticsCollectorTest.java
similarity index 94%
rename from
features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/ShardingStatisticsTableCollectorTest.java
rename to
features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/ShardingTableStatisticsCollectorTest.java
index e625d89e233..aa0339176ad 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/ShardingStatisticsTableCollectorTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/ShardingTableStatisticsCollectorTest.java
@@ -27,7 +27,7 @@ import
org.apache.shardingsphere.infra.metadata.database.rule.RuleMetaData;
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import org.apache.shardingsphere.infra.metadata.statistics.RowStatistics;
import org.apache.shardingsphere.infra.metadata.statistics.TableStatistics;
-import
org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector;
+import
org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import org.apache.shardingsphere.sharding.rule.ShardingRule;
import org.apache.shardingsphere.sharding.rule.ShardingTable;
@@ -53,15 +53,15 @@ import static org.mockito.Mockito.RETURNS_DEEP_STUBS;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
-class ShardingStatisticsTableCollectorTest {
+class ShardingTableStatisticsCollectorTest {
private final DatabaseType databaseType =
TypedSPILoader.getService(DatabaseType.class, "FIXTURE");
- private ShardingSphereStatisticsCollector statisticsCollector;
+ private TableStatisticsCollector statisticsCollector;
@BeforeEach
void setUp() {
- statisticsCollector =
TypedSPILoader.getService(ShardingSphereStatisticsCollector.class,
"sharding_table_statistics");
+ statisticsCollector =
TypedSPILoader.getService(TableStatisticsCollector.class,
"sharding_table_statistics");
}
@Test
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/MySQLShardingStatisticsTableCollectorTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/MySQLShardingTableStatisticsCollectorTest.java
similarity index 94%
rename from
features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/MySQLShardingStatisticsTableCollectorTest.java
rename to
features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/MySQLShardingTableStatisticsCollectorTest.java
index 95468ff578e..b3241c946df 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/MySQLShardingStatisticsTableCollectorTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/MySQLShardingTableStatisticsCollectorTest.java
@@ -27,7 +27,7 @@ import
org.apache.shardingsphere.infra.metadata.database.rule.RuleMetaData;
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import org.apache.shardingsphere.infra.metadata.statistics.RowStatistics;
import org.apache.shardingsphere.infra.metadata.statistics.TableStatistics;
-import
org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector;
+import
org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import org.apache.shardingsphere.sharding.rule.ShardingRule;
import org.apache.shardingsphere.sharding.rule.ShardingTable;
@@ -55,15 +55,15 @@ import static org.mockito.Mockito.RETURNS_DEEP_STUBS;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
-class MySQLShardingStatisticsTableCollectorTest {
+class MySQLShardingTableStatisticsCollectorTest {
private final DatabaseType databaseType =
TypedSPILoader.getService(DatabaseType.class, "MySQL");
- private ShardingSphereStatisticsCollector statisticsCollector;
+ private TableStatisticsCollector statisticsCollector;
@BeforeEach
void setUp() {
- statisticsCollector =
TypedSPILoader.getService(ShardingSphereStatisticsCollector.class,
"sharding_table_statistics");
+ statisticsCollector =
TypedSPILoader.getService(TableStatisticsCollector.class,
"sharding_table_statistics");
}
@Test
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/OpenGaussShardingStatisticsTableCollectorTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/OpenGaussShardingTableStatisticsCollectorTest.java
similarity index 96%
rename from
features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/OpenGaussShardingStatisticsTableCollectorTest.java
rename to
features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/OpenGaussShardingTableStatisticsCollectorTest.java
index e4435688b75..034dc1d78a4 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/OpenGaussShardingStatisticsTableCollectorTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/OpenGaussShardingTableStatisticsCollectorTest.java
@@ -27,7 +27,7 @@ import
org.apache.shardingsphere.infra.metadata.database.rule.RuleMetaData;
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import org.apache.shardingsphere.infra.metadata.statistics.RowStatistics;
import org.apache.shardingsphere.infra.metadata.statistics.TableStatistics;
-import
org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector;
+import
org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import org.apache.shardingsphere.sharding.rule.ShardingRule;
import org.apache.shardingsphere.sharding.rule.ShardingTable;
@@ -56,15 +56,15 @@ import static org.mockito.Mockito.RETURNS_DEEP_STUBS;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
-class OpenGaussShardingStatisticsTableCollectorTest {
+class OpenGaussShardingTableStatisticsCollectorTest {
private final DatabaseType databaseType =
TypedSPILoader.getService(DatabaseType.class, "openGauss");
- private ShardingSphereStatisticsCollector statisticsCollector;
+ private TableStatisticsCollector statisticsCollector;
@BeforeEach
void setUp() {
- statisticsCollector =
TypedSPILoader.getService(ShardingSphereStatisticsCollector.class,
"sharding_table_statistics");
+ statisticsCollector =
TypedSPILoader.getService(TableStatisticsCollector.class,
"sharding_table_statistics");
}
@Test
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/PostgreSQLShardingStatisticsTableCollectorTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/PostgreSQLShardingTableStatisticsCollectorTest.java
similarity index 95%
rename from
features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/PostgreSQLShardingStatisticsTableCollectorTest.java
rename to
features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/PostgreSQLShardingTableStatisticsCollectorTest.java
index bc37197ca89..ffcc2805b6e 100644
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/PostgreSQLShardingStatisticsTableCollectorTest.java
+++
b/features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/metadata/data/dialect/type/PostgreSQLShardingTableStatisticsCollectorTest.java
@@ -27,7 +27,7 @@ import
org.apache.shardingsphere.infra.metadata.database.rule.RuleMetaData;
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import org.apache.shardingsphere.infra.metadata.statistics.RowStatistics;
import org.apache.shardingsphere.infra.metadata.statistics.TableStatistics;
-import
org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector;
+import
org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import org.apache.shardingsphere.sharding.rule.ShardingRule;
import org.apache.shardingsphere.sharding.rule.ShardingTable;
@@ -55,15 +55,15 @@ import static org.mockito.Mockito.RETURNS_DEEP_STUBS;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
-class PostgreSQLShardingStatisticsTableCollectorTest {
+class PostgreSQLShardingTableStatisticsCollectorTest {
private final DatabaseType databaseType =
TypedSPILoader.getService(DatabaseType.class, "PostgreSQL");
- private ShardingSphereStatisticsCollector statisticsCollector;
+ private TableStatisticsCollector statisticsCollector;
@BeforeEach
void setUp() {
- statisticsCollector =
TypedSPILoader.getService(ShardingSphereStatisticsCollector.class,
"sharding_table_statistics");
+ statisticsCollector =
TypedSPILoader.getService(TableStatisticsCollector.class,
"sharding_table_statistics");
}
@Test
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/ShardingSphereStatisticsCollector.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/TableStatisticsCollector.java
similarity index 92%
rename from
infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/ShardingSphereStatisticsCollector.java
rename to
infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/TableStatisticsCollector.java
index bda89ca21ce..862d49e0f6c 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/ShardingSphereStatisticsCollector.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/TableStatisticsCollector.java
@@ -27,13 +27,13 @@ import java.sql.SQLException;
import java.util.Optional;
/**
- * ShardingSphere statistics collector.
+ * Table statistics collector.
*/
@SingletonSPI
-public interface ShardingSphereStatisticsCollector extends TypedSPI {
+public interface TableStatisticsCollector extends TypedSPI {
/**
- * Collect statistics.
+ * Collect table statistics.
*
* @param databaseName database name
* @param table table
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgClassTableCollector.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgClassTableStatisticsCollector.java
similarity index 95%
rename from
infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgClassTableCollector.java
rename to
infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgClassTableStatisticsCollector.java
index 455e60e899b..b56320e5135 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgClassTableCollector.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgClassTableStatisticsCollector.java
@@ -23,7 +23,7 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSp
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import org.apache.shardingsphere.infra.metadata.statistics.RowStatistics;
import org.apache.shardingsphere.infra.metadata.statistics.TableStatistics;
-import
org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector;
+import
org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector;
import
org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereTableDataCollectorUtils;
import java.sql.SQLException;
@@ -33,9 +33,9 @@ import java.util.Map;
import java.util.Optional;
/**
- * Table pg_class data collector.
+ * Table statistics collector for pg_class.
*/
-public final class PgClassTableCollector implements
ShardingSphereStatisticsCollector {
+public final class PgClassTableStatisticsCollector implements
TableStatisticsCollector {
private static final String PG_CLASS = "pg_class";
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgNamespaceTableCollector.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgNamespaceTableStatisticsCollector.java
similarity index 94%
rename from
infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgNamespaceTableCollector.java
rename to
infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgNamespaceTableStatisticsCollector.java
index 0789e6feb55..3d9f3281504 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgNamespaceTableCollector.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/statistics/collector/tables/PgNamespaceTableStatisticsCollector.java
@@ -23,7 +23,7 @@ import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSp
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import org.apache.shardingsphere.infra.metadata.statistics.RowStatistics;
import org.apache.shardingsphere.infra.metadata.statistics.TableStatistics;
-import
org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector;
+import
org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector;
import
org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereTableDataCollectorUtils;
import java.sql.SQLException;
@@ -32,9 +32,9 @@ import java.util.Map;
import java.util.Optional;
/**
- * Table pg_namespace data collector.
+ * Table statistics collector for pg_namespace.
*/
-public final class PgNamespaceTableCollector implements
ShardingSphereStatisticsCollector {
+public final class PgNamespaceTableStatisticsCollector implements
TableStatisticsCollector {
private static final String PG_NAMESPACE = "pg_namespace";
diff --git
a/infra/common/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector
b/infra/common/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector
similarity index 92%
rename from
infra/common/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector
rename to
infra/common/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector
index 8154ad584aa..602a2038048 100644
---
a/infra/common/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector
+++
b/infra/common/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector
@@ -15,5 +15,5 @@
# limitations under the License.
#
-org.apache.shardingsphere.infra.metadata.statistics.collector.tables.PgNamespaceTableCollector
-org.apache.shardingsphere.infra.metadata.statistics.collector.tables.PgClassTableCollector
+org.apache.shardingsphere.infra.metadata.statistics.collector.tables.PgNamespaceTableStatisticsCollector
+org.apache.shardingsphere.infra.metadata.statistics.collector.tables.PgClassTableStatisticsCollector
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/ShardingSphereStatisticsRefreshEngine.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/ShardingSphereStatisticsRefreshEngine.java
index 704a29852ab..5503e503d2e 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/ShardingSphereStatisticsRefreshEngine.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/refresher/ShardingSphereStatisticsRefreshEngine.java
@@ -31,7 +31,7 @@ import
org.apache.shardingsphere.infra.metadata.statistics.RowStatistics;
import org.apache.shardingsphere.infra.metadata.statistics.SchemaStatistics;
import
org.apache.shardingsphere.infra.metadata.statistics.ShardingSphereStatistics;
import org.apache.shardingsphere.infra.metadata.statistics.TableStatistics;
-import
org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector;
+import
org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector;
import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
import
org.apache.shardingsphere.infra.yaml.data.swapper.YamlRowStatisticsSwapper;
import
org.apache.shardingsphere.mode.metadata.persist.statistics.AlteredDatabaseStatistics;
@@ -127,7 +127,7 @@ public final class ShardingSphereStatisticsRefreshEngine {
private void collectForTable(final String databaseName, final String
schemaName, final ShardingSphereTable table,
final ShardingSphereMetaData metaData, final
ShardingSphereStatistics statistics) {
- Optional<ShardingSphereStatisticsCollector> statisticsCollector =
TypedSPILoader.findService(ShardingSphereStatisticsCollector.class,
table.getName());
+ Optional<TableStatisticsCollector> statisticsCollector =
TypedSPILoader.findService(TableStatisticsCollector.class, table.getName());
Optional<TableStatistics> tableStatistics = Optional.empty();
if (statisticsCollector.isPresent()) {
try {
diff --git
a/mode/core/src/test/java/org/apache/shardingsphere/mode/fixture/StatisticsCollectorFixture.java
b/mode/core/src/test/java/org/apache/shardingsphere/mode/fixture/TableStatisticsCollectorFixture.java
similarity index 91%
rename from
mode/core/src/test/java/org/apache/shardingsphere/mode/fixture/StatisticsCollectorFixture.java
rename to
mode/core/src/test/java/org/apache/shardingsphere/mode/fixture/TableStatisticsCollectorFixture.java
index b05ea79f556..7606e956924 100644
---
a/mode/core/src/test/java/org/apache/shardingsphere/mode/fixture/StatisticsCollectorFixture.java
+++
b/mode/core/src/test/java/org/apache/shardingsphere/mode/fixture/TableStatisticsCollectorFixture.java
@@ -21,16 +21,16 @@ import
org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
import
org.apache.shardingsphere.infra.metadata.database.schema.model.ShardingSphereTable;
import org.apache.shardingsphere.infra.metadata.statistics.RowStatistics;
import org.apache.shardingsphere.infra.metadata.statistics.TableStatistics;
-import
org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector;
+import
org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector;
import java.sql.SQLException;
import java.util.Arrays;
import java.util.Optional;
/**
- * Statistics collector fixture.
+ * Table statistics collector fixture.
*/
-public final class StatisticsCollectorFixture implements
ShardingSphereStatisticsCollector {
+public final class TableStatisticsCollectorFixture implements
TableStatisticsCollector {
@Override
public Optional<TableStatistics> collect(final String databaseName, final
ShardingSphereTable table, final ShardingSphereMetaData metaData) throws
SQLException {
diff --git
a/mode/core/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector
b/mode/core/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector
similarity index 91%
rename from
mode/core/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector
rename to
mode/core/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector
index 1c364ce3e81..77485be7eb9 100644
---
a/mode/core/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.ShardingSphereStatisticsCollector
+++
b/mode/core/src/test/resources/META-INF/services/org.apache.shardingsphere.infra.metadata.statistics.collector.TableStatisticsCollector
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.mode.fixture.StatisticsCollectorFixture
+org.apache.shardingsphere.mode.fixture.TableStatisticsCollectorFixture
