ExecutionSpan
class ExecutionSpan(start, stop)
Bases: ABC
Padre abstracto para clases que almacenan un lapso de tiempo de ejecución para un subconjunto de datos de trabajo.
Se dice que un pub tiene dependencia de un tramo de ejecución si la ejecución correspondiente incluye datos que forman parte de los resultados del pub.
Los tramos de ejecución son verificables por igualdad, e implementan un operador de comparación basado en la tupla (start, stop), por lo que pueden ordenarse.
Parámetros
- start (datetime) – La hora de inicio del tramo, en UTC.
- stop (datetime) – La hora de parada del tramo, en UTC.
Atributos
duration
La duración de este lapso, en segundos.
pub_idxs
Qué pubs, por índice, tienen dependencia de este tramo de ejecución.
size
El número total de resultados con dependencia de este intervalo de ejecución, en todos los pubs.
mask()Este atributo equivale a la suma de los elementos de todos los caracteres \s presentes. En el caso de los resultados del muestreador, representa el número total de disparos en función de este intervalo de ejecución.
Combine este atributo con filter_by_pub() para encontrar el tamaño de algún pub en particular:
span.filter_by_pub(2).sizestart
La hora de inicio del tramo, en UTC.
stop
La hora de parada del tramo, en UTC.
Métodos
contains_pub
contains_pub(pub_idx)
Devuelve si el pub con el índice dado tiene datos con dependencia de este span.
Parámetros
pub_idx (int | Iterable[int]) – Uno o más índices pub de la llamada primitiva original.
Devuelve
Si existe dependencia de este tramo.
Tipo de retorno
bool
filter_by_pub
abstract filter_by_pub(pub_idx)
Devuelve un nuevo span cuyas rebanadas se filtran a los índices de pub proporcionados.
Por ejemplo, si este span contiene información de cortes para pubs con índices 1, 3, 4 y se proporciona [1, 4] , entonces el span devuelto por este método contendrá información de cortes sólo para esos dos índices, pero será idéntico por lo demás.
Parámetros
pub_idx (int | Iterable[int]) – Uno o más índices pub de la llamada primitiva original.
Devuelve
Un nuevo tramo filtrado.
Tipo de retorno
mask
abstract mask(pub_idx)
Devuelve una máscara con valores de matriz que especifica qué partes del resultado de un pub dependen de este span.
Parámetros
pub_idx (int) – El índice del pub para el que devolver una máscara.
Devuelve
Un array con la misma forma que los datos del pub.
Eleva
KeyError - si el pub no está incluido en el span
Tipo de retorno
npt.NDArray[np.bool_]