Share via


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

請參閱

參考

AdvanceTimeImportSettings 類別

Microsoft.ComplexEventProcessing 命名空間