데이터 흐름 구성 요소의 런타임 메서드

PrimeOutput 메서드는 구성 요소에 IDTSPath100 개체를 통해 다운스트림 구성 요소에 연결된 출력이 하나 이상 있고 이 출력의 SynchronousInputID 속성이 0인 경우에 호출됩니다. 비동기 출력을 사용하는 원본 구성 요소 및 변환의 경우에는 PrimeOutput이 호출됩니다. 아래에 설명된 ProcessInput 메서드와 달리 PrimeOutput 메서드는 해당 메서드가 필요한 각 구성 요소에 대해 한 번씩만 호출됩니다.

ProcessInput 메서드는 IDTSPath100 개체를 통해 업스트림 구성 요소에 연결된 하나 이상의 입력이 있는 구성 요소에 대해 호출됩니다. ProcessInput 메서드는 대상 구성 요소와 동기 출력을 사용하는 변환에 대해 호출됩니다. ProcessInput은 업스트림 구성 요소에서 처리할 행이 더 이상 없을 때까지 반복적으로 호출됩니다.

구성 요소에서는 PipelineBuffer 개체에 행을 추가하는 방법으로 다운스트림 구성 요소에 행을 제공합니다. 데이터 흐름 태스크에서는 다운스트림 구성 요소에 연결된 각 IDTSOutput100 개체에 대한 출력 버퍼가 하나씩 포함된 출력 버퍼 배열을 PrimeOutput 메서드에 대한 매개 변수로 제공합니다. 원본 구성 요소와 비동기 출력을 사용하는 변환 구성 요소에서는 버퍼에 행을 추가하고 행 추가가 완료되면 SetEndOfRowset 메서드를 호출합니다. 데이터 흐름 태스크에서는 해당 태스크가 구성 요소에 제공한 출력 버퍼를 관리하고 버퍼가 가득 차면 해당 버퍼의 행을 자동으로 다음 구성 요소로 이동합니다. PrimeOutput 메서드는 반복적으로 호출되는 ProcessInput 메서드와 달리 구성 요소마다 한 번씩 호출됩니다.

다음 코드 예에서는 구성 요소에서 PrimeOutput 메서드 실행 중 출력 버퍼에 행을 추가한 다음 SetEndOfRowset 메서드를 호출하는 방법을 보여 줍니다.

public override void PrimeOutput( int outputs, int []outputIDs,PipelineBuffer []buffers)
{
    for( int x=0; x < outputs; x++ )
    {
        IDTSOutput100 output = ComponentMetaData.OutputCollection.GetObjectByID( outputIDs[x]);
        PipelineBuffer buffer = buffers[x];

        // TODO: Add rows to the output buffer.
    }
    foreach( PipelineBuffer buffer in buffers )
    {
        /// Notify the data flow task that no more rows are coming.
        buffer.SetEndOfRowset();
    }
}

public overrides sub PrimeOutput( outputs as Integer , outputIDs() as Integer ,buffers() as PipelineBuffer buffers)

    For x As Integer = 0 To outputs.MaxValue

        Dim output As IDTSOutput100 = ComponentMetaData.OutputCollection.GetObjectByID(outputIDs(x))
        Dim buffer As PipelineBuffer = buffers(x)

        ' TODO: Add rows to the output buffer.

    Next

    For Each buffer As PipelineBuffer In buffers

        ' Notify the data flow task that no more rows are coming.
        buffer.SetEndOfRowset()

    Next

End Sub

출력 버퍼에 행을 추가하는 구성 요소를 개발하는 방법은 사용자 지정 원본 구성 요소 개발 및 비동기 출력을 사용하여 사용자 지정 변환 구성 요소 개발을 참조하십시오.

구성 요소는 PipelineBuffer 개체에서 업스트림 구성 요소의 행을 받습니다. 데이터 흐름 태스크에서는 업스트림 구성 요소가 ProcessInput 메서드에 대한 매개 변수로 데이터 흐름에 추가한 행이 들어 있는 PipelineBuffer 개체를 제공합니다. 이 입력 버퍼를 사용하여 버퍼의 행 및 열을 검사하거나 수정할 수 있지만 행을 추가하거나 제거할 수는 없습니다. ProcessInput 메서드는 사용할 수 없는 버퍼가 더 이상 없을 때까지 반복적으로 호출됩니다. 이 메서드가 마지막으로 호출될 때는 EndOfRowset 속성이 true로 설정됩니다. 버퍼 내에서 다음 행으로 진행하는 NextRow 메서드를 사용하면 버퍼의 행 컬렉션을 반복할 수 있습니다. 버퍼가 컬렉션의 마지막 행에 있으면 이 메서드는 false를 반환합니다. 마지막 데이터 행이 처리된 후 추가 동작을 수행해야 하는 경우가 아니면 EndOfRowset 속성을 확인할 필요가 없습니다.

다음 텍스트는 NextRow 메서드와 EndOfRowset 속성을 사용할 때 올바른 패턴을 보여 줍니다.

while (buffer.NextRow())

{

// Do something with each row.

}

if (buffer.EndOfRowset)

{

// Optionally, do something after all rows have been processed.

}

다음 코드 예에서는 구성 요소에서 ProcessInput 메서드 실행 중 입력 버퍼의 행을 처리하는 방법을 보여 줍니다.

public override void ProcessInput( int inputID, PipelineBuffer buffer )
{
    {
        IDTSInput100 input = ComponentMetaData.InputCollection.GetObjectByID(inputID);
        while( buffer.NextRow())
        {
            // TODO: Examine the columns in the current row.
        }
}

Public Overrides Sub ProcessInput(ByVal inputID As Integer, ByVal buffer As PipelineBuffer)

        Dim input As IDTSInput100 = ComponentMetaData.InputCollection.GetObjectByID(inputID)
        While buffer.NextRow() = True

            ' TODO: Examine the columns in the current row.
        End While

End Sub

입력 버퍼에서 행을 받는 구성 요소를 개발하는 방법은 사용자 지정 대상 구성 요소 개발 및 동기 출력을 사용하여 사용자 지정 변환 구성 요소 개발를 참조하십시오.