This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch ci-add-column
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/ci-add-column by this push:
new 113334993 add javadoc
113334993 is described below
commit 1133349931ae465534269c3d9e2e18f69430bd9e
Author: Jark Wu <[email protected]>
AuthorDate: Mon Dec 1 10:07:36 2025 +0800
add javadoc
---
.../src/main/java/org/apache/fluss/record/FileLogProjection.java | 5 +----
.../main/java/org/apache/fluss/record/ProjectionPushdownCache.java | 4 ++++
2 files changed, 5 insertions(+), 4 deletions(-)
diff --git
a/fluss-common/src/main/java/org/apache/fluss/record/FileLogProjection.java
b/fluss-common/src/main/java/org/apache/fluss/record/FileLogProjection.java
index 546275f55..9f227adb1 100644
--- a/fluss-common/src/main/java/org/apache/fluss/record/FileLogProjection.java
+++ b/fluss-common/src/main/java/org/apache/fluss/record/FileLogProjection.java
@@ -455,7 +455,6 @@ public class FileLogProjection {
nodesProjection,
buffersProjection,
bufferIndex,
- rowType,
metadataLength,
bodyCompression,
selectedFieldPositions);
@@ -492,11 +491,11 @@ public class FileLogProjection {
return selectedFieldPositions;
}
+ /** Projection pushdown information for a specific schema and selected
fields. */
public static final class ProjectionInfo {
final BitSet nodesProjection;
final BitSet buffersProjection;
final int bufferCount;
- final RowType schema;
final int arrowMetadataLength;
final ArrowBodyCompression bodyCompression;
final int[] selectedFieldPositions;
@@ -505,14 +504,12 @@ public class FileLogProjection {
BitSet nodesProjection,
BitSet buffersProjection,
int bufferCount,
- RowType schema,
int arrowMetadataLength,
ArrowBodyCompression bodyCompression,
int[] selectedFieldPositions) {
this.nodesProjection = nodesProjection;
this.buffersProjection = buffersProjection;
this.bufferCount = bufferCount;
- this.schema = schema;
this.arrowMetadataLength = arrowMetadataLength;
this.bodyCompression = bodyCompression;
this.selectedFieldPositions = selectedFieldPositions;
diff --git
a/fluss-common/src/main/java/org/apache/fluss/record/ProjectionPushdownCache.java
b/fluss-common/src/main/java/org/apache/fluss/record/ProjectionPushdownCache.java
index dc5821e70..a2d3da1ae 100644
---
a/fluss-common/src/main/java/org/apache/fluss/record/ProjectionPushdownCache.java
+++
b/fluss-common/src/main/java/org/apache/fluss/record/ProjectionPushdownCache.java
@@ -28,6 +28,10 @@ import java.time.Duration;
import java.util.Arrays;
import java.util.Objects;
+/**
+ * A cache for projection pushdown information. The cache key is composed of
table id, schema id,
+ * and selected column ids. The cache is designed to be shared across
different tables and schemas.
+ */
@ThreadSafe
public class ProjectionPushdownCache {
