public KuduWriter()

in flink-connector-kudu/src/main/java/org/apache/flink/connector/kudu/connector/writer/KuduWriter.java [65:79]

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

    public KuduWriter(
            KuduTableInfo tableInfo,
            KuduWriterConfig writerConfig,
            KuduOperationMapper<T> operationMapper,
            KuduFailureHandler failureHandler)
            throws IOException {
        this.tableInfo = tableInfo;
        this.writerConfig = writerConfig;
        this.failureHandler = failureHandler;

        this.client = obtainClient();
        this.session = obtainSession();
        this.table = obtainTable();
        this.operationMapper = operationMapper;
    }