Skip to content

04-Options

Abnormal data: table
test data disorder/update/delete change cases to stream
path: cases/18-StreamProcessing/04-Options/test_abnormal_data_table.py

Abnormal data: virtual table
test data disorder/update/delete change cases to stream for virtual table
path: cases/18-StreamProcessing/04-Options/test_abnormal_data_vtable.py

Basic idle detection - trigger IDLE event after timeout
Test that a partition group triggers an IDLE event when no data
is received for the configured IDLE_TIMEOUT period.
path: cases/18-StreamProcessing/04-Options/test_idle_trigger.py

Basic resume detection - trigger RESUME event after idle
Test that a partition group triggers a RESUME event when data
is received after being in IDLE state.
path: cases/18-StreamProcessing/04-Options/test_idle_trigger.py

Multiple partitions with independent idle states
Test that each partition group maintains independent idle state
and triggers IDLE events independently.
path: cases/18-StreamProcessing/04-Options/test_idle_trigger.py

Configuration flexibility - different timeout values
Test that IDLE_TIMEOUT can be configured with different values
within the valid range (1s to 10d).
path: cases/18-StreamProcessing/04-Options/test_idle_trigger.py

Verify _tidlestart and _tidleend placeholder values
Test that _tidlestart and _tidleend placeholders are correctly
filled with idle period timestamps.
path: cases/18-StreamProcessing/04-Options/test_idle_trigger.py

Test EVENT_TYPE combinations (IDLE only, RESUME only, IDLE|RESUME)
Test that different event type combinations work correctly.
path: cases/18-StreamProcessing/04-Options/test_idle_trigger.py

Test behavior when IDLE_TIMEOUT is not configured
Test that idle detection is disabled when IDLE_TIMEOUT is not configured.
path: cases/18-StreamProcessing/04-Options/test_idle_trigger.py

Test multiple idle-resume cycles
Test that a partition can go through multiple idle-resume cycles.
path: cases/18-StreamProcessing/04-Options/test_idle_trigger.py

Edge case: Test that mixing window and idle placeholders is rejected
Test that using both _twstart/_twend and _tidlestart/_tidleend
in the same stream is rejected by the parser.
path: cases/18-StreamProcessing/04-Options/test_idle_trigger.py

Edge case: Test that IDLE/RESUME events require IDLE_TIMEOUT
Test that using EVENT_TYPE(IDLE) or EVENT_TYPE(RESUME) without
IDLE_TIMEOUT configuration is rejected.
path: cases/18-StreamProcessing/04-Options/test_idle_trigger.py

Meta change: table
test meta change (add/drop/modify) cases to stream
path: cases/18-StreamProcessing/04-Options/test_meta_change_table.py

Meta Change: virtual table
test meta change (add/drop/modify) cases to stream for virtual table
path: cases/18-StreamProcessing/04-Options/test_meta_change_vtable.py

Options: abnormal
test abnormal cases to stream
path: cases/18-StreamProcessing/04-Options/test_options_abnormal.py

Options: basic test
test options item of stream
path: cases/18-StreamProcessing/04-Options/test_options_basic.py

Options: precision ns
test options item of stream to precision ns
path: cases/18-StreamProcessing/04-Options/test_options_ns.py

Options: precision us
test options item of stream
path: cases/18-StreamProcessing/04-Options/test_options_us.py

Options: virtual table
test options item of stream to virtual table
path: cases/18-StreamProcessing/04-Options/test_options_vtable.py