[
https://issues.apache.org/jira/browse/NIFI-14861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matt Burgess updated NIFI-14861:
--------------------------------
Description:
This Jira proposes to add an EnrichGraphNodes processor to do the following:
- A property specifying a GraphClientService
- RecordReader for incoming FlowFiles
- RecordSetWriter for failed operations
- A property for Components to Enrich to choose between Nodes or Edges
- An optional property specifying the Component Type which (when indexed in the
graph DB) optimizes the query/statement (supports FF attributes)
- A property to specify a field to be used as the identifier for matching
node(s)
- Dynamic properties specifying RecordField Expressions to locate field name(s)
and value(s) which will be used to set properties on the matched node(s)
GraphClientService will have a new method generateSetPropertiesStatement()
(defaulting to return null) that when implemented will generate a
query/statement in the graph database's supported language for creating the
component (if it doesn't exist, with the Component Type if specified) and
setting the specified properties to the values in the record fields.
was:
This Jira proposes to add an EnrichGraphNodes processor to do the following:
- A property specifying a GraphClientService
- RecordReader for incoming FlowFiles
- RecordSetWriter for failed operations
- An optional property specifying the Node Type which (when indexed in the
graph DB) optimizes the query/statement (supports FF attributes)
- A property to specify a field to be used as the identifier for matching
node(s)
- Dynamic properties specifying RecordField Expressions to locate field name(s)
and value(s) which will be used to set properties on the matched node(s)
GraphClientService will have a new method generateSetPropertiesStatement()
(defaulting to return null) that when implemented will generate a
query/statement in the graph database's supported language for creating the
node (if it doesn't exist, with the Node Type if specified) and setting the
specified properties to the values in the record fields
> Add EnrichGraphRecord processor
> -------------------------------
>
> Key: NIFI-14861
> URL: https://issues.apache.org/jira/browse/NIFI-14861
> Project: Apache NiFi
> Issue Type: New Feature
> Components: Extensions
> Reporter: Matt Burgess
> Assignee: Matt Burgess
> Priority: Major
>
> This Jira proposes to add an EnrichGraphNodes processor to do the following:
> - A property specifying a GraphClientService
> - RecordReader for incoming FlowFiles
> - RecordSetWriter for failed operations
> - A property for Components to Enrich to choose between Nodes or Edges
> - An optional property specifying the Component Type which (when indexed in
> the graph DB) optimizes the query/statement (supports FF attributes)
> - A property to specify a field to be used as the identifier for matching
> node(s)
> - Dynamic properties specifying RecordField Expressions to locate field
> name(s) and value(s) which will be used to set properties on the matched
> node(s)
> GraphClientService will have a new method generateSetPropertiesStatement()
> (defaulting to return null) that when implemented will generate a
> query/statement in the graph database's supported language for creating the
> component (if it doesn't exist, with the Component Type if specified) and
> setting the specified properties to the values in the record fields.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
