- Hong Kong
Highlights
- Pro
Block or Report
Block or report lmatz
Report abuse
Contact GitHub support about this user’s behavior. Learn more about reporting abuse.
Report abusePinned
-
husky-team/husky Public
A more expressive and most importantly, more efficient system for distributed data analytics.
-
singularity-data/risingwave Public
RisingWave: the next-generation streaming database in the cloud.
995 contributions in the last year
Contribution activity
May 2022
Created 16 commits in 1 repository
Created 1 repository
Created a pull request in singularity-data/risingwave that received 3 comments
refactor(batch): rename executor2 to executor
What's changed and what's your intention? Just rename all.
+476
−518
•
3
comments
Opened 15 other pull requests in 1 repository
singularity-data/risingwave
1
open
13
merged
1
closed
- refactor(storage): use iter instead of scan in CellBasedTableRowIter
- refactor(batch,rpc): move get_data's concrete implementation to BatchManager
- refactor(frontend): unpin epoch when all leaf stages are scheduled
- chore: bump toolchain
- refactor: use oneshot channel for shutdown
- fix(ci, doc): make pr title labeler and checker consistent with the doc
- feat(batch): abort task
- chore: lifetime error
- refactor(frontend): use compute client pool to get ComputeClient
- refactor(rpc): move stream and compute client pool into rpc crate
- feat(ci): pr title checker
- refactor(common): use next_visible_row_idx for data chunk iter
- chore(batch): remove outdated TODO in MergeSortExchangeExecutor
- feat(storage): vacuum a larger set of ssts
- chore(storage): rename reverse to backward
Reviewed 31 pull requests in 1 repository
singularity-data/risingwave
25 pull requests
- refactor(storage): use iter instead of scan in CellBasedTableRowIter
- fix: batch TopN sort_util handles null
- test(optimizer): test simple-agg with different input distributions
- feat(optimizer): Add 2-phase aggregation for queries with no group keys
- feat(doc): Add design doc for batch local execution mode
- feat(batch): abort task
- chore: lifetime error
- fix(test): fix state table tests
- refactor(frontend): use compute client pool to get ComputeClient
- feat(optimizer): add multijoin filter merge rule
- feat(streaming): implement append-only hash join exectuor
- feat(expression): Implement IS [NOT] DISTINCT FROM in backend
- test(stream): add e2e time window join test case
- feat(optimizer): Multi join reordering
- feat(expr): IN-list support non-literals
- feat(expr): Implement IS [NOT] DISTINCT FROM expression
-
feat(frontend): add
LogicalMultijoin - fix(source): remove epoch in state user key and no flush on idle
- chore(batch): remove unnecessary compact
- refactor(batch): Remove fuse and trace v1
- refactor(batch): Remove join v1
- fix(batch): fix a bug of exchange and project.
- refactor: Remove unused file
- feat(expr): Implement evaluation for CONCAT_WS expression
- refactor(batch): enable GenericExchangeExecutor2 poll all the sources
- Some pull request reviews not shown.
Created an issue in singularity-data/risingwave that received 5 comments
Tracking: Introduce per-crate error type for frontend
As mentioned in #1367. Tracking: #2035 Introduce HandleError Type Introduce PlanError Type Intoduce ScheduleError Type.
4 tasks
Opened 8 other issues in 1 repository
singularity-data/risingwave
8
closed
- Reuse ComputeClient when scheduling batch tasks
- Meta: Stream Manager
-
Possibly wrong result produced by
bitandof twoBitmaps - Stop a running batch task
- let GenericExchangeExecutor2 poll all the sources at the same instead of polling them sequentially
- Failed execution of batch query does not unpin its epoch/snapshot
- Specify the additional independencies in doc when optional feature is enabled
-
Rename all
ReverseIteratortoBackwardIterator

