nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ald...@apache.org
Subject [nifi-minifi-cpp] branch master updated (c3c47b6 -> 8a4c2ac)
Date Fri, 01 Mar 2019 02:09:30 GMT
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%)


Mime
View raw message