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

    Name 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