AdvanceTimeImportSettings-Konstruktor
Initialisiert eine neue Instanz der AdvanceTimeImportSettings-Klasse.
Namespace: Microsoft.ComplexEventProcessing
Assembly: Microsoft.ComplexEventProcessing (in Microsoft.ComplexEventProcessing.dll)
Syntax
public AdvanceTimeImportSettings(
string streamName
)
Parameter
- streamName
Typ: System. . :: . .String
Name des Datenstroms, der die Anwendungszeit verschiebt, indem die CTI-Ereignisse aus diesem Datenstrom in die Abfrage importiert werden.
Hinweise
Weitere Informationen finden Sie unter Vorlauf der Anwendungszeit.
Beispiele
In diesem Beispiel wird ein typischer Anwendungsfall veranschaulicht, in dem ein schneller Datenstrom mit einem langsamen Referenzdatenstrom verknüpft werden muss. Bei dem langsamen Datenstrom handelt es sich möglicherweise um Suchdaten, die sich viel seltener als der schnelle Datenstrom ändern. Damit der Join die Ausgabe so schnell wie die schnellste Eingabe erzeugt, wird der langsame Eingabedatenstrom durch Importieren der zugehörigen CTIs mit dem schnellen Datenstrom synchronisiert. In diesem Beispiel wird davon ausgegangen, dass die Anwendungszeitbehandlung des schnellen Datenstroms im Adapter erfolgt.
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 ...