Constructeur AdvanceTimeImportSettings
Initialise une nouvelle instance de la classe AdvanceTimeImportSettings.
Espace de noms : Microsoft.ComplexEventProcessing
Assembly : Microsoft.ComplexEventProcessing (en Microsoft.ComplexEventProcessing.dll)
Syntaxe
public AdvanceTimeImportSettings(
string streamName
)
Paramètres
- streamName
Type : System. . :: . .String
Nom du flux de données qui avance l'heure de l'application en important, dans la requête, les événements CTI de ce flux de données.
Notes
Pour plus d'informations, consultez Avancer le temps d'application.
Exemples
Cet exemple montre un cas d'usage typique dans lequel un flux de données « rapide » doit être joint à un flux de données de référence « lent ». Le flux de données lent peut contenir des données de recherche qui changent beaucoup moins fréquemment que celles du flux de données rapide. Pour rendre la sortie jointe aussi rapide que l'est son entrée la plus rapide, le flux d'entrée lent est synchronisé au flux de données rapide en important ses CTI. Dans cet exemple, on considère que la gestion de l'heure de l'application du flux de données rapide a lieu dans l'adaptateur.
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 ...