Examples

use com.ibm.streams.timeseries.analysis::Normalize;
composite Main {	
	graph	
		stream<list<float64> inp> stockNormalize = FileSource(){
			param
				file: "stockNormalize.csv";
				format: csv;
				initDelay: 1.0f;
		}
		
		stream<float64 Open, list<float64> normalizedStock> 
			stockNormal=Normalize(stockNormalize) 
		{
			param
				//Use the first 14 samples to estimate the means
				initSamples: 14u; 
				inputTimeSeries: inp;
			output
				stockNormal: 
				normalizedStock=normalizedTimeSeries();
			}
		() as SinkOP1 = FileSink(stockNormal){
			param
				file: "stockNormal.csv";
				format: csv;
		}
}