private Schema getObjectSchema()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageDeserializer.java [352:366]

• 13 lines of code
• 3 McCabe index (conditional complexity)

    private Schema getObjectSchema(ClassDataType type) {
        SchemaBuilder schemaBuilder = SchemaBuilder.struct();
        schemaBuilder.name(type.getFixedDescriptor().getName());

        for (DataField field : type.getFixedDescriptor().getFields()) {
            Schema valueSchema = getFieldSchema(field.getType());
            schemaBuilder.field(field.getName(), valueSchema);
            LOG.info("Adding field " + field.getName() + " -- " + valueSchema.type() + " IS OPTIONAL: " + valueSchema.isOptional());
        }

        if (type.isNullable()) {
            schemaBuilder.optional().defaultValue(null);
        }
        return schemaBuilder.build();
    }