This is an automated email from the ASF dual-hosted git repository. sijie pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
commit 162df68d53c8f0fce34b55edf9119d47cdd6fac4 Merge: d237b53 501d0c0 Author: Sijie Guo <[email protected]> AuthorDate: Tue Feb 27 15:22:48 2018 -0800 Merge remote-tracking branch 'apache/merge_table_service' stream/.gitignore | 32 + stream/.travis.yml | 39 + stream/LICENSE | 202 ++++ stream/README.md | 110 ++ stream/api/pom.xml | 53 + .../org/apache/bookkeeper/api/StorageClient.java | 40 + .../bookkeeper/api/exceptions/ApiException.java | 37 + .../bookkeeper/api/exceptions/package-info.java | 22 + .../java/org/apache/bookkeeper/api/kv/PTable.java | 26 + .../org/apache/bookkeeper/api/kv/PTableBase.java | 77 ++ .../apache/bookkeeper/api/kv/PTableReadView.java | 116 +++ .../apache/bookkeeper/api/kv/PTableWriteView.java | 274 +++++ .../java/org/apache/bookkeeper/api/kv/Table.java | 29 + .../apache/bookkeeper/api/kv/TableReadView.java | 99 ++ .../apache/bookkeeper/api/kv/TableWriteView.java | 262 +++++ .../java/org/apache/bookkeeper/api/kv/Txn.java | 95 ++ .../api/kv/exceptions/KvApiException.java | 46 + .../bookkeeper/api/kv/exceptions/package-info.java | 22 + .../bookkeeper/api/kv/impl/op/CompareOpImpl.java | 74 ++ .../bookkeeper/api/kv/impl/op/DeleteOpImpl.java | 69 ++ .../bookkeeper/api/kv/impl/op/IncrementOpImpl.java | 76 ++ .../bookkeeper/api/kv/impl/op/OpFactoryImpl.java | 175 ++++ .../bookkeeper/api/kv/impl/op/PutOpImpl.java | 78 ++ .../bookkeeper/api/kv/impl/op/RangeOpImpl.java | 69 ++ .../api/kv/impl/op/TxnOpBuilderImpl.java | 100 ++ .../bookkeeper/api/kv/impl/op/TxnOpImpl.java | 83 ++ .../bookkeeper/api/kv/impl/op/package-info.java | 22 + .../kv/impl/options/DeleteOptionBuilderImpl.java | 82 ++ .../api/kv/impl/options/DeleteOptionImpl.java | 62 ++ .../impl/options/IncrementOptionBuilderImpl.java | 68 ++ .../api/kv/impl/options/IncrementOptionImpl.java | 59 ++ .../api/kv/impl/options/OptionFactoryImpl.java | 112 +++ .../api/kv/impl/options/PutOptionBuilderImpl.java | 68 ++ .../api/kv/impl/options/PutOptionImpl.java | 54 + .../kv/impl/options/RangeOptionBuilderImpl.java | 94 ++ .../api/kv/impl/options/RangeOptionImpl.java | 80 ++ .../api/kv/impl/options/package-info.java | 22 + .../bookkeeper/api/kv/impl/package-info.java | 21 + .../api/kv/impl/result/DeleteResultImpl.java | 76 ++ .../api/kv/impl/result/IncrementResultImpl.java | 63 ++ .../api/kv/impl/result/KeyValueFactory.java | 43 + .../api/kv/impl/result/KeyValueImpl.java | 86 ++ .../api/kv/impl/result/PutResultImpl.java | 67 ++ .../api/kv/impl/result/RangeResultImpl.java | 80 ++ .../api/kv/impl/result/ResultFactory.java | 97 ++ .../bookkeeper/api/kv/impl/result/ResultImpl.java | 76 ++ .../api/kv/impl/result/TxnResultImpl.java | 65 ++ .../api/kv/impl/result/package-info.java | 22 + .../org/apache/bookkeeper/api/kv/op/CompareOp.java | 47 + .../apache/bookkeeper/api/kv/op/CompareResult.java | 35 + .../apache/bookkeeper/api/kv/op/CompareTarget.java | 31 + .../org/apache/bookkeeper/api/kv/op/DeleteOp.java | 35 + .../apache/bookkeeper/api/kv/op/IncrementOp.java | 41 + .../java/org/apache/bookkeeper/api/kv/op/Op.java | 36 + .../org/apache/bookkeeper/api/kv/op/OpFactory.java | 59 ++ .../org/apache/bookkeeper/api/kv/op/OpType.java | 39 + .../org/apache/bookkeeper/api/kv/op/PutOp.java | 41 + .../org/apache/bookkeeper/api/kv/op/RangeOp.java | 36 + .../org/apache/bookkeeper/api/kv/op/TxnOp.java | 33 + .../apache/bookkeeper/api/kv/op/TxnOpBuilder.java | 52 + .../apache/bookkeeper/api/kv/op/package-info.java | 21 + .../apache/bookkeeper/api/kv/options/Builder.java | 27 + .../bookkeeper/api/kv/options/DeleteOption.java | 26 + .../api/kv/options/DeleteOptionBuilder.java | 29 + .../bookkeeper/api/kv/options/IncrementOption.java | 33 + .../api/kv/options/IncrementOptionBuilder.java | 28 + .../apache/bookkeeper/api/kv/options/Option.java | 28 + .../bookkeeper/api/kv/options/OptionFactory.java | 33 + .../apache/bookkeeper/api/kv/options/Options.java | 232 +++++ .../bookkeeper/api/kv/options/PutOption.java | 24 + .../api/kv/options/PutOptionBuilder.java | 27 + .../bookkeeper/api/kv/options/RangeOption.java | 37 + .../api/kv/options/RangeOptionBuilder.java | 41 + .../bookkeeper/api/kv/options/package-info.java | 18 + .../org/apache/bookkeeper/api/kv/package-info.java | 21 + .../org/apache/bookkeeper/api/kv/result/Code.java | 43 + .../bookkeeper/api/kv/result/DeleteResult.java | 45 + .../bookkeeper/api/kv/result/IncrementResult.java | 46 + .../apache/bookkeeper/api/kv/result/KeyValue.java | 42 + .../apache/bookkeeper/api/kv/result/PutResult.java | 28 + .../bookkeeper/api/kv/result/RangeResult.java | 51 + .../apache/bookkeeper/api/kv/result/Result.java | 50 + .../apache/bookkeeper/api/kv/result/TxnResult.java | 31 + .../bookkeeper/api/kv/result/package-info.java | 18 + .../org/apache/bookkeeper/api/package-info.java | 23 + .../org/apache/bookkeeper/api/stream/Position.java | 29 + .../apache/bookkeeper/api/stream/package-info.java | 22 + stream/bin/streamstorage | 153 +++ stream/bin/streamstorage-cli | 111 +++ stream/cli/pom.xml | 47 + .../bookkeeper/stream/cli/StreamStorageCli.java | 192 ++++ .../stream/cli/commands/AdminCommand.java | 39 + .../stream/cli/commands/ClientCommand.java | 40 + .../bookkeeper/stream/cli/commands/CmdBase.java | 90 ++ .../stream/cli/commands/CmdNamespace.java | 33 + .../bookkeeper/stream/cli/commands/CmdStream.java | 33 + .../bookkeeper/stream/cli/commands/CmdTable.java | 37 + .../bookkeeper/stream/cli/commands/SubCommand.java | 39 + .../commands/namespace/CreateNamespaceCommand.java | 58 ++ .../cli/commands/namespace/package-info.java | 22 + .../stream/cli/commands/package-info.java | 22 + .../cli/commands/stream/CreateStreamCommand.java | 58 ++ .../stream/cli/commands/stream/package-info.java | 22 + .../stream/cli/commands/table/GetCommand.java | 82 ++ .../cli/commands/table/IncrementCommand.java | 64 ++ .../stream/cli/commands/table/PutCommand.java | 65 ++ .../stream/cli/commands/table/package-info.java | 21 + .../apache/bookkeeper/stream/cli/package-info.java | 22 + stream/clients/java/all/pom.xml | 38 + .../bookkeeper/clients/StorageClientBuilder.java | 107 ++ .../bookkeeper/clients/StorageClientImpl.java | 127 +++ .../clients/admin/StorageAdminClient.java | 47 + .../clients/admin/StorageAdminClientImpl.java | 133 +++ .../bookkeeper/clients/admin/package-info.java | 22 + .../apache/bookkeeper/clients/package-info.java | 21 + .../clients/TestStorageClientBuilder.java | 55 + .../clients/admin/TestStorageAdminClientImpl.java | 130 +++ .../java/all/src/test/resources/log4j.properties | 53 + stream/clients/java/base/pom.xml | 76 ++ .../clients/config/StorageClientSettings.java | 109 ++ .../bookkeeper/clients/config/package-info.java | 23 + .../clients/exceptions/ClientException.java | 39 + .../exceptions/InternalServerException.java | 40 + .../exceptions/InvalidNamespaceNameException.java | 31 + .../exceptions/InvalidStreamNameException.java | 31 + .../exceptions/NamespaceExistsException.java | 31 + .../exceptions/NamespaceNotFoundException.java | 31 + .../exceptions/StorageContainerException.java | 42 + .../clients/exceptions/StreamExistsException.java | 31 + .../exceptions/StreamNotFoundException.java | 31 + .../clients/exceptions/package-info.java | 22 + .../clients/impl/channel/StorageServerChannel.java | 125 +++ .../impl/channel/StorageServerChannelManager.java | 163 +++ .../clients/impl/channel/package-info.java | 21 + .../impl/container/StorageContainerChannel.java | 185 ++++ .../container/StorageContainerChannelFactory.java | 29 + .../container/StorageContainerChannelManager.java | 93 ++ .../impl/container/StorageContainerInfo.java | 61 ++ .../impl/container/StorageContainerManager.java | 71 ++ .../clients/impl/container/package-info.java | 22 + .../clients/impl/internal/LocationClientImpl.java | 142 +++ .../clients/impl/internal/MetaRangeClientImpl.java | 78 ++ .../impl/internal/ProtocolInternalUtils.java | 122 +++ .../clients/impl/internal/RootRangeClientImpl.java | 237 +++++ .../internal/StorageServerClientManagerImpl.java | 153 +++ .../clients/impl/internal/StreamMetadataCache.java | 59 ++ .../impl/internal/api/HashStreamRanges.java | 35 + .../clients/impl/internal/api/LocationClient.java | 42 + .../clients/impl/internal/api/MetaRangeClient.java | 45 + .../clients/impl/internal/api/RootRangeClient.java | 100 ++ .../internal/api/StorageServerClientManager.java | 78 ++ .../clients/impl/internal/api/StreamRanges.java | 62 ++ .../clients/impl/internal/api/package-info.java | 25 + .../internal/mr/MetaRangeRequestProcessor.java | 95 ++ .../clients/impl/internal/mr/package-info.java | 22 + .../clients/impl/internal/package-info.java | 22 + .../clients/impl/routing/RangeRouter.java | 117 +++ .../clients/impl/routing/package-info.java | 23 + .../resolver/SimpleStreamResolverFactory.java | 90 ++ .../bookkeeper/clients/resolver/package-info.java | 22 + .../bookkeeper/clients/utils/ClientConstants.java | 36 + .../bookkeeper/clients/utils/ClientResources.java | 135 +++ .../apache/bookkeeper/clients/utils/GrpcUtils.java | 67 ++ .../utils/ListenableFutureRpcProcessor.java | 162 +++ .../apache/bookkeeper/clients/utils/NetUtils.java | 122 +++ .../apache/bookkeeper/clients/utils/RpcUtils.java | 76 ++ .../bookkeeper/clients/utils/package-info.java | 22 + .../clients/config/TestStorageClientSettings.java | 61 ++ .../clients/grpc/GrpcClientTestBase.java | 128 +++ .../impl/channel/TestStorageServerChannel.java | 71 ++ .../channel/TestStorageServerChannelManager.java | 167 ++++ .../container/TestStorageContainerChannel.java | 445 +++++++++ .../TestStorageContainerChannelManager.java | 74 ++ .../impl/container/TestStorageContainerInfo.java | 51 + .../container/TestStorageContainerManager.java | 116 +++ .../impl/internal/RootRangeClientImplTestBase.java | 213 ++++ .../impl/internal/TestLocationClientImpl.java | 283 ++++++ .../impl/internal/TestMetaRangeClientImpl.java | 193 ++++ .../impl/internal/TestProtocolInternalUtils.java | 250 +++++ .../TestRootRangeClientCreateNamespaceRpc.java | 166 ++++ .../TestRootRangeClientCreateStreamRpc.java | 161 +++ .../TestRootRangeClientDeleteNamespaceRpc.java | 139 +++ .../TestRootRangeClientDeleteStreamRpc.java | 141 +++ .../TestRootRangeClientGetNamespaceRpc.java | 166 ++++ .../TestRootRangeClientGetStreamByIdRpc.java | 152 +++ .../internal/TestRootRangeClientGetStreamRpc.java | 155 +++ .../TestStorageServerClientManagerImpl.java | 122 +++ .../impl/internal/TestStreamMetadataCache.java | 70 ++ .../impl/internal/api/TestHashStreamRanges.java | 56 ++ .../impl/internal/api/TestStreamRanges.java | 124 +++ .../bookkeeper/clients/utils/TestNetUtils.java | 114 +++ stream/clients/java/kv/pom.xml | 45 + .../clients/impl/kv/ByteBufTableImpl.java | 82 ++ .../apache/bookkeeper/clients/impl/kv/KvUtils.java | 352 +++++++ .../clients/impl/kv/PByteBufTableImpl.java | 308 ++++++ .../clients/impl/kv/PByteBufTableRangeImpl.java | 266 +++++ .../clients/impl/kv/TableRangeFactory.java | 38 + .../clients/impl/kv/TableRequestProcessor.java | 89 ++ .../bookkeeper/clients/impl/kv/package-info.java | 18 + .../clients/impl/kv/ByteBufTableImplTest.java | 114 +++ .../clients/impl/kv/TableRequestProcessorTest.java | 215 ++++ .../bookkeeper/clients/impl/kv/TestKvUtils.java | 183 ++++ .../clients/impl/kv/TestPByteBufTableImpl.java | 247 +++++ .../java/kv/src/test/resources/log4j.properties | 51 + stream/clients/java/pom.xml | 35 + stream/clients/pom.xml | 33 + stream/common/pom.xml | 44 + .../bookkeeper/common/coder/ByteArrayCoder.java | 57 ++ .../org/apache/bookkeeper/common/coder/Coder.java | 86 ++ .../bookkeeper/common/coder/StringUtf8Coder.java | 69 ++ .../bookkeeper/common/coder/package-info.java | 25 + .../common/exceptions/ObjectClosedException.java | 31 + .../bookkeeper/common/exceptions/package-info.java | 21 + .../apache/bookkeeper/common/hash/MurmurHash.java | 158 +++ .../bookkeeper/common/hash/package-info.java | 21 + .../java/org/apache/bookkeeper/common/kv/KV.java | 38 + .../org/apache/bookkeeper/common/kv/KVImpl.java | 51 + .../apache/bookkeeper/common/kv/package-info.java | 23 + .../common/resolver/AbstractNameResolver.java | 126 +++ .../resolver/AbstractNameResolverFactory.java | 38 + .../common/resolver/SimpleNameResolver.java | 55 + .../bookkeeper/common/resolver/package-info.java | 22 + .../common/router/AbstractHashRouter.java | 47 + .../common/router/ByteBufHashRouter.java | 37 + .../bookkeeper/common/router/HashRouter.java | 24 + .../bookkeeper/common/router/IntHashRouter.java | 41 + .../apache/bookkeeper/common/router/Router.java | 38 + .../common/router/StringUtf8HashRouter.java | 48 + .../bookkeeper/common/router/package-info.java | 22 + .../common/util/AbstractAutoAsyncCloseable.java | 60 ++ .../bookkeeper/common/util/AsyncCloseable.java | 35 + .../bookkeeper/common/util/AutoAsyncCloseable.java | 42 + .../org/apache/bookkeeper/common/util/Bytes.java | 67 ++ .../common/util/CompletableRunnable.java | 33 + .../bookkeeper/common/util/ExceptionUtils.java | 76 ++ .../common/util/ExceptionalFunction.java | 91 ++ .../apache/bookkeeper/common/util/IRevisioned.java | 38 + .../bookkeeper/common/util/ListenableFutures.java | 97 ++ .../apache/bookkeeper/common/util/Recycled.java | 28 + .../apache/bookkeeper/common/util/Revisioned.java | 36 + .../bookkeeper/common/util/package-info.java | 23 + .../common/reslover/TestSimpleNameResolver.java | 72 ++ .../apache/bookkeeper/common/util/TestBytes.java | 51 + .../bookkeeper/common/util/TestExceptionUtils.java | 78 ++ stream/conf/log4j.cli.properties | 73 ++ stream/conf/log4j.properties | 73 ++ stream/conf/standalone.conf | 21 + stream/conf/streamstorage_cli_env.sh | 60 ++ stream/conf/streamstorage_env.sh | 60 ++ stream/pom.xml | 390 ++++++++ stream/proto/pom.xml | 114 +++ .../stream/protocol/ProtocolConstants.java | 110 ++ .../apache/bookkeeper/stream/protocol/RangeId.java | 59 ++ .../bookkeeper/stream/protocol/package-info.java | 22 + .../stream/protocol/util/ProtoUtils.java | 354 +++++++ .../util/StorageContainerPlacementPolicy.java | 38 + .../stream/protocol/util/package-info.java | 22 + stream/proto/src/main/proto/common.proto | 28 + stream/proto/src/main/proto/kv.proto | 60 ++ stream/proto/src/main/proto/kv_rpc.proto | 317 ++++++ stream/proto/src/main/proto/kv_store.proto | 70 ++ .../main/proto/proto2_coder_test_messages.proto | 53 + stream/proto/src/main/proto/storage.proto | 268 +++++ stream/proto/src/main/proto/stream.proto | 209 ++++ .../stream/protocol/TestStreamRange.java | 58 ++ .../stream/protocol/util/TestProtoUtils.java | 211 ++++ stream/proto/src/test/resources/log4j.properties | 53 + stream/server/conf/rangeserver.conf.template | 25 + stream/server/pom.xml | 114 +++ .../stream/cluster/StandaloneStarter.java | 69 ++ .../bookkeeper/stream/cluster/StreamCluster.java | 325 ++++++ .../stream/cluster/StreamClusterSpec.java | 100 ++ .../bookkeeper/stream/cluster/package-info.java | 18 + .../apache/bookkeeper/stream/server/ExitCode.java | 51 + .../bookkeeper/stream/server/StorageServer.java | 244 +++++ .../stream/server/conf/BookieConfiguration.java | 33 + .../stream/server/conf/DLConfiguration.java | 34 + .../server/conf/StorageServerConfiguration.java | 34 + .../stream/server/conf/package-info.java | 18 + .../exceptions/StorageServerRuntimeException.java | 37 + .../stream/server/exceptions/package-info.java | 18 + .../stream/server/grpc/GrpcMetaRangeService.java | 49 + .../stream/server/grpc/GrpcRootRangeService.java | 138 +++ .../bookkeeper/stream/server/grpc/GrpcServer.java | 109 ++ .../stream/server/grpc/GrpcServerSpec.java | 79 ++ .../server/grpc/GrpcStorageContainerService.java | 68 ++ .../stream/server/grpc/GrpcTableService.java | 73 ++ .../stream/server/grpc/package-info.java | 18 + .../stream/server/handler/ResponseHandler.java | 53 + .../handler/StorageContainerResponseHandler.java | 44 + .../stream/server/handler/package-info.java | 22 + .../bookkeeper/stream/server/package-info.java | 18 + .../stream/server/service/BookieService.java | 85 ++ .../server/service/DLNamespaceProviderService.java | 126 +++ .../stream/server/service/GrpcService.java | 53 + .../server/service/StatsProviderService.java | 57 ++ .../stream/server/service/StorageService.java | 64 ++ .../stream/server/service/package-info.java | 18 + .../stream/server/TestResponseObserver.java | 88 ++ .../stream/server/TestStorageServerMain.java | 41 + .../server/grpc/TestGrpcMetaRangeService.java | 137 +++ .../server/grpc/TestGrpcRootRangeService.java | 615 ++++++++++++ .../stream/server/grpc/TestGrpcServer.java | 69 ++ .../stream/server/grpc/TestGrpcTableService.java | 329 ++++++ .../TestStorageContainerResponseHandler.java | 115 +++ stream/server/src/test/resources/log4j.properties | 53 + .../resources/distributedlog/findbugsExclude.xml | 191 ++++ stream/statelib/pom.xml | 100 ++ .../apache/bookkeeper/statelib/StateStores.java | 75 ++ .../bookkeeper/statelib/api/AsyncStateStore.java | 66 ++ .../apache/bookkeeper/statelib/api/StateStore.java | 74 ++ .../bookkeeper/statelib/api/StateStoreBuilder.java | 33 + .../bookkeeper/statelib/api/StateStoreSpec.java | 54 + .../statelib/api/checkpoint/CheckpointStore.java | 53 + .../statelib/api/checkpoint/package-info.java | 23 + .../api/exceptions/InvalidStateStoreException.java | 39 + .../api/exceptions/MVCCStoreException.java | 50 + .../api/exceptions/StateStoreClosedException.java | 31 + .../api/exceptions/StateStoreException.java | 39 + .../api/exceptions/StateStoreRuntimeException.java | 39 + .../statelib/api/exceptions/package-info.java | 22 + .../statelib/api/kv/KVAsyncReadOnlyStore.java | 27 + .../bookkeeper/statelib/api/kv/KVAsyncStore.java | 28 + .../statelib/api/kv/KVAsyncStoreReadView.java | 30 + .../statelib/api/kv/KVAsyncStoreWriteView.java | 34 + .../bookkeeper/statelib/api/kv/KVIterator.java | 41 + .../apache/bookkeeper/statelib/api/kv/KVMulti.java | 59 ++ .../apache/bookkeeper/statelib/api/kv/KVStore.java | 31 + .../statelib/api/kv/KVStoreReadView.java | 51 + .../statelib/api/kv/KVStoreWriteView.java | 72 ++ .../bookkeeper/statelib/api/kv/package-info.java | 23 + .../statelib/api/mvcc/MVCCAsyncStore.java | 507 ++++++++++ .../statelib/api/mvcc/MVCCAsyncStoreReadView.java | 48 + .../statelib/api/mvcc/MVCCAsyncStoreWriteView.java | 77 ++ .../bookkeeper/statelib/api/mvcc/MVCCStore.java | 43 + .../statelib/api/mvcc/MVCCStoreReadView.java | 38 + .../statelib/api/mvcc/MVCCStoreWriteView.java | 47 + .../bookkeeper/statelib/api/mvcc/package-info.java | 22 + .../bookkeeper/statelib/api/package-info.java | 22 + .../org/apache/bookkeeper/statelib/impl/Bytes.java | 86 ++ .../apache/bookkeeper/statelib/impl/Constants.java | 43 + .../journal/AbstractStateStoreWithJournal.java | 518 ++++++++++ .../statelib/impl/journal/CommandProcessor.java | 37 + .../statelib/impl/journal/package-info.java | 23 + .../statelib/impl/kv/KVCommandProcessor.java | 97 ++ .../bookkeeper/statelib/impl/kv/KVUtils.java | 107 ++ .../statelib/impl/kv/RocksdbKVAsyncStore.java | 177 ++++ .../statelib/impl/kv/RocksdbKVStore.java | 688 +++++++++++++ .../bookkeeper/statelib/impl/kv/package-info.java | 23 + .../impl/mvcc/MVCCAsyncBytesStoreImpl.java | 152 +++ .../statelib/impl/mvcc/MVCCCommandProcessor.java | 139 +++ .../bookkeeper/statelib/impl/mvcc/MVCCRecord.java | 140 +++ .../statelib/impl/mvcc/MVCCRecordCoder.java | 129 +++ .../statelib/impl/mvcc/MVCCStoreImpl.java | 1046 ++++++++++++++++++++ .../bookkeeper/statelib/impl/mvcc/MVCCStores.java | 46 + .../bookkeeper/statelib/impl/mvcc/MVCCUtils.java | 271 +++++ .../impl/mvcc/op/proto/ProtoDeleteOpImpl.java | 112 +++ .../impl/mvcc/op/proto/ProtoIncrementOpImpl.java | 95 ++ .../impl/mvcc/op/proto/ProtoPutOpImpl.java | 107 ++ .../impl/mvcc/op/proto/ProtoRangeOpImpl.java | 143 +++ .../statelib/impl/mvcc/op/proto/package-info.java | 22 + .../statelib/impl/mvcc/package-info.java | 22 + .../bookkeeper/statelib/impl/package-info.java | 22 + .../statelib/impl/rocksdb/RocksConstants.java | 44 + .../statelib/impl/rocksdb/RocksUtils.java | 77 ++ .../impl/rocksdb/checkpoint/RocksCheckpointer.java | 168 ++++ .../rocksdb/checkpoint/RocksdbCheckpointTask.java | 236 +++++ .../rocksdb/checkpoint/RocksdbRestoreTask.java | 131 +++ .../rocksdb/checkpoint/fs/FSCheckpointManager.java | 110 ++ .../impl/rocksdb/checkpoint/fs/package-info.java | 21 + .../impl/rocksdb/checkpoint/package-info.java | 22 + .../statelib/impl/rocksdb/package-info.java | 22 + .../apache/bookkeeper/statelib/package-info.java | 22 + stream/statelib/src/main/proto/kv.proto | 60 ++ .../bookkeeper/statelib/impl/kv/TestKVUtils.java | 42 + .../statelib/impl/kv/TestRocksdbKVAsyncStore.java | 172 ++++ .../kv/TestRocksdbKVAsyncStoreWithCheckpoints.java | 285 ++++++ .../statelib/impl/kv/TestRocksdbKVStore.java | 376 +++++++ .../impl/mvcc/TestMVCCAsyncBytesStoreImpl.java | 426 ++++++++ .../statelib/impl/mvcc/TestMVCCStoreImpl.java | 475 +++++++++ .../statelib/impl/mvcc/TestMVCCUtils.java | 41 + .../statelib/impl/rocksdb/RocksUtilsTest.java | 133 +++ .../rocksdb/checkpoint/RocksCheckpointerTest.java | 416 ++++++++ .../checkpoint/fs/FSCheckpointManagerTest.java | 135 +++ .../statelib/testing/executors/MockClock.java | 65 ++ .../statelib/testing/executors/MockClockTest.java | 46 + .../testing/executors/MockExecutorController.java | 230 +++++ .../executors/MockExecutorControllerTest.java | 104 ++ .../MockExecutorControllerWithSchedulerTest.java | 115 +++ .../statelib/src/test/resources/log4j.properties | 33 + stream/storage/api/pom.xml | 78 ++ .../bookkeeper/stream/storage/api/RangeStore.java | 42 + .../storage/api/controller/StorageController.java | 46 + .../storage/api/controller/package-info.java | 18 + .../stream/storage/api/kv/TableStore.java | 39 + .../stream/storage/api/kv/package-info.java | 22 + .../storage/api/metadata/MetaRangeStore.java | 38 + .../storage/api/metadata/RangeStoreService.java | 25 + .../storage/api/metadata/RootRangeStore.java | 104 ++ .../stream/storage/api/metadata/package-info.java | 22 + .../storage/api/metadata/stream/MetaRange.java | 92 ++ .../storage/api/metadata/stream/package-info.java | 22 + .../stream/storage/api/package-info.java | 17 + .../stream/storage/api/sc/StorageContainer.java | 58 ++ .../storage/api/sc/StorageContainerFactory.java | 31 + .../storage/api/sc/StorageContainerManager.java | 27 + .../api/sc/StorageContainerManagerFactory.java | 36 + .../storage/api/sc/StorageContainerRegistry.java | 58 ++ .../api/sc/StorageContainerRoutingService.java | 31 + .../stream/storage/api/sc/package-info.java | 22 + .../stream/storage/conf/StorageConfiguration.java | 68 ++ .../stream/storage/conf/package-info.java | 17 + .../exceptions/DataRangeNotFoundException.java | 31 + .../StorageContainerNotFoundException.java | 28 + .../storage/exceptions/StorageException.java | 31 + .../exceptions/StorageRuntimeException.java | 36 + .../stream/storage/exceptions/package-info.java | 17 + .../bookkeeper/stream/storage/package-info.java | 17 + .../storage/conf/TestStorageConfiguration.java | 43 + stream/storage/impl/pom.xml | 93 ++ .../stream/storage/RangeStoreBuilder.java | 144 +++ .../stream/storage/StorageResources.java | 123 +++ .../stream/storage/StorageResourcesSpec.java | 44 + .../storage/impl/AsyncOperationProcessor.java | 70 ++ .../stream/storage/impl/RangeStoreImpl.java | 208 ++++ .../stream/storage/impl/kv/TableStoreCache.java | 106 ++ .../stream/storage/impl/kv/TableStoreFactory.java | 36 + .../stream/storage/impl/kv/TableStoreImpl.java | 338 +++++++ .../stream/storage/impl/kv/TableStoreUtils.java | 292 ++++++ .../stream/storage/impl/kv/package-info.java | 22 + .../impl/metadata/CreateNamespaceProcessor.java | 56 ++ .../impl/metadata/DeleteNamespaceProcessor.java | 56 ++ .../impl/metadata/MetaRangeStoreFactory.java | 36 + .../storage/impl/metadata/MetaRangeStoreImpl.java | 145 +++ .../impl/metadata/RootRangeStoreFactory.java | 37 + .../storage/impl/metadata/RootRangeStoreImpl.java | 662 +++++++++++++ .../stream/storage/impl/metadata/package-info.java | 22 + .../impl/metadata/stream/MetaRangeImpl.java | 475 +++++++++ .../storage/impl/metadata/stream/package-info.java | 22 + .../stream/storage/impl/package-info.java | 22 + .../impl/sc/DefaultStorageContainerFactory.java | 58 ++ .../impl/sc/FailRequestStorageContainer.java | 164 +++ .../impl/sc/LocalStorageContainerManager.java | 77 ++ .../storage/impl/sc/StorageContainerImpl.java | 348 +++++++ .../sc/StorageContainerPlacementPolicyImpl.java | 45 + .../impl/sc/StorageContainerRegistryImpl.java | 139 +++ .../sc/helix/HelixStorageContainerManager.java | 119 +++ .../impl/sc/helix/HelixStorageController.java | 113 +++ .../stream/storage/impl/sc/helix/WriteReadSMD.java | 163 +++ .../impl/sc/helix/WriteReadStateModelFactory.java | 117 +++ .../stream/storage/impl/sc/helix/package-info.java | 18 + .../stream/storage/impl/sc/package-info.java | 22 + .../storage/impl/store/MVCCStoreFactory.java | 48 + .../storage/impl/store/MVCCStoreFactoryImpl.java | 259 +++++ .../stream/storage/impl/store/package-info.java | 22 + .../bookkeeper/stream/storage/package-info.java | 18 + .../stream/storage/TestRangeStoreBuilder.java | 109 ++ .../stream/storage/impl/TestRangeStoreImpl.java | 554 +++++++++++ .../storage/impl/kv/TableStoreCacheTest.java | 144 +++ .../stream/storage/impl/kv/TableStoreImplTest.java | 529 ++++++++++ .../storage/impl/kv/TableStoreUtilsTest.java | 169 ++++ .../impl/metadata/MetaRangeStoreImplTest.java | 243 +++++ .../impl/metadata/TestRootRangeStoreImpl.java | 480 +++++++++ .../impl/metadata/stream/TestMetaRangeImpl.java | 247 +++++ .../storage/impl/sc/StorageContainerImplTest.java | 486 +++++++++ .../sc/TestDefaultStorageContainerFactory.java | 64 ++ .../TestStorageContainerPlacementPolicyImpl.java | 37 + .../impl/sc/TestStorageContainerRegistryImpl.java | 167 ++++ .../sc/helix/TestHelixStorageContainerManager.java | 232 +++++ .../storage/impl/store/MVCCAsyncStoreTestBase.java | 125 +++ .../impl/store/MVCCStoreFactoryImplTest.java | 154 +++ .../impl/src/test/resources/log4j.properties | 53 + stream/storage/pom.xml | 34 + stream/tests/integration/pom.xml | 117 +++ .../tests/integration/LocationClientTest.java | 92 ++ .../tests/integration/StorageAdminClientTest.java | 208 ++++ .../tests/integration/StorageClientTest.java | 114 +++ .../tests/integration/StorageServerTestBase.java | 80 ++ .../tests/integration/TableClientSimpleTest.java | 268 +++++ .../stream/tests/integration/TableClientTest.java | 321 ++++++ .../src/test/resources/log4j.properties | 55 + stream/tests/pom.xml | 32 + 482 files changed, 46058 insertions(+) -- To stop receiving notification emails like this one, please contact [email protected].
