public class

ZKPropertyTransferServer

extends Object
java.lang.Object
   ↳ org.apache.helix.controller.restlet.ZKPropertyTransferServer

Class Overview

Controller side restlet server that receives ZNRecordUpdate requests from clients, and batch the ZNRecordUpdate and apply them to zookeeper. This is to optimize the concurrency level of zookeeper access for ZNRecord updates that does not require real-time, like message handling status updates and healthcheck reports. As one server will be used by multiple helix controllers that runs on the same machine, This class is designed as a singleton. Application is responsible to call init() and shutdown() on the getInstance().

Summary

Constants
String PORT
String SERVER
Fields
public static int MAX_UPDATE_LIMIT
public static int PERIOD
public static String RESTRESOURCENAME
Public Methods
static ZKPropertyTransferServer getInstance()
String getWebserviceUrl()
void init(int localWebservicePort, String zkAddress)
boolean isInitialized()
void reset()
void shutdown()
[Expand]
Inherited Methods
From class java.lang.Object

Constants

public static final String PORT

Constant Value: "port"

public static final String SERVER

Constant Value: "ZKPropertyTransferServer"

Fields

public static int MAX_UPDATE_LIMIT

public static int PERIOD

public static String RESTRESOURCENAME

Public Methods

public static ZKPropertyTransferServer getInstance ()

public String getWebserviceUrl ()

public void init (int localWebservicePort, String zkAddress)

public boolean isInitialized ()

public void reset ()

public void shutdown ()