Skip to content
This repository has been archived by the owner on Apr 13, 2024. It is now read-only.

Commit

Permalink
fix for siddhi ql in custom xml sample
Browse files Browse the repository at this point in the history
  • Loading branch information
ramindu90 committed Jul 6, 2017
1 parent e16382a commit 754b620
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions modules/samples/artifacts/0006/xml-custom-sample.siddhi
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
@App:name('xml-custom-sample')

@source(type='kafka', topic.list='kafka_topic', partition.no.list='0', threading.option='single.thread', group
.id="group", bootstrap.servers='localhost:9092', @map(type='xml', namespaces = "dt=urn:schemas-microsoft-com:datatypes", enclosing.element="//portfolio", @attributes(symbol ="symbol", price = "price", volume = "volume")))
@source(type='kafka', topic.list='kafka_topic', partition.no.list='0', threading.option='single.thread', group.id="group", bootstrap.servers='localhost:9092', @map(type='xml', namespaces = "dt=urn:schemas-microsoft-com:datatypes", enclosing.element="//portfolio", @attributes(symbol ="symbol", price = "price", volume = "volume")))
define stream StockStream(symbol string, price float, volume long);

@sink(type='kafka', topic='kafka_result_topic', bootstrap.servers='localhost:9092', partition.no='0', @map(type='xml', @payload("<StockData><Symbol>{{symbol}}</Symbol><Price>{{price}}</Price></StockData>")))
Expand Down

0 comments on commit 754b620

Please sign in to comment.