feat(api): add method set schema namespace and doc

Author: fhussonnois

connect-file-pulse-api/src/main/java/io/streamthoughts/kafka/connect/filepulse/data/StructSchema.java

@@ -37,13 +37,26 @@ public class StructSchema implements Schema, Iterable<TypedField> {
 
     private String name;
 
+    private String namespace;
+
+    private String doc;
+
     /**
      * Creates a new {@link StructSchema} instance.
      */
     public StructSchema() {
         this(Collections.emptyList(), null);
     }
 
+    /**
+     * Creates a new {@link StructSchema} instance.
+     */
+    public StructSchema(final StructSchema schema) {
+        this(schema.fields(), schema.name);
+        this.namespace = schema.namespace;
+        this.doc = schema.doc;
+    }
+
     /**
      * Creates a new {@link StructSchema} instance.
      *
@@ -140,15 +153,67 @@ public Type type() {
         return this.type;
     }
 
+    /**
+     * Gets the name for this schema.
+     *
+     * @return  the schema name.
+     */
     public String name() {
         return this.name;
     }
 
+    /**
+     * Sets the name for this schema.
+     * @param name  the schema name.
+     *
+     * @return  {@code this}
+     */
     public StructSchema name(final String name) {
         this.name = name;
         return this;
     }
 
+    /**
+     * Gets the namespace for this schema.
+     *
+     * @return  the schema namespace.
+     */
+    public String namespace() {
+        return namespace;
+    }
+
+    /**
+     * Sets the namespace for this schema.
+     *
+     * @param namespace the namespace.
+     *
+     * @return  {@code this}
+     */
+    public StructSchema namespace(final String namespace) {
+        this.namespace = namespace;
+        return this;
+    }
+
+    /**
+     * Gets the doc for this schema.
+     *
+     * @return  the doc.
+     */
+    public String doc() {
+        return this.doc;
+    }
+
+    /**
+     * Sets the doc for this schema.
+     * @param doc   the schema doc.
+     *
+     * @return  {@code this}
+     */
+    public StructSchema doc(final String doc) {
+        this.doc = doc;
+        return this;
+    }
+
     /**
      * {@inheritDoc}
      */

connect-file-pulse-api/src/main/java/io/streamthoughts/kafka/connect/filepulse/data/TypedValue.java

@@ -126,7 +126,7 @@ public static TypedValue float32(final Float value) {
      */
     public static TypedValue struct(final TypedStruct value) {
         return new TypedValue(
-            new StructSchema(value.schema().fields(), value.schema().name()),
+            new StructSchema(value.schema()),
             value
         );
     }

connect-file-pulse-api/src/main/java/io/streamthoughts/kafka/connect/filepulse/source/internal/ConnectSchemaMapper.java

@@ -70,12 +70,23 @@ public Schema map(final ArraySchema schema) {
     @Override
     public Schema map(final StructSchema schema) {
         SchemaBuilder sb = SchemaBuilder.struct();
+
+        String schemaName = schema.name();
+        if (schemaName != null) {
+            if (schema.namespace() != null) {
+                schemaName = schema.namespace() + "." + schemaName;
+            }
+            sb.name(schemaName);
+        }
+
+        if (schema.doc() != null) {
+            sb.doc(schema.doc());
+        }
+
         for(final TypedField field : schema) {
             sb.field(field.name(), field.schema().map(this)).optional();
         }
-        if (schema.name() != null) {
-            sb.name(schema.name());
-        }
+
         return sb.build();
     }