public HBaseDynamicTableSink()

in flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/sink/HBaseDynamicTableSink.java [56:69]

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

    public HBaseDynamicTableSink(
            String tableName,
            DataType physicalDataType,
            Configuration hbaseConf,
            HBaseWriteOptions writeOptions,
            String nullStringLiteral) {
        this.tableName = tableName;
        this.physicalDataType = physicalDataType;
        this.hbaseTableSchema = HBaseTableSchema.fromDataType(physicalDataType);
        this.metadataKeys = Collections.emptyList();
        this.hbaseConf = hbaseConf;
        this.writeOptions = writeOptions;
        this.nullStringLiteral = nullStringLiteral;
    }