| <!-- |
| |
| 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| |
| +-----------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+------------------------------------------+ |
| ``` |
