Have you considered using stream views?

  CREATE VIEW streamB AS SELECT e.*, e.b * 2 AS b1 FROM streamA AS e;

The "*" ensures that streamB will contain at least columns a, b, c
from streamA. And when you add column d to streamA, that will appear
in streamB also.

Julian


On Mon, Mar 13, 2017 at 8:51 PM, Shihuihua <[email protected]> wrote:
> Hi all,
>
>    In our Stream processing system, we use the Calctie as the SQL engine, and 
> now there is a need for help。
>
> for exsample:
>     The stream streamA contains three integer fields for a, b, and c ( 
> streamA{a,b,c} )。 it need do the flowing SQL operation。
>
>          create stream streamB(a1 int,b1 int ,c1 int);
>    insert into streamB select stream e.a, e.b*2 , e.c from streamA e ;
>
>          But when the streamA new field d , streamA{a,b,c,d} ,  how to make 
> the output stream streamB with the d field content and can not change the sql 
> rules?
>     For the above scene,i want to use the flowing sql rules,but it needs to 
> increase the others keyword syntax for the the other fields in the 
> stream。When the streamA increase a field ,the streamB is also increased and 
> with the content of the increased filed .
>
>          create stream streamB from streamA;
>    insert into streamB select stream e.a, e.b*2 , e.others from streamA e ;
>
> Is there any other way to solve this problem?  if not,does the community plan 
> to support this function ? Thanks in advance for the help!
>
>
>
>
>
>
>
> Thanks,
>
>
>
> HuiHua SHI
>

Reply via email to