diff --git a/src/sdk/python/rtdip_sdk/pipelines/monitoring/logger/dataframe/__init__.py b/src/sdk/python/rtdip_sdk/pipelines/logging/__init__.py similarity index 90% rename from src/sdk/python/rtdip_sdk/pipelines/monitoring/logger/dataframe/__init__.py rename to src/sdk/python/rtdip_sdk/pipelines/logging/__init__.py index 5305a429e..16c2bbafa 100644 --- a/src/sdk/python/rtdip_sdk/pipelines/monitoring/logger/dataframe/__init__.py +++ b/src/sdk/python/rtdip_sdk/pipelines/logging/__init__.py @@ -1,4 +1,4 @@ -# Copyright 2022 RTDIP +# Copyright 2024 RTDIP # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. @@ -10,4 +10,4 @@ # 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. +# limitations under the License. \ No newline at end of file diff --git a/src/sdk/python/rtdip_sdk/pipelines/logging/interfaces.py b/src/sdk/python/rtdip_sdk/pipelines/logging/interfaces.py new file mode 100644 index 000000000..021e23ea0 --- /dev/null +++ b/src/sdk/python/rtdip_sdk/pipelines/logging/interfaces.py @@ -0,0 +1,23 @@ +# Copyright 2022 RTDIP +# +# Licensed 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 abc import abstractmethod + +from pyspark.sql import DataFrame +from ..interfaces import PipelineComponentBaseInterface + +class LoggingBaseInterface(PipelineComponentBaseInterface): + @abstractmethod + def log(self) -> DataFrame: + pass \ No newline at end of file diff --git a/src/sdk/python/rtdip_sdk/pipelines/logging/pipeline_logger.py b/src/sdk/python/rtdip_sdk/pipelines/logging/pipeline_logger.py new file mode 100644 index 000000000..e69de29bb diff --git a/src/sdk/python/rtdip_sdk/pipelines/monitoring/logger/file/__init__.py b/src/sdk/python/rtdip_sdk/pipelines/logging/spark/__init__.py similarity index 90% rename from src/sdk/python/rtdip_sdk/pipelines/monitoring/logger/file/__init__.py rename to src/sdk/python/rtdip_sdk/pipelines/logging/spark/__init__.py index 5305a429e..16c2bbafa 100644 --- a/src/sdk/python/rtdip_sdk/pipelines/monitoring/logger/file/__init__.py +++ b/src/sdk/python/rtdip_sdk/pipelines/logging/spark/__init__.py @@ -1,4 +1,4 @@ -# Copyright 2022 RTDIP +# Copyright 2024 RTDIP # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. @@ -10,4 +10,4 @@ # 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. +# limitations under the License. \ No newline at end of file diff --git a/src/sdk/python/rtdip_sdk/pipelines/logging/spark/dataframe/__init__.py b/src/sdk/python/rtdip_sdk/pipelines/logging/spark/dataframe/__init__.py new file mode 100644 index 000000000..16c2bbafa --- /dev/null +++ b/src/sdk/python/rtdip_sdk/pipelines/logging/spark/dataframe/__init__.py @@ -0,0 +1,13 @@ +# Copyright 2024 RTDIP +# +# Licensed 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. \ No newline at end of file diff --git a/src/sdk/python/rtdip_sdk/pipelines/logging/spark/log_file/__init__.py b/src/sdk/python/rtdip_sdk/pipelines/logging/spark/log_file/__init__.py new file mode 100644 index 000000000..16c2bbafa --- /dev/null +++ b/src/sdk/python/rtdip_sdk/pipelines/logging/spark/log_file/__init__.py @@ -0,0 +1,13 @@ +# Copyright 2024 RTDIP +# +# Licensed 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. \ No newline at end of file