Class PslReadDataSourceOptions

public abstract class PslReadDataSourceOptions implements Serializable

Inheritance

java.lang.Object > PslReadDataSourceOptions

Implements

Serializable

Constructors

PslReadDataSourceOptions()

public PslReadDataSourceOptions()

Methods

builder()

public static PslReadDataSourceOptions.Builder builder()
Returns
TypeDescription
PslReadDataSourceOptions.Builder

credentialsKey()

public abstract String credentialsKey()
Returns
TypeDescription
String

flowControlSettings()

public abstract FlowControlSettings flowControlSettings()
Returns
TypeDescription
com.google.cloud.pubsublite.cloudpubsub.FlowControlSettings

fromSparkDataSourceOptions(DataSourceOptions options)

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

maxMessagesPerBatch()

public abstract long maxMessagesPerBatch()
Returns
TypeDescription
long

subscriptionPath()

public abstract SubscriptionPath subscriptionPath()
Returns
TypeDescription
com.google.cloud.pubsublite.SubscriptionPath