NiFi Drunken Dev - Bundle

NiFi processors developed by the drunken developer.

License	Apache License, Version 2.0
GroupId	com.drunkendev
ArtifactId	nifi-drunken-bundle
Last Version	1.0.0
Release Date	Jan 4, 2018
Type	pom
Description	NiFi Drunken Dev - Bundle NiFi processors developed by the drunken developer.
Project URL	https://github.com/brettryan/nifi-drunken-bundle
Project Organization	Drunken Dev
Source Code Management	https://github.com/brettryan/nifi-drunken-bundle

Download nifi-drunken-bundle

Filename	Size
nifi-drunken-bundle-1.0.0.pom	5 KB

How to add to project

Apache Maven

<!-- https://jarcasting.com/artifacts/com.drunkendev/nifi-drunken-bundle/ -->
<dependency>
    <groupId>com.drunkendev</groupId>
    <artifactId>nifi-drunken-bundle</artifactId>
    <version>1.0.0</version>
    <type>pom</type>
</dependency>

Gradle Groovy

// https://jarcasting.com/artifacts/com.drunkendev/nifi-drunken-bundle/
implementation 'com.drunkendev:nifi-drunken-bundle:1.0.0'

Gradle Kotlin

// https://jarcasting.com/artifacts/com.drunkendev/nifi-drunken-bundle/
implementation ("com.drunkendev:nifi-drunken-bundle:1.0.0")

Apache Buildr

'com.drunkendev:nifi-drunken-bundle:pom:1.0.0'

Apache Ivy

<dependency org="com.drunkendev" name="nifi-drunken-bundle" rev="1.0.0">
  <artifact name="nifi-drunken-bundle" type="pom" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='com.drunkendev', module='nifi-drunken-bundle', version='1.0.0')
)

Scala SBT

libraryDependencies += "com.drunkendev" % "nifi-drunken-bundle" % "1.0.0"

Leiningen

[com.drunkendev/nifi-drunken-bundle "1.0.0"]

Dependencies

test (4)

Group / Artifact	Type	Version
junit : junit	jar	4.12
org.mockito : mockito-core	jar	1.10.19
org.slf4j : slf4j-simple	jar	1.7.12
org.codehaus.groovy : groovy-all	jar	2.4.5

Project Modules

• nifi-drunken-nar
• nifi-drunken-processors

NiFi Drunken Dev Bundle

This NiFi bundle serves to add enrichment support to FlowFiles by adding attributes.

Presently one process is available which will execute SQL against the FlowFile adding the values from the first record returned as properties to the FlowFile with the property names being that of the column names identified in the ResultSet.

Example

Given a table with the following

create table if not exists test_table (
  id    identity primary key,
  some_name   varchar,
  some_id     int
);
insert into test_table (some_name, some_id) values ('test val', 3);

We could define a processor as follows:

This would result in the following flow file attributes being applied.

Versions

Version
1.0.0 Jan 4, 2018