public RocketMQRowDataConverter()

in src/main/java/org/apache/flink/connector/rocketmq/sink/table/RocketMQRowDataConverter.java [73:100]

• 28 lines of code
• 1 McCabe index (conditional complexity)

    public RocketMQRowDataConverter(
            String topic,
            String tag,
            String dynamicColumn,
            String fieldDelimiter,
            String encoding,
            boolean isDynamicTag,
            boolean isDynamicTagIncluded,
            boolean writeKeysToBody,
            String[] keyColumns,
            RowTypeInfo rowTypeInfo,
            DataType[] fieldDataTypes,
            boolean hasMetadata,
            int[] metadataPositions) {
        this.topic = topic;
        this.tag = tag;
        this.dynamicColumn = dynamicColumn;
        this.fieldDelimiter = fieldDelimiter;
        this.encoding = encoding;
        this.isDynamicTag = isDynamicTag;
        this.isDynamicTagIncluded = isDynamicTagIncluded;
        this.writeKeysToBody = writeKeysToBody;
        this.keyColumns = keyColumns;
        this.rowTypeInfo = rowTypeInfo;
        this.fieldDataTypes = fieldDataTypes;
        this.hasMetadata = hasMetadata;
        this.metadataPositions = metadataPositions;
    }