Microsoft.StreamProcessing Przestrzeń nazw

Klasy

Afa	Metody rozszerzenia do tworzenia obiektu usługi AFA
Afa<TInput,TRegister>	Prostsza forma uwierzytelniania AFA, której akumulator jest prostą wartością logiczną wskazującą, że wzorzec został dopasowany
Afa<TInput,TRegister,TAccumulator>	Klasa, która całkowicie opisuje usługę AFA wraz z jej właściwościami.
AfaPlanNode	Węzeł w planie zapytania reprezentujący aplikację funkcji do wszystkich wierszy wejściowych.
AlterLifetimePlanNode	Węzeł w planie zapytania reprezentujący zmianę okresów istnienia zdarzeń do zmiennego czasu trwania w aktywnym, uruchomionym zapytaniu.
ARegex	Klasa konstruktora do tworzenia wzorców, względem których mają być zgodne dane strumienia przy użyciu interfejsu wyrażeń regularnych
BeatPlanNode	Węzeł w planie zapytania reprezentujący podział każdej osi czasu zdarzeń na równe interwały.
ClipByConstantPlanNode	Węzeł w planie zapytania reprezentujący obcinanie okresu istnienia ("ClipByConstant") w aktywnym, uruchomionym zapytaniu.
ColumnToRowPlanNode	Węzeł w planie zapytania reprezentujący przejście od danych zorientowanych na kolumny do zorientowanego na wiersz w aktywnym, uruchomionym zapytaniu.
Config	Klasa statyczna, która przechowuje wszystkie ustawienia konfiguracji użytkownika.
DisorderPolicy	Określa sposób obsługi zdarzeń poza kolejnością
EgressPlanNode	Węzeł w planie zapytania reprezentujący źródło danych w aktywnym, uruchomionym zapytaniu.
EndEdgeFreeOutputPlanNode	Węzeł w planie zapytania reprezentujący aplikację funkcji do wszystkich wierszy wejściowych.
EqualityComparerExpression<T>	Zapewnia implementację do zawijania dwóch funkcji do elementu IEqualityComparerExpression<T>.
EvolvingStateEnumerable<TPayload>	Obiekt wyliczalny, którego zawartość podlega zmianom w miarę udostępniania dodatkowych danych ze strumienia.
ExtendLifetimePlanNode	Węzeł w planie zapytania reprezentujący operację rozszerzenia okresu istnienia ("ExtendLifetime") w aktywnym, uruchomionym zapytaniu.
FilteredWindow<TKey,TSource>	Klasa pochodna z okna, w którym są stosowane dodatkowe semantyka, gdy filtr jest obecny
FusedPlanNode	Węzeł w planie zapytania reprezentujący źródło danych w aktywnym, uruchomionym zapytaniu.
GroupedWindowPlanNode<TInput,TState,TResult>	Węzeł w planie zapytania reprezentujący operację migawki okna zgrupowanego.
GroupPlanNode	Reprezentuje operację grupowania w procesie Map-Reduce.
IngressException	Wyjątek specyficzny dla błędu występującego podczas ruchu przychodzącego danych.
IngressPlanNode	Węzeł w planie zapytania reprezentujący źródło danych w aktywnym, uruchomionym zapytaniu.
JoinPlanNode	Węzeł w planie zapytania reprezentujący operację sprzężenia w aktywnym, uruchomionym zapytaniu.
MulticastPlanNode	Reprezentuje operację w strumieniu, aby umożliwić wielu subskrybentom odbieranie tych samych komunikatów.
OnCompletedPolicy	Określa sposób obsługi uzupełniania zapytań (podczas odbierania wywołania OnCompleted).
OutOfOrderPartitionedStreamEvent	Statyczna klasa zawierająca metody generatora dla obiektów OutOfOrderPartitionedStreamEvent.
OutOfOrderStreamEvent	Statyczna klasa zawierająca metody generatora dla obiektów OutOfOrderStreamEvent.
PartitionedDisorderPolicy	Określa sposób obsługi zdarzeń poza kolejnością
PartitionedPeriodicPunctuationPolicy	Określa sposób wstrzykiwania interpunkcji do wynikowego strumienia. Ponieważ znaki interpunkcyjne wymuszają wyjście, uwidacznia to kompromis przepływności/opóźnienia.
PartitionedStreamEvent	Partycjonowane pomocniki zdarzeń strumienia, które nie zależą od argumentów ogólnych.
PeriodicPunctuationPolicy	Określa sposób wstrzykiwania interpunkcji do wynikowego strumienia. Ponieważ znaki interpunkcyjne wymuszają wyjście, uwidacznia to kompromis przepływności/opóźnienia.
PlanNode	Węzeł w planie zapytania reprezentujący obiekty w aktywnym, uruchomionym zapytaniu.
PointAtEndPlanNode	Węzeł w planie zapytania reprezentujący transformację okresu istnienia przenosząc okres istnienia do operacji interwału jednostkowego ("PointAtEnd") w aktywnym, uruchomionym zapytaniu.
Process	Klasa reprezentująca uruchomione zapytanie, które można wskazać.
Properties	Metody rozszerzeń z możliwością przesyłania strumieniowego.
QuantizeLifetimePlanNode	Węzeł w planie zapytania reprezentujący transformację okresu istnienia kwantyzujący czas rozpoczęcia i zakończenia wzdłuż granic przeskoków w aktywnym, uruchomionym zapytaniu.
QueryContainer	Obiekt kontenera reprezentujący zapytanie strumienia.
ReshapingPolicy	Zasady określające, czy zdarzenia są przekształcane w ruch wychodzący i jak są zmieniane
RowToColumnPlanNode	Węzeł w planie zapytania reprezentujący przejście od danych zorientowanych na wiersz do zorientowanych na kolumny w aktywnym, uruchomionym zapytaniu.
SelectBatchPlanNode	Węzeł w planie zapytania reprezentujący aplikację funkcji do wszystkich wierszy wejściowych.
SelectManyPlanNode	Węzeł w planie zapytania reprezentujący operację SelectMany w aktywnym, uruchomionym zapytaniu.
SelectPlanNode	Węzeł w planie zapytania reprezentujący aplikację funkcji do wszystkich wierszy wejściowych.
SessionWindowPlanNode	Węzeł w planie zapytania reprezentujący obcinanie okna sesji ("SessionTimeoutWindow") operacji w aktywnym, uruchomionym zapytaniu.
SnapshotWindowPlanNode<TInput,TState,TResult>	Węzeł w planie zapytania reprezentujący operację migawki okna wsadowego.
SprayPlanNode	Reprezentuje operację w zadaniu Map-Reduce, które rozpyla dane do różnych węzłów.
StitchPlanNode	Węzeł w planie zapytania reprezentujący zjednoczenie takich zdarzeń z sąsiednimi interwałami okresu istnienia.
Streamable	Metody rozszerzeń z możliwością przesyłania strumieniowego.
StreamCache<TKey,TPayload>	Przechowuje pełny strumień w sposób wysoce wydajny i przyjazny dla kolejnych iteracji dane.
StreamEvent	Pomocnicy zdarzeń strumienia, które nie zależą od argumentów ogólnych.
StreamProcessingException	Reprezentuje wyjątek użytkownika w obrębie
StreamProperties<TKey,TPayload>	Klasa przechowująca zestaw właściwości strumienia dla strumienia
StreamScheduler	Klasa do ustawiania strategii planowania dla usługi Trill (za pośrednictwem Microsoft.StreamProcessing.Config. StreamScheduler)
TemporalSortPlanNode	Węzeł w planie zapytania reprezentujący operację sortowania czasowego (na sygnaturach czasowych) w aktywnym, uruchomionym zapytaniu.
TimelinePolicy	Określa sposób przypisywania monotonicznie rosnącego składnika czasowego do danych wewnętrznie atemporalnych.
UngroupPlanNode	Reprezentuje operację rozgrupowania w procesie Map-Reduce.
UnionPlanNode	Wskazuje, że bieżący węzeł jest operacją unii.
UserDefinedPlanNode<TKey,TSource,TResult>	Węzeł w planie zapytania reprezentujący operację zdefiniowaną poza biblioteką.
WherePlanNode	Węzeł w planie zapytania reprezentujący operację filtrowania ("gdzie") w aktywnym, uruchomionym zapytaniu.
Window<TKey,TSource>	Klasa reprezentująca okno w ramach operacji agregacji.

