背壓功能(Back Pressure)

在Slipstream中，資料來源發來的訊息量大時，出於穩定性的考慮，有時會需要讓receiver暫停接收發來的消 息，這個功能稱為背壓功能。設定方法如下:

SET streamsql.enable.backpressure.receiver=true; 1 SET streamsql.backpressure.max.pendingJobs=<int>; 2

1 開啟背壓功能。
2 可選，值需要為正整數，預設值為2。設定有多少擠壓的底層任務(注意不是StreamJob)時停止接收消
息。

Application級別管理

使用者執行任何StreamJob之前需要進入對應的Application。預設情況下，當前的Application是default。
語法:進入Application

USE APPLICATION <app_name>;

語法:顯示正在執行的Application

LIST APPLICATIONS;

StreamJob級別管理

StreamJob作為Slipstream執行時的基本單元，也是使用者做實時監控的基本單元。
語法:啟動當前Application下的所有StreamJob

  START STREAMJOBS;

語法:啟動當前Application下的某個StreamJob

  START STREAMJOB s1;

語法:啟動一個臨時的StreamJob

INSERT INTO <table_name> SELECT ... FROM <stream_name>;

這樣可以啟動一個臨時的StreamJob，這個StreamJob會得到一個隨機的StreamID，通過 LIST STREAMJOBS 可以看到。要將它停止需要使用這個StreamID。
檢視當前Application下的正在執行的StreamJob

  LIST STREAMJOBS;

檢視當前Application下的某個StreamJob的詳細資訊

 LIST STREAMJOB <streamid>;

停止當前Application下的所有StreamJob

STOP STREAMJOBS;

停止當前Application下的某個StreamJob

STOP STREAMJOB s1;