AdvanceTimeImportSettings Constructor (String)
Initializes a new instance of the AdvanceTimeImportSettings class.
Namespace: Microsoft.ComplexEventProcessing
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Syntax
public AdvanceTimeImportSettings(
string streamName
)
public:
AdvanceTimeImportSettings(
String^ streamName
)
new :
streamName:string -> AdvanceTimeImportSettings
Public Sub New (
streamName As String
)
Parameters
streamName
Type: System.StringName of the stream that advances application time by importing the CTI events from that stream to the query.
Remarks
For more information, see Advancing Application Time.
Examples
This example demonstrates a typical use case in which a "fast" data stream needs to be joined with a "slow" reference stream. The slow stream may be lookup data that changes much less frequently than the fast stream. In order to make the join produce output as fast as its fastest input, the slow input stream is synchronized to the fast stream by importing its CTIs. In this example, the application time handling of the fast stream is considered to happen in the adapter.
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 ...
See Also
AdvanceTimeImportSettings Class
Microsoft.ComplexEventProcessing Namespace
Return to top