public class ReconciliationCoordinator$ extends Object
Modifier and Type | Field and Description |
---|---|
static ReconciliationCoordinator$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
ReconciliationCoordinator$() |
Modifier and Type | Method and Description |
---|---|
<T extends ReconciliationCoordinator> |
createActorProps(Class<T> actorClass,
Configuration flinkConfig,
org.apache.mesos.SchedulerDriver schedulerDriver)
Create the properties for a reconciliation coordinator.
|
scala.concurrent.duration.FiniteDuration |
INITIAL_RECONCILIATION_TIMEOUT() |
scala.concurrent.duration.FiniteDuration |
RECONCILIATION_MAX_BACKOFF() |
scala.concurrent.duration.FiniteDuration |
RECONCILIATION_MIN_BACKOFF() |
public static final ReconciliationCoordinator$ MODULE$
public scala.concurrent.duration.FiniteDuration INITIAL_RECONCILIATION_TIMEOUT()
public scala.concurrent.duration.FiniteDuration RECONCILIATION_MIN_BACKOFF()
public scala.concurrent.duration.FiniteDuration RECONCILIATION_MAX_BACKOFF()
public <T extends ReconciliationCoordinator> akka.actor.Props createActorProps(Class<T> actorClass, Configuration flinkConfig, org.apache.mesos.SchedulerDriver schedulerDriver)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.