PipelineBuffer Classe

Définition

public ref class PipelineBuffer : IDisposable

public class PipelineBuffer : IDisposable

type PipelineBuffer = class
    interface IDisposable

Public Class PipelineBuffer
Implements IDisposable

Héritage

Object

PipelineBuffer

Implémente

IDisposable

Exemples

L’exemple suivant montre un composant de transformation qui itère les lignes et colonnes de a PipelineBuffer dans 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.  
         }  
      }  
      }  
   }  
}  

L’exemple suivant montre un composant source qui ajoute des lignes au tampon de sortie dans 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();  
      }  
   }  
}  

Remarques

Il PipelineBuffer s’agit d’un magasin de données bidimensionnel en mémoire contenant des lignes et des colonnes. Il est créé par la tâche de flux de données et fourni aux composants de flux de données gérés lors de l’exécution. Les colonnes contenues dans un tampon sont basées sur les colonnes des IDTSOutputColumnCollection100 collections des composantes du graphe.

Les composants source et les composants avec des sorties asynchrones reçoivent un tampon pour chacun des objets de sortie connectés à un composant en aval. Ces tampons sont appelés tampons de sortie et ne contiennent pas de lignes. Le composant qui reçoit le tampon de sortie ajoute des lignes au tampon et appelle la SetEndOfRowset méthode une fois terminée. Cette méthode fixe la valeur de la EndOfRowset propriété à true sur le tampon final. La tâche de flux de données fournit alors ce tampon vers le composant suivant du graphe.

Les composantes de transformation avec sorties synchrones et composantes de destination reçoivent PipelineBuffer des objets dans la ProcessInput méthode. Le PipelineBuffer reçu dans cette méthode est un Input tampon et contient les lignes ajoutées par les composants en amont. Ce tampon est restreint et ne peut pas être utilisé pour ajouter ou retirer des lignes du tampon.

Il PipelineBuffer est écrit en code managé et prend en charge les développeurs de composants de flux de données managés en rassemblant les données entre le code managé et l’objet COM sous-jacent IDTSBuffer100 .

Pour une liste complète des types de données des Services d’intégration ainsi que des méthodes correspondantes GetSet de la PipelineBuffer classe à utiliser avec chaque type de données, voir Travailler avec les types de données dans le Data Flow.