linkedin / venice

Venice, Derived Data Platform for Planet-Scale Workloads.
https://venicedb.org
BSD 2-Clause "Simplified" License
487 stars 84 forks source link

[vpj] Kafka ingestion into rows of a data frame via Spark Table API #1227

Closed eldernewborn closed 2 weeks ago

eldernewborn commented 3 weeks ago

[vpj] Spark input module to read from a Kafka topic and populate a dataframe

How was this PR tested?

unit tests, integration tests, manual testing.

Does this PR introduce any user-facing changes?