流数据里面可以通过自定义handler的方式，将输入流表的数据通过sql进行pivot或者unpivot置换，参考代码如下：

def myHand(t){
 t1 = select last(factor1), last(factor2), last(factor3) from t pivot by  time,code
 /*
  * do something
  */
}

subscribeTable(, tableName = "factor", actionName="act1", offset = -1, handler = myHand, msgAsTable =true)

响应式状态引擎计算的结果表作为输入流表本身没有什么问题，不过如果同一时间所有股票的因子，不能同时进来的话，只能对部分股票的进行pivot操作，代码本身不会有问题，可以根据需要确定是否需要这么做。