Aracılığıyla paylaş


PipelineComponent.ProcessInput Yöntemi

Çalışma zamanında adı verilen saat bir PipelineBuffer ters yönde bir bileşen tarafından kullanılabilir bileşen seçeyim bileşeni işlem gelen satırları.

Ad Alanı:  Microsoft.SqlServer.Dts.Pipeline
Derleme:  Microsoft.SqlServer.PipelineHost (Microsoft.SqlServer.PipelineHost içinde.dll)

Sözdizimi

'Bildirim
Public Overridable Sub ProcessInput ( _
    inputID As Integer, _
    buffer As PipelineBuffer _
)
'Kullanım
Dim instance As PipelineComponent
Dim inputID As Integer
Dim buffer As PipelineBuffer

instance.ProcessInput(inputID, buffer)
public virtual void ProcessInput(
    int inputID,
    PipelineBuffer buffer
)
public:
virtual void ProcessInput(
    int inputID, 
    PipelineBuffer^ buffer
)
abstract ProcessInput : 
        inputID:int * 
        buffer:PipelineBuffer -> unit 
override ProcessInput : 
        inputID:int * 
        buffer:PipelineBuffer -> unit 
public function ProcessInput(
    inputID : int, 
    buffer : PipelineBuffer
)

Parametreler

Açıklamalar

ProcessInput Sağlamaya yönelik tam bileşen yöntem çağrılır PipelineBuffer nesne içeren satırları ters yönde bir bileşen.Tanımlanan bu sütunlar arabellekte bulunan sütunlar dahil IDTSInputColumnCollection100 bileşeni.Zaman uyumlu çıkışlarına bileşen varsa, arabellek da dahil sütunçıkışı eklendi s sütun bileşen ve tüm koleksiyonda sütuns çıktı sütun bileşeninden upstream bileşen koleksiyonudur.Sütunları bir arabellek satır kullanımında bulunan FindColumnByLineageID yöntem, BufferManager.

ProcessInputters yönde bileşenlerini tam arabellek veri akışı görevi alır gibi sürekli olarak adlandırılır.ProcessInputyöntem Kadar adlı EndOfRowset özellik doğru.

Kullanmak için doğru desen NextRow yöntem ve EndOfRowset özellik:

(sırasında arabellek.NextRow())

{

/ / Her satırın bir şey yapın.

}

yoksa (arabellek.EndOfRowset)

{

/ / Tüm satırlar işlendikten sonra isteğe bağlı olarak, bir şey yapın.

}

Örnekler

public override void ProcessInput( int inputID, PipelineBuffer buffer )
{
    while( buffer.NextRow() )
    {
        // TODO: Read or write data to the columns in the buffer.
    }
}
Public Overrides Sub ProcessInput(ByVal inputID As Integer, ByVal buffer As PipelineBuffer) 
 While buffer.NextRow 
  ' TODO: Read or write data to the columns in the buffer.
 End While 
End Sub