Skip to content

Instantly share code, notes, and snippets.

What would you like to do?
Registering "Task" state model to this Helix Participant
// 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