SliceSpan
class SliceSpan(start, stop, data_slices)
Basi: ExecutionSpan
Un ExecutionSpan per i dati memorizzati in un formato affettabile.
Questo tipo di esecuzione fa riferimento ai dati del risultato del pub assumendo che si tratti di una porzione affettabile dei dati appiattiti (di riga maggiore). Pertanto, per ogni pub dipendente da questo intervallo, il costruttore accetta un singolo oggetto slice , insieme alla forma corrispondente dei dati da affettare.
Parametri
- start (datetime) – L'ora di inizio dell'intervallo, in UTC.
- stop (datetime) – L'ora di arresto dell'intervallo, in UTC.
- data_slices (dict[int, tuple[ShapeType, slice]]) – Una mappa da indici pub a coppie
(shape_tuple, slice).
Attributi
duration
La durata di questo intervallo, in secondi.
pub_idxs
Quali pub, in base all'indice, presentano una dipendenza da uno o più intervalli di esecuzione.
size
Il numero totale di risultati che dipendono da questo intervallo di esecuzione, considerando tutti i pub.
start
L'ora di inizio dell'intervallo, in UTC.
stop
L'ora di arresto dell'intervallo, in UTC.
Metodi
contains_pub
contains_pub(pub_idx)
Restituisce se il pub con l'indice dato ha dati che dipendono da questo intervallo.
Parametri
pub_idx (int | Iterable[int]) – Uno o più indici pub della chiamata primitiva originale.
Risultati
Se c'è dipendenza da questo arco di tempo.
Tipo di restituzione
bool
filter_by_pub
filter_by_pub(pub_idx)
Restituisce un nuovo insieme di intervalli, ciascuno dei quali è stato filtrato in base ai pub specificati.
Parametri
pub_idx (int | Iterable[int])
Tipo di restituzione
mask
mask(pub_idx)
Restituisce una maschera di tipo array che specifica quali parti del risultato di una pubblicazione dipendono da questo span.
Parametri
pub_idx (int)
Tipo di restituzione
npt.NDArray[np.bool_]