Skip to content

Commit 7b066c8

Browse files
authored
Merge pull request #106 from george0st/change
Doc update
2 parents d4b0770 + af0b99f commit 7b066c8

File tree

5 files changed

+25
-9
lines changed

5 files changed

+25
-9
lines changed

README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@ ScyllaDB, AstraDB, etc.). The implementation details:
1616
## 2. Usage in NiFi
1717

1818
You can use this preferred way (NiFi v2 processor with controller):
19-
-[**PutCQL**](./nifi/cql-processor/docs/README.md#3-putcql-nifi-processor), where inputs are FlowFiles
20-
-[**GetCQL**](./nifi/cql-processor/docs/README.md#4-getcql-nifi-processor), where outputs are FlowFiles
19+
-[**PutCQL**](./nifi/cql-processor/docs/README.md#3-putcql-nifi-processor), put data to CQL solution, where inputs are FlowFiles
20+
-[**GetCQL**](./nifi/cql-processor/docs/README.md#4-getcql-nifi-processor), get data from CQL solution, where outputs are FlowFiles
2121
- NOTE: You can download the [latest version](./nifi/cql-processor/output/), see 'nifi-cql-nar-*.nar' file
2222

2323
or two other older alternative ways:

nifi/cql-processor/docs/README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
## 1. Usage in NiFi
22

33
You can use NiFi v2 processor with controller (nifi-cql-nar-*.nar).
4-
-[**PutCQL**](#3-putcql-nifi-processor), where inputs are FlowFiles
5-
-[**GetCQL**](#4-getcql-nifi-processor), where outputs are FlowFiles
4+
-[**PutCQL**](#3-putcql-nifi-processor), put data to CQL solution, where inputs are FlowFiles
5+
-[**GetCQL**](#4-getcql-nifi-processor), get data from CQL solution, where outputs are FlowFiles
66

77
### 1.1 Preconditions for usage
88

nifi/cql-processor/docs/todo-list.md

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -3,8 +3,3 @@
33
1. finish yugabyteDB
44
- https://docs.yugabyte.com/preview/drivers-orms/java/ycql-ssl/
55

6-
2. Extend performance tests
7-
- add more parallel tasks
8-
9-
3. Extend data flow
10-
- one with write and read in cycle

nifi/cql-processor/docs/useful-links.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,10 @@
44
- https://medium.com/@mr.sinchan.banerjee/nifi-custom-processor-series-part-1-writing-your-first-custom-processor-dd7aa901c896
55
- https://medium.com/@mr.sinchan.banerjee/nifi-custom-processor-series-part-2-add-custom-validation-to-custom-processor-95bb56763834
66
- https://medium.com/@mr.sinchan.banerjee/nifi-custom-processor-series-part-3-junit-test-with-nifi-mock-a935a1a4e3e5
7+
78
- Custom processor and controller
89
- https://medium.com/hashmapinc/creating-custom-processors-and-controllers-in-apache-nifi-e14148740ea
10+
911
- Sample of code from Github
1012
- MongoDB ControllerService
1113
- https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-services/src/main/java/org/apache/nifi/mongodb/MongoDBControllerService.java#L187
@@ -14,3 +16,6 @@
1416
- DBCPConnectionPool
1517
- https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-standard-services/nifi-dbcp-service-bundle/nifi-dbcp-service/src/main/java/org/apache/nifi/dbcp/DBCPConnectionPool.java
1618
- https://github.com/apache/nifi/blob/main/nifi-extension-bundles/nifi-extension-utils/nifi-dbcp-base/src/main/java/org/apache/nifi/dbcp/AbstractDBCPConnectionPool.java
19+
20+
- Monitoring Apache NiFi’s Back Pressure
21+
- https://developers.ascendcorp.com/monitoring-apache-nifis-back-pressure-c63ce8d1ca84
Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
{
2+
"enable": false,
3+
"name": "yugabyte",
4+
"ipAddresses": ["localhost"],
5+
"port": 9042,
6+
"localDC": "datacenter1",
7+
"connectionTimeout": "900",
8+
"requestTimeout": "60",
9+
"defaultConsistencyLevel": "LOCAL_ONE",
10+
11+
"table": "prftest.csv2cql_test3",
12+
"consistencyLevel": "LOCAL_ONE",
13+
14+
"replication": "{'class': 'SimpleStrategy', 'replication_factor': 1}",
15+
"compaction": "{'class':'SizeTieredCompactionStrategy'}"
16+
}

0 commit comments

Comments
 (0)