PipelineBuffer 클래스

정의

public ref class PipelineBuffer : IDisposable

public class PipelineBuffer : IDisposable

type PipelineBuffer = class
    interface IDisposable

Public Class PipelineBuffer
Implements IDisposable

상속

Object

PipelineBuffer

구현

IDisposable

예제

다음 예제에서는 in의 PipelineBufferProcessInput행과 열을 반복하는 변환 구성 요소를 보여 줍니다.

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 호출합니다. 이 메서드는 속성 true 의 EndOfRowset 값을 최종 버퍼에 설정합니다. 그런 다음 데이터 흐름 태스크는 그래프의 다음 구성 요소에 해당 버퍼를 제공합니다.

동기 출력 및 대상 구성 요소가 있는 변환 구성 요소는 메서드의 개체를 ProcessInput 받 PipelineBuffer 습니다. PipelineBuffer 이 메서드에서 받은 버퍼이며 Input 업스트림 구성 요소에 의해 추가된 행을 포함합니다. 이 버퍼는 제한되며 버퍼에서 행을 추가하거나 제거하는 데 사용할 수 없습니다.

관리 PipelineBuffer 코드로 작성되며 관리 코드와 기본 COM 개체 간에 데이터를 마샬링하여 관리되는 데이터 흐름 구성 요소 개발자를 IDTSBuffer100 지원합니다.

Integration Services 데이터 형식의 전체 목록과 각 데이터 형식에 사용할 클래스의 PipelineBuffer 해당 Get 및 Set 메서드는 Data Flow 데이터 형식 작업을 참조하세요.

생성자

속성

메서드

적용 대상