Package | Description |
---|---|
org.apache.flink.streaming.connectors.gcp.pubsub |
Modifier and Type | Method and Description |
---|---|
PubSubSink.PubSubSinkBuilder<IN> |
PubSubSink.PubSubSinkBuilder.withCredentials(com.google.auth.Credentials credentials)
Set the credentials.
|
PubSubSink.PubSubSinkBuilder<IN> |
PubSubSink.PubSubSinkBuilder.withHostAndPortForEmulator(String hostAndPort)
Set the custom hostname/port combination of PubSub.
|
PubSubSink.PubSubSinkBuilder<IN> |
PubSubSink.PubSubSinkBuilder.withTopicName(String topicName) |
PubSubSink.PubSubSinkBuilder<IN> |
PubSubSink.TopicNameBuilder.withTopicName(String topicName)
Set the subscription name of the subscription to pull messages from.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.