ExecutionSpan
class ExecutionSpan(start, stop)
ベース： ABC
ジョブ・データのサブセットの実行時間スパンを格納するクラスの抽象的な親。
パブは、対応する実行がパブの結果のいずれかの部分を形成するデータを含む場合、実行スパンへの依存を持つと言われる。
実行スパンは等号チェックが可能であり、タプル (start, stop) に基づいた比較演算子を実装しているため、ソートすることができる。
パラメーター
- start (datetime) – スパンの開始時間（UTC）。
- stop (datetime) – スパンの停止時間（UTC）。
属性
duration
このスパンの継続時間（秒）。
pub_idxs
インデックスによって、どのパブがこの実行スパンに依存しているか。
size
すべてのパブにわたる、この実行スパンに依存する結果の総数。
mask()この属性は、存在するすべての\sの要素の合計に相当します。 サンプリング結果については、これは当該実行期間におけるショット総数を表しています。
この属性を filter_by_pub() と組み合わせると、特定のパブのサイズを見つけることができます：
span.filter_by_pub(2).sizestart
スパンの開始時間（UTC）。
stop
スパンの停止時間（UTC）。
方法
contains_pub
contains_pub(pub_idx)
指定されたインデックスを持つパブが、このスパンに依存するデータを持っているかどうかを返します。
パラメーター
pub_idx (int | Iterable[int]) – 元のプリミティブ呼び出しからの1つ以上のパブインデックス。
戻り値
このスパンへの依存があるかどうか。
戻りの型
ブール値
filter_by_pub
abstract filter_by_pub(pub_idx)
指定されたパブインデックスでスライスをフィルタリングした新しいスパンを返す。
例えば、このスパンがインデックス1、3、4のパブのスライス情報を含み、 [1, 4] が提供された場合、このメソッドによって返されるスパンは、これら2つのインデックスのみのスライス情報を含むが、それ以外は同一である。
パラメーター
pub_idx (int | Iterable[int]) – 元のプリミティブ呼び出しからの1つ以上のパブインデックス。
戻り値
新しいフィルター付きスパン。
戻りの型
mask
abstract mask(pub_idx)
パブの結果のどの部分がこのスパンに依存するかを指定する、配列値のマスクを返す。
パラメーター
pub_idx (int) – マスクを返すパブのインデックス。
戻り値
パブデータと同じ形状の配列。
レイズ
KeyError - パブがスパンに含まれていない場合
戻りの型
npt.NDArray[np.bool_]