You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pegasus.apache.org by la...@apache.org on 2022/05/09 08:55:10 UTC
[incubator-pegasus] branch master updated (5278a669 -> fbed9a13)
This is an automated email from the ASF dual-hosted git repository.
laiyingchun pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
from 5278a669 refactor(admin-cli): move disk-balance code into `toolkits` package (#958)
new ba4dc3ce First commit
new c6bb6ffa add java client source code
new 46a3343d rpc: fix delay overflow, explictly close socket when close, fix test
new 15be3749 fix ut: MetricsPoolTest mistakenly relying on the output order of json obj
new cdba5e4a add reverse option in MultiGetOptions to support search in reverse direction for multiGet
new 7fbde179 fix logging
new 566b68a6 Bump version to 1.9.SNAPSHOT-thrift-0.11.0-inlined
new e8236e75 idl: add namespace for python
new 5924f496 add scan test; change default scan batch size (#4)
new 757d7899 support incr (#7)
new 78e879f5 Bump version to 1.10.SNAPSHOT-thrift-0.11.0-inlined
new d941b556 add checkAndSet and compareExchange interface (#8)
new e2cb6687 Bump version to 1.11.SNAPSHOT-thrift-0.11.0-inlined
new 987796ac rpc: use nio socket channel of netty (#9)
new bdf69da6 make fields of CheckAndSetResult/CompareExchangeResult public (#10)
new 1414e6c6 table: bugfix for hashkey filtering of unorderedScan (#12)
new 5822933a rpc: add message filter to support anandon message easily (#13)
new 7927b4bc add check_and_mutate() (#11)
new 171e98cb Bump version to 1.12.SNAPSHOT-thrift-0.11.0-inlined
new 9d0b96ce Mutations: constructor public (#14)
new bac5d3a9 Mutations: make all member methods public (#15)
new e06bd868 rpc: add some comments (#16)
new a4e45c9a interface: incr support reset ttl (#17)
new cf7893eb tools: fix Toollet static{} (#18)
new c8d0bb24 logging: validate table name and print log for problem diagnosis (#20)
new e28961d7 tools: add zstd compression support (#21)
new 5b9a69a7 add copy_data operator in PegasusCli (#23)
new 53e19084 set client_timeout in header (#24)
new 5c260cec support get forward address from configuration_query_by_index_response (#27)
new 920217a9 re-implement getting forward address from configuration_query_by_index_response (#28)
new 3f0f2e65 close session when it's not responding for a while (#32)
new 5890bf5a add travis ci support and checkstyle to enforce code style (#35)
new 1d81a8c1 format test codes and ensure travis fails on unformatted files (#36)
new ffa86ba5 ensure if response decode failed, client can be informed (#37)
new dcbbb5e1 format sources under base/ (#40)
new 6b1beeee fix vulnerability alert of checkstyle (#43)
new 6bfc6d3b Adapt to partition split (#44)
new 97559d97 bugfix: fix unit test failure on travis (#47)
new 76dcf055 fix travis; fix comments; fix zk client handle not close bug (#46)
new 4f8bd7de add createClient API with clientOptions (#49)
new eeabaa5a upgrade netty version to 4.0.56.Final (#50)
new e7a26c94 bugfix: catch and rethrow BlockingOperationException for batchSet (#51)
new c924e2c9 fix: handle case where Future.cause() is null in FutureGroup (#52)
new 63ad1a51 fix: set error to ERR_SESSION_RESET to trigger meta query while se… (#54)
new 8877531f docs: update PegasusClientFactory annotations (#57)
new 2f9cac11 refactor: add more exception info (#59)
new 57b9f46e feat: add delRange api (#48)
new 59a4a15b feat: support resolving meta host through DNS (#60)
new cce3f898 feat: establish the connection when session is initialized (#38)
new 592bcdef feat: add more exception info on synchronous APIs (#62)
new 0ec8cb35 feat: have package version prefixed in PException (#63)
new 40349416 build(deps): bump netty-all from 4.0.56.Final to 4.1.42.Final (#58)
new ce180c5e fix: fix block bug of InetAddressValidator.getInstance() (#64)
new 127eb4ed fix: fix bug where timeout in exception info is 0 (#65)
new d0787304 refactor: check the value of ttl #69
new 0619e2c7 fix: add info for ERR_SESSION_RESET when querying meta failed (#66)
new 7021c9b9 fix: use operation_timeout as socket connect timeout (#73)
new 29935c11 refactor: bound minimal value for socket connect timeout (#74)
new 612b0d39 fix: add check of invalid ttl value for checkAndSet interface (#75)
new ad297a5a refactor: update async_workers default value to cpu cores number (#76)
new 521ba739 build: add maven-shade for zkclient&guava (#72)
new 7666a607 fix: handle potential NullPointerException on RequestEntry.timeoutTask (#78)
new fac0ffa6 fix: close session when unable to connect (#81)
new 3b5c0d1a fix: prevent session to be actively closed when it gets response from server (#86)
new 50cb7a1a refactor: delete unused log in TableHandler (#87)
new d4a30a0f refactor(rpc): refactor request meta to adapt to new version of rpc protocol (#82)
new 28b67eef feat: implement backup request (#93)
new 6100bb63 build(deps): bump checkstyle from 8.18 to 8.29 (#99)
new 5d57146f build: add maven-shade for thrift (#71)
new 0d234962 feat: forbid large-size-value written to pegasus server (#95)
new 2d65cc6c feat: handle scan iteration exceed limit and refactor code (#96)
new 1f746aea fix: make SetItem Serializable (#101)
new 6a76f589 refactor: reduce parameters in construction of internal Table and Cluster (#104)
new 76620abd feat: add configuration for meta query timeout (#103)
new 197c7eed fix: use origin expireNanoTime to init new clientRequestRound (#105)
new 67d48d6c improvement: add detailed information when operation has exception (#106)
new 717eefe9 fix: startSortKey can't pass null (#108)
new 05051e10 build(deps): add dependency of javax.annotation-api (#109)
new 33a9a05f refactor: optimize perf-counter (#98)
new 2b244d9d fix: release streams resource while loading config (#113)
new bd90d94d fix: revert default asyncWorkers value (#114)
new d857d406 chore: change the dev branch to 2.1-SNAPSHOT (#116)
new 70047f3d docs: add example on table scan (#120)
new 2f5af933 refactor: delete duplicate config and use ClientOptions uniformly (#117)
new 8ecd6b32 refactor: restrict enableBackupRequest to read_operator (#128)
new 5d60bd14 refactor: using "interceptor" to implement backup-request (#125)
new ed7d4c7e feat: using "interceptor" to enhance the api(compress) (#126)
new 1b602ba3 feat(security): add negotiation class (#132)
new 4cf307c4 refactor: using abstract Batch class to refactor all batch api (#129)
new a79ea8c6 feat(security): implement start negotiation (#134)
new 3615cfd9 feat(security): add ReplicaSession interceptor (#135)
new 6081ceae test: add license check as a ci step (#140)
new 7eb3a566 chore: fix license missing in some files (#141)
new c027e85d chore: fix license for files in rpc/async and metrics/ (#142)
new 13d3b36c feat(security): implement AuthProtocol and Credential classes (#139)
new 6923623f feat(security): handle list mechanism response (#136)
new 5aa92a00 feat(security): handle mechanism selected response (#137)
new befbf8b1 feat(security): handle challenge from server (#138)
new d17b81ab refactor: remove unused PegasusCli (#144)
new d427496a refactor: remove unused methods in replica session (#143)
new 55f78931 feat(security): treat negotiation succeed if server is old version (#145)
new 0091762d fix: make sure return "maxFetchCount" record if valid record is enough when multiGetSortKeys (#148)
new f58574f3 docs: change the license to ASF (#147)
new 210f9f04 fix: validate the client config value (#153)
new fdcdc6f0 fix: return value of asyncNext should use netty future (#155)
new b8b01a0a fix: scanner.next() won't automatically recover when server side not return ERR_OK (#156)
new f7b18ba9 feat(security): refresh tgt in background (#158)
new 614c76d7 chore: update ci from travis to github-action (#163)
new 42228178 feat: support session reset time windows config and init default value to 30s (#161)
new 034c1147 feat: support create client with Proprities object (#166)
new b31c5062 feat: adapt partition split (#165)
new 497f1b16 fix: decompress will failed when the value is null (#167)
new b3d80c97 fix: incorrect expire time of client request (#164)
new e2cc8601 fix: gc task may encounter deadlock (#168)
new ed66cf98 feat: handle ERR_DISK_INSUFFICIENT (#170)
new 83f9ea76 fix: full scan may be failed when the server side encounter error (#171)
new 2fe35313 fix: auto close the io after decompress (#172)
new 8f858b64 build: require add issue reference in description using github action (#173)
new 5e297d44 fix: batchMultiGet may not fetch all required data (#177)
new fd2c32a4 feat: change download url of pegasus tools (#178)
new fe4bfa2a feat: add a batch get client interface which uses 'BATCH_GET' rpc for read optimization (#175)
new 9db2efc6 feat: add a app create interface to the java client (#180)
new 6660e9bf fix: fix a mismatch code (#181)
new bdce8464 fix: HashKeyData constructor compatible (#184)
new 88c5018e chore: prepare to merge into incubator-pegasus (#183)
new 7af817b0 Merge pegasus-java-client repo
new c1f15383 java client conform to apache style
new fbed9a13 Merge pull request #964 from cauchy1988/merge-java-client
The 895 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:
...{dockerfile_linter.yml => test_java-client.yml} | 43 +-
.gitignore | 15 +
README.md | 6 +-
java-client/README.md | 99 +
java-client/configuration/log4j.properties | 42 +
.../configuration/pegasus.properties | 17 +-
.../dev-support/checkstyle-suppressions.xml | 55 +
java-client/dev-support/findbugs-exclude.xml | 42 +
java-client/dev-support/google-checks.xml | 270 +
.../dev-support/license-header.txt | 7 +-
.../idl/apache-licence-template | 6 +-
.../test/main.cpp => java-client/idl/base.thrift | 26 +-
.../job.cpp => java-client/idl/meta_admin.thrift | 33 +-
java-client/idl/recompile_thrift.sh | 57 +
java-client/idl/replication.thrift | 59 +
{src => java-client}/idl/rrdb.thrift | 150 +-
java-client/idl/security.thrift | 79 +
java-client/pom.xml | 439 +
java-client/scripts/ci-test.sh | 65 +
java-client/src/assembly/dep.xml | 57 +
.../org/apache/pegasus/apps/batch_get_request.java | 469 +
.../apache/pegasus/apps/batch_get_response.java | 896 ++
.../org/apache/pegasus/apps/cas_check_type.java | 106 +
.../pegasus/apps/check_and_mutate_request.java | 1047 ++
.../pegasus/apps/check_and_mutate_response.java | 1174 ++
.../apache/pegasus/apps/check_and_set_request.java | 1331 ++
.../pegasus/apps/check_and_set_response.java | 1172 ++
.../org/apache/pegasus/apps/count_response.java | 830 ++
.../java/org/apache/pegasus/apps/filter_type.java | 64 +
.../java/org/apache/pegasus/apps/full_data.java | 644 +
.../java/org/apache/pegasus/apps/full_key.java | 531 +
.../apache/pegasus/apps/get_scanner_request.java | 1772 +++
.../java/org/apache/pegasus/apps/incr_request.java | 635 +
.../org/apache/pegasus/apps/incr_response.java | 938 ++
.../java/org/apache/pegasus/apps/key_value.java | 532 +
.../main/java/org/apache/pegasus/apps/meta.java | 2116 +++
.../org/apache/pegasus/apps/multi_get_request.java | 1690 +++
.../apache/pegasus/apps/multi_get_response.java | 895 ++
.../org/apache/pegasus/apps/multi_put_request.java | 696 +
.../apache/pegasus/apps/multi_remove_request.java | 691 +
.../apache/pegasus/apps/multi_remove_response.java | 937 ++
.../main/java/org/apache/pegasus/apps/mutate.java | 759 +
.../org/apache/pegasus/apps/mutate_operation.java | 55 +-
.../org/apache/pegasus/apps/mutate_result.java | 748 +
.../apache/pegasus/apps/negotiation_request.java | 533 +
.../apache/pegasus/apps/negotiation_response.java | 533 +
.../apache/pegasus/apps/negotiation_status.java | 85 +
.../org/apache/pegasus/apps/read_response.java | 843 ++
.../main/java/org/apache/pegasus/apps/rrdb.java | 14202 +++++++++++++++++++
.../java/org/apache/pegasus/apps/scan_request.java | 414 +
.../org/apache/pegasus/apps/scan_response.java | 999 ++
.../java/org/apache/pegasus/apps/security.java | 1133 ++
.../java/org/apache/pegasus/apps/ttl_response.java | 831 ++
.../org/apache/pegasus/apps/update_request.java | 646 +
.../org/apache/pegasus/apps/update_response.java | 831 ++
.../main/java/org/apache/pegasus/base/blob.java | 201 +
.../java/org/apache/pegasus/base/error_code.java | 300 +
.../main/java/org/apache/pegasus/base/gpid.java | 221 +
.../java/org/apache/pegasus/base/rpc_address.java | 249 +
.../java/org/apache/pegasus/base/task_code.java | 193 +
.../pegasus/client/CheckAndMutateOptions.java | 34 +-
.../apache/pegasus/client/CheckAndSetOptions.java | 27 +-
.../java/org/apache/pegasus/client/CheckType.java | 62 +
.../org/apache/pegasus/client/ClientOptions.java | 566 +
.../org/apache/pegasus/client/DelRangeOptions.java | 22 +-
.../java/org/apache/pegasus/client/FilterType.java | 23 +-
.../org/apache/pegasus/client/FutureGroup.java | 122 +
.../org/apache/pegasus/client/HashKeyData.java | 54 +
.../org/apache/pegasus/client/MultiGetOptions.java | 43 +
.../java/org/apache/pegasus/client/Mutations.java | 80 +
.../org/apache/pegasus/client/PConfigUtil.java | 146 +
.../java/org/apache/pegasus/client/PException.java | 76 +
.../pegasus/client/PegasusAbstractClient.java | 70 +
.../apache/pegasus/client/PegasusAdminClient.java | 197 +
.../pegasus/client/PegasusAdminClientFactory.java | 64 +
.../client/PegasusAdminClientInterface.java | 63 +
.../org/apache/pegasus/client/PegasusClient.java | 551 +
.../pegasus/client/PegasusClientFactory.java | 183 +
.../pegasus/client/PegasusClientInterface.java | 681 +
.../org/apache/pegasus/client/PegasusScanner.java | 363 +
.../pegasus/client/PegasusScannerInterface.java | 48 +
.../org/apache/pegasus/client/PegasusTable.java | 2151 +++
.../pegasus/client/PegasusTableInterface.java | 1241 ++
.../org/apache/pegasus/client/ScanOptions.java | 51 +
.../java/org/apache/pegasus/client/SetItem.java | 34 +-
.../org/apache/pegasus/client/TableOptions.java | 52 +
.../pegasus/client/request/AbstractBatch.java | 56 +
.../org/apache/pegasus/client/request/Batch.java | 74 +
.../pegasus/client/request/BatchWithResponse.java | 68 +
.../org/apache/pegasus/client/request/Delete.java | 31 +-
.../apache/pegasus/client/request/DeleteBatch.java | 26 +-
.../org/apache/pegasus/client/request/Get.java | 31 +-
.../apache/pegasus/client/request/GetBatch.java | 26 +-
.../apache/pegasus/client/request/MultiDelete.java | 52 +
.../pegasus/client/request/MultiDeleteBatch.java | 26 +-
.../apache/pegasus/client/request/MultiGet.java | 52 +
.../pegasus/client/request/MultiGetBatch.java | 27 +-
.../apache/pegasus/client/request/MultiSet.java | 62 +
.../pegasus/client/request/MultiSetBatch.java | 26 +-
.../org/apache/pegasus/client/request/Set.java | 32 +-
.../apache/pegasus/client/request/SetBatch.java | 26 +-
.../org/apache/pegasus/example/BatchSample.java | 99 +
.../org/apache/pegasus/example/FullScanSample.java | 66 +
.../org/apache/pegasus/metrics/MetricsManager.java | 83 +
.../org/apache/pegasus/metrics/MetricsPool.java | 142 +
.../apache/pegasus/metrics/MetricsReporter.java | 254 +
.../pegasus/operator/batch_get_operator.java | 70 +
.../apache/pegasus/operator/client_operator.java | 113 +
.../pegasus/operator/create_app_operator.java | 67 +
.../pegasus/operator/negotiation_operator.java | 64 +
.../pegasus/operator/query_cfg_operator.java | 65 +
.../org/apache/pegasus/operator/read_operator.java | 26 +-
.../operator/rrdb_check_and_mutate_operator.java | 69 +
.../operator/rrdb_check_and_set_operator.java | 69 +
.../operator/rrdb_clear_scanner_operator.java | 55 +
.../apache/pegasus/operator/rrdb_get_operator.java | 62 +
.../operator/rrdb_get_scanner_operator.java | 65 +
.../pegasus/operator/rrdb_incr_operator.java | 63 +
.../pegasus/operator/rrdb_multi_get_operator.java | 64 +
.../pegasus/operator/rrdb_multi_put_operator.java | 69 +
.../operator/rrdb_multi_remove_operator.java | 65 +
.../apache/pegasus/operator/rrdb_put_operator.java | 68 +
.../pegasus/operator/rrdb_remove_operator.java | 63 +
.../pegasus/operator/rrdb_scan_operator.java | 63 +
.../operator/rrdb_sortkey_count_operator.java | 65 +
.../apache/pegasus/operator/rrdb_ttl_operator.java | 62 +
.../configuration_create_app_request.java | 532 +
.../configuration_create_app_response.java | 533 +
.../pegasus/replication/create_app_options.java | 1014 ++
.../replication/partition_configuration.java | 1196 ++
.../pegasus/replication/query_cfg_request.java | 579 +
.../pegasus/replication/query_cfg_response.java | 906 ++
.../apache/pegasus/replication/request_meta.java | 840 ++
.../main/java/org/apache/pegasus/rpc/Cluster.java | 34 +-
.../apache/pegasus/rpc/InternalTableOptions.java | 31 +-
.../java/org/apache/pegasus/rpc/KeyHasher.java | 19 +-
.../src/main/java/org/apache/pegasus/rpc/Meta.java | 12 +-
.../apache/pegasus/rpc/ReplicationException.java | 47 +-
.../main/java/org/apache/pegasus/rpc/Table.java | 83 +
.../java/org/apache/pegasus/rpc/ThriftHeader.java | 36 +-
.../pegasus/rpc/async/ClientRequestRound.java | 110 +
.../apache/pegasus/rpc/async/ClusterManager.java | 222 +
.../apache/pegasus/rpc/async/HostNameResolver.java | 60 +
.../org/apache/pegasus/rpc/async/MetaHandler.java | 28 +-
.../org/apache/pegasus/rpc/async/MetaSession.java | 330 +
.../apache/pegasus/rpc/async/ReplicaSession.java | 493 +
.../pegasus/rpc/async/TByteBufTransport.java | 48 +-
.../org/apache/pegasus/rpc/async/TableHandler.java | 536 +
.../pegasus/rpc/async/ThriftFrameDecoder.java | 105 +
.../pegasus/rpc/async/ThriftFrameEncoder.java | 62 +
.../rpc/interceptor/BackupRequestInterceptor.java | 83 +
.../rpc/interceptor/CompressionInterceptor.java | 110 +
.../rpc/interceptor/ReplicaSessionInterceptor.java | 15 +-
.../ReplicaSessionInterceptorManager.java | 51 +
.../pegasus/rpc/interceptor/TableInterceptor.java | 20 +-
.../rpc/interceptor/TableInterceptorManager.java | 56 +
.../org/apache/pegasus/security/AuthProtocol.java | 20 +-
.../security/AuthReplicaSessionInterceptor.java | 42 +
.../org/apache/pegasus/security/Credential.java | 39 +-
.../pegasus/security/KerberosCredential.java | 156 +
.../apache/pegasus/security/KerberosProtocol.java | 181 +
.../org/apache/pegasus/security/Negotiation.java | 189 +
.../org/apache/pegasus/security/SaslWrapper.java | 78 +
.../org/apache/pegasus/tools/FlowController.java | 103 +
.../main/java/org/apache/pegasus/tools/Tools.java | 181 +
.../org/apache/pegasus/tools/WriteLimiter.java | 192 +
.../java/org/apache/pegasus/tools/ZstdWrapper.java | 101 +
.../org/apache/pegasus/base/TestRpcAddress.java | 59 +
.../org/apache/pegasus/client/TestAdminClient.java | 98 +
.../java/org/apache/pegasus/client/TestBasic.java | 2783 ++++
.../java/org/apache/pegasus/client/TestBatch.java | 192 +
.../pegasus/client/TestBatchGetByPartitions.java | 124 +
.../java/org/apache/pegasus/client/TestBench.java | 206 +
.../apache/pegasus/client/TestCheckAndMutate.java | 1857 +++
.../org/apache/pegasus/client/TestCheckAndSet.java | 1744 +++
.../org/apache/pegasus/client/TestFutureGroup.java | 104 +
.../java/org/apache/pegasus/client/TestIncr.java | 115 +
.../org/apache/pegasus/client/TestMultiThread.java | 185 +
.../org/apache/pegasus/client/TestNoOperate.java | 45 +-
.../org/apache/pegasus/client/TestPException.java | 138 +
.../java/org/apache/pegasus/client/TestPing.java | 128 +
.../java/org/apache/pegasus/client/TestPingZK.java | 86 +
.../java/org/apache/pegasus/client/TestScan.java | 560 +
.../org/apache/pegasus/client/TestTimeout.java | 66 +
.../apache/pegasus/metrics/MetricsPoolTest.java | 162 +
.../pegasus/operator/ClientOperatorTest.java | 52 +
.../pegasus/rpc/async/ClusterManagerTest.java | 93 +
.../apache/pegasus/rpc/async/InterceptorTest.java | 61 +
.../apache/pegasus/rpc/async/MetaSessionTest.java | 345 +
.../pegasus/rpc/async/ReplicaSessionTest.java | 315 +
.../apache/pegasus/rpc/async/TableHandlerTest.java | 215 +
.../apache/pegasus/rpc/async/TimeoutBenchmark.java | 100 +
.../apache/pegasus/security/NegotiationTest.java | 179 +
.../org/apache/pegasus/tools/TestZstdWrapper.java | 77 +
.../java/org/apache/pegasus/tools/Toollet.java | 183 +
.../src/test/resource/pegasus.properties | 11 +-
196 files changed, 73277 insertions(+), 558 deletions(-)
copy .github/workflows/{dockerfile_linter.yml => test_java-client.yml} (56%)
create mode 100644 java-client/README.md
create mode 100644 java-client/configuration/log4j.properties
copy .gitmodules => java-client/configuration/pegasus.properties (69%)
create mode 100644 java-client/dev-support/checkstyle-suppressions.xml
create mode 100644 java-client/dev-support/findbugs-exclude.xml
create mode 100644 java-client/dev-support/google-checks.xml
copy docker/pegasus-build-env/README.md => java-client/dev-support/license-header.txt (80%)
copy src/test/kill_test/killer_registry.h => java-client/idl/apache-licence-template (94%)
copy src/base/test/main.cpp => java-client/idl/base.thrift (80%)
copy src/test/kill_test/job.cpp => java-client/idl/meta_admin.thrift (57%)
create mode 100755 java-client/idl/recompile_thrift.sh
create mode 100644 java-client/idl/replication.thrift
copy {src => java-client}/idl/rrdb.thrift (68%)
create mode 100644 java-client/idl/security.thrift
create mode 100644 java-client/pom.xml
create mode 100755 java-client/scripts/ci-test.sh
create mode 100644 java-client/src/assembly/dep.xml
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/batch_get_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/batch_get_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/cas_check_type.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/check_and_mutate_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/check_and_mutate_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/check_and_set_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/check_and_set_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/count_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/filter_type.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/full_data.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/full_key.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/get_scanner_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/incr_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/incr_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/key_value.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/meta.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/multi_get_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/multi_get_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/multi_put_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/multi_remove_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/multi_remove_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/mutate.java
copy src/server/info_collector_app.h => java-client/src/main/java/org/apache/pegasus/apps/mutate_operation.java (50%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/mutate_result.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/negotiation_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/negotiation_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/negotiation_status.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/read_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/rrdb.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/scan_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/scan_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/security.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/ttl_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/update_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/apps/update_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/base/blob.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/base/error_code.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/base/gpid.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/base/rpc_address.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/base/task_code.java
copy admin-cli/executor/toolkits/log.go => java-client/src/main/java/org/apache/pegasus/client/CheckAndMutateOptions.java (68%)
copy admin-cli/cmd/list_nodes.go => java-client/src/main/java/org/apache/pegasus/client/CheckAndSetOptions.java (62%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/CheckType.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/ClientOptions.java
copy admin-cli/client/options.go => java-client/src/main/java/org/apache/pegasus/client/DelRangeOptions.java (53%)
copy admin-cli/client/options.go => java-client/src/main/java/org/apache/pegasus/client/FilterType.java (64%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/FutureGroup.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/HashKeyData.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/MultiGetOptions.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/Mutations.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PConfigUtil.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PException.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PegasusAbstractClient.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PegasusAdminClient.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PegasusAdminClientFactory.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PegasusAdminClientInterface.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PegasusClient.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PegasusClientFactory.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PegasusScanner.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PegasusScannerInterface.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/ScanOptions.java
copy admin-cli/cmd/init.go => java-client/src/main/java/org/apache/pegasus/client/SetItem.java (55%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/TableOptions.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/request/AbstractBatch.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/request/Batch.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/request/BatchWithResponse.java
copy admin-cli/executor/toolkits/log.go => java-client/src/main/java/org/apache/pegasus/client/request/Delete.java (69%)
copy admin-cli/cmd/init.go => java-client/src/main/java/org/apache/pegasus/client/request/DeleteBatch.java (62%)
copy admin-cli/executor/toolkits/log.go => java-client/src/main/java/org/apache/pegasus/client/request/Get.java (69%)
copy admin-cli/cmd/init.go => java-client/src/main/java/org/apache/pegasus/client/request/GetBatch.java (62%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/request/MultiDelete.java
copy admin-cli/cmd/init.go => java-client/src/main/java/org/apache/pegasus/client/request/MultiDeleteBatch.java (60%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/request/MultiGet.java
copy admin-cli/cmd/init.go => java-client/src/main/java/org/apache/pegasus/client/request/MultiGetBatch.java (57%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/client/request/MultiSet.java
copy admin-cli/cmd/init.go => java-client/src/main/java/org/apache/pegasus/client/request/MultiSetBatch.java (60%)
copy admin-cli/cmd/init.go => java-client/src/main/java/org/apache/pegasus/client/request/Set.java (55%)
copy admin-cli/cmd/init.go => java-client/src/main/java/org/apache/pegasus/client/request/SetBatch.java (62%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/example/BatchSample.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/example/FullScanSample.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/metrics/MetricsManager.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/metrics/MetricsPool.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/metrics/MetricsReporter.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/batch_get_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/client_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/create_app_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/negotiation_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/query_cfg_operator.java
copy admin-cli/cmd/table_stat.go => java-client/src/main/java/org/apache/pegasus/operator/read_operator.java (68%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_check_and_mutate_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_check_and_set_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_clear_scanner_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_get_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_get_scanner_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_incr_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_multi_get_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_multi_put_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_multi_remove_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_put_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_remove_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_scan_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_sortkey_count_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/operator/rrdb_ttl_operator.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/replication/configuration_create_app_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/replication/configuration_create_app_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/replication/create_app_options.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/replication/partition_configuration.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/replication/query_cfg_request.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/replication/query_cfg_response.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/replication/request_meta.java
copy admin-cli/executor/toolkits/log.go => java-client/src/main/java/org/apache/pegasus/rpc/Cluster.java (55%)
copy admin-cli/cmd/init.go => java-client/src/main/java/org/apache/pegasus/rpc/InternalTableOptions.java (57%)
copy src/test/upgrade_test/upgrader_registry.cpp => java-client/src/main/java/org/apache/pegasus/rpc/KeyHasher.java (71%)
copy src/geo/test/main.cpp => java-client/src/main/java/org/apache/pegasus/rpc/Meta.java (77%)
copy admin-cli/executor/toolkits/log.go => java-client/src/main/java/org/apache/pegasus/rpc/ReplicationException.java (51%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/Table.java
copy src/test/kill_test/partition_kill_testor.h => java-client/src/main/java/org/apache/pegasus/rpc/ThriftHeader.java (63%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/async/ClientRequestRound.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/async/ClusterManager.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/async/HostNameResolver.java
copy admin-cli/cmd/init.go => java-client/src/main/java/org/apache/pegasus/rpc/async/MetaHandler.java (61%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/async/MetaSession.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/async/ReplicaSession.java
copy src/shell/commands/misc.cpp => java-client/src/main/java/org/apache/pegasus/rpc/async/TByteBufTransport.java (50%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/async/TableHandler.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/async/ThriftFrameDecoder.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/async/ThriftFrameEncoder.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/interceptor/BackupRequestInterceptor.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/interceptor/CompressionInterceptor.java
copy admin-cli/client/options.go => java-client/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptor.java (64%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/interceptor/ReplicaSessionInterceptorManager.java
copy admin-cli/client/options.go => java-client/src/main/java/org/apache/pegasus/rpc/interceptor/TableInterceptor.java (59%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/rpc/interceptor/TableInterceptorManager.java
copy admin-cli/executor/drop_table.go => java-client/src/main/java/org/apache/pegasus/security/AuthProtocol.java (72%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/security/AuthReplicaSessionInterceptor.java
copy src/test/upgrade_test/main.cpp => java-client/src/main/java/org/apache/pegasus/security/Credential.java (53%)
create mode 100644 java-client/src/main/java/org/apache/pegasus/security/KerberosCredential.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/security/KerberosProtocol.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/security/Negotiation.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/security/SaslWrapper.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/tools/FlowController.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/tools/Tools.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/tools/WriteLimiter.java
create mode 100644 java-client/src/main/java/org/apache/pegasus/tools/ZstdWrapper.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/base/TestRpcAddress.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestAdminClient.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestBasic.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestBatch.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestBatchGetByPartitions.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestBench.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestCheckAndMutate.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestCheckAndSet.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestFutureGroup.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestIncr.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestMultiThread.java
copy src/shell/args.h => java-client/src/test/java/org/apache/pegasus/client/TestNoOperate.java (51%)
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestPException.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestPing.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestPingZK.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestScan.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/client/TestTimeout.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/metrics/MetricsPoolTest.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/operator/ClientOperatorTest.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/rpc/async/ClusterManagerTest.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/rpc/async/InterceptorTest.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/rpc/async/MetaSessionTest.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/rpc/async/ReplicaSessionTest.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/rpc/async/TableHandlerTest.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/rpc/async/TimeoutBenchmark.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/security/NegotiationTest.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/tools/TestZstdWrapper.java
create mode 100644 java-client/src/test/java/org/apache/pegasus/tools/Toollet.java
copy .gitmodules => java-client/src/test/resource/pegasus.properties (78%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org