This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch IOTDB-5195 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d79568b436e12cb15d8cffd936442853d92b04c6 Author: Steve Yurong Su <[email protected]> AuthorDate: Tue Dec 13 23:51:36 2022 +0800 remove mappable api from pyudf package --- .../customizer/strategy/access_strategy_type.py | 2 -- .../mappable_row_by_row_access_strategy.py | 40 ---------------------- udf-py/udf_api/udtf.py | 10 ------ 3 files changed, 52 deletions(-) diff --git a/udf-py/udf_api/customizer/strategy/access_strategy_type.py b/udf-py/udf_api/customizer/strategy/access_strategy_type.py index 23dbfdad7c..070f92e046 100644 --- a/udf-py/udf_api/customizer/strategy/access_strategy_type.py +++ b/udf-py/udf_api/customizer/strategy/access_strategy_type.py @@ -19,8 +19,6 @@ from enum import Enum class AccessStrategyType(Enum): - # MappableRowByRowAccessStrategy - MAPPABLE_ROW_BY_ROW = 0 # RowByRowAccessStrategy ROW_BY_ROW = 1 diff --git a/udf-py/udf_api/customizer/strategy/mappable_row_by_row_access_strategy.py b/udf-py/udf_api/customizer/strategy/mappable_row_by_row_access_strategy.py deleted file mode 100644 index eb2e92fc90..0000000000 --- a/udf-py/udf_api/customizer/strategy/mappable_row_by_row_access_strategy.py +++ /dev/null @@ -1,40 +0,0 @@ -# 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. - -from udf_api.customizer.strategy.access_strategy import AccessStrategy -from udf_api.customizer.strategy.access_strategy_type import AccessStrategyType - - -class MappableRowByRowAccessStrategy(AccessStrategy): - """ - Used in UDTF#beforeStart(UDFParameters, UDTFConfigurations). - - When the access strategy of a UDTF is set to an instance of this class, the method UDTF#transform(Row) of the UDTF - will be called to transform the original data. You need to override the method in your own UDTF class. - - Each call of the method UDTF#transform(Row) processes only one row (aligned by time) of the original data and can - generate any number of data points. - """ - - def check(self): - """ - nothing needs to check - """ - pass - - def get_access_strategy_type(self) -> AccessStrategyType: - return AccessStrategyType.MAPPABLE_ROW_BY_ROW diff --git a/udf-py/udf_api/udtf.py b/udf-py/udf_api/udtf.py index c4684660b8..9c1bf4dbf7 100644 --- a/udf-py/udf_api/udtf.py +++ b/udf-py/udf_api/udtf.py @@ -84,16 +84,6 @@ class UDTF(UDF): :param collector: used to collect output data points """ - def map_row(self, row: Row) -> object: - """ - When the user specifies MappableRowByRowAccessStrategy to access the original data in UDTFConfigurations, this - method will be called to process the transformation. In a single UDF query, this method may be called multiple - times. - - :param row: original input data row (aligned by time) - """ - pass - def terminate(self, collector: PointCollector): """ This method will be called once after all calls or { UDTF#transform(RowWindow, PointCollector) calls have been
