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 ...