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

Interface ManagedBacklogReaderFactory

All Superinterfaces:

java.lang.AutoCloseable, java.io.Serializable

All Known Implementing Classes:

ManagedBacklogReaderFactoryImpl

public interface ManagedBacklogReaderFactory
extends java.lang.AutoCloseable, java.io.Serializable

A ManagedBacklogReaderFactory produces TopicBacklogReaders and tears down any produced readers when it is itself closed.

close() should never be called on produced readers.

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.beam.sdk.io.gcp.pubsublite.internal.TopicBacklogReader	newReader(SubscriptionPartition subscriptionPartition)

Method Detail

newReader

org.apache.beam.sdk.io.gcp.pubsublite.internal.TopicBacklogReader newReader(SubscriptionPartition subscriptionPartition)

close

void close()

Specified by:

close in interface java.lang.AutoCloseable