public DataType getProducedDataType()

in flink-connector-kudu/src/main/java/org/apache/flink/connectors/kudu/table/KuduTableSource.java [104:121]

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

    public DataType getProducedDataType() {
        if (projectedFields == null) {
            return flinkSchema.toRowDataType();
        } else {
            DataTypes.Field[] fields = new DataTypes.Field[projectedFields.length];
            for (int i = 0; i < fields.length; i++) {
                String fieldName = projectedFields[i];
                fields[i] = DataTypes.FIELD(
                        fieldName,
                        flinkSchema
                                .getTableColumn(fieldName)
                                .get()
                                .getType()
                );
            }
            return DataTypes.ROW(fields);
        }
    }