public MongoDynamicTableSink()

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

17 lines of code
1 McCabe index (conditional complexity)


    public MongoDynamicTableSink(
            MongoConnectionOptions connectionOptions,
            MongoWriteOptions writeOptions,
            @Nullable Integer parallelism,
            ResolvedSchema resolvedSchema,
            String[] partitionKeys) {
        this.connectionOptions = checkNotNull(connectionOptions);
        this.writeOptions = checkNotNull(writeOptions);
        this.parallelism = parallelism;
        this.resolvedSchema = checkNotNull(resolvedSchema);
        this.partitionKeys = checkNotNull(partitionKeys);
        this.supportUpsert = resolvedSchema.getPrimaryKey().isPresent();
        this.primaryKeyExtractor =
                MongoPrimaryKeyExtractor.createPrimaryKeyExtractor(resolvedSchema);
        this.shardKeysExtractor =
                MongoShardKeysExtractor.createShardKeysExtractor(resolvedSchema, partitionKeys);
    }