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/10/22 12:56:56 UTC
[nifi] branch master updated (d148fb1 -> ace23c3)
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 d148fb1 NIFI-3834 This closes #3821. Added encrypted content repository implementation. Added skeleton implementation of EncryptedFileSystemRepository. Added new impl to META-INF registry. Added investigation comments to FileSystemRepository. Implemented RepositoryObject block and stream encryptors. Added passing unit test for encryption and decryption of multiple content writes (large buffered file) for AES-CTR encryptor. Refactored shared logic from AES CTR and G/CM encryptors [...]
add ace23c3 NIFI-6780: Add QueryNiFiReportingTask, RecordSinkService, S2S and DB impls (#3826)
No new revisions were added by this update.
Summary of changes:
.../apache/nifi/reporting/ReportingContext.java | 7 +
nifi-assembly/pom.xml | 15 +
.../reporting/StandardReportingContext.java | 7 +
.../nifi-site-to-site-reporting-task/pom.xml | 5 +
.../reporting/AbstractSiteToSiteReportingTask.java | 194 +-------
.../reporting/SiteToSiteBulletinReportingTask.java | 28 +-
.../reporting/SiteToSiteMetricsReportingTask.java | 3 +-
.../SiteToSiteProvenanceReportingTask.java | 19 +-
.../reporting/SiteToSiteStatusReportingTask.java | 5 +-
.../apache/nifi/reporting/s2s/SiteToSiteUtils.java | 201 ++++++++
.../sink/SiteToSiteReportingRecordSink.java | 190 +++++++
.../org.apache.nifi.controller.ControllerService | 3 +-
.../TestSiteToSiteBulletinReportingTask.java | 15 +-
.../TestSiteToSiteMetricsReportingTask.java | 13 +-
.../TestSiteToSiteProvenanceReportingTask.java | 35 +-
.../TestSiteToSiteStatusReportingTask.java | 25 +-
.../sink/TestSiteToSiteReportingRecordSink.java | 160 ++++++
.../nifi-sql-reporting-nar/pom.xml | 47 ++
.../src/main/resources/META-INF/NOTICE | 56 +++
.../nifi-sql-reporting-tasks}/pom.xml | 66 +--
.../apache/nifi/reporting/sql/CachedStatement.java | 38 ++
.../nifi/reporting/sql/MetricsQueryService.java | 29 ++
.../nifi/reporting/sql/MetricsSqlQueryService.java | 242 +++++++++
.../nifi/reporting/sql/QueryNiFiReportingTask.java | 172 +++++++
.../org/apache/nifi/reporting/sql/QueryResult.java | 25 +
.../sql/bulletins/BulletinEnumerator.java | 149 ++++++
.../bulletins/BulletinProjectTableScanRule.java | 76 +++
.../reporting/sql/bulletins/BulletinTable.java | 192 +++++++
.../reporting/sql/bulletins/BulletinTableScan.java | 91 ++++
.../ConnectionStatusEnumerator.java | 140 ++++++
.../ConnectionStatusProjectTableScanRule.java | 76 +++
.../connectionstatus/ConnectionStatusTable.java | 205 ++++++++
.../ConnectionStatusTableScan.java | 91 ++++
.../ConnectionStatusPredictionsEnumerator.java | 133 +++++
...ctionStatusPredictionsProjectTableScanRule.java | 76 +++
.../ConnectionStatusPredictionsTable.java | 182 +++++++
.../ConnectionStatusPredictionsTableScan.java | 91 ++++
.../sql/metrics/JvmMetricsEnumerator.java | 149 ++++++
.../metrics/JvmMetricsProjectTableScanRule.java | 76 +++
.../reporting/sql/metrics/JvmMetricsTable.java | 208 ++++++++
.../reporting/sql/metrics/JvmMetricsTableScan.java | 91 ++++
.../ProcessGroupStatusEnumerator.java | 167 +++++++
.../ProcessGroupStatusProjectTableScanRule.java | 76 +++
.../ProcessGroupStatusTable.java | 207 ++++++++
.../ProcessGroupStatusTableScan.java | 91 ++++
.../processorstatus/ProcessorStatusEnumerator.java | 175 +++++++
.../ProcessorStatusProjectTableScanRule.java | 76 +++
.../sql/processorstatus/ProcessorStatusTable.java | 211 ++++++++
.../processorstatus/ProcessorStatusTableScan.java | 91 ++++
.../util/ConnectionStatusRecursiveIterator.java | 91 ++++
.../org.apache.nifi.reporting.ReportingTask} | 4 +-
.../additionalDetails.html | 195 ++++++++
.../nifi/record/sink/MockRecordSinkService.java | 66 +++
.../reporting/sql/TestQueryNiFiReportingTask.java | 274 ++++++++++
nifi-nar-bundles/nifi-sql-reporting-bundle/pom.xml | 37 ++
.../nifi-dbcp-service/pom.xml | 21 +
.../nifi/record/sink/db/DatabaseRecordSink.java | 550 +++++++++++++++++++++
.../org.apache.nifi.controller.ControllerService | 3 +-
.../record/sink/db/DatabaseRecordSinkTest.groovy | 318 ++++++++++++
.../nifi-record-sink-api/pom.xml | 40 ++
.../apache/nifi/record/sink/RecordSinkService.java | 46 ++
.../nifi-standard-services-api-nar/pom.xml | 6 +
nifi-nar-bundles/nifi-standard-services/pom.xml | 1 +
nifi-nar-bundles/pom.xml | 5 +-
64 files changed, 6065 insertions(+), 312 deletions(-)
create mode 100644 nifi-nar-bundles/nifi-site-to-site-reporting-bundle/nifi-site-to-site-reporting-task/src/main/java/org/apache/nifi/reporting/s2s/SiteToSiteUtils.java
create mode 100644 nifi-nar-bundles/nifi-site-to-site-reporting-bundle/nifi-site-to-site-reporting-task/src/main/java/org/apache/nifi/reporting/sink/SiteToSiteReportingRecordSink.java
copy nifi-nar-bundles/{nifi-standard-services/nifi-dbcp-service-bundle/nifi-dbcp-service => nifi-site-to-site-reporting-bundle/nifi-site-to-site-reporting-task}/src/main/resources/META-INF/services/org.apache.nifi.controller.ControllerService (90%)
create mode 100644 nifi-nar-bundles/nifi-site-to-site-reporting-bundle/nifi-site-to-site-reporting-task/src/test/java/org/apache/nifi/reporting/sink/TestSiteToSiteReportingRecordSink.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-nar/pom.xml
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-nar/src/main/resources/META-INF/NOTICE
copy nifi-nar-bundles/{nifi-site-to-site-reporting-bundle/nifi-site-to-site-reporting-task => nifi-sql-reporting-bundle/nifi-sql-reporting-tasks}/pom.xml (63%)
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/CachedStatement.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/MetricsQueryService.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/MetricsSqlQueryService.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/QueryNiFiReportingTask.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/QueryResult.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/bulletins/BulletinEnumerator.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/bulletins/BulletinProjectTableScanRule.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/bulletins/BulletinTable.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/bulletins/BulletinTableScan.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/connectionstatus/ConnectionStatusEnumerator.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/connectionstatus/ConnectionStatusProjectTableScanRule.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/connectionstatus/ConnectionStatusTable.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/connectionstatus/ConnectionStatusTableScan.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/connectionstatuspredictions/ConnectionStatusPredictionsEnumerator.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/connectionstatuspredictions/ConnectionStatusPredictionsProjectTableScanRule.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/connectionstatuspredictions/ConnectionStatusPredictionsTable.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/connectionstatuspredictions/ConnectionStatusPredictionsTableScan.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/metrics/JvmMetricsEnumerator.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/metrics/JvmMetricsProjectTableScanRule.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/metrics/JvmMetricsTable.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/metrics/JvmMetricsTableScan.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/processgroupstatus/ProcessGroupStatusEnumerator.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/processgroupstatus/ProcessGroupStatusProjectTableScanRule.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/processgroupstatus/ProcessGroupStatusTable.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/processgroupstatus/ProcessGroupStatusTableScan.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/processorstatus/ProcessorStatusEnumerator.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/processorstatus/ProcessorStatusProjectTableScanRule.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/processorstatus/ProcessorStatusTable.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/processorstatus/ProcessorStatusTableScan.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/java/org/apache/nifi/reporting/sql/util/ConnectionStatusRecursiveIterator.java
copy nifi-nar-bundles/{nifi-standard-services/nifi-dbcp-service-bundle/nifi-dbcp-service/src/main/resources/META-INF/services/org.apache.nifi.controller.ControllerService => nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/resources/META-INF/services/org.apache.nifi.reporting.ReportingTask} (90%)
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/main/resources/docs/org.apache.nifi.reporting.sql.QueryNiFiReportingTask/additionalDetails.html
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/test/java/org/apache/nifi/record/sink/MockRecordSinkService.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/nifi-sql-reporting-tasks/src/test/java/org/apache/nifi/reporting/sql/TestQueryNiFiReportingTask.java
create mode 100644 nifi-nar-bundles/nifi-sql-reporting-bundle/pom.xml
create mode 100644 nifi-nar-bundles/nifi-standard-services/nifi-dbcp-service-bundle/nifi-dbcp-service/src/main/java/org/apache/nifi/record/sink/db/DatabaseRecordSink.java
create mode 100644 nifi-nar-bundles/nifi-standard-services/nifi-dbcp-service-bundle/nifi-dbcp-service/src/test/groovy/org/apache/nifi/record/sink/db/DatabaseRecordSinkTest.groovy
create mode 100644 nifi-nar-bundles/nifi-standard-services/nifi-record-sink-api/pom.xml
create mode 100644 nifi-nar-bundles/nifi-standard-services/nifi-record-sink-api/src/main/java/org/apache/nifi/record/sink/RecordSinkService.java