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

Method start

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

Starts the RPC server by binding to the configured bind address and port (blocking).

()

Source from the content-addressed store, hash-verified

55
56 /** Starts the RPC server by binding to the configured bind address and port (blocking). */
57 void start() throws IOException;
58
59 /**
60 * Gets the bind address of the RPC server. If maybe different from the configured endpoints.

Callers 15

testStatisticsEventMethod · 0.65
testDiscoverPartitionsPeriodicallyMethod · 0.65
testPartitionsExpiredInFlussButExistInLakeMethod · 0.65
testHandleTieringReachMaxDurationEventMethod · 0.65
testTableReachMaxTieringDurationMethod · 0.65
getJavaCommandPathMethod · 0.65
PipeForwarderMethod · 0.65
setupMethod · 0.65
testRunServerUsingProcessMethod · 0.65
startCoordinatorServerMethod · 0.65
testMultiGeneratorMethod · 0.65
testInitialDelayMethod · 0.65

Implementers 1

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

Calls

no outgoing calls

Tested by 15

testStatisticsEventMethod · 0.52
testDiscoverPartitionsPeriodicallyMethod · 0.52
testPartitionsExpiredInFlussButExistInLakeMethod · 0.52
testHandleTieringReachMaxDurationEventMethod · 0.52
testTableReachMaxTieringDurationMethod · 0.52
getJavaCommandPathMethod · 0.52
PipeForwarderMethod · 0.52
setupMethod · 0.52
testRunServerUsingProcessMethod · 0.52
startCoordinatorServerMethod · 0.52
testMultiGeneratorMethod · 0.52
testInitialDelayMethod · 0.52