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

Class BlockingCommitterImpl

java.lang.Object

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

public class BlockingCommitterImpl
extends java.lang.Object

Method Summary

Modifier and Type	Method and 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 Detail

commitOffset

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

close

public void close()
           throws java.lang.Exception

Throws:

java.lang.Exception