EpochCoordinatorRef

EpochCoordinatorRef is…​FIXME

Creating Remote Reference to EpochCoordinator RPC Endpoint — create Factory Method

create(
  writer: StreamWriter,
  reader: ContinuousReader,
  query: ContinuousExecution,
  epochCoordinatorId: String,
  startEpoch: Long,
  session: SparkSession,
  env: SparkEnv): RpcEndpointRef

create…​FIXME

Note
 create is used exclusively when ContinuousExecution is requested to run a streaming query in continuous mode.

Getting Remote Reference to EpochCoordinator RPC Endpoint — get Factory Method

get(id: String, env: SparkEnv): RpcEndpointRef

get…​FIXME

Note

get is used when:

results matching ""

    No results matching ""