-/*******************************************************************************\r
- * Copyright (c) 2007, 2011 Association for Decentralized Information Management in\r
- * Industry THTH ry.\r
- * All rights reserved. This program and the accompanying materials\r
- * are made available under the terms of the Eclipse Public License v1.0\r
- * which accompanies this distribution, and is available at\r
- * http://www.eclipse.org/legal/epl-v10.html\r
- *\r
- * Contributors:\r
- * VTT Technical Research Centre of Finland - initial API and implementation\r
- *******************************************************************************/\r
-package org.simantics.history.examples;\r
-\r
-import java.io.File;\r
-\r
-import org.simantics.databoard.Bindings;\r
-import org.simantics.databoard.Datatypes;\r
-import org.simantics.databoard.accessor.StreamAccessor;\r
-import org.simantics.databoard.binding.Binding;\r
-import org.simantics.databoard.type.Datatype;\r
-import org.simantics.databoard.type.RecordType;\r
-import org.simantics.databoard.util.Bean;\r
-import org.simantics.history.Collector;\r
-import org.simantics.history.History;\r
-import org.simantics.history.HistoryManager;\r
-import org.simantics.history.ItemManager;\r
-import org.simantics.history.impl.CollectorImpl;\r
-import org.simantics.history.util.subscription.SubscriptionItem;\r
-import org.simantics.history.util.subscription.SamplingFormat;\r
-import org.simantics.utils.FileUtils;\r
-\r
-public class HistoryExample2 {\r
- \r
- public static void main(String[] args) throws Exception {\r
- \r
- //// Create sampling formats \r
- // Simple format captures all samples, no min/max/avg/median \r
- SamplingFormat simpleFormat, intervalFormat;\r
- simpleFormat = new SamplingFormat();\r
- RecordType format = (RecordType) (simpleFormat.format = new RecordType());\r
- format.addComponent("time", Datatypes.DOUBLE);\r
- format.addComponent("value", Datatypes.DOUBLE );\r
- format.addComponent("quality", Datatypes.BYTE );\r
- simpleFormat.interval = Double.NaN;\r
- simpleFormat.deadband = Double.NaN;\r
- simpleFormat.formatId = "Simple";\r
- \r
- // Interval format captures samples with 0.5s interval. It also calculates min/max/avg/median \r
- intervalFormat = new SamplingFormat();\r
- format = (RecordType) (intervalFormat.format = new RecordType());\r
- format.addComponent("time", Datatypes.DOUBLE);\r
- format.addComponent("endTime", Datatypes.DOUBLE);\r
- format.addComponent("value", Datatypes.DOUBLE );\r
- format.addComponent("lastValue", Datatypes.DOUBLE); \r
- format.addComponent("min", Datatypes.DOUBLE);\r
- format.addComponent("max", Datatypes.DOUBLE);\r
- format.addComponent("avg", Datatypes.DOUBLE);\r
- format.addComponent("median", Datatypes.DOUBLE);\r
- format.addComponent("quality", Datatypes.BYTE );\r
- format.addComponent("count", Datatypes.INTEGER);\r
- intervalFormat.interval = Double.NaN;\r
- intervalFormat.deadband = Double.NaN;\r
- intervalFormat.interval = 0.5;\r
- intervalFormat.formatId = "Interval";\r
- \r
- //// Create item descriptions\r
- SubscriptionItem[] items = SubscriptionItem.createItems("Variable", "MySubscription", simpleFormat, intervalFormat);\r
-\r
- // Manage items\r
- ItemManager im = new ItemManager( items );\r
- im.search("groupId", "MySubscription");\r
- \r
- //// Open file history & initialize subscription \r
- File workarea = FileUtils.createTmpDir();\r
- HistoryManager historian = History.openFileHistory( workarea );\r
- historian.create( items );\r
- \r
- //// Record data\r
- Collector collector = new CollectorImpl( historian );\r
- collector.addItems( items );\r
- try {\r
- double NaN = Double.NaN;\r
- double[] data = { 5.0, 5.0, 5.0, 5.0, 6.0, 6.0, 6.0, 7.0, 8.0, 9.0, NaN,10.0, NaN, NaN, NaN };\r
-\r
- for (int i=0; i<data.length; i++) \r
- {\r
- collector.beginStep(Bindings.DOUBLE, i * 0.1);\r
- collector.setValue("Variable", Bindings.DOUBLE, data[i]);\r
- collector.endStep();\r
- }\r
- \r
- } finally {\r
- collector.close();\r
- }\r
- \r
- // Open accessor to the data, read & print data.\r
- System.out.println("IntervalFormat = "+intervalFormat.toString());\r
- StreamAccessor sa = historian.openStream( items[1].id, "r" );\r
- try { \r
- sa.reset();\r
- Datatype sampleType = sa.type().componentType;\r
- Binding beanBinding = Bindings.getBeanBinding( sampleType );\r
- Bean sample = (Bean) beanBinding.createDefault();\r
- for (int i=0; i<sa.size(); i++) {\r
- sa.get(i, beanBinding, sample);\r
- System.out.println( sample );\r
- }\r
- } finally {\r
- sa.close();\r
- }\r
- \r
- // The data can also be read using generic binding\r
- System.out.println("\nSimpleFormat = "+simpleFormat.toString());\r
- sa = historian.openStream(items[0].id, "r");\r
- try { \r
- sa.reset();\r
- Binding b = Bindings.getBinding( simpleFormat.format );\r
- Object sample = b.createDefault();\r
- for (int i=0; i<sa.size(); i++) {\r
- sa.get(i, b, sample);\r
- System.out.println( b.toString(sample) );\r
- }\r
- } finally {\r
- sa.close();\r
- }\r
- \r
- \r
- }\r
-\r
-}\r
+/*******************************************************************************
+ * Copyright (c) 2007, 2011 Association for Decentralized Information Management in
+ * Industry THTH ry.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * VTT Technical Research Centre of Finland - initial API and implementation
+ *******************************************************************************/
+package org.simantics.history.examples;
+
+import java.io.File;
+
+import org.simantics.databoard.Bindings;
+import org.simantics.databoard.Datatypes;
+import org.simantics.databoard.accessor.StreamAccessor;
+import org.simantics.databoard.binding.Binding;
+import org.simantics.databoard.type.Datatype;
+import org.simantics.databoard.type.RecordType;
+import org.simantics.databoard.util.Bean;
+import org.simantics.history.Collector;
+import org.simantics.history.History;
+import org.simantics.history.HistoryManager;
+import org.simantics.history.ItemManager;
+import org.simantics.history.impl.CollectorImpl;
+import org.simantics.history.util.subscription.SubscriptionItem;
+import org.simantics.history.util.subscription.SamplingFormat;
+import org.simantics.utils.FileUtils;
+
+public class HistoryExample2 {
+
+ public static void main(String[] args) throws Exception {
+
+ //// Create sampling formats
+ // Simple format captures all samples, no min/max/avg/median
+ SamplingFormat simpleFormat, intervalFormat;
+ simpleFormat = new SamplingFormat();
+ RecordType format = (RecordType) (simpleFormat.format = new RecordType());
+ format.addComponent("time", Datatypes.DOUBLE);
+ format.addComponent("value", Datatypes.DOUBLE );
+ format.addComponent("quality", Datatypes.BYTE );
+ simpleFormat.interval = Double.NaN;
+ simpleFormat.deadband = Double.NaN;
+ simpleFormat.formatId = "Simple";
+
+ // Interval format captures samples with 0.5s interval. It also calculates min/max/avg/median
+ intervalFormat = new SamplingFormat();
+ format = (RecordType) (intervalFormat.format = new RecordType());
+ format.addComponent("time", Datatypes.DOUBLE);
+ format.addComponent("endTime", Datatypes.DOUBLE);
+ format.addComponent("value", Datatypes.DOUBLE );
+ format.addComponent("lastValue", Datatypes.DOUBLE);
+ format.addComponent("min", Datatypes.DOUBLE);
+ format.addComponent("max", Datatypes.DOUBLE);
+ format.addComponent("avg", Datatypes.DOUBLE);
+ format.addComponent("median", Datatypes.DOUBLE);
+ format.addComponent("quality", Datatypes.BYTE );
+ format.addComponent("count", Datatypes.INTEGER);
+ intervalFormat.interval = Double.NaN;
+ intervalFormat.deadband = Double.NaN;
+ intervalFormat.interval = 0.5;
+ intervalFormat.formatId = "Interval";
+
+ //// Create item descriptions
+ SubscriptionItem[] items = SubscriptionItem.createItems("Variable", "MySubscription", simpleFormat, intervalFormat);
+
+ // Manage items
+ ItemManager im = new ItemManager( items );
+ im.search("groupId", "MySubscription");
+
+ //// Open file history & initialize subscription
+ File workarea = FileUtils.createTmpDir();
+ HistoryManager historian = History.openFileHistory( workarea );
+ historian.create( items );
+
+ //// Record data
+ Collector collector = new CollectorImpl( historian );
+ collector.addItems( items );
+ try {
+ double NaN = Double.NaN;
+ double[] data = { 5.0, 5.0, 5.0, 5.0, 6.0, 6.0, 6.0, 7.0, 8.0, 9.0, NaN,10.0, NaN, NaN, NaN };
+
+ for (int i=0; i<data.length; i++)
+ {
+ collector.beginStep(Bindings.DOUBLE, i * 0.1);
+ collector.setValue("Variable", Bindings.DOUBLE, data[i]);
+ collector.endStep();
+ }
+
+ } finally {
+ collector.close();
+ }
+
+ // Open accessor to the data, read & print data.
+ System.out.println("IntervalFormat = "+intervalFormat.toString());
+ StreamAccessor sa = historian.openStream( items[1].id, "r" );
+ try {
+ sa.reset();
+ Datatype sampleType = sa.type().componentType;
+ Binding beanBinding = Bindings.getBeanBinding( sampleType );
+ Bean sample = (Bean) beanBinding.createDefault();
+ for (int i=0; i<sa.size(); i++) {
+ sa.get(i, beanBinding, sample);
+ System.out.println( sample );
+ }
+ } finally {
+ sa.close();
+ }
+
+ // The data can also be read using generic binding
+ System.out.println("\nSimpleFormat = "+simpleFormat.toString());
+ sa = historian.openStream(items[0].id, "r");
+ try {
+ sa.reset();
+ Binding b = Bindings.getBinding( simpleFormat.format );
+ Object sample = b.createDefault();
+ for (int i=0; i<sa.size(); i++) {
+ sa.get(i, b, sample);
+ System.out.println( b.toString(sample) );
+ }
+ } finally {
+ sa.close();
+ }
+
+
+ }
+
+}
Code Review / simantics / platform.git / blobdiff