This is an automated email from the ASF dual-hosted git repository.
aldrin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git.
from c3c47b6 MINIFICPP-745: update readme with table
new f01953b MINIFICPP-738 - EL should be able to access global properties
new 8a4c2ac MINIFICPP-740: Add ability to run NiFi processors from Java and Python
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:
.gitignore | 2 +
CMakeLists.txt | 66 +-
CMakeSettings.json | 9 +-
LICENSE | 32 +-
NOTICE | 14 +
bootstrap.sh | 4 +
bstrp_functions.sh | 6 +-
centos.sh | 2 +-
conf/minifi.properties | 9 +
debian.sh | 2 +
extensions/coap/CMakeLists.txt | 2 +-
extensions/coap/nanofi/coap_connection.c | 13 +-
extensions/coap/nanofi/coap_functions.c | 88 +-
extensions/coap/nanofi/coap_functions.h | 2 +-
extensions/coap/nanofi/coap_server.c | 47 +-
extensions/coap/server/CoapServer.h | 5 +-
extensions/coap/tests/CoapC2VerifyHeartbeat.cpp | 15 +-
extensions/expression-language/Expression.cpp | 1282 ++++----------------
.../expression-language/ProcessContextExpr.cpp | 15 +-
extensions/expression-language/common/Value.h | 6 +-
.../impl/expression/Expression.h | 32 +-
.../noop/expression/Expression.h | 3 +-
extensions/http-curl/client/HTTPClient.cpp | 20 +-
extensions/http-curl/client/HTTPClient.h | 13 +
extensions/http-curl/protocols/RESTSender.cpp | 16 +-
.../http-curl/tests/unit/InvokeHTTPTests.cpp | 16 +-
extensions/jni/CMakeLists.txt | 75 ++
extensions/jni/ExecuteJavaControllerService.cpp | 104 ++
extensions/jni/ExecuteJavaControllerService.h | 135 +++
extensions/jni/ExecuteJavaProcessor.cpp | 219 ++++
extensions/jni/ExecuteJavaProcessor.h | 296 +++++
.../expression/Expression.h => jni/JNILoader.cpp} | 37 +-
extensions/jni/JNILoader.h | 79 ++
.../expression/Expression.h => jni/JVMCreator.cpp} | 38 +-
extensions/jni/JVMCreator.h | 113 ++
extensions/jni/JavaException.h | 117 ++
extensions/jni/README.md | 49 +
.../Expression.h => jni/jvm/JVMLoader.cpp} | 34 +-
extensions/jni/jvm/JVMLoader.h | 518 ++++++++
extensions/jni/jvm/JavaClass.h | 139 +++
extensions/jni/jvm/JavaControllerService.cpp | 117 ++
extensions/jni/jvm/JavaControllerService.h | 170 +++
.../expression/Expression.h => jni/jvm/JavaDefs.h} | 34 +-
.../Expression.h => jni/jvm/JavaServicer.h} | 31 +-
extensions/jni/jvm/JniBundle.h | 87 ++
extensions/jni/jvm/JniFlowFile.cpp | 153 +++
extensions/jni/jvm/JniFlowFile.h | 53 +
extensions/jni/jvm/JniLogger.cpp | 107 ++
extensions/jni/jvm/JniLogger.h | 71 ++
extensions/jni/jvm/JniMethod.h | 129 ++
extensions/jni/jvm/JniProcessContext.cpp | 79 ++
extensions/jni/jvm/JniProcessContext.h | 80 ++
extensions/jni/jvm/JniProcessSession.cpp | 478 ++++++++
extensions/jni/jvm/JniProcessSession.h | 90 ++
.../jvm/JniReferenceObjects.cpp} | 31 +-
extensions/jni/jvm/JniReferenceObjects.h | 374 ++++++
extensions/jni/jvm/NarClassLoader.h | 443 +++++++
extensions/jni/nifi-framework-jni/pom.xml | 96 ++
.../main/java/org/apache/nifi/nar/JniUnpacker.java | 267 ++++
.../java/org/apache/nifi/processor/JniBundle.java | 29 +
.../org/apache/nifi/processor/JniClassLoader.java | 498 ++++++++
.../org/apache/nifi/processor/JniComponent.java | 118 ++
.../apache/nifi/processor/JniComponentLogger.java | 358 ++++++
.../org/apache/nifi/processor/JniFlowFile.java | 59 +
.../nifi/processor/JniInitializationContext.java | 61 +
.../org/apache/nifi/processor/JniInputStream.java | 19 +
.../java/org/apache/nifi/processor/JniLogger.java | 21 +
.../apache/nifi/processor/JniProcessContext.java | 169 +++
.../apache/nifi/processor/JniProcessSession.java | 323 +++++
.../nifi/processor/JniProcessSessionFactory.java | 9 +
.../org/apache/nifi/processor/JniProperty.java | 9 +
.../nifi/processor/JniProvenanceReporter.java | 208 ++++
extensions/librdkafka/PublishKafka.cpp | 251 ++--
extensions/librdkafka/PublishKafka.h | 267 +++-
extensions/script/CMakeLists.txt | 7 +-
extensions/script/ExampleProcessor.py | 11 +
extensions/script/README.md | 61 +
.../script/python/ExecutePythonProcessor.cpp | 204 ++++
extensions/script/python/ExecutePythonProcessor.h | 155 +++
.../python/PyProcCreator.cpp} | 38 +-
extensions/script/python/PyProcCreator.h | 107 ++
extensions/script/python/PythonBindings.h | 8 +-
.../python/PythonCreator.cpp} | 43 +-
extensions/script/python/PythonCreator.h | 139 +++
extensions/script/python/PythonProcessor.cpp | 65 +
extensions/script/python/PythonProcessor.h | 71 ++
extensions/script/python/PythonScriptEngine.cpp | 2 +-
extensions/script/python/PythonScriptEngine.h | 104 +-
.../pythonloader/PyProcLoader.cpp} | 38 +-
extensions/script/pythonloader/PyProcLoader.h | 69 ++
fedora.sh | 2 +
libminifi/include/FlowController.h | 2 +
libminifi/include/agent/build_description.h | 71 +-
libminifi/include/core/ClassLoader.h | 33 +
libminifi/include/core/ConfigurableComponent.h | 8 +
libminifi/include/core/ContentRepository.h | 1 -
libminifi/include/core/Core.h | 9 +-
libminifi/include/core/FlowConfiguration.h | 1 +
libminifi/include/core/FlowFile.h | 8 +-
libminifi/include/core/ProcessContext.h | 23 +-
libminifi/include/core/ProcessSession.h | 16 +-
libminifi/include/core/Processor.h | 2 +-
libminifi/include/core/Property.h | 20 +-
libminifi/include/core/VariableRegistry.h | 105 ++
libminifi/include/core/WeakReference.h | 103 ++
.../include/core/controller/ControllerService.h | 11 +
.../include/core/logging/LoggerConfiguration.h | 5 +
.../include/core/state/nodes/AgentInformation.h | 103 +-
libminifi/include/processors/RouteOnAttribute.h | 12 +-
libminifi/include/processors/UpdateAttribute.h | 2 +-
libminifi/include/properties/Configure.h | 1 +
libminifi/include/provenance/Provenance.h | 15 +-
libminifi/include/utils/Id.h | 3 +
libminifi/include/utils/file/FileManager.h | 34 +-
libminifi/include/utils/file/FileUtils.h | 180 ++-
libminifi/src/Configure.cpp | 1 +
libminifi/src/FlowController.cpp | 16 +-
libminifi/src/Properties.cpp | 15 +-
libminifi/src/ThreadedSchedulingAgent.cpp | 2 +-
libminifi/src/c2/C2Agent.cpp | 35 +-
libminifi/src/core/ConfigurableComponent.cpp | 66 +-
libminifi/src/core/FlowConfiguration.cpp | 36 +
libminifi/src/core/FlowFile.cpp | 19 +-
libminifi/src/core/ProcessSession.cpp | 24 +-
libminifi/src/core/yaml/YamlConfiguration.cpp | 6 +-
libminifi/src/io/FileStream.cpp | 3 +
libminifi/src/processors/RouteOnAttribute.cpp | 4 +
libminifi/src/provenance/Provenance.cpp | 25 +-
libminifi/test/TestBase.cpp | 9 +-
libminifi/test/TestBase.h | 25 +-
.../test/archive-tests/CompressContentTests.cpp | 20 +-
libminifi/test/archive-tests/MergeFileTests.cpp | 14 +-
.../ExpressionLanguageTests.cpp | 17 +-
libminifi/test/gps-tests/GPSTests.cpp | 2 +-
.../test/{mqtt-tests => jni-tests}/CMakeLists.txt | 0
.../test/script-tests/LuaExecuteScriptTests.cpp | 4 +-
.../test/script-tests/PythonExecuteScriptTests.cpp | 4 +-
libminifi/test/unit/GetTCPTests.cpp | 14 +-
libminifi/test/unit/ProcessorTests.cpp | 23 +-
libminifi/test/unit/PutFileTests.cpp | 8 +-
libminifi/test/unit/TailFileTests.cpp | 4 +-
main/CMakeLists.txt | 11 +-
main/Main.h | 71 +-
main/MiNiFiMain.cpp | 387 +++---
nanofi/include/cxx/Instance.h | 12 +-
nanofi/include/cxx/Plan.h | 2 +-
nanofi/src/cxx/Plan.cpp | 2 +-
thirdparty/pybind11/include/pybind11/pytypes.h | 2 +-
148 files changed, 9753 insertions(+), 1985 deletions(-)
create mode 100644 extensions/jni/CMakeLists.txt
create mode 100644 extensions/jni/ExecuteJavaControllerService.cpp
create mode 100644 extensions/jni/ExecuteJavaControllerService.h
create mode 100644 extensions/jni/ExecuteJavaProcessor.cpp
create mode 100644 extensions/jni/ExecuteJavaProcessor.h
copy extensions/{expression-language/noop/expression/Expression.h => jni/JNILoader.cpp}
(55%)
create mode 100644 extensions/jni/JNILoader.h
copy extensions/{expression-language/noop/expression/Expression.h => jni/JVMCreator.cpp}
(67%)
create mode 100644 extensions/jni/JVMCreator.h
create mode 100644 extensions/jni/JavaException.h
create mode 100644 extensions/jni/README.md
copy extensions/{expression-language/noop/expression/Expression.h => jni/jvm/JVMLoader.cpp}
(55%)
create mode 100644 extensions/jni/jvm/JVMLoader.h
create mode 100644 extensions/jni/jvm/JavaClass.h
create mode 100644 extensions/jni/jvm/JavaControllerService.cpp
create mode 100644 extensions/jni/jvm/JavaControllerService.h
copy extensions/{expression-language/noop/expression/Expression.h => jni/jvm/JavaDefs.h}
(55%)
copy extensions/{expression-language/noop/expression/Expression.h => jni/jvm/JavaServicer.h}
(63%)
create mode 100644 extensions/jni/jvm/JniBundle.h
create mode 100644 extensions/jni/jvm/JniFlowFile.cpp
create mode 100644 extensions/jni/jvm/JniFlowFile.h
create mode 100644 extensions/jni/jvm/JniLogger.cpp
create mode 100644 extensions/jni/jvm/JniLogger.h
create mode 100644 extensions/jni/jvm/JniMethod.h
create mode 100644 extensions/jni/jvm/JniProcessContext.cpp
create mode 100644 extensions/jni/jvm/JniProcessContext.h
create mode 100644 extensions/jni/jvm/JniProcessSession.cpp
create mode 100644 extensions/jni/jvm/JniProcessSession.h
copy extensions/{expression-language/noop/expression/Expression.h => jni/jvm/JniReferenceObjects.cpp}
(67%)
create mode 100644 extensions/jni/jvm/JniReferenceObjects.h
create mode 100644 extensions/jni/jvm/NarClassLoader.h
create mode 100644 extensions/jni/nifi-framework-jni/pom.xml
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/nar/JniUnpacker.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniBundle.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniClassLoader.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniComponent.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniComponentLogger.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniFlowFile.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniInitializationContext.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniInputStream.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniLogger.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProcessContext.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProcessSession.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProcessSessionFactory.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProperty.java
create mode 100644 extensions/jni/nifi-framework-jni/src/main/java/org/apache/nifi/processor/JniProvenanceReporter.java
create mode 100644 extensions/script/ExampleProcessor.py
create mode 100644 extensions/script/README.md
create mode 100644 extensions/script/python/ExecutePythonProcessor.cpp
create mode 100644 extensions/script/python/ExecutePythonProcessor.h
copy extensions/{expression-language/noop/expression/Expression.h => script/python/PyProcCreator.cpp}
(55%)
create mode 100644 extensions/script/python/PyProcCreator.h
copy extensions/{expression-language/noop/expression/Expression.h => script/python/PythonCreator.cpp}
(67%)
create mode 100644 extensions/script/python/PythonCreator.h
create mode 100644 extensions/script/python/PythonProcessor.cpp
create mode 100644 extensions/script/python/PythonProcessor.h
copy extensions/{expression-language/noop/expression/Expression.h => script/pythonloader/PyProcLoader.cpp}
(55%)
create mode 100644 extensions/script/pythonloader/PyProcLoader.h
create mode 100644 libminifi/include/core/VariableRegistry.h
create mode 100644 libminifi/include/core/WeakReference.h
copy libminifi/test/{mqtt-tests => jni-tests}/CMakeLists.txt (100%)
|