org.apache.flink.streaming.connectors.kinesis.util

Class TimeoutLatch

java.lang.Object

org.apache.flink.streaming.connectors.kinesis.util.TimeoutLatch

@Internal
public class TimeoutLatch
extends Object

Internal use.

Constructor Summary

Constructors

Constructor and Description
TimeoutLatch()

Method Summary

Modifier and Type	Method and Description
void	await(long timeout)
void	trigger()

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeoutLatch

public TimeoutLatch()

Method Detail

await

public void await(long timeout)
           throws InterruptedException

Throws:

InterruptedException

trigger

public void trigger()