You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "Ilya Kovalev (JIRA)" <ji...@apache.org> on 2019/04/06 12:03:00 UTC
[jira] [Updated] (NIFI-6195) Create nar-bundle for interaction with
Aerospike database
[ https://issues.apache.org/jira/browse/NIFI-6195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ilya Kovalev updated NIFI-6195:
-------------------------------
Description:
[Aerospike|https://www.aerospike.com/docs/] is a distributed NoSQL database and key-value store architected to meet the performance needs.
The core idea is to create nar-bundle (group of processors and services) for interaction with database in SYNC and ASYNC mode.
Interaction in this context is just CRUD operations.
Three main components of nar-bundle that need to create.
* PutAerospike - receive flow file, read it with RecordReader service and push records to Aerospike.
* ExecuteSqlRecordAerospike has sql statement in processor's attributes (or obtain it from flowfile) and execute it creating new flowfiles that content result of query in record format (json | csv | etc...).
* AerospikeService - service for tune and obtain Aerospike client.
was:
[Aerospike|https://www.aerospike.com/docs/] is a distributed NoSQL database and key-value store architected to meet the performance needs.
The core idea is to create nar-bundle (group of processors and services) for interaction with database in SYNC and ASYNC mode.
Interaction in this context is just CRUD operations.
Three main components of nar-bundle that need create.
* PutAerospike - receive flow file, read it with RecordReader service and push records to Aerospike.
* ExecuteSqlRecordAerospike has sql statement in processor's attributes (or obtain it from flowfile) and execute it creating new flowfiles that content result of query in record format (json | csv | etc...).
* AerospikeService - service for tune and obtain Aerospike client.
> Create nar-bundle for interaction with Aerospike database
> ---------------------------------------------------------
>
> Key: NIFI-6195
> URL: https://issues.apache.org/jira/browse/NIFI-6195
> Project: Apache NiFi
> Issue Type: New Feature
> Components: Extensions
> Reporter: Ilya Kovalev
> Priority: Minor
>
> [Aerospike|https://www.aerospike.com/docs/] is a distributed NoSQL database and key-value store architected to meet the performance needs.
> The core idea is to create nar-bundle (group of processors and services) for interaction with database in SYNC and ASYNC mode.
> Interaction in this context is just CRUD operations.
> Three main components of nar-bundle that need to create.
> * PutAerospike - receive flow file, read it with RecordReader service and push records to Aerospike.
> * ExecuteSqlRecordAerospike has sql statement in processor's attributes (or obtain it from flowfile) and execute it creating new flowfiles that content result of query in record format (json | csv | etc...).
> * AerospikeService - service for tune and obtain Aerospike client.
>
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)