private void addDataField()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/RawMessageSerializer.java [384:407]

23 lines of code
7 McCabe index (conditional complexity)


    private void addDataField(String fieldName, Schema fieldSchema, List<DataField> fields, boolean flatten) {

        if (flatten && fieldSchema.type() == Schema.Type.STRUCT) {
            for (Field field : fieldSchema.fields()) {
                addDataField(fieldMap.addToPath(fieldName, field.name()), field.schema(), fields, flatten);
            }
        }
        else {
            if (fieldSelection.isSelected(fieldName)) {
                DataType fieldType = getDataType(fieldName, fieldSchema);
                if (fieldType != null) {
                    fieldName = fieldMap.getDestination(fieldName); //rename
                    DataField dataField = new NonStaticDataField(fieldName, fieldName, fieldType);
                    dataField.setDescription(fieldSchema.doc());
                    fields.add(dataField);
                    if (LOG.isDebugEnabled())
                        LOG.debug("Added Field " + fieldName + "/" + fieldType.getClass());
                }
            }
            else {
                LOG.debug("Skipping Excluded Field " + fieldName);
            }
        }
    }