Struktury

Empty	Typ reprezentujący pustą strukturę, podobnie jak Unit w innych bibliotekach i językach.
OutOfOrderPartitionedStreamEvent<TKey,TPayload>	Struktura reprezentująca, gdy trzeba było dostosować lub usunąć krotkę ze źródła danych przychodzących.
OutOfOrderStreamEvent<TPayload>	Struktura reprezentująca, gdy trzeba było dostosować lub usunąć krotkę ze źródła danych przychodzących.
PartitionedStreamEvent<TKey,TPayload>	Reprezentuje zdarzenie partycjonowanego strumienia
StreamEvent<TPayload>	Reprezentuje niepartycjonowane zdarzenie strumienia

Interfejsy

IAbstractPattern<TKey,TPayload,TRegister,TAccumulator>	Interfejs jest publiczny tylko do obsługi silnego wpisywania clR — wystąpienia powinny być tworzone tylko wewnętrznie. Nie używaj bezpośrednio.
IAbstractPatternRoot<TKey,TPayload,TRegister,TAccumulator>	Interfejs jest publiczny tylko do obsługi silnego wpisywania clR — wystąpienia powinny być tworzone tylko wewnętrznie. Nie używaj bezpośrednio.
IComparerExpression<T>	Interfejs otoki dla wyrażenia w celu porównania dwóch wartości danego typu.
IConnectableStreamable<TKey,TPayload>	Interfejs umożliwiający dynamiczne łączenie nowych strumieniowych danych wyjściowych z istniejącym strumieniem
IEqualityComparerExpression<T>	Interfejs, który zapewnia oparty na wyrażeniach sposób określania tego samego, co IComparer<T> robi: funkcja równości i funkcja do obliczania skrótu.
IIngressStreamable<TKey,TPayload>	Interfejs odpowiadający strumieniowi w punkcie ruchu przychodzącego do zapytania.
IMapDefinition<TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput>	Interfejs zastępczy dla operacji, która reprezentuje funkcję map-reduce
IMapDefinition<TOuterKey,TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput>	Interfejs zastępczy dla operacji, która reprezentuje funkcję map-reduce
IObservableIngressStreamable<TPayload>	Interfejs odpowiadający strumieniowi w ruchu przychodzącym wskazuje zapytanie, w którym dane wejściowe mogą być poza kolejnością.
IPartitionedIngressStreamable<TPartitionKey,TPayload>	Interfejs odpowiadający strumieniowi w ruchu przychodzącym wskazuje zapytanie, w którym dane wejściowe mogą być poza kolejnością.
IPassiveIngressStreamable<TKey,TPayload>	Interfejs dla pasywnej lokacji ruchu przychodzącego, która może zostać wyzwolona zewnętrznie w celu odczytu dostępnych danych.
IPattern<TKey,TPayload,TRegister,TAccumulator>	Interfejs jest publiczny tylko do obsługi silnego wpisywania clR — wystąpienia powinny być tworzone tylko wewnętrznie. Nie używaj bezpośrednio.
IStreamable<TKey,TPayload>	Podstawowy interfejs dla operacji przesyłanych strumieniowo — użytkownicy nie powinni tworzyć nowych klas implementujących ten interfejs bez bezpośredniej komunikacji z zespołem deweloperów

Wyliczenia

AggregatePipeType	Wyliczenie dostępnych typów algorytmów zarządzania stanem.
JoinKind	Opisuje rodzaj sprzężenia używanego w określonym węźle planu zapytania sprzężenia.
OperationalHint	Podaje wskazówkę dotyczącą metod, które powinny być używane dla operatora
PlanNodeKind	Rodzaj węzła planu.
SortingTechnique	Do wyboru, jakiej techniki należy używać w przypadku danych przychodzących do sortowania dowolnych danych poza kolejnością.
StreamEventKind	Rodzaje zdarzeń dla elementów StreamEvents z uwzględnieniem wierszy
StreamMessageKind	Przesyłanie strumieniowe rodzajów komunikatów dla poszczególnych komunikatów przechodzących przez zapytanie