This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a change to branch support/nifi-1.x
in repository https://gitbox.apache.org/repos/asf/nifi.git
from 7f0cedf6b6 NIFI-12387 Initialize Controller Service Comments with
Empty String
add fa9f05812a NIFI-11294 Support Component State Checkpoints in
ConsumeAzureEventHub
No new revisions were added by this update.
Summary of changes:
.../org/apache/nifi/state/MockStateManager.java | 29 +-
.../nifi-azure-processors/pom.xml | 6 +
.../azure/eventhub/ConsumeAzureEventHub.java | 152 ++++++--
.../eventhub/checkpoint/CheckpointStoreKey.java | 33 ++
.../checkpoint/CheckpointStoreKeyPrefix.java | 33 ++
.../eventhub/checkpoint/CheckpointStrategy.java | 48 +++
.../checkpoint/ComponentStateCheckpointStore.java | 333 +++++++++++++++++
.../ComponentStateCheckpointStoreUtils.java | 163 +++++++++
.../ClusterNodeDisconnectedException.java | 24 ++
.../ComponentStateCheckpointStoreException.java | 28 ++
.../ConcurrentStateModificationException.java | 24 ++
.../exception/StateNotAvailableException.java | 24 ++
.../azure/eventhub/TestConsumeAzureEventHub.java | 14 +
.../checkpoint/AbstractCheckpointStoreTest.java | 220 +++++++++++
.../AbstractComponentStateCheckpointStoreTest.java | 72 ++++
...mponentStateCheckpointStoreConcurrencyTest.java | 182 ++++++++++
.../ComponentStateCheckpointStoreFailureTest.java | 255 +++++++++++++
.../ComponentStateCheckpointStoreTest.java | 403 +++++++++++++++++++++
.../ComponentStateCheckpointStoreUtilsTest.java | 129 +++++++
19 files changed, 2128 insertions(+), 44 deletions(-)
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/checkpoint/CheckpointStoreKey.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/checkpoint/CheckpointStoreKeyPrefix.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/checkpoint/CheckpointStrategy.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/checkpoint/ComponentStateCheckpointStore.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/checkpoint/ComponentStateCheckpointStoreUtils.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/checkpoint/exception/ClusterNodeDisconnectedException.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/checkpoint/exception/ComponentStateCheckpointStoreException.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/checkpoint/exception/ConcurrentStateModificationException.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/eventhub/checkpoint/exception/StateNotAvailableException.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/test/java/org/apache/nifi/processors/azure/eventhub/checkpoint/AbstractCheckpointStoreTest.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/test/java/org/apache/nifi/processors/azure/eventhub/checkpoint/AbstractComponentStateCheckpointStoreTest.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/test/java/org/apache/nifi/processors/azure/eventhub/checkpoint/ComponentStateCheckpointStoreConcurrencyTest.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/test/java/org/apache/nifi/processors/azure/eventhub/checkpoint/ComponentStateCheckpointStoreFailureTest.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/test/java/org/apache/nifi/processors/azure/eventhub/checkpoint/ComponentStateCheckpointStoreTest.java
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/test/java/org/apache/nifi/processors/azure/eventhub/checkpoint/ComponentStateCheckpointStoreUtilsTest.java
