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 двухмерное хранилище данных в памяти, содержащее строки и столбцы. Она создается задачей потока данных и предоставляется компонентам управляемого потока данных во время выполнения. Столбцы, содержащиеся в буфере, основаны на столбцах в IDTSOutputColumnCollection100 коллекциях компонентов графа.

Исходные компоненты и компоненты с асинхронными выходными данными получают буфер для каждого выходного объекта, подключенного к подчиненному компоненту. Эти буферы называются выходными буферами и не содержат строки. Компонент, получающий выходной буфер, добавляет строки в буфер и вызывает SetEndOfRowset метод по завершении. Этот метод задает значение EndOfRowset свойства true в последнем буфере. Затем задача потока данных предоставляет этот буфер следующему компоненту в графе.

Компоненты преобразования с синхронными выходными данными и целевыми компонентами получают PipelineBuffer объекты в методе ProcessInput . Полученный PipelineBuffer в этом методе Input буфер и содержит строки, добавленные вышестоящими компонентами. Этот буфер ограничен и не может использоваться для добавления или удаления строк из буфера.

Он PipelineBuffer написан в управляемом коде и поддерживает разработчиков компонентов управляемого потока данных путем маршалинга данных между управляемым кодом и базовым IDTSBuffer100 COM-объектом.

Полный список типов данных Служб Integration Services и соответствующих и методов класса для использования с каждым типом данных см. в разделе "Работа с типами данных" в Поток данных.PipelineBufferSetGet

Конструкторы

Свойства

Методы

Применяется к