ACCUMULO-2571 State machine for data which needs replication
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/71475cf8 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/71475cf8 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/71475cf8 Branch: refs/heads/ACCUMULO-378 Commit: 71475cf87596e9d4d85d54e6565b1a5c70dcf88d Parents: de7f591 Author: Josh Elser <els...@apache.org> Authored: Fri Apr 4 18:29:20 2014 -0400 Committer: Josh Elser <els...@apache.org> Committed: Fri Apr 4 18:29:20 2014 -0400 ---------------------------------------------------------------------- .../main/resources/state/replicationstatus.gv | 25 +++++++++++++++++++ .../main/resources/state/replicationstatus.png | Bin 0 -> 65414 bytes 2 files changed, 25 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/71475cf8/docs/src/main/resources/state/replicationstatus.gv ---------------------------------------------------------------------- diff --git a/docs/src/main/resources/state/replicationstatus.gv b/docs/src/main/resources/state/replicationstatus.gv new file mode 100644 index 0000000..518dd83 --- /dev/null +++ b/docs/src/main/resources/state/replicationstatus.gv @@ -0,0 +1,25 @@ +digraph Replication { + graph [ label="Replication", fontsize=24, fontname=Helvetica]; + node [fontsize=12, fontname=Helvetica]; + edge [fontsize=9, fontcolor=blue, fontname=ArialMT]; + subgraph cluster_ReplicationStatus { + label="ReplicationStatus" + "ReplicationStatus.OPEN" [ label = "Open for\nreplication" ]; + "ReplicationStatus.OPEN" -> "ReplicationStatus.DATA_REPLICATED" [ label = "Data replicated" ]; + "ReplicationStatus.OPEN" -> "ReplicationStatus.DATA_INGESTED" [ label = "Data ingested locally" ]; + "ReplicationStatus.OPEN" -> "ReplicationStatus.CLOSED" [ label = "Local file closed\nfor addl writes" ]; + + "ReplicationStatus.DATA_REPLICATED" [ label = "Data Replicated" ]; + "ReplicationStatus.DATA_REPLICATED" -> "ReplicationStatus.OPEN" [ label = "Increment replication\nfinished offset" ]; + "ReplicationStatus.DATA_REPLICATED" -> "ReplicationStatus.CLOSED" [ label = "Increment replication\nfinished offset" ]; + + "ReplicationStatus.DATA_INGESTED" [ label = "Data Ingested" ]; + "ReplicationStatus.DATA_INGESTED" -> "ReplicationStatus.OPEN" [ label = "Increment replication\nneeded offset" ]; + + "ReplicationStatus.CLOSED" [ label = Closed]; + "ReplicationStatus.CLOSED" -> "ReplicationStatus.DATA_REPLICATED" [ label = "Data replicated" ]; + "ReplicationStatus.CLOSED" -> "ReplicationStatus.DELETED" [ label = "All data replicated" ]; + + "ReplicationStatus.DELETED" [ label = "Local resources ready for deletion" ]; + } +} http://git-wip-us.apache.org/repos/asf/accumulo/blob/71475cf8/docs/src/main/resources/state/replicationstatus.png ---------------------------------------------------------------------- diff --git a/docs/src/main/resources/state/replicationstatus.png b/docs/src/main/resources/state/replicationstatus.png new file mode 100644 index 0000000..85ca0e0 Binary files /dev/null and b/docs/src/main/resources/state/replicationstatus.png differ
