Github user pvillard31 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/3098#discussion_r227674603
--- Diff:
nifi-commons/nifi-record/src/main/java/org/apache/nifi/serialization/SimpleRecordSchema.java
---
@@ -213,4 +215,30 @@ public String toString() {
public SchemaIdentifier getIdentifier() {
return schemaIdentifier;
}
+
+ /**
+ * Set schema name.
+ * @param schemaName schema name as defined in a root record.
+ */
+ public void setSchemaName(String schemaName) {
+ this.schemaName = schemaName;
+ }
+
+ @Override
+ public Optional<String> getSchemaName() {
+ return Optional.ofNullable(schemaName);
+ }
+
+ /**
+ * Set schema namespace.
+ * @param schemaNamespace schema name as defined in a root record.
--- End diff --
schema namespace
---
