org.apache.drill.yarn.appMaster

Interface AMRegistrar

All Known Implementing Classes:

ZKClusterCoordinatorDriver

public interface AMRegistrar

Interface to register the AM. Registration prevents two AMs from running for the same Drill cluster. A normal return means that this AM now "owns" the cluster. An exception means this is a duplicate AM (or something went wrong.)

Although the interface contains a deregister call, the implementation should automatically deregister on death of the AM to prevent zombie registrations. (The production system, ZK, handles this via ephemeral znodes.)

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	AMRegistrar.AMRegistrationException

Method Summary

Modifier and Type	Method and Description
void	deregister()
void	register(String amHost, int amPort, String appId)

Method Detail

register

void register(String amHost,
              int amPort,
              String appId)
       throws AMRegistrar.AMRegistrationException

Throws:

AMRegistrar.AMRegistrationException

deregister

void deregister()