Конструктор AdvanceTimeImportSettings
Инициализирует новый экземпляр класса AdvanceTimeImportSettings.
Пространство имен: Microsoft.ComplexEventProcessing
Сборка: Microsoft.ComplexEventProcessing (в Microsoft.ComplexEventProcessing.dll)
Синтаксис
public AdvanceTimeImportSettings(
string streamName
)
Параметры
- streamName
Тип: System. . :: . .String
Имя потока, который обрабатывает время приложения путем импорта событий CTI из этого потока в запрос.
Замечания
Дополнительные сведения см. в разделе Обработка времени приложения.
Примеры
В этом примере показан типичный случай использования, где «быстрый» поток данных необходимо соединить с «медленным» эталонным потоком. Медленный поток может представлять данные для подстановки, которые меняются намного реже, чем быстрый поток. Чтобы сделать результат соединения таким же быстрым, как самый быстрый из входов соединения, медленный входной поток синхронизируется с быстрым потоком, импортируя его события CTI. В этом примере предполагается, что обработка времени приложения в быстром потоке выполняется в адаптере.
var dataStream = CepStream<DataType>.Create("dataStream ",
typeof(DataInputAdapterFactory),
new MyDataAdapterConfiguation(),
EventShape.Point);
var ats = new AdvanceTimeSettings(null, new AdvanceTimeImportSettings("dataStream"), AdvanceTimePolicy.Adjust);
var lookupStream = CepStream<LookupType>.Create("lookupStream",
typeof(ReferenceInputAdapterFactory),
new MyReferenceConfiguation(),
EventShape.Edge,
ats);
var joined = from eLeft in dataStream
join eRight in lookupStream
where ...