Added streaming query api