Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-11336 Added CapabilityDescription to PutAccumuloRecord 

This closes #7080

Signed-off-by: David Handermann <exceptionfactory@apache.org>
This commit is contained in:
Joe Gresock 2023-03-23 13:57:54 -04:00 committed by exceptionfactory
parent cac76e339d
commit 1b84927ed5
No known key found for this signature in database
GPG Key ID: 29B6A52D2AAE8DBA
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
nifi-nar-bundles/nifi-accumulo-bundle/nifi-accumulo-processors/src/main/java/org/apache/nifi/accumulo/processors/PutAccumuloRecord.java
View File

@ -36,6 +36,7 @@ import org.apache.nifi.annotation.behavior.DynamicProperty;
import org.apache.nifi.annotation.behavior.EventDriven;
import org.apache.nifi.annotation.behavior.InputRequirement;
import org.apache.nifi.annotation.behavior.SupportsBatching;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.annotation.lifecycle.OnDisabled;
import org.apache.nifi.annotation.lifecycle.OnScheduled;
@ -82,6 +83,8 @@ import java.util.stream.Collectors;
@SupportsBatching
@InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED)
@Tags({"hadoop", "accumulo", "put", "record"})
@CapabilityDescription("This is a record aware processor that reads the content of the incoming FlowFile as individual records using the " +
"configured 'Record Reader' and writes them to Apache Accumulo.")
@DynamicProperties({
@DynamicProperty(name = "visibility.<COLUMN FAMILY>", description = "Visibility label for everything under that column family " +
"when a specific label for a particular column qualifier is not available.", expressionLanguageScope = ExpressionLanguageScope.FLOWFILE_ATTRIBUTES,
@ -94,7 +97,7 @@ import java.util.stream.Collectors;
})
/**
* Purpose and Design: Requires a connector be defined by way of an AccumuloService object. This class
* simply extens BaseAccumuloProcessor to extract records from a flow file. The location of a record field value can be
* simply extends BaseAccumuloProcessor to extract records from a flow file. The location of a record field value can be
* placed into the value or part of the column qualifier ( this can/may change )
*
* Supports deletes. If the delete flag is used we'll delete keys found within that flow file.