(nifi) branch main updated: NIFI-15241 Improved extensibility of WriteAheadProvenanceRepository (#10553)

[exceptionfactory]

This is an automated email from the ASF dual-hosted git repository.

exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new 9346cf0fac NIFI-15241 Improved extensibility of 
WriteAheadProvenanceRepository (#10553)
9346cf0fac is described below

commit 9346cf0fac0aad0ef248210332c65c0eee1ff2e0
Author: Peter Turcsanyi <35004384+turcsan...@users.noreply.github.com>
AuthorDate: Mon Nov 24 21:55:09 2025 +0100

    NIFI-15241 Improved extensibility of WriteAheadProvenanceRepository (#10553)
    
    - Adjusted selected method visibility from package-private to protected
    
    Signed-off-by: David Handermann <exceptionfact...@apache.org>
---
 .../nifi/provenance/EventIdFirstSchemaRecordReader.java  | 16 ++++++++--------
 .../nifi/provenance/WriteAheadProvenanceRepository.java  |  6 +++---
 2 files changed, 11 insertions(+), 11 deletions(-)

diff --git 
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/EventIdFirstSchemaRecordReader.java
 
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/EventIdFirstSchemaRecordReader.java
index 797402e280..0dcb942449 100644
--- 
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/EventIdFirstSchemaRecordReader.java
+++ 
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/EventIdFirstSchemaRecordReader.java
@@ -35,11 +35,11 @@ import org.apache.nifi.stream.io.LimitingInputStream;
 import org.apache.nifi.stream.io.StreamUtils;
 
 public class EventIdFirstSchemaRecordReader extends CompressableRecordReader {
-    RecordSchema getSchema() {
+    protected RecordSchema getSchema() {
         return schema;
     }
 
-    SchemaRecordReader getRecordReader() {
+    protected SchemaRecordReader getRecordReader() {
         return recordReader;
     }
 
@@ -52,27 +52,27 @@ public class EventIdFirstSchemaRecordReader extends 
CompressableRecordReader {
     private List<String> eventTypes;
     private long firstEventId;
 
-    List<String> getComponentIds() {
+    protected List<String> getComponentIds() {
         return componentIds;
     }
 
-    List<String> getComponentTypes() {
+    protected List<String> getComponentTypes() {
         return componentTypes;
     }
 
-    List<String> getQueueIds() {
+    protected List<String> getQueueIds() {
         return queueIds;
     }
 
-    List<String> getEventTypes() {
+    protected List<String> getEventTypes() {
         return eventTypes;
     }
 
-    long getFirstEventId() {
+    protected long getFirstEventId() {
         return firstEventId;
     }
 
-    long getSystemTimeOffset() {
+    protected long getSystemTimeOffset() {
         return systemTimeOffset;
     }
 
diff --git 
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/WriteAheadProvenanceRepository.java
 
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/WriteAheadProvenanceRepository.java
index 583d84d64c..9b5afc7243 100644
--- 
a/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/WriteAheadProvenanceRepository.java
+++ 
b/nifi-framework-bundle/nifi-framework-extensions/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/WriteAheadProvenanceRepository.java
@@ -89,7 +89,7 @@ import java.util.Set;
  */
 public class WriteAheadProvenanceRepository implements ProvenanceRepository {
     private static final Logger logger = 
LoggerFactory.getLogger(WriteAheadProvenanceRepository.class);
-    static final int BLOCK_SIZE = 1024 * 32;
+    protected static final int BLOCK_SIZE = 1024 * 32;
     public static final String EVENT_CATEGORY = "Provenance Repository";
 
     private final RepositoryConfiguration config;
@@ -139,7 +139,7 @@ public class WriteAheadProvenanceRepository implements 
ProvenanceRepository {
        init(recordWriterFactory, recordReaderFactory, eventReporter, 
authorizer, resourceFactory, fileManager);
     }
 
-    synchronized void init(RecordWriterFactory recordWriterFactory, 
RecordReaderFactory recordReaderFactory,
+    protected synchronized void init(RecordWriterFactory recordWriterFactory, 
RecordReaderFactory recordReaderFactory,
                            final EventReporter eventReporter, final Authorizer 
authorizer,
                            final ProvenanceAuthorizableFactory 
resourceFactory, final EventFileManager fileManager) throws IOException {
 
@@ -301,7 +301,7 @@ public class WriteAheadProvenanceRepository implements 
ProvenanceRepository {
         return Collections.unmodifiableList(config.getSearchableAttributes());
     }
 
-    RepositoryConfiguration getConfig() {
+    protected RepositoryConfiguration getConfig() {
         return this.config;
     }