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

Class BlockingCommitterImpl

java.lang.Object

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

All Implemented Interfaces:

AutoCloseable

public class BlockingCommitterImpl
extends Object

Method Summary

Modifier and Type	Method	Description
void	close()
void	commitOffset(com.google.cloud.pubsublite.Offset offset)

Methods inherited from class java.lang.Object

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

Method Details

commitOffset

public void commitOffset(com.google.cloud.pubsublite.Offset offset)

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception