Package com.here.platform.data.client.spark

Class SparkSupport.AugmentedFuture<A>

java.lang.Object

scala.AnyVal

com.here.platform.data.client.spark.SparkSupport.AugmentedFuture<A>

Enclosing class:

SparkSupport

public static final class SparkSupport.AugmentedFuture<A>
extends scala.AnyVal

Constructor Summary

Constructors

Constructor	Description
AugmentedFuture(scala.concurrent.Future<A> self)

Method Summary

Modifier and Type	Method	Description
A	awaitResult()	Wait for a asynchronous to result.
A	awaitResult(scala.concurrent.duration.FiniteDuration atMost)	Wait for a asynchronous with a defined timeout.
scala.concurrent.Future<A>	self()

Methods inherited from class java.lang.Object

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

Constructor Details

AugmentedFuture

public AugmentedFuture(scala.concurrent.Future<A> self)

Method Details

self

public scala.concurrent.Future<A> self()

awaitResult

public A awaitResult()

Wait for a asynchronous to result.

awaitResult

public A awaitResult(scala.concurrent.duration.FiniteDuration atMost)

Wait for a asynchronous with a defined timeout. This duration need to be bigger than all internal DataClient retries and timeouts.