SparkScheduler Class

SparkScheduler.

Inheritance
SparkScheduler

Constructor

SparkScheduler(*, submitted_at: typing.Union[datetime.datetime, NoneType] = None, scheduled_at: typing.Union[datetime.datetime, NoneType] = None, ended_at: typing.Union[datetime.datetime, NoneType] = None, cancellation_requested_at: typing.Union[datetime.datetime, NoneType] = None, current_state: typing.Union[str, _ForwardRef('SchedulerCurrentState'), NoneType] = None, **kwargs)

Parameters

submitted_at
datetime
Required
scheduled_at
datetime
Required
ended_at
datetime
Required
cancellation_requested_at
datetime
Required
current_state
str or SchedulerCurrentState
Required

Possible values include: "Queued", "Scheduled", "Ended".