public void open()

in flink-connector-cassandra/src/main/java/org/apache/flink/batch/connectors/cassandra/CassandraPojoInputFormat.java [57:70]

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

    public void open(InputSplit split) {
        this.session = cluster.connect();
        MappingManager manager = new MappingManager(session);

        Mapper<OUT> mapper = manager.mapper(inputClass);

        if (mapperOptions != null) {
            Mapper.Option[] optionsArray = mapperOptions.getMapperOptions();
            if (optionsArray != null) {
                mapper.setDefaultGetOptions(optionsArray);
            }
        }
        this.resultSet = mapper.map(session.execute(query));
    }