public class

Worker

extends Object
implements Runnable
java.lang.Object
   ↳ org.apache.helix.taskexecution.Worker

Class Overview

Generic Worker that is a HELIX Participant which on start up joins the cluster and waits for state transitions from Helix.
This class takes taskfactory and taskresultstore as arguments.
As part of state transition @see TaskStateModel, it launches task corresponding to the resource id.

Summary

Public Constructors
Worker(String zkAddr, String clusterName, String workerId, TaskFactory taskFactory, TaskResultStore taskResultStore)
Public Methods
void connect()
void disconnect()
static void main(String[] args)
void run()
[Expand]
Inherited Methods
From class java.lang.Object
From interface java.lang.Runnable

Public Constructors

public Worker (String zkAddr, String clusterName, String workerId, TaskFactory taskFactory, TaskResultStore taskResultStore)

Public Methods

public void connect ()

public void disconnect ()

public static void main (String[] args)

Throws
Exception

public void run ()