Class PslWriteDataSourceOptions (0.3.4)

public abstract class PslWriteDataSourceOptions implements Serializable

Inheritance

java.lang.Object > PslWriteDataSourceOptions

Implements

Serializable

Constructors

PslWriteDataSourceOptions()

public PslWriteDataSourceOptions()

Methods

builder()

public static PslWriteDataSourceOptions.Builder builder()
Returns
Type Description
PslWriteDataSourceOptions.Builder

createNewPublisher()

public Publisher<MessageMetadata> createNewPublisher()
Returns
Type Description
com.google.cloud.pubsublite.internal.Publisher<com.google.cloud.pubsublite.MessageMetadata>

credentialsKey()

public abstract String credentialsKey()
Returns
Type Description
String

fromSparkDataSourceOptions(DataSourceOptions options)

public static PslWriteDataSourceOptions fromSparkDataSourceOptions(DataSourceOptions options)
Parameter
Name Description
options org.apache.spark.sql.sources.v2.DataSourceOptions
Returns
Type Description
PslWriteDataSourceOptions

getCredentialProvider()

public PslCredentialsProvider getCredentialProvider()
Returns
Type Description
PslCredentialsProvider

topicPath()

public abstract TopicPath topicPath()
Returns
Type Description
com.google.cloud.pubsublite.TopicPath