rename operators

streamsadmin · streamsadmin · commit 6c3fb2fb299e · 2017-03-22T15:16:22.000-04:00
diff --git a/QuickStart/TradesApp/application/TradesAppCloud.spl b/QuickStart/TradesApp/application/TradesAppCloud.spl
@@ -39,29 +39,29 @@ composite TradesAppCloud
 		
 		}
 		
-		stream<Quotes> FilteredQuotes = Filter(Quotes)
+		stream<Quote> FilteredQuotes = Filter(Quotes)
 		{
 			param
 				filter : askprice > 0.0 ; 
 		}
 
-		stream<rstring ticker, float64 min, float64 max, float64 average> AverageAskingPrice = Aggregate(FilteredQuotes as inPort0Alias)
+		stream<rstring ticker, float64 min, float64 max, float64 average> AvgPrice = Aggregate(FilteredQuotes as inPort0Alias)
 		{
 			window
 				inPort0Alias : tumbling, count(5), partitioned ;
 			param
 				partitionBy : ticker ;
 			output
-				AverageAskingPrice : average = Average(askprice), min = Min(askprice),
+				AvgPrice : average = Average(askprice), min = Min(askprice),
 					max = Max(askprice) ;
 			config
 				placement :  partitionExlocation("input") ;
 		}
 
-		() as PrintAveragePrice = Custom(AverageAskingPrice)
+		() as PrintAvPrice = Custom(AvgPrice)
 		{
 			logic
-				onTuple AverageAskingPrice :
+				onTuple AvgPrice :
 				{
 					if(average != 0.0l)
 					{

Original file line number	Diff line number	Diff line change
`@@ -39,29 +39,29 @@ composite TradesAppCloud`
`39`	`39`
`40`	`40`	`}`
`41`	`41`
`42`		`- stream<Quotes> FilteredQuotes = Filter(Quotes)`
	`42`	`+ stream<Quote> FilteredQuotes = Filter(Quotes)`
`43`	`43`	`{`
`44`	`44`	`param`
`45`	`45`	`filter : askprice > 0.0 ;`
`46`	`46`	`}`
`47`	`47`
`48`		`- stream<rstring ticker, float64 min, float64 max, float64 average> AverageAskingPrice = Aggregate(FilteredQuotes as inPort0Alias)`
	`48`	`+ stream<rstring ticker, float64 min, float64 max, float64 average> AvgPrice = Aggregate(FilteredQuotes as inPort0Alias)`
`49`	`49`	`{`
`50`	`50`	`window`
`51`	`51`	`inPort0Alias : tumbling, count(5), partitioned ;`
`52`	`52`	`param`
`53`	`53`	`partitionBy : ticker ;`
`54`	`54`	`output`
`55`		`- AverageAskingPrice : average = Average(askprice), min = Min(askprice),`
	`55`	`+ AvgPrice : average = Average(askprice), min = Min(askprice),`
`56`	`56`	`max = Max(askprice) ;`
`57`	`57`	`config`
`58`	`58`	`placement : partitionExlocation("input") ;`
`59`	`59`	`}`
`60`	`60`
`61`		`- () as PrintAveragePrice = Custom(AverageAskingPrice)`
	`61`	`+ () as PrintAvPrice = Custom(AvgPrice)`
`62`	`62`	`{`
`63`	`63`	`logic`
`64`		`- onTuple AverageAskingPrice :`
	`64`	`+ onTuple AvgPrice :`
`65`	`65`	`{`
`66`	`66`	`if(average != 0.0l)`
`67`	`67`	`{`