다음을 통해 공유

AdvanceTimeImportSettings 생성자

  • 아티클

AdvanceTimeImportSettings 클래스의 새 인스턴스를 초기화합니다.

네임스페이스:  Microsoft.ComplexEventProcessing
어셈블리:  Microsoft.ComplexEventProcessing(Microsoft.ComplexEventProcessing.dll)

구문

public AdvanceTimeImportSettings(
    string streamName
)

매개 변수

  • streamName
    유형: System. . :: . .String
    해당 스트림에서 쿼리로 CTI(현재 시간 증분) 이벤트를 가져와서 응용 프로그램 시간을 이동하는 스트림의 이름입니다.

주의

자세한 내용은 응용 프로그램 시간 이동을 참조하십시오.

예

이 예에서는 “고속” 데이터 스트림을 “저속” 참조 스트림과 조인해야 하는 일반적인 사용 사례를 보여 줍니다. 저속 스트림은 고속 스트림에 비해 변경 빈도가 훨씬 낮은 조회 데이터일 수 있습니다. 조인을 통해 최고속 입력만큼 빠른 출력을 생성할 수 있도록 저속 입력 스트림의 CTI를 가져와서 이 스트림을 고속 스트림에 동기화합니다. 이 예에서는 고속 스트림의 응용 프로그램 시간 처리를 어댑터에서 수행한다고 간주합니다.

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

참고 항목

참조

AdvanceTimeImportSettings 클래스

Microsoft.ComplexEventProcessing 네임스페이스