PipelineBuffer クラス
定義
重要
一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。
データの行と列を含むメモリ内のデータ ストアを提供します。
public ref class PipelineBuffer : IDisposablepublic class PipelineBuffer : IDisposabletype PipelineBuffer = class
interface IDisposablePublic Class PipelineBuffer
Implements IDisposable- 継承
-
PipelineBuffer
- 実装
例
次の例は、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でのデータ型の操作」を参照してください。
コンストラクター
| PipelineBuffer(IntPtr, PipelineBufferMode) |
PipelineBuffer の新しいインスタンスをインスタンス化します。 |
| PipelineBuffer(UInt32, UInt32, UInt64, IntPtr*, DTP_BUFFCOL*, Boolean) |
PipelineBuffer クラスの新しいインスタンスを初期化します。 |
プロパティ
| ColumnCount |
PipelineBuffer の列数を取得します。 |
| ColumnInfo |
列に関する読み取り専用のメタデータを取得します。 |
| CurrentRow |
PipelineBuffer での現在の行のインデックスを取得します。 |
| EndOfRowset |
現在の PipelineBuffer が最終バッファーかどうかを示す値を取得します。 |
| Item[Int32] |
現在の行の指定された列の値 |
| Mode |
PipelineBuffer が IDTSInput100 バッファーなのか、IDTSOutput100 バッファーなのかを示す値を取得します。 |
| RowCount |
PipelineBuffer オブジェクトの行数を取得します。 |
| RowSize |
PipelineBuffer オブジェクトの行のサイズを取得します。 |
| RowStarts |
行の開始点を取得します。 |