[
https://issues.apache.org/jira/browse/SAMZA-2777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708063#comment-17708063
]
Eric Honer commented on SAMZA-2777:
-----------------------------------
[PR#1661|#1661] submitted.
> Add support for GenericFixed to AzureBlobAvroWriter
> ---------------------------------------------------
>
> Key: SAMZA-2777
> URL: https://issues.apache.org/jira/browse/SAMZA-2777
> Project: Samza
> Issue Type: Bug
> Reporter: Aditya Toomula
> Priority: Major
> Time Spent: 10m
> Remaining Estimate: 0h
>
> Add support for avro type {{GenericFixed}} to
> {{{}AzureBlobAvroWriter.write(){}}}. This will allow the caller to provide
> both {{Schema}} and an encoded message when sending messages to the
> {{{}SystemProducer{}}}. This types avoids the message encoding required by
> {{IndexedRecord}} and still provides the {{Schema}} to the writer instance.
> The existing {{AzureBlobAvroWriter}} allows either an {{IndexedRecord}} or a
> {{{}byte[]{}}}, but requires that the first message is *always* an
> {{{}IndexedRecord{}}}. The existing writer uses the first message to "set"
> the {{{}Schema, }}subsequent messages can be \{{{}byte[]{}}}s. This requires
> the sender be aware of the writer's internal state and how it's state is
> changed by {{flush()}} and {{{}close(){}}}. The writer can use the
> {{GenericFixed}} to "set" the {{Schema}} since the {{Schema}} is provided by
> the common parent type {{{}GenericContainer{}}}.
>
> Avro reference:
> *
> [GenericFixed|https://avro.apache.org/docs/1.7.7/api/java/org/apache/avro/generic/GenericFixed.html]
> *
> [GenericContainer|https://avro.apache.org/docs/1.7.7/api/java/org/apache/avro/generic/GenericContainer.html]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
