public MongoDynamicTableSink()

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

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

    public MongoDynamicTableSink(
            MongoConnectionOptions connectionOptions,
            MongoWriteOptions writeOptions,
            @Nullable Integer parallelism,
            boolean isUpsert,
            DataType physicalRowDataType,
            SerializableFunction<RowData, BsonValue> keyExtractor) {
        this.connectionOptions = checkNotNull(connectionOptions);
        this.writeOptions = checkNotNull(writeOptions);
        this.parallelism = parallelism;
        this.isUpsert = isUpsert;
        this.physicalRowDataType = checkNotNull(physicalRowDataType);
        this.keyExtractor = checkNotNull(keyExtractor);
    }