This is an automated email from the ASF dual-hosted git repository.
manishswaminathan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 783075165da Add configs when initing column reader factory (#17635)
783075165da is described below
commit 783075165da49ee23b8e5e56215ddf9697926b35
Author: Krishan Goyal <[email protected]>
AuthorDate: Thu Feb 5 19:53:14 2026 +0530
Add configs when initing column reader factory (#17635)
---
.../pinot/spi/data/readers/ColumnReaderFactory.java | 18 ++++++++++++++++++
1 file changed, 18 insertions(+)
diff --git
a/pinot-spi/src/main/java/org/apache/pinot/spi/data/readers/ColumnReaderFactory.java
b/pinot-spi/src/main/java/org/apache/pinot/spi/data/readers/ColumnReaderFactory.java
index e31293c0b96..ce9a9c3cc90 100644
---
a/pinot-spi/src/main/java/org/apache/pinot/spi/data/readers/ColumnReaderFactory.java
+++
b/pinot-spi/src/main/java/org/apache/pinot/spi/data/readers/ColumnReaderFactory.java
@@ -41,6 +41,12 @@ import org.apache.pinot.spi.data.Schema;
*/
public interface ColumnReaderFactory extends Closeable, Serializable {
+ /**
+ * Configuration key to enable random access mode for column readers.
+ * When set to "true", implementations may cache data to support
non-sequential access patterns.
+ */
+ String CONFIG_ENABLE_RANDOM_ACCESS = "enableRandomAccess";
+
/**
* Initialize the factory with the data source and target schema.
*
@@ -59,6 +65,18 @@ public interface ColumnReaderFactory extends Closeable,
Serializable {
void init(Schema targetSchema, Set<String> colsToRead)
throws IOException;
+ /**
+ * Initialize the factory with the data source, target schema, specific
columns, and configuration.
+ * @param targetSchema Target schema for the output segment
+ * @param colsToRead Set of target columns to read
+ * @param configs Configuration map for implementation-specific settings
+ * @throws IOException If initialization fails
+ */
+ default void init(Schema targetSchema, Set<String> colsToRead, Map<String,
String> configs)
+ throws IOException {
+ init(targetSchema, colsToRead);
+ }
+
/**
* Get the set of column names available in the source data.
*
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
