0 
@App:name("VehicleCountCheckApp")
@source(type='kafka',topic.list='vehicle_data',....)
define stream TrafficStream (vehicleCount int, location string);
@sink(type='kafka',topic='vehicle_output', .....)
define stream AlertStream (vehicleCount int, location string);

@info(name = 'CheckVehicleCount')
from TrafficStream[vehicleCount > {{HIGH_DENSITY_VEHICLE_COUNT}}]
select vehicleCount, location
insert into AlertStream;

I'm getting an error:

no viable alternative at input 'TrafficStream[vehicleCount > {{HIGH_DENSITY_VEHICLE_COUNT}}

So in this I take kafka input Json and based on this siddhi query I will check output in separate kafka topic bit this HIGH_DENSITY_VEHICLE_COUNT value will declare in deployment file

Improve this question
Related questions
1
WSO2CEP Siddhi query error using geo within function
2
Syntax error in SiddhiQL, no viable alternative at input
1
Not able to process kafka json message with Flink siddhi library
Load 6 more related questions Show fewer related questions

0

Reset to default

Your Answer

By clicking “Post Your Answer”, you agree to our terms of service and acknowledge you have read our privacy policy.

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.