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
TypeDescription
PslWriteDataSourceOptions.Builder

createNewPublisher()

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

credentialsKey()

public abstract String credentialsKey()
Returns
TypeDescription
String

fromSparkDataSourceOptions(DataSourceOptions options)

public static PslWriteDataSourceOptions fromSparkDataSourceOptions(DataSourceOptions options)
Parameter
NameDescription
optionsorg.apache.spark.sql.sources.v2.DataSourceOptions
Returns
TypeDescription
PslWriteDataSourceOptions

getCredentialProvider()

public PslCredentialsProvider getCredentialProvider()
Returns
TypeDescription
PslCredentialsProvider

topicPath()

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