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

Class DataClientSparkContext

java.lang.Object

com.here.platform.data.client.spark.DataClientSparkContext

All Implemented Interfaces:

DataClientContext

public class DataClientSparkContext
extends Object
implements DataClientContext

Context holder with shared resources used by DataClient.

The context is not serializable (contains threads and sockets) and should never be shared between master and workers.

Constructor Summary

Constructors

Constructor	Description
DataClientSparkContext(org.apache.pekko.actor.ActorSystem actorSystem)

Method Summary

Modifier and Type	Method	Description
org.apache.pekko.actor.ActorSystem	actorSystem()
org.apache.pekko.stream.Materializer	materializer()
org.apache.pekko.Done	terminate()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.here.platform.data.client.utils.DataClientContext

dispatcher

Constructor Details

DataClientSparkContext

public DataClientSparkContext(org.apache.pekko.actor.ActorSystem actorSystem)

Method Details

actorSystem

public org.apache.pekko.actor.ActorSystem actorSystem()

Specified by:

actorSystem in interface DataClientContext

materializer

public org.apache.pekko.stream.Materializer materializer()

Specified by:

materializer in interface DataClientContext

terminate

public org.apache.pekko.Done terminate()

Specified by:

terminate in interface DataClientContext