| <!-- | |
| 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. | |
| --> | |
| # Time Series Processing | |
| ## CHANGE_POINTS | |
| ### Usage | |
| This function is used to remove consecutive identical values from an input sequence. | |
| For example, input:`1，1，2，2，3` output:`1，2，3`. | |
| **Name：** CHANGE_POINTS | |
| **Input Series：** Support only one input series. | |
| **Parameters：** No parameters. | |
| ### Example | |
| Raw data： | |
| ``` | |
| +-----------------------------+---------------------------+---------------------------+---------------------------+---------------------------+---------------------------+---------------------------+ | |
| | Time|root.testChangePoints.d1.s1|root.testChangePoints.d1.s2|root.testChangePoints.d1.s3|root.testChangePoints.d1.s4|root.testChangePoints.d1.s5|root.testChangePoints.d1.s6| | |
| +-----------------------------+---------------------------+---------------------------+---------------------------+---------------------------+---------------------------+---------------------------+ | |
| |1970-01-01T08:00:00.001+08:00| true| 1| 1| 1.0| 1.0| 1test1| | |
| |1970-01-01T08:00:00.002+08:00| true| 2| 2| 2.0| 1.0| 2test2| | |
| |1970-01-01T08:00:00.003+08:00| false| 1| 2| 1.0| 1.0| 2test2| | |
| |1970-01-01T08:00:00.004+08:00| true| 1| 3| 1.0| 1.0| 1test1| | |
| |1970-01-01T08:00:00.005+08:00| true| 1| 3| 1.0| 1.0| 1test1| | |
| +-----------------------------+---------------------------+---------------------------+---------------------------+---------------------------+---------------------------+---------------------------+ | |
| ``` | |
| SQL for query： | |
| ```sql | |
| select change_points(s1), change_points(s2), change_points(s3), change_points(s4), change_points(s5), change_points(s6) from root.testChangePoints.d1 | |
| ``` | |
| Output series： | |
| ``` | |
| +-----------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+ | |
| | Time|change_points(root.testChangePoints.d1.s1)|change_points(root.testChangePoints.d1.s2)|change_points(root.testChangePoints.d1.s3)|change_points(root.testChangePoints.d1.s4)|change_points(root.testChangePoints.d1.s5)|change_points(root.testChangePoints.d1.s6)| | |
| +-----------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+ | |
| |1970-01-01T08:00:00.001+08:00| true| 1| 1| 1.0| 1.0| 1test1| | |
| |1970-01-01T08:00:00.002+08:00| null| 2| 2| 2.0| null| 2test2| | |
| |1970-01-01T08:00:00.003+08:00| false| 1| null| 1.0| null| null| | |
| |1970-01-01T08:00:00.004+08:00| true| null| 3| null| null| 1test1| | |
| +-----------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+ | |
| ``` |