Parameterize PubSubWebSocketInputOperator