public CassandraPojoOutputFormat()

in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoOutputFormat.java [59:69]

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

    public CassandraPojoOutputFormat(
            ClusterBuilder builder,
            Class<OUT> outputClass,
            MapperOptions mapperOptions,
            int maxConcurrentRequests,
            Duration maxConcurrentRequestsTimeout) {
        super(builder, maxConcurrentRequests, maxConcurrentRequestsTimeout);
        Preconditions.checkNotNull(outputClass, "OutputClass cannot be null");
        this.mapperOptions = mapperOptions;
        this.outputClass = outputClass;
    }