Construtor AdvanceTimeImportSettings

Artigo
08/01/2011

Inicializa uma nova instância da classe AdvanceTimeImportSettings.

Namespace: Microsoft.ComplexEventProcessing
Assembly: Microsoft.ComplexEventProcessing (em Microsoft.ComplexEventProcessing.dll)

Sintaxe

public AdvanceTimeImportSettings(
    string streamName
)

Parâmetros

streamName
Tipo: System. . :: . .String
Nome do fluxo que adianta a hora do aplicativo através da importação dos eventos CTI daquele fluxo para a consulta.

Comentários

Para obter mais informações, consulte Tempo avançado do aplicativo.

Exemplos

Esse exemplo demonstra um caso de uso típico no qual um fluxo de dados "rápido" precisa ser unido a um fluxo de referência "lento". O fluxo lento pode corresponder a dados de pesquisa que são alterados com menor frequência do que o fluxo rápido. Para tornar a saída de produção de junção tão rápida quanto sua entrada mais rápida, o fluxo de entrada lento é sincronizado ao fluxo rápido através da importação de seus CTIs. Neste exemplo, considera-se o adaptador como local onde ocorre a manipulação da hora do fluxo rápido do aplicativo.

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

Consulte também

Referência

AdvanceTimeImportSettings Classe

Namespace Microsoft.ComplexEventProcessing

Compartilhar via