This is an automated email from the ASF dual-hosted git repository.
lidongdai pushed a change to branch dev
in repository
https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git.
from fbe0eda Update README.md (#4882)
new e008781 rpc
new fd05153 rpc
new e247284 rpc
new 2327da7 rpc
new c78f5e2 rpc
new 3bcb892 rpc
new d2f136b rpc
new 74a4de4 rpc
new ed164fe rpc
new 985a4fc rpc
new 0db1906 rpc test
new 9d3c37e rpc
new e950b65 rpc
new 4ae52cb rpc
new 939ee1f rpc
new 6fafcc2 rpc
new 21cec62 test
new ff67386 update
new 91b27b7 Merge branch 'dev' into rpc
new 230f3a3 add rpc config
new a2d245d add rpc config
new 9f58eb7 add rpc config
new a97f781 add license
new 4325410 add license
new 958d2fd add license
new d1f4e6a add IUserService Interface
new ea97ed1 fix bug and add license
new a63c2c6 fix bug
new 246332b fix bug
new 967ab64 fix bug and code style
new 7a976f4 fix code smell
new d1658e9 fix init rpc request error
new 0f62284 add rpc protocol
new 825870c Rename LICENSE-protostuff-api.txt to LICENSE-protostuff.txt
new efde946 Delete LICENSE-protostuff-collectionschema.txt
new 3a8df41 Delete LICENSE-protostuff-core.txt
new 3c18d63 Delete LICENSE-protostuff-runtime.txt
new 0a92a53 add jmh test
new 93fb043 code style
new 54ca216 rpc protocol
new 392136c rpc protocol
new 4578079 rpc protocol
new d3a1da4 code style
new 3ba0321 code style
new c9daf6a async not needed callback
new 50dbe7d async not needed callback
new 98d2406 async not needed callback
new fba133c move license
new dad9436 Merge branch 'dev' into rpc
new 12c1347 rpc
new 91304e6 test
new 1c047e4 test
new d30500f test
new b4c7e35 Merge branch 'dev' into rpc
new dc20d6a add NOTICE
new c6b7eb3 Merge pull request #4565 from CalvinKirs/rpc
The 4653 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:
dolphinscheduler-dist/release-docs/LICENSE | 13 +-
dolphinscheduler-dist/release-docs/NOTICE | 28 +++
...NSE-jamon-runtime.txt => LICENSE-javassist.txt} | 0
...NSE-xml-apis.txt => LICENSE-protostuff-api.txt} | 0
...SE-xml-apis.txt => LICENSE-protostuff-core.txt} | 0
...xml-apis.txt => LICENSE-protostuff-runtime.txt} | 0
...txt => LICENSE-protostuff.collectionschema.txt} | 0
.../release-docs/licenses/LICENSE-reflections.txt | 13 ++
dolphinscheduler-microbench/pom.xml | 4 +
.../microbench/common/IUserService.java | 20 +-
.../microbench/common/RpcTest.java | 77 +++++++
.../microbench/common/UserCallback.java | 15 +-
.../microbench/common/UserService.java | 16 +-
dolphinscheduler-remote/pom.xml | 26 +++
.../remote/codec/NettyDecoder.java | 36 +--
.../dolphinscheduler/remote/utils/Constants.java | 2 +-
.../org/apache/dolphinscheduler/rpc/base/Rpc.java | 43 +++-
.../dolphinscheduler/rpc/base/RpcService.java | 19 +-
.../rpc/client/ConsumerConfig.java | 87 +++++++
.../rpc/client/ConsumerConfigCache.java | 26 +--
.../rpc/client/ConsumerInterceptor.java | 124 ++++++++++
.../dolphinscheduler/rpc/client/IRpcClient.java | 16 +-
.../dolphinscheduler/rpc/client/RpcClient.java | 37 ++-
.../rpc/client/RpcRequestCache.java | 32 ++-
.../rpc/client/RpcRequestTable.java | 32 ++-
.../dolphinscheduler/rpc/codec/NettyDecoder.java | 82 +++++++
.../dolphinscheduler/rpc/codec/NettyEncoder.java | 52 +++++
.../common/AbstractRpcCallBack.java} | 13 +-
.../rpc/common/ConsumerConfigConstants.java | 16 +-
.../rpc/common/RequestEventType.java | 34 ++-
.../rpc/common/ResponseEventType.java | 34 ++-
.../dolphinscheduler/rpc/common/RpcRequest.java | 84 +++++++
.../common/RpcResponse.java} | 46 ++--
.../rpc/common/ThreadPoolManager.java | 43 ++--
.../dolphinscheduler/rpc/config/ServiceBean.java | 71 ++++++
.../dolphinscheduler/rpc/future/RpcFuture.java | 87 +++++++
.../dolphinscheduler/rpc/protocol/EventType.java | 27 +--
.../rpc/protocol/MessageHeader.java | 77 +++++++
.../dolphinscheduler/rpc/protocol/RpcProtocol.java | 26 +--
.../rpc/protocol/RpcProtocolConstants.java | 12 +-
.../dolphinscheduler/rpc/remote/NettyClient.java | 253 +++++++++++++++++++++
.../rpc/remote/NettyClientHandler.java | 120 ++++++++++
.../remote/NettyServer.java} | 102 +++------
.../rpc/remote/NettyServerHandler.java | 114 ++++++++++
.../rpc/serializer/ProtoStuffSerializer.java | 60 +++++
.../rpc/serializer/ProtoStuffUtils.java | 68 ++++++
.../rpc/serializer/RpcSerializer.java | 41 ++--
.../rpc/serializer/Serializer.java | 19 +-
.../apache/dolphinscheduler/rpc/IUserService.java | 25 +-
.../org/apache/dolphinscheduler/rpc/RpcTest.java | 64 ++++++
.../apache/dolphinscheduler/rpc/UserCallback.java | 16 +-
.../apache/dolphinscheduler/rpc/UserService.java | 31 ++-
pom.xml | 30 +++
tools/dependencies/check-LICENSE.sh | 2 +-
tools/dependencies/known-dependencies.txt | 6 +
55 files changed, 1922 insertions(+), 399 deletions(-)
copy dolphinscheduler-dist/release-docs/licenses/{LICENSE-jamon-runtime.txt =>
LICENSE-javassist.txt} (100%)
copy dolphinscheduler-dist/release-docs/licenses/{LICENSE-xml-apis.txt =>
LICENSE-protostuff-api.txt} (100%)
copy dolphinscheduler-dist/release-docs/licenses/{LICENSE-xml-apis.txt =>
LICENSE-protostuff-core.txt} (100%)
copy dolphinscheduler-dist/release-docs/licenses/{LICENSE-xml-apis.txt =>
LICENSE-protostuff-runtime.txt} (100%)
copy dolphinscheduler-dist/release-docs/licenses/{LICENSE-xml-apis.txt =>
LICENSE-protostuff.collectionschema.txt} (100%)
create mode 100644
dolphinscheduler-dist/release-docs/licenses/LICENSE-reflections.txt
copy
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/dispatch/host/assign/Selector.java
=>
dolphinscheduler-microbench/src/main/java/org/apache/dolphinscheduler/microbench/common/IUserService.java
(74%)
create mode 100644
dolphinscheduler-microbench/src/main/java/org/apache/dolphinscheduler/microbench/common/RpcTest.java
copy
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/resources/Directory.java
=>
dolphinscheduler-microbench/src/main/java/org/apache/dolphinscheduler/microbench/common/UserCallback.java
(78%)
copy
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/dto/resources/Directory.java
=>
dolphinscheduler-microbench/src/main/java/org/apache/dolphinscheduler/microbench/common/UserService.java
(72%)
copy
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/exceptions/ApiException.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/base/Rpc.java
(52%)
copy
dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/exceptions/ApiException.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/base/RpcService.java
(71%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/ConsumerConfig.java
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptParamsConstants.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/ConsumerConfigCache.java
(60%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/ConsumerInterceptor.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/DependResult.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/IRpcClient.java
(79%)
copy
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/dispatch/host/RoundRobinHostManager.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/RpcClient.java
(57%)
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/RpcRequestCache.java
(60%)
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptParamsConstants.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/client/RpcRequestTable.java
(52%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/codec/NettyDecoder.java
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/codec/NettyEncoder.java
copy
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/{remote/future/InvokeCallback.java
=> rpc/common/AbstractRpcCallBack.java} (73%)
copy
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils/ArgsUtils.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/common/ConsumerConfigConstants.java
(72%)
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/common/RequestEventType.java
(65%)
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/common/ResponseEventType.java
(64%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/common/RpcRequest.java
copy
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/{remote/command/alert/AlertSendResponseResult.java
=> rpc/common/RpcResponse.java} (54%)
copy
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/dispatch/host/RoundRobinHostManager.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/common/ThreadPoolManager.java
(52%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/config/ServiceBean.java
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/future/RpcFuture.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SqoopQueryType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/EventType.java
(63%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/MessageHeader.java
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/SqoopQueryType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/RpcProtocol.java
(66%)
copy
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils/ArgsUtils.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/protocol/RpcProtocolConstants.java
(76%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/remote/NettyClient.java
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/remote/NettyClientHandler.java
copy
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/{remote/NettyRemotingServer.java
=> rpc/remote/NettyServer.java} (66%)
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/remote/NettyServerHandler.java
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/serializer/ProtoStuffSerializer.java
create mode 100644
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/serializer/ProtoStuffUtils.java
copy
dolphinscheduler-alert-plugin/dolphinscheduler-alert-script/src/main/java/org/apache/dolphinscheduler/plugin/alert/script/ScriptType.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/serializer/RpcSerializer.java
(54%)
copy
dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/TaskRecordStatus.java
=>
dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/serializer/Serializer.java
(77%)
copy
dolphinscheduler-spi/src/main/java/org/apache/dolphinscheduler/spi/params/base/DataType.java
=>
dolphinscheduler-remote/src/test/java/org/apache/dolphinscheduler/rpc/IUserService.java
(72%)
create mode 100644
dolphinscheduler-remote/src/test/java/org/apache/dolphinscheduler/rpc/RpcTest.java
copy
dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/plugin/PluginManagerTest.java
=>
dolphinscheduler-remote/src/test/java/org/apache/dolphinscheduler/rpc/UserCallback.java
(71%)
copy
dolphinscheduler-common/src/test/java/org/apache/dolphinscheduler/common/plugin/PluginManagerTest.java
=>
dolphinscheduler-remote/src/test/java/org/apache/dolphinscheduler/rpc/UserService.java
(55%)
