Microsoft.StreamProcessing Namespace

Classes

Afa	Métodos de extensão para criar um objeto AFA
Afa<TInput,TRegister>	Uma forma mais simples de AFA cujo acumulador é um booliano simples indicando que o padrão correspondeu
Afa<TInput,TRegister,TAccumulator>	Classe que descreve completamente uma AFA, juntamente com suas propriedades.
AfaPlanNode	Um nó no plano de consulta que representa o aplicativo de funções para todas as linhas de entrada.
AlterLifetimePlanNode	Um nó no plano de consulta que representa uma alteração nos tempos de vida do evento para uma duração variável na consulta ativa e em execução.
ARegex	Classe Builder para criar padrões nos quais corresponder dados de fluxo usando uma interface de expressão regular
BeatPlanNode	Um nó no plano de consulta que representa a separação de cada evento linha do tempo em intervalos iguais.
ClipByConstantPlanNode	Um nó no plano de consulta que representa uma operação de truncamento de tempo de vida ("ClipByConstant") na consulta ativa e em execução.
ColumnToRowPlanNode	Um nó no plano de consulta que representa uma mudança de dados orientados a colunas para orientados a linhas na consulta ativa e em execução.
Config	Classe estática que contém todas as configurações do usuário.
DisorderPolicy	Especifica como lidar com eventos fora de ordem
EgressPlanNode	Um nó no plano de consulta que representa uma fonte de dados na consulta ativa e em execução.
EndEdgeFreeOutputPlanNode	Um nó no plano de consulta que representa o aplicativo de funções para todas as linhas de entrada.
EqualityComparerExpression<T>	Fornece uma implementação para encapsular duas funções em um IEqualityComparerExpression<T>.
EvolvingStateEnumerable<TPayload>	Um objeto enumerável cujo conteúdo está sujeito a alterações à medida que dados adicionais ficam disponíveis em um fluxo.
ExtendLifetimePlanNode	Um nó no plano de consulta que representa uma operação de extensão de tempo de vida ("ExtendLifetime") na consulta ativa e em execução.
FilteredWindow<TKey,TSource>	Classe derivada de Window em que a semântica adicional é aplicada quando um filtro está presente
FusedPlanNode	Um nó no plano de consulta que representa uma fonte de dados na consulta ativa e em execução.
GroupedWindowPlanNode<TInput,TState,TResult>	Um nó no plano de consulta que representa uma janela agrupada instantâneo operação.
GroupPlanNode	Representa uma operação de agrupamento em um processo de Map-Reduce.
IngressException	Exceção específica de um erro que ocorre durante a entrada de dados.
IngressPlanNode	Um nó no plano de consulta que representa uma fonte de dados na consulta ativa e em execução.
JoinPlanNode	Um nó no plano de consulta que representa uma operação de junção na consulta ativa e em execução.
MulticastPlanNode	Representa uma operação em um fluxo para permitir que vários assinantes recebam as mesmas mensagens.
OnCompletedPolicy	Especifica como lidar com a conclusão da consulta (ao receber uma chamada OnCompleted).
OutOfOrderPartitionedStreamEvent	Classe estática que contém métodos geradores para objetos OutOfOrderPartitionedStreamEvent.
OutOfOrderStreamEvent	Classe estática que contém métodos geradores para objetos OutOfOrderStreamEvent.
PartitionedDisorderPolicy	Especifica como lidar com eventos fora de ordem
PartitionedPeriodicPunctuationPolicy	Especifica como injetar pontuações no fluxo resultante. Como as pontuações forçam a saída, isso expõe uma compensação de taxa de transferência/latência.
PartitionedStreamEvent	Auxiliares de eventos de fluxo particionados que não dependem de argumentos genéricos.
PeriodicPunctuationPolicy	Especifica como injetar pontuações no fluxo resultante. Como as pontuações forçam a saída, isso expõe uma compensação de taxa de transferência/latência.
PlanNode	Um nó no plano de consulta que representa os objetos na consulta ativa e em execução.
PointAtEndPlanNode	Um nó no plano de consulta que representa uma transformação de tempo de vida movendo o tempo de vida para uma operação de intervalo de unidade ("PointAtEnd") na consulta ativa e em execução.
Process	Uma classe que representa uma consulta em execução que pode ser ponto de verificação.
Properties	Métodos de extensão que podem ser transmitidos.
QuantizeLifetimePlanNode	Um nó no plano de consulta que representa uma transformação de tempo de vida que quantifica os horários de início e término ao longo dos limites de salto na consulta ativa e em execução.
QueryContainer	Um objeto de contêiner que representa uma consulta de fluxo.
ReshapingPolicy	Política que especifica se e como os eventos são remodelados na saída
RowToColumnPlanNode	Um nó no plano de consulta que representa uma mudança dos dados orientados para a coluna na consulta ativa e em execução.
SelectBatchPlanNode	Um nó no plano de consulta que representa o aplicativo de funções para todas as linhas de entrada.
SelectManyPlanNode	Um nó no plano de consulta que representa uma operação SelectMany na consulta ativa e em execução.
SelectPlanNode	Um nó no plano de consulta que representa o aplicativo de funções para todas as linhas de entrada.
SessionWindowPlanNode	Um nó no plano de consulta que representa uma operação de truncamento de janela de sessão ("SessionTimeoutWindow") na consulta ativa e em execução.
SnapshotWindowPlanNode<TInput,TState,TResult>	Um nó no plano de consulta que representa uma janela em lote instantâneo operação.
SprayPlanNode	Representa uma operação em um trabalho Map-Reduce que pulveriza dados em nós diferentes.
StitchPlanNode	Um nó no plano de consulta que representa uma unificação de eventos semelhantes com intervalos de tempo de vida adjacentes.
Streamable	Métodos de extensão que podem ser transmitidos.
StreamCache<TKey,TPayload>	Armazena um fluxo completo de maneira altamente eficiente e amigável para iteração subsequente os dados.
StreamEvent	Auxiliares de eventos de fluxo que não dependem de argumentos genéricos.
StreamProcessingException	Representa uma exceção de usuário em algum lugar dentro do
StreamProperties<TKey,TPayload>	Classe que contém o conjunto de propriedades de fluxo para o fluxo
StreamScheduler	Classe para definir a estratégia de agendamento para trill (via Microsoft.StreamProcessing.Config. StreamScheduler)
TemporalSortPlanNode	Um nó no plano de consulta que representa uma operação de classificação temporal (em carimbos de data/hora) na consulta ativa e em execução.
TimelinePolicy	Especifica como atribuir um componente temporal de aumento monotonicamente a dados intrinsecamente atemporais.
UngroupPlanNode	Representa uma operação de desagrupamento em um processo de Map-Reduce.
UnionPlanNode	Indica que o nó atual é uma operação de união.
UserDefinedPlanNode<TKey,TSource,TResult>	Um nó no plano de consulta que representa uma operação definida fora da biblioteca.
WherePlanNode	Um nó no plano de consulta que representa uma operação de filtragem ("where") na consulta ativa e em execução.
Window<TKey,TSource>	Classe que representa uma janela dentro de uma operação de agregação.

