SliceSpan
class SliceSpan(start, stop, data_slices)
Bases: ExecutionSpan
En ExecutionSpan para datos almacenados en un formato rebanable.
Este tipo de span de ejecución hace referencia a los datos de resultado del pub asumiendo que se trata de una porción rebanable de los datos aplanados (fila mayor). Por lo tanto, para cada pub dependiente de este span, el constructor acepta un único objeto slice , junto con la forma correspondiente de los datos a trocear.
Parámetros
- start (datetime) – La hora de inicio del tramo, en UTC.
- stop (datetime) – La hora de parada del tramo, en UTC.
- data_slices (dict[int, tuple[ShapeType, slice]]) – Un mapa de índices pub a pares
(shape_tuple, slice).
Atributos
duration
La duración de este lapso, en segundos.
pub_idxs
¿Qué pubs, según el índice, presentan dependencia de uno o más intervalos de ejecución?
size
El número total de resultados que dependen de este intervalo de ejecución, en todos los pubs.
start
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
filter_by_pub(pub_idx)
Devuelve un nuevo conjunto de tramos, cada uno de los cuales se ha filtrado según los pubs especificados.
Parámetros
pub_idx (int | Iterable[int])
Tipo de retorno
mask
mask(pub_idx)
Devuelve una máscara con valores en forma de matriz que especifica qué partes del resultado de una publicación dependen de este fragmento.
Parámetros
pub_idx (int)
Tipo de retorno
npt.NDArray[np.bool_]