private PubSubSink()

in flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/PubSubSink.java [80:94]

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

    private PubSubSink(
            Credentials credentials,
            SerializationSchema<IN> serializationSchema,
            String projectName,
            String topicName,
            String hostAndPortForEmulator) {
        this.exceptionAtomicReference = new AtomicReference<>();
        this.failureHandler = new FailureHandler();
        this.numPendingFutures = new AtomicInteger(0);
        this.credentials = credentials;
        this.serializationSchema = serializationSchema;
        this.projectName = projectName;
        this.topicName = topicName;
        this.hostAndPortForEmulator = hostAndPortForEmulator;
    }