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(-)
