Run -saat yöntemleri bir veri akışı bileşen

The PrimeOutput method is called when a component has at least one output, attached to a downstream component through an IDTSPath100 object, and the SynchronousInputID property of the output is zero.The PrimeOutput method is called for source components and for transformations with asynchronous outputs.Aksine ProcessInput , aşağıda açıklanan yöntem PrimeOutput yöntem yalnızca adlı bir kez her bileşen için gerektiren it.

The ProcessInput method is called for components that have at least one input attached to an upstream component by an IDTSPath100 object.The ProcessInput method is called for destination components and for transformations with synchronous outputs.ProcessInput is called repeatedly until there are no more rows to process from upstream components.

Bileşenleri tedarik satır aşağı akım bileşenleri için satır ekleyerek PipelineBuffer nesneler.veri akışı görevi çıktı arabelleği - her bir dizi sağlar IDTSOutput100 bir parametre olarak bir aşağı akım bileşeni - bağlı nesne PrimeOutput yöntem.Kaynak bileşenleri ve zaman uyumsuz çıkışlarına dönüştürme bileşenlerle satır arabellekleri ve Ekle çağrısı için SetEndOfRowset bitmiş ekleme satırları olduklarında yöntemveri akışı görevi için bileşenleri sağlar ve, bir arabellek edilince tam, otomatik olarak bir arabellek satırları sonraki bileşene taşır çıktı arabelleği yönetir.The PrimeOutput method is called one time per component, unlike the ProcessInput method, which is called repeatedly.

Aşağıdaki kod örneği, nasıl bir bileşen satırları sırasında kendi çıktı arabelleği ekler gösterir PrimeOutput sonra yöntem çağırarak SetEndOfRowset yöntem.

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

Çıkış arabelleği için satır ekleme bileşenler geliştirme hakkında daha fazla bilgi için bkz: Özel kaynak Bileşen geliştirme ve Bir zaman uyumsuz çıkışlarına ile özel dönüşümü Bileşen geliştirme.

Bileşenleri ters yönde bileşenlerinden satırları almak PipelineBuffer nesneler.veri akışı görevi sağlar bir PipelineBuffer veri akışı için bir parametre olarak ters yönde bileşenleri tarafından eklenen satırlar içeren nesne ProcessInput yöntem.Bu giriş arabelleği incelemek ve satır ve sütunları arabellekte değiştirmek için kullanılan, ancak satırları kaldırmak veya eklemek için kullanılamaz.The ProcessInput method is called repeatedly until there are no more available buffers.Son saat denir, EndOfRowset özellik true.Üzerinden yinelemek yapabilirsiniz koleksiyon kullanarak arabelleğindeki satır NextRow yöntem, ilerletir arabelleğe sonraki satır.Bu yöntem döndürür false arabellek olduğunda son satırdaki koleksiyon.Denetlenecek olan EndOfRowset özellik gerçekleştirmek bir ek olmadığı sürece eylem son satır verinin işlendikten sonra.

Aşağıdaki metni kullanarak için doğru deseni gösteren NextRow yöntem ve EndOfRowset özellik:

while (buffer.NextRow())

{

// Do something with each row.

}

if (buffer.EndOfRowset)

{

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

}

Aşağıdaki kod örneği sırasında giriş arabellekleri satırları bir bileşeni nasıl işlediğini gösterir ProcessInput yöntem.

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

Satır giriş arabellekleri bileşenler geliştirme hakkında daha fazla bilgi için bkz: Özel hedef Bileşen geliştirme ve Bir zaman uyumlu çıkışlarına ile özel dönüşümü Bileşen geliştirme.