public void open()

in flink-connector-cassandra/src/main/java/org/apache/flink/streaming/connectors/cassandra/CassandraPojoSink.java [99:114]

• 16 lines of code
• 4 McCabe index (conditional complexity)

    public void open(Configuration configuration) {
        super.open(configuration);
        try {
            this.mappingManager = new MappingManager(session);
            this.mapper = mappingManager.mapper(clazz);
            if (options != null) {
                Mapper.Option[] optionsArray = options.getMapperOptions();
                if (optionsArray != null) {
                    this.mapper.setDefaultSaveOptions(optionsArray);
                }
            }
        } catch (Exception e) {
            throw new RuntimeException(
                    "Cannot create CassandraPojoSink with input: " + clazz.getSimpleName(), e);
        }
    }