public class

MyTaskService

extends StatelessParticipantService
java.lang.Object
   ↳ com.google.common.util.concurrent.AbstractService
     ↳ org.apache.helix.participant.AbstractParticipantService
       ↳ org.apache.helix.provisioning.participant.StatelessParticipantService
         ↳ org.apache.helix.provisioning.yarn.example.MyTaskService

Class Overview

A simple "service" for task callback registration.

Summary

Public Constructors
MyTaskService(HelixConnection connection, ClusterId clusterId, ParticipantId participantId)
Protected Methods
void goOffine()
Invoked when this service is instructed to go offline
void goOnline()
Invoked when this service is instructed to go online
void init(ServiceConfig serviceConfig)
Initialize the service with a configuration
[Expand]
Inherited Methods
From class org.apache.helix.provisioning.participant.StatelessParticipantService
From class org.apache.helix.participant.AbstractParticipantService
From class com.google.common.util.concurrent.AbstractService
From class java.lang.Object
From interface com.google.common.util.concurrent.Service

Public Constructors

public MyTaskService (HelixConnection connection, ClusterId clusterId, ParticipantId participantId)

Protected Methods

protected void goOffine ()

Invoked when this service is instructed to go offline

protected void goOnline ()

Invoked when this service is instructed to go online

protected void init (ServiceConfig serviceConfig)

Initialize the service with a configuration