This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/bookkeeper.git.
from d237b53 ISSUE #1147: Move bookkeeper-server/{bin,conf} to root module
add 5555e0b State Store: Define the k/v interface
add 8315883 Fix checkstyle and findbugs errors
add 0cd6116 State Store: Add MVCC Store Interface
add 3171228 Async and Sync MVCC Store
add e666fc3 Make all interfaces
add f16b556 Add javadoc and annotation, fix checkstyle
add 97656e7 Reorganize builder and op
add 72b8735 Implement op and result
add c2a5d41 Add internal structure for mvcc record
add 18e918e Implement Record Factory
add 5e36a28 address compilation issue with @FreeBuilder
add 481b57e Implement Range and Put Operation
add a914eed Implement put and range operation in mvcc store
add 96e52de Make localStateStoreDir, stream and ioExecutor optional
add cef37ed Add protobuf definition for put/delete/txn request
add a25d9f3 Implement MVCC Async Store using local rocksdb and
distributedlog stream
add 5170c52 Implement delete op in local mvcc store
add e7292cd Implement txn operation in local mvcc store
add f0c251b Make keys optional for range operations and make range
operations correctly handle head and tail ranges
add 4424ba7 Return the right revision for results
add cc9a7a9 Implement cas shortcuts in mvcc store
add 02da55b Introduce StateStores and MVCCStores as factory for supplying
stores
add 578de75 Move the module from `distributedlog-io/statestore` to root
module
add 37e2f20 Fix compilation issue after moved statestore out of
distributedlog repo
add cf4e8e0 Incremental checkpoint on rocksdb
add f9bba3c Split the statestore module into api and impl
add e299642 Move api classes to api module
add a9b94ef Add LICENSE file
add 40ef780 Enable travis ci
add 04afde6 Remove duplicated matrix section
add c4a73d9 Enable apache-rat:check
add 6be3e96 Exclude travis log for apache-rat:check
add 45d49ca Move the simple kv statestore api/impl to `kv` package
add 7d4345f - Move the journaling logic to an abstract implementation of
AsyncStateStore - Provide async interfaces on simple kv store
add be560d6 implement the rocksdb based async kv store
add aaada2e Rename `CheckpointManager` to `CheckpointStore` (#1)
add 4ff9036 Use default column family for storing data and introduce a
`.meta` column family
add 362e912 Redirect tests output from console to files
add be193ca Add test cases for rocksdb incremental checkpointing
add 793cc3a Enable checkpointing in AsyncStateStoreWithJournal
add 777a89c Stream Store: Protocol module
add 6befd49 Stream Store: Define the table API in stream store.
add 32ad513 Stream Store: Client
add e62bd80 Stream Store : storage api & impl
add 3cc78ba [md_proxy2 6/14] Pluggable interface to resolve bookie
address from name (#40)
add 9a29dd6 Move `bookkeeper-common` as `common` module
add 30d889d Remove the simple name resolver factory.
add c2c2ca3 Finished the import of streamstore module and make it
compilable.
add 4cf41eb Move kv api from `stream.api.view.kv` to `api.kv`
add 0f547bd Relocate the protocol package
add 56ed506 Relocate storage package
add 9d621ff Refactor, cleanup and enable bookkeeper checkstyle
add 5ca0f0e Move client implementation from `streamstore/client` to
clients/java
add 81c2bca Refactor client package from `stream.client` to `clients`
add 87ea6ab Add clients-parent module
add db293f3 refactor `rangeservice` to `storage`
add 0593846 Rename RangeServer as StorageServer
add 0390849 Storage module should depends on the new client module
add 70d7153 Fix NPE on LocalClientImpl
add f493c27 Rename "Collection" to "Namespace" (#2)
add 73bdbea Fix status codes which still reference collection (#3)
add 1e72c59 Fix the namespace processor filenames (#4)
add 0981dbc Introduce a store factory to manage and create mvcc stores
(#5)
add 0235223 Use local state store to store root range (#6)
add e95abb9 Cherry-pick the stream storage server module (#7)
add 32f963d Cherry-pick integration tests from stream storage (#8)
add f4d35c4 store stream/range metadata in a mvcc local store (#9)
add 8e53bde Expose table service to grpc endpoint (#10)
add d75ee30 Implement table storage using the local mvcc store (#11)
add 70bb9d7 Implement table storage using the local mvcc store (#12)
add b18cdd5 Fix compilation issue: remove duplicated method (#13)
add 9f901bc Add an integrate test case on testing end-to-end kv store
(#14)
add ef6f871 Improve the client api to a type-safe api (#15)
add 7464dcc Enable txn on both server side and client side (#16)
add caa97bd Add some simplified kv methods in PTable (#17)
add 74185c3 Add Table api and its implementation (#18)
add 716684a Table -> Stream (part 1): add table writer for appending
events to stream
add 16fb26b Table -> Stream (part 2): Introduce `defaultBackendUri` in
stream configuration
add 81c8ed3 Table -> Stream (part 3): Implement dlog based table writer
add 3d9b08d Table -> Stream (part 4): storage server supports serving
readonly table
add 1e1aa52 Support Increment (part 1): provide increment op support in
local state store.
add 9935bb0 Support Increment (part 2): provide increment op support in
storage container, server and client
add eba3142 Support Increment (part 3): fix integration test
add cab8fd3 Provide a standalone cluster and a storage cli to interact
with it (#19)
add 80530b3 Use github repo as a temp location for deploying artifacts
(#20)
add 5d749d7 repackage under `org.apache.bookkeeper`
add e4a0798 Format the indent to 4 spaces (to align with bookkeeper
coding style)
add e62445f Remove OrderedBy annotation (#21)
add d923c89 Cleanup unused protobuf definitions (#22)
add 7ebf12b Remove `type` from StorageContainerRequest (#36)
add c754c8d Use the kv api defined in client for statelib (#37)
add e92bcec Consolidate the protobuf definition used in state store and
in client/service (#38)
add fce92af Fix compilation warnings (#39)
add 6e5210c Cleanup - remove writer api from table
add 1807b16 Cleanup - remove `ByteBufUtils`
add 2f0f6d1 Cleanup - remove unneeded test cases (#40)
add 32bd02a Introduce IncrementOption to support `incrementAndGet` (#41)
add e3608d2 Bump bk/dl version to 4.7.0-SNAPSHOT (#42)
add 5254818 Update readme (#43)
add b6558ff Fix type in README
add 34e6c7c Fix LifecycleComponentStarter
add 754f257 Prepare merging table service
add 501d0c0 Merge branch 'master' of ../stream_storage_merge into
merge_table_service
new 162df68 Merge remote-tracking branch 'apache/merge_table_service'
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
stream/.gitignore | 32 +
stream/.travis.yml | 39 +
LICENSE => stream/LICENSE | 0
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, 45856 insertions(+)
create mode 100644 stream/.gitignore
create mode 100644 stream/.travis.yml
copy LICENSE => stream/LICENSE (100%)
create mode 100644 stream/README.md
create mode 100644 stream/api/pom.xml
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/StorageClient.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/exceptions/ApiException.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/exceptions/package-info.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/PTable.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/PTableBase.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/PTableReadView.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/PTableWriteView.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/Table.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/TableReadView.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/TableWriteView.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/Txn.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/exceptions/KvApiException.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/exceptions/package-info.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/CompareOpImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/DeleteOpImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/IncrementOpImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/OpFactoryImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/PutOpImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/RangeOpImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/TxnOpBuilderImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/TxnOpImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/op/package-info.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/DeleteOptionBuilderImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/DeleteOptionImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/IncrementOptionBuilderImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/IncrementOptionImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/OptionFactoryImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/PutOptionBuilderImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/PutOptionImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/RangeOptionBuilderImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/RangeOptionImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/options/package-info.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/package-info.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/DeleteResultImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/IncrementResultImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/KeyValueFactory.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/KeyValueImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/PutResultImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/RangeResultImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/ResultFactory.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/ResultImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/TxnResultImpl.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/impl/result/package-info.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/CompareOp.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/CompareResult.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/CompareTarget.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/DeleteOp.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/IncrementOp.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/Op.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/OpFactory.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/OpType.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/PutOp.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/RangeOp.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/TxnOp.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/TxnOpBuilder.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/op/package-info.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/Builder.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/DeleteOption.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/DeleteOptionBuilder.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/IncrementOption.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/IncrementOptionBuilder.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/Option.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/OptionFactory.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/Options.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/PutOption.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/PutOptionBuilder.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/RangeOption.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/RangeOptionBuilder.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/options/package-info.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/package-info.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/Code.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/DeleteResult.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/IncrementResult.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/KeyValue.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/PutResult.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/RangeResult.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/Result.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/TxnResult.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/kv/result/package-info.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/package-info.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/stream/Position.java
create mode 100644
stream/api/src/main/java/org/apache/bookkeeper/api/stream/package-info.java
create mode 100755 stream/bin/streamstorage
create mode 100755 stream/bin/streamstorage-cli
create mode 100644 stream/cli/pom.xml
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/StreamStorageCli.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/AdminCommand.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/ClientCommand.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/CmdBase.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/CmdNamespace.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/CmdStream.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/CmdTable.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/SubCommand.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/namespace/CreateNamespaceCommand.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/namespace/package-info.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/package-info.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/stream/CreateStreamCommand.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/stream/package-info.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/GetCommand.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/IncrementCommand.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/PutCommand.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/commands/table/package-info.java
create mode 100644
stream/cli/src/main/java/org/apache/bookkeeper/stream/cli/package-info.java
create mode 100644 stream/clients/java/all/pom.xml
create mode 100644
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/StorageClientBuilder.java
create mode 100644
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/StorageClientImpl.java
create mode 100644
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/admin/StorageAdminClient.java
create mode 100644
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/admin/StorageAdminClientImpl.java
create mode 100644
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/admin/package-info.java
create mode 100644
stream/clients/java/all/src/main/java/org/apache/bookkeeper/clients/package-info.java
create mode 100644
stream/clients/java/all/src/test/java/org/apache/bookkeeper/clients/TestStorageClientBuilder.java
create mode 100644
stream/clients/java/all/src/test/java/org/apache/bookkeeper/clients/admin/TestStorageAdminClientImpl.java
create mode 100644 stream/clients/java/all/src/test/resources/log4j.properties
create mode 100644 stream/clients/java/base/pom.xml
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/config/StorageClientSettings.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/config/package-info.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/ClientException.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/InternalServerException.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/InvalidNamespaceNameException.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/InvalidStreamNameException.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/NamespaceExistsException.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/NamespaceNotFoundException.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/StorageContainerException.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/StreamExistsException.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/StreamNotFoundException.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/exceptions/package-info.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/channel/StorageServerChannel.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/channel/StorageServerChannelManager.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/channel/package-info.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/StorageContainerChannel.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/StorageContainerChannelFactory.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/StorageContainerChannelManager.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/StorageContainerInfo.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/StorageContainerManager.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/container/package-info.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/LocationClientImpl.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/MetaRangeClientImpl.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/ProtocolInternalUtils.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/RootRangeClientImpl.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/StorageServerClientManagerImpl.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/StreamMetadataCache.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/HashStreamRanges.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/LocationClient.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/MetaRangeClient.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/RootRangeClient.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/StorageServerClientManager.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/StreamRanges.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/api/package-info.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/mr/MetaRangeRequestProcessor.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/mr/package-info.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/internal/package-info.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/routing/RangeRouter.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/impl/routing/package-info.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/resolver/SimpleStreamResolverFactory.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/resolver/package-info.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/ClientConstants.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/ClientResources.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/GrpcUtils.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/ListenableFutureRpcProcessor.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/NetUtils.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/RpcUtils.java
create mode 100644
stream/clients/java/base/src/main/java/org/apache/bookkeeper/clients/utils/package-info.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/config/TestStorageClientSettings.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/grpc/GrpcClientTestBase.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/channel/TestStorageServerChannel.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/channel/TestStorageServerChannelManager.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/container/TestStorageContainerChannel.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/container/TestStorageContainerChannelManager.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/container/TestStorageContainerInfo.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/container/TestStorageContainerManager.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/RootRangeClientImplTestBase.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestLocationClientImpl.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestMetaRangeClientImpl.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestProtocolInternalUtils.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestRootRangeClientCreateNamespaceRpc.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestRootRangeClientCreateStreamRpc.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestRootRangeClientDeleteNamespaceRpc.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestRootRangeClientDeleteStreamRpc.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestRootRangeClientGetNamespaceRpc.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestRootRangeClientGetStreamByIdRpc.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestRootRangeClientGetStreamRpc.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestStorageServerClientManagerImpl.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/TestStreamMetadataCache.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/api/TestHashStreamRanges.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/impl/internal/api/TestStreamRanges.java
create mode 100644
stream/clients/java/base/src/test/java/org/apache/bookkeeper/clients/utils/TestNetUtils.java
create mode 100644 stream/clients/java/kv/pom.xml
create mode 100644
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/ByteBufTableImpl.java
create mode 100644
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/KvUtils.java
create mode 100644
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/PByteBufTableImpl.java
create mode 100644
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/PByteBufTableRangeImpl.java
create mode 100644
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/TableRangeFactory.java
create mode 100644
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/TableRequestProcessor.java
create mode 100644
stream/clients/java/kv/src/main/java/org/apache/bookkeeper/clients/impl/kv/package-info.java
create mode 100644
stream/clients/java/kv/src/test/java/org/apache/bookkeeper/clients/impl/kv/ByteBufTableImplTest.java
create mode 100644
stream/clients/java/kv/src/test/java/org/apache/bookkeeper/clients/impl/kv/TableRequestProcessorTest.java
create mode 100644
stream/clients/java/kv/src/test/java/org/apache/bookkeeper/clients/impl/kv/TestKvUtils.java
create mode 100644
stream/clients/java/kv/src/test/java/org/apache/bookkeeper/clients/impl/kv/TestPByteBufTableImpl.java
create mode 100644 stream/clients/java/kv/src/test/resources/log4j.properties
create mode 100644 stream/clients/java/pom.xml
create mode 100644 stream/clients/pom.xml
create mode 100644 stream/common/pom.xml
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/coder/ByteArrayCoder.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/coder/Coder.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/coder/StringUtf8Coder.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/coder/package-info.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/exceptions/ObjectClosedException.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/exceptions/package-info.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/hash/MurmurHash.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/hash/package-info.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/kv/KV.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/kv/KVImpl.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/kv/package-info.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/resolver/AbstractNameResolver.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/resolver/AbstractNameResolverFactory.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/resolver/SimpleNameResolver.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/resolver/package-info.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/router/AbstractHashRouter.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/router/ByteBufHashRouter.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/router/HashRouter.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/router/IntHashRouter.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/router/Router.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/router/StringUtf8HashRouter.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/router/package-info.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/AbstractAutoAsyncCloseable.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/AsyncCloseable.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/AutoAsyncCloseable.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/Bytes.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/CompletableRunnable.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/ExceptionUtils.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/ExceptionalFunction.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/IRevisioned.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/ListenableFutures.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/Recycled.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/Revisioned.java
create mode 100644
stream/common/src/main/java/org/apache/bookkeeper/common/util/package-info.java
create mode 100644
stream/common/src/test/java/org/apache/bookkeeper/common/reslover/TestSimpleNameResolver.java
create mode 100644
stream/common/src/test/java/org/apache/bookkeeper/common/util/TestBytes.java
create mode 100644
stream/common/src/test/java/org/apache/bookkeeper/common/util/TestExceptionUtils.java
create mode 100644 stream/conf/log4j.cli.properties
create mode 100644 stream/conf/log4j.properties
create mode 100755 stream/conf/standalone.conf
create mode 100644 stream/conf/streamstorage_cli_env.sh
create mode 100644 stream/conf/streamstorage_env.sh
create mode 100644 stream/pom.xml
create mode 100644 stream/proto/pom.xml
create mode 100644
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/ProtocolConstants.java
create mode 100644
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/RangeId.java
create mode 100644
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/package-info.java
create mode 100644
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/util/ProtoUtils.java
create mode 100644
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/util/StorageContainerPlacementPolicy.java
create mode 100644
stream/proto/src/main/java/org/apache/bookkeeper/stream/protocol/util/package-info.java
create mode 100644 stream/proto/src/main/proto/common.proto
create mode 100644 stream/proto/src/main/proto/kv.proto
create mode 100644 stream/proto/src/main/proto/kv_rpc.proto
create mode 100644 stream/proto/src/main/proto/kv_store.proto
create mode 100644 stream/proto/src/main/proto/proto2_coder_test_messages.proto
create mode 100644 stream/proto/src/main/proto/storage.proto
create mode 100644 stream/proto/src/main/proto/stream.proto
create mode 100644
stream/proto/src/test/java/org/apache/bookkeeper/stream/protocol/TestStreamRange.java
create mode 100644
stream/proto/src/test/java/org/apache/bookkeeper/stream/protocol/util/TestProtoUtils.java
create mode 100644 stream/proto/src/test/resources/log4j.properties
create mode 100644 stream/server/conf/rangeserver.conf.template
create mode 100644 stream/server/pom.xml
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/cluster/StandaloneStarter.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/cluster/StreamCluster.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/cluster/StreamClusterSpec.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/cluster/package-info.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/ExitCode.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/StorageServer.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/conf/BookieConfiguration.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/conf/DLConfiguration.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/conf/StorageServerConfiguration.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/conf/package-info.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/exceptions/StorageServerRuntimeException.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/exceptions/package-info.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/grpc/GrpcMetaRangeService.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/grpc/GrpcRootRangeService.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/grpc/GrpcServer.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/grpc/GrpcServerSpec.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/grpc/GrpcStorageContainerService.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/grpc/GrpcTableService.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/grpc/package-info.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/handler/ResponseHandler.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/handler/StorageContainerResponseHandler.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/handler/package-info.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/package-info.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/BookieService.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/DLNamespaceProviderService.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/GrpcService.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/StatsProviderService.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/StorageService.java
create mode 100644
stream/server/src/main/java/org/apache/bookkeeper/stream/server/service/package-info.java
create mode 100644
stream/server/src/test/java/org/apache/bookkeeper/stream/server/TestResponseObserver.java
create mode 100644
stream/server/src/test/java/org/apache/bookkeeper/stream/server/TestStorageServerMain.java
create mode 100644
stream/server/src/test/java/org/apache/bookkeeper/stream/server/grpc/TestGrpcMetaRangeService.java
create mode 100644
stream/server/src/test/java/org/apache/bookkeeper/stream/server/grpc/TestGrpcRootRangeService.java
create mode 100644
stream/server/src/test/java/org/apache/bookkeeper/stream/server/grpc/TestGrpcServer.java
create mode 100644
stream/server/src/test/java/org/apache/bookkeeper/stream/server/grpc/TestGrpcTableService.java
create mode 100644
stream/server/src/test/java/org/apache/bookkeeper/stream/server/handler/TestStorageContainerResponseHandler.java
create mode 100644 stream/server/src/test/resources/log4j.properties
create mode 100644 stream/src/main/resources/distributedlog/findbugsExclude.xml
create mode 100644 stream/statelib/pom.xml
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/StateStores.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/AsyncStateStore.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/StateStore.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/StateStoreBuilder.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/StateStoreSpec.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/checkpoint/CheckpointStore.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/checkpoint/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/InvalidStateStoreException.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/MVCCStoreException.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/StateStoreClosedException.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/StateStoreException.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/StateStoreRuntimeException.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/exceptions/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVAsyncReadOnlyStore.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVAsyncStore.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVAsyncStoreReadView.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVAsyncStoreWriteView.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVIterator.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVMulti.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVStore.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVStoreReadView.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/KVStoreWriteView.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/kv/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCAsyncStore.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCAsyncStoreReadView.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCAsyncStoreWriteView.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCStore.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCStoreReadView.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/MVCCStoreWriteView.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/mvcc/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/api/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/Bytes.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/Constants.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/journal/AbstractStateStoreWithJournal.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/journal/CommandProcessor.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/journal/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/KVCommandProcessor.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/KVUtils.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/RocksdbKVAsyncStore.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/RocksdbKVStore.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/kv/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCAsyncBytesStoreImpl.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCCommandProcessor.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCRecord.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCRecordCoder.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCStoreImpl.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCStores.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/MVCCUtils.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/ProtoDeleteOpImpl.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/ProtoIncrementOpImpl.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/ProtoPutOpImpl.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/ProtoRangeOpImpl.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/op/proto/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/mvcc/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/RocksConstants.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/RocksUtils.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/RocksCheckpointer.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/RocksdbCheckpointTask.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/RocksdbRestoreTask.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/fs/FSCheckpointManager.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/fs/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/impl/rocksdb/package-info.java
create mode 100644
stream/statelib/src/main/java/org/apache/bookkeeper/statelib/package-info.java
create mode 100644 stream/statelib/src/main/proto/kv.proto
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/impl/kv/TestKVUtils.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/impl/kv/TestRocksdbKVAsyncStore.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/impl/kv/TestRocksdbKVAsyncStoreWithCheckpoints.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/impl/kv/TestRocksdbKVStore.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/impl/mvcc/TestMVCCAsyncBytesStoreImpl.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/impl/mvcc/TestMVCCStoreImpl.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/impl/mvcc/TestMVCCUtils.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/impl/rocksdb/RocksUtilsTest.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/RocksCheckpointerTest.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/impl/rocksdb/checkpoint/fs/FSCheckpointManagerTest.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/testing/executors/MockClock.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/testing/executors/MockClockTest.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/testing/executors/MockExecutorController.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/testing/executors/MockExecutorControllerTest.java
create mode 100644
stream/statelib/src/test/java/org/apache/bookkeeper/statelib/testing/executors/MockExecutorControllerWithSchedulerTest.java
create mode 100644 stream/statelib/src/test/resources/log4j.properties
create mode 100644 stream/storage/api/pom.xml
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/RangeStore.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/controller/StorageController.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/controller/package-info.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/kv/TableStore.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/kv/package-info.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/MetaRangeStore.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/RangeStoreService.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/RootRangeStore.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/package-info.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/stream/MetaRange.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/metadata/stream/package-info.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/package-info.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainer.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerFactory.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerManager.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerManagerFactory.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerRegistry.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/StorageContainerRoutingService.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/api/sc/package-info.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/conf/StorageConfiguration.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/conf/package-info.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/exceptions/DataRangeNotFoundException.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/exceptions/StorageContainerNotFoundException.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/exceptions/StorageException.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/exceptions/StorageRuntimeException.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/exceptions/package-info.java
create mode 100644
stream/storage/api/src/main/java/org/apache/bookkeeper/stream/storage/package-info.java
create mode 100644
stream/storage/api/src/test/java/org/apache/bookkeeper/stream/storage/conf/TestStorageConfiguration.java
create mode 100644 stream/storage/impl/pom.xml
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/RangeStoreBuilder.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/StorageResources.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/StorageResourcesSpec.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/AsyncOperationProcessor.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/RangeStoreImpl.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/kv/TableStoreCache.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/kv/TableStoreFactory.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/kv/TableStoreImpl.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/kv/TableStoreUtils.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/kv/package-info.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/CreateNamespaceProcessor.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/DeleteNamespaceProcessor.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/MetaRangeStoreFactory.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/MetaRangeStoreImpl.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/RootRangeStoreFactory.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/RootRangeStoreImpl.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/package-info.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/stream/MetaRangeImpl.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/metadata/stream/package-info.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/package-info.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/DefaultStorageContainerFactory.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/FailRequestStorageContainer.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/LocalStorageContainerManager.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/StorageContainerImpl.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/StorageContainerPlacementPolicyImpl.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/StorageContainerRegistryImpl.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/helix/HelixStorageContainerManager.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/helix/HelixStorageController.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/helix/WriteReadSMD.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/helix/WriteReadStateModelFactory.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/helix/package-info.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/sc/package-info.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/store/MVCCStoreFactory.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/store/MVCCStoreFactoryImpl.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/impl/store/package-info.java
create mode 100644
stream/storage/impl/src/main/java/org/apache/bookkeeper/stream/storage/package-info.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/TestRangeStoreBuilder.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/TestRangeStoreImpl.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/kv/TableStoreCacheTest.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/kv/TableStoreImplTest.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/kv/TableStoreUtilsTest.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/metadata/MetaRangeStoreImplTest.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/metadata/TestRootRangeStoreImpl.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/metadata/stream/TestMetaRangeImpl.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/sc/StorageContainerImplTest.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/sc/TestDefaultStorageContainerFactory.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/sc/TestStorageContainerPlacementPolicyImpl.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/sc/TestStorageContainerRegistryImpl.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/sc/helix/TestHelixStorageContainerManager.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/store/MVCCAsyncStoreTestBase.java
create mode 100644
stream/storage/impl/src/test/java/org/apache/bookkeeper/stream/storage/impl/store/MVCCStoreFactoryImplTest.java
create mode 100644 stream/storage/impl/src/test/resources/log4j.properties
create mode 100644 stream/storage/pom.xml
create mode 100644 stream/tests/integration/pom.xml
create mode 100644
stream/tests/integration/src/test/java/org/apache/bookkeeper/stream/tests/integration/LocationClientTest.java
create mode 100644
stream/tests/integration/src/test/java/org/apache/bookkeeper/stream/tests/integration/StorageAdminClientTest.java
create mode 100644
stream/tests/integration/src/test/java/org/apache/bookkeeper/stream/tests/integration/StorageClientTest.java
create mode 100644
stream/tests/integration/src/test/java/org/apache/bookkeeper/stream/tests/integration/StorageServerTestBase.java
create mode 100644
stream/tests/integration/src/test/java/org/apache/bookkeeper/stream/tests/integration/TableClientSimpleTest.java
create mode 100644
stream/tests/integration/src/test/java/org/apache/bookkeeper/stream/tests/integration/TableClientTest.java
create mode 100644 stream/tests/integration/src/test/resources/log4j.properties
create mode 100644 stream/tests/pom.xml
--
To stop receiving notification emails like this one, please contact
[email protected].
