public class

YarnProvisioner

extends Object
implements ContainerProvider Provisioner TargetProvider
java.lang.Object
   ↳ org.apache.helix.provisioning.yarn.YarnProvisioner

Summary

Fields
public static AppMasterConfig applicationMasterConfig
public static ApplicationSpec applicationSpec
Public Constructors
YarnProvisioner()
Public Methods
ListenableFuture<ContainerId> allocateContainer(ContainerSpec spec)
ListenableFuture<Boolean> deallocateContainer(ContainerId containerId)
TargetProviderResponse evaluateExistingContainers(Cluster cluster, ResourceId resourceId, Collection<Participant> participants)
ContainerProvider getContainerProvider()
TargetProvider getTargetProvider()
void init(HelixManager helixManager, ResourceConfig resourceConfig)
ListenableFuture<Boolean> startContainer(ContainerId containerId, Participant participant)
ListenableFuture<Boolean> stopContainer(ContainerId containerId)
[Expand]
Inherited Methods
From class java.lang.Object
From interface org.apache.helix.controller.provisioner.ContainerProvider
From interface org.apache.helix.controller.provisioner.Provisioner
From interface org.apache.helix.controller.provisioner.TargetProvider

Fields

public static AppMasterConfig applicationMasterConfig

public static ApplicationSpec applicationSpec

Public Constructors

public YarnProvisioner ()

Public Methods

public ListenableFuture<ContainerId> allocateContainer (ContainerSpec spec)

public ListenableFuture<Boolean> deallocateContainer (ContainerId containerId)

public TargetProviderResponse evaluateExistingContainers (Cluster cluster, ResourceId resourceId, Collection<Participant> participants)

public ContainerProvider getContainerProvider ()

public TargetProvider getTargetProvider ()

public void init (HelixManager helixManager, ResourceConfig resourceConfig)

public ListenableFuture<Boolean> startContainer (ContainerId containerId, Participant participant)

public ListenableFuture<Boolean> stopContainer (ContainerId containerId)