public RowDataToMutationConverter()

in flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/sink/RowDataToMutationConverter.java [47:58]

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

    public RowDataToMutationConverter(
            HBaseTableSchema schema,
            DataType physicalDataType,
            List<String> metadataKeys,
            String nullStringLiteral,
            boolean ignoreNullValue) {
        this.schema = schema;
        this.nullStringLiteral = nullStringLiteral;
        this.ignoreNullValue = ignoreNullValue;
        this.timestampMetadata = new TimestampMetadata(metadataKeys, physicalDataType);
        this.timeToLiveMetadata = new TimeToLiveMetadata(metadataKeys, physicalDataType);
    }