[EAGLE-1041] Support policy processing pipeline

https://issues.apache.org/jira/browse/EAGLE-1041

Two updates:
* if an inputStream is an intermediate stream (defined by select clause statement), then remove it from inputStream list and outputStream list
* if an inputStream is an intermediate stream, remove its PartitionSpec

Author: Zhao, Qingwen <qingwzhao@apache.org>

Closes #947 from qingwen220/EAGLE-1041.
1 file changed