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 02873cc04 MINIFICPP-2647 Fix Dependency installer for older pythons
new 97011df5a MINIFICPP-2565 Add compression support for site to site
communication
new a0ab21f03 MINIFICPP-2640 Remove explicit use of ExecutePythonProcessor
new 5b750041f MINIFICPP-2651 Add documenation on asset reference syntax
The 3 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:
CONFIGURE.md | 39 +++-
PROCESSORS.md | 29 ---
README.md | 4 +-
SITE_TO_SITE.md | 8 +-
core-framework/include/io/CRCStream.h | 4 +
core-framework/src/io/ZlibStream.cpp | 2 +-
.../features/MiNiFi_integration_test_driver.py | 6 +-
docker/test/integration/features/python.feature | 10 -
docker/test/integration/features/s2s.feature | 85 ++++++++
docker/test/integration/features/steps/steps.py | 14 ++
docker/test/integration/minifi/core/InputPort.py | 4 +
docker/test/integration/minifi/core/OutputPort.py | 4 +
.../Minifi_flow_json_serializer.py | 1 +
.../Minifi_flow_yaml_serializer.py | 1 +
.../minifi/processors/ExecutePythonProcessor.py | 25 ---
.../resources/python/add_attribute_to_flowfile.py | 29 ---
extensions/python/ExecutePythonProcessor.cpp | 164 ++++++----------
extensions/python/ExecutePythonProcessor.h | 49 +----
extensions/python/PYTHON.md | 130 ++++++++-----
extensions/python/PythonObjectFactory.h | 1 -
.../python/tests/ExecutePythonProcessorTests.cpp | 179 ++++-------------
.../{SiteToSiteFactory.h => CompressionConsts.h} | 8 +-
...iteToSiteFactory.h => CompressionInputStream.h} | 33 +++-
...teToSiteFactory.h => CompressionOutputStream.h} | 28 ++-
libminifi/include/sitetosite/SiteToSiteClient.h | 6 +-
.../src/sitetosite/CompressionInputStream.cpp | 154 +++++++++++++++
.../src/sitetosite/CompressionOutputStream.cpp | 139 +++++++++++++
libminifi/src/sitetosite/HttpSiteToSiteClient.cpp | 5 +-
libminifi/src/sitetosite/RawSiteToSiteClient.cpp | 3 +-
libminifi/src/sitetosite/SiteToSiteClient.cpp | 115 ++++++++---
libminifi/test/libtest/unit/TestBase.h | 13 +-
.../test/unit/SiteToSiteCompressionStreamTests.cpp | 215 +++++++++++++++++++++
libminifi/test/unit/SiteToSiteTests.cpp | 174 ++++++++++++-----
33 files changed, 1131 insertions(+), 550 deletions(-)
delete mode 100644
docker/test/integration/minifi/processors/ExecutePythonProcessor.py
delete mode 100644
docker/test/integration/resources/python/add_attribute_to_flowfile.py
copy libminifi/include/sitetosite/{SiteToSiteFactory.h => CompressionConsts.h}
(82%)
copy libminifi/include/sitetosite/{SiteToSiteFactory.h =>
CompressionInputStream.h} (51%)
copy libminifi/include/sitetosite/{SiteToSiteFactory.h =>
CompressionOutputStream.h} (53%)
create mode 100644 libminifi/src/sitetosite/CompressionInputStream.cpp
create mode 100644 libminifi/src/sitetosite/CompressionOutputStream.cpp
create mode 100644 libminifi/test/unit/SiteToSiteCompressionStreamTests.cpp
