dagger
dagger copied to clipboard
Implement BQ sink in Dagger using ODPF sink
Acceptance Criteria
-
Add Basic BigQuery Sink using the sink-connector APIs.
-
Configure Proto/JSON Serialiser to convert Row into OdpfMessage
-
Call sink APIs to push messages to BQ.
Out of scope:
-
No batching
-
No checkpointing.