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 d80875e NIFI-7053 Update Toolkit Guide with macOS 10.15 requirements
for trus… (#4018)
add dd6bcc7 NIFI-7054: Add RecordSinkServiceLookup for dynamic sink
routing (#4020)
No new revisions were added by this update.
Summary of changes:
nifi-assembly/pom.xml | 6 +
.../nifi-record-sink-service-nar}/pom.xml | 9 +-
.../src/main/resources/META-INF/LICENSE | 0
.../nifi-record-sink-service}/pom.xml | 26 +--
.../sink/lookup/RecordSinkServiceLookup.java | 84 +++++++++
.../org.apache.nifi.controller.ControllerService | 2 +-
.../record/sink/lookup}/MockRecordSinkService.java | 28 ++-
.../nifi/record/sink/lookup}/TestProcessor.java | 15 +-
.../sink/lookup/TestRecordSinkServiceLookup.java | 209 +++++++++++++++++++++
.../pom.xml | 7 +-
nifi-nar-bundles/nifi-standard-services/pom.xml | 1 +
11 files changed, 353 insertions(+), 34 deletions(-)
copy
nifi-nar-bundles/nifi-standard-services/{nifi-dbcp-service-bundle/nifi-dbcp-service-nar
=> nifi-record-sink-service-bundle/nifi-record-sink-service-nar}/pom.xml (90%)
copy nifi-nar-bundles/{nifi-poi-bundle/nifi-poi-nar =>
nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service-nar}/src/main/resources/META-INF/LICENSE
(100%)
copy nifi-nar-bundles/{nifi-standard-bundle/nifi-standard-reporting-tasks =>
nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service}/pom.xml
(79%)
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/main/java/org/apache/nifi/record/sink/lookup/RecordSinkServiceLookup.java
copy nifi-nar-bundles/{nifi-easyrules-bundle/nifi-easyrules-service =>
nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service}/src/main/resources/META-INF/services/org.apache.nifi.controller.ControllerService
(92%)
copy
nifi-nar-bundles/{nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard
=>
nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/test/java/org/apache/nifi/record/sink/lookup}/MockRecordSinkService.java
(83%)
copy
nifi-nar-bundles/nifi-standard-services/{nifi-dbcp-service-bundle/nifi-dbcp-service/src/test/java/org/apache/nifi/dbcp
=>
nifi-record-sink-service-bundle/nifi-record-sink-service/src/test/java/org/apache/nifi/record/sink/lookup}/TestProcessor.java
(85%)
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-record-sink-service-bundle/nifi-record-sink-service/src/test/java/org/apache/nifi/record/sink/lookup/TestRecordSinkServiceLookup.java
copy nifi-nar-bundles/nifi-standard-services/{nifi-http-context-map-bundle =>
nifi-record-sink-service-bundle}/pom.xml (88%)
