Share via

Classe CepStream

  • Articolo

Fornisce i metodi di estensione utilizzati per la scrittura di query LINQ tramite un flusso di eventi CEP.

Gerarchia di ereditarietà

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..CepStream

Spazio dei nomi  Microsoft.ComplexEventProcessing.Linq
Assembly:  Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)

Sintassi

public static class CepStream

Nel tipo CepStream sono esposti i membri seguenti.

Metodi

  Nome Descrizione
Metodo pubblicoMembro statico AlterEventDuration< (Of < <' (TPayload> ) > > ) Modifica la durata degli eventi di input. Questo metodo non modifica l'ora di inizio di un evento.
Metodo pubblicoMembro statico AlterEventLifetime< (Of < <' (TPayload> ) > > ) Modifica la durata degli eventi nel flusso. Questo metodo può modificare sia l'ora di inizio che l'ora di fine di un evento.
Metodo pubblicoMembro statico ClipEventDuration< (Of < <' (TSource, TClip> ) > > ) Riduce la durata degli eventi in sourceStream all'ora di inizio dell'evento corrispondente successivo in clipStream di cui è stata trovata la corrispondenza tramite matchExpression.
Metodo pubblicoMembro statico CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32) Raggruppa gli eventi del flusso di input in finestre di eventi in base a un numero specificato di ore di inizio univoche degli eventi utilizzando i criteri di output predefiniti. La finestra scorre quando arriva un nuovo evento che inizia a un'ora diversa.
Metodo pubblicoMembro statico CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, CountWindowOutputPolicy) Raggruppa gli eventi del flusso di input in finestre di eventi basate su un numero specificato di ore di inizio univoche degli eventi. La finestra scorre quando arriva un nuovo evento che inizia a un'ora diversa.
Metodo pubblicoMembro statico CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, WindowInputPolicy, CountWindowOutputPolicy) Raggruppa gli eventi del flusso di input in finestre di eventi in base a un numero specificato di ore di inizio univoche degli eventi. La finestra scorre quando arriva un nuovo evento che inizia a un'ora diversa.
Metodo pubblicoMembro statico GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) Partiziona il flusso di input per la chiave di raggruppamento specificata.
Metodo pubblicoMembro statico GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) Raggruppa il flusso di origine per le funzioni del selettore di chiave specificate e proietta i risultati utilizzando la funzione del selettore di elementi.
Metodo pubblicoMembro statico HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan) Trasforma un flusso in un flusso di finestre in cui ciascun membro è un oggetto CepWindow utilizzando i criteri di output predefiniti. La finestra è definita dagli intervalli di tempo costanti di dimensioni hop e dimensioni di finestra.
Metodo pubblicoMembro statico HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, HoppingWindowOutputPolicy) Trasforma un flusso in un flusso della finestra in cui ciascun membro è un oggetto CepWindow. La finestra è definita dagli intervalli di tempo costanti di dimensioni hop e dimensioni di finestra.
Metodo pubblicoMembro statico HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime) Trasforma un flusso in un flusso di finestre in cui ciascun membro è un oggetto CepWindow utilizzando i criteri di output predefiniti. La finestra è definita da intervalli di tempo costanti di dimensioni hop e dimensioni di finestra. È inoltre possibile fornire un'ora di allineamento come riferimento per il punto iniziale per la finestra.
Metodo pubblicoMembro statico HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Trasforma un flusso in un flusso della finestra in cui ciascun membro è un oggetto CepWindow. La finestra è definita dagli intervalli di tempo costanti di dimensioni hop e dimensioni di finestra. È inoltre possibile fornire un'ora di allineamento come riferimento per il punto iniziale per la finestra.
Metodo pubblicoMembro statico HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) Trasforma un flusso in un flusso della finestra in cui ciascun membro è un oggetto CepWindow. La finestra è definita da intervalli di tempo costanti di dimensioni hop e dimensioni di finestra. È inoltre possibile fornire un'ora di allineamento come riferimento per il punto iniziale per la finestra.
Metodo pubblicoMembro statico HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) La finestra è definita da intervalli di tempo costanti di dimensioni hop e dimensioni di finestra. È inoltre possibile fornire un'ora di allineamento come riferimento per il punto iniziale della finestra.
Metodo pubblicoMembro statico IsEmpty< (Of < <' (TPayload> ) > > ) Funzione utilizzata nelle query per indicare un Left Anti Semi Join (LASJ).
Metodo pubblicoMembro statico Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) Unisce gli eventi dal flusso esterno agli eventi dal flusso interno nella chiave di join specificata.
Metodo pubblicoMembro statico OrderBy< (Of < <' (TPayload, TOrderKey> ) > > ) Ordina il flusso di input per rankSelector.
Metodo pubblicoMembro statico OrderByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) Ordina il flusso di input per rankSelector in ordine decrescente.
Metodo pubblicoMembro statico Scan< (Of < <' (TInputEvent, TInputPayload, TOutputPayload> ) > > ) Analizza un flusso di input utilizzando un operatore del flusso definito dall'utente.
Metodo pubblicoMembro statico Select< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TResult> ) > > )> ) > > )) Dato un flusso ordinato, questo metodo produce un flusso ordinato che può essere utilizzato nell'ordinamento per rango.
Metodo pubblicoMembro statico Select< (Of < <' (TPayload, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) Proietta gli eventi dal flusso di input utilizzando un'espressione di proiezione.
Metodo pubblicoMembro statico Select< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) Esegue il mapping di un flusso di finestre a un flusso basato su un'espressione di mapping specificata.
Metodo pubblicoMembro statico Select< (Of < <' (TInput, TOutput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TOutput> ) > > )> ) > > )) Proietta ogni evento di un flusso di input enumerabile in un nuovo evento.
Metodo pubblicoMembro statico SelectMany< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), CepWindow< (Of < <' (TInput> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TInput, TResult> ) > > )> ) > > )) Supporta l'operazione Ordina per su un flusso a finestre.
Metodo pubblicoMembro statico SelectMany< (Of < <' (TInput, TBind, TResult> ) > > )(CepStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TBind, TResult> ) > > )> ) > > )) Produce un flusso basato sul cross join di due flussi di input.
Metodo pubblicoMembro statico SelectMany< (Of < <' (TInput, TGroupingKey, TBind, TResult> ) > > )(CepGroupingStreams< (Of < <' (TInput, TGroupingKey> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (IKey< (Of < <' (TGroupingKey> ) > > ), TBind, TResult> ) > > )> ) > > )) Supporta l'aggiunta della logica delle query all'interno di un operatore di raggruppamento e applicazione.
Metodo pubblicoMembro statico SelectMany< (Of < <' (TInput, TGroupingKey, TBind, TResult> ) > > )(CepGroupingStreams< (Of < <' (TInput, TGroupingKey> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepWindowStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (IKey< (Of < <' (TGroupingKey> ) > > ), TBind, TResult> ) > > )> ) > > )) Produce un flusso basato sul cross join di due flussi di input.
Metodo pubblicoMembro statico ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) Sposta l'ora di inizio dell'evento su un nuovo timestamp senza modificare la durata.
Metodo pubblicoMembro statico ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) Sposta l'ora di inizio dell'evento in base all'intervallo specificato senza modificare la durata.
Metodo pubblicoMembro statico SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Trasforma un flusso in un flusso di finestre in cui ciascun membro è un oggetto CepWindow utilizzando i criteri di output predefiniti. Ogni finestra è una finestra snapshot definita dagli endpoint dell'evento più vicini nel flusso.
Metodo pubblicoMembro statico SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), SnapshotWindowOutputPolicy) Trasforma un flusso in un flusso della finestra in cui ciascun membro è un oggetto CepWindow. Ogni finestra è una finestra snapshot definita dagli endpoint dell'evento più vicini nel flusso.
Metodo pubblicoMembro statico SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), WindowInputPolicy, SnapshotWindowOutputPolicy) Trasforma un flusso in un flusso della finestra in cui ciascun membro è un oggetto CepWindow. Ogni finestra è una finestra snapshot definita dagli endpoint dell'evento più vicini nel flusso.
Metodo pubblicoMembro statico Take< (Of < <' (TPayload> ) > > )(CepOrderedStream< (Of < <' (TPayload> ) > > ), UInt32) Dato un flusso ordinato, seleziona un determinato numero di eventi da ogni finestra.
Metodo pubblicoMembro statico Take< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), UInt32, Expression< (Of < <' (Func< (Of < <' (CepRankedEvent< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) Seleziona un determinato numero di eventi da ogni finestra e valuta inoltre l'espressione specificata. Viene utilizzato per i casi in cui si desidera proiettare il rango nel risultato di Take().
Metodo pubblicoMembro statico ThenBy< (Of < <' (TPayload, TOrderKey> ) > > ) Ordina un flusso ordinato in base a un altro oggetto orderKey come indicato da rankSelector.
Metodo pubblicoMembro statico ThenByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) Ordina un flusso ordinato in base a un altro oggetto orderKey come indicato da rankSelector.
Metodo pubblicoMembro statico ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Converte un oggetto CepStream di eventi Edge in un sink di evento che implementa l'interfaccia IEnumerable. L'ordine degli eventi è FullyOrdered.
Metodo pubblicoMembro statico ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Converte un oggetto CepStream di eventi Edge con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IEnumerable.
Metodo pubblicoMembro statico ToEdgeStream< (Of < <' (TInput, TPayload> ) > > ) Converte un flusso di input enumerabile in un flusso di eventi Edge e fornisce le caratteristiche temporali dell'input.
Metodo pubblicoMembro statico ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Converte un flusso di eventi in output enumerabile rimuovendo le intestazioni degli eventi e annullando gli eventi CTI.
Metodo pubblicoMembro statico ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Converte un flusso di eventi in output enumerabile con l'ordine degli eventi specificato rimuovendo le intestazioni degli eventi e annullando gli eventi CTI.
Metodo pubblicoMembro statico ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Converte un oggetto CepStream di eventi intervallo in un sink di evento che implementa l'interfaccia IEnumerable. L'ordine degli eventi è FullyOrdered.
Metodo pubblicoMembro statico ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Converte un oggetto CepStream di eventi intervallo con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IEnumerable.
Metodo pubblicoMembro statico ToIntervalStream< (Of < <' (TInput, TPayload> ) > > ) Converte un flusso di input enumerabile in un flusso di eventi intervallo e fornisce le caratteristiche temporali dell'input.
Metodo pubblicoMembro statico ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Converte un oggetto CepStream di eventi punto in un sink di evento che implementa l'interfaccia IEnumerable. L'ordine degli eventi è FullyOrdered.
Metodo pubblicoMembro statico ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Converte un oggetto CepStream di eventi punto con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IEnumerable.
Metodo pubblicoMembro statico ToPointEventStream< (Of < <' (TPayload> ) > > ) Modifica gli eventi in un flusso di input in eventi punto, mantenendo solo le ore di inizio degli eventi.
Metodo pubblicoMembro statico ToPointStream< (Of < <' (TInput, TPayload> ) > > )
Metodo pubblicoMembro statico ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Metodo pubblicoMembro statico ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Metodo pubblicoMembro statico ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Metodo pubblicoMembro statico TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan) Trasforma un flusso in un flusso di finestre in cui ciascun membro è un oggetto CepWindow utilizzando i criteri di output predefiniti. Una finestra a cascata è un tipo speciale di finestra di salto in cui le dimensioni della finestra e le dimensioni hop sono uguali.
Metodo pubblicoMembro statico TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, HoppingWindowOutputPolicy) Trasforma un flusso in un flusso della finestra in cui ciascun membro è un oggetto CepWindow. Una finestra a cascata è un tipo speciale di finestra di salto in cui le dimensioni della finestra e le dimensioni hop sono uguali.
Metodo pubblicoMembro statico TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime) Trasforma un flusso in un flusso di finestre in cui ciascun membro è un oggetto CepWindow utilizzando i criteri di output predefiniti. Una finestra a cascata è un tipo speciale di finestra di salto in cui le dimensioni della finestra e le dimensioni hop sono uguali. È inoltre possibile fornire un'ora di allineamento come riferimento per il punto iniziale della finestra.
Metodo pubblicoMembro statico TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Trasforma un flusso in un flusso della finestra in cui ciascun membro è un oggetto CepWindow. Una finestra a cascata è un tipo speciale di finestra di salto in cui le dimensioni della finestra e le dimensioni hop sono uguali. È inoltre possibile fornire un'ora di allineamento come riferimento per il punto iniziale della finestra.
Metodo pubblicoMembro statico TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, HoppingWindowOutputPolicy) Trasforma un flusso in un flusso della finestra in cui ciascun membro è un oggetto CepWindow. Una finestra a cascata è un tipo speciale di finestra di salto in cui le dimensioni della finestra e le dimensioni hop sono uguali. È inoltre possibile fornire un'ora di allineamento come riferimento per il punto iniziale della finestra.
Metodo pubblicoMembro statico TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) Trasforma un flusso in un flusso della finestra in cui ciascun membro è un oggetto CepWindow. Una finestra a cascata è un tipo speciale di finestra di salto in cui le dimensioni della finestra e le dimensioni hop sono uguali. È inoltre possibile fornire un'ora di allineamento come riferimento per il punto iniziale della finestra.
Metodo pubblicoMembro statico Union< (Of < <' (TPayload> ) > > ) Unisce due flussi in uno.
Metodo pubblicoMembro statico Where< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, Boolean> ) > > )> ) > > )) Filtra gli eventi da un flusso di input utilizzando una funzione di filtro specificata.
Metodo pubblicoMembro statico Where< (Of < <' (TInput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, Boolean> ) > > )> ) > > )) Filtra gli eventi da un flusso di input enumerabile utilizzando l'espressione filtro specificata.

In alto

Osservazioni

CepStream è una raccolta dei metodi di estensione. In generale i metodi di estensione restituiscono un'espressione di chiamata al metodo LINQ. Questa chiamata al metodo acquisisce la sequenza di chiamate in una forma canonica che viene poi tradotta in una query CEP eseguibile.

Protezione dei thread

I membri static (Shared in Visual Basic) pubblici di questo tipo sono affidabili. Non è invece garantita la sicurezza dei membri dell'istanza.

Vedere anche

Riferimento

Spazio dei nomi Microsoft.ComplexEventProcessing.Linq