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

NIFI-4227: Fixed typo

This commit is contained in:
Mark Payne 2018-05-24 15:57:28 -04:00
parent be0ed70423
commit 397e88c858
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ForkRecord.java
View File

@ -98,9 +98,9 @@ public class ForkRecord extends AbstractProcessor {
private volatile RecordPathCache recordPathCache = new RecordPathCache(25); private volatile RecordPathCache recordPathCache = new RecordPathCache(25);
static final AllowableValue MODE_EXTRACT = new AllowableValue("extract", "Extract", static final AllowableValue MODE_EXTRACT = new AllowableValue("extract", "Extract",
"Generated records will preserve the input schema and will contain a one-element array"); "Generated records will be the elements of the array");
static final AllowableValue MODE_SPLIT = new AllowableValue("split", "Split", static final AllowableValue MODE_SPLIT = new AllowableValue("split", "Split",
"Generated records will be the elements of the array"); "Generated records will preserve the input schema and will contain a one-element array");
public static final PropertyDescriptor RECORD_READER = new PropertyDescriptor.Builder() public static final PropertyDescriptor RECORD_READER = new PropertyDescriptor.Builder()
.name("record-reader") .name("record-reader")
@ -209,7 +209,7 @@ public class ForkRecord extends AbstractProcessor {
return; return;
} }
final List<RecordPath> recordPaths = new ArrayList<RecordPath>(); final List<RecordPath> recordPaths = new ArrayList<>();
Map<PropertyDescriptor, String> processorProperties = context.getProperties(); Map<PropertyDescriptor, String> processorProperties = context.getProperties();
for (final Map.Entry<PropertyDescriptor, String> entry : processorProperties.entrySet()) { for (final Map.Entry<PropertyDescriptor, String> entry : processorProperties.entrySet()) {
PropertyDescriptor property = entry.getKey(); PropertyDescriptor property = entry.getKey();