plot trend

CHANGELOG.md

@@ -14,7 +14,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Prediction intervals visualization in `plot_forecast` ([#538](https://github.com/tinkoff-ai/etna/pull/538))
 - 
 - Add plot_time_series_with_change_points function ([#534](https://github.com/tinkoff-ai/etna/pull/534))
-- 
+- Add plot_trend ([#565](https://github.com/tinkoff-ai/etna/pull/565))
 - Add find_change_points function ([#521](https://github.com/tinkoff-ai/etna/pull/521))
 - 
 - Add plot_residuals ([#539](https://github.com/tinkoff-ai/etna/pull/539))

etna/analysis/__init__.py

@@ -24,3 +24,4 @@
 from etna.analysis.plotters import plot_forecast
 from etna.analysis.plotters import plot_residuals
 from etna.analysis.plotters import plot_time_series_with_change_points
+from etna.analysis.plotters import plot_trend

etna/analysis/plotters.py

@@ -23,6 +23,10 @@
 
 if TYPE_CHECKING:
     from etna.datasets import TSDataset
+    from etna.transforms import ChangePointsTrendTransform
+    from etna.transforms import LinearTrendTransform
+    from etna.transforms import STLTransform
+    from etna.transforms import TheilSenTrendTransform
 
 
 def prepare_axes(segments: List[str], columns_num: int, figsize: Tuple[int, int]) -> Sequence[matplotlib.axes.Axes]:
@@ -729,3 +733,59 @@ def plot_residuals(
         ax[i].set_title(segment)
         ax[i].tick_params("x", rotation=45)
         ax[i].set_xlabel(feature)
+
+
+TrendTransformType = Union[
+    "ChangePointsTrendTransform", "LinearTrendTransform", "TheilSenTrendTransform", "STLTransform"
+]
+
+
+def plot_trend(
+    ts: "TSDataset",
+    trend_transform: Union["TrendTransformType", List["TrendTransformType"]],
+    segments: Optional[List[str]] = None,
+    columns_num: int = 2,
+    figsize: Tuple[int, int] = (10, 5),
+):
+    """Plot series and trend from trend transform for this series.
+
+    Parameters
+    ----------
+    ts:
+        dataframe of timeseries that was used for trend plot
+    trend_transform:
+        trend transform or list of trend transforms to apply
+    segments:
+        segments to use
+    columns_num:
+        number of columns in subplots
+    figsize:
+        size of the figure per subplot with one segment in inches
+    """
+    if not segments:
+        segments = list(set(ts.columns.get_level_values("segment")))
+
+    ax = prepare_axes(segments=segments, columns_num=columns_num, figsize=figsize)
+    df = ts.df
+    linear_coeffs = dict(zip(segments, ["" for i in range(len(segments))]))
+    if isinstance(trend_transform, list):
+        df_detrend = [transform.fit_transform(df.copy()) for transform in trend_transform]
+        labels = [transform.__repr__() for transform in trend_transform]
+        labels_short = [i[: i.find("(")] for i in labels]
+        if len(np.unique(labels_short)) == len(labels_short):
+            labels = labels_short
+    else:
+        df_detrend = [trend_transform.fit_transform(df.copy())]
+        labels = [trend_transform.__repr__()[: trend_transform.__repr__().find("(")]]
+        if isinstance(trend_transform, LinearTrendTransform) or isinstance(trend_transform, TheilSenTrendTransform):
+            for seg in segments:
+
+                linear_coeffs[seg] = ", k=" + str(trend_transform.segment_transforms[seg]._linear_model.coef_[0])
+
+    for i, segment in enumerate(segments):
+        ax[i].plot(df[segment]["target"], label="Initial series")
+        for label, df_now in zip(labels, df_detrend):
+            ax[i].plot(df[segment, "target"] - df_now[segment, "target"], label=label + linear_coeffs[segment])
+        ax[i].set_title(segment)
+        ax[i].tick_params("x", rotation=45)
+        ax[i].legend()