StateStoreCoordinatorRef
allows for communication with StateStoreCoordinator (through rpcEndpointRef
reference).
Method | RPC Message | Description | ||
---|---|---|---|---|
|
Synchronous event to announce that
|
|||
|
||||
|
||||
|
||||
|
forDriver(env: SparkEnv): StateStoreCoordinatorRef
forDriver
…FIXME
Note
|
forDriver is used exclusively when StreamingQueryManager is created.
|
forExecutor(env: SparkEnv): StateStoreCoordinatorRef
forExecutor
…FIXME
Note
|
forExecutor is used exclusively when StateStore creates a StateStoreCoordinatorRef (for executors).
|