SessionTracker 类

SessionTracker 跟踪会话以及会话中运行的作业状态。

它会与 Livy 服务通信以获取 Livy 会话状态，并通过 SynapseComm 将状态传递给 Jupyter 前端。 Jupyter 前端将基于跟踪状态在笔记本 UI 中呈现 SparkMonitor。

继承

builtins.object

SessionTracker

构造函数

SessionTracker(session)

参数

session

方法

close	关闭并结束跟踪器。
handle_output	将输出写入 stdout，因此也会写入笔记本。
session_create_end	会话创建完成后调用此方法。
session_delete_end	会话删除完成后调用此方法。
statement_execution_start	跟踪的入口点。
track_statement	跟踪语句状态。

close

关闭并结束跟踪器。

close()

handle_output

将输出写入 stdout，因此也会写入笔记本。

handle_output(statement)

参数

statement

必需

session_create_end

会话创建完成后调用此方法。

session_create_end()

session_delete_end

会话删除完成后调用此方法。

session_delete_end()

statement_execution_start

跟踪的入口点。

statement_execution_start(cell_uuid, statement_id)

参数

cell_uuid

必需

statement_id

必需

track_statement

跟踪语句状态。

track_statement(statement_id, cell_uuid)

参数

statement_id

必需

cell_uuid

必需