Use streamDefinition
create query