.gitignore
.whitesource
CODEOWNERS.md
CODE_OF_CONDUCT.md
CONTRIBUTING.md
GOVERNANCE.md
LICENSE.md
PYPI-README.md
README.md
RELEASE.md
SUPPORT.md
environment.yml
mkdocs.yml
setup.py
.devcontainer/devcontainer.json
.github/release.yml
.github/ISSUE_TEMPLATE/bug_report.md
.github/ISSUE_TEMPLATE/feature_request.md
.github/ISSUE_TEMPLATE/general_inquiry.md
.github/ISSUE_TEMPLATE/security_vulnerability.md
.github/workflows/develop.yml
.github/workflows/main.yml
.github/workflows/pr.yml
.github/workflows/release.yml
.github/workflows/sonarcloud.yml
.github/workflows/sonarcloud_reusable.yml
.github/workflows/stale_issues.yml
.github/workflows/test.yml
.vscode/extensions.json
.vscode/launch.json
.vscode/settings.json
.vscode/tasks.json
docs/CNAME
docs/__init__.py
docs/index.md
docs/macros.py
docs/api/authentication.md
docs/api/examples.md
docs/api/overview.md
docs/api/rest_apis.md
docs/api/deployment/azure.md
docs/api/images/open-api.png
docs/api/images/redoc-logo.png
docs/api/images/rest-api-logo.png
docs/api/images/swagger.png
docs/assets/extra.css
docs/assets/favicon.png
docs/assets/illustration.png
docs/assets/logo_lfe.png
docs/assets/rtdip-horizontal-black.png
docs/assets/rtdip-horizontal-color.png
docs/assets/rtdip-horizontal-white.png
docs/assets/rtdip-icon-black.png
docs/blog/.authors.yml
docs/blog/index.md
docs/blog/images/agile.svg
docs/blog/images/airflowlogo.png
docs/blog/images/amos_mvi.png
docs/blog/images/amos_mvi_raw.png
docs/blog/images/apachespark.png
docs/blog/images/aws-azure-gcp.png
docs/blog/images/aws.png
docs/blog/images/azure.png
docs/blog/images/blog-icon.png
docs/blog/images/dagster-primary-horizontal.png
docs/blog/images/dagster-primary-vertical.png
docs/blog/images/data-quality.png
docs/blog/images/databricks.png
docs/blog/images/databricks_horizontal.png
docs/blog/images/delta-lakehouse.svg
docs/blog/images/dlt.svg
docs/blog/images/energy-forecasting.png
docs/blog/images/framework.png
docs/blog/images/gcp.png
docs/blog/images/generative-ai.png
docs/blog/images/opcua-to-deltalake.png
docs/blog/images/pyspark.png
docs/blog/images/python.png
docs/blog/images/spark-query-plan.png
docs/blog/posts/delta_and_rtdip.md
docs/blog/posts/enhancing_data_quality_amos.md
docs/blog/posts/opcua_to_delta.md
docs/blog/posts/rtdip_data_quality.md
docs/blog/posts/rtdip_energy_forecasting.md
docs/blog/posts/rtdip_ingestion_pipelines.md
docs/domains/process_control/data_model.md
docs/domains/process_control/overview.md
docs/domains/process_control/images/iot_hub.png
docs/domains/process_control/images/kafka-logo-wide.png
docs/domains/process_control/images/mqtt.png
docs/domains/smart_meter/data_model.md
docs/domains/smart_meter/overview.md
docs/domains/weather/data_model.md
docs/domains/weather/overview.md
docs/getting-started/about-rtdip.md
docs/getting-started/installation.md
docs/getting-started/images/rtdip-horizontal-color.png
docs/getting-started/images/timeseries.gif
docs/getting-started/images/timeseries2.gif
docs/images/background-curve-default.svg
docs/images/background-curve-slate.svg
docs/images/curve.png
docs/images/release-images/Generate Release Notes.png
docs/images/release-images/Publish Release.png
docs/images/release-images/Release Target Title.png
docs/images/release-images/Set As Latest Release.png
docs/integration/power-bi.md
docs/integration/images/bi-azure-signin.png
docs/integration/images/bi-getdata-more.png
docs/integration/images/bi-search-databricks.png
docs/integration/images/databricks_powerbi.png
docs/integration/images/power-bi-desktop.png
docs/integration/images/power-bi-install.png
docs/overrides/essentials.css
docs/overrides/essentials.html
docs/overrides/home.css
docs/overrides/home.html
docs/overrides/main.html
docs/overrides/university.css
docs/overrides/university.html
docs/overrides/images/ai-icon.png
docs/overrides/images/bi-image.png
docs/overrides/images/deployment-icon.png
docs/overrides/images/destinations-image.png
docs/overrides/images/docker-icon-white.png
docs/overrides/images/docker-icon.png
docs/overrides/images/down-icon.png
docs/overrides/images/github-icon-white.png
docs/overrides/images/github-icon.png
docs/overrides/images/multicloud-icon.png
docs/overrides/images/opensource-icon.png
docs/overrides/images/orb.png
docs/overrides/images/pipeline-icon.png
docs/overrides/images/pypi-icon-white.png
docs/overrides/images/pypi-icon.png
docs/overrides/images/query-icon.png
docs/overrides/images/querybuilder-image.png
docs/overrides/images/rtdip-queries.png
docs/overrides/images/slack-icon-purple.png
docs/overrides/images/slack-icon-white.png
docs/overrides/images/sources-image.png
docs/overrides/images/terrain-orb-background.png
docs/overrides/images/terrain.png
docs/overrides/images/transformers-image.png
docs/overrides/images/trusted-industry-image.png
docs/overrides/images/university-course-badge.png
docs/overrides/images/university-essential-course.png
docs/overrides/images/university-pipeline-course.png
docs/releases/core.md
docs/roadmap/roadmap-overview.md
docs/roadmap/images/roadmap-overview.jpeg
docs/roadmap/yearly-roadmaps/2022-development-roadmap.md
docs/roadmap/yearly-roadmaps/2023-development-roadmap.md
docs/roadmap/yearly-roadmaps/images/2023.jpeg
docs/roadmap/yearly-roadmaps/images/IEC-CIM.png
docs/roadmap/yearly-roadmaps/images/awsazure.png
docs/roadmap/yearly-roadmaps/images/delta-live-tables.png
docs/roadmap/yearly-roadmaps/images/delta-sharing.png
docs/roadmap/yearly-roadmaps/images/delta-unity-catalog.png
docs/roadmap/yearly-roadmaps/images/lakehouse.png
docs/roadmap/yearly-roadmaps/images/lfenergy.png
docs/roadmap/yearly-roadmaps/images/microgrid.jpeg
docs/roadmap/yearly-roadmaps/images/multicloud.jpeg
docs/roadmap/yearly-roadmaps/images/power-bi.png
docs/roadmap/yearly-roadmaps/images/roadmap.png
docs/roadmap/yearly-roadmaps/images/sdk-vs-api.png
docs/roadmap/yearly-roadmaps/images/seeq.png
docs/roadmap/yearly-roadmaps/images/smart-meter.jpeg
docs/sdk/overview.md
docs/sdk/authentication/azure.md
docs/sdk/authentication/databricks.md
docs/sdk/code-reference/authentication/azure.md
docs/sdk/code-reference/pipelines/converters/pipeline_job_json.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/dimensionality_reduction.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/duplicate_detection.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/flatline_filter.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/gaussian_smoothing.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/interval_filtering.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/k_sigma_anomaly_detection.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/missing_value_imputation.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/out_of_range_value_filter.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/normalization/denormalization.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/normalization/normalization.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/normalization/normalization_mean.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/normalization/normalization_minmax.md
docs/sdk/code-reference/pipelines/data_quality/data_manipulation/spark/normalization/normalization_zscore.md
docs/sdk/code-reference/pipelines/data_quality/monitoring/spark/check_value_ranges.md
docs/sdk/code-reference/pipelines/data_quality/monitoring/spark/flatline_detection.md
docs/sdk/code-reference/pipelines/data_quality/monitoring/spark/great_expectations.md
docs/sdk/code-reference/pipelines/data_quality/monitoring/spark/identify_missing_data_interval.md
docs/sdk/code-reference/pipelines/data_quality/monitoring/spark/identify_missing_data_pattern.md
docs/sdk/code-reference/pipelines/data_quality/monitoring/spark/moving_average.md
docs/sdk/code-reference/pipelines/deploy/databricks.md
docs/sdk/code-reference/pipelines/destinations/blockchain/evm.md
docs/sdk/code-reference/pipelines/destinations/python/delta.md
docs/sdk/code-reference/pipelines/destinations/spark/delta.md
docs/sdk/code-reference/pipelines/destinations/spark/delta_merge.md
docs/sdk/code-reference/pipelines/destinations/spark/eventhub.md
docs/sdk/code-reference/pipelines/destinations/spark/kafka.md
docs/sdk/code-reference/pipelines/destinations/spark/kafka_eventhub.md
docs/sdk/code-reference/pipelines/destinations/spark/kinesis.md
docs/sdk/code-reference/pipelines/destinations/spark/pcdm_latest_to_delta.md
docs/sdk/code-reference/pipelines/destinations/spark/pcdm_to_delta.md
docs/sdk/code-reference/pipelines/destinations/spark/rest_api.md
docs/sdk/code-reference/pipelines/forecasting/spark/arima.md
docs/sdk/code-reference/pipelines/forecasting/spark/auto_arima.md
docs/sdk/code-reference/pipelines/forecasting/spark/data_binning.md
docs/sdk/code-reference/pipelines/forecasting/spark/k_nearest_neighbors.md
docs/sdk/code-reference/pipelines/forecasting/spark/linear_regression.md
docs/sdk/code-reference/pipelines/secrets/azure_key_vault.md
docs/sdk/code-reference/pipelines/secrets/databricks.md
docs/sdk/code-reference/pipelines/secrets/hashicorp_vault.md
docs/sdk/code-reference/pipelines/sources/python/delta.md
docs/sdk/code-reference/pipelines/sources/python/delta_sharing.md
docs/sdk/code-reference/pipelines/sources/python/entsoe.md
docs/sdk/code-reference/pipelines/sources/python/mffbas.md
docs/sdk/code-reference/pipelines/sources/spark/autoloader.md
docs/sdk/code-reference/pipelines/sources/spark/delta.md
docs/sdk/code-reference/pipelines/sources/spark/delta_sharing.md
docs/sdk/code-reference/pipelines/sources/spark/eventhub.md
docs/sdk/code-reference/pipelines/sources/spark/iot_hub.md
docs/sdk/code-reference/pipelines/sources/spark/kafka.md
docs/sdk/code-reference/pipelines/sources/spark/kafka_eventhub.md
docs/sdk/code-reference/pipelines/sources/spark/kinesis.md
docs/sdk/code-reference/pipelines/sources/spark/ecmwf/base_mars.md
docs/sdk/code-reference/pipelines/sources/spark/ecmwf/weather_forecast.md
docs/sdk/code-reference/pipelines/sources/spark/iso/caiso_daily_load_iso.md
docs/sdk/code-reference/pipelines/sources/spark/iso/caiso_historical_load_iso.md
docs/sdk/code-reference/pipelines/sources/spark/iso/ercot_daily_load_iso.md
docs/sdk/code-reference/pipelines/sources/spark/iso/miso_daily_load_iso.md
docs/sdk/code-reference/pipelines/sources/spark/iso/miso_historical_load_iso.md
docs/sdk/code-reference/pipelines/sources/spark/iso/pjm_daily_load_iso.md
docs/sdk/code-reference/pipelines/sources/spark/iso/pjm_daily_pricing_iso.md
docs/sdk/code-reference/pipelines/sources/spark/iso/pjm_historical_load_iso.md
docs/sdk/code-reference/pipelines/sources/spark/iso/pjm_historical_pricing_iso.md
docs/sdk/code-reference/pipelines/sources/spark/the_weather_company/base_weather.md
docs/sdk/code-reference/pipelines/sources/spark/the_weather_company/weather_forecast_api_v1.md
docs/sdk/code-reference/pipelines/sources/spark/the_weather_company/weather_forecast_api_v1_multi.md
docs/sdk/code-reference/pipelines/transformers/spark/base_raw_to_mdm.md
docs/sdk/code-reference/pipelines/transformers/spark/binary_to_string.md
docs/sdk/code-reference/pipelines/transformers/spark/edgex_opcua_json_to_pcdm.md
docs/sdk/code-reference/pipelines/transformers/spark/fledge_opcua_json_to_pcdm.md
docs/sdk/code-reference/pipelines/transformers/spark/honeywell_apm_to_pcdm.md
docs/sdk/code-reference/pipelines/transformers/spark/mirico_json_to_pcdm.md
docs/sdk/code-reference/pipelines/transformers/spark/opc_publisher_opcae_json_to_pcdm.md
docs/sdk/code-reference/pipelines/transformers/spark/opc_publisher_opcua_json_to_pcdm.md
docs/sdk/code-reference/pipelines/transformers/spark/pandas_to_pyspark.md
docs/sdk/code-reference/pipelines/transformers/spark/pcdm_to_honeywell_apm.md
docs/sdk/code-reference/pipelines/transformers/spark/pyspark_to_pandas.md
docs/sdk/code-reference/pipelines/transformers/spark/sem_json_to_pcdm.md
docs/sdk/code-reference/pipelines/transformers/spark/ssip_pi_binary_file_to_pcdm.md
docs/sdk/code-reference/pipelines/transformers/spark/ssip_pi_binary_json_to_pcdm.md
docs/sdk/code-reference/pipelines/transformers/spark/ecmwf/nc_extractbase_to_weather_data_model.md
docs/sdk/code-reference/pipelines/transformers/spark/ecmwf/nc_extractgrid_to_weather_data_model.md
docs/sdk/code-reference/pipelines/transformers/spark/ecmwf/nc_extractpoint_to_weather_data_model.md
docs/sdk/code-reference/pipelines/transformers/spark/iso/caiso_to_mdm.md
docs/sdk/code-reference/pipelines/transformers/spark/iso/ercot_to_mdm.md
docs/sdk/code-reference/pipelines/transformers/spark/iso/miso_to_mdm.md
docs/sdk/code-reference/pipelines/transformers/spark/iso/pjm_to_mdm.md
docs/sdk/code-reference/pipelines/transformers/spark/the_weather_company/raw_forecast_to_weather_data_model.md
docs/sdk/code-reference/pipelines/utilities/aws/s3_bucket_policy.md
docs/sdk/code-reference/pipelines/utilities/aws/s3_copy_utility.md
docs/sdk/code-reference/pipelines/utilities/azure/adls_gen2_acl.md
docs/sdk/code-reference/pipelines/utilities/azure/autoloader_resources.md
docs/sdk/code-reference/pipelines/utilities/spark/adls_gen2_spn_connect.md
docs/sdk/code-reference/pipelines/utilities/spark/configuration.md
docs/sdk/code-reference/pipelines/utilities/spark/delta_table_create.md
docs/sdk/code-reference/pipelines/utilities/spark/delta_table_optimize.md
docs/sdk/code-reference/pipelines/utilities/spark/delta_table_vacuum.md
docs/sdk/code-reference/pipelines/utilities/spark/session.md
docs/sdk/code-reference/query/connectors/db-sql-connector.md
docs/sdk/code-reference/query/connectors/pyodbc-sql-connector.md
docs/sdk/code-reference/query/connectors/spark-connector.md
docs/sdk/code-reference/query/connectors/turbodbc-sql-connector.md
docs/sdk/code-reference/query/functions/metadata.md
docs/sdk/code-reference/query/functions/time_series/circular-average.md
docs/sdk/code-reference/query/functions/time_series/circular-standard-deviation.md
docs/sdk/code-reference/query/functions/time_series/interpolate.md
docs/sdk/code-reference/query/functions/time_series/interpolation-at-time.md
docs/sdk/code-reference/query/functions/time_series/latest.md
docs/sdk/code-reference/query/functions/time_series/plot.md
docs/sdk/code-reference/query/functions/time_series/raw.md
docs/sdk/code-reference/query/functions/time_series/resample.md
docs/sdk/code-reference/query/functions/time_series/summary.md
docs/sdk/code-reference/query/functions/time_series/time-weighted-average.md
docs/sdk/code-reference/query/functions/time_series/time_series_query_builder.md
docs/sdk/code-reference/query/functions/weather/latest.md
docs/sdk/code-reference/query/functions/weather/raw.md
docs/sdk/code-reference/query/functions/weather/weather_query_builder.md
docs/sdk/code-reference/query/sql/sql_query.md
docs/sdk/examples/pipelines/deploy/ECMWF-to-Delta.md
docs/sdk/examples/pipelines/deploy/EdgeX-Eventhub-to-Delta.md
docs/sdk/examples/pipelines/deploy/Fledge-SparkConnect-PCDM.md
docs/sdk/examples/pipelines/deploy/MISODailyLoad-Batch-Pipeline-Local.md
docs/sdk/examples/pipelines/deploy/PJMDailyLoad-Batch-Pipeline-Local.md
docs/sdk/examples/pipelines/deploy/Python-Delta-to-Delta.md
docs/sdk/examples/pipelines/deploy/dagster/Fledge-Dagster-Pipeline-Databricks.md
docs/sdk/examples/pipelines/deploy/dagster/Fledge-Dagster-Pipeline-Local.md
docs/sdk/examples/pipelines/deploy/databricks/MISODailyLoad-Batch-Pipeline-Databricks.md
docs/sdk/examples/query/Circular-Average.md
docs/sdk/examples/query/Circular-Standard-Deviation.md
docs/sdk/examples/query/Interpolate.md
docs/sdk/examples/query/Interpolation-at-Time.md
docs/sdk/examples/query/Metadata.md
docs/sdk/examples/query/Plot.md
docs/sdk/examples/query/Raw.md
docs/sdk/examples/query/Resample.md
docs/sdk/examples/query/Summary.md
docs/sdk/examples/query/Time-Weighted-Average.md
docs/sdk/images/sdk-logo.png
docs/sdk/pipelines/components.md
docs/sdk/pipelines/framework.md
docs/sdk/pipelines/jobs.md
docs/sdk/pipelines/deploy/apache-airflow.md
docs/sdk/pipelines/deploy/databricks.md
docs/sdk/pipelines/images/apachespark.png
docs/sdk/pipelines/images/dagster-primary-vertical.png
docs/sdk/pipelines/images/databricks_horizontal.png
docs/sdk/pipelines/images/dlt.svg
docs/sdk/pipelines/images/python.png
docs/sdk/queries/connectors.md
docs/sdk/queries/functions.md
docs/sdk/queries/databricks/databricks-sql.md
docs/sdk/queries/databricks/sql-warehouses.md
docs/sdk/queries/databricks/troubleshooting.md
docs/sdk/queries/spark/spark-connect.md
docs/university/overview.md
docs/university/essentials/overview.md
docs/university/essentials/api/authentication.md
docs/university/essentials/api/exercise.md
docs/university/essentials/api/overview.md
docs/university/essentials/api/postman.md
docs/university/essentials/api/swagger.md
docs/university/essentials/api/assets/postman.png
docs/university/essentials/excel-connector/dashboard.md
docs/university/essentials/excel-connector/functions.md
docs/university/essentials/excel-connector/getting-started.md
docs/university/essentials/excel-connector/overview.md
docs/university/essentials/excel-connector/taskpane.md
docs/university/essentials/excel-connector/assets/Excel-Logo.png
docs/university/essentials/excel-connector/assets/dashboard-icon.png
docs/university/essentials/excel-connector/assets/home-tab.png
docs/university/essentials/excel-connector/assets/plot.gif
docs/university/essentials/excel-connector/assets/tagsearch-icon.png
docs/university/essentials/excel-connector/assets/taskpane.png
docs/university/essentials/powerbi/exercise.md
docs/university/essentials/powerbi/overview.md
docs/university/essentials/powerbi/images/bi-azure-signin.png
docs/university/essentials/powerbi/images/bi-getdata-more.png
docs/university/essentials/powerbi/images/bi-search-databricks.png
docs/university/essentials/powerbi/images/databricks_powerbi.png
docs/university/essentials/powerbi/images/power-bi-desktop.png
docs/university/essentials/powerbi/images/power-bi-install.png
docs/university/essentials/rtdip/architecture/databricks.md
docs/university/essentials/rtdip/architecture/pipelines.md
docs/university/essentials/rtdip/architecture/queries.md
docs/university/essentials/rtdip/assets/rtdip_databricks.png
docs/university/essentials/rtdip/assets/rtdip_sdk_pipelines.png
docs/university/essentials/rtdip/assets/rtdip_sdk_queries.png
docs/university/essentials/rtdip/introduction/overview.md
docs/university/essentials/rtdip/introduction/prerequisites.md
docs/university/essentials/sdk/authentication/azure.md
docs/university/essentials/sdk/authentication/databricks.md
docs/university/essentials/sdk/authentication/overview.md
docs/university/essentials/sdk/connectors/databricks-sql-connector.md
docs/university/essentials/sdk/connectors/exercise.md
docs/university/essentials/sdk/connectors/odbc-connectors.md
docs/university/essentials/sdk/connectors/overview.md
docs/university/essentials/sdk/connectors/spark-connector.md
docs/university/essentials/sdk/getting-started/exercise.md
docs/university/essentials/sdk/getting-started/installation.md
docs/university/essentials/sdk/getting-started/prerequisites.md
docs/university/essentials/sdk/queries/exercise.md
docs/university/essentials/sdk/queries/sql.md
docs/university/essentials/sdk/queries/timeseries.md
docs/university/essentials/sdk/queries/weather.md
src/__init__.py
src/api/.dockerignore
src/api/.funcignore
src/api/.gitignore
src/api/Dockerfile
src/api/README.md
src/api/__init__.py
src/api/host.json
src/api/requirements.txt
src/api/FastAPIApp/__init__.py
src/api/assets/__init__.py
src/api/auth/__init__.py
src/api/auth/azuread.py
src/api/v1/__init__.py
src/api/v1/batch.py
src/api/v1/circular_average.py
src/api/v1/circular_standard_deviation.py
src/api/v1/common.py
src/api/v1/function.json
src/api/v1/interpolate.py
src/api/v1/interpolation_at_time.py
src/api/v1/latest.py
src/api/v1/metadata.py
src/api/v1/models.py
src/api/v1/plot.py
src/api/v1/raw.py
src/api/v1/resample.py
src/api/v1/sql.py
src/api/v1/summary.py
src/api/v1/time_weighted_average.py
src/sdk/__init__.py
src/sdk/python/__init__.py
src/sdk/python/rtdip_sdk/__init__.py
src/sdk/python/rtdip_sdk.egg-info/PKG-INFO
src/sdk/python/rtdip_sdk.egg-info/SOURCES.txt
src/sdk/python/rtdip_sdk.egg-info/dependency_links.txt
src/sdk/python/rtdip_sdk.egg-info/requires.txt
src/sdk/python/rtdip_sdk.egg-info/top_level.txt
src/sdk/python/rtdip_sdk/_sdk_utils/__init__.py
src/sdk/python/rtdip_sdk/_sdk_utils/compare_versions.py
src/sdk/python/rtdip_sdk/_sdk_utils/pandas.py
src/sdk/python/rtdip_sdk/authentication/__init__.py
src/sdk/python/rtdip_sdk/authentication/authenticate.py
src/sdk/python/rtdip_sdk/authentication/azure.py
src/sdk/python/rtdip_sdk/connectors/__init__.py
src/sdk/python/rtdip_sdk/connectors/connection_interface.py
src/sdk/python/rtdip_sdk/connectors/cursor_interface.py
src/sdk/python/rtdip_sdk/connectors/models.py
src/sdk/python/rtdip_sdk/connectors/grpc/__init__.py
src/sdk/python/rtdip_sdk/connectors/grpc/spark_connector.py
src/sdk/python/rtdip_sdk/connectors/llm/__init__.py
src/sdk/python/rtdip_sdk/connectors/odbc/__init__.py
src/sdk/python/rtdip_sdk/connectors/odbc/db_sql_connector.py
src/sdk/python/rtdip_sdk/connectors/odbc/pyodbc_sql_connector.py
src/sdk/python/rtdip_sdk/connectors/odbc/turbodbc_sql_connector.py
src/sdk/python/rtdip_sdk/data_models/__init__.py
src/sdk/python/rtdip_sdk/data_models/timeseries.py
src/sdk/python/rtdip_sdk/data_models/meters/__init__.py
src/sdk/python/rtdip_sdk/data_models/meters/ami_meter.py
src/sdk/python/rtdip_sdk/data_models/meters/utils/CreateUsageObject.py
src/sdk/python/rtdip_sdk/data_models/meters/utils/__init__.py
src/sdk/python/rtdip_sdk/data_models/meters/utils/transform.py
src/sdk/python/rtdip_sdk/data_models/meters/utils/transformers.py
src/sdk/python/rtdip_sdk/data_models/storage_objects/__init__.py
src/sdk/python/rtdip_sdk/data_models/storage_objects/storage_objects_utils.py
src/sdk/python/rtdip_sdk/data_models/transformers/__init__.py
src/sdk/python/rtdip_sdk/data_models/transformers/london_smart_meter_transformer_2_usage.py
src/sdk/python/rtdip_sdk/data_models/utils/CreateTimeSeriesObject.py
src/sdk/python/rtdip_sdk/data_models/utils/timeseries_utils.py
src/sdk/python/rtdip_sdk/data_models/weather/__init__.py
src/sdk/python/rtdip_sdk/data_models/weather/weather_models.py
src/sdk/python/rtdip_sdk/data_models/weather/utils/CreateWeatherObject.py
src/sdk/python/rtdip_sdk/data_models/weather/utils/__init__.py
src/sdk/python/rtdip_sdk/functions/__init__.py
src/sdk/python/rtdip_sdk/functions/_query_builder.py
src/sdk/python/rtdip_sdk/functions/interpolate.py
src/sdk/python/rtdip_sdk/functions/interpolation_at_time.py
src/sdk/python/rtdip_sdk/functions/latest.py
src/sdk/python/rtdip_sdk/functions/metadata.py
src/sdk/python/rtdip_sdk/functions/raw.py
src/sdk/python/rtdip_sdk/functions/resample.py
src/sdk/python/rtdip_sdk/functions/time_weighted_average.py
src/sdk/python/rtdip_sdk/odbc/__init__.py
src/sdk/python/rtdip_sdk/odbc/db_sql_connector.py
src/sdk/python/rtdip_sdk/odbc/pyodbc_sql_connector.py
src/sdk/python/rtdip_sdk/odbc/turbodbc_sql_connector.py
src/sdk/python/rtdip_sdk/pipelines/__init__.py
src/sdk/python/rtdip_sdk/pipelines/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/__init__.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/amqp.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/constants.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/iso.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/mdm.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/mirico_field_mappings.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/models.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/obc_field_mappings.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/spark.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/temp_cert_files.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/weather.py
src/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/weather_ecmwf.py
src/sdk/python/rtdip_sdk/pipelines/converters/__init__.py
src/sdk/python/rtdip_sdk/pipelines/converters/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/converters/pipeline_job_json.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/__init__.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/input_validator.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/__init__.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/__init__.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/dimensionality_reduction.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/duplicate_detection.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/flatline_filter.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/gaussian_smoothing.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/interval_filtering.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/k_sigma_anomaly_detection.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/missing_value_imputation.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/out_of_range_value_filter.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/normalization/__init__.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/normalization/denormalization.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/normalization/normalization.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/normalization/normalization_mean.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/normalization/normalization_minmax.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/normalization/normalization_zscore.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/__init__.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/__init__.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/check_value_ranges.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/flatline_detection.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/great_expectations_data_quality.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/identify_missing_data_interval.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/identify_missing_data_pattern.py
src/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/moving_average.py
src/sdk/python/rtdip_sdk/pipelines/deploy/__init__.py
src/sdk/python/rtdip_sdk/pipelines/deploy/databricks.py
src/sdk/python/rtdip_sdk/pipelines/deploy/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/destinations/__init__.py
src/sdk/python/rtdip_sdk/pipelines/destinations/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/destinations/blockchain/__init__.py
src/sdk/python/rtdip_sdk/pipelines/destinations/blockchain/evm.py
src/sdk/python/rtdip_sdk/pipelines/destinations/python/__init__.py
src/sdk/python/rtdip_sdk/pipelines/destinations/python/delta.py
src/sdk/python/rtdip_sdk/pipelines/destinations/spark/__init__.py
src/sdk/python/rtdip_sdk/pipelines/destinations/spark/delta.py
src/sdk/python/rtdip_sdk/pipelines/destinations/spark/delta_merge.py
src/sdk/python/rtdip_sdk/pipelines/destinations/spark/eventhub.py
src/sdk/python/rtdip_sdk/pipelines/destinations/spark/kafka.py
src/sdk/python/rtdip_sdk/pipelines/destinations/spark/kafka_eventhub.py
src/sdk/python/rtdip_sdk/pipelines/destinations/spark/kinesis.py
src/sdk/python/rtdip_sdk/pipelines/destinations/spark/pcdm_latest_to_delta.py
src/sdk/python/rtdip_sdk/pipelines/destinations/spark/pcdm_to_delta.py
src/sdk/python/rtdip_sdk/pipelines/destinations/spark/rest_api.py
src/sdk/python/rtdip_sdk/pipelines/execute/__init__.py
src/sdk/python/rtdip_sdk/pipelines/execute/container.py
src/sdk/python/rtdip_sdk/pipelines/execute/job.py
src/sdk/python/rtdip_sdk/pipelines/execute/models.py
src/sdk/python/rtdip_sdk/pipelines/forecasting/__init__.py
src/sdk/python/rtdip_sdk/pipelines/forecasting/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/forecasting/spark/__init__.py
src/sdk/python/rtdip_sdk/pipelines/forecasting/spark/arima.py
src/sdk/python/rtdip_sdk/pipelines/forecasting/spark/auto_arima.py
src/sdk/python/rtdip_sdk/pipelines/forecasting/spark/data_binning.py
src/sdk/python/rtdip_sdk/pipelines/forecasting/spark/k_nearest_neighbors.py
src/sdk/python/rtdip_sdk/pipelines/forecasting/spark/linear_regression.py
src/sdk/python/rtdip_sdk/pipelines/logging/__init__.py
src/sdk/python/rtdip_sdk/pipelines/logging/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/logging/logger_manager.py
src/sdk/python/rtdip_sdk/pipelines/logging/spark/__init__.py
src/sdk/python/rtdip_sdk/pipelines/logging/spark/runtime_log_collector.py
src/sdk/python/rtdip_sdk/pipelines/logging/spark/dataframe/__init__.py
src/sdk/python/rtdip_sdk/pipelines/logging/spark/dataframe/dataframe_log_handler.py
src/sdk/python/rtdip_sdk/pipelines/logging/spark/log_file/__init__.py
src/sdk/python/rtdip_sdk/pipelines/logging/spark/log_file/file_log_handler.py
src/sdk/python/rtdip_sdk/pipelines/secrets/__init__.py
src/sdk/python/rtdip_sdk/pipelines/secrets/azure_key_vault.py
src/sdk/python/rtdip_sdk/pipelines/secrets/databricks.py
src/sdk/python/rtdip_sdk/pipelines/secrets/hashicorp_vault.py
src/sdk/python/rtdip_sdk/pipelines/secrets/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/secrets/models.py
src/sdk/python/rtdip_sdk/pipelines/sources/__init__.py
src/sdk/python/rtdip_sdk/pipelines/sources/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/sources/python/__init__.py
src/sdk/python/rtdip_sdk/pipelines/sources/python/delta.py
src/sdk/python/rtdip_sdk/pipelines/sources/python/delta_sharing.py
src/sdk/python/rtdip_sdk/pipelines/sources/python/entsoe.py
src/sdk/python/rtdip_sdk/pipelines/sources/python/mffbas.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/__init__.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/autoloader.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/delta.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/delta_sharing.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/eventhub.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iot_hub.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/kafka.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/kafka_eventhub.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/kinesis.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/ecmwf/__init__.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/ecmwf/base_mars.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/ecmwf/weather_forecast.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/__init__.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/base_iso.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/caiso_daily_load_iso.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/caiso_historical_load_iso.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/ercot_daily_load_iso.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/miso_daily_load_iso.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/miso_historical_load_iso.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/pjm_daily_load_iso.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/pjm_daily_pricing_iso.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/pjm_historical_load_iso.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/pjm_historical_pricing_iso.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/the_weather_company/__init__.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/the_weather_company/base_weather.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/the_weather_company/weather_forecast_api_v1.py
src/sdk/python/rtdip_sdk/pipelines/sources/spark/the_weather_company/weather_forecast_api_v1_multi.py
src/sdk/python/rtdip_sdk/pipelines/transformers/__init__.py
src/sdk/python/rtdip_sdk/pipelines/transformers/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/__init__.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/aio_json_to_pcdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/base_raw_to_mdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/binary_to_string.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/edgex_opcua_json_to_pcdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/fledge_opcua_json_to_pcdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/honeywell_apm_to_pcdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/mirico_json_to_metadata.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/mirico_json_to_pcdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/opc_publisher_opcae_json_to_pcdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/opc_publisher_opcua_json_to_pcdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/opcua_json_to_pcdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/pandas_to_pyspark.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/pcdm_to_honeywell_apm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/pyspark_to_pandas.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/sem_json_to_pcdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/ssip_pi_binary_file_to_pcdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/ssip_pi_binary_json_to_pcdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/ecmwf/__init__.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/ecmwf/nc_extractbase_to_weather_data_model.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/ecmwf/nc_extractgrid_to_weather_data_model.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/ecmwf/nc_extractpoint_to_weather_data_model.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/__init__.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/caiso_to_mdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/ercot_to_mdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/miso_to_mdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/pjm_to_mdm.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/machine_learning/__init__.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/machine_learning/columns_to_vector.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/machine_learning/one_hot_encoding.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/machine_learning/polynomial_features.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/the_weather_company/__init__.py
src/sdk/python/rtdip_sdk/pipelines/transformers/spark/the_weather_company/raw_forecast_to_weather_data_model.py
src/sdk/python/rtdip_sdk/pipelines/utilities/__init__.py
src/sdk/python/rtdip_sdk/pipelines/utilities/interfaces.py
src/sdk/python/rtdip_sdk/pipelines/utilities/pipeline_components.py
src/sdk/python/rtdip_sdk/pipelines/utilities/aws/__init__.py
src/sdk/python/rtdip_sdk/pipelines/utilities/aws/s3_bucket_policy.py
src/sdk/python/rtdip_sdk/pipelines/utilities/aws/s3_copy_utility.py
src/sdk/python/rtdip_sdk/pipelines/utilities/azure/__init__.py
src/sdk/python/rtdip_sdk/pipelines/utilities/azure/adls_gen2_acl.py
src/sdk/python/rtdip_sdk/pipelines/utilities/azure/autoloader_resources.py
src/sdk/python/rtdip_sdk/pipelines/utilities/spark/__init__.py
src/sdk/python/rtdip_sdk/pipelines/utilities/spark/adls_gen2_spn_connect.py
src/sdk/python/rtdip_sdk/pipelines/utilities/spark/configuration.py
src/sdk/python/rtdip_sdk/pipelines/utilities/spark/delta_table_create.py
src/sdk/python/rtdip_sdk/pipelines/utilities/spark/delta_table_optimize.py
src/sdk/python/rtdip_sdk/pipelines/utilities/spark/delta_table_vacuum.py
src/sdk/python/rtdip_sdk/pipelines/utilities/spark/session.py
src/sdk/python/rtdip_sdk/pipelines/utilities/spark/time_string_parsing.py
src/sdk/python/rtdip_sdk/queries/__init__.py
src/sdk/python/rtdip_sdk/queries/_utilities_query_builder.py
src/sdk/python/rtdip_sdk/queries/metadata.py
src/sdk/python/rtdip_sdk/queries/sql/__init__.py
src/sdk/python/rtdip_sdk/queries/sql/sql_query.py
src/sdk/python/rtdip_sdk/queries/time_series/__init__.py
src/sdk/python/rtdip_sdk/queries/time_series/_time_series_query_builder.py
src/sdk/python/rtdip_sdk/queries/time_series/batch.py
src/sdk/python/rtdip_sdk/queries/time_series/circular_average.py
src/sdk/python/rtdip_sdk/queries/time_series/circular_standard_deviation.py
src/sdk/python/rtdip_sdk/queries/time_series/interpolate.py
src/sdk/python/rtdip_sdk/queries/time_series/interpolation_at_time.py
src/sdk/python/rtdip_sdk/queries/time_series/latest.py
src/sdk/python/rtdip_sdk/queries/time_series/plot.py
src/sdk/python/rtdip_sdk/queries/time_series/raw.py
src/sdk/python/rtdip_sdk/queries/time_series/resample.py
src/sdk/python/rtdip_sdk/queries/time_series/summary.py
src/sdk/python/rtdip_sdk/queries/time_series/time_series_query_builder.py
src/sdk/python/rtdip_sdk/queries/time_series/time_weighted_average.py
src/sdk/python/rtdip_sdk/queries/weather/__init__.py
src/sdk/python/rtdip_sdk/queries/weather/_weather_query_builder.py
src/sdk/python/rtdip_sdk/queries/weather/latest.py
src/sdk/python/rtdip_sdk/queries/weather/raw.py
src/sdk/python/rtdip_sdk/queries/weather/weather_query_builder.py
tests/__init__.py
tests/conftest.py
tests/api/__init__.py
tests/api/auth/__init__.py
tests/api/auth/test_auth_azuread.py
tests/api/v1/__init__.py
tests/api/v1/api_test_objects.py
tests/api/v1/test_api_batch.py
tests/api/v1/test_api_circular_average.py
tests/api/v1/test_api_circular_standard_deviation.py
tests/api/v1/test_api_common.py
tests/api/v1/test_api_interpolate.py
tests/api/v1/test_api_interpolation_at_time.py
tests/api/v1/test_api_latest.py
tests/api/v1/test_api_metadata.py
tests/api/v1/test_api_plot.py
tests/api/v1/test_api_raw.py
tests/api/v1/test_api_resample.py
tests/api/v1/test_api_sql.py
tests/api/v1/test_api_summary.py
tests/api/v1/test_api_time_weighted_average.py
tests/api/v1/test_api_utilities.py
tests/docs/__init__.py
tests/docs/test_macros.py
tests/docs/test_mkdocs_build.py
tests/sdk/__init__.py
tests/sdk/python/__init__.py
tests/sdk/python/rtdip_sdk/__init__.py
tests/sdk/python/rtdip_sdk/_sdk_utils/__init__.py
tests/sdk/python/rtdip_sdk/_sdk_utils/test_compare_versions.py
tests/sdk/python/rtdip_sdk/authentication/__init__.py
tests/sdk/python/rtdip_sdk/authentication/test_authenticate.py
tests/sdk/python/rtdip_sdk/connectors/__init__.py
tests/sdk/python/rtdip_sdk/connectors/grpc/__init__.py
tests/sdk/python/rtdip_sdk/connectors/grpc/test_spark_connector.py
tests/sdk/python/rtdip_sdk/connectors/llm/__init__.py
tests/sdk/python/rtdip_sdk/connectors/odbc/__init__.py
tests/sdk/python/rtdip_sdk/connectors/odbc/test_connection_interface.py
tests/sdk/python/rtdip_sdk/connectors/odbc/test_cursor_interface.py
tests/sdk/python/rtdip_sdk/connectors/odbc/test_db_sql_connector.py
tests/sdk/python/rtdip_sdk/connectors/odbc/test_pyodbc_sql_connector.py
tests/sdk/python/rtdip_sdk/connectors/odbc/test_turbodbc_sql_connector.py
tests/sdk/python/rtdip_sdk/connectors/odbc/mock/turbodbc
tests/sdk/python/rtdip_sdk/data_models/__init__.py
tests/sdk/python/rtdip_sdk/data_models/test_timeseries.py
tests/sdk/python/rtdip_sdk/data_models/meters/utils/__init__.py
tests/sdk/python/rtdip_sdk/data_models/meters/utils/test_transform.py
tests/sdk/python/rtdip_sdk/data_models/meters/utils/test_data/smart_meters_london/CC_LCL-FullData.csv
tests/sdk/python/rtdip_sdk/data_models/meters/utils/test_data/smart_meters_london/LCL-June2015v2_0.csv
tests/sdk/python/rtdip_sdk/data_models/storage_objects/test_storage_objects_utils.py
tests/sdk/python/rtdip_sdk/data_models/transformers/__init__.py
tests/sdk/python/rtdip_sdk/data_models/transformers/test_transformers.py
tests/sdk/python/rtdip_sdk/data_models/utils/test_utils.py
tests/sdk/python/rtdip_sdk/data_models/weather/__init__.py
tests/sdk/python/rtdip_sdk/data_models/weather/test_weather_objects.py
tests/sdk/python/rtdip_sdk/pipelines/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/aws.py
tests/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/azure.py
tests/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/pipeline_job_templates.py
tests/sdk/python/rtdip_sdk/pipelines/_pipeline_utils/spark_configuration_constants.py
tests/sdk/python/rtdip_sdk/pipelines/converters/test_pipeline_job_json.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/test_data.csv
tests/sdk/python/rtdip_sdk/pipelines/data_quality/test_input_validator.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/test_dimensionality_reduction.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/test_duplicate_detection.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/test_flatline_filter.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/test_gaussian_smoothing.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/test_interval_filtering.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/test_k_sigma_anomaly_detection.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/test_missing_value_imputation.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/test_normalization.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/test_one_hot_encoding.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/data_manipulation/spark/test_out_of_range_value_filter.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/__init__ .py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/test_check_value_ranges.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/test_flatline_detection.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/test_great_expectations_data_quality.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/test_identify_missing_data_interval.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/test_identify_missing_data_pattern.py
tests/sdk/python/rtdip_sdk/pipelines/data_quality/monitoring/spark/test_moving_average.py
tests/sdk/python/rtdip_sdk/pipelines/deploy/test_databricks_deploy.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/blockchain/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/blockchain/test_evm.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/python/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/python/test_delta.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/spark/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/spark/test_delta.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/spark/test_delta_merge.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/spark/test_eventhub.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/spark/test_kafka.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/spark/test_kafka_eventhub.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/spark/test_kinesis.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/spark/test_pcdm_latest_to_delta.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/spark/test_pcdm_to_delta.py
tests/sdk/python/rtdip_sdk/pipelines/destinations/spark/test_rest_api.py
tests/sdk/python/rtdip_sdk/pipelines/execute/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/execute/test_spark_job.py
tests/sdk/python/rtdip_sdk/pipelines/forecasting/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/forecasting/spark/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/forecasting/spark/test_arima.py
tests/sdk/python/rtdip_sdk/pipelines/forecasting/spark/test_data_binning.py
tests/sdk/python/rtdip_sdk/pipelines/forecasting/spark/test_k_nearest_neighbors.py
tests/sdk/python/rtdip_sdk/pipelines/forecasting/spark/test_linear_regression.py
tests/sdk/python/rtdip_sdk/pipelines/logging/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/logging/test_log_collection.py
tests/sdk/python/rtdip_sdk/pipelines/logging/test_logger_manager.py
tests/sdk/python/rtdip_sdk/pipelines/secrets/test_azure_key_vault_secrets.py
tests/sdk/python/rtdip_sdk/pipelines/secrets/test_databricks_secrets.py
tests/sdk/python/rtdip_sdk/pipelines/secrets/test_hashicorp_secrets.py
tests/sdk/python/rtdip_sdk/pipelines/sources/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/sources/python/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/sources/python/test_delta.py
tests/sdk/python/rtdip_sdk/pipelines/sources/python/test_delta_sharing.py
tests/sdk/python/rtdip_sdk/pipelines/sources/python/test_entsoe.py
tests/sdk/python/rtdip_sdk/pipelines/sources/python/test_mffbas.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/test_autoloader.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/test_delta.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/test_delta_sharing.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/test_eventhub.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/test_iot_hub.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/test_kafka.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/test_kafka_eventhub.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/test_kinesis.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/ecmwf/test_base_mars.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/ecmwf/test_weather_forecast.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/test_base_iso.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/test_caiso_daily_load_iso.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/test_caiso_historical_load_iso.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/test_ercot_daily_load_iso.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/test_miso_daily_load_iso.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/test_miso_historical_load_iso.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/test_pjm_daily_load_iso.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/test_pjm_daily_pricing_iso.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/test_pjm_historical_load_iso.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/test_pjm_historical_pricing_iso.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/data/caiso_daily_load_sample1.zip
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/data/caiso_daily_load_sample2.zip
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/data/caiso_historical_load_sample1.zip
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/data/ercot_daily_load_actual_expected.csv
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/data/ercot_daily_load_actual_sample1.zip
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/data/ercot_daily_load_actual_sample2.zip
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/data/ercot_daily_load_forecast_expected.csv
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/iso/data/ercot_daily_load_forecast_sample1.zip
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/the_weather_company/test_base_weather.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/the_weather_company/test_weather_forecast_api_v1.py
tests/sdk/python/rtdip_sdk/pipelines/sources/spark/the_weather_company/test_weather_forecast_api_v1_multi.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_aio_json_to_pcdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_binary_to_string.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_edgex_opcua_json_to_pcdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_fledge_opcua_json_to_pcdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_honeywell_apm_to_pcdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_mirico_json_to_metadata.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_mirico_json_to_pcdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_opc_publisher_opcae_json_to_pcdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_opc_publisher_opcua_json_to_pcdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_opcua_json_to_pcdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_pandas_to_pyspark.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_pcdm_to_honeywell_apm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_pyspark_to_pandas.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_sem_json_to_pcdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_ssip_pi_binary_file_to_pcdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/test_ssip_pi_binary_json_to_pcdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/ecmwf/test_nc_extractbase_to_weather_data_model.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/ecmwf/test_nc_extractgrid_to_weather_data_model.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/ecmwf/test_nc_extractpoint_to_weather_data_model.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/ecmwf/test_file/2021-01-01_00.nc
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/ecmwf/test_file/2021-01-01_12.nc
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/__init__.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_caiso_to_mdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_ercot_to_mdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_miso_to_mdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_pjm_to_mdm.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/caiso_meta/input.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/caiso_meta/output.json
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/caiso_usage/input.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/caiso_usage/output.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/ercot_meta/input.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/ercot_meta/output.json
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/ercot_usage/input.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/ercot_usage/output.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/miso_meta/input.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/miso_meta/output.json
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/miso_usage/input.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/miso_usage/output.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/pjm_meta/input.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/pjm_meta/output.json
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/pjm_usage/input.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/iso/test_data/pjm_usage/output.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/the_weather_company/test_raw_forecast_to_weather_data_model.py
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/the_weather_company/raw_forecast_to_weather_data_model/input.csv
tests/sdk/python/rtdip_sdk/pipelines/transformers/spark/the_weather_company/raw_forecast_to_weather_data_model/output.csv
tests/sdk/python/rtdip_sdk/pipelines/utilities/aws/test_s3_bucket_policy.py
tests/sdk/python/rtdip_sdk/pipelines/utilities/aws/test_s3_copy_utility.py
tests/sdk/python/rtdip_sdk/pipelines/utilities/azure/test_adls_gen2_acl.py
tests/sdk/python/rtdip_sdk/pipelines/utilities/azure/test_autoloader_resources.py
tests/sdk/python/rtdip_sdk/pipelines/utilities/spark/test_adls_gen2_spn_connect.py
tests/sdk/python/rtdip_sdk/pipelines/utilities/spark/test_configuration.py
tests/sdk/python/rtdip_sdk/pipelines/utilities/spark/test_delta_table_create.py
tests/sdk/python/rtdip_sdk/pipelines/utilities/spark/test_delta_table_optimize.py
tests/sdk/python/rtdip_sdk/pipelines/utilities/spark/test_delta_table_vacuum.py
tests/sdk/python/rtdip_sdk/queries/__init__.py
tests/sdk/python/rtdip_sdk/queries/_test_utils/sdk_test_objects.py
tests/sdk/python/rtdip_sdk/queries/sql/__init__.py
tests/sdk/python/rtdip_sdk/queries/sql/test_sql_query.py
tests/sdk/python/rtdip_sdk/queries/time_series/__init__.py
tests/sdk/python/rtdip_sdk/queries/time_series/_test_base.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_circular_average.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_circular_standard_deviation.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_interpolate.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_interpolation_at_time.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_latest.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_metadata.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_plot.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_query_builder.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_raw.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_resample.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_summary.py
tests/sdk/python/rtdip_sdk/queries/time_series/test_time_weighted_average.py
tests/sdk/python/rtdip_sdk/queries/weather/__init__.py
tests/sdk/python/rtdip_sdk/queries/weather/test_latest.py
tests/sdk/python/rtdip_sdk/queries/weather/test_raw.py
tests/sdk/python/rtdip_sdk/queries/weather/test_weather_query_builder.py