LoreonLabsPlatform

Overview

Intelligence

Markets
Builders
Research
Narratives
Ecosystems
Launchpads

Discover

Search
Sources

Java

beam-kafka-to-bigquery

Example beam pipelines

JavaEmerging

Stars

—

Forks

1

Contributors

1

Last push

29mo ago

Recent commits

Latest commits.

Updated README and information messages
d720fbfBhupinder Sindhwani29mo ago
address AVRO types such as ENUMS writing it as AVRO using withAvroFormatFunction and Storage Write APIs
899feecBhupinder Sindhwani29mo ago
Refactored code to remove placeholder (ad-hoc) schema conversion and use Beam default classes
6afdeb5Bhupinder Sindhwani29mo ago
Updated README
eaf2554Bhupinder Sindhwani29mo ago
updated readme
6c67d84Bhupinder Sindhwani

29mo ago

KafkaAvroExampleDynamicGraph to dynamically create multiple disjointed graphs based on the list of topics to read using .withTopic method and write to BQ using dyanmic destinations

c053ae1Bhupinder Sindhwani29mo ago

cbaf8eeBhupinder Sindhwani29mo ago

KafkaAvroExample to read data from multiple topics using .withTopics and write to BQ using dynamic destinations

dd8bb2fBhupinder Sindhwani29mo ago

Top contributors

Builders behind this project.