Skip to content

Instantly share code, notes, and snippets.

@apiri
Created August 21, 2017 19:08
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save apiri/fda176111f0112f724b8c9ad6b8dd476 to your computer and use it in GitHub Desktop.
Save apiri/fda176111f0112f724b8c9ad6b8dd476 to your computer and use it in GitHub Desktop.
MiNiFi Flow to generate and sink flowfiles
MiNiFi Config Version: 3
Flow Controller:
name: Lots of Logs
comment: ''
Core Properties:
flow controller graceful shutdown period: 10 sec
flow service write delay interval: 500 ms
administrative yield duration: 30 sec
bored yield duration: 10 millis
max concurrent threads: 1
variable registry properties: ''
FlowFile Repository:
partitions: 256
checkpoint interval: 2 mins
always sync: false
Swap:
threshold: 20000
in period: 5 sec
in threads: 1
out period: 5 sec
out threads: 4
Content Repository:
content claim max appendable size: 10 MB
content claim max flow files: 100
always sync: false
Provenance Repository:
provenance rollover time: 1 min
Component Status Repository:
buffer size: 1440
snapshot frequency: 1 min
Security Properties:
keystore: ''
keystore type: ''
keystore password: ''
key password: ''
truststore: ''
truststore type: ''
truststore password: ''
ssl protocol: ''
Sensitive Props:
key:
algorithm: PBEWITHMD5AND256BITAES-CBC-OPENSSL
provider: BC
Processors:
- id: e6119d54-b026-359a-0000-000000000000
name: GenerateFlowFile
class: org.apache.nifi.processors.standard.GenerateFlowFile
max concurrent tasks: 1
scheduling strategy: TIMER_DRIVEN
scheduling period: 0 sec
penalization period: 30 sec
yield period: 1 sec
run duration nanos: 0
auto-terminated relationships list: []
Properties:
Batch Size: '1'
Data Format: Text
File Size: 1 B
Unique FlowFiles: 'false'
generate-ff-custom-text:
- id: 58f8d1a1-987e-31f6-0000-000000000000
name: UpdateAttribute
class: org.apache.nifi.processors.attributes.UpdateAttribute
max concurrent tasks: 1
scheduling strategy: TIMER_DRIVEN
scheduling period: 0 sec
penalization period: 30 sec
yield period: 1 sec
run duration nanos: 0
auto-terminated relationships list:
- success
Properties:
Delete Attributes Expression:
Stateful Variables Initial Value:
Store State: Do not store state
Controller Services: []
Process Groups: []
Input Ports: []
Output Ports: []
Funnels: []
Connections:
- id: a62a8298-9f53-3d19-0000-000000000000
name: GenerateFlowFile/success/UpdateAttribute
source id: e6119d54-b026-359a-0000-000000000000
source relationship names:
- success
destination id: 58f8d1a1-987e-31f6-0000-000000000000
max work queue size: 1000
max work queue data size: 1 GB
flowfile expiration: 0 sec
queue prioritizer class: ''
Remote Process Groups: []
NiFi Properties Overrides: {}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment