This is an automated email from the ASF dual-hosted git repository.
martinzink pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
from dc5c441ed MINIFICPP-2445 Allow NiFi Python Source processor triggering
without creating flow files
new 1e199675e MINIFICPP-2439 Restrict failure and original python
relationship usage
new 76c33cb73 MINIFICPP-2441: Refactored Creating Properties via to_array
to Auto Determine Number of Properties
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docker/test/integration/cluster/ImageStore.py | 8 ++++++--
docker/test/integration/features/python.feature | 24 ++++++++++++++++++++++
...{RotatingForwarder.py => FailureWithContent.py} | 6 +++---
...{RotatingForwarder.py => TransferToOriginal.py} | 6 +++---
...lureWithAttributes.py => FailureWithContent.py} | 4 ++--
.../python/ProcessContextInterfaceChecker.py | 16 +++++++--------
.../resources/python/SpecialPropertyTypeChecker.py | 22 ++++++++++----------
...lureWithAttributes.py => TransferToOriginal.py} | 4 ++--
.../aws/controllerservices/AWSCredentialsService.h | 4 ++--
extensions/aws/processors/DeleteS3Object.h | 4 ++--
extensions/aws/processors/FetchS3Object.h | 4 ++--
extensions/aws/processors/ListS3.h | 4 ++--
extensions/aws/processors/PutS3Object.h | 4 ++--
extensions/aws/processors/S3Processor.h | 4 ++--
.../AzureStorageCredentialsService.h | 4 ++--
.../processors/AzureBlobStorageProcessorBase.h | 4 ++--
.../AzureBlobStorageSingleBlobProcessorBase.h | 2 +-
.../AzureDataLakeStorageFileProcessorBase.h | 2 +-
.../processors/AzureDataLakeStorageProcessorBase.h | 4 ++--
.../azure/processors/AzureStorageProcessorBase.h | 2 +-
.../azure/processors/DeleteAzureBlobStorage.h | 2 +-
.../azure/processors/FetchAzureBlobStorage.h | 4 ++--
.../azure/processors/FetchAzureDataLakeStorage.h | 4 ++--
extensions/azure/processors/ListAzureBlobStorage.h | 4 ++--
.../azure/processors/ListAzureDataLakeStorage.h | 4 ++--
extensions/azure/processors/PutAzureBlobStorage.h | 2 +-
.../azure/processors/PutAzureDataLakeStorage.h | 2 +-
extensions/bustache/ApplyTemplate.h | 2 +-
extensions/civetweb/processors/ListenHTTP.h | 4 ++--
.../ElasticsearchCredentialsControllerService.h | 4 ++--
extensions/elasticsearch/PostElasticsearch.h | 4 ++--
extensions/execute-process/ExecuteProcess.h | 4 ++--
.../tests/ProcessContextExprTests.cpp | 2 +-
.../GCPCredentialsControllerService.h | 5 +++--
extensions/gcp/processors/DeleteGCSObject.h | 4 ++--
extensions/gcp/processors/FetchGCSObject.h | 4 ++--
extensions/gcp/processors/GCSProcessor.h | 4 ++--
extensions/gcp/processors/ListGCSBucket.h | 4 ++--
extensions/gcp/processors/PutGCSObject.h | 4 ++--
extensions/gps/GetGPS.h | 4 ++--
extensions/grafana-loki/PushGrafanaLoki.h | 4 ++--
extensions/grafana-loki/PushGrafanaLokiGrpc.h | 4 ++--
extensions/grafana-loki/PushGrafanaLokiREST.h | 4 ++--
.../KubernetesControllerService.h | 4 ++--
.../processors/CollectKubernetesPodMetrics.h | 2 +-
extensions/libarchive/BinFiles.h | 4 ++--
extensions/libarchive/CompressContent.h | 4 ++--
extensions/libarchive/FocusArchiveEntry.h | 2 +-
extensions/libarchive/ManipulateArchive.h | 4 ++--
extensions/libarchive/MergeContent.h | 4 ++--
extensions/librdkafka/ConsumeKafka.h | 4 ++--
extensions/librdkafka/KafkaProcessorBase.h | 4 ++--
extensions/librdkafka/PublishKafka.h | 4 ++--
extensions/mqtt/processors/AbstractMQTTProcessor.h | 8 ++++----
extensions/mqtt/processors/ConsumeMQTT.h | 4 ++--
extensions/mqtt/processors/PublishMQTT.h | 4 ++--
extensions/opc/include/fetchopc.h | 4 ++--
extensions/opc/include/opcbase.h | 4 ++--
extensions/opc/include/putopc.h | 4 ++--
extensions/opencv/CaptureRTSPFrame.h | 4 ++--
extensions/opencv/MotionDetector.h | 4 ++--
extensions/pdh/PerformanceDataMonitor.h | 4 ++--
extensions/procfs/processors/ProcFsMonitor.h | 4 ++--
extensions/python/ExecutePythonProcessor.h | 4 ++--
.../pythonprocessors/nifiapi/flowfiletransform.py | 8 ++++++++
.../controllers/RocksDbStateStorage.h | 4 ++--
extensions/script/ExecuteScript.h | 4 ++--
extensions/sftp/processors/FetchSFTP.h | 4 ++--
extensions/sftp/processors/ListSFTP.h | 4 ++--
extensions/sftp/processors/PutSFTP.h | 4 ++--
extensions/sftp/processors/SFTPProcessorBase.h | 4 ++--
extensions/smb/FetchSmb.h | 4 ++--
extensions/smb/ListSmb.h | 4 ++--
extensions/smb/PutSmb.h | 2 +-
extensions/smb/SmbConnectionControllerService.h | 4 ++--
extensions/splunk/PutSplunkHTTP.h | 4 ++--
extensions/splunk/QuerySplunkIndexingStatus.h | 4 ++--
extensions/splunk/SplunkHECProcessor.h | 4 ++--
extensions/sql/processors/ExecuteSQL.h | 2 +-
extensions/sql/processors/FlowFileSource.h | 2 +-
extensions/sql/processors/PutSQL.h | 2 +-
extensions/sql/processors/QueryDatabaseTable.h | 4 ++--
extensions/sql/processors/SQLProcessor.h | 2 +-
extensions/sql/services/DatabaseService.h | 2 +-
.../controllers/JsonRecordSetWriter.h | 4 ++--
.../controllers/PersistentMapStateStorage.h | 4 ++--
.../controllers/VolatileMapStateStorage.h | 2 +-
.../standard-processors/modbus/FetchModbusTcp.h | 4 ++--
.../processors/AppendHostInfo.h | 4 ++--
.../processors/AttributeRollingWindow.h | 4 ++--
.../processors/AttributesToJSON.h | 4 ++--
.../processors/DefragmentText.h | 4 ++--
.../standard-processors/processors/ExtractText.h | 4 ++--
.../standard-processors/processors/FetchFile.h | 4 ++--
.../processors/GenerateFlowFile.h | 4 ++--
.../standard-processors/processors/GetFile.h | 4 ++--
extensions/standard-processors/processors/GetTCP.h | 4 ++--
.../standard-processors/processors/HashContent.h | 4 ++--
.../standard-processors/processors/InvokeHTTP.h | 4 ++--
.../processors/JoltTransformJSON.h | 4 ++--
.../standard-processors/processors/ListFile.h | 4 ++--
.../standard-processors/processors/ListenSyslog.h | 4 ++--
.../standard-processors/processors/ListenTCP.h | 4 ++--
.../standard-processors/processors/ListenUDP.h | 4 ++--
.../standard-processors/processors/LogAttribute.h | 4 ++--
.../standard-processors/processors/PutFile.h | 8 +++++---
extensions/standard-processors/processors/PutTCP.h | 4 ++--
extensions/standard-processors/processors/PutUDP.h | 2 +-
.../standard-processors/processors/ReplaceText.h | 4 ++--
.../standard-processors/processors/RetryFlowFile.h | 4 ++--
.../standard-processors/processors/RouteText.h | 4 ++--
.../standard-processors/processors/SplitText.h | 4 ++--
.../standard-processors/processors/TailFile.h | 4 ++--
.../tests/unit/FlowJsonTests.cpp | 2 +-
.../tests/unit/YamlConfigurationTests.cpp | 18 ++++++++--------
extensions/systemd/ConsumeJournald.h | 4 ++--
extensions/test-processors/KamikazeProcessor.h | 4 ++--
.../windows-event-log/ConsumeWindowsEventLog.h | 4 ++--
extensions/windows-event-log/TailEventLog.h | 4 ++--
.../tests/ConsumeWindowsEventLogTests.cpp | 8 ++++----
libminifi/include/RemoteProcessorGroupPort.h | 4 ++--
.../controllers/LinuxPowerManagementService.h | 4 ++--
.../controllers/NetworkPrioritizerService.h | 4 ++--
libminifi/include/controllers/SSLContextService.h | 6 +++---
.../controllers/UpdatePolicyControllerService.h | 4 ++--
libminifi/test/flow-tests/CustomProcessors.h | 2 +-
libminifi/test/unit/AbstractProcessorTest.cpp | 4 ++--
libminifi/test/unit/ComponentManifestTests.cpp | 2 +-
libminifi/test/unit/ProcessorConfigUtilsTests.cpp | 2 +-
129 files changed, 301 insertions(+), 262 deletions(-)
copy docker/test/integration/minifi/processors/{RotatingForwarder.py =>
FailureWithContent.py} (89%)
copy docker/test/integration/minifi/processors/{RotatingForwarder.py =>
TransferToOriginal.py} (89%)
copy docker/test/integration/resources/python/{FailureWithAttributes.py =>
FailureWithContent.py} (87%)
copy docker/test/integration/resources/python/{FailureWithAttributes.py =>
TransferToOriginal.py} (87%)
