Класс CepStream(TPayload)

Представляет поток событий из любого определяемого типа полезных данных.

Иерархия наследования

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

Пространство имен:  Microsoft.ComplexEventProcessing.Linq
Сборка:  Microsoft.ComplexEventProcessing (в Microsoft.ComplexEventProcessing.dll)

Синтаксис

public sealed class CepStream<TPayload>

Параметры типа

• TPayload
  Тип полезных данных события из потока.

Тип CepStream<(Of <(<'TPayload>)>)> обеспечивает доступ к следующим элементам.

Методы

	Имя	Описание
	Create(String)	Создает непривязанный поток, который имеет тип полезных данных события «TPayload».
	Create(Uri, EventShape)	Создает привязанный поток для входа из заданного опубликованного потока.
	Create(Uri, EventShape, AdvanceTimeSettings)	Создает привязанный поток для входа из заданного опубликованного потока.
	Create(Application, Uri, EventShape)	Создает привязанный поток для входа из заданного опубликованного потока.
	Create(String, Type, Object, EventShape)	Создает привязанный поток из заданной фабрики входного адаптера.
	Create(Application, Uri, EventShape, AdvanceTimeSettings)	Создает привязанный поток для входа из заданного опубликованного потока.
	Create(String, Type, Object, EventShape, AdvanceTimeSettings)	Создает привязанный поток из заданной фабрики входного адаптера.
	Create(Application, String, Type, Object, EventShape)	Создает привязанный поток из заданной фабрики входного адаптера.
	Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings)	Создает привязанный поток из заданной фабрики входного адаптера.
	Equals	(Производный от Object.)
	ExtractInputStreams	Извлекает список сведений о входных потоках из данного определения потока.
	Finalize	(Производный от Object.)
	GetHashCode	(Производный от Object.)
	GetType	(Производный от Object.)
	MemberwiseClone	(Производный от Object.)
	ToPublishedStreamQuery(Uri, String, String, EventShape, StreamEventOrder)	Создает запрос с выходом, связанным с явно поименованным опубликованным потоком. Выход запроса может быть востребован через формирование динамических запросов. В любой момент времени только один запрос может создавать события для опубликованного потока.
	ToPublishedStreamQuery(Uri, Application, String, String, EventShape, StreamEventOrder)	Создает запрос с выходом, связанным с явно поименованным опубликованным потоком. Выход запроса может быть востребован через формирование динамических запросов. В любой момент времени только один запрос может создавать события для опубликованного потока.
	ToQuery(String, String, EventShape, StreamEventOrder)	Создает запрос из потока с несвязанным выходом. Все входы запроса должны быть связаны с адаптерами, последовательностями или другими запросами. Выход запроса может быть востребован только через формирование динамических запросов. Приложение, в котором будет выполняться этот запрос, выводится из определения потока.
	ToQuery(Application, String, String, EventShape, StreamEventOrder)	Создает запрос из потока с несвязанным выходом, работающего в определенном приложении. Все входы запроса должны быть связаны с адаптерами, последовательностями или другими запросами. Выход запроса может быть востребован только через формирование динамических запросов.
	ToQuery(String, String, Type, Object, EventShape, StreamEventOrder)	Создает запрос из потока с выходом, привязанным к выходному адаптеру. Выходной адаптер задается типом фабрики выходного адаптера и объектом конфигурации. Приложение, в котором будет выполняться этот запрос, выводится из определения потока.
	ToQuery(String, String, Type, Object, EventShape, StreamEventOrder, Boolean)	Создает запрос из потока с выходом, привязанным к выходному адаптеру. Выходной адаптер задается типом фабрики выходного адаптера и объектом конфигурации. Приложение, в котором будет выполняться этот запрос, выводится из определения потока. Запрос может быть определен как эластичный.
	ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder)	Создает запрос из потока с выходом, связанным с выходным адаптером, работающим в определенном приложении. Выходной адаптер задается типом фабрики выходного адаптера и объектом конфигурации.
	ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder, Boolean)	Создает запрос из потока с выходом, связанным с выходным адаптером, работающим в определенном приложении. Выходной адаптер задается типом фабрики выходного адаптера и объектом конфигурации. Запрос может быть определен как эластичный.
	ToString	(Производный от Object.)

В начало

