PipelineBuffer クラス

定義

public ref class PipelineBuffer : IDisposable

public class PipelineBuffer : IDisposable

type PipelineBuffer = class
    interface IDisposable

Public Class PipelineBuffer
Implements IDisposable

継承

Object

PipelineBuffer

実装

IDisposable

例

次の例は、PipelineBuffer で ProcessInput の行および列を繰り返す変換コンポーネントを示します。

using System;  
using Microsoft.SqlServer.Dts;  
using Microsoft.SqlServer.Dts.Pipeline;  
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;  
using Microsoft.SqlServer.Dts.Runtime.Wrapper;  

namespace Microsoft.Samples.SqlServer.Dts  
{  
   [DtsPipelineComponent  
   (  
   DisplayName="SampleComponent",  
   ComponentType=ComponentType.Transform  
   )]  
   public class SampleComponent: PipelineComponent  
   {  
      public override void ProvideComponentProperties()  
      {  
         base.ProvideComponentProperties();  

         ///Name the input and output add by the base class.  
         ComponentMetaData.InputCollection[0].Name = "SampleInput";  
         ComponentMetaData.OutputCollection[0].Name = "SampleOutput";  
      }  

      public override void ProcessInput(int inputID, PipelineBuffer buffer)  
      {  

      IDTSInput100 input = ComponentMetaData.InputCollection.GetObjectByID(inputID);  

      while (buffer.NextRow())  
      {  
         foreach (IDTSInputColumn100 col in input.InputColumnCollection)  
         {  
            int colIndex = BufferManager.FindColumnByLineageID(input.Buffer,col.LineageID);  
            object colData = buffer[colIndex];  
            //TODO: Do something with the column data.  
         }  
      }  
      }  
   }  
}  

次の例は、PrimeOutput の出力バッファーに行を追加する、基になるコンポーネントを示します。

using System;  
using Microsoft.SqlServer.Dts;  
using Microsoft.SqlServer.Dts.Pipeline;  
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;  
using Microsoft.SqlServer.Dts.Runtime.Wrapper;  

namespace Microsoft.Samples.SqlServer.Dts  
{  
   [DtsPipelineComponent  
   (  
      DisplayName="SampleComponent",  
      ComponentType=ComponentType.SourceComponent  
)]  
   public class SampleComponent: PipelineComponent  
   {  
      public override void PrimeOutput(int outputs, int[] outputIDs,PipelineBuffer[] buffers)  
      {  
         int rows = 100;  
         PipelineBuffer buf = buffers[0];  
         IDTSOutput100 output = ComponentMetaData.OutputCollection[0];  
         Random rand = new Random();  

         //Loop rows number of times  
         for(int r = 0; r < rows; r++)  
         {  
            buf.AddRow();  
            foreach( IDTSOutputColumn100 col in output.OutputColumnCollection)  
            {  
               int colIndex = BufferManager.FindColumnByLineageID( output.Buffer, col.LineageID);  
               // Note, buffer columns containing binary large objects  
               // can not be set using the following syntax. Instead,  
               // the AddBlobData and SetBytes methods are used.  
               buf[colIndex] = rand.Next();  
            }  
         }  
         buf.SetEndOfRowset();  
      }  
   }  
}  

注釈

PipelineBuffer は、行と列を含む、メモリ内の 2 次元データ ストアです。 これは実行中にデータ フロー タスクによって作成され、マネージド データ フロー コンポーネントに提供されます。 バッファーに含まれる列は、グラフのコンポーネントの IDTSOutputColumnCollection100 コレクションの列に基づきます。

基になるコンポーネントと非同期出力のコンポーネントは、下流コンポーネントに接続されている出力オブジェクトごとにバッファーを受信します。 これらのバッファーは出力バッファーと呼ばれるものであり、行は格納されていません。 出力バッファーを受信するコンポーネントは、バッファーに行を追加し、完了したら SetEndOfRowset メソッドを呼び出します。 このメソッドにより、最終バッファーの EndOfRowset プロパティの値が true に設定されます。 データ フロー タスクは、このバッファーをグラフの次のコンポーネントに提供します。

同期出力の変換コンポーネントと対象になるコンポーネントは、PipelineBuffer メソッドで ProcessInput オブジェクトを受信します。 このメソッドで受信される PipelineBuffer は、Input バッファーで、上流コンポーネントによって追加された行が含まれています。 このバッファーは制限されており、行の追加に使用したり、このバッファーから行を削除することはできません。

PipelineBuffer は、マネージド コードで記述され、マネージド コードと基になる IDTSBuffer100 COM オブジェクトとの間でデータをマーシャリングすることで、マネージド データ フロー コンポーネント開発者をサポートします。

Integration Services データ型の完全な一覧と、各データ型で使用するクラスのPipelineBuffer対応するGetSetメソッドについては、「Data Flowでのデータ型の操作」を参照してください。

コンストラクター

プロパティ

メソッド

適用対象