Repository: nifi Updated Branches: refs/heads/master 29e96ed0e -> d79216d6b
NIFI-5217: Allow non-nullable fields to be added to MockRecordParser Signed-off-by: Matthew Burgess <[email protected]> This closes #2720 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/d79216d6 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/d79216d6 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/d79216d6 Branch: refs/heads/master Commit: d79216d6b08a842dc0c5f6b847429aae87fb5561 Parents: 29e96ed Author: Matthew Burgess <[email protected]> Authored: Fri May 18 15:17:03 2018 -0400 Committer: Matthew Burgess <[email protected]> Committed: Fri May 18 15:59:12 2018 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/serialization/record/RecordField.java | 2 +- .../org/apache/nifi/serialization/record/MockRecordParser.java | 6 +++++- 2 files changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/d79216d6/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/RecordField.java ---------------------------------------------------------------------- diff --git a/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/RecordField.java b/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/RecordField.java index b4ff848..2c4954c 100644 --- a/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/RecordField.java +++ b/nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/record/RecordField.java @@ -24,7 +24,7 @@ import java.util.Objects; import java.util.Set; public class RecordField { - private static final boolean DEFAULT_NULLABLE = true; + public static final boolean DEFAULT_NULLABLE = true; private final String fieldName; private final DataType dataType; http://git-wip-us.apache.org/repos/asf/nifi/blob/d79216d6/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/src/main/java/org/apache/nifi/serialization/record/MockRecordParser.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/src/main/java/org/apache/nifi/serialization/record/MockRecordParser.java b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/src/main/java/org/apache/nifi/serialization/record/MockRecordParser.java index 0fcdcbf..9b5441e 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/src/main/java/org/apache/nifi/serialization/record/MockRecordParser.java +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/src/main/java/org/apache/nifi/serialization/record/MockRecordParser.java @@ -51,7 +51,11 @@ public class MockRecordParser extends AbstractControllerService implements Recor } public void addSchemaField(final String fieldName, final RecordFieldType type) { - fields.add(new RecordField(fieldName, type.getDataType())); + addSchemaField(fieldName, type, RecordField.DEFAULT_NULLABLE); + } + + public void addSchemaField(final String fieldName, final RecordFieldType type, boolean isNullable) { + fields.add(new RecordField(fieldName, type.getDataType(), isNullable)); } public void addRecord(Object... values) {
