This is an automated email from the ASF dual-hosted git repository. mattyb149 pushed a change to branch main in repository https://gitbox.apache.org/repos/asf/nifi.git.
from b9076ca NIFI-7989: Add Update Field Names and Record Writer to UpdateHiveTable processors add 097edf4 NIFI-8136: Added getState/setState/replaceState/clearState methods to ProcessSession, updated processors to use these methods instead of StateManager version where appropriate No new revisions were added by this update. Summary of changes: .../org/apache/nifi/processor/ProcessSession.java | 71 +++++++- .../org/apache/nifi/state/MockStateManager.java | 47 +++++- .../org/apache/nifi/util/MockProcessSession.java | 67 +++++--- .../org/apache/nifi/util/MockSessionFactory.java | 14 +- .../nifi/util/StandardProcessorTestRunner.java | 61 +++---- .../apache/nifi/util/TestMockProcessSession.java | 30 ++-- .../org/apache/nifi/processors/aws/s3/ListS3.java | 69 ++++---- .../cdc/mysql/processors/CaptureChangeMySQL.java | 180 +++++++++++---------- .../mysql/processors/CaptureChangeMySQLTest.groovy | 19 +-- .../elasticsearch/ScrollElasticsearchHttp.java | 23 +-- .../processor/util/list/AbstractListProcessor.java | 59 ++++--- .../repository/AbstractRepositoryContext.java | 11 +- .../controller/repository/RepositoryContext.java | 3 + .../repository/StandardProcessSession.java | 141 +++++++++++++++- .../org/apache/nifi/controller/FlowController.java | 71 ++++---- .../repository/BatchingSessionFactory.java | 41 +++-- .../repository/StandardRepositoryContext.java | 6 +- .../scheduling/RepositoryContextFactory.java | 9 +- .../repository/StandardProcessSessionIT.java | 147 ++++++++++++++++- .../flow/StandardStatelessDataflowFactory.java | 3 +- .../repository/StatelessRepositoryContext.java | 6 +- .../StatelessRepositoryContextFactory.java | 10 +- .../nifi/processors/gcp/storage/ListGCSBucket.java | 39 ++--- .../processors/gcp/storage/ListGCSBucketTest.java | 11 +- .../groovyx/flow/GroovyProcessSessionWrap.java | 5 +- .../groovyx/flow/ProcessSessionWrap.java | 45 ++++-- .../apache/nifi/processors/hadoop/ListHDFS.java | 4 +- .../processors/hadoop/inotify/GetHDFSEvents.java | 13 +- .../main/java/org/apache/nifi/hbase/GetHBase.java | 71 ++++---- .../org/apache/nifi/processors/solr/GetSolr.java | 12 +- .../apache/nifi/processors/splunk/GetSplunk.java | 15 +- .../standard/AbstractQueryDatabaseTable.java | 11 +- .../nifi/processors/standard/EnforceOrder.java | 13 +- .../processors/standard/GenerateTableFetch.java | 12 +- .../apache/nifi/processors/standard/GetHTTP.java | 69 ++++---- .../processors/standard/ListDatabaseTables.java | 13 +- .../nifi/processors/standard/MonitorActivity.java | 9 +- .../apache/nifi/processors/standard/TailFile.java | 27 ++-- .../stateful/analysis/AttributeRollingWindow.java | 14 +- .../processors/attributes/UpdateAttribute.java | 4 +- 40 files changed, 968 insertions(+), 507 deletions(-)