PipelineBuffer Clase

Definición

public ref class PipelineBuffer : IDisposable

public class PipelineBuffer : IDisposable

type PipelineBuffer = class
    interface IDisposable

Public Class PipelineBuffer
Implements IDisposable

Herencia

Object

PipelineBuffer

Implementaciones

IDisposable

Ejemplos

En el ejemplo siguiente se muestra un componente de transformación que recorre en iteración las filas y columnas de en 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.  
         }  
      }  
      }  
   }  
}  

En el ejemplo siguiente se muestra un componente de origen que agrega filas al búfer de salida en 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();  
      }  
   }  
}  

Comentarios

PipelineBuffer es un almacén de datos bidimensional en memoria que contiene filas y columnas. Se crea mediante la tarea de flujo de datos y se proporciona a los componentes de flujo de datos administrados durante la ejecución. Las columnas contenidas en un búfer se basan en las columnas de las IDTSOutputColumnCollection100 colecciones de los componentes del gráfico.

Los componentes y componentes de origen con salidas asincrónicas reciben un búfer para cada uno de los objetos de salida que están conectados a un componente de bajada. Estos búferes se conocen como búferes de salida y no contienen filas. El componente que recibe el búfer de salida agrega filas al búfer y llama al SetEndOfRowset método cuando termine. Este método establece el valor de la EndOfRowset propiedad true en en el búfer final. A continuación, la tarea flujo de datos proporciona ese búfer al siguiente componente del grafo.

Los componentes de transformación con salidas sincrónicas y componentes de destino reciben PipelineBuffer objetos en el ProcessInput método . El PipelineBuffer objeto recibido en este método es un Input búfer y contiene las filas que se agregaron a los componentes ascendentes. Este búfer está restringido y no se puede usar para agregar o quitar filas del búfer.

PipelineBuffer se escribe en código administrado y admite desarrolladores de componentes de flujo de datos administrados mediante la serialización de datos entre código administrado y el objeto COM subyacenteIDTSBuffer100.

Para obtener una lista completa de los tipos de datos de Integration Services y los métodos y Set correspondientes Get de la PipelineBuffer clase que se van a usar con cada tipo de datos, vea Trabajar con tipos de datos en el Data Flow.

Constructores

Propiedades

Métodos

Se aplica a