protected CassandraTupleWriteAheadSink()

in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraTupleWriteAheadSink.java [62:72]

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

    protected CassandraTupleWriteAheadSink(
            String insertQuery,
            TypeSerializer<IN> serializer,
            ClusterBuilder builder,
            CheckpointCommitter committer)
            throws Exception {
        super(committer, serializer, UUID.randomUUID().toString().replace("-", "_"));
        this.insertQuery = insertQuery;
        this.builder = builder;
        ClosureCleaner.clean(builder, ExecutionConfig.ClosureCleanerLevel.RECURSIVE, true);
    }