You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by mattyb149 <gi...@git.apache.org> on 2018/10/15 15:43:39 UTC

[GitHub] nifi pull request #2861: NIFI-5248 Added new Elasticsearch json and record p...

Github user mattyb149 commented on a diff in the pull request:

    https://github.com/apache/nifi/pull/2861#discussion_r225215710
  
    --- Diff: nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ElasticSearchRestProcessor.java ---
    @@ -75,6 +76,19 @@
                 .required(true)
                 .build();
     
    +    Relationship REL_FAILURE = new Relationship.Builder()
    +            .name("failure")
    +            .description("All flowfiles that fail for reasons unrelated to server availability go to this relationship.")
    +            .build();
    +    Relationship REL_RETRY = new Relationship.Builder()
    +            .name("retry")
    +            .description("All flowfiles that fail due to server/cluster availability go to this relationship.")
    +            .build();
    +    Relationship REL_SUCCESS = new Relationship.Builder()
    +            .name("success")
    +            .description("All flowfiles that succeed in being indexed into ElasticSearch go here.")
    --- End diff --
    
    Maybe "transmitted to ElasticSearch"? Unless "indexed" is a generic enough term that users would know covers upserts, deletes, and any other supported operation.


---