31-OldTsimCases¶

¶

OldTsim: stream basic

Basic test cases for streaming, part 1

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_basic1.py

¶

OldTsim: stream basic status

1. Create snode

2. Create multiple databases

3. Create stream sliding window, tag stream, trigger interval 0, window close scenarios

4. Insert data and verify the correctness of stream processing results

5. Verify the status of all streams

6. Check data correctness for all streams

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_basic2.py

¶

OldTsim: check stable

Verify the computation results of streams when triggered by different windows.

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_check.py

¶

OldTsim: checkpoint

Test if the stream continues to run after a restart.

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_checkpoint.py

¶

OldTsim: concat

Test the use of the concat function in output_subtable and tags statements.

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_concat.py

¶

OldTsim: continue window close

Verify the alternative approach to the original continuous window close trigger mode in the new streaming computation

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_continuewindowclose.py

¶

OldTsim: count window

Basic use cases of count window, include expired-data, out-of-order data, and data-deletion

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_count.py

¶

OldTsim: delete data

Test the correctness of results when deleting data in various trigger windows

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_delete.py

¶

OldTsim: distribute

Perform multiple write triggers to verify the correctness of the calculation results

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_distribute.py

¶

OldTsim: event window

Test event window deletion and update

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_event.py

¶

OldTsim: fill history

Verify the correctness of historical data calculation results, as well as the calculation results at the boundary between historical and real-time computation.

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_fillhistory.py

¶

OldTsim: fill interval

Test the results of various numerical fillings in the interval window

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_fillinternal.py

¶

OldTsim: force window close

Verify the alternative approach to the original force window close trigger mode in the new streaming computation

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_forcewindowclose.py

¶

OldTsim: interp delete

Verify the calculation results of the interp function when deleting data

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_interp_delete.py

¶

OldTsim: interp fill

Validate the calculation results of the interp function when filling data

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_interp_fill.py

¶

OldTsim: interp history

Validate the calculation results of the interp function when processing historical data

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_interp_history.py

¶

OldTsim: interp partition by

Validate the calculation results of the ​​interp​​ function under ​​PARTITION BY​​ clauses

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_interp_partitionby.py

¶

OldTsim: interp compisite key

Validate the calculation results of the interp function with cmposite keys

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_interp_primary.py

¶

OldTsim: interp update

Validate the calculation results of the interp function during data updates

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_interp_update.py

¶

OldTsim: options

Validate the calculation results when ignore update and ignore delete are applied

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_options.py

¶

OldTsim: partition by

Validate the calculation results under PARTITION BY clauses

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_partitionby.py

¶

OldTsim: composite key

Validate the calculation results with composite keys

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_primary.py

¶

OldTsim: session window

Test the correctness of session windows

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_session.py

¶

OldTsim: snode

Test basic operations of snode

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_snode.py

¶

OldTsim: state window

Test the correctness of state windows

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_state.py

¶

OldTsim: twa

Verify the behavior of the legacy TWA function in the new streaming computation system

path: cases/18-StreamProcessing/31-OldTsimCases/test_oldcase_twa.py