Package com.here.platform.data.client.flink.impl

Class ContinuousSourceUtils.AvailabilityHelper

java.lang.Object

com.here.platform.data.client.flink.impl.ContinuousSourceUtils.AvailabilityHelper

Enclosing class:

ContinuousSourceUtils

public static final class ContinuousSourceUtils.AvailabilityHelper
extends Object

Thread-safe availability notifier for bridging push (background thread) to pull (pollNext).

Constructor Summary

Constructors

Constructor	Description
AvailabilityHelper()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	getAvailabilityFuture(scala.Function0<Object> hasData)	Called by the framework thread.
void	notifyAvailable()	Called from background thread when new data is available.

Methods inherited from class java.lang.Object

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

Constructor Details

AvailabilityHelper

public AvailabilityHelper()

Method Details

getAvailabilityFuture

public CompletableFuture<Void> getAvailabilityFuture(scala.Function0<Object> hasData)

Called by the framework thread. Returns completed if data is available.

Parameters:

hasData - supplier re-evaluated under lock to avoid race with notifyAvailable()

notifyAvailable

public void notifyAvailable()

Called from background thread when new data is available.