Interface | Description |
---|---|
SplitLogManagerCoordination |
Coordination for SplitLogManager.
|
SplitLogWorkerCoordination |
Coordinated operations for
SplitLogWorker and
WALSplitterHandler Important
methods for SplitLogWorker: SplitLogWorkerCoordination.isReady() called from SplitLogWorker.run() to check whether the coordination is
ready to supply the tasks SplitLogWorkerCoordination.taskLoop() loop for new tasks until the worker is stopped SplitLogWorkerCoordination.isStop() a flag indicates whether worker should finish SplitLogWorkerCoordination.registerListener() called from SplitLogWorker.run() and could register listener
for external changes in coordination (if required) SplitLogWorkerCoordination.endTask(SplitLogTask, LongAdder, SplitTaskDetails) notify coordination engine that |
SplitLogWorkerCoordination.SplitTaskDetails |
Interface for log-split tasks Used to carry implementation details in encapsulated way through
Handlers to the coordination API.
|
ZKSplitLogManagerCoordination.TaskFinisher |
SplitLogManager can use objects implementing this
interface to finish off a partially done task by
SplitLogWorker . |
Class | Description |
---|---|
SplitLogManagerCoordination.SplitLogManagerDetails |
Detail class that shares data between coordination and split log manager
|
ZkCoordinatedStateManager |
ZooKeeper-based implementation of
CoordinatedStateManager . |
ZKSplitLogManagerCoordination |
ZooKeeper based implementation of
SplitLogManagerCoordination |
ZkSplitLogWorkerCoordination |
ZooKeeper based implementation of
SplitLogWorkerCoordination
It listen for changes in ZooKeeper and |
ZkSplitLogWorkerCoordination.ZkSplitTaskDetails |
When ZK-based implementation wants to complete the task, it needs to know task znode and
current znode cversion (needed for subsequent update operation).
|
Enum | Description |
---|---|
ZKSplitLogManagerCoordination.TaskFinisher.Status |
status that can be returned finish()
|
Copyright © 2007–2019 Cloudera. All rights reserved.