protected void postOpen()

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

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

    protected void postOpen() {
        super.postOpen();
        MappingManager mappingManager = new MappingManager(session);
        this.mapper = mappingManager.mapper(outputClass);
        if (mapperOptions != null) {
            Mapper.Option[] optionsArray = mapperOptions.getMapperOptions();
            if (optionsArray != null) {
                mapper.setDefaultSaveOptions(optionsArray);
            }
        }
    }