AdvanceTimeImportSettings Constructor
Inicializa una nueva instancia de la clase AdvanceTimeImportSettings.
Espacio de nombres: Microsoft.ComplexEventProcessing
Ensamblado: Microsoft.ComplexEventProcessing (en Microsoft.ComplexEventProcessing.dll)
Sintaxis
public AdvanceTimeImportSettings(
string streamName
)
Parámetros
- streamName
Tipo: System. . :: . .String
Nombre del flujo que adelanta el tiempo de aplicación importando los eventos CTI de ese flujo en la consulta.
Comentarios
Para obtener más información, vea Adelantar tiempo de aplicación.
Ejemplos
En este ejemplo se muestra un caso de uso típico en el que un flujo de datos "rápido" debe combinarse con un flujo de referencia "lento". El flujo lento puede consistir en datos de búsqueda que cambian con mucha menos frecuencia que el flujo rápido. Para que la combinación genere la salida tan rápido como la entrada más rápida, el flujo de entrada lento se sincroniza con el flujo rápido mediante la importación de sus CTI. En este ejemplo, se considera que el control de tiempo de aplicación del flujo rápido tiene lugar en el adaptador.
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 ...