MCPcopy Create free account
hub / github.com/apache/fluss / create

Method create

fluss-rpc/src/main/java/org/apache/fluss/rpc/RpcClient.java:44–44  ·  view source on GitHub ↗

Create a new RPC client that can be used to send requests to the RpcServer. @param conf The configuration to use. @param clientMetricGroup The client metric group @param isInnerClient Whether it is an inner client used for communicate from server to server. @return The RPC client.

(
            Configuration conf, ClientMetricGroup clientMetricGroup, boolean isInnerClient)

Source from the content-addressed store, hash-verified

42 * @return The RPC client.
43 */
44 static RpcClient create(
45 Configuration conf, ClientMetricGroup clientMetricGroup, boolean isInnerClient) {
46 return new NettyClient(conf, clientMetricGroup, isInnerClient);
47 }

Callers 15

openMethod · 0.95
startMethod · 0.95
testGetMetaInfoMethod · 0.95
FlussConnectionMethod · 0.95
startMethod · 0.95
setupMethod · 0.95
createReplicaManagerMethod · 0.95

Implementers 1

NettyClientfluss-rpc/src/main/java/org/apache/flu

Calls

no outgoing calls

Tested by 14

testGetMetaInfoMethod · 0.76
startMethod · 0.76
setupMethod · 0.76
createReplicaManagerMethod · 0.76
testMetadataMethod · 0.76