[
https://issues.apache.org/jira/browse/BEAM-11338?focusedWorklogId=523334&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-523334
]
ASF GitHub Bot logged work on BEAM-11338:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 11/Dec/20 22:42
Start Date: 11/Dec/20 22:42
Worklog Time Spent: 10m
Work Description: TheNeuralBit commented on pull request #13428:
URL: https://github.com/apache/beam/pull/13428#issuecomment-743464814
> I guess what you're saying is that the right approach would be to make use
of some BeamKafkaThriftTable extending BeamKafkaTable and just read/write bytes
from/to Kafka.
Yes exactly! Ideally we'd add similar support for PubSub, but as it stands
that will require duplicating code.
> So do expect a follow-up PR, unless you think this schema provider alone
does not really deserve to be merged by itself. I will also have a closer look
at the current abstractions and file Jiras for potential improvements if I'll
be able to come up with
any.
Oh this PR is certainly useful on it's own! I just wanted to gauge the need
for further work. If you'd like to build on this I can help point you in the
right direction.
> P.S. as a side joke: you misspelled my name in a way that also changes my
gender (at least in my native language), but it sounds so funny that I'm
thinking of changing my username to that. :)
Ah I'm so sorry! I guess typing "data" is very strong in my muscle memory
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 523334)
Time Spent: 4h 20m (was: 4h 10m)
> Beam schema for thrift data
> ---------------------------
>
> Key: BEAM-11338
> URL: https://issues.apache.org/jira/browse/BEAM-11338
> Project: Beam
> Issue Type: New Feature
> Components: io-java-utilities
> Reporter: Costi Ciudatu
> Assignee: Costi Ciudatu
> Priority: P2
> Labels: thrift
> Time Spent: 4h 20m
> Remaining Estimate: 0h
>
> Define a SchemaProvider that can handle thrift objects, the same way as
> ProtoMessageSchema handles protobuf.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
