airlines) {
+ this.airlines = airlines;
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/desktop.ini b/realTimeAnalyticsTimeSeries/desktop.ini
new file mode 100644
index 0000000..d1ead95
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/desktop.ini
@@ -0,0 +1,2 @@
+[LocalizedFileNames]
+Command Prompt.lnk=@%SystemRoot%\system32\shell32.dll,-22022
diff --git a/realTimeAnalyticsTimeSeries/feeder/.classpath b/realTimeAnalyticsTimeSeries/feeder/.classpath
new file mode 100644
index 0000000..5fd7e85
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/.classpath
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/feeder/.project b/realTimeAnalyticsTimeSeries/feeder/.project
new file mode 100644
index 0000000..624cc2b
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/.project
@@ -0,0 +1,16 @@
+
+
+ feeder
+ NO_M2ECLIPSE_SUPPORT: Project files created with the maven-eclipse-plugin are not supported in M2Eclipse.
+
+ common
+
+
+
+ org.eclipse.jdt.core.javabuilder
+
+
+
+ org.eclipse.jdt.core.javanature
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/feeder/.settings/org.eclipse.jdt.core.prefs b/realTimeAnalyticsTimeSeries/feeder/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 0000000..1e87c1a
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,5 @@
+#Tue Jan 07 14:12:12 EST 2014
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.source=1.6
+org.eclipse.jdt.core.compiler.compliance=1.6
diff --git a/realTimeAnalyticsTimeSeries/feeder/pom.xml b/realTimeAnalyticsTimeSeries/feeder/pom.xml
new file mode 100644
index 0000000..b6daee8
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/pom.xml
@@ -0,0 +1,50 @@
+
+ 4.0.0
+ com.mycompany.app
+ feeder
+ jar
+ 1.0-SNAPSHOT
+ feeder
+
+ com.mycompany.app
+ realTimeAnalyticsTimeSeries
+ 1.0-SNAPSHOT
+
+
+ PU
+
+
+
+ com.mycompany.app
+ common
+ 1.0-SNAPSHOT
+ compile
+
+
+
+ my-app-feeder
+
+
+ maven-assembly-plugin
+
+ false
+ false
+ true
+
+ src/main/assembly/assembly.xml
+
+
+
+
+ assembly
+ package
+
+ single
+
+
+
+
+
+
+
diff --git a/realTimeAnalyticsTimeSeries/feeder/src/main/assembly/assembly.xml b/realTimeAnalyticsTimeSeries/feeder/src/main/assembly/assembly.xml
new file mode 100644
index 0000000..7b226e7
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/src/main/assembly/assembly.xml
@@ -0,0 +1,37 @@
+
+ assemble-pu
+
+ jar
+ dir
+
+ false
+
+
+ target/classes
+ keep
+ /
+
+ **/**
+
+
+
+
+
+ false
+ false
+ lib
+
+ com.mycompany.app:common
+
+
+
+ false
+ true
+ true
+ lib
+
+ com.mycompany.app:common
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/dao/impl/BookingRequestDAO.java b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/dao/impl/BookingRequestDAO.java
new file mode 100644
index 0000000..e2b1e6f
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/dao/impl/BookingRequestDAO.java
@@ -0,0 +1,24 @@
+package com.mycompany.app.dao.impl;
+
+import com.mycompany.app.common.dao.IBookingRequestDAO;
+import com.mycompany.app.common.domain.BookingRequest;
+
+import net.jini.core.lease.Lease;
+
+import org.openspaces.core.GigaSpace;
+import org.openspaces.core.context.GigaSpaceContext;
+
+public class BookingRequestDAO implements IBookingRequestDAO {
+
+ @GigaSpaceContext(name = "gigaSpace")
+ private GigaSpace gigaSpace;
+
+ public void setGigaSpace(GigaSpace gigaSpace) {
+ this.gigaSpace = gigaSpace;
+ }
+
+ public void save(BookingRequest bookingRequest) {
+ gigaSpace.write(bookingRequest, Lease.FOREVER);
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/dao/impl/SearchRequestDAO.java b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/dao/impl/SearchRequestDAO.java
new file mode 100644
index 0000000..db0e715
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/dao/impl/SearchRequestDAO.java
@@ -0,0 +1,24 @@
+package com.mycompany.app.dao.impl;
+
+import net.jini.core.lease.Lease;
+
+import com.mycompany.app.common.dao.ISearchRequestDAO;
+import com.mycompany.app.common.domain.SearchRequest;
+
+import org.openspaces.core.GigaSpace;
+import org.openspaces.core.context.GigaSpaceContext;
+
+public class SearchRequestDAO implements ISearchRequestDAO {
+
+ @GigaSpaceContext(name = "gigaSpace")
+ private GigaSpace gigaSpace;
+
+ public void setGigaSpace(GigaSpace gigaSpace) {
+ this.gigaSpace = gigaSpace;
+ }
+
+ public void save(SearchRequest searchRequest) {
+ gigaSpace.write(searchRequest, Lease.FOREVER);
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/feeder/BookingRequestFeeder.java b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/feeder/BookingRequestFeeder.java
new file mode 100644
index 0000000..dabc363
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/feeder/BookingRequestFeeder.java
@@ -0,0 +1,83 @@
+package com.mycompany.app.feeder;
+
+import com.mycompany.app.common.dao.IBookingRequestDAO;
+import com.mycompany.app.common.domain.BookingRequest;
+import com.mycompany.app.common.utils.AirportDataUtils;
+import com.mycompany.app.common.vo.SourceDestinationAirports;
+
+import org.openspaces.core.SpaceInterruptedException;
+import org.springframework.beans.factory.DisposableBean;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.util.Assert;
+
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * A feeder bean starts a scheduled task that writes a new Data objects to the space (in an unprocessed state).
+ *
+ * The scheduling uses the java.util.concurrent Scheduled Executor Service. It
+ * is started and stopped based on Spring life cycle events.
+ */
+public class BookingRequestFeeder extends Feeder implements InitializingBean, DisposableBean {
+
+ public FeederTask feederTask;
+ private IBookingRequestDAO bookingRequestDAO;
+
+ public void afterPropertiesSet() throws Exception {
+ log.info("--- STARTING BOOKING REQUEST FEEDER WITH CYCLE [" + defaultDelay + "]");
+ Assert.notNull(bookingRequestDAO, "****** bookingRequestDAO is a required property ******");
+
+ executorService = Executors.newScheduledThreadPool(3);
+ feederTask = new FeederTask();
+ sf = executorService.scheduleAtFixedRate(feederTask, defaultDelay, defaultDelay, TimeUnit.MILLISECONDS);
+ }
+
+ public void destroy() throws Exception {
+ sf.cancel(false);
+ sf = null;
+ executorService.shutdown();
+ }
+
+ public class FeederTask implements Runnable {
+ private long counter = 1;
+
+ public void run() {
+ try {
+ long time = System.currentTimeMillis();
+ BookingRequest bookingRequest = new BookingRequest("FEEDER " + Long.toString(time));
+
+ SourceDestinationAirports airports = AirportDataUtils.generateRandomSourceDestinationAirPorts();
+ bookingRequest.setSourceDestinationId(airports.getId());
+ bookingRequest.setDestinationAirport(airports.getDesintationAirport());
+ bookingRequest.setSourceAirport(airports.getSourceAirport());
+ bookingRequest.setAirline(AirportDataUtils.generateRandomAirport());
+
+ bookingRequestDAO.save(bookingRequest);
+ //log.info("--- FEEDER WROTE BOOKING REQUEST " + bookingRequest);
+ }catch(SpaceInterruptedException e) {
+ // ignore, we are being shutdown
+ }catch(Exception e) {
+ e.printStackTrace();
+ }
+ counter++;
+ }
+
+ public long getCounter() {
+ return counter;
+ }
+ }
+
+ public long getFeedCount() {
+ return feederTask.getCounter();
+ }
+
+ public void setDefaultDelay(long defaultDelay) {
+ this.defaultDelay = defaultDelay;
+ }
+
+ public void setBookingRequestDAO(IBookingRequestDAO bookingRequestDAO) {
+ this.bookingRequestDAO = bookingRequestDAO;
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/feeder/Feeder.java b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/feeder/Feeder.java
new file mode 100644
index 0000000..8f7c942
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/feeder/Feeder.java
@@ -0,0 +1,20 @@
+package com.mycompany.app.feeder;
+
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ScheduledFuture;
+import java.util.logging.Logger;
+
+public abstract class Feeder {
+
+ protected Logger log = Logger.getLogger(this.getClass().getName());
+
+ protected ScheduledExecutorService executorService;
+ protected ScheduledFuture sf;
+
+ protected long defaultDelay = 100;
+
+ public void setDefaultDelay(long defaultDelay) {
+ this.defaultDelay = defaultDelay;
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/feeder/SearchRequestFeeder.java b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/feeder/SearchRequestFeeder.java
new file mode 100644
index 0000000..9af6c9f
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/feeder/SearchRequestFeeder.java
@@ -0,0 +1,83 @@
+package com.mycompany.app.feeder;
+
+import com.mycompany.app.common.dao.ISearchRequestDAO;
+import com.mycompany.app.common.domain.SearchRequest;
+import com.mycompany.app.common.utils.AirportDataUtils;
+import com.mycompany.app.common.vo.SourceDestinationAirports;
+
+import org.openspaces.core.SpaceInterruptedException;
+import org.springframework.beans.factory.DisposableBean;
+import org.springframework.beans.factory.InitializingBean;
+import org.springframework.util.Assert;
+
+import java.util.concurrent.Executors;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * A feeder bean starts a scheduled task that writes a new Data objects to the space (in an unprocessed state).
+ *
+ *
The scheduling uses the java.util.concurrent Scheduled Executor Service. It
+ * is started and stopped based on Spring life cycle events.
+ */
+public class SearchRequestFeeder extends Feeder implements InitializingBean, DisposableBean {
+
+ private FeederTask feederTask;
+ private ISearchRequestDAO searchRequestDAO;
+
+ public void afterPropertiesSet() throws Exception {
+ log.info("--- STARTING SEARCH REQUEST FEEDER WITH CYCLE [" + defaultDelay + "]");
+ Assert.notNull(searchRequestDAO, "****** searchRequestDAO is a required property ******");
+
+ executorService = Executors.newScheduledThreadPool(1);
+ feederTask = new FeederTask();
+ sf = executorService.scheduleAtFixedRate(feederTask, defaultDelay, defaultDelay, TimeUnit.MILLISECONDS);
+ }
+
+ public void destroy() throws Exception {
+ sf.cancel(false);
+ sf = null;
+ executorService.shutdown();
+ }
+
+ public class FeederTask implements Runnable {
+ private long counter = 1;
+
+ public void run() {
+ try {
+ long time = System.currentTimeMillis();
+ SearchRequest searchRequest = new SearchRequest("FEEDER " + Long.toString(time));
+
+ SourceDestinationAirports airports = AirportDataUtils.generateRandomSourceDestinationAirPorts();
+ searchRequest.setSourceDestinationId(airports.getId());
+ searchRequest.setDestinationAirport(airports.getDesintationAirport());
+ searchRequest.setSourceAirport(airports.getSourceAirport());
+ searchRequest.setAirline(AirportDataUtils.generateRandomAirport());
+
+ searchRequestDAO.save(searchRequest);
+ //log.info("--- FEEDER WROTE SEARCH REQUEST " + searchRequest);
+ }catch(SpaceInterruptedException e) {
+ // ignore, we are being shutdown
+ }catch(Exception e) {
+ e.printStackTrace();
+ }
+ counter++;
+ }
+
+ public long getCounter() {
+ return counter;
+ }
+ }
+
+ public long getFeedCount() {
+ return feederTask.getCounter();
+ }
+
+ public void setDefaultDelay(long defaultDelay) {
+ this.defaultDelay = defaultDelay;
+ }
+
+ public void setSearchRequestDAO(ISearchRequestDAO searchRequestDAO) {
+ this.searchRequestDAO = searchRequestDAO;
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/init/InitalizeFeeders.java b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/init/InitalizeFeeders.java
new file mode 100644
index 0000000..fd0152d
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/src/main/java/com/mycompany/app/init/InitalizeFeeders.java
@@ -0,0 +1,32 @@
+package com.mycompany.app.init;
+
+import org.openspaces.core.cluster.ClusterInfo;
+import org.openspaces.pu.container.ProcessingUnitContainer;
+import org.openspaces.pu.container.standalone.StandaloneProcessingUnitContainerProvider;
+
+public class InitalizeFeeders {
+
+ public static void main(String[] args) throws Exception {
+ StandaloneProcessingUnitContainerProvider provider = new StandaloneProcessingUnitContainerProvider("target/my-app-feeder.jar");
+
+ //Provide cluster information for the specific PU instance
+ ClusterInfo clusterInfo = new ClusterInfo();
+ clusterInfo.setSchema("partitioned-sync2backup");
+ clusterInfo.setNumberOfInstances(2);
+ clusterInfo.setNumberOfBackups(1);
+ clusterInfo.setInstanceId(1);
+ provider.setClusterInfo(clusterInfo);
+
+ //Build the Spring application context and "start" it
+ ProcessingUnitContainer container = provider.createContainer();
+
+ //Stop the Feeder after 20 minutes in case the demonstrator forget to manually stop the process
+ try {
+ Thread.sleep(1200000);
+ container.close();
+ }catch(Exception e) {
+ System.out.println(e);
+ }
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/feeder/src/main/resources/META-INF/spring/pu.xml b/realTimeAnalyticsTimeSeries/feeder/src/main/resources/META-INF/spring/pu.xml
new file mode 100644
index 0000000..2aa953a
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/src/main/resources/META-INF/spring/pu.xml
@@ -0,0 +1,50 @@
+
+
+
+
+
+
+
+
+ 25
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/feeder/src/main/resources/META-INF/spring/sla.xml b/realTimeAnalyticsTimeSeries/feeder/src/main/resources/META-INF/spring/sla.xml
new file mode 100644
index 0000000..fcda6ae
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/feeder/src/main/resources/META-INF/spring/sla.xml
@@ -0,0 +1,20 @@
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/pom.xml b/realTimeAnalyticsTimeSeries/pom.xml
new file mode 100644
index 0000000..d6d59ef
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/pom.xml
@@ -0,0 +1,76 @@
+
+
+ 4.0.0
+ com.mycompany.app
+ realTimeAnalyticsTimeSeries
+ 1.0-SNAPSHOT
+ my-app
+ pom
+
+
+ org.openspaces
+ http://maven-repository.openspaces.org
+
+
+
+
+ org.openspaces
+ http://maven-repository.openspaces.org
+
+
+
+ 9.6.2-9900-RELEASE
+ 3.1.3.RELEASE
+ UTF-8
+
+
+ common
+ processor
+ feeder
+ web
+
+
+
+ com.gigaspaces
+ gs-openspaces
+ ${gsVersion}
+ provided
+
+
+ junit
+ junit
+ 4.8.1
+ test
+
+
+ org.springframework
+ spring-test
+ ${springVersion}
+ test
+
+
+
+ package
+
+
+ org.apache.maven.plugins
+ maven-compiler-plugin
+
+ 1.6
+ 1.6
+
+ 2.3.2
+
+
+ org.apache.maven.plugins
+ maven-assembly-plugin
+ 2.2-beta-2
+
+
+ org.apache.maven.plugins
+ maven-openspaces-plugin
+ ${gsVersion}
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/processor/.classpath b/realTimeAnalyticsTimeSeries/processor/.classpath
new file mode 100644
index 0000000..5fd7e85
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/.classpath
@@ -0,0 +1,31 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/processor/.project b/realTimeAnalyticsTimeSeries/processor/.project
new file mode 100644
index 0000000..8fe8580
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/.project
@@ -0,0 +1,16 @@
+
+
+ processor
+ NO_M2ECLIPSE_SUPPORT: Project files created with the maven-eclipse-plugin are not supported in M2Eclipse.
+
+ common
+
+
+
+ org.eclipse.jdt.core.javabuilder
+
+
+
+ org.eclipse.jdt.core.javanature
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/processor/.settings/org.eclipse.jdt.core.prefs b/realTimeAnalyticsTimeSeries/processor/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 0000000..1e87c1a
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,5 @@
+#Tue Jan 07 14:12:12 EST 2014
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.source=1.6
+org.eclipse.jdt.core.compiler.compliance=1.6
diff --git a/realTimeAnalyticsTimeSeries/processor/Processor.launch b/realTimeAnalyticsTimeSeries/processor/Processor.launch
new file mode 100644
index 0000000..c659d29
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/Processor.launch
@@ -0,0 +1,12 @@
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/realTimeAnalyticsTimeSeries/processor/pom.xml b/realTimeAnalyticsTimeSeries/processor/pom.xml
new file mode 100644
index 0000000..22518e3
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/pom.xml
@@ -0,0 +1,50 @@
+
+ 4.0.0
+ com.mycompany.app
+ processor
+ jar
+ 1.0-SNAPSHOT
+ processor
+
+ com.mycompany.app
+ realTimeAnalyticsTimeSeries
+ 1.0-SNAPSHOT
+
+
+ PU
+
+
+
+ com.mycompany.app
+ common
+ 1.0-SNAPSHOT
+ compile
+
+
+
+ my-app-processor
+
+
+ maven-assembly-plugin
+
+ false
+ false
+ true
+
+ src/main/assembly/assembly.xml
+
+
+
+
+ assembly
+ package
+
+ single
+
+
+
+
+
+
+
diff --git a/realTimeAnalyticsTimeSeries/processor/src/main/assembly/assembly.xml b/realTimeAnalyticsTimeSeries/processor/src/main/assembly/assembly.xml
new file mode 100644
index 0000000..7b226e7
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/src/main/assembly/assembly.xml
@@ -0,0 +1,37 @@
+
+ assemble-pu
+
+ jar
+ dir
+
+ false
+
+
+ target/classes
+ keep
+ /
+
+ **/**
+
+
+
+
+
+ false
+ false
+ lib
+
+ com.mycompany.app:common
+
+
+
+ false
+ true
+ true
+ lib
+
+ com.mycompany.app:common
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/dao/impl/BookingTimeSeriesDAO.java b/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/dao/impl/BookingTimeSeriesDAO.java
new file mode 100644
index 0000000..0199faf
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/dao/impl/BookingTimeSeriesDAO.java
@@ -0,0 +1,72 @@
+package com.mycompany.app.dao.impl;
+
+import java.util.Date;
+
+import com.gigaspaces.client.ChangeSet;
+import com.gigaspaces.query.IdQuery;
+import com.j_spaces.core.client.SQLQuery;
+import com.mycompany.app.common.dao.IBookingTimeSeriesDAO;
+import com.mycompany.app.common.domain.BookingTimeSeries;
+import com.mycompany.app.common.domain.TimeSeries;
+import com.mycompany.app.common.utils.Constants;
+
+import org.openspaces.core.GigaSpace;
+import org.openspaces.core.context.GigaSpaceContext;
+
+
+public class BookingTimeSeriesDAO implements IBookingTimeSeriesDAO {
+
+ @GigaSpaceContext(name = "gigaSpace")
+ private GigaSpace gigaSpace;
+
+ public void setGigaSpace(GigaSpace gigaSpace) {
+ this.gigaSpace = gigaSpace;
+ }
+
+ public BookingTimeSeries[] readAllCompletedTimeSeriesAfterInterval(Integer lastInterval) {
+ SQLQuery query = new SQLQuery(BookingTimeSeries.class, "interval > ? and status = ?");
+ query.setParameter(1, lastInterval);
+ query.setParameter(2, Constants.STATUS_COMPLETE);
+
+ return gigaSpace.readMultiple(query);
+ }
+
+ public BookingTimeSeries readActiveTimeSeriesByAirline(String airline) {
+ SQLQuery query = new SQLQuery(BookingTimeSeries.class, "airline = ? and status = ?")
+ .setProjections("interval"); //Use Projections API to return only the interval attribute
+
+ query.setParameter(1, airline);
+ query.setParameter(2, Constants.STATUS_ACTIVE);
+
+ return gigaSpace.read(query);
+ }
+
+ public BookingTimeSeries readTimeSeriesByIntervalId(Integer interval, String airline) {
+ String intervalId = TimeSeries.createIntervalId(interval, airline);
+ return gigaSpace.readById(BookingTimeSeries.class, intervalId, airline);
+ }
+
+ //BookingTimeSeries will only remain in the space for 60 seconds which correlates to approximately 35-40 intervals
+ public void save(BookingTimeSeries bookingTimeSeries) {
+ gigaSpace.write(bookingTimeSeries, 60000);
+ }
+
+ public BookingTimeSeries findBookingTimeSeriesWithinActiveInterval(String airline, long timeSeriesInterval) {
+ SQLQuery query = new SQLQuery(BookingTimeSeries.class, "airline = ? and lasttimestamp > ?");
+ query.setParameter(1, airline);
+ query.setParameter(2, new Date(System.currentTimeMillis() - timeSeriesInterval));
+
+ return gigaSpace.read(query);
+ }
+
+ public void incrementSourceDestinationCounter(BookingTimeSeries bookingTimeSeries, String sourceDestination) {
+ IdQuery idQuery = new IdQuery(BookingTimeSeries.class, bookingTimeSeries.getIntervalId());
+ gigaSpace.change(idQuery, new ChangeSet().increment("sourceDestinationCounter." + sourceDestination, 1));
+ }
+
+ public void updateCompletedStatus(BookingTimeSeries bookingTimeSeries) {
+ IdQuery idQuery = new IdQuery(BookingTimeSeries.class, bookingTimeSeries.getIntervalId());
+ gigaSpace.change(idQuery, new ChangeSet().set("status", Constants.STATUS_COMPLETE));
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/dao/impl/SearchTimeSeriesDAO.java b/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/dao/impl/SearchTimeSeriesDAO.java
new file mode 100644
index 0000000..2302618
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/dao/impl/SearchTimeSeriesDAO.java
@@ -0,0 +1,47 @@
+package com.mycompany.app.dao.impl;
+
+import java.util.Date;
+
+import com.gigaspaces.client.ChangeSet;
+import com.gigaspaces.query.IdQuery;
+import com.j_spaces.core.client.SQLQuery;
+import com.mycompany.app.common.dao.ISearchTimeSeriesDAO;
+import com.mycompany.app.common.domain.SearchTimeSeries;
+
+import org.openspaces.core.GigaSpace;
+import org.openspaces.core.context.GigaSpaceContext;
+import org.springframework.stereotype.Component;
+
+@Component
+public class SearchTimeSeriesDAO implements ISearchTimeSeriesDAO {
+
+ @GigaSpaceContext(name = "gigaSpace")
+ private GigaSpace gigaSpace;
+
+ public void setGigaSpace(GigaSpace gigaSpace) {
+ this.gigaSpace = gigaSpace;
+ }
+
+ public SearchTimeSeries[] readAllSearchTimeSeries() {
+ return gigaSpace.readMultiple(new SearchTimeSeries());
+ }
+
+ //SearchTimeSeries will only remain in the space for 24 seconds which correlates to 50+ intervals @ 2 seconds each
+ public void save(SearchTimeSeries searchTimeSeries) {
+ gigaSpace.write(searchTimeSeries, 24000);
+ }
+
+ public SearchTimeSeries findSearchTimeSeriesWithinCurrentInterval(String airline, long timeSeriesInterval) {
+ SQLQuery query = new SQLQuery(SearchTimeSeries.class, "airline = ? and lasttimestamp > ?");
+ query.setParameter(1, airline);
+ query.setParameter(2, new Date(System.currentTimeMillis() - timeSeriesInterval));
+
+ return gigaSpace.read(query);
+ }
+
+ public void incrementSourceDestinationCounter(SearchTimeSeries searchTimeSeries, String sourceDestination) {
+ IdQuery idQuery = new IdQuery(SearchTimeSeries.class, searchTimeSeries.getIntervalId());
+ gigaSpace.change(idQuery, new ChangeSet().increment("sourceDestinationCounter." + sourceDestination, 1));
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/processor/BookingRequestProcessor.java b/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/processor/BookingRequestProcessor.java
new file mode 100644
index 0000000..bf722d6
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/processor/BookingRequestProcessor.java
@@ -0,0 +1,85 @@
+package com.mycompany.app.processor;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.logging.Logger;
+
+import org.openspaces.events.adapter.SpaceDataEvent;
+import org.openspaces.events.polling.Polling;
+import org.springframework.util.Assert;
+
+import com.mycompany.app.common.dao.IBookingTimeSeriesDAO;
+import com.mycompany.app.common.domain.BookingRequest;
+import com.mycompany.app.common.domain.BookingTimeSeries;
+import com.mycompany.app.common.utils.AirportDataUtils;
+import com.mycompany.app.common.utils.Constants;
+
+/**
+ * The processor simulates work done on unprocessed BookingRequest objects. The processData accepts a BookingRequest object,
+ * simulates work by sleeping, and then sets the processed flag to true and returns the processed BookingRequest.
+ */
+@Polling(concurrentConsumers=10)
+public class BookingRequestProcessor {
+
+ private Logger log = Logger.getLogger(this.getClass().getName());
+
+ private long timeSeriesInterval;
+ private Map intervalAirlineMap = new HashMap(4);
+
+ private IBookingTimeSeriesDAO bookingTimeSeriesDAO;
+
+
+ @SpaceDataEvent
+ public void processData(BookingRequest bookingRequest) {
+ Assert.notNull(bookingTimeSeriesDAO, "**** bookingTimeSeriesDAO is a required property ****");
+
+ bookingRequest.setProcessedData("PROCESSED : " + bookingRequest.getRawData());
+ bookingRequest.setProcessed(true);
+ String sourceDestinationAirport = AirportDataUtils.generateSourceDestinationKey(bookingRequest.getSourceAirport(), bookingRequest.getDestinationAirport());
+ //log.info(" ------ BOOKING REQUEST PROCESSED : " + bookingRequest);
+
+ BookingTimeSeries result = bookingTimeSeriesDAO.findBookingTimeSeriesWithinActiveInterval(bookingRequest.getAirline(), timeSeriesInterval);
+ if(result != null)
+ bookingTimeSeriesDAO.incrementSourceDestinationCounter(result, sourceDestinationAirport);
+ else
+ createNewInterval(bookingRequest.getAirline(), sourceDestinationAirport);
+ }
+
+ private void createNewInterval(String airline, String sourceDestination) {
+ Integer interval = intervalAirlineMap.get(airline);
+ if(interval != null)
+ intervalAirlineMap.put(airline, ++interval);
+ else {
+ interval = 1;
+ intervalAirlineMap.put(airline, interval);
+ }
+
+ Map sourceDestinationCounterMap = new HashMap();
+ sourceDestinationCounterMap.put(sourceDestination, 1);
+
+ BookingTimeSeries bookingTimeSeries = new BookingTimeSeries(interval, airline);
+ bookingTimeSeries.setSourceDestinationCounter(sourceDestinationCounterMap);
+ bookingTimeSeries.setLasttimestamp(new Date(System.currentTimeMillis()));
+ bookingTimeSeries.setStatus(Constants.STATUS_ACTIVE);
+ bookingTimeSeriesDAO.save(bookingTimeSeries);
+
+ updatePreviousIntervalStatusAsCompleted(airline, interval-1);
+ }
+
+ private void updatePreviousIntervalStatusAsCompleted(String airline, Integer interval) {
+ BookingTimeSeries bookingTimeSeries = bookingTimeSeriesDAO.readTimeSeriesByIntervalId(interval, airline);
+ if(bookingTimeSeries != null) {
+ bookingTimeSeriesDAO.updateCompletedStatus(bookingTimeSeries);
+ }
+ }
+
+ public void setTimeSeriesInterval(long timeSeriesInterval) {
+ this.timeSeriesInterval = timeSeriesInterval;
+ }
+
+ public void setBookingTimeSeriesDAO(IBookingTimeSeriesDAO bookingTimeSeriesDAO) {
+ this.bookingTimeSeriesDAO = bookingTimeSeriesDAO;
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/processor/SearchRequestProcessor.java b/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/processor/SearchRequestProcessor.java
new file mode 100644
index 0000000..2e5f2bd
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/src/main/java/com/mycompany/app/processor/SearchRequestProcessor.java
@@ -0,0 +1,75 @@
+package com.mycompany.app.processor;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.logging.Logger;
+
+import org.openspaces.core.GigaSpace;
+import org.openspaces.events.adapter.SpaceDataEvent;
+import org.openspaces.events.polling.Polling;
+import org.springframework.util.Assert;
+
+import com.mycompany.app.common.dao.ISearchTimeSeriesDAO;
+import com.mycompany.app.common.domain.SearchRequest;
+import com.mycompany.app.common.domain.SearchTimeSeries;
+import com.mycompany.app.common.utils.AirportDataUtils;
+
+/**
+ * The processor simulates work done on unprocessed SearchRequest objects. The processData accepts a SearchRequest object,
+ * simulates work by sleeping, and then sets the processed flag to true and returns the processed SearchRequest.
+ */
+@Polling(concurrentConsumers=10)
+public class SearchRequestProcessor {
+
+ private Logger log = Logger.getLogger(this.getClass().getName());
+
+ private long timeSeriesInterval;
+ private Map intervalAirlineMap = new HashMap(4);
+
+ private ISearchTimeSeriesDAO searchTimeSeriesDAO;
+
+
+ @SpaceDataEvent
+ public void processData(SearchRequest searchRequest, GigaSpace space) {
+ Assert.notNull(searchTimeSeriesDAO, "**** searchTimeSeriesDAO is a required property ****");
+
+ searchRequest.setProcessedData("PROCESSED : " + searchRequest.getRawData());
+ searchRequest.setProcessed(true);
+ String sourceDestinationAirport = AirportDataUtils.generateSourceDestinationKey(searchRequest.getSourceAirport(), searchRequest.getDestinationAirport());
+ //log.info(" ------ SEARCH REQUEST PROCESSED : " + searchRequest);
+
+ SearchTimeSeries result = searchTimeSeriesDAO.findSearchTimeSeriesWithinCurrentInterval(searchRequest.getAirline(), timeSeriesInterval);
+ if(result != null)
+ searchTimeSeriesDAO.incrementSourceDestinationCounter(result, sourceDestinationAirport);
+ else
+ createNewInterval(searchRequest.getAirline(), sourceDestinationAirport);
+ }
+
+ private void createNewInterval(String airline, String sourceDestination) {
+ Integer interval = intervalAirlineMap.get(airline);
+ if(interval != null)
+ intervalAirlineMap.put(airline, ++interval);
+ else {
+ interval = 1;
+ intervalAirlineMap.put(airline, interval);
+ }
+
+ Map newSourceDestinationCounterMap = new HashMap();
+ newSourceDestinationCounterMap.put(sourceDestination, 1);
+
+ SearchTimeSeries searchTimeSeries = new SearchTimeSeries(interval, airline);
+ searchTimeSeries.setSourceDestinationCounter(newSourceDestinationCounterMap);
+ searchTimeSeries.setLasttimestamp(new Date(System.currentTimeMillis()));
+ searchTimeSeriesDAO.save(searchTimeSeries);
+ }
+
+ public void setTimeSeriesInterval(long timeSeriesInterval) {
+ this.timeSeriesInterval = timeSeriesInterval;
+ }
+
+ public void setSearchTimeSeriesDAO(ISearchTimeSeriesDAO searchTimeSeriesDAO) {
+ this.searchTimeSeriesDAO = searchTimeSeriesDAO;
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/processor/src/main/resources/META-INF/spring/pu.xml b/realTimeAnalyticsTimeSeries/processor/src/main/resources/META-INF/spring/pu.xml
new file mode 100644
index 0000000..d8792e1
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/src/main/resources/META-INF/spring/pu.xml
@@ -0,0 +1,95 @@
+
+
+
+
+
+
+
+
+ 1800
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ yyyy-MM-dd HH:mm:ss
+ HH:mm:ss
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/processor/src/main/resources/META-INF/spring/sla.xml b/realTimeAnalyticsTimeSeries/processor/src/main/resources/META-INF/spring/sla.xml
new file mode 100644
index 0000000..ee8ede6
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/processor/src/main/resources/META-INF/spring/sla.xml
@@ -0,0 +1,20 @@
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/readme.txt b/realTimeAnalyticsTimeSeries/readme.txt
new file mode 100644
index 0000000..196961f
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/readme.txt
@@ -0,0 +1,109 @@
+Creates a basic SBA application with two processing units. The Feeder
+processing unit sends Data objects through the Space to a Processor.
+The Space and the Processor are collocated in the same processing unit.
+JVM: >= 5.
+
+GENERAL DESCRIPTION:
+--------------------
+
+ The project consists of three modules: common, processor and feeder. The common
+module includes all the shared resources and classes between both the processor
+and the feeder. In our case, the common module includes the "Data" class which
+is written and taken from the Space.
+
+ The processor module, which is a processing unit, starts up a Space and on top of
+it starts a polling container that performs a take from the Space of unprocessed Data
+entries. The take operation results in an "event" that will end up executing the
+"Processor" class. The Processor "processes" the Data object (by setting its processed
+flag to true) and returns it. The return value is automatically written back to the Space.
+ The processor also comes with both a unit test and integration test that verifies its behavior.
+
+ The feeder module, which is also a processing unit, connects to a Space remotely and
+writes unprocessed Data objects to the Space (resulting in events firing up within
+the processor processing unit).
+
+BUILDING, PACKAGING, RUNNING, DEPLOYING
+---------------------------------------
+
+Quick list:
+
+* mvn compile: Compiles the project.
+* mvn os:run: Runs the project.
+* mvn test: Runs the tests in the project.
+* mvn package: Compiles and packages the project.
+* mvn os:run-standalone: Runs a packaged application (from the jars).
+* mvn os:deploy: Deploys the project onto the Service Grid.
+* mvn os:undeploy: Removes the project from the Service Grid.
+
+ In order to build the example, a simple "mvn compile" executed from the root of the
+project will compile all the different modules.
+
+ Packaging the application can be done using "mvn package" (note, by default, it also
+runs the tests, in order to disable it, use -DskipTests). The packaging process jars up
+the common module. The feeder and processor modules packaging process creates a
+"processing unit structure" directory within the target directory called [app-name]-[module].
+It also creates a jar from the mentioned directory called [app-name]-[module].jar.
+
+ In order to simply run both the processor and the feeder (after compiling), "mvn os:run" can be used.
+This will run a single instance of the processor and a single instance of the feeder within
+the same JVM using the compilation level classpath (no need for packaging).
+ A specific module can also be executed by itself, which in this case, executing more than
+one instance of the processing unit can be done. For example, running the processor module with
+a cluster topology of 2 partitions, each with one backup, the following command can be used:
+mvn os:run -Dmodule=processor -Dcluster="total_members=2,1".
+
+ In order to run a packaged processing unit, "mvn package os:run-standalone" can be used (if
+"mvn package" was already executed, it can be omitted). This operation will run the processing units
+using the packaged jar files. Running a specific module with a cluster topology can be executed using:
+mvn package os:run-standalone -Dmodule=processor -Dcluster="total_members=2,1".
+
+ Deploying the application requires starting up a GSM and at least 2 GSCs (scripts located under
+the bin directory within the GigaSpaces installation). Once started, running "mvn package os:deploy"
+will deploy the two processing units.
+ When deploying, the SLA elements within each processing unit descriptor (pu.xml) are taken into
+account. This means that by default when deploying the application, 2 partitions, each with
+one backup will be created for the processor, and a single instance of the feeder will be created.
+ A special note regarding groups and deployment: If the GSM and GSCs were started under a specific
+group, the -Dgroups=[group-name] will need to be used in the deploy command.
+
+WORKING WITH ECLIPSE
+--------------------
+
+ In order to generate eclipse project the following command need to be executed from the root of
+the application: "mvn eclipse:eclipse". Pointing the Eclipse import existing project wizard
+to the application root directory will result in importing the three modules.
+If this is a fresh Eclipse installation, the M2_REPO needs be defined and pointed to the local
+maven repository (which resides under USER_HOME/.m2/repository).
+
+After generating the projects, configure them to work with maven:
+for each project, right click on it and select Configure > Convert to Maven Project.
+
+ The application itself comes with built in launch targets allowing to run the processor and the
+feeder using Eclipse run (or debug) targets.
+
+A NOTE OF CLUSTERING
+--------------------
+
+ This application focus on showing how SBA is used. The processor starts up an embedded Space and
+works directly on it. When deploying 2 partitions of the processor, two embedded spaces (within the
+same cluster) will be created, with each polling container working only on the cluster member it
+started in an in memory and transactional manner. This is the power of such an architecture, where
+the processing of the Data happens in a collocated manner with the Data. If we want to add High
+Availability to the processor, we can deploy 2 partitions, each with one backup (2,1). In this
+case, the processor instances that ends up starting a cluster member Space which is the backup
+will not perform any processing since the polling container identifies the Space state and won't
+perform the take operation. If one of the processor primaries instances will fail, the backup
+instance will become primary (with an up to date data), and its polling container will start
+processing all the relevant Data. Note, when deploying on top of the Service Grid, the Service
+Grid will also identify that one instance failed, and will automatically start it over in another
+container (GSC).
+
+ The feeder works with a clustered view of the Space (the 2,1 cluster topology looking as one), and
+simply writes unprocessed Data objects to the Space. The routing (@SpaceRouting) controls to which
+partition the unprocessed Data will be written and consequently which instance will process it.
+
+MAVEN PLUGIN WIKI PAGE
+---------------------------------
+
+ For more information about the Maven Plugin please refer to:
+http://www.gigaspaces.com/wiki/display/XAP91/Maven+Plugin
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/web/.classpath b/realTimeAnalyticsTimeSeries/web/.classpath
new file mode 100644
index 0000000..9775750
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/.classpath
@@ -0,0 +1,99 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/realTimeAnalyticsTimeSeries/web/.project b/realTimeAnalyticsTimeSeries/web/.project
new file mode 100644
index 0000000..c1b3cb5
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/.project
@@ -0,0 +1,23 @@
+
+
+ web
+ NO_M2ECLIPSE_SUPPORT: Project files created with the maven-eclipse-plugin are not supported in M2Eclipse.
+
+
+
+ org.eclipse.jdt.core.javabuilder
+
+
+ org.eclipse.wst.common.project.facet.core.builder
+
+
+ org.eclipse.wst.validation.validationbuilder
+
+
+
+ org.eclipse.wst.common.project.facet.core.nature
+ org.eclipse.jdt.core.javanature
+ org.eclipse.wst.common.modulecore.ModuleCoreNature
+ org.eclipse.jem.workbench.JavaEMFNature
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/web/.settings/org.eclipse.jdt.core.prefs b/realTimeAnalyticsTimeSeries/web/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 0000000..721d77c
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,5 @@
+#Fri Jan 10 12:56:27 EST 2014
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.source=1.6
+org.eclipse.jdt.core.compiler.compliance=1.6
diff --git a/realTimeAnalyticsTimeSeries/web/.settings/org.eclipse.wst.common.component b/realTimeAnalyticsTimeSeries/web/.settings/org.eclipse.wst.common.component
new file mode 100644
index 0000000..6a96f1d
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/.settings/org.eclipse.wst.common.component
@@ -0,0 +1,43 @@
+
+
+
+
+
+
+ uses
+
+
+ uses
+
+
+ uses
+
+
+ uses
+
+
+ uses
+
+
+ uses
+
+
+ uses
+
+
+ uses
+
+
+ uses
+
+
+ uses
+
+
+ uses
+
+
+
+
+
+
diff --git a/realTimeAnalyticsTimeSeries/web/.settings/org.eclipse.wst.common.project.facet.core.xml b/realTimeAnalyticsTimeSeries/web/.settings/org.eclipse.wst.common.project.facet.core.xml
new file mode 100644
index 0000000..f3728ad
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/.settings/org.eclipse.wst.common.project.facet.core.xml
@@ -0,0 +1,7 @@
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/web/pom.xml b/realTimeAnalyticsTimeSeries/web/pom.xml
new file mode 100644
index 0000000..c08c81b
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/pom.xml
@@ -0,0 +1,56 @@
+
+
+ 4.0.0
+
+ com.mycompany.app
+ realTimeAnalyticsTimeSeries
+ 1.0-SNAPSHOT
+
+ com.mycompany.app
+ web
+ 1.0-SNAPSHOT
+ war
+ web
+ http://maven.apache.org
+
+
+ junit
+ junit
+ 3.8.1
+ test
+
+
+ org.springframework
+ spring-core
+ 3.1.3.RELEASE
+
+
+ org.springframework
+ spring-web
+ 3.1.3.RELEASE
+
+
+ org.springframework
+ spring-webmvc
+ 3.1.3.RELEASE
+
+
+ javax.servlet
+ javax.servlet-api
+ 3.0.1
+
+
+ com.mycompany.app
+ common
+ 1.0-SNAPSHOT
+
+
+
+ my-app-web
+
+
+ GigaSpaces
+ http://www.gigaspaces.com/
+
+
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/delegate/TaskDelegate.java b/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/delegate/TaskDelegate.java
new file mode 100644
index 0000000..9a54227
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/delegate/TaskDelegate.java
@@ -0,0 +1,61 @@
+package com.mycompany.app.web.delegate;
+
+import java.util.TreeMap;
+
+import org.openspaces.core.GigaSpace;
+import org.openspaces.core.context.GigaSpaceContext;
+
+import com.gigaspaces.async.AsyncFuture;
+import com.mycompany.app.common.vo.SourceDestinationAirports;
+import com.mycompany.app.web.tasks.DetermineInitialIntervalTask;
+import com.mycompany.app.web.tasks.RetrieveNextActiveBookingTimeSeriesTask;
+import com.mycompany.app.web.tasks.distributed.RetrieveCompletedBookingTimeSeriesTask;
+
+
+public class TaskDelegate {
+
+ @GigaSpaceContext(name = "gigaSpace")
+ private GigaSpace gigaSpace;
+
+ public TaskDelegate() {}
+
+ public void setGigaSpace(GigaSpace gigaSpace) {
+ this.gigaSpace = gigaSpace;
+ }
+
+ public TreeMap retrieveCompletedBookingTimeSeriesIntervals(String airline, Integer maxIntervals) {
+ AsyncFuture determineInitialIntervalResult = gigaSpace.execute(new DetermineInitialIntervalTask(airline, maxIntervals));
+
+ Integer lastInterval = null;
+ try {
+ lastInterval = determineInitialIntervalResult.get();
+ }catch(Exception e) {
+ e.printStackTrace();
+ }
+
+ AsyncFuture> retrieveCompletedBookingTimeSeriesResult
+ = gigaSpace.execute(new RetrieveCompletedBookingTimeSeriesTask(airline, lastInterval));
+
+ TreeMap airports = null;
+ try {
+ airports = retrieveCompletedBookingTimeSeriesResult.get();
+ }catch(Exception e) {
+ e.printStackTrace();
+ }
+ return airports;
+ }
+
+ public TreeMap retrieveNextActiveBookingTimeSeries(String airline, Integer lastInterval) {
+ AsyncFuture> retrieveNextActiveBookingTimeSeriesResult
+ = gigaSpace.execute(new RetrieveNextActiveBookingTimeSeriesTask(airline, lastInterval));
+
+ TreeMap airports = null;
+ try {
+ airports = retrieveNextActiveBookingTimeSeriesResult.get();
+ }catch(Exception e) {
+ e.printStackTrace();
+ }
+ return airports;
+ }
+
+}
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/servlet/TimeSeriesServlet.java b/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/servlet/TimeSeriesServlet.java
new file mode 100644
index 0000000..5d7cfd9
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/servlet/TimeSeriesServlet.java
@@ -0,0 +1,94 @@
+package com.mycompany.app.web.servlet;
+
+import java.io.IOException;
+import java.util.SortedMap;
+import java.util.logging.Logger;
+
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+
+import org.springframework.util.Assert;
+
+import com.mycompany.app.common.utils.StringUtils;
+import com.mycompany.app.common.vo.Airline;
+import com.mycompany.app.common.vo.Interval;
+import com.mycompany.app.common.vo.SourceDestinationAirports;
+import com.mycompany.app.web.delegate.TaskDelegate;
+
+
+public class TimeSeriesServlet extends HttpServlet {
+ private Logger log = Logger.getLogger(this.getClass().getName());
+
+ private static final long serialVersionUID = -3774809284043159067L;
+
+ private TaskDelegate taskDelegate;
+
+ @Override
+ public void init() throws ServletException {
+ taskDelegate = (TaskDelegate) getServletContext().getAttribute("taskDelegate");
+ if(taskDelegate == null) {
+ throw new IllegalStateException("taskDelegate cannot be null");
+ }
+ }
+
+ protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+ doPost(request, response);
+ }
+
+ protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
+ Assert.notNull(taskDelegate, "**** taskDelegate is a required property ****");
+
+ String service = StringUtils.trim(request.getParameter("service"));
+ String airline = StringUtils.trim(request.getParameter("airline"));
+ Integer lastInterval = StringUtils.stringToInteger(request.getParameter("lastInterval"));
+
+ SortedMap sourceDestinationMap = null;
+ if("getAllIntervals".equals(service)) {
+ sourceDestinationMap = taskDelegate.retrieveCompletedBookingTimeSeriesIntervals(airline, 12);
+
+ }else if("getNextInterval".equals(service)) {
+ sourceDestinationMap = taskDelegate.retrieveNextActiveBookingTimeSeries(airline, lastInterval);
+ }
+
+ if(sourceDestinationMap != null) {
+ response.setContentType("text/html");
+ response.getWriter().println(createXmlResponsePayload(sourceDestinationMap));
+ }
+ }
+
+ private String createXmlResponsePayload(SortedMap sourceDestinationMap) {
+ StringBuffer sb = new StringBuffer();
+
+ sb.append("");
+ for(String sourceDestination : sourceDestinationMap.keySet()) {
+ sb.append("");
+
+ SourceDestinationAirports airports = sourceDestinationMap.get(sourceDestination);
+ sb.append("") .append(airports.getId()) .append("");
+
+ SortedMap airlines = airports.getAirlines();
+ for(String airlineName : airlines.keySet()) {
+ Airline airline = airlines.get(airlineName);
+ sb.append("");
+ sb.append("") .append(airlineName) .append("");
+
+ SortedMap intervals = airline.getIntervals();
+ for(Integer intervalNo : intervals.keySet()) {
+ Interval interval = intervals.get(intervalNo);
+ sb.append("");
+ sb.append("") .append(intervalNo) .append("");
+ sb.append("") .append(interval.getCount()) .append("");
+ sb.append("");
+ }
+ sb.append("");
+ }
+ sb.append("");
+ }
+ sb.append("");
+
+ return sb.toString();
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/tasks/DetermineInitialIntervalTask.java b/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/tasks/DetermineInitialIntervalTask.java
new file mode 100644
index 0000000..b5e5820
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/tasks/DetermineInitialIntervalTask.java
@@ -0,0 +1,54 @@
+package com.mycompany.app.web.tasks;
+
+import javax.annotation.Resource;
+
+import org.openspaces.core.executor.AutowireTask;
+import org.openspaces.core.executor.Task;
+
+import com.gigaspaces.annotation.pojo.SpaceRouting;
+import com.mycompany.app.common.dao.IBookingTimeSeriesDAO;
+import com.mycompany.app.common.domain.BookingTimeSeries;
+
+@AutowireTask
+public class DetermineInitialIntervalTask implements Task {
+
+ private static final long serialVersionUID = -2846168106076276015L;
+
+ private String airline;
+ private Integer maxIntervals;
+
+ @Resource
+ private transient IBookingTimeSeriesDAO bookingTimeSeriesDAO;
+
+ public DetermineInitialIntervalTask() {};
+
+ public DetermineInitialIntervalTask(String airline, Integer maxIntervals) {
+ this.airline = airline;
+ this.maxIntervals = maxIntervals;
+ }
+
+ @SpaceRouting
+ public String getAirline() {
+ return airline;
+ }
+
+ public Integer execute() throws Exception {
+ BookingTimeSeries activeBookingTimeSeries = bookingTimeSeriesDAO.readActiveTimeSeriesByAirline(airline);
+
+ //If applicable, limits the initial graph rendering to a max of provided intervals
+ Integer activeInterval = activeBookingTimeSeries.getInterval();
+ if(activeInterval > maxIntervals) {
+ return activeInterval - maxIntervals;
+ }
+ return 0;
+ }
+
+ public IBookingTimeSeriesDAO getBookingTimeSeriesDAO() {
+ return bookingTimeSeriesDAO;
+ }
+
+ public void setBookingTimeSeriesDAO(IBookingTimeSeriesDAO bookingTimeSeriesDAO) {
+ this.bookingTimeSeriesDAO = bookingTimeSeriesDAO;
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/tasks/RetrieveNextActiveBookingTimeSeriesTask.java b/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/tasks/RetrieveNextActiveBookingTimeSeriesTask.java
new file mode 100644
index 0000000..0bfb839
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/tasks/RetrieveNextActiveBookingTimeSeriesTask.java
@@ -0,0 +1,57 @@
+package com.mycompany.app.web.tasks;
+
+import java.util.TreeMap;
+
+import javax.annotation.Resource;
+
+import org.openspaces.core.executor.AutowireTask;
+import org.openspaces.core.executor.Task;
+
+import com.gigaspaces.annotation.pojo.SpaceRouting;
+import com.mycompany.app.common.dao.IBookingTimeSeriesDAO;
+import com.mycompany.app.common.domain.BookingTimeSeries;
+import com.mycompany.app.common.utils.AirportDataUtils;
+import com.mycompany.app.common.vo.SourceDestinationAirports;
+
+@AutowireTask
+public class RetrieveNextActiveBookingTimeSeriesTask implements Task> {
+
+ private static final long serialVersionUID = -2846168106076276015L;
+
+ private String airline;
+ private Integer lastInterval;
+
+ @Resource
+ private transient IBookingTimeSeriesDAO bookingTimeSeriesDAO;
+
+ public RetrieveNextActiveBookingTimeSeriesTask() {};
+
+ public RetrieveNextActiveBookingTimeSeriesTask(String airline, Integer lastInterval) {
+ this.airline = airline;
+ this.lastInterval = lastInterval;
+ }
+
+ @SpaceRouting
+ public String getAirline() {
+ return airline;
+ }
+
+ public TreeMap execute() throws Exception {
+ BookingTimeSeries bookingTimeSeries = bookingTimeSeriesDAO.readTimeSeriesByIntervalId(lastInterval+1, airline);
+
+ //Reuse the array structure to reduce complexity and redundancy in the web layer
+ TreeMap airports = new TreeMap();
+ AirportDataUtils.updateAirportMap(bookingTimeSeries, airports);
+
+ return airports;
+ }
+
+ public IBookingTimeSeriesDAO getBookingTimeSeriesDAO() {
+ return bookingTimeSeriesDAO;
+ }
+
+ public void setBookingTimeSeriesDAO(IBookingTimeSeriesDAO bookingTimeSeriesDAO) {
+ this.bookingTimeSeriesDAO = bookingTimeSeriesDAO;
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/tasks/distributed/RetrieveCompletedBookingTimeSeriesTask.java b/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/tasks/distributed/RetrieveCompletedBookingTimeSeriesTask.java
new file mode 100644
index 0000000..c255733
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/java/com/mycompany/app/web/tasks/distributed/RetrieveCompletedBookingTimeSeriesTask.java
@@ -0,0 +1,76 @@
+package com.mycompany.app.web.tasks.distributed;
+
+import java.util.List;
+import java.util.TreeMap;
+
+import javax.annotation.Resource;
+
+import org.openspaces.core.executor.AutowireTask;
+import org.openspaces.core.executor.DistributedTask;
+
+import com.gigaspaces.annotation.pojo.SpaceRouting;
+import com.gigaspaces.async.AsyncResult;
+import com.mycompany.app.common.dao.IBookingTimeSeriesDAO;
+import com.mycompany.app.common.domain.BookingTimeSeries;
+import com.mycompany.app.common.utils.AirportDataUtils;
+import com.mycompany.app.common.vo.SourceDestinationAirports;
+
+
+@AutowireTask
+public class RetrieveCompletedBookingTimeSeriesTask implements DistributedTask> {
+
+ private static final long serialVersionUID = -2846168106076276015L;
+
+ private String airline;
+ private Integer lastInterval;
+
+ @Resource
+ private transient IBookingTimeSeriesDAO bookingTimeSeriesDAO;
+
+ public RetrieveCompletedBookingTimeSeriesTask() {};
+
+ public RetrieveCompletedBookingTimeSeriesTask(String airline, Integer lastInterval) {
+ this.airline = airline;
+ this.lastInterval = lastInterval;
+ }
+
+ @SpaceRouting
+ public String getAirline() {
+ return airline;
+ }
+
+ public BookingTimeSeries[] execute() throws Exception {
+ return bookingTimeSeriesDAO.readAllCompletedTimeSeriesAfterInterval(lastInterval);
+ }
+
+ public TreeMap reduce(List> results) throws Exception {
+ TreeMap airports = new TreeMap();
+
+ if(results != null) {
+ for(AsyncResult result: results) {
+ if(result != null) {
+ if(result.getException() != null) {
+ throw result.getException();
+ }
+
+ for(BookingTimeSeries bookingTimeSeries : result.getResult()) {
+ if(bookingTimeSeries != null) {
+ AirportDataUtils.updateAirportMap(bookingTimeSeries, airports);
+ }
+ }
+ }
+ }
+ }
+
+ return airports;
+ }
+
+ public IBookingTimeSeriesDAO getBookingTimeSeriesDAO() {
+ return bookingTimeSeriesDAO;
+ }
+
+ public void setBookingTimeSeriesDAO(IBookingTimeSeriesDAO bookingTimeSeriesDAO) {
+ this.bookingTimeSeriesDAO = bookingTimeSeriesDAO;
+ }
+
+}
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/META-INF/MANIFEST.MF b/realTimeAnalyticsTimeSeries/web/src/main/webapp/META-INF/MANIFEST.MF
new file mode 100644
index 0000000..254272e
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/webapp/META-INF/MANIFEST.MF
@@ -0,0 +1,3 @@
+Manifest-Version: 1.0
+Class-Path:
+
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/META-INF/spring/pu.xml b/realTimeAnalyticsTimeSeries/web/src/main/webapp/META-INF/spring/pu.xml
new file mode 100644
index 0000000..36085c1
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/webapp/META-INF/spring/pu.xml
@@ -0,0 +1,23 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/META-INF/spring/sla.xml b/realTimeAnalyticsTimeSeries/web/src/main/webapp/META-INF/spring/sla.xml
new file mode 100644
index 0000000..1197f63
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/webapp/META-INF/spring/sla.xml
@@ -0,0 +1,9 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/WEB-INF/web.xml b/realTimeAnalyticsTimeSeries/web/src/main/webapp/WEB-INF/web.xml
new file mode 100644
index 0000000..09aa24e
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/webapp/WEB-INF/web.xml
@@ -0,0 +1,21 @@
+
+
+
+ ClientWeb
+
+ index.jsp
+
+
+
+ TimeSeriesServlet
+ TimeSeriesServlet
+ com.mycompany.app.web.servlet.TimeSeriesServlet
+
+
+ TimeSeriesServlet
+ /TimeSeriesServlet
+
+
\ No newline at end of file
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/detail.css b/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/detail.css
new file mode 100644
index 0000000..4b42981
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/detail.css
@@ -0,0 +1,103 @@
+.rickshaw_graph .detail {
+ pointer-events: none;
+ position: absolute;
+ top: 0;
+ z-index: 2;
+ background: rgba(0, 0, 0, 0.1);
+ bottom: 0;
+ width: 1px;
+ transition: opacity 0.25s linear;
+ -moz-transition: opacity 0.25s linear;
+ -o-transition: opacity 0.25s linear;
+ -webkit-transition: opacity 0.25s linear;
+}
+.rickshaw_graph .detail.inactive {
+ opacity: 0;
+}
+.rickshaw_graph .detail .item.active {
+ opacity: 1;
+}
+.rickshaw_graph .detail .x_label {
+ font-family: Arial, sans-serif;
+ border-radius: 3px;
+ padding: 6px;
+ opacity: 0.5;
+ border: 1px solid #e0e0e0;
+ font-size: 12px;
+ position: absolute;
+ background: white;
+ white-space: nowrap;
+}
+.rickshaw_graph .detail .x_label.left {
+ left: 0;
+}
+.rickshaw_graph .detail .x_label.right {
+ right: 0;
+}
+.rickshaw_graph .detail .item {
+ position: absolute;
+ z-index: 2;
+ border-radius: 3px;
+ padding: 0.25em;
+ font-size: 12px;
+ font-family: Arial, sans-serif;
+ opacity: 0;
+ background: rgba(0, 0, 0, 0.4);
+ color: white;
+ border: 1px solid rgba(0, 0, 0, 0.4);
+ margin-left: 1em;
+ margin-right: 1em;
+ margin-top: -1em;
+ white-space: nowrap;
+}
+.rickshaw_graph .detail .item.left {
+ left: 0;
+}
+.rickshaw_graph .detail .item.right {
+ right: 0;
+}
+.rickshaw_graph .detail .item.active {
+ opacity: 1;
+ background: rgba(0, 0, 0, 0.8);
+}
+.rickshaw_graph .detail .item:after {
+ position: absolute;
+ display: block;
+ width: 0;
+ height: 0;
+
+ content: "";
+
+ border: 5px solid transparent;
+}
+.rickshaw_graph .detail .item.left:after {
+ top: 1em;
+ left: -5px;
+ margin-top: -5px;
+ border-right-color: rgba(0, 0, 0, 0.8);
+ border-left-width: 0;
+}
+.rickshaw_graph .detail .item.right:after {
+ top: 1em;
+ right: -5px;
+ margin-top: -5px;
+ border-left-color: rgba(0, 0, 0, 0.8);
+ border-right-width: 0;
+}
+.rickshaw_graph .detail .dot {
+ width: 4px;
+ height: 4px;
+ margin-left: -2px;
+ margin-top: -2px;
+ border-radius: 5px;
+ position: absolute;
+ box-shadow: 0 0 2px rgba(0, 0, 0, 0.6);
+ background: white;
+ border-width: 2px;
+ border-style: solid;
+ display: none;
+ background-clip: padding-box;
+}
+.rickshaw_graph .detail .dot.active {
+ display: block;
+}
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/extensions.css b/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/extensions.css
new file mode 100644
index 0000000..fd9bb1d
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/extensions.css
@@ -0,0 +1,184 @@
+div, span, p, td {
+ font-family: Arial, sans-serif;
+}
+#content {
+ width: 1200px;
+}
+#chart {
+ display: inline-block;
+}
+#chart path {
+ -webkit-transition: opacity 0.2s linear;
+}
+#preview {
+ margin-top: 10px;
+}
+#legend {
+ display: inline-block;
+ position: relative;
+ left: 8px;
+}
+#legend_container {
+ position: absolute;
+ right: 0;
+ bottom: 26px;
+ width: 0;
+}
+#chart_container {
+ position: relative;
+ display: inline-block;
+}
+#smoother {
+ margin: 0 0 10px 16px;
+ width: 100px;
+}
+.rickshaw_graph .detail {
+ left: -1000;
+}
+#chart {
+ border: 1px solid #f0f0f0;
+}
+#side_panel {
+ padding: 0 20px 20px 0;
+ width: 240px;
+ display: inline-block;
+ vertical-align: top;
+}
+#side_panel section {
+ color: #505050;
+ font-size: 12px;
+}
+#side_panel section h6 {
+ margin: 0 0 1em 0;
+ font-size: 12px;
+ font-weight: normal;
+}
+#side_panel .ui-slider-horizontal {
+ height: 1px !important;
+ border-color: #e0e0e0;
+ margin-bottom: 10px;
+}
+#side_panel .ui-slider-handle {
+ border-color: #a0a0a0;
+ height: 9px !important;
+ width: 9px !important;
+ top: -5px !important;
+ border-radius: 6px;
+ outline: none;
+ cursor: pointer;
+}
+#legend {
+ background-color: white;
+ margin-left: 0;
+ padding: 0;
+ left: 0;
+}
+#legend .label {
+ color: #404040;
+}
+#legend .action {
+ color: black;
+ opacity: 0.5;
+}
+#legend ul {
+ padding: 0;
+}
+h1 {
+ font-family: Franklin Gothic Medium, UnDotum, Helvetica, Arial;
+ font-weight: normal;
+ font-size: 20px;
+}
+section {
+ border: none;
+ border-top: 1px solid #eaeaea;
+ padding: 15px 0;
+}
+#smoother {
+ margin: 5px 0 0 10px;
+ width: 90%;
+}
+label.disabled {
+ opacity: 0.4;
+}
+#renderer_form.toggler {
+ display: block;
+ margin: 0;
+}
+#renderer_form.toggler input[type=radio]:checked {
+ outline: 2px solid steelblue;
+}
+#renderer_form.toggler input[type=radio] {
+ -moz-appearance: button;
+ background: white;
+ margin: 0 7px;
+ width: 39px;
+ height: 26px;
+ position: absolute;
+}
+#renderer_form.toggler label {
+ display: inline-block;
+ padding: 0;
+ width: 39px;
+ padding-top: 27px;
+ text-align: center;
+ font-size: 10px;
+ color: #808080;
+ background-repeat: no-repeat;
+ position: relative;
+ margin: 0 7px;
+ cursor: pointer;
+}
+#interpolation_form,
+#offset_form {
+ vertical-align: top;
+ display: inline-block;
+ width: 45%;
+}
+#interpolation_form label,
+#offset_form label {
+ display: block;
+}
+label[for=area] {
+ background: url(images/om_stack.png);
+}
+label[for=line] {
+ background: url(images/om_lines.png);
+}
+label[for=bar] {
+ background: url(images/om_bar.png);
+}
+label[for=scatter] {
+ background: url(images/om_scatter.png);
+}
+#offset_form label,
+#interpolation_form label {
+ background-repeat: no-repeat;
+ background-position: 2em center;
+ cursor: pointer;
+ cursor: hand;
+}
+#offset_form label span,
+#interpolation_form label span {
+ padding-left: 36px;
+}
+label[for=stack] {
+ background-image: url(images/offset_stack.png);
+}
+label[for=pct] {
+ background-image: url(images/offset_pct.png);
+}
+label[for=stream] {
+ background-image: url(images/offset_stream.png);
+}
+label[for=value] {
+ background-image: url(images/offset_value.png);
+}
+label[for=cardinal] {
+ background-image: url(images/interp_cardinal.png);
+}
+label[for=linear] {
+ background-image: url(images/interp_linear.png);
+}
+label[for=step] {
+ background-image: url(images/interp_step.png);
+}
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/graph.css b/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/graph.css
new file mode 100644
index 0000000..1f9c976
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/graph.css
@@ -0,0 +1,177 @@
+/* graph */
+
+.rickshaw_graph {
+ position: relative;
+}
+.rickshaw_graph svg {
+ display: block;
+ overflow: hidden;
+}
+
+/* ticks */
+
+.rickshaw_graph .x_tick {
+ position: absolute;
+ top: 0;
+ bottom: 0;
+ width: 0px;
+ border-left: 1px dotted rgba(0, 0, 0, 0.2);
+ pointer-events: none;
+}
+.rickshaw_graph .x_tick .title {
+ position: absolute;
+ font-size: 12px;
+ font-family: Arial, sans-serif;
+ opacity: 0.5;
+ white-space: nowrap;
+ margin-left: 3px;
+ bottom: 1px;
+}
+
+/* annotations */
+
+.rickshaw_annotation_timeline {
+ height: 1px;
+ border-top: 1px solid #e0e0e0;
+ margin-top: 10px;
+ position: relative;
+}
+.rickshaw_annotation_timeline .annotation {
+ position: absolute;
+ height: 6px;
+ width: 6px;
+ margin-left: -2px;
+ top: -3px;
+ border-radius: 5px;
+ background-color: rgba(0, 0, 0, 0.25);
+}
+.rickshaw_graph .annotation_line {
+ position: absolute;
+ top: 0;
+ bottom: -6px;
+ width: 0px;
+ border-left: 2px solid rgba(0, 0, 0, 0.3);
+ display: none;
+}
+.rickshaw_graph .annotation_line.active {
+ display: block;
+}
+
+.rickshaw_graph .annotation_range {
+ background: rgba(0, 0, 0, 0.1);
+ display: none;
+ position: absolute;
+ top: 0;
+ bottom: -6px;
+}
+.rickshaw_graph .annotation_range.active {
+ display: block;
+}
+.rickshaw_graph .annotation_range.active.offscreen {
+ display: none;
+}
+
+.rickshaw_annotation_timeline .annotation .content {
+ background: white;
+ color: black;
+ opacity: 0.9;
+ padding: 5px 5px;
+ box-shadow: 0 0 2px rgba(0, 0, 0, 0.8);
+ border-radius: 3px;
+ position: relative;
+ z-index: 20;
+ font-size: 12px;
+ padding: 6px 8px 8px;
+ top: 18px;
+ left: -11px;
+ width: 160px;
+ display: none;
+ cursor: pointer;
+}
+.rickshaw_annotation_timeline .annotation .content:before {
+ content: "\25b2";
+ position: absolute;
+ top: -11px;
+ color: white;
+ text-shadow: 0 -1px 1px rgba(0, 0, 0, 0.8);
+}
+.rickshaw_annotation_timeline .annotation.active,
+.rickshaw_annotation_timeline .annotation:hover {
+ background-color: rgba(0, 0, 0, 0.8);
+ cursor: none;
+}
+.rickshaw_annotation_timeline .annotation .content:hover {
+ z-index: 50;
+}
+.rickshaw_annotation_timeline .annotation.active .content {
+ display: block;
+}
+.rickshaw_annotation_timeline .annotation:hover .content {
+ display: block;
+ z-index: 50;
+}
+.rickshaw_graph .y_axis,
+.rickshaw_graph .x_axis_d3 {
+ fill: none;
+}
+.rickshaw_graph .y_ticks .tick,
+.rickshaw_graph .x_ticks_d3 .tick {
+ stroke: rgba(0, 0, 0, 0.16);
+ stroke-width: 2px;
+ shape-rendering: crisp-edges;
+ pointer-events: none;
+}
+.rickshaw_graph .y_grid .tick,
+.rickshaw_graph .x_grid_d3 .tick {
+ z-index: -1;
+ stroke: rgba(0, 0, 0, 0.20);
+ stroke-width: 1px;
+ stroke-dasharray: 1 1;
+}
+.rickshaw_graph .y_grid .tick[data-y-value="0"] {
+ stroke-dasharray: 1 0;
+}
+.rickshaw_graph .y_grid path,
+.rickshaw_graph .x_grid_d3 path {
+ fill: none;
+ stroke: none;
+}
+.rickshaw_graph .y_ticks path,
+.rickshaw_graph .x_ticks_d3 path {
+ fill: none;
+ stroke: #808080;
+}
+.rickshaw_graph .y_ticks text,
+.rickshaw_graph .x_ticks_d3 text {
+ opacity: 0.5;
+ font-size: 12px;
+ pointer-events: none;
+}
+.rickshaw_graph .x_tick.glow .title,
+.rickshaw_graph .y_ticks.glow text {
+ fill: black;
+ color: black;
+ text-shadow:
+ -1px 1px 0 rgba(255, 255, 255, 0.1),
+ 1px -1px 0 rgba(255, 255, 255, 0.1),
+ 1px 1px 0 rgba(255, 255, 255, 0.1),
+ 0px 1px 0 rgba(255, 255, 255, 0.1),
+ 0px -1px 0 rgba(255, 255, 255, 0.1),
+ 1px 0px 0 rgba(255, 255, 255, 0.1),
+ -1px 0px 0 rgba(255, 255, 255, 0.1),
+ -1px -1px 0 rgba(255, 255, 255, 0.1);
+}
+.rickshaw_graph .x_tick.inverse .title,
+.rickshaw_graph .y_ticks.inverse text {
+ fill: white;
+ color: white;
+ text-shadow:
+ -1px 1px 0 rgba(0, 0, 0, 0.8),
+ 1px -1px 0 rgba(0, 0, 0, 0.8),
+ 1px 1px 0 rgba(0, 0, 0, 0.8),
+ 0px 1px 0 rgba(0, 0, 0, 0.8),
+ 0px -1px 0 rgba(0, 0, 0, 0.8),
+ 1px 0px 0 rgba(0, 0, 0, 0.8),
+ -1px 0px 0 rgba(0, 0, 0, 0.8),
+ -1px -1px 0 rgba(0, 0, 0, 0.8);
+}
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/legend.css b/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/legend.css
new file mode 100644
index 0000000..a78eaae
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/legend.css
@@ -0,0 +1,73 @@
+.rickshaw_legend {
+ font-family: Arial;
+ font-size: 12px;
+ color: white;
+ background: #404040;
+ display: inline-block;
+ padding: 12px 5px;
+ border-radius: 2px;
+ position: relative;
+}
+.rickshaw_legend:hover {
+ z-index: 10;
+}
+.rickshaw_legend .swatch {
+ width: 10px;
+ height: 10px;
+ border: 1px solid rgba(0, 0, 0, 0.2);
+}
+.rickshaw_legend .line {
+ clear: both;
+ line-height: 140%;
+ padding-right: 15px;
+}
+.rickshaw_legend .line .swatch {
+ display: inline-block;
+ margin-right: 3px;
+ border-radius: 2px;
+}
+.rickshaw_legend .label {
+ margin: 0;
+ white-space: nowrap;
+ display: inline;
+ font-size: inherit;
+ background-color: transparent;
+ color: inherit;
+ font-weight: normal;
+ line-height: normal;
+ padding: 0px;
+ text-shadow: none;
+}
+.rickshaw_legend .action:hover {
+ opacity: 0.6;
+}
+.rickshaw_legend .action {
+ margin-right: 0.2em;
+ font-size: 10px;
+ opacity: 0.2;
+ cursor: pointer;
+ font-size: 14px;
+}
+.rickshaw_legend .line.disabled {
+ opacity: 0.4;
+}
+.rickshaw_legend ul {
+ list-style-type: none;
+ margin: 0;
+ padding: 0;
+ margin: 2px;
+ cursor: pointer;
+}
+.rickshaw_legend li {
+ padding: 0 0 0 2px;
+ min-width: 80px;
+ white-space: nowrap;
+}
+.rickshaw_legend li:hover {
+ background: rgba(255, 255, 255, 0.08);
+ border-radius: 3px;
+}
+.rickshaw_legend li:active {
+ background: rgba(255, 255, 255, 0.2);
+ border-radius: 3px;
+}
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/lines.css b/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/lines.css
new file mode 100644
index 0000000..5f157be
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/webapp/css/lines.css
@@ -0,0 +1,21 @@
+div, span, p, td {
+ font-family: Arial, sans-serif;
+}
+#chart {
+ display: inline-block;
+}
+#legend {
+ display: inline-block;
+ position: relative;
+ left: 8px;
+}
+#legend_container {
+ position: absolute;
+ right: 0;
+ bottom: 26px;
+ width: 0;
+}
+#chart_container {
+ float: left;
+ position: relative;
+}
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/airplane.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/airplane.png
new file mode 100644
index 0000000..bbae8b2
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/airplane.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/interp_cardinal.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/interp_cardinal.png
new file mode 100644
index 0000000..ac774af
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/interp_cardinal.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/interp_linear.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/interp_linear.png
new file mode 100644
index 0000000..8d39900
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/interp_linear.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/interp_step.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/interp_step.png
new file mode 100644
index 0000000..18611c1
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/interp_step.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_pct.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_pct.png
new file mode 100644
index 0000000..a1b9a52
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_pct.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_stack.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_stack.png
new file mode 100644
index 0000000..5a0e6fc
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_stack.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_stream.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_stream.png
new file mode 100644
index 0000000..27af678
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_stream.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_value.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_value.png
new file mode 100644
index 0000000..43c0346
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/offset_value.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_bar.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_bar.png
new file mode 100644
index 0000000..4f703bc
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_bar.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_curves.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_curves.png
new file mode 100644
index 0000000..abede5a
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_curves.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_lines.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_lines.png
new file mode 100644
index 0000000..0b47dfe
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_lines.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_percent.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_percent.png
new file mode 100644
index 0000000..467d7fb
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_percent.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_scatter.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_scatter.png
new file mode 100644
index 0000000..dd5e5bf
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_scatter.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_stack.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_stack.png
new file mode 100644
index 0000000..9b28ac3
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_stack.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_step.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_step.png
new file mode 100644
index 0000000..4cb24e5
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_step.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_stream.png b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_stream.png
new file mode 100644
index 0000000..57ab199
Binary files /dev/null and b/realTimeAnalyticsTimeSeries/web/src/main/webapp/images/om_stream.png differ
diff --git a/realTimeAnalyticsTimeSeries/web/src/main/webapp/index.jsp b/realTimeAnalyticsTimeSeries/web/src/main/webapp/index.jsp
new file mode 100644
index 0000000..70d6a59
--- /dev/null
+++ b/realTimeAnalyticsTimeSeries/web/src/main/webapp/index.jsp
@@ -0,0 +1,243 @@
+
+
+
+ Time Series Demo
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
Flight Operations Dashboard
+
+
+
+
+
+