This is an automated email from the ASF dual-hosted git repository.
JingsongLi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new abaf053ae7 [core] Rename more classes to DataEvolution header
abaf053ae7 is described below
commit abaf053ae706569f8b3bb76c6fa466057c7e9de0
Author: JingsongLi <[email protected]>
AuthorDate: Wed Jul 22 16:25:11 2026 +0800
[core] Rename more classes to DataEvolution header
---
...ctVectorRead.java => AbstractDataEvolutionVectorRead.java} | 4 ++--
.../paimon/table/source/BatchVectorSearchBuilderImpl.java | 2 +-
...hVectorReadImpl.java => DataEvolutionBatchVectorRead.java} | 5 +++--
.../apache/paimon/table/source/DataEvolutionFullTextRead.java | 11 -----------
.../apache/paimon/table/source/DataEvolutionFullTextScan.java | 4 ----
.../apache/paimon/table/source/DataEvolutionVectorRead.java | 2 +-
.../apache/paimon/table/source/PrimaryKeyFullTextScan.java | 7 -------
.../org/apache/paimon/table/source/PrimaryKeyVectorScan.java | 8 --------
.../apache/paimon/table/source/PrimaryKeyVectorScanTest.java | 2 +-
.../apache/paimon/table/source/VectorSearchBuilderTest.java | 2 +-
10 files changed, 9 insertions(+), 38 deletions(-)
diff --git
a/paimon-core/src/main/java/org/apache/paimon/table/source/AbstractVectorRead.java
b/paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataEvolutionVectorRead.java
similarity index 99%
rename from
paimon-core/src/main/java/org/apache/paimon/table/source/AbstractVectorRead.java
rename to
paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataEvolutionVectorRead.java
index 326f814428..2545a14777 100644
---
a/paimon-core/src/main/java/org/apache/paimon/table/source/AbstractVectorRead.java
+++
b/paimon-core/src/main/java/org/apache/paimon/table/source/AbstractDataEvolutionVectorRead.java
@@ -71,7 +71,7 @@ import java.util.concurrent.ExecutorService;
import static org.apache.paimon.utils.Preconditions.checkNotNull;
/** Base implementation for vector reads. */
-public abstract class AbstractVectorRead implements Serializable {
+public abstract class AbstractDataEvolutionVectorRead implements Serializable {
private static final long serialVersionUID = 1L;
@@ -86,7 +86,7 @@ public abstract class AbstractVectorRead implements
Serializable {
Comparator.<long[]>comparingDouble(a -> Float.intBitsToFloat((int)
a[1]))
.thenComparing((a, b) -> Long.compare(b[0], a[0]));
- protected AbstractVectorRead(
+ protected AbstractDataEvolutionVectorRead(
FileStoreTable table,
@Nullable PartitionPredicate partitionFilter,
@Nullable Predicate filter,
diff --git
a/paimon-core/src/main/java/org/apache/paimon/table/source/BatchVectorSearchBuilderImpl.java
b/paimon-core/src/main/java/org/apache/paimon/table/source/BatchVectorSearchBuilderImpl.java
index 8209f93c4c..81916cac7b 100644
---
a/paimon-core/src/main/java/org/apache/paimon/table/source/BatchVectorSearchBuilderImpl.java
+++
b/paimon-core/src/main/java/org/apache/paimon/table/source/BatchVectorSearchBuilderImpl.java
@@ -149,7 +149,7 @@ public class BatchVectorSearchBuilderImpl implements
BatchVectorSearchBuilder {
return new PrimaryKeyBatchVectorRead(
table, vectorColumn, vectors, limit, options, filter);
}
- return new BatchVectorReadImpl(
+ return new DataEvolutionBatchVectorRead(
table, partitionFilter, filter, limit, vectorColumn, vectors,
options);
}
diff --git
a/paimon-core/src/main/java/org/apache/paimon/table/source/BatchVectorReadImpl.java
b/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionBatchVectorRead.java
similarity index 97%
rename from
paimon-core/src/main/java/org/apache/paimon/table/source/BatchVectorReadImpl.java
rename to
paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionBatchVectorRead.java
index 72003cff82..9e598b783d 100644
---
a/paimon-core/src/main/java/org/apache/paimon/table/source/BatchVectorReadImpl.java
+++
b/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionBatchVectorRead.java
@@ -41,13 +41,14 @@ import java.util.concurrent.ExecutorService;
import static org.apache.paimon.CoreOptions.GLOBAL_INDEX_THREAD_NUM;
/** Implementation for {@link BatchVectorRead}. */
-public class BatchVectorReadImpl extends AbstractVectorRead implements
BatchVectorRead {
+public class DataEvolutionBatchVectorRead extends
AbstractDataEvolutionVectorRead
+ implements BatchVectorRead {
private static final long serialVersionUID = 1L;
protected final float[][] vectors;
- public BatchVectorReadImpl(
+ public DataEvolutionBatchVectorRead(
FileStoreTable table,
@Nullable PartitionPredicate partitionFilter,
@Nullable Predicate filter,
diff --git
a/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionFullTextRead.java
b/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionFullTextRead.java
index bf74d2e036..7e759c648d 100644
---
a/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionFullTextRead.java
+++
b/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionFullTextRead.java
@@ -41,7 +41,6 @@ import org.apache.paimon.utils.RoaringNavigableMap64;
import javax.annotation.Nullable;
import java.util.ArrayList;
-import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -61,16 +60,6 @@ public class DataEvolutionFullTextRead implements
FullTextRead {
private final DataField textColumn;
private final String query;
- public DataEvolutionFullTextRead(
- FileStoreTable table, int limit, DataField textColumn, String
query) {
- this(table, null, limit, Collections.singletonList(textColumn), query);
- }
-
- public DataEvolutionFullTextRead(
- FileStoreTable table, int limit, List<DataField> textColumns,
String query) {
- this(table, null, limit, textColumns, query);
- }
-
public DataEvolutionFullTextRead(
FileStoreTable table,
@Nullable PartitionPredicate partitionFilter,
diff --git
a/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionFullTextScan.java
b/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionFullTextScan.java
index 87ef271d4b..1b6ef7adc7 100644
---
a/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionFullTextScan.java
+++
b/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionFullTextScan.java
@@ -56,10 +56,6 @@ public class DataEvolutionFullTextScan implements
FullTextScan {
private final PartitionPredicate partitionFilter;
private final List<DataField> textColumns;
- public DataEvolutionFullTextScan(FileStoreTable table, DataField
textColumn) {
- this(table, null, textColumn);
- }
-
public DataEvolutionFullTextScan(
FileStoreTable table, PartitionPredicate partitionFilter,
DataField textColumn) {
this(table, partitionFilter, Collections.singletonList(textColumn));
diff --git
a/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionVectorRead.java
b/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionVectorRead.java
index 354bdbe15d..8d32363146 100644
---
a/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionVectorRead.java
+++
b/paimon-core/src/main/java/org/apache/paimon/table/source/DataEvolutionVectorRead.java
@@ -41,7 +41,7 @@ import java.util.concurrent.ExecutorService;
import static org.apache.paimon.CoreOptions.GLOBAL_INDEX_THREAD_NUM;
/** Data-evolution implementation for {@link VectorRead}. */
-public class DataEvolutionVectorRead extends AbstractVectorRead implements
VectorRead {
+public class DataEvolutionVectorRead extends AbstractDataEvolutionVectorRead
implements VectorRead {
private static final long serialVersionUID = 1L;
diff --git
a/paimon-core/src/main/java/org/apache/paimon/table/source/PrimaryKeyFullTextScan.java
b/paimon-core/src/main/java/org/apache/paimon/table/source/PrimaryKeyFullTextScan.java
index 5b2799cf79..b4b91ff348 100644
---
a/paimon-core/src/main/java/org/apache/paimon/table/source/PrimaryKeyFullTextScan.java
+++
b/paimon-core/src/main/java/org/apache/paimon/table/source/PrimaryKeyFullTextScan.java
@@ -57,13 +57,6 @@ public class PrimaryKeyFullTextScan implements FullTextScan {
@Nullable private final PartitionPredicate partitionFilter;
@Nullable private final Snapshot pinnedSnapshot;
- public PrimaryKeyFullTextScan(
- FileStoreTable table,
- PrimaryKeyIndexDefinition definition,
- @Nullable PartitionPredicate partitionFilter) {
- this(table, definition, partitionFilter, null);
- }
-
PrimaryKeyFullTextScan(
FileStoreTable table,
PrimaryKeyIndexDefinition definition,
diff --git
a/paimon-core/src/main/java/org/apache/paimon/table/source/PrimaryKeyVectorScan.java
b/paimon-core/src/main/java/org/apache/paimon/table/source/PrimaryKeyVectorScan.java
index cc3ef15874..f02af9228d 100644
---
a/paimon-core/src/main/java/org/apache/paimon/table/source/PrimaryKeyVectorScan.java
+++
b/paimon-core/src/main/java/org/apache/paimon/table/source/PrimaryKeyVectorScan.java
@@ -56,14 +56,6 @@ public class PrimaryKeyVectorScan implements VectorScan {
@Nullable private final Predicate filter;
@Nullable private final Snapshot pinnedSnapshot;
- public PrimaryKeyVectorScan(
- FileStoreTable table,
- int vectorFieldId,
- String indexType,
- @Nullable PartitionPredicate partitionFilter) {
- this(table, vectorFieldId, indexType, partitionFilter, null, null);
- }
-
public PrimaryKeyVectorScan(
FileStoreTable table,
int vectorFieldId,
diff --git
a/paimon-core/src/test/java/org/apache/paimon/table/source/PrimaryKeyVectorScanTest.java
b/paimon-core/src/test/java/org/apache/paimon/table/source/PrimaryKeyVectorScanTest.java
index 1f677eac28..7569dab513 100644
---
a/paimon-core/src/test/java/org/apache/paimon/table/source/PrimaryKeyVectorScanTest.java
+++
b/paimon-core/src/test/java/org/apache/paimon/table/source/PrimaryKeyVectorScanTest.java
@@ -95,7 +95,7 @@ class PrimaryKeyVectorScanTest {
when(reader.indexFileHandler()).thenReturn(indexFileHandler);
configureBatchScan(table, reader, snapshot);
- new PrimaryKeyVectorScan(table, 7, "ivf-pq", null).scan();
+ new PrimaryKeyVectorScan(table, 7, "ivf-pq", null, null).scan();
verify(reader).onlyReadRealBuckets();
}
diff --git
a/paimon-core/src/test/java/org/apache/paimon/table/source/VectorSearchBuilderTest.java
b/paimon-core/src/test/java/org/apache/paimon/table/source/VectorSearchBuilderTest.java
index 63c2d1834d..2153b44f2b 100644
---
a/paimon-core/src/test/java/org/apache/paimon/table/source/VectorSearchBuilderTest.java
+++
b/paimon-core/src/test/java/org/apache/paimon/table/source/VectorSearchBuilderTest.java
@@ -1574,7 +1574,7 @@ public class VectorSearchBuilderTest extends
TableTestBase {
}
}
- private static class RecordingBatchVectorRead extends BatchVectorReadImpl {
+ private static class RecordingBatchVectorRead extends
DataEvolutionBatchVectorRead {
private int rawReadCount;
private List<Range> rawReadRanges;
