This is an automated email from the ASF dual-hosted git repository.
aglinxinyuan pushed a change to branch xinyuan-loop-feb
in repository https://gitbox.apache.org/repos/asf/texera.git
omit 0e64234b4f Merge branch 'xinyuan-state-only' into xinyuan-loop-feb
omit 92905d89ad fix fmt
omit b6d14ee05d fix fmt
omit 345fa41c78 fix fmt
omit 94b874c53b fix fmt
omit 42201cba49 fix fmt
omit 907dd10a4d fix fmt
omit 1173dd4599 fix fmt
omit 5cd9657696 fix fmt
omit 67c4e24f54 fix fmt
omit 808a5e7ca2 fix fmt
omit 157156c496 fix fmt
omit 8af461e8ad fix fmt
omit c78ae88014 Merge remote-tracking branch 'origin/xinyuan-loop-feb' into
xinyuan-loop-feb
omit 460a615f59 fix fmt
omit 8d4aa91d1d Merge branch 'xinyuan-state-only' into xinyuan-loop-feb
omit b313e16f3c fix: update if operator state access
omit be81f7d231 fix: persist state in scala data processor
omit 6ae30e8344 Merge remote-tracking branch 'origin/xinyuan-loop-feb' into
xinyuan-loop-feb
omit dc4785bd9d fix fmt
omit be153347f4 Merge branch 'xinyuan-state-only' into xinyuan-loop-feb
omit d21a25271f refactor: isolate state serialization and materialization
changes
omit 39681ebbdc update
omit 1128b88c88 fix fmt
omit f372662e8f fix fmt
omit ec01fdddca Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
omit 00e78f88e7 Merge branch 'main' into xiaozhen-sync-region-kill
omit 39a1d45a07 fix fmt
omit 7172471a8d fix fmt
omit c2e7fa5138 fix fmt
omit 9cc0d7a114 fix fmt
omit 71ac3c2e8d update
omit 8d24e10ee6 fix fmt
omit 3d0aeb802d update
omit 196942b8ef fix fmt
omit 4c26e04efe update
omit 404f989d60 fix fmt
omit 484eb37965 fix fmt
omit 6b369fec62 fix fmt
omit 6eafeb68f9 fix fmt
omit 35b0f0aa02 fix fmt
omit af0c0ea9f0 fix fmt
omit e722dc7825 fix fmt
omit afd5ac27f0 fix fmt
omit cf20d8fb26 fix fmt
omit 7054861855 fix fmt
omit db819e2d67 fix fmt
omit 367f7bef39 Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
omit 2bc211f727 Merge branch 'main' into xiaozhen-sync-region-kill
omit 2aa0bbc3bf fix fmt
omit a35df2f85e update
omit 754d4d19be Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
omit 42befa9ebc Merge branch 'main' into xiaozhen-sync-region-kill
omit 02d79d1837 update
omit cd90b928c0 update
omit c327ae6cab update
omit f3b99e0dcf update
omit ddf413b3c9 update
omit b9092d0382 update
omit 4977837877 update
omit b2037740ea update
omit 0c72e255e6 Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
omit c134106199 Merge branch 'main' into xiaozhen-sync-region-kill
omit 2d86c45ca4 fix
omit e3a4dad420 init
omit 1c74e3bab1 update
omit fbd5403f54 update
omit 64e2ddad58 Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
omit 4504e281c2 Merge branch 'main' into xiaozhen-sync-region-kill
omit f09c9e368d update
omit be4360829b update
omit 3ada4c2313 update
omit 43f2ca68c8 update
omit dac211aff4 update
omit b18d9dbc52 update
omit 08679f003f update
omit ba1b50f491 Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
omit 4fbb195aba Merge branch 'main' into xiaozhen-sync-region-kill
omit fe7e07146c update
omit f8ce99fec1 update
omit 2e7c72ac4e update
omit aa444a0093 update
omit 565ee717c8 update
omit f71dbec110 update
omit 00e49a56e4 update
omit 0cfcf2fb3d update
omit 3a2d0b9abe update
omit 9b0d14dea3 update
omit 2ccde1e0df update
omit 55f288fd06 update
omit 2b78e2ce01 update
omit 0970a53a65 update
omit c65585650a update
omit bc5856643b update
omit 92ab10f566 update
omit 8c7d53cc10 update
omit 53ae08be55 update
omit 99e0f86c2e update
omit bd270311c1 update
omit 160bc6d68c Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
omit 4063cefa8b Merge branch 'main' into xiaozhen-sync-region-kill
omit 04fe614bf0 update
omit da8d6ed15c Merge remote-tracking branch 'origin/xinyuan-loop-feb' into
xinyuan-loop-feb
omit b717fb0d46 update
omit 30a85623a7 update
omit 4d18d1dcc6 Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
omit e18c7a831a Merge branch 'main' into xiaozhen-sync-region-kill
omit e35a33286c update
omit 1cd48fd12b update
omit d44a664f9f update
omit a53506afca update
omit b8faf93e5a update
omit 55d5cec6fb update
omit ae0d4ed6ad Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
omit 30f47b0347 Merge branch 'main' into xiaozhen-sync-region-kill
omit 084f602990 update
omit cbb2fc7343 Merge branch 'xiaozhen-sync-region-kill' into
xinyuan-loop-feb
omit 393faacf1b Merge branch 'main' into xinyuan-loop-feb
omit fb1471e8d3 Merge branch 'refs/heads/main' into
xiaozhen-sync-region-kill
omit e0a28667ce fix(amber): improve region kill behavior error handling and
add synchronous kill logic.
omit a4bfbdb218 fix
omit 36e517e463 fix
omit d8338d1241 update
omit 6be7dc5bcf update
omit 846aac2187 update
omit 44fc0e795b update
omit a05ffd1f78 update
omit 2ba0fa400d update
omit 24da3e38ac update
omit 21e6a41bb5 update
omit 706884f0b9 update
omit 19be0c1a3b update
omit bd5ac3aba6 update
omit 7b13fef2bd update
omit 144ae29f27 update
omit d9d0cd9438 update
omit f83041a47a Merge branch 'main' into xinyuan-loop-feb
omit b95465d2e0 update
omit 592ff644f6 init
add 0485b4d6d8 feat(operator): add carpet plot operator (#4398)
add 52eace6ecd Apply xinyuan-loop-feb changes from 157156c onto main
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (0e64234b4f)
\
N -- N -- N refs/heads/xinyuan-loop-feb (52eace6ecd)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
amber/src/main/python/core/models/operator.py | 32 ++++++
.../main/python/core/runnables/data_processor.py | 1 +
amber/src/main/python/core/runnables/main_loop.py | 1 +
.../input_port_materialization_reader_runnable.py | 1 +
.../pythonworker/PythonProxyClient.scala | 6 +-
.../pythonworker/PythonProxyServer.scala | 5 +-
.../scheduling/RegionExecutionCoordinator.scala | 39 +++++--
.../apache/texera/amber/operator/LogicalOp.scala | 2 +
.../carpetPlot/CarpetPlotOpDesc.scala | 124 +++++++++++++++++++++
frontend/src/assets/operator_images/CarpetPlot.png | Bin 0 -> 17941 bytes
10 files changed, 199 insertions(+), 12 deletions(-)
create mode 100644
common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/visualization/carpetPlot/CarpetPlotOpDesc.scala
create mode 100644 frontend/src/assets/operator_images/CarpetPlot.png
