IBM Streams 4.2

Example

This example shows how to configure the operator to detect Hangouts when an entity spends 5 or more minutes within the same region of roughly 75m x 75m:

stream<rstring hangoutGeohash, boolean isHangingOut, uint64 hangoutDuration> HangoutStream =
	Hangout(LocationData)
{
	param
		//this is the desired size of the geohash cells, a value of 75.0 means geohash cells will be roughly 75mx75m in area
		cellSize: 75.0; 
		//our incoming data generally has a latitude of 50-51
		sampleLatitude: 51.0; 
		//5 minute dwell time specified in seconds - the minimum amount of time an entity must remain within the same geohash.
		minimumDwellTime : 600u ;
		precision : 10.0 ; //incoming location data is adjusted to within 10m
		
	output
		HangoutStream : 
		hangoutGeohash = HangoutGeohashBase32(), 
		isHangingOut = 	IsInHangout(), 
		hangoutDuration = HangoutDuration() ;
}