You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ym...@apache.org on 2019/11/14 19:21:11 UTC
[nifi] branch master updated (86cae18 -> 55c334f)
This is an automated email from the ASF dual-hosted git repository.
ymdavis pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 86cae18 NIFI-6599 Fix MergeRecord failure in defragment mode
add 55c334f NIFI-6859: Add scripted versions of RecordSinkService, RulesEngineService, and ActionHandler (#3881)
No new revisions were added by this update.
Summary of changes:
.../nifi-scripting-processors/pom.xml | 10 +
.../record/sink/script/ScriptedRecordSink.java | 259 +++++++++++++++++++++
.../engine/script/ScriptedRulesEngine.java} | 128 +++++++---
.../handlers/script/ScriptedActionHandler.java | 247 ++++++++++++++++++++
.../impl/ClojureScriptEngineConfigurator.java | 1 +
.../impl/GroovyScriptEngineConfigurator.java | 1 +
.../org.apache.nifi.controller.ControllerService | 3 +
.../sink/script/ScriptedRecordSinkTest.java} | 110 ++++-----
.../engine/script/ScriptedRulesEngineTest.java | 104 +++++++++
.../handlers/script/ScriptedActionHandlerTest.java | 247 ++++++++++++++++++++
.../nifi/rules/handlers/script}/TestProcessor.java | 23 +-
.../resources/groovy/test_action_handler.groovy} | 24 +-
.../test_propertycontext_action_handler.groovy | 49 ++++
.../test/resources/groovy/test_record_sink.groovy | 37 +++
.../test/resources/groovy/test_rules_engine.groovy | 39 ++++
15 files changed, 1170 insertions(+), 112 deletions(-)
create mode 100644 nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/record/sink/script/ScriptedRecordSink.java
copy nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/{record/script/ScriptedReader.java => rules/engine/script/ScriptedRulesEngine.java} (51%)
create mode 100644 nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/main/java/org/apache/nifi/rules/handlers/script/ScriptedActionHandler.java
copy nifi-nar-bundles/{nifi-prometheus-bundle/nifi-prometheus-reporting-task/src/test/java/org/apache/nifi/reporting/prometheus/TestPrometheusRecordSink.java => nifi-scripting-bundle/nifi-scripting-processors/src/test/java/org/apache/nifi/record/sink/script/ScriptedRecordSinkTest.java} (53%)
create mode 100644 nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/test/java/org/apache/nifi/rules/engine/script/ScriptedRulesEngineTest.java
create mode 100644 nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/test/java/org/apache/nifi/rules/handlers/script/ScriptedActionHandlerTest.java
copy nifi-nar-bundles/{nifi-standard-services/nifi-lookup-services-bundle/nifi-lookup-services/src/test/java/org/apache/nifi/lookup => nifi-scripting-bundle/nifi-scripting-processors/src/test/java/org/apache/nifi/rules/handlers/script}/TestProcessor.java (81%)
copy nifi-nar-bundles/{nifi-redis-bundle/nifi-redis-extensions/src/main/java/org/apache/nifi/redis/util/RedisAction.java => nifi-scripting-bundle/nifi-scripting-processors/src/test/resources/groovy/test_action_handler.groovy} (58%)
create mode 100644 nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/test/resources/groovy/test_propertycontext_action_handler.groovy
create mode 100644 nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/test/resources/groovy/test_record_sink.groovy
create mode 100644 nifi-nar-bundles/nifi-scripting-bundle/nifi-scripting-processors/src/test/resources/groovy/test_rules_engine.groovy