diff --git a/epl/trading_system_1.epl b/epl/trading_system_1.epl index dccecc5..e7c49fb 100644 --- a/epl/trading_system_1.epl +++ b/epl/trading_system_1.epl @@ -53,9 +53,9 @@ on TickEvent as t set InTradingHours = -- A stream of OHLC values calculated from TickEvents -- -create variant schema OneMinuteOHLCStream as OHLCEvent +create variant schema OHLCStream as OHLCEvent -insert into OneMinuteOHLCStream +insert into OHLCStream select * from TickEvent#OHLC(Interval, time, midDouble) @@ -70,7 +70,7 @@ create schema SMACloseStream as ats.plugin.OHLCValueEvent insert into SMACloseStream select new ats.plugin.OHLCValueEvent(time, open, high, low, close, Avg(close)) - from OneMinuteOHLCStream#length(SMASize) + from OHLCStream#length(SMASize) -- @@ -153,7 +153,7 @@ create schema LogStream as (stream string, event string) -- insert into LogStream select 'TickEvent' as stream, EPLHelpers.str(*) as event from TickEvent --- insert into LogStream select 'OneMinuteOHLCStream' as stream, EPLHelpers.str(*) as event from OneMinuteOHLCStream +-- insert into LogStream select 'OHLCStream' as stream, EPLHelpers.str(*) as event from OHLCStream -- insert into LogStream select 'BStream' as stream, EPLHelpers.str(*) as event from BStream