Методы расширения

	Имя	Описание
	AlterEventDuration< (Of < <' (TPayload> ) > > )	Изменяет продолжительность событий во входном потоке. Этот метод не изменяет время начала события. (Определено CepStream.)
	AlterEventLifetime< (Of < <' (TPayload> ) > > )	Изменяет время существования событий в потоке. Этот метод может изменить время начала и окончания события. (Определено CepStream.)
	ClipEventDuration< (Of < <' (TSource, TClip> ) > > )	Укорачивает время существования событий в потоке sourceStream до точки начала следующего соответствующего события в потоке clipStream, соответствующего выражению matchExpression. (Определено CepStream.)
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32)	Перегружен. Группирует события входного потока в окна событий на основе заданного количества уникальных времен начала событий с использованием политики вывода по умолчанию. Окно прокручивается, когда поступает новое событие, начавшееся в другое время. (Определено CepStream.)
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, CountWindowOutputPolicy)	Перегружен. Группирует события входного потока в окна событий на основе заданного количества уникальных времен начала событий. Окно прокручивается, когда поступает новое событие, начавшееся в другое время. (Определено CepStream.)
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, WindowInputPolicy, CountWindowOutputPolicy)	Перегружен. Группирует события входного потока в окна событий на основе заданного количества уникальных времен начала событий. Окно прокручивается, когда поступает новое событие, начавшееся в другое время. (Определено CepStream.)
	GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ))	Перегружен. Разделяет входной поток по указанному группирующему ключу. (Определено CepStream.)
	GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > ))	Перегружен. Группирует исходный поток в соответствии с указанной функцией выбора ключа и проецирует результаты с помощью функции выбора элементов. (Определено CepStream.)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow с использованием политики вывода по умолчанию. Это окно определяется постоянными временными интервалами — размером окна и размером прыжка. (Определено CepStream.)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow с использованием политики вывода по умолчанию. Это окно определяется постоянным размером и размером прыжка. Для стартовой точки окна можно также задать время выравнивания. (Определено CepStream.)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, HoppingWindowOutputPolicy)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow. Это окно определяется постоянными временными интервалами — размером окна и размером прыжка. (Определено CepStream.)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow. Это окно определяется постоянным размером и длиной прыжка. Для стартовой точки окна можно также задать время выравнивания. (Определено CepStream.)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow. Это окно определяется постоянными временными интервалами — размером окна и размером прыжка. Для стартовой точки окна можно также задать время выравнивания. (Определено CepStream.)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)	Перегружен. Это окно определяется постоянным размером и размером прыжка. В качестве ссылки для стартовой точки окна можно также задать время выравнивания (Определено CepStream.)
	IsEmpty< (Of < <' (TPayload> ) > > )	Функция, используемая в запросах для обозначения левого антиполусоединения (LASJ). (Определено CepStream.)
	Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > )	Соединяет события внешнего потока с событиями внутреннего потока по заданному ключу соединения. (Определено CepStream.)
	Select< (Of < <' (TPayload, TResult> ) > > )	Проецирует события из заданного потока с помощью выражения проецирования. (Определено CepStream.)
	SelectMany< (Of < <' (TInput, TBind, TResult> ) > > )	Создает поток на основе кросс-соединения двух входных потоков. (Определено CepStream.)
	ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > ))	Перегружен. Смещает время начала события на новую отметку времени без изменения времени существования. (Определено CepStream.)
	ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > ))	Перегружен. Смещает время начала события на указанный промежуток времени без изменения времени существования. (Определено CepStream.)
	SnapshotWindow< (Of < <' (TPayload> ) > > )() () () ()	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow с использованием политики вывода по умолчанию. Каждое окно представляет собой окно моментального снимка, которое определяется по ближайшим конечным точкам событий в потоке. (Определено CepStream.)
	SnapshotWindow< (Of < <' (TPayload> ) > > )(SnapshotWindowOutputPolicy)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow. Каждое окно является окном моментального снимка, которое определяется ближайшими конечными точками событий в потоке. (Определено CepStream.)
	SnapshotWindow< (Of < <' (TPayload> ) > > )(WindowInputPolicy, SnapshotWindowOutputPolicy)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow. Каждое окно является окном моментального снимка, которое определяется ближайшими конечными точками событий в потоке. (Определено CepStream.)
	ToEdgeEnumerable< (Of < <' (TPayload> ) > > )() () () ()	Перегружен. Преобразует поток CepStream граничных событий в приемник событий, реализующий интерфейс IEnumerable. Порядок событий имеет значение FullyOrdered. (Определено CepStream.)
	ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	Перегружен. Преобразует поток CepStream граничных событий с указанным порядком в приемник событий, реализующий интерфейс IEnumerable. (Определено CepStream.)
	ToEdgeObservable< (Of < <' (TPayload> ) > > )() () () ()	Перегружен. Преобразует поток CepStream граничных событий в приемник событий, реализующий интерфейс IObservable. Порядок событий имеет значение FullyOrdered. (Определено ObservableCepStream.)
	ToEdgeObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	Перегружен. Преобразует поток CepStream граничных событий с указанным порядком в приемник событий, реализующий интерфейс IObservable. (Определено ObservableCepStream.)
	ToEnumerable< (Of < <' (TPayload> ) > > )() () () ()	Перегружен. Преобразует поток событий в перечислимый выход, удаляя заголовки событий и отменяя события CTI. (Определено CepStream.)
	ToEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	Перегружен. Преобразует поток событий в перечислимый выход с указанным порядком событий, удаляя заголовки событий и отменяя события CTI. (Определено CepStream.)
	ToIntervalEnumerable< (Of < <' (TPayload> ) > > )() () () ()	Перегружен. Преобразует поток CepStream интервальных событий в приемник событий, реализующий интерфейс IEnumerable. Порядок событий имеет значение FullyOrdered. (Определено CepStream.)
	ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	Перегружен. Преобразует поток CepStream интервальных событий с указанным порядком в приемник событий, реализующий интерфейс IEnumerable. (Определено CepStream.)
	ToIntervalObservable< (Of < <' (TPayload> ) > > )() () () ()	Перегружен. Преобразует поток CepStream интервальных событий в приемник событий, реализующий интерфейс IObservable. Порядок событий имеет значение FullyOrdered. (Определено ObservableCepStream.)
	ToIntervalObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	Перегружен. Преобразует поток CepStream интервальных событий с указанным порядком в приемник событий, реализующий интерфейс IObservable. (Определено ObservableCepStream.)
	ToObservable< (Of < <' (TPayload> ) > > )() () () ()	Перегружен. Преобразует поток событий в наблюдаемый выход, удаляя заголовки событий и отменяя события CTI. (Определено ObservableCepStream.)
	ToObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	Перегружен. Преобразует поток событий в наблюдаемый выход с указанным порядком событий, удаляя заголовки событий и отменяя события CTI. (Определено ObservableCepStream.)
	ToPointEnumerable< (Of < <' (TPayload> ) > > )() () () ()	Перегружен. Преобразует поток CepStream точечных событий в приемник событий, реализующий интерфейс IEnumerable. Порядок событий имеет значение FullyOrdered. (Определено CepStream.)
	ToPointEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	Перегружен. Преобразует поток CepStream точечных событий с указанным порядком в приемник событий, реализующий интерфейс IEnumerable. (Определено CepStream.)
	ToPointEventStream< (Of < <' (TPayload> ) > > )	Меняет события во входном потоке на точечные, оставляя только время их начала. (Определено CepStream.)
	ToPointObservable< (Of < <' (TPayload> ) > > )() () () ()	Перегружен. Преобразует поток CepStream точечных событий в приемник событий, реализующий интерфейс IObservable. Порядок событий имеет значение FullyOrdered. (Определено ObservableCepStream.)
	ToPointObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	Перегружен. Преобразует поток CepStream точечных событий с указанным порядком в приемник событий, реализующий интерфейс IObservable. (Определено ObservableCepStream.)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow с использованием политики вывода по умолчанию. «Переворачивающееся» окно — это особый вид прыгающего окна, в котором размер окна и размер прыжка совпадают. (Определено CepStream.)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow с использованием политики вывода по умолчанию. «Переворачивающееся» окно — это особый вид «прыгающего окна», в котором размер окна и размер прыжка совпадают. В качестве ссылки для стартовой точки окна можно также задать время выравнивания (Определено CepStream.)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, HoppingWindowOutputPolicy)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow. «Переворачивающееся» окно — это особый тип «прыгающего окна», размер и длина прыжка которого совпадают. (Определено CepStream.)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, HoppingWindowOutputPolicy)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow. «Переворачивающееся» окно — это особый тип «прыгающего окна», размер и длина прыжка которого совпадают. В качестве ссылки для стартовой точки окна можно также задать время выравнивания (Определено CepStream.)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow. «Переворачивающееся» окно — это особый тип «прыгающего окна», размер и длина прыжка которого совпадают. В качестве ссылки для стартовой точки окна можно также задать время выравнивания (Определено CepStream.)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)	Перегружен. Преобразует поток в оконный поток, каждый элемент которого имеет тип CepWindow. «Переворачивающееся» окно — это особый тип «прыгающего окна», размер и длина прыжка которого совпадают. В качестве ссылки для стартовой точки окна можно также задать время выравнивания (Определено CepStream.)
	Union< (Of < <' (TPayload> ) > > )	Объединяет два потока в один. (Определено CepStream.)
	Where< (Of < <' (TPayload> ) > > )	Фильтрует события из входного потока с помощью заданной функции фильтра. (Определено CepStream.)

В начало

Замечания

Перед тем, как можно будет написать запрос CEP, необходимо предоставить соответствующее определение потока. Этот класс предоставляет различные методы для создания объекта CepStream.

Безопасность многопоточности

Любые открытые статический (Shared в Visual Basic) элементы этого типа потокобезопасны. Потокобезопасность с элементами экземпляров не гарантируется.

См. также

Справочник

Пространство имен Microsoft.ComplexEventProcessing.Linq