Skip to content

Instantly share code, notes, and snippets.

@narendly

narendly/StorageNode.java

Created July 16, 2018 05:32
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save narendly/d6f9cd295fab40439c848fd8b876d559 to your computer and use it in GitHub Desktop.
Save narendly/d6f9cd295fab40439c848fd8b876d559 to your computer and use it in GitHub Desktop.
Download ZIP
Registering "Task" state model to this Helix Participant
Raw
StorageNode.java
// Register TaskFactory with this storageNode's helixManager
HelixManager helixManager = _clusterManagerAdmin.getClusterManager();
StateMachineEngine stateMachine = helixManager.getStateMachineEngine();
_helixTaskFactory = new TaskStateModelFactory(helixManager, taskFactoryMap);
stateMachine.registerStateModelFactory("Task", _helixTaskFactory);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment