org.apache.beam.sdk.io.gcp.pubsublite

Class PublisherOptions

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsublite.PublisherOptions

All Implemented Interfaces:

java.io.Serializable

public abstract class PublisherOptions
extends java.lang.Object
implements java.io.Serializable

Options needed for a Pub/Sub Lite Publisher.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PublisherOptions.Builder

Constructor Summary

Constructors

Constructor and Description
PublisherOptions()

Method Summary

Modifier and Type	Method and Description
abstract int	hashCode()
static PublisherOptions.Builder	newBuilder()
abstract @Nullable SerializableSupplier<com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub>	stubSupplier() A supplier for the stub to be used.
abstract com.google.cloud.pubsublite.TopicPath	topicPath()
boolean	usesCache()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PublisherOptions

public PublisherOptions()

Method Detail

topicPath

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

stubSupplier

public abstract @Nullable SerializableSupplier<com.google.cloud.pubsublite.proto.PublisherServiceGrpc.PublisherServiceStub> stubSupplier()

A supplier for the stub to be used. If enabled, does not use the publisher cache.

hashCode

public abstract int hashCode()

Overrides:

hashCode in class java.lang.Object

newBuilder

public static PublisherOptions.Builder newBuilder()

usesCache

public boolean usesCache()