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

Class DataClientFlinkContext

java.lang.Object

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

All Implemented Interfaces:

DataClientContext

public class DataClientFlinkContext
extends Object
implements DataClientContext

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
org.apache.pekko.actor.ActorSystem	actorSystem()
scala.concurrent.ExecutionContextExecutor	dispatcher()
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

Constructor Details

DataClientFlinkContext

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

Method Details

actorSystem

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

Specified by:

actorSystem in interface DataClientContext

dispatcher

public scala.concurrent.ExecutionContextExecutor dispatcher()

Specified by:

dispatcher 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