Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-4814 - Add distinctive attribute to S2S reporting tasks 

NIFI-4814 - added UUID attribute

NIFI-4814 - added type attribute

Signed-off-by: Matthew Burgess <mattyb149@apache.org>

This closes #2431
This commit is contained in:
Pierre Villard 2018-01-24 16:15:22 +01:00 committed by Matthew Burgess
parent b4b970b876
commit bc37015693
3 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
nifi-nar-bundles/nifi-site-to-site-reporting-bundle/nifi-site-to-site-reporting-task/src/main/java/org/apache/nifi/reporting/SiteToSiteBulletinReportingTask.java
View File

@ -159,6 +159,9 @@ public class SiteToSiteBulletinReportingTask extends AbstractSiteToSiteReporting
final Map<String, String> attributes = new HashMap<>(); final Map<String, String> attributes = new HashMap<>();
final String transactionId = UUID.randomUUID().toString(); final String transactionId = UUID.randomUUID().toString();
attributes.put("reporting.task.transaction.id", transactionId); attributes.put("reporting.task.transaction.id", transactionId);
attributes.put("reporting.task.name", getName());
attributes.put("reporting.task.uuid", getIdentifier());
attributes.put("reporting.task.type", this.getClass().getSimpleName());
attributes.put("mime.type", "application/json"); attributes.put("mime.type", "application/json");
final byte[] data = jsonArray.toString().getBytes(StandardCharsets.UTF_8); final byte[] data = jsonArray.toString().getBytes(StandardCharsets.UTF_8);

3
nifi-nar-bundles/nifi-site-to-site-reporting-bundle/nifi-site-to-site-reporting-task/src/main/java/org/apache/nifi/reporting/SiteToSiteProvenanceReportingTask.java
View File

@ -277,6 +277,9 @@ public class SiteToSiteProvenanceReportingTask extends AbstractSiteToSiteReporti
final Map<String, String> attributes = new HashMap<>(); final Map<String, String> attributes = new HashMap<>();
final String transactionId = UUID.randomUUID().toString(); final String transactionId = UUID.randomUUID().toString();
attributes.put("reporting.task.transaction.id", transactionId); attributes.put("reporting.task.transaction.id", transactionId);
attributes.put("reporting.task.name", getName());
attributes.put("reporting.task.uuid", getIdentifier());
attributes.put("reporting.task.type", this.getClass().getSimpleName());
attributes.put("mime.type", "application/json"); attributes.put("mime.type", "application/json");
final byte[] data = jsonArray.toString().getBytes(StandardCharsets.UTF_8); final byte[] data = jsonArray.toString().getBytes(StandardCharsets.UTF_8);

3
nifi-nar-bundles/nifi-site-to-site-reporting-bundle/nifi-site-to-site-reporting-task/src/main/java/org/apache/nifi/reporting/SiteToSiteStatusReportingTask.java
View File

@ -158,6 +158,9 @@ public class SiteToSiteStatusReportingTask extends AbstractSiteToSiteReportingTa
final Map<String, String> attributes = new HashMap<>(); final Map<String, String> attributes = new HashMap<>();
final String transactionId = UUID.randomUUID().toString(); final String transactionId = UUID.randomUUID().toString();
attributes.put("reporting.task.transaction.id", transactionId); attributes.put("reporting.task.transaction.id", transactionId);
attributes.put("reporting.task.name", getName());
attributes.put("reporting.task.uuid", getIdentifier());
attributes.put("reporting.task.type", this.getClass().getSimpleName());
attributes.put("mime.type", "application/json"); attributes.put("mime.type", "application/json");
JsonArrayBuilder jsonBatchArrayBuilder = factory.createArrayBuilder(); JsonArrayBuilder jsonBatchArrayBuilder = factory.createArrayBuilder();