Software Engineer @MaterializeInc; Committer and PMC member at Apache Flink; Committer and PMC member at Apache Beam
- Europe
- aljoschakrettek.org
Block or Report
Block or report aljoscha
Report abuse
Contact GitHub support about this user’s behavior. Learn more about reporting abuse.
Report abusePopular repositories
-
statefun-rust Public
A Rust SDK for StateFun (https://flink.apache.org/stateful-functions.html)
-
An example of using Flink for Fault-Tolerant Stream Processing
-
609 contributions in the last year
Less
More
Activity overview
Contributed to
MaterializeInc/materialize,
aljoscha/vim-colors-mostly-off,
TimelyDataflow/timely-dataflow
and 4 other
repositories
Contribution activity
April 2022
Created 20 commits in 1 repository
Created a pull request in MaterializeInc/materialize that received 9 comments
persist: fix assortment of usability issues
Testing [no] This PR has adequate test coverage / QA involvement has been duly considered.
+24
−10
•
9
comments
Opened 7 other pull requests in 1 repository
MaterializeInc/materialize
6
merged
1
closed
- persist: change WriteHandle::append to return current upper on mismatch
- persist: add WriteHandle::fetch_upper(), which retrieves the shard-global upper
- all of it: add a persist sink/source
- persist: implement FromStr for ShardId
- persist: don't validate sorting of batches, because we don't sort right now
- persist: make API structs Send + Sync
- persist-client: separate state of multiple shards in Consensus
Reviewed 17 pull requests in 1 repository
MaterializeInc/materialize
17 pull requests
- all of it: add a persist sink/source
- persist: change WriteHandle::append to return current upper on mismatch
- persist: add WriteHandle::fetch_upper(), which retrieves the shard-global upper
- Persist ts bindings during source ingestion
- persist: add a helper for immediately consuming a snapshot
- persist: prep for inc state part 1
- persist: open-loop benchmark
- persist: extend Consensus to support scan and truncate.
- persist: remove the old persist integration.
- persist: add unreliable wrappers for BlobMulti and Consensus
- persist: support interchange of ShardId via its string format
- persist: add new persistent source example
- doc/developer: add reclocking implementation design doc
- persist: hook up transmissible Location to Client construction
- persist-client: separate state of multiple shards in Consensus
- design: add initial version of persist doc
- persist: skeleton of real impl delegating to durable Blob + Consensus