This is an automated email from the ASF dual-hosted git repository.
fgerlits pushed a change to branch
MINIFICPP-2019_Fix-autogeneration-of-processors-md
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
omit 5331a2377 fix a typo in the Description of PutS3Object
omit 4a69170c4 add unit tests for TableFormatter
omit b617491a4 rename: find_widths() -> findWidths()
omit e256beadd merge fixes
omit 12427fbd5 rebase fix
omit d27a9cecd add a missing include guard
omit 96e8583cc fix a typo
omit e33e5ff50 update PROCESSORS.md and unify Description strings with
descriptions in PROCESSORS.md
omit afcf304d7 MINIFICPP-2019 Fix the auto-generation of PROCESSORS.md
add 556407c86 MINIFICPP-2024 Refactor repository hierarchy
add 2600a98f8 MINIFICPP-2044 Make listing processors single threaded
add e63a287fe MINIFICPP-1997 Fix transiently failing
FileSystemRepositoryTests
add ce288b920 MINIFICPP-2035 NiFi flow json format support
add 5a9c1c334 MINIFICPP-2034 Cache SID lookups in CWEL
add 7e8c5c49c MINIFICPP-2045 Synchronous flow file reloading
add 2c7f989ae MINIFICPP-2007 Add rocksdb compression options
add c4c80e630 MINIFICPP-2047 added reverseDnsLookup to EL
add f27e349b5 MINIFICPP-1887 Add default connection size limits
add 9c5e2996b MINIFICPP-2041 Fix transient failure of
HttpPostIntegrationTestChunked
add 268985995 MINIFICPP-2057 Improve the performance of ListFile
add 7942e0e7f MINIFICPP-2053 Reduce CentOS image size in CI build
add 0a937973e MINIFICPP-2055 Remove C2 metrics from default configuration
add 32043f51f MINIFICPP-2061 reverseDnsLookup shouldn't throw on timeout
add 7425983a1 MINIFICPP-2054 Periodically run rocksdb compaction
add 033ef9d0a MINIFICPP-2059 Handle content repository remove failures
add 62ec9a5fd MINIFICPP-2064 Skip extensions which have not been loaded
add a57e38c75 MINIFICPP-2065 Only accept configuration format the agent
can handle
add d12c354ea MINIFICPP-2056 CWEL: support UserData in json Closes #1515
add ab396b7aa MINIFICPP-2066 Close handle when querying file owner on
Windows Closes #1523
add 09153adc6 MINIFICPP-2067 Remove OpenSSL system dependency from MQTT
add 70015a3a5 MINIFICPP-1961 Use Python stable ABI instead of pybind11
add 314fd81d6 MINIFICPP-1869 Metrics-related refactoring
add 7ad624d19 MINIFICPP-2028 Remove SerializableComponent dependency from
Repository
add 06d5467c6 MINIFICPP-2048 ARM64 support part 1
add 551be5b55 MINIFICPP-2068 Fix transiently failing "Reverse DNS lookup
with valid timeout parameter" testcase
add 247393bf4 MINIFICPP-2078 Remove cleanup from __del__ functions closes
#1533
add 333971ad5 MINIFICPP-2079 Fix OOM in python.feature
add be34911e8 MINIFICPP-2075 Fix flaky PutTCPTests testcase
add e775efaff MINIFICPP-1713 Fix transient segfault in RepoTests
add 28087bfa7 MINIFICPP-2080 Add missing processors to README.md
add dc94061d8 MINIFICPP-2085 Clear stale processor controller cache on
flow update
add 29659402e MINIFICPP-2086 Add more specific flow media type
add 7771c651a MINIFICPP-2072 Docker test for ListenSyslog/ReplaceText
workflow
add 5f44a0cc6 MINIFICPP-2019 Fix the auto-generation of PROCESSORS.md
add 027c1849a update PROCESSORS.md and unify Description strings with
descriptions in PROCESSORS.md
add fb961705a fix a typo
add 6e5648366 add a missing include guard
add e43537335 rebase fix
add 7f2121e6e merge fixes
add 9e9a71cd7 rename: find_widths() -> findWidths()
add fcbc203ef add unit tests for TableFormatter
add ee90f7f19 fix a typo in the Description of PutS3Object
add 7769fcf5e Fix the description of ConsumeJournald::TimestampFormat
add db384d7d5 Fix a typo in the description of
ConsumeKafka::HeadersToAddAsAttributes
add 94f0a3f79 Change the order of the allowed values in
ConsumeWindowsEventLog::JSONFormat
add 2af3e5ee2 Expand the description of the GCP Credentials Provider
Service property.
add 33616e4aa Expand the description of ExecutePythonProcessor.
add 49f605fef Restore the description of ExecuteSQL.
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (5331a2377)
\
N -- N -- N
refs/heads/MINIFICPP-2019_Fix-autogeneration-of-processors-md (49f605fef)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci.yml | 28 +-
.github/workflows/verify-python-compatibility.yml | 140 +
CMakeLists.txt | 16 +-
CMakeSettings.json | 2 +-
CONFIGURE.md | 19 +-
EXPRESSIONS.md | 26 +
LICENSE | 134 +-
NOTICE | 2 +
PROCESSORS.md | 46 +-
README.md | 109 +-
Windows.md | 62 +-
bootstrap.sh | 9 +-
bstrp_functions.sh | 25 +-
cmake/BundledOSSPUUID.cmake | 13 +-
cmake/BundledRocksDB.cmake | 35 +-
cmake/BundledZLIB.cmake | 1 -
cmake/Crc32c.cmake | 4 +-
cmake/DockerConfig.cmake | 22 +-
...onSchemaValidator.cmake => GenericPython.cmake} | 18 +-
cmake/JsonSchemaValidator.cmake | 1 +
cmake/LZ4.cmake | 53 +
cmake/MiNiFiOptions.cmake | 6 +-
cmake/PahoMqttC.cmake | 5 +
cmake/VerifyPythonCompatibility.cmake | 82 +
cmake/Zstd.cmake | 56 +
.../dummy/Findlz4.cmake} | 23 +-
.../{Pybind11.cmake => zstd/dummy/Findzstd.cmake} | 27 +-
conf/minifi.properties | 25 +-
controller/Controller.h | 12 +-
docker/DockerBuild.sh | 7 +-
docker/DockerVerify.sh | 105 +-
docker/Dockerfile | 4 +-
docker/bionic/Dockerfile | 3 +-
docker/centos/Dockerfile | 18 +-
docker/fedora/Dockerfile | 3 +-
docker/focal/Dockerfile | 3 +-
docker/python-verify/conda.Dockerfile | 43 +
docker/python-verify/conda.dockerignore | 1 +
docker/python-verify/installed.Dockerfile | 46 +
docker/python-verify/installed.dockerignore | 2 +
docker/python-verify/venv.Dockerfile | 32 +
docker/python-verify/venv.dockerignore | 1 +
.../integration/MiNiFi_integration_test_driver.py | 12 +-
docker/test/integration/cluster/ContainerStore.py | 6 +-
.../test/integration/cluster/DockerTestCluster.py | 6 +-
docker/test/integration/cluster/ImageStore.py | 3 -
docker/test/integration/cluster/KubernetesProxy.py | 3 -
.../integration/cluster/containers/Container.py | 3 -
.../cluster/containers/MinifiContainer.py | 14 +-
docker/test/integration/features/CMakeLists.txt | 8 +-
.../{script.feature => lua_script.feature} | 13 +-
docker/test/integration/features/python.feature | 8 +
.../{script.feature => python_script.feature} | 13 +-
.../features/python_with_modules.feature | 23 +-
docker/test/integration/features/s2s.feature | 7 +-
docker/test/integration/features/sql.feature | 3 +-
.../integration/features/syslog_listener.feature | 12 +-
.../filesystem_validation/FileSystemObserver.py | 2 +-
.../Minifi_flow_json_serializer.py | 141 +
.../minifi/processors/CountingProcessor.py | 15 +-
.../processors/GaussianDistributionWithNumpy.py | 15 +-
.../minifi/validators/FileOutputValidator.py | 17 +
.../SingleOrMultiFileOutputRegexValidator.py | 28 +-
docker/test/integration/steps/steps.py | 10 +
encrypt-config/tests/resources/minifi.properties | 18 +-
...th-additional-sensitive-props.minifi.properties | 18 +-
extensions/aws/CMakeLists.txt | 2 +-
extensions/aws/processors/ListS3.h | 2 +-
.../aws/tests}/AWSCredentialsServiceTest.cpp | 6 +-
.../aws/tests}/CMakeLists.txt | 3 +
.../aws/tests}/DeleteS3ObjectTests.cpp | 0
.../aws/tests}/FetchS3ObjectTests.cpp | 0
.../aws/tests}/ListS3Tests.cpp | 0
.../aws/tests}/MockS3RequestSender.h | 0
.../aws/tests}/PutS3ObjectTests.cpp | 0
.../aws/tests}/S3TestsFixture.h | 4 +-
extensions/azure/processors/ListAzureBlobStorage.h | 2 +-
.../azure/processors/ListAzureDataLakeStorage.h | 2 +-
extensions/civetweb/processors/ListenHTTP.cpp | 1 +
extensions/coap/tests/CoapIntegrationBase.h | 7 +-
extensions/expression-language/Expression.cpp | 28 +
.../tests/ExpressionLanguageTests.cpp | 73 +
.../processors/GCSProcessorStaticDefinitions.cpp | 2 +-
extensions/http-curl/protocols/RESTSender.cpp | 17 +-
extensions/http-curl/protocols/RESTSender.h | 7 +-
.../tests/C2ClearCoreComponentStateTest.cpp | 2 +-
.../http-curl/tests/C2DescribeMetricsTest.cpp | 1 -
extensions/http-curl/tests/C2EmptyMetricTest.cpp | 1 -
extensions/http-curl/tests/C2LogHeartbeatTest.cpp | 2 +-
extensions/http-curl/tests/C2MetricsTest.cpp | 1 -
extensions/http-curl/tests/C2PauseResumeTest.cpp | 9 +-
.../http-curl/tests/C2SameProcessorMetrics.cpp | 1 -
extensions/http-curl/tests/C2UpdateAssetTest.cpp | 3 +
.../tests/ControllerServiceIntegrationTests.cpp | 6 +-
.../http-curl/tests/HttpPostIntegrationTest.cpp | 2 +-
extensions/http-curl/tests/VerifyInvokeHTTP.h | 5 +-
extensions/libarchive/CMakeLists.txt | 6 -
.../librdkafka/KafkaProcessorStaticDefinitions.cpp | 2 +-
extensions/lua/CMakeLists.txt | 45 +
extensions/{script => }/lua/LuaInputStream.cpp | 4 +-
extensions/{script => }/lua/LuaInputStream.h | 4 +-
extensions/{script => }/lua/LuaOutputStream.cpp | 4 +-
extensions/{script => }/lua/LuaOutputStream.h | 4 +-
extensions/{script => }/lua/LuaProcessSession.cpp | 28 +-
extensions/{script => }/lua/LuaProcessSession.h | 22 +-
extensions/lua/LuaScriptEngine.cpp | 137 +
extensions/lua/LuaScriptEngine.h | 90 +
.../lua/LuaScriptException.h | 18 +-
extensions/lua/LuaScriptExecutor.cpp | 75 +
extensions/lua/LuaScriptExecutor.h | 51 +
.../LuaScriptFlowFile.cpp} | 31 +-
.../ScriptFlowFile.h => lua/LuaScriptFlowFile.h} | 17 +-
.../LuaScriptProcessContext.cpp} | 20 +-
.../LuaScriptProcessContext.h} | 16 +-
.../lua/tests}/CMakeLists.txt | 28 +-
.../{script => lua}/tests/LuaScriptEngineTests.cpp | 18 +-
.../TestExecuteScriptProcessorWithLuaScript.cpp | 322 ++
.../tests/test_lua_scripts/bar_modules/bar.lua | 0
.../tests/test_lua_scripts/foo_bar_processor.lua | 0
.../tests/test_lua_scripts/foo_modules/foo.lua | 0
.../prometheus/PrometheusMetricsPublisher.cpp | 22 +-
extensions/prometheus/PrometheusMetricsPublisher.h | 10 +-
.../tests/PrometheusMetricsPublisherTest.cpp | 11 +-
extensions/python/CMakeLists.txt | 47 +
.../{script => }/python/ExecutePythonProcessor.cpp | 10 +-
.../{script => }/python/ExecutePythonProcessor.h | 11 +-
extensions/python/PyException.cpp | 54 +
.../PyInputStream.h => python/PyException.h} | 29 +-
extensions/python/PythonBindings.cpp | 87 +
.../python/PythonBindings.h | 20 +-
extensions/{script => }/python/PythonCreator.h | 4 +-
.../{script => }/python/PythonObjectFactory.h | 18 +-
extensions/{script => }/python/PythonProcessor.cpp | 10 +-
extensions/{script => }/python/PythonProcessor.h | 13 +-
extensions/python/PythonScriptEngine.cpp | 183 +
extensions/python/PythonScriptEngine.h | 147 +
.../PythonScriptException.h} | 25 +-
extensions/python/PythonScriptExecutor.cpp | 73 +
extensions/python/PythonScriptExecutor.h | 49 +
extensions/{script => python}/README.md | 36 +
.../pythonloader/PyProcLoader.cpp | 5 +-
.../examples/AddPythonAttribute.py | 0
.../examples/CountingProcessor.py} | 24 +-
.../examples/GaussianDistributionWithNumpy.py} | 26 +-
.../pythonprocessors/examples/MoveContentToJson.py | 0
.../pythonprocessors/examples/RemoveFlowFile.py | 0
.../pythonprocessors/examples/SentimentAnalysis.py | 0
.../pythonprocessors/google/SentimentAnalyzer.py | 0
.../pythonprocessors/h2o/ConvertDsToCsv.py | 0
.../h2o/h2o3/mojo/ExecuteH2oMojoScoring.py | 0
extensions/python/tests/CMakeLists.txt | 76 +
.../tests/ExecutePythonProcessorTests.cpp | 3 +-
.../tests/PythonManifestTests.cpp | 7 +-
.../python/tests/PythonScriptEngineTests.cpp | 76 +
.../TestExecuteScriptProcessorWithPythonScript.cpp | 265 +
.../tests/test_python_scripts/bar_modules/bar.py | 0
.../tests/test_python_scripts/foo_bar_processor.py | 0
.../tests/test_python_scripts/foo_modules/foo.py | 0
.../non_transferring_processor.py | 0
...passthrough_processor_transfering_to_failure.py | 0
...passthrough_processor_transfering_to_success.py | 0
.../test_python_scripts/stateful_processor.py | 0
extensions/python/types/BaseTypes.h | 247 +
extensions/python/types/PyInputStream.cpp | 91 +
.../python => python/types}/PyInputStream.h | 29 +-
extensions/python/types/PyLogger.cpp | 142 +
extensions/python/types/PyLogger.h | 49 +
extensions/python/types/PyOutputStream.cpp | 88 +
.../python => python/types}/PyOutputStream.h | 27 +-
extensions/python/types/PyProcessContext.cpp | 81 +
.../types/PyProcessContext.h} | 32 +-
extensions/python/types/PyProcessSession.cpp | 265 +
extensions/python/types/PyProcessSession.h | 68 +
extensions/python/types/PyProcessor.cpp | 127 +
.../types/PyProcessor.h} | 42 +-
extensions/python/types/PyRelationship.cpp | 72 +
.../types/PyRelationship.h} | 42 +-
extensions/python/types/PyScriptFlowFile.cpp | 145 +
extensions/python/types/PyScriptFlowFile.h | 48 +
extensions/python/types/Types.h | 365 ++
.../rocksdb-repos/DatabaseContentRepository.cpp | 102 +-
.../rocksdb-repos/DatabaseContentRepository.h | 53 +-
extensions/rocksdb-repos/FlowFileRepository.cpp | 241 +-
extensions/rocksdb-repos/FlowFileRepository.h | 171 +-
extensions/rocksdb-repos/ProvenanceRepository.cpp | 101 +
extensions/rocksdb-repos/ProvenanceRepository.h | 154 +-
extensions/rocksdb-repos/database/OpenRocksDb.cpp | 20 +-
extensions/rocksdb-repos/database/OpenRocksDb.h | 14 +-
extensions/rocksdb-repos/database/RocksDbUtils.cpp | 54 +
extensions/rocksdb-repos/database/RocksDbUtils.h | 21 +-
.../rocksdb-repos/database/StringAppender.cpp | 2 +-
extensions/script/CMakeLists.txt | 47 +-
extensions/script/ExecuteScript.cpp | 108 +-
extensions/script/ExecuteScript.h | 54 +-
.../script/{ScriptEngine.h => ScriptExecutor.h} | 46 +-
extensions/script/lua/LuaScriptEngine.cpp | 104 -
extensions/script/lua/LuaScriptEngine.h | 114 -
extensions/script/python/PyProcessSession.cpp | 152 -
extensions/script/python/PyProcessSession.h | 70 -
extensions/script/python/PythonBindings.h | 85 -
extensions/script/python/PythonScriptEngine.cpp | 83 -
extensions/script/python/PythonScriptEngine.h | 242 -
extensions/script/tests/CMakeLists.txt | 92 +-
extensions/script/tests/ExecuteScriptTests.cpp | 58 +
.../script/tests/PythonScriptEngineTests.cpp | 45 -
.../TestExecuteScriptProcessorWithLuaScript.cpp | 477 --
.../TestExecuteScriptProcessorWithPythonScript.cpp | 429 --
extensions/sftp/tests/ListSFTPTests.cpp | 42 +-
extensions/sql/processors/ExecuteSQL.h | 6 +-
.../standard-processors/processors/ListFile.cpp | 113 +-
.../standard-processors/processors/ListFile.h | 12 +-
.../tests/unit/AdaptiveConfigurationTests.cpp | 66 +
.../tests/unit/FlowJsonTests.cpp | 163 +
.../tests/unit/ListFileTests.cpp | 40 +-
.../tests/unit/ManifestTests.cpp | 70 +-
.../tests/unit/ProcessorTests.cpp | 16 +-
.../standard-processors/tests/unit/PutTCPTests.cpp | 18 +-
.../tests/unit/RetryFlowFileTests.cpp | 4 +-
.../tests/unit/TailFileTests.cpp | 50 +-
.../tests/unit/YamlConfigurationTests.cpp | 153 +-
.../tests/unit/YamlConnectionParserTest.cpp | 4 +-
extensions/systemd/ConsumeJournald.cpp | 4 +-
.../windows-event-log/ConsumeWindowsEventLog.cpp | 27 +-
.../windows-event-log/ConsumeWindowsEventLog.h | 7 +-
extensions/windows-event-log/tests/CMakeLists.txt | 6 +-
extensions/windows-event-log/tests/CWELTestUtils.h | 2 +-
.../tests/ConsumeWindowsEventLogTests.cpp | 82 +-
.../windows-event-log/tests/LookupCacherTests.cpp | 77 +
.../tests/MetadataWalkerTests.cpp | 24 +-
extensions/windows-event-log/wel/JSONUtils.cpp | 53 +-
.../wel/LookupCacher.cpp} | 30 +-
.../wel/LookupCacher.h} | 58 +-
.../windows-event-log/wel/MetadataWalker.cpp | 5 +-
extensions/windows-event-log/wel/MetadataWalker.h | 10 +-
libminifi/CMakeLists.txt | 2 +-
libminifi/include/Connection.h | 110 +-
libminifi/include/FlowController.h | 110 +-
libminifi/include/RemoteProcessorGroupPort.h | 4 +
libminifi/include/RootProcessGroupWrapper.h | 91 +
libminifi/include/c2/C2Agent.h | 29 +-
.../c2/{C2Client.h => C2MetricsPublisher.h} | 49 +-
libminifi/include/c2/C2Protocol.h | 5 +
.../include/c2/C2Utils.h | 22 +-
libminifi/include/core/ContentRepository.h | 27 +-
libminifi/include/core/Flow.h | 59 -
libminifi/include/core/FlowConfiguration.h | 6 +-
libminifi/include/core/ProcessGroup.h | 2 -
libminifi/include/core/Processor.h | 2 +-
libminifi/include/core/ProcessorConfig.h | 6 +-
libminifi/include/core/Repository.h | 111 +-
libminifi/include/core/SerializableComponent.h | 74 +-
.../core/flow/AdaptiveConfiguration.h} | 20 +-
libminifi/include/core/flow/CheckRequiredField.h | 6 +-
libminifi/include/core/flow/FlowSchema.h | 88 +
libminifi/include/core/flow/Node.h | 59 +-
.../include/core/flow/StructuredConfiguration.h | 28 +-
.../include/core/flow/StructuredConnectionParser.h | 10 +-
libminifi/include/core/json/JsonNode.h | 19 +
.../include/core/repository/FileSystemRepository.h | 20 +-
.../core/repository/VolatileContentRepository.h | 38 +-
.../core/repository/VolatileFlowFileRepository.h | 49 +-
.../core/repository/VolatileProvenanceRepository.h | 24 +-
.../include/core/repository/VolatileRepository.h | 306 +-
.../core/repository/VolatileRepositoryData.h | 49 +
libminifi/include/core/state/ConnectionStore.h | 10 +-
libminifi/include/core/state/MetricsPublisher.h | 16 +-
.../include/core/state/MetricsPublisherFactory.h | 19 +-
.../include/core/state/MetricsPublisherStore.h | 55 +
libminifi/include/core/state/UpdateController.h | 2 +
.../include/core/state/nodes/AgentInformation.h | 13 +-
.../include/core/state/nodes/FlowInformation.h | 18 +-
libminifi/include/core/state/nodes/MetricsBase.h | 40 +-
libminifi/include/core/state/nodes/QueueMetrics.h | 21 +-
.../include/core/state/nodes/ResponseNodeLoader.h | 48 +-
.../include/core/state/nodes/SchedulingNodes.h | 4 +-
libminifi/include/core/yaml/YamlConfiguration.h | 12 +-
libminifi/include/core/yaml/YamlNode.h | 16 +-
libminifi/include/properties/Configuration.h | 8 +-
libminifi/include/provenance/Provenance.h | 240 +-
libminifi/include/utils/IntegrationTestUtils.h | 2 +-
libminifi/include/utils/StoppableThread.h | 60 +
libminifi/include/utils/file/FileUtils.h | 2 +
libminifi/include/utils/net/DNS.h | 7 +
libminifi/src/Configuration.cpp | 5 +-
libminifi/src/Connection.cpp | 19 +-
libminifi/src/FlowController.cpp | 366 +-
libminifi/src/RootProcessGroupWrapper.cpp | 190 +
libminifi/src/c2/C2Agent.cpp | 104 +-
.../c2/{C2Client.cpp => C2MetricsPublisher.cpp} | 133 +-
.../python_lib.cpp => libminifi/src/c2/C2Utils.cpp | 30 +-
libminifi/src/core/ConfigurationFactory.cpp | 14 +-
libminifi/src/core/ContentRepository.cpp | 42 +-
libminifi/src/core/ProcessGroup.cpp | 6 +-
libminifi/src/core/ProcessSession.cpp | 2 +-
libminifi/src/core/Processor.cpp | 8 +-
.../core/Repository.cpp} | 53 +-
libminifi/src/core/RepositoryFactory.cpp | 6 +-
libminifi/src/core/flow/AdaptiveConfiguration.cpp | 67 +
libminifi/src/core/flow/CheckRequiredField.cpp | 18 +-
libminifi/src/core/flow/FlowSchema.cpp | 144 +
libminifi/src/core/flow/Node.cpp | 10 +-
.../src/core/flow/StructuredConfiguration.cpp | 231 +-
.../src/core/flow/StructuredConnectionParser.cpp | 33 +-
libminifi/src/core/json/JsonConfiguration.cpp | 89 -
.../SiteToSiteProvenanceReportingTask.cpp | 5 +-
.../src/core/repository/FileSystemRepository.cpp | 45 +-
.../core/repository/VolatileContentRepository.cpp | 40 +-
.../src/core/repository/VolatileRepository.cpp | 104 +-
.../src/core/repository/VolatileRepositoryData.cpp | 74 +
.../src/core/state/MetricsPublisherFactory.cpp | 45 +
libminifi/src/core/state/MetricsPublisherStore.cpp | 68 +
libminifi/src/core/state/nodes/MetricsBase.cpp | 52 +
.../src/core/state/nodes/ResponseNodeLoader.cpp | 146 +-
libminifi/src/core/yaml/YamlConfiguration.cpp | 24 +-
libminifi/src/provenance/Provenance.cpp | 180 +-
.../src/utils/StoppableThread.cpp | 42 +-
libminifi/src/utils/net/DNS.cpp | 36 +
libminifi/test/ConfigurationTestController.h | 56 +
libminifi/test/LogUtils.h | 12 +-
libminifi/test/TestBase.cpp | 21 +-
libminifi/test/TestBase.h | 19 +-
.../test/azure-tests/ListAzureBlobStorageTests.cpp | 4 +-
.../azure-tests/ListAzureDataLakeStorageTests.cpp | 4 +-
libminifi/test/flow-tests/SessionTests.cpp | 9 +-
libminifi/test/flow-tests/TestControllerWithFlow.h | 13 +-
libminifi/test/integration/IntegrationBase.h | 14 +-
.../integration/OnScheduleErrorHandlingTests.cpp | 16 +-
.../test/integration/ProvenanceReportingTest.cpp | 4 +-
.../integration/StateTransactionalityTests.cpp | 14 +-
.../keyvalue-tests/PersistentStateStorageTest.cpp | 5 +-
.../keyvalue-tests/VolatileMapStateStorageTest.cpp | 2 +
.../test/persistence-tests/PersistenceTests.cpp | 29 +-
.../test/resources/encrypted.minifi.properties | 18 +-
.../rocksdb-tests/DBContentRepositoryTests.cpp | 77 +-
libminifi/test/rocksdb-tests/EncryptionTests.cpp | 9 +-
libminifi/test/rocksdb-tests/ProvenanceTests.cpp | 138 +-
libminifi/test/rocksdb-tests/RepoTests.cpp | 147 +-
libminifi/test/rocksdb-tests/SwapTests.cpp | 1 -
libminifi/test/unit/ConnectionTests.cpp | 41 +
libminifi/test/unit/ControllerTests.cpp | 4 +
libminifi/test/unit/FileStreamTests.cpp | 1 +
libminifi/test/unit/FileSystemRepositoryTests.cpp | 133 +-
libminifi/test/unit/MetricsTests.cpp | 4 +-
libminifi/test/unit/NetUtilsTest.cpp | 34 +-
libminifi/test/unit/ProcessSessionTests.cpp | 2 +-
libminifi/test/unit/ProvenanceTestHelper.h | 58 +-
libminifi/test/unit/ResponseNodeLoaderTests.cpp | 22 +-
libminifi/test/unit/StringUtilsTests.cpp | 45 +-
libminifi/test/unit/SwapTestController.h | 3 -
minifi_main/MiNiFiMain.cpp | 14 +-
nanofi/PYTHON.md | 57 -
nanofi/include/cxx/C2CallbackAgent.h | 24 +-
nanofi/include/cxx/Instance.h | 2 +-
nanofi/src/cxx/C2CallbackAgent.cpp | 6 +-
python/getFile.py | 74 -
python/library/CMakeLists.txt | 38 -
python/minifi/__init__.py | 238 -
.../ossp-uuid/ossp-uuid-update-config-guess.patch | 5538 ++++++++++++++++++++
thirdparty/paho-mqtt/cmake-openssl.patch | 56 +
...e_gcc_clang_compiler_options_from_windows.patch | 37 +
win_build_vs.bat | 78 +-
361 files changed, 15439 insertions(+), 6511 deletions(-)
create mode 100644 .github/workflows/verify-python-compatibility.yml
copy cmake/{JsonSchemaValidator.cmake => GenericPython.cmake} (66%)
create mode 100644 cmake/LZ4.cmake
create mode 100644 cmake/VerifyPythonCompatibility.cmake
create mode 100644 cmake/Zstd.cmake
copy cmake/{JsonSchemaValidator.cmake => lz4/dummy/Findlz4.cmake} (54%)
rename cmake/{Pybind11.cmake => zstd/dummy/Findzstd.cmake} (53%)
create mode 100644 docker/python-verify/conda.Dockerfile
create mode 100644 docker/python-verify/conda.dockerignore
create mode 100644 docker/python-verify/installed.Dockerfile
create mode 100644 docker/python-verify/installed.dockerignore
create mode 100644 docker/python-verify/venv.Dockerfile
create mode 100644 docker/python-verify/venv.dockerignore
copy docker/test/integration/features/{script.feature => lua_script.feature}
(67%)
rename docker/test/integration/features/{script.feature =>
python_script.feature} (65%)
copy extensions/pythonprocessors/examples/AddPythonAttribute.py =>
docker/test/integration/features/python_with_modules.feature (56%)
create mode 100644
docker/test/integration/minifi/flow_serialization/Minifi_flow_json_serializer.py
copy extensions/pythonprocessors/examples/RemoveFlowFile.py =>
docker/test/integration/minifi/processors/CountingProcessor.py (71%)
copy extensions/pythonprocessors/examples/RemoveFlowFile.py =>
docker/test/integration/minifi/processors/GaussianDistributionWithNumpy.py (71%)
copy extensions/pythonprocessors/examples/AddPythonAttribute.py =>
docker/test/integration/minifi/validators/SingleOrMultiFileOutputRegexValidator.py
(55%)
rename {libminifi/test/aws-tests =>
extensions/aws/tests}/AWSCredentialsServiceTest.cpp (98%)
copy {libminifi/test/aws-tests => extensions/aws/tests}/CMakeLists.txt (91%)
rename {libminifi/test/aws-tests =>
extensions/aws/tests}/DeleteS3ObjectTests.cpp (100%)
rename {libminifi/test/aws-tests =>
extensions/aws/tests}/FetchS3ObjectTests.cpp (100%)
rename {libminifi/test/aws-tests => extensions/aws/tests}/ListS3Tests.cpp
(100%)
rename {libminifi/test/aws-tests =>
extensions/aws/tests}/MockS3RequestSender.h (100%)
rename {libminifi/test/aws-tests => extensions/aws/tests}/PutS3ObjectTests.cpp
(100%)
rename {libminifi/test/aws-tests => extensions/aws/tests}/S3TestsFixture.h
(99%)
create mode 100644 extensions/lua/CMakeLists.txt
rename extensions/{script => }/lua/LuaInputStream.cpp (94%)
rename extensions/{script => }/lua/LuaInputStream.h (91%)
copy extensions/{script => }/lua/LuaOutputStream.cpp (90%)
rename extensions/{script => }/lua/LuaOutputStream.h (91%)
rename extensions/{script => }/lua/LuaProcessSession.cpp (77%)
rename extensions/{script => }/lua/LuaProcessSession.h (65%)
create mode 100644 extensions/lua/LuaScriptEngine.cpp
create mode 100644 extensions/lua/LuaScriptEngine.h
copy libminifi/src/core/flow/Node.cpp => extensions/lua/LuaScriptException.h
(69%)
create mode 100644 extensions/lua/LuaScriptExecutor.cpp
create mode 100644 extensions/lua/LuaScriptExecutor.h
rename extensions/{script/ScriptFlowFile.cpp => lua/LuaScriptFlowFile.cpp}
(69%)
rename extensions/{script/ScriptFlowFile.h => lua/LuaScriptFlowFile.h} (81%)
rename extensions/{script/ScriptProcessContext.cpp =>
lua/LuaScriptProcessContext.cpp} (68%)
rename extensions/{script/ScriptProcessContext.h =>
lua/LuaScriptProcessContext.h} (76%)
rename {libminifi/test/aws-tests => extensions/lua/tests}/CMakeLists.txt (57%)
rename extensions/{script => lua}/tests/LuaScriptEngineTests.cpp (69%)
create mode 100644
extensions/lua/tests/TestExecuteScriptProcessorWithLuaScript.cpp
rename extensions/{script => lua}/tests/test_lua_scripts/bar_modules/bar.lua
(100%)
rename extensions/{script => lua}/tests/test_lua_scripts/foo_bar_processor.lua
(100%)
rename extensions/{script => lua}/tests/test_lua_scripts/foo_modules/foo.lua
(100%)
create mode 100644 extensions/python/CMakeLists.txt
rename extensions/{script => }/python/ExecutePythonProcessor.cpp (96%)
rename extensions/{script => }/python/ExecutePythonProcessor.h (93%)
create mode 100644 extensions/python/PyException.cpp
copy extensions/{script/python/PyInputStream.h => python/PyException.h} (68%)
create mode 100644 extensions/python/PythonBindings.cpp
rename python/library/python_lib.h => extensions/python/PythonBindings.h (76%)
rename extensions/{script => }/python/PythonCreator.h (98%)
rename extensions/{script => }/python/PythonObjectFactory.h (69%)
copy extensions/{script => }/python/PythonProcessor.cpp (80%)
copy extensions/{script => }/python/PythonProcessor.h (76%)
create mode 100644 extensions/python/PythonScriptEngine.cpp
create mode 100644 extensions/python/PythonScriptEngine.h
rename extensions/{script/lua/LuaOutputStream.cpp =>
python/PythonScriptException.h} (67%)
create mode 100644 extensions/python/PythonScriptExecutor.cpp
create mode 100644 extensions/python/PythonScriptExecutor.h
rename extensions/{script => python}/README.md (78%)
rename extensions/{script => python}/pythonloader/PyProcLoader.cpp (90%)
copy extensions/{ => python}/pythonprocessors/examples/AddPythonAttribute.py
(100%)
copy extensions/{pythonprocessors/examples/AddPythonAttribute.py =>
python/pythonprocessors/examples/CountingProcessor.py} (66%)
rename extensions/{pythonprocessors/examples/AddPythonAttribute.py =>
python/pythonprocessors/examples/GaussianDistributionWithNumpy.py} (61%)
rename extensions/{ => python}/pythonprocessors/examples/MoveContentToJson.py
(100%)
rename extensions/{ => python}/pythonprocessors/examples/RemoveFlowFile.py
(100%)
rename extensions/{ => python}/pythonprocessors/examples/SentimentAnalysis.py
(100%)
rename extensions/{ => python}/pythonprocessors/google/SentimentAnalyzer.py
(100%)
rename extensions/{ => python}/pythonprocessors/h2o/ConvertDsToCsv.py (100%)
rename extensions/{ =>
python}/pythonprocessors/h2o/h2o3/mojo/ExecuteH2oMojoScoring.py (100%)
create mode 100644 extensions/python/tests/CMakeLists.txt
rename extensions/{script => python}/tests/ExecutePythonProcessorTests.cpp
(99%)
rename extensions/{script => python}/tests/PythonManifestTests.cpp (94%)
create mode 100644 extensions/python/tests/PythonScriptEngineTests.cpp
create mode 100644
extensions/python/tests/TestExecuteScriptProcessorWithPythonScript.cpp
rename extensions/{script =>
python}/tests/test_python_scripts/bar_modules/bar.py (100%)
rename extensions/{script =>
python}/tests/test_python_scripts/foo_bar_processor.py (100%)
rename extensions/{script =>
python}/tests/test_python_scripts/foo_modules/foo.py (100%)
rename extensions/{script =>
python}/tests/test_python_scripts/non_transferring_processor.py (100%)
rename extensions/{script =>
python}/tests/test_python_scripts/passthrough_processor_transfering_to_failure.py
(100%)
rename extensions/{script =>
python}/tests/test_python_scripts/passthrough_processor_transfering_to_success.py
(100%)
rename extensions/{script =>
python}/tests/test_python_scripts/stateful_processor.py (100%)
create mode 100644 extensions/python/types/BaseTypes.h
create mode 100644 extensions/python/types/PyInputStream.cpp
copy extensions/{script/python => python/types}/PyInputStream.h (57%)
create mode 100644 extensions/python/types/PyLogger.cpp
create mode 100644 extensions/python/types/PyLogger.h
create mode 100644 extensions/python/types/PyOutputStream.cpp
copy extensions/{script/python => python/types}/PyOutputStream.h (55%)
create mode 100644 extensions/python/types/PyProcessContext.cpp
rename extensions/{script/python/PyInputStream.h =>
python/types/PyProcessContext.h} (53%)
create mode 100644 extensions/python/types/PyProcessSession.cpp
create mode 100644 extensions/python/types/PyProcessSession.h
create mode 100644 extensions/python/types/PyProcessor.cpp
rename extensions/{script/python/PythonProcessor.cpp =>
python/types/PyProcessor.h} (50%)
create mode 100644 extensions/python/types/PyRelationship.cpp
rename extensions/{script/python/PythonProcessor.h =>
python/types/PyRelationship.h} (52%)
create mode 100644 extensions/python/types/PyScriptFlowFile.cpp
create mode 100644 extensions/python/types/PyScriptFlowFile.h
create mode 100644 extensions/python/types/Types.h
create mode 100644 extensions/rocksdb-repos/database/RocksDbUtils.cpp
rename extensions/script/{ScriptEngine.h => ScriptExecutor.h} (55%)
delete mode 100644 extensions/script/lua/LuaScriptEngine.cpp
delete mode 100644 extensions/script/lua/LuaScriptEngine.h
delete mode 100644 extensions/script/python/PyProcessSession.cpp
delete mode 100644 extensions/script/python/PyProcessSession.h
delete mode 100644 extensions/script/python/PythonBindings.h
delete mode 100644 extensions/script/python/PythonScriptEngine.cpp
delete mode 100644 extensions/script/python/PythonScriptEngine.h
create mode 100644 extensions/script/tests/ExecuteScriptTests.cpp
delete mode 100644 extensions/script/tests/PythonScriptEngineTests.cpp
delete mode 100644
extensions/script/tests/TestExecuteScriptProcessorWithLuaScript.cpp
delete mode 100644
extensions/script/tests/TestExecuteScriptProcessorWithPythonScript.cpp
create mode 100644
extensions/standard-processors/tests/unit/AdaptiveConfigurationTests.cpp
create mode 100644 extensions/standard-processors/tests/unit/FlowJsonTests.cpp
create mode 100644 extensions/windows-event-log/tests/LookupCacherTests.cpp
copy extensions/{script/python/PyOutputStream.cpp =>
windows-event-log/wel/LookupCacher.cpp} (57%)
rename extensions/{script/ScriptException.h =>
windows-event-log/wel/LookupCacher.h} (53%)
create mode 100644 libminifi/include/RootProcessGroupWrapper.h
rename libminifi/include/c2/{C2Client.h => C2MetricsPublisher.h} (53%)
rename extensions/script/python/PyOutputStream.h =>
libminifi/include/c2/C2Utils.h (69%)
delete mode 100644 libminifi/include/core/Flow.h
copy libminifi/{src/core/flow/Node.cpp =>
include/core/flow/AdaptiveConfiguration.h} (65%)
create mode 100644 libminifi/include/core/flow/FlowSchema.h
create mode 100644 libminifi/include/core/repository/VolatileRepositoryData.h
rename extensions/script/python/PyOutputStream.cpp =>
libminifi/include/core/state/MetricsPublisherFactory.h (60%)
create mode 100644 libminifi/include/core/state/MetricsPublisherStore.h
create mode 100644 libminifi/include/utils/StoppableThread.h
create mode 100644 libminifi/src/RootProcessGroupWrapper.cpp
rename libminifi/src/c2/{C2Client.cpp => C2MetricsPublisher.cpp} (57%)
rename python/library/python_lib.cpp => libminifi/src/c2/C2Utils.cpp (66%)
rename libminifi/{include/core/json/JsonConfiguration.h =>
src/core/Repository.cpp} (53%)
create mode 100644 libminifi/src/core/flow/AdaptiveConfiguration.cpp
create mode 100644 libminifi/src/core/flow/FlowSchema.cpp
delete mode 100644 libminifi/src/core/json/JsonConfiguration.cpp
create mode 100644 libminifi/src/core/repository/VolatileRepositoryData.cpp
create mode 100644 libminifi/src/core/state/MetricsPublisherFactory.cpp
create mode 100644 libminifi/src/core/state/MetricsPublisherStore.cpp
create mode 100644 libminifi/src/core/state/nodes/MetricsBase.cpp
rename extensions/script/python/PyInputStream.cpp =>
libminifi/src/utils/StoppableThread.cpp (55%)
create mode 100644 libminifi/test/ConfigurationTestController.h
delete mode 100644 nanofi/PYTHON.md
delete mode 100644 python/getFile.py
delete mode 100644 python/library/CMakeLists.txt
delete mode 100644 python/minifi/__init__.py
create mode 100644 thirdparty/ossp-uuid/ossp-uuid-update-config-guess.patch
create mode 100644 thirdparty/paho-mqtt/cmake-openssl.patch
create mode 100644
thirdparty/zstd/exclude_gcc_clang_compiler_options_from_windows.patch
