You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2014/06/14 06:55:51 UTC
[51/51] [abbrv] git commit: ACCUMULO-378 Merge replication work into
upstream.
ACCUMULO-378 Merge replication work into upstream.
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/a2aabbcb
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/a2aabbcb
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/a2aabbcb
Branch: refs/heads/master
Commit: a2aabbcbbcb17e2ecccb71e58b531d3135b6ada0
Parents: a32b926 19bdff3
Author: Josh Elser <el...@apache.org>
Authored: Sat Jun 14 00:44:07 2014 -0400
Committer: Josh Elser <el...@apache.org>
Committed: Sat Jun 14 00:44:07 2014 -0400
----------------------------------------------------------------------
core/pom.xml | 23 +
.../org/apache/accumulo/core/Constants.java | 1 +
.../apache/accumulo/core/client/Connector.java | 9 +
.../client/admin/ReplicationOperations.java | 86 +
.../core/client/impl/ConnectorImpl.java | 12 +
.../accumulo/core/client/impl/MasterClient.java | 1 +
.../core/client/impl/ReplicationClient.java | 246 ++
.../client/impl/ReplicationOperationsImpl.java | 284 +++
.../core/client/mock/MockConnector.java | 7 +
.../client/replication/PeerExistsException.java | 36 +
.../replication/PeerNotFoundException.java | 40 +
.../core/client/replication/ReplicaSystem.java | 47 +
.../replication/ReplicaSystemFactory.java | 82 +
.../org/apache/accumulo/core/conf/Property.java | 37 +-
.../accumulo/core/data/ConditionalMutation.java | 7 +
.../org/apache/accumulo/core/data/Mutation.java | 85 +-
.../core/data/thrift/MultiScanResult.java | 152 +-
.../accumulo/core/data/thrift/ScanResult.java | 36 +-
.../core/data/thrift/TConditionalMutation.java | 36 +-
.../accumulo/core/data/thrift/TMutation.java | 181 +-
.../accumulo/core/data/thrift/UpdateErrors.java | 132 +-
.../core/metadata/schema/MetadataSchema.java | 97 +-
.../accumulo/core/protobuf/ProtobufUtil.java | 38 +
.../AccumuloReplicationReplayer.java | 32 +
.../replication/PrintReplicationRecords.java | 97 +
.../core/replication/ReplicaSystemHelper.java | 71 +
.../ReplicationConfigurationUtil.java | 42 +
.../core/replication/ReplicationConstants.java | 30 +
.../core/replication/ReplicationSchema.java | 303 +++
.../core/replication/ReplicationTarget.java | 187 ++
.../core/replication/StatusFormatter.java | 187 ++
.../accumulo/core/replication/StatusUtil.java | 210 ++
.../core/replication/proto/Replication.java | 949 +++++++
.../core/replication/thrift/KeyValues.java | 456 ++++
.../thrift/RemoteReplicationErrorCode.java | 70 +
.../thrift/RemoteReplicationException.java | 518 ++++
.../core/replication/thrift/Replication.java | 1917 ++++++++++++++
.../thrift/ReplicationCoordinator.java | 1119 +++++++++
.../thrift/ReplicationCoordinatorErrorCode.java | 64 +
.../thrift/ReplicationCoordinatorException.java | 518 ++++
.../replication/thrift/ReplicationServicer.java | 2343 ++++++++++++++++++
.../core/replication/thrift/WalEdits.java | 456 ++++
.../apache/accumulo/core/schema/Section.java | 37 +
.../thrift/ReplicationFailedException.java | 402 +++
core/src/main/protobuf/replication.proto | 26 +
core/src/main/scripts/generate-protobuf.sh | 97 +
core/src/main/scripts/generate-thrift.sh | 2 +-
core/src/main/thrift/data.thrift | 3 +-
core/src/main/thrift/replication.thrift | 63 +
.../ReplicationConfigurationUtilTest.java | 82 +
.../ReplicationOperationsImplTest.java | 414 ++++
.../core/replication/ReplicationSchemaTest.java | 134 +
.../core/replication/ReplicationTargetTest.java | 98 +
.../core/replication/StatusUtilTest.java | 57 +
.../core/replication/proto/StatusTest.java | 36 +
.../main/asciidoc/accumulo_user_manual.asciidoc | 2 +
docs/src/main/asciidoc/chapters/replication.txt | 314 +++
.../resources/design/ACCUMULO-378-design.mdtext | 468 ++++
.../main/resources/state/replicationstatus.gv | 40 +
.../main/resources/state/replicationstatus.png | Bin 0 -> 65414 bytes
.../src/main/resources/state/table-lifecycle.gv | 77 +
.../main/resources/state/table-lifecycle.png | Bin 0 -> 190640 bytes
.../impl/MiniAccumuloConfigImpl.java | 2 +
server/base/pom.xml | 18 +-
.../server/conf/TableConfigurationCopy.java | 77 +
.../server/constraints/MetadataConstraints.java | 8 +-
.../apache/accumulo/server/fs/VolumeUtil.java | 19 +-
.../apache/accumulo/server/init/Initialize.java | 106 +-
.../DistributedWorkQueueWorkAssignerHelper.java | 77 +
.../server/replication/ReplicationTable.java | 227 ++
.../server/replication/StatusCombiner.java | 154 ++
.../server/replication/WorkAssigner.java | 42 +
.../server/util/MasterMetadataUtil.java | 87 +-
.../accumulo/server/util/MetadataTableUtil.java | 1 +
.../server/util/ReplicationTableUtil.java | 214 ++
.../accumulo/server/util/SystemPropUtil.java | 8 +-
.../server/zookeeper/DistributedWorkQueue.java | 24 +-
.../replication/ReplicationTableTest.java | 132 +
.../server/replication/StatusCombinerTest.java | 257 ++
.../server/util/ReplicationTableUtilTest.java | 157 ++
server/gc/pom.xml | 18 +-
.../gc/GarbageCollectWriteAheadLogs.java | 280 ++-
.../accumulo/gc/GarbageCollectionAlgorithm.java | 36 +
.../gc/GarbageCollectionEnvironment.java | 10 +
.../accumulo/gc/SimpleGarbageCollector.java | 46 +
.../CloseWriteAheadLogReferences.java | 257 ++
.../gc/GarbageCollectWriteAheadLogsTest.java | 254 +-
.../accumulo/gc/GarbageCollectionTest.java | 89 +
.../CloseWriteAheadLogReferencesTest.java | 370 +++
server/gc/src/test/resources/log4j.properties | 3 +
server/master/pom.xml | 15 +-
.../java/org/apache/accumulo/master/Master.java | 34 +
.../DistributedWorkQueueWorkAssigner.java | 278 +++
.../master/replication/FinishedWorkUpdater.java | 175 ++
.../MasterReplicationCoordinator.java | 107 +
.../RemoveCompleteReplicationRecords.java | 217 ++
.../master/replication/ReplicationDriver.java | 108 +
.../replication/SequentialWorkAssigner.java | 229 ++
.../master/replication/StatusMaker.java | 254 ++
.../replication/UnorderedWorkAssigner.java | 172 ++
.../accumulo/master/replication/WorkDriver.java | 110 +
.../accumulo/master/replication/WorkMaker.java | 198 ++
.../accumulo/master/tableOps/CreateTable.java | 14 +-
...tributedWorkQueueWorkAssignerHelperTest.java | 56 +
.../replication/FinishedWorkUpdaterTest.java | 170 ++
.../MasterReplicationCoordinatorTest.java | 95 +
.../RemoveCompleteReplicationRecordsTest.java | 335 +++
.../replication/SequentialWorkAssignerTest.java | 424 ++++
.../master/replication/StatusMakerTest.java | 262 ++
.../replication/UnorderedWorkAssignerTest.java | 295 +++
.../master/replication/WorkMakerTest.java | 212 ++
.../master/src/test/resources/log4j.properties | 2 +
server/monitor/pom.xml | 10 +-
.../org/apache/accumulo/monitor/Monitor.java | 2 +
.../accumulo/monitor/servlets/BasicServlet.java | 1 +
.../monitor/servlets/ReplicationServlet.java | 275 ++
server/tserver/pom.xml | 22 +-
.../apache/accumulo/tserver/TabletServer.java | 85 +-
.../tserver/log/TabletServerLogger.java | 28 +-
.../replication/AccumuloReplicaSystem.java | 696 ++++++
.../BatchWriterReplicationReplayer.java | 114 +
.../replication/ReplicationProcessor.java | 180 ++
.../replication/ReplicationServicerHandler.java | 123 +
.../tserver/replication/ReplicationWorker.java | 77 +
.../tserver/tablet/DatafileManager.java | 26 +-
.../apache/accumulo/tserver/tablet/Tablet.java | 26 +-
.../replication/AccumuloReplicaSystemTest.java | 496 ++++
.../replication/ReplicationProcessorTest.java | 100 +
.../tserver/src/test/resources/log4j.properties | 19 +-
.../test/replication/MockReplicaSystem.java | 94 +
.../ReplicationTablesPrinterThread.java | 51 +
.../test/replication/CyclicReplicationIT.java | 241 ++
.../replication/MultiTserverReplicationIT.java | 114 +
.../test/replication/ReplicationIT.java | 661 +++++
.../test/replication/ReplicationTest.java | 1467 +++++++++++
.../test/replication/StatusCombinerMacTest.java | 84 +
.../UnorderedWorkAssignerReplicationIT.java | 657 +++++
test/src/test/resources/log4j.properties | 17 +-
138 files changed, 25566 insertions(+), 431 deletions(-)
----------------------------------------------------------------------