Estruturas

Empty	Um tipo que representa o struct vazio, semelhante à Unidade em outras bibliotecas e idiomas.
OutOfOrderPartitionedStreamEvent<TKey,TPayload>	Uma estrutura para representar quando uma tupla teve que ser ajustada ou descartada de uma fonte de entrada de dados.
OutOfOrderStreamEvent<TPayload>	Uma estrutura para representar quando uma tupla teve que ser ajustada ou descartada de uma fonte de entrada de dados.
PartitionedStreamEvent<TKey,TPayload>	Representa um evento do Stream particionado
StreamEvent<TPayload>	Representa um evento stream não particionado

Interfaces

IAbstractPattern<TKey,TPayload,TRegister,TAccumulator>	A interface só é pública para atender à digitação forte clr – as instâncias só devem ser criadas internamente. Não use diretamente.
IAbstractPatternRoot<TKey,TPayload,TRegister,TAccumulator>	A interface só é pública para atender à digitação forte clr – as instâncias só devem ser criadas internamente. Não use diretamente.
IComparerExpression<T>	Uma interface wrapper de uma expressão para comparar dois valores do tipo especificado.
IConnectableStreamable<TKey,TPayload>	Interface para conectar dinamicamente novas saídas que podem ser transmitidas a um fluxo existente
IEqualityComparerExpression<T>	Uma interface que fornece uma maneira baseada em expressão de especificar a mesma coisa que IComparer<T> : uma função para igualdade e uma função para calcular um hash.
IIngressStreamable<TKey,TPayload>	Uma interface correspondente a um que pode ser transmitido em um ponto de entrada para uma consulta.
IMapDefinition<TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput>	Interface de espaço reservado para uma operação que representa uma função de redução de mapa
IMapDefinition<TOuterKey,TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput>	Interface de espaço reservado para uma operação que representa uma função de redução de mapa
IObservableIngressStreamable<TPayload>	Uma interface correspondente a um streamable em um ponto de entrada para uma consulta em que a entrada pode estar fora de ordem.
IPartitionedIngressStreamable<TPartitionKey,TPayload>	Uma interface correspondente a um streamable em um ponto de entrada para uma consulta em que a entrada pode estar fora de ordem.
IPassiveIngressStreamable<TKey,TPayload>	Interface para um site de entrada passivo que pode ser disparado externamente para ler os dados disponíveis.
IPattern<TKey,TPayload,TRegister,TAccumulator>	A interface só é pública para atender à digitação forte clr – as instâncias só devem ser criadas internamente. Não use diretamente.
IStreamable<TKey,TPayload>	Interface primária para operações que podem ser transmitidas – os usuários não devem criar novas classes que implementam essa interface sem comunicação direta com a equipe de desenvolvimento

Enumerações

AggregatePipeType	Uma enumeração dos tipos de algoritmo de gerenciamento de estado disponíveis.
JoinKind	Descreve o tipo de junção usado em um nó de plano de consulta de junção específico.
OperationalHint	Fornece uma dica sobre quais métodos devem ser usados para um operador
PlanNodeKind	O tipo de nó do plano.
SortingTechnique	Escolhas para qual técnica deve ser usada na entrada de dados para classificar quaisquer dados fora de ordem.
StreamEventKind	Tipos de evento para StreamEvents em linha
StreamMessageKind	Transmitir tipos de mensagens para mensagens individuais passando por uma consulta