| <!-- | |
| Licensed to the Apache Software Foundation (ASF) under one | |
| or more contributor license agreements. See the NOTICE file | |
| distributed with this work for additional information | |
| regarding copyright ownership. The ASF licenses this file | |
| to you under the Apache License, Version 2.0 (the | |
| "License"); you may not use this file except in compliance | |
| with the License. You may obtain a copy of the License at | |
| http://www.apache.org/licenses/LICENSE-2.0 | |
| Unless required by applicable law or agreed to in writing, | |
| software distributed under the License is distributed on an | |
| "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY | |
| KIND, either express or implied. See the License for the | |
| specific language governing permissions and limitations | |
| under the License. | |
| --> | |
| # Quick Start | |
| ## Sample Data | |
|  | |
| ## Installation Method | |
| Add the following content to the `dependencies` in `pom.xml` | |
| ```shell | |
| <dependency> | |
| <groupId>org.apache.tsfile</groupId> | |
| <artifactId>tsfile</artifactId> | |
| <version>1.1.0</version> | |
| </dependency> | |
| ``` | |
| ## Writing Process | |
| ### Construct TsFileWriter | |
| ```shell | |
| File f = new File("test.tsfile"); | |
| TsFileWriter tsFileWriter = new TsFileWriter(f); | |
| ``` | |
| ### Registration Time Series | |
| ```shell | |
| List<MeasurementSchema> schema1 = new ArrayList<>(); | |
| schema1.add(new MeasurementSchema("voltage", TSDataType.FLOAT)); | |
| schema1.add(new MeasurementSchema("current", TSDataType.FLOAT)); | |
| tsFileWriter.registerTimeseries(new Path("Solar_panel_1"), schema1); | |
| List<MeasurementSchema> schema2 = new ArrayList<>(); | |
| schema2.add(new MeasurementSchema("voltage", TSDataType.FLOAT)); | |
| schema2.add(new MeasurementSchema("current", TSDataType.FLOAT)); | |
| schema2.add(new MeasurementSchema("wind_speed", TSDataType.FLOAT)); | |
| tsFileWriter.registerTimeseries(new Path("Fan_1"), schema2); | |
| ``` | |
| ### Write Data | |
| ```shell | |
| TSRecord tsRecord = new TSRecord(1, "Solar_panel_1"); | |
| tsRecord.addTuple(DataPoint.getDataPoint(TSDataType.FLOAT, "voltage", 1.1f)); | |
| tsRecord.addTuple(DataPoint.getDataPoint(TSDataType.FLOAT, "current", 2.2f)); | |
| tsFileWriter.write(tsRecord); | |
| ``` | |
| ### Close File | |
| ```shell | |
| tsFileWriter.close(); | |
| ``` | |
| ### Sample Code | |
| <https://github.com/apache/tsfile/blob/develop/java/examples/src/main/java/org/apache/tsfile/TsFileWriteWithTSRecord.java> | |
| ## Query Process | |
| ### Construct TsFileReader | |
| ```shell | |
| TsFileSequenceReader reader = new TsFileSequenceReader(path); | |
| TsFileReader tsFileReader = new TsFileReader(reader); | |
| ``` | |
| ### Construct Query Request | |
| ```shell | |
| ArrayList<Path> paths = new ArrayList<>(); | |
| paths.add(new Path("Solar_panel_1", "voltage",true)); | |
| paths.add(new Path("Solar_panel_1", "current",true)); | |
| IExpression timeFilter = | |
| BinaryExpression.and( | |
| new GlobalTimeExpression(TimeFilterApi.gtEq(4L)), | |
| new GlobalTimeExpression(TimeFilterApi.ltEq(10L))); | |
| QueryExpression queryExpression = QueryExpression.create(paths, timeFilter); | |
| ``` | |
| ### Query Data | |
| ```shell | |
| QueryDataSet queryDataSet = tsFileReader.query(queryExpression); | |
| while (queryDataSet.hasNext()) { | |
| queryDataSet.next(); | |
| } | |
| ``` | |
| ### Close File | |
| ```shell | |
| tsFileReader.close(); | |
| ``` | |
| ### Sample Code | |
| <https://github.com/apache/tsfile/blob/develop/java/examples/src/main/java/org/apache/tsfile/TsFileRead.java> | |