Condividi tramite

Classe CepStream(TPayload)

  • Articolo

Rappresenta un flusso di eventi da qualsiasi tipo di payload specificato dall'utente.

Gerarchia di ereditarietà

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..CepStream<(Of <(<'TPayload>)>)>

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

Sintassi

public sealed class CepStream<TPayload>

Parametri di tipo

  • TPayload
    Tipo di payload dell'evento nel flusso.

Nel tipo CepStream<(Of <(<'TPayload>)>)> sono esposti i membri seguenti.

Metodi

  Nome Descrizione
Metodo pubblicoMembro statico Create(String) Crea un flusso non associato al payload dell'evento di tipo 'TPayload'.
Metodo pubblicoMembro statico Create(Uri, EventShape) Crea un flusso associato tramite un input da un flusso pubblicato specificato.
Metodo pubblicoMembro statico Create(Uri, EventShape, AdvanceTimeSettings) Crea un flusso associato per l'input da un flusso pubblicato specificato.
Metodo pubblicoMembro statico Create(Application, Uri, EventShape) Crea un flusso associato tramite un input da un flusso pubblicato specificato.
Metodo pubblicoMembro statico Create(String, Type, Object, EventShape) Crea un flusso associato da una factory dell'adattatore di input specificata.
Metodo pubblicoMembro statico Create(Application, Uri, EventShape, AdvanceTimeSettings) Crea un flusso associato per l'input da un flusso pubblicato specificato.
Metodo pubblicoMembro statico Create(String, Type, Object, EventShape, AdvanceTimeSettings) Crea un flusso associato da una factory dell'adattatore di input specificata.
Metodo pubblicoMembro statico Create(Application, String, Type, Object, EventShape) Crea un flusso associato da una factory dell'adattatore di input specificata.
Metodo pubblicoMembro statico Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings) Crea un flusso associato da una factory dell'adattatore di input specificata.
Metodo pubblico Equals Ereditato da Object.
Metodo pubblico ExtractInputStreams Recupera un elenco con informazioni sui flussi di input da una definizione di flusso specificata.
Metodo protetto Finalize Ereditato da Object.
Metodo pubblico GetHashCode Ereditato da Object.
Metodo pubblico GetType Ereditato da Object.
Metodo protetto MemberwiseClone Ereditato da Object.
Metodo pubblico ToPublishedStreamQuery(Uri, String, String, EventShape, StreamEventOrder) Crea una query con un output associato a un flusso pubblicato denominato in modo esplicito. L'output della query può essere utilizzato tramite la composizione di query dinamica. Solo una query può generare eventi per un flusso pubblicato in un momento specificato.
Metodo pubblico ToPublishedStreamQuery(Uri, Application, String, String, EventShape, StreamEventOrder) Crea una query con un output associato a un flusso pubblicato denominato in modo esplicito. L'output della query può essere utilizzato tramite la composizione di query dinamica. Solo una query può generare eventi per un flusso pubblicato in un momento specificato.
Metodo pubblico ToQuery(String, String, EventShape, StreamEventOrder) Crea una query dal flusso con un output non associato. Tutti gli input della query devono essere associati ad adattatori, sequenze o altre query. L'output della query può essere utilizzato solo tramite composizione di query dinamica. L'applicazione in cui verrà eseguita questa query è implicita nella definizione del flusso.
Metodo pubblico ToQuery(Application, String, String, EventShape, StreamEventOrder) Crea una query dal flusso con un output non associato in esecuzione nell'applicazione specificata. Tutti gli input della query devono essere associati ad adattatori, sequenze o altre query. L'output della query può essere utilizzato solo tramite composizione di query dinamica.
Metodo pubblico ToQuery(String, String, Type, Object, EventShape, StreamEventOrder) Crea una query dal flusso associato a un adattatore di output. L'adattatore di output viene specificato dal tipo di factory dell'adattatore e dall'oggetto di configurazione. L'applicazione in cui verrà eseguita questa query è implicita nella definizione del flusso.
Metodo pubblico ToQuery(String, String, Type, Object, EventShape, StreamEventOrder, Boolean) Crea una query dal flusso associato a un adattatore di output. L'adattatore di output viene specificato dal tipo di factory dell'adattatore e dall'oggetto di configurazione. L'applicazione in cui verrà eseguita questa query è implicita nella definizione del flusso. È possibile specificare che la query sia resiliente.
Metodo pubblico ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder) Crea una query dal flusso associato a un adattatore di output in esecuzione nell'applicazione specificata. L'adattatore di output viene specificato dal tipo di factory dell'adattatore e dall'oggetto di configurazione.
Metodo pubblico ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder, Boolean) Crea una query dal flusso associato a un adattatore di output in esecuzione nell'applicazione specificata. L'adattatore di output viene specificato dal tipo di factory dell'adattatore e dall'oggetto di configurazione. È possibile specificare che la query sia resiliente.
Metodo pubblico ToString Ereditato da Object.

In alto

Metodi di estensione

  Nome Descrizione
Metodo di estensione pubblico AlterEventDuration< (Of < <' (TPayload> ) > > ) Modifica la durata degli eventi di input. Questo metodo non modifica l'ora di inizio di un evento. Definito da CepStream.
Metodo di estensione pubblico 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. Definito da CepStream.
Metodo di estensione pubblico 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. Definito da CepStream.
Metodo di estensione pubblico CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, CountWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, WindowInputPolicy, CountWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) Di overload. Partiziona il flusso di input per la chiave di raggruppamento specificata. Definito da CepStream.
Metodo di estensione pubblico GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) Di overload. Raggruppa il flusso di origine per le funzioni del selettore di chiave specificate e proietta i risultati utilizzando la funzione del selettore di elementi. Definito da CepStream.
Metodo di estensione pubblico HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, HoppingWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico IsEmpty< (Of < <' (TPayload> ) > > ) Funzione utilizzata nelle query per indicare un Left Anti Semi Join (LASJ). Definito da CepStream.
Metodo di estensione pubblico Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) Unisce gli eventi dal flusso esterno agli eventi dal flusso interno nella chiave di join specificata. Definito da CepStream.
Metodo di estensione pubblico Select< (Of < <' (TPayload, TResult> ) > > ) Proietta gli eventi dal flusso di input utilizzando un'espressione di proiezione. Definito da CepStream.
Metodo di estensione pubblico SelectMany< (Of < <' (TInput, TBind, TResult> ) > > ) Produce un flusso basato sul cross join di due flussi di input. Definito da CepStream.
Metodo di estensione pubblico ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) Di overload. Sposta l'ora di inizio dell'evento su un nuovo timestamp senza modificare la durata. Definito da CepStream.
Metodo di estensione pubblico ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) Di overload. Sposta l'ora di inizio dell'evento in base all'intervallo specificato senza modificare la durata. Definito da CepStream.
Metodo di estensione pubblico SnapshotWindow< (Of < <' (TPayload> ) > > )() () () () Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico SnapshotWindow< (Of < <' (TPayload> ) > > )(SnapshotWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico SnapshotWindow< (Of < <' (TPayload> ) > > )(WindowInputPolicy, SnapshotWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico ToEdgeEnumerable< (Of < <' (TPayload> ) > > )() () () () Di overload. Converte un oggetto CepStream di eventi Edge in un sink di evento che implementa l'interfaccia IEnumerable. L'ordine degli eventi è FullyOrdered. Definito da CepStream.
Metodo di estensione pubblico ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Di overload. Converte un oggetto CepStream di eventi Edge con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IEnumerable. Definito da CepStream.
Metodo di estensione pubblico ToEdgeObservable< (Of < <' (TPayload> ) > > )() () () () Di overload. Converte un oggetto CepStream di eventi Edge in un sink di evento che implementa l'interfaccia IObservable. L'ordine degli eventi è FullyOrdered. Definito da ObservableCepStream.
Metodo di estensione pubblico ToEdgeObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Di overload. Converte un oggetto CepStream di eventi Edge con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IObservable. Definito da ObservableCepStream.
Metodo di estensione pubblico ToEnumerable< (Of < <' (TPayload> ) > > )() () () () Di overload. Converte un flusso di eventi in output enumerabile rimuovendo le intestazioni degli eventi e annullando gli eventi CTI. Definito da CepStream.
Metodo di estensione pubblico ToEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Di overload. Converte un flusso di eventi in output enumerabile con l'ordine degli eventi specificato rimuovendo le intestazioni degli eventi e annullando gli eventi CTI. Definito da CepStream.
Metodo di estensione pubblico ToIntervalEnumerable< (Of < <' (TPayload> ) > > )() () () () Di overload. Converte un oggetto CepStream di eventi intervallo in un sink di evento che implementa l'interfaccia IEnumerable. L'ordine degli eventi è FullyOrdered. Definito da CepStream.
Metodo di estensione pubblico ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Di overload. Converte un oggetto CepStream di eventi intervallo con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IEnumerable. Definito da CepStream.
Metodo di estensione pubblico ToIntervalObservable< (Of < <' (TPayload> ) > > )() () () () Di overload. Converte un oggetto CepStream di eventi intervallo in un sink di evento che implementa l'interfaccia IObservable. L'ordine degli eventi è FullyOrdered. Definito da ObservableCepStream.
Metodo di estensione pubblico ToIntervalObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Di overload. Converte un oggetto CepStream di eventi intervallo con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IObservable. Definito da ObservableCepStream.
Metodo di estensione pubblico ToObservable< (Of < <' (TPayload> ) > > )() () () () Di overload. Converte un flusso di eventi in output osservabile rimuovendo le intestazioni degli eventi e annullando gli eventi CTI. Definito da ObservableCepStream.
Metodo di estensione pubblico ToObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Di overload. Converte un flusso di eventi in output osservabile con l'ordine degli eventi specificato rimuovendo le intestazioni degli eventi e annullando gli eventi CTI. Definito da ObservableCepStream.
Metodo di estensione pubblico ToPointEnumerable< (Of < <' (TPayload> ) > > )() () () () Di overload. Converte un oggetto CepStream di eventi punto in un sink di evento che implementa l'interfaccia IEnumerable. L'ordine degli eventi è FullyOrdered. Definito da CepStream.
Metodo di estensione pubblico ToPointEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Di overload. Converte un oggetto CepStream di eventi punto con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IEnumerable. Definito da CepStream.
Metodo di estensione pubblico ToPointEventStream< (Of < <' (TPayload> ) > > ) Modifica gli eventi in un flusso di input in eventi punto, mantenendo solo le ore di inizio degli eventi. Definito da CepStream.
Metodo di estensione pubblico ToPointObservable< (Of < <' (TPayload> ) > > )() () () () Di overload. Converte un oggetto CepStream di eventi punto in un sink di evento che implementa l'interfaccia IObservable. L'ordine degli eventi è FullyOrdered. Definito da ObservableCepStream.
Metodo di estensione pubblico ToPointObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Di overload. Converte un oggetto CepStream di eventi punto con l'ordine di eventi specificato in un sink di evento che implementa l'interfaccia IObservable. Definito da ObservableCepStream.
Metodo di estensione pubblico TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, HoppingWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, HoppingWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) Di overload. 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. Definito da CepStream.
Metodo di estensione pubblico Union< (Of < <' (TPayload> ) > > ) Unisce due flussi in uno. Definito da CepStream.
Metodo di estensione pubblico Where< (Of < <' (TPayload> ) > > ) Filtra gli eventi da un flusso di input utilizzando una funzione di filtro specificata. Definito da CepStream.

In alto

Osservazioni

Prima di scrivere una query CEP, è necessario fornire la definizione di flusso appropriata. Questa classe fornisce vari metodi per creare un oggetto CepStream.

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