| Age | Commit message (Collapse) | Author | Files | Lines | |
|---|---|---|---|---|---|
| 2025-07-16 | convert error fromating to %w everywhere (#6995) | Chris Lu | 1 | -1/+1 | |
| 2025-06-23 | chore(deps): bump github.com/parquet-go/parquet-go from 0.24.0 to 0.25.1 (#6851) | dependabot[bot] | 1 | -10/+31 | |
| * chore(deps): bump github.com/parquet-go/parquet-go from 0.24.0 to 0.25.1 Bumps [github.com/parquet-go/parquet-go](https://github.com/parquet-go/parquet-go) from 0.24.0 to 0.25.1. - [Release notes](https://github.com/parquet-go/parquet-go/releases) - [Changelog](https://github.com/parquet-go/parquet-go/blob/main/CHANGELOG.md) - [Commits](https://github.com/parquet-go/parquet-go/compare/v0.24.0...v0.25.1) --- updated-dependencies: - dependency-name: github.com/parquet-go/parquet-go dependency-version: 0.25.1 dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> * adjust to updated API Fixed Reader Construction: Updated to use parquet.OpenFile() instead of passing io.Reader directly to NewReader() Fixed EOF Handling: Changed the order of operations to process rows before checking for EOF Added Zero Row Count Check: Added explicit check for rowCount == 0 as an additional termination condition --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Chris Lu <chrislusf@users.noreply.github.com> Co-authored-by: chrislu <chris.lu@gmail.com> | |||||
| 2025-03-04 | adjust logs | chrislu | 1 | -3/+3 | |
| 2025-01-20 | Add message queue agent (#6463) | Chris Lu | 1 | -2/+7 | |
| * scaffold message queue agent * adjust proto, add mq_agent * add agent client implementation * remove unused function * agent publish server implementation * adding agent | |||||
| 2024-11-04 | merge current message queue code changes (#6201) | Chris Lu | 1 | -0/+7 | |
| * listing files to convert to parquet * write parquet files * save logs into parquet files * pass by value * compact logs into parquet format * can skip existing files * refactor * refactor * fix compilation * when no partition found * refactor * add untested parquet file read * rename package * refactor * rename files * remove unused * add merged log read func * parquet wants to know the file size * rewind by time * pass in stop ts * add stop ts * adjust log * minor * adjust log * skip .parquet files when reading message logs * skip non message files * Update subscriber_record.go * send messages * skip message data with only ts * skip non log files * update parquet-go package * ensure a valid record type * add new field to a record type * Update read_parquet_to_log.go * fix parquet file name generation * separating reading parquet and logs * add key field * add skipped logs * use in memory cache * refactor * refactor * refactor * refactor, and change compact log * refactor * rename * refactor * fix format * prefix v to version directory | |||||
| 2024-10-03 | add helper functions | chrislu | 1 | -0/+27 | |
| 2024-05-20 | go fmt | chrislu | 10 | -55/+54 | |
| 2024-05-05 | fix test | chrislu | 1 | -5/+5 | |
| 2024-05-03 | working | chrislu | 1 | -1/+1 | |
| 2024-05-02 | rename | chrislu | 5 | -13/+13 | |
| 2024-05-02 | rename field types | chrislu | 7 | -21/+21 | |
| 2024-05-02 | consistent with protobuf data types | chrislu | 6 | -28/+28 | |
| 2024-05-02 | rename to WithField() | chrislu | 4 | -36/+36 | |
| 2024-04-28 | Update write_parquet_test.go | chrislu | 1 | -1/+1 | |
| 2024-04-28 | record value API | chrislu | 2 | -34/+37 | |
| 2024-04-28 | record type begin and end | chrislu | 4 | -41/+55 | |
| 2024-04-28 | improve api | chrislu | 2 | -25/+7 | |
| 2024-04-28 | rename api | chrislu | 3 | -22/+10 | |
| 2024-04-28 | Delete schema_builder_test.go | chrislu | 1 | -17/+0 | |
| 2024-04-28 | struct to schema correctly | chrislu | 3 | -20/+152 | |
| 2024-04-28 | compile test | chrislu | 1 | -5/+5 | |
| 2024-04-28 | recursive struct to schema | chrislu | 2 | -8/+63 | |
| 2024-04-27 | rename | chrislu | 4 | -31/+31 | |
| 2024-04-27 | rename | chrislu | 2 | -22/+22 | |
| 2024-04-25 | a little bit more efficient | chrislu | 3 | -12/+14 | |
| 2024-04-25 | minor | chrislu | 1 | -1/+1 | |
| 2024-04-25 | use parquet levels to construct row | chrislu | 1 | -28/+31 | |
| 2024-04-25 | toRow conversion with levels info | chrislu | 1 | -20/+18 | |
| 2024-04-25 | file rename | chrislu | 2 | -0/+0 | |
| 2024-04-25 | printout test values | chrislu | 1 | -4/+8 | |
| 2024-04-25 | add visitor | chrislu | 2 | -0/+155 | |
| 2024-04-24 | add field types but without value | chrislu | 1 | -1/+4 | |
| 2024-04-24 | record type is also optional | chrislu | 1 | -0/+1 | |
| 2024-04-24 | delete the generated file | chrislu | 1 | -0/+4 | |
| 2024-04-24 | add some notes | chrislu | 1 | -0/+3 | |
| 2024-04-24 | adjust test | chrislu | 1 | -6/+10 | |
| 2024-04-24 | works with single level of list | chrislu | 4 | -60/+71 | |
| 2024-04-24 | fix ordering | chrislu | 1 | -1/+1 | |
| 2024-04-22 | has a bug | chrislu | 6 | -19/+317 | |
| 2024-04-18 | all record fields are optional by default | chrislu | 1 | -1/+4 | |
| 2024-04-18 | add test | chrislu | 2 | -9/+25 | |
| 2024-04-18 | support list type | chrislu | 1 | -10/+16 | |
| 2024-04-18 | add schema builder | chrislu | 2 | -0/+99 | |
| 2024-04-17 | convert to parquet schema and value | chrislu | 3 | -15/+160 | |
| 2024-04-12 | fix test | chrislu | 1 | -13/+0 | |
| 2024-04-12 | Create schema.go | chrislu | 1 | -0/+32 | |
| 2024-04-12 | add schema.proto | chrislu | 1 | -0/+98 | |
 |
index : seaweedfs/.git | |
| Unnamed repository; edit this file 'description' to name the repository. | root |
| aboutsummaryrefslogtreecommitdiff |