public void applyOverwrite()

in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSink.java [125:130]

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

    public void applyOverwrite(boolean overwrite) {
        if (overwrite && !supportUpsert) {
            throw new IllegalStateException(
                    "Overwrite sink requires specifying the table's primary key");
        }
    }