共用方式為


PipelineComponent.ProcessInput Method

Called at run time when a PipelineBuffer from an upstream component is available to the component to let the component process the incoming rows.

命名空間: Microsoft.SqlServer.Dts.Pipeline
組件: Microsoft.SqlServer.PipelineHost (in microsoft.sqlserver.pipelinehost.dll)

語法

'宣告
Public Overridable Sub ProcessInput ( _
    inputID As Integer, _
    buffer As PipelineBuffer _
)
public virtual void ProcessInput (
    int inputID,
    PipelineBuffer buffer
)
public:
virtual void ProcessInput (
    int inputID, 
    PipelineBuffer^ buffer
)
public void ProcessInput (
    int inputID, 
    PipelineBuffer buffer
)
public function ProcessInput (
    inputID : int, 
    buffer : PipelineBuffer
)

參數

  • inputID
    The ID of the input of the component.

備註

The ProcessInput method is called to provide the component a full PipelineBuffer object that contains rows from the upstream component. The columns contained in buffer include those columns defined in the IDTSInputColumnCollection90 of the component. If the component has synchronous outputs, the buffer will also include the columns added to the output column collection by the component, and all the columns in the output column collection of the components upstream from the component. Columns are located in a buffer row using the FindColumnByLineageID method of the BufferManager.

ProcessInput will be called repeatedly as the data flow task receives full buffers from the upstream components. The final call to ProcessInput is confirmed when the EndOfRowset property is true.

範例

public override void ProcessInput( int inputID, PipelineBuffer buffer )
{
    if( !buffer.EndOfRowset)
    {
        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) 
 If Not buffer.EndOfRowset Then 
   While buffer.NextRow 
    ' TODO: Read or write data to the columns in the buffer.
   End While 
 End If 
End Sub

執行緒安全性

Any public static (Shared in Microsoft Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.

平台

開發平台

如需受支援的平台清單,請參閱<安裝 SQL Server 2005 的硬體和軟體需求>。

目標平台

如需受支援的平台清單,請參閱<安裝 SQL Server 2005 的硬體和軟體需求>。

請參閱

參考

PipelineComponent Class
PipelineComponent Members
Microsoft.SqlServer.Dts.Pipeline Namespace