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
- inputID
Tür: System.Int32
Bileşenin giriş kimliği.
- buffer
Tür: Microsoft.SqlServer.Dts.Pipeline.PipelineBuffer
PipelineBuffer Nesne.
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