Database: berlintest
Restore: No

Operator : writetokafka
Number   : 2
Signature   : stream(tuple) x KafkaHost x KafkaTopic -> stream(tuple)
Example  : query plz feed writetokafka["localhost","test"] count
Result   : 40

Operator : readfromkafka
Number   : 1
Signature: KafkaHost x KafkaTopic x ContinuousReading -> stream(tuple)
Example  : query readfromkafka("localhost", "test", FALSE) count
Result   : 7

Operator : finishStream
Number   : 2
Signature: stream(tuple) x Port -> stream(tuple)
Example  : query readfromkafka("localhost", "test", TRUE) finishStream[8080] consoleConsumer count
Result   : 7

Operator : signalFinish
Number   : 2
Signature: signalFinish(host, port)
Example  : query signalFinish("localhost", 8080)
Result   : 0

Operator : consoleConsumer
Number   : 0
Signature   : stream -> stream
Example  : query plz feed consoleConsumer count
Result   : 40

Operator : readfromwebsocket
Number   : 1
Signature: URI x Subscription x Type -> stream(tuple)
Example  : query readfromwebsocket('wss://ws.blockchain.info/inv', '{"op":"unconfirmed_sub"}', 'Operation : string /op') finishStream[8080] head[10] consume
Result   : 7

Operator : installLocalKafka
Number   : 0
Signature: installLocalKafka
Example  : query installLocalKafka()
Result   : 0

Operator : startLocalKafka
Number   : 0
Signature: startLocalKafka
Example  : query startLocalKafka()
Result   : 0

Operator : stopLocalKafka
Number   : 0
Signature: stopLocalKafka
Example  : query stopLocalKafka()
Result   : 0

Operator : statusLocalKafka
Number   : 0
Signature: statusLocalKafka
Example  : query statusLocalKafka()
Result   : 0

Operator : localKafka
Number   : 1
Signature: localKafka("command")
Example  : query localKafka("topics")
Result   : 0