Class PslReadDataSourceOptions (0.3.4)

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

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

maxMessagesPerBatch()

public abstract long maxMessagesPerBatch()
Returns
TypeDescription
long

subscriptionPath()

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