Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Add tiled implementation of the Flink app #627

Merged
merged 46 commits into from
Feb 28, 2024
Merged

Add tiled implementation of the Flink app #627

merged 46 commits into from
Feb 28, 2024

Commits on Dec 13, 2023

  1. Add custom triggers

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    a202daf View commit details
    Browse the repository at this point in the history

  2. Move triggers

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    3b894a6 View commit details
    Browse the repository at this point in the history

  3. Add KeySelector

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    393d58b View commit details
    Browse the repository at this point in the history

  4. Comments

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    28aa0ab View commit details
    Browse the repository at this point in the history

  5. Rename tiling package to window

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    27295e7 View commit details
    Browse the repository at this point in the history

  6. WIP runTiledGroupByJob

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    1224965 View commit details
    Browse the repository at this point in the history

  7. Comment-out AsyncKVStoreWriterTest.scala ? question mark ?

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    4b73485 View commit details
    Browse the repository at this point in the history

  8. Add ChrononFlinkRowAggregators

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    edac39f View commit details
    Browse the repository at this point in the history

  9. Refactor AvroCodec slightly

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    083b870 View commit details
    Browse the repository at this point in the history

  10. Add TiledAvroCodecFn

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    a39496d View commit details
    Browse the repository at this point in the history

  11. Add LateEventCounter

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    d4816bc View commit details
    Browse the repository at this point in the history

  12. Finish runTiledGroupByJob

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    4f295c8 View commit details
    Browse the repository at this point in the history

  13. Add ChrononFlinkRowAggregationFunctionTest

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    321eaaa View commit details
    Browse the repository at this point in the history

  14. Add missing @test decorator

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    e2e85df View commit details
    Browse the repository at this point in the history

  15. Add KeySelector tests

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    369c62e View commit details
    Browse the repository at this point in the history

  16. Add e2e tiled test

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    75ac625 View commit details
    Browse the repository at this point in the history

  17. Scalafmt

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    d0c35b1 View commit details
    Browse the repository at this point in the history

  18. Comments

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    68eb5bc View commit details
    Browse the repository at this point in the history

  19. Uncomment AsyncKVStoreWriterTest

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    e6ebf3a View commit details
    Browse the repository at this point in the history

  20. Remove slot sharing so that test finally halts

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    40d9a08 View commit details
    Browse the repository at this point in the history

  21. Tweak strings in key selector test

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    213cb7b View commit details
    Browse the repository at this point in the history

  22. Rename files, change comments

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    09c305b View commit details
    Browse the repository at this point in the history

  23. keyToBytes in process function should convert to array first

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    d52e0fc View commit details
    Browse the repository at this point in the history

  24. Refactor tiled Flink test, use watermark strategy

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    b249063 View commit details
    Browse the repository at this point in the history

  25. Improve e2e test so that we check actual tile IRs

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    e66b17e View commit details
    Browse the repository at this point in the history

  26. rm debug=true

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    920cc4e View commit details
    Browse the repository at this point in the history

  27. Use log4j

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    f10468c View commit details
    Browse the repository at this point in the history

  28. Remove comment

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    164fc62 View commit details
    Browse the repository at this point in the history

  29. Minor clean up, change comments

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    85431e1 View commit details
    Browse the repository at this point in the history

  30. scalafmt

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    c38c402 View commit details
    Browse the repository at this point in the history

  31. Add missing getSmallestWindowResolutionInMillis

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    4a93eb3 View commit details
    Browse the repository at this point in the history

  32. Add missing tiledCodec

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    bd44ceb View commit details
    Browse the repository at this point in the history

  33. Enable debug logs it tests

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    36b9bf2 View commit details
    Browse the repository at this point in the history

  34. Info instead of debug

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 13, 2023
    Configuration menu
    Copy the full SHA
    639e6ea View commit details
    Browse the repository at this point in the history

Commits on Dec 14, 2023

  1. Fix lack of isolation in test sink

    @caiocamatta-stripe
    caiocamatta-stripe committed Dec 14, 2023
    Configuration menu
    Copy the full SHA
    fb06f9b View commit details
    Browse the repository at this point in the history

Commits on Jan 3, 2024

  1. Make BaseAvroCodecFn abstract

    @caiocamatta-stripe
    caiocamatta-stripe committed Jan 3, 2024
    Configuration menu
    Copy the full SHA
    30f2cd7 View commit details
    Browse the repository at this point in the history

  2. Update FlinkJob comments

    @caiocamatta-stripe
    caiocamatta-stripe committed Jan 3, 2024
    Configuration menu
    Copy the full SHA
    829a914 View commit details
    Browse the repository at this point in the history

  3. Comment

    @caiocamatta-stripe
    caiocamatta-stripe committed Jan 3, 2024
    Configuration menu
    Copy the full SHA
    2128cfe View commit details
    Browse the repository at this point in the history

Commits on Jan 16, 2024

  1. Move getSmallestWindowResolutionInMillis to GroupByOps

    @caiocamatta-stripe
    caiocamatta-stripe committed Jan 16, 2024
    Configuration menu
    Copy the full SHA
    e114e18 View commit details
    Browse the repository at this point in the history

  2. Use new GroupByOps method, fix mistake

    @caiocamatta-stripe
    caiocamatta-stripe committed Jan 16, 2024
    Configuration menu
    Copy the full SHA
    b93e292 View commit details
    Browse the repository at this point in the history

Commits on Jan 24, 2024

  1. Merge remote-tracking branch 'upstream/master' into caiocamatta--add-… 

    …flink-tiling-oss
    @caiocamatta-stripe
    caiocamatta-stripe committed Jan 24, 2024
    Configuration menu
    Copy the full SHA
    54337a3 View commit details
    Browse the repository at this point in the history

Commits on Feb 12, 2024

  1. Revert "Move getSmallestWindowResolutionInMillis to GroupByOps"

    @caiocamatta-stripe
    caiocamatta-stripe committed Feb 12, 2024
    Configuration menu
    Copy the full SHA
    b2c6716 View commit details
    Browse the repository at this point in the history

Commits on Feb 27, 2024

  1. Use toScala, use multiline strings

    @caiocamatta-stripe
    caiocamatta-stripe committed Feb 27, 2024
    Configuration menu
    Copy the full SHA
    c72ee4e View commit details
    Browse the repository at this point in the history

  2. Use logger.debug

    @caiocamatta-stripe
    caiocamatta-stripe committed Feb 27, 2024
    Configuration menu
    Copy the full SHA
    c366012 View commit details
    Browse the repository at this point in the history

  3. Scalafmt

    @caiocamatta-stripe
    caiocamatta-stripe committed Feb 27, 2024
    Configuration menu
    Copy the full SHA
    aab3496 View commit details
    Browse the repository at this point in the history

Commits on Feb 28, 2024

  1. Fix compile error

    @caiocamatta-stripe
    caiocamatta-stripe committed Feb 28, 2024
    Configuration menu
    Copy the full SHA
    2f53c7e View commit details
    Browse the repository at this point in the history