From 2ef785225aa8101415515132461b4e3817d1d13e Mon Sep 17 00:00:00 2001 From: Seth Ladygo Date: Mon, 23 Jul 2018 01:20:36 -0700 Subject: [PATCH] trading_system_1.epl: rename OneMinuteOHLCStream -> OHLCStream --- epl/trading_system_1.epl | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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