Issues
- 1
- 0
docs: create Examples module containing walk-throughs of common dagger features
#219 opened by Meghajit - 0
- 0
- 4
Gradle script does not run on M1 chipsets
#199 opened by stym06 - 0
Docker compose setup for dagger quickstart
#207 opened by sumitaich1998 - 1
Use of python UDF with external third-party dependencies is not supported in Flink SQL-query.
#205 opened by Shreyansh228 - 0
Add Support for Http Sink
#204 opened by jesrypandawa - 1
feat: Create sink-connectors repo and add atleast one sink with one abstraction
#126 opened by gauravsinghania - 0
feat: enable metrics to be sent by BigQuery Sink
#197 opened by Meghajit - 6
runFlink fails on fresh checkout repo
#191 opened by yz-chime - 0
Implement BQ sink in Dagger using ODPF sink
#132 opened by gauravsinghania - 0
- 0
docs: update documentation images and other sections to account for Parquet Source
#189 opened by Meghajit - 1
docs: add documentation for BQ sink in Dagger
#188 opened by Meghajit - 0
- 1
test: Load test Parquet Data Source and get throughput and memory requirements
#106 opened by Meghajit - 1
- 1
- 0
feat: Create a Parquet Data Source with ability to read and process primitive data types from a parquet file
#99 opened by Meghajit - 0
test: Add integration test for Parquet Data Source
#107 opened by Meghajit - 0
feat: Handle complex/nested data types from a parquet file in Parquet Data Source: Struct, Repeated Struct, Maps and Timestamp of type SimpleGroup
#137 opened by Meghajit - 0
- 1
feat: implement checkpointing and state persistence for Parquet Reader and FileSource
#127 opened by Meghajit - 1
feat: Add metrics for Parquet DataSource
#108 opened by Meghajit - 0
- 0
- 0
Darts udf cache not getting refreshed
#87 opened by mayankrai09 - 0
analyze: Support for python UDFs
#123 opened by gauravsinghania - 2
feat: Conglomerate and update dagger dependencies
#166 opened by Meghajit - 1
feat: Parquet DataSource should provide ability to read multiple GCS buckets for creating multiple streams
#105 opened by Meghajit - 1
feat: Analyse different strategies and add validation for missing fields in parquet data compared to protobuf schema
#102 opened by Meghajit - 1
feat: implement IndexOrderedSplitAssigner
#128 opened by Meghajit - 0
- 0
feat: Add ability to read and process complex/nested data types from a parquet file in Parquet Data Source: enums, repeated enums, message, repeated message, repeated primitives
#100 opened by Meghajit - 0
feat: Add support for reading files from a GCS bucket for Parquet Data Source
#103 opened by Meghajit - 0
feat: Parquet DataSource should provide ability to read selective folders within a GCS bucket for the same stream
#104 opened by Meghajit - 0
doc: Add documentation+FAQs for Parquet DataSource
#109 opened by Meghajit - 0
Handle missing configs, extra whitespaces or incorrect config values for Parquet Source
#150 opened by Meghajit - 0
- 0
feat: Add support for kafka consumer
#125 opened by gauravsinghania - 2
Dagger test case are failing in EsResponseHandlerTest while setting it up locally ./gradlew clean build
#84 opened by shubhangi-1 - 0
Add support for Flink 1.14
#86 opened by ravisuhag - 1
Use odpf stencil client
#60 opened by prakharmathur82 - 0
Add Count Window Transformer
#64 opened by prakharmathur82 - 0
Support for Distributed tracing
#63 opened by prakharmathur82 - 0
Add Integration test for Longbow+
#62 opened by prakharmathur82 - 0
Add Integration test for Longbow
#61 opened by prakharmathur82 - 0
Add support for Struct SerDe
#59 opened by prakharmathur82 - 0