AvroRecordSetWriter

Descrição

Grava o conteúdo de um RecordSet no formato Avro binário.

Tags

avro, record, recordset, result, row, serializer, set, writer

Propriedades

Na lista abaixo, as propriedades obrigatórias são mostradas com um asterisco (*). Outras propriedades são consideradas opcionais. A tabela também indica os valores padrão e se uma propriedade é compatível com linguagem de expressão NiFi.

Nome de exibição

Nome da API

Valor padrão

Valores permitidos

Descrição

Gravador de referência de esquema *

Gravador de referência de esquema

Implementação de serviço responsável por gravar atributos FlowFile ou cabeçalho de conteúdo com informações de referência de esquema

Estratégia de gravação de esquema *

Estratégia de gravação de esquema

avro-embedded

  • Incorpora o esquema Avro

  • Não grava o esquema

  • Define o atributo “schema.name”

  • Define o atributo “avro.schema”

  • Gravador de referência de esquema

Especifica como o esquema de um registro deve ser adicionado aos dados.

Tamanho do cache *

cache-size

1000

Especifica quantos esquemas devem ser armazenados em cache

Formato de compressão *

compression-format

NONE

  • BZIP2

  • DEFLATE

  • NONE

  • SNAPPY

  • LZO

Tipo de compressão a ser usado ao gravar arquivos Avro. O padrão é nenhum.

Tamanho do pool de codificadores *

encoder-pool-size

32

Os gravadores Avro exigem o uso de um codificador. A criação de codificadores é cara, mas, uma vez criados, eles podem ser reutilizados. Essa propriedade controla o número máximo de codificadores que podem ser agrupados e reutilizados. A configuração de um valor muito pequeno pode resultar em desempenho prejudicado, mas a configuração de um valor mais alto pode resultar no uso de mais heap. Essa propriedade é ignorada se o gravador do Avro estiver configurado com uma estratégia de gravação de esquema “ Incorpora o esquema Avro”.

Estratégia de acesso ao esquema *

schema-access-strategy

inherit-record-schema

  • Herda o esquema de registro

  • Usar a propriedade “Schema Name”

  • Use a propriedade “Schema Text”

Especifica como obter o esquema que deve ser usado para interpretar os dados.

Ramificação do esquema

schema-branch

Especifica o nome da ramificação a ser usada ao procurar o esquema na propriedade do registro de esquema. Se a propriedade do registro de esquema escolhida não for compatível com a ramificação, esse valor será ignorado.

Cache de esquema

schema-cache

Especifica um cache de esquema para o qual o esquema de registro será adicionado, permitindo que os Record Readers encontrem rapidamente o esquema.

Nome do esquema

schema-name

${schema.name}

Especifica o nome do esquema a ser pesquisado na propriedade do registro de esquema

Leitor de referência de esquema *

schema-reference-reader

Implementação do serviço responsável pela leitura dos atributos ou do conteúdo do FlowFile para determinar o identificador da referência de esquema

Registro de esquema

schema-registry

Especifica o Controller Service a ser usado para o registro de esquema

Texto do esquema

schema-text

${avro.schema}

O texto de um esquema formatado por Avro

Versão do esquema

schema-version

Especifica a versão do esquema a ser pesquisada no registro de esquema. Se não for especificada, será recuperada a versão mais recente do esquema.

Gerenciamento do estado

Esse componente não armazena o estado.

Restrito

Esse componente não é restrito.

Considerações sobre os recursos do sistema

Esse componente não especifica considerações sobre os recursos do sistema.