• 定义SourceTable

      1. CREATE STREAM SOURCE TableName{}

    • 定义SinkTable

      1. CREATE STREAM SINK TableName{}

    • 分流

      1. CREATE STREAM VIEW newTableName(X,X,X) AS SELECT Field1,Field2,Filed3 
      2.   FROM QuerySourceTable WHERE xxx LIKE '%xxx%';

    • Join

      1. ON