public class

BootstrapProcess

extends Object
java.lang.Object
   ↳ org.apache.helix.examples.BootstrapProcess

Class Overview

This process does little more than handling the state transition messages. This is generally the case when the server needs to bootstrap when it comes up.
Flow for a typical Master-slave state model

  • Gets OFFLINE-SLAVE transition
  • Figure out if it has any data and how old it is for the SLAVE partition
  • If the data is fresh enough it can probably catch up from the replication stream of the master
  • If not, then it can use the messaging service provided by cluster manager to talk other nodes to figure out if they have any backup
  • Once it gets a response from other nodes in the cluster the process can decide which back up it wants to use to bootstrap

Summary

Nested Classes
class BootstrapProcess.CustomMessageHandlerFactory  
Constants
String cluster
String configFile
String help
String hostAddress
String hostPort
String relayCluster
String stateModel
String transDelay
String zkServer
Public Constructors
BootstrapProcess(String zkConnectString, String clusterName, String instanceName, String stateModel, int delay)
Public Methods
static void main(String[] args)
static void printUsage(Options cliOptions)
static CommandLine processCommandLineArgs(String[] cliArgs)
void start()
[Expand]
Inherited Methods
From class java.lang.Object

Constants

public static final String cluster

Constant Value: "cluster"

public static final String configFile

Constant Value: "configFile"

public static final String help

Constant Value: "help"

public static final String hostAddress

Constant Value: "host"

public static final String hostPort

Constant Value: "port"

public static final String relayCluster

Constant Value: "relayCluster"

public static final String stateModel

Constant Value: "stateModelType"

public static final String transDelay

Constant Value: "transDelay"

public static final String zkServer

Constant Value: "zkSvr"

Public Constructors

public BootstrapProcess (String zkConnectString, String clusterName, String instanceName, String stateModel, int delay)

Public Methods

public static void main (String[] args)

Throws
Exception

public static void printUsage (Options cliOptions)

public static CommandLine processCommandLineArgs (String[] cliArgs)

Throws
Exception

public void start ()

Throws
Exception