PipelineBuffer Classe

Definição

public ref class PipelineBuffer : IDisposable

public class PipelineBuffer : IDisposable

type PipelineBuffer = class
    interface IDisposable

Public Class PipelineBuffer
Implements IDisposable

Herança

Object

PipelineBuffer

Implementações

IDisposable

Exemplos

O exemplo a seguir mostra um componente de transformação que itera as linhas e colunas de um PipelineBuffer in 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.  
         }  
      }  
      }  
   }  
}  

O exemplo a seguir mostra um componente de origem que adiciona linhas ao buffer de saída em 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();  
      }  
   }  
}  

Comentários

Trata-se PipelineBuffer de um armazenamento de dados bidimensional na memória que contém linhas e colunas. Ele é criado pela tarefa de fluxo de dados e fornecido para componentes de fluxo de dados gerenciados durante a execução. As colunas contidas em um buffer são baseadas nas colunas nas IDTSOutputColumnCollection100 coleções dos componentes no grafo.

Componentes e componentes de origem com saídas assíncronas recebem um buffer para cada um dos objetos de saída conectados a um componente downstream. Esses buffers são chamados de buffers de saída e não contêm linhas. O componente que recebe o buffer de saída adiciona linhas ao buffer e chama o SetEndOfRowset método quando concluído. Esse método define o valor da EndOfRowset propriedade como true no buffer final. Em seguida, a tarefa de fluxo de dados fornece esse buffer para o próximo componente no grafo.

Componentes de transformação com saídas síncronas e componentes de destino recebem PipelineBuffer objetos no ProcessInput método. O PipelineBuffer recebido neste método é um Input buffer e contém as linhas que foram adicionadas por componentes upstream. Esse buffer é restrito e não pode ser usado para adicionar ou remover linhas do buffer.

Ele PipelineBuffer é escrito em código gerenciado e dá suporte a desenvolvedores de componentes de fluxo de dados gerenciados por meio do marshalling de dados entre o código gerenciado e o objeto COM subjacente IDTSBuffer100 .

Para obter uma lista completa de tipos de dados do Integration Services e os métodos e Set correspondentes Get da classe a PipelineBuffer serem usados com cada tipo de dados, consulte Trabalhando com tipos de dados no Fluxo de Dados.

Construtores

Propriedades

Métodos

Aplica-se a