diff --git a/community/user/Airports_visualizer/Airports_visualizer.py b/community/user/Airports_visualizer/Airports_visualizer.py
new file mode 100644
index 0000000..53ac91e
--- /dev/null
+++ b/community/user/Airports_visualizer/Airports_visualizer.py
@@ -0,0 +1,45 @@
+@fused.udf
+def udf(
+ path: str = 's3://fused-users/fused/aaryan/airports.csv',
+ bounds: fused.types.TileGDF = None,
+ airport_type: str = None,
+ continent: str = None,
+ min_elevation: float = None,
+ scheduled_service: str = None,
+ use_columns: list = None
+):
+ """
+ Returns airport data as a GeoDataFrame with visualization parameters.
+ """
+ import geopandas as gpd
+ import pandas as pd
+ from shapely.geometry import Point
+
+
+ df = pd.read_csv(path)
+
+ # Create geometry from lat/lon
+ geometry = [Point(xy) for xy in zip(df.longitude_deg, df.latitude_deg)]
+ gdf = gpd.GeoDataFrame(df, geometry=geometry)
+
+ # Apply filters if provided
+ print("hi")
+ if airport_type:
+ gdf = gdf[gdf.type == airport_type]
+ if continent:
+ gdf = gdf[gdf.continent == continent]
+ if min_elevation:
+ gdf = gdf[gdf.elevation_ft >= min_elevation]
+ if scheduled_service:
+ gdf = gdf[gdf.scheduled_service == scheduled_service]
+
+ # Spatial filter if bounds provided
+ if bounds is not None:
+ gdf = gdf[gdf.geometry.intersects(bounds.geometry.iloc[0])]
+
+ # Select columns
+ if use_columns:
+ keep_cols = list(set(use_columns + ['geometry']))
+ gdf = gdf[keep_cols]
+
+ return gdf
\ No newline at end of file
diff --git a/community/user/Airports_visualizer/README.MD b/community/user/Airports_visualizer/README.MD
new file mode 100644
index 0000000..7f402c9
--- /dev/null
+++ b/community/user/Airports_visualizer/README.MD
@@ -0,0 +1,5 @@
+
+
+
+
+Read a CSV or TSV file.
diff --git a/community/user/Airports_visualizer/meta.json b/community/user/Airports_visualizer/meta.json
new file mode 100644
index 0000000..4f4d7c0
--- /dev/null
+++ b/community/user/Airports_visualizer/meta.json
@@ -0,0 +1,75 @@
+{
+ "version": "0.0.3",
+ "job_config": {
+ "version": "0.0.3",
+ "name": null,
+ "steps": [
+ {
+ "type": "udf",
+ "udf": {
+ "type": "geopandas_v2",
+ "name": "Airports_visualizer",
+ "entrypoint": "udf",
+ "parameters": {},
+ "metadata": {
+ "fused:vizConfig": {
+ "tileLayer": {
+ "@@type": "TileLayer",
+ "minZoom": 0,
+ "maxZoom": 19,
+ "tileSize": 256,
+ "pickable": true
+ },
+ "rasterLayer": {
+ "@@type": "BitmapLayer",
+ "pickable": true
+ },
+ "vectorLayer": {
+ "@@type": "GeoJsonLayer",
+ "stroked": true,
+ "filled": false,
+ "pickable": true,
+ "lineWidthMinPixels": 1,
+ "pointRadiusMinPixels": 1,
+ "getLineColor": {
+ "@@function": "colorContinuous",
+ "attr": "value",
+ "domain": [
+ 0,
+ 10
+ ],
+ "colors": "Teal",
+ "nullColor": [
+ 184,
+ 184,
+ 184
+ ]
+ },
+ "getFillColor": [
+ 208,
+ 208,
+ 208,
+ 40
+ ]
+ }
+ },
+ "fused:udfType": "auto",
+ "fused:slug": "Airports_visualizer",
+ "fused:name": "Airports_visualizer",
+ "fused:defaultParameters": [],
+ "fused:mcp": {
+ "description": "Read a CSV or TSV file.\n",
+ "parameters": "[\n {\n \"name\": \"foo\",\n \"type\": \"string\"\n },\n {\n \"name\": \"string-param\",\n \"type\": \"string\"\n }\n]"
+ },
+ "fused:assetUrl": "https://fused-magic.s3.amazonaws.com/thumbnails/preview/fusedlabs/fusedudfs/Airports_visualizer/3e212a38-5524-48b1-84fc-c7753648e365",
+ "fused:description": "Read a CSV or TSV file.\n",
+ "fused:tags": []
+ },
+ "source": "Airports_visualizer.py",
+ "headers": []
+ }
+ }
+ ],
+ "metadata": null
+ }
+}
\ No newline at end of file
diff --git a/community/user/Overture_Maps_Example/README.MD b/community/user/Overture_Maps_Example/README.MD
new file mode 100644
index 0000000..e8a34d7
--- /dev/null
+++ b/community/user/Overture_Maps_Example/README.MD
@@ -0,0 +1,28 @@
+
+
+
+
+
+Tags: `overture` `coop`
+
+
+Buildings footprints, places of interest (POIs), admin boundaries, and transportation globally from [Overture Maps](https://overturemaps.org/).
+
+## Parameters
+
+- `release`: Overture release ID. Defaults to `2024-12-18-0`. Note that `.` should be replaced with `-` in the ID.
+- `type`: One of `infrastructure`, `land`, `land_use`, `water`, `division`, `division_boundary`, `division_area`, `place`, `connector`, `segment`, `address`, `building` (default).
+- `theme`: One of `buildings`, `base`, `places`, `transportation`, `divisions`, `addresses`. If not specified, this will be inferred from the type.
+- `use_columns`: Load only these columns if specified. Default is to load all columns.
+
+## Run this in any Jupyter Notebook
+
+```python
+import fused
+import geopandas as gpd
+
+udf = fused.load("https://github.com/fusedio/udfs/tree/main/public/Overture_Maps_Example")
+gdf_output = fused.run(udf, x=2622, y=6333, z=14)
+gdf = gpd.GeoDataFrame(gdf_output, geometry='geometry', crs='epsg:4326')
+gdf.plot()
+```
diff --git a/community/user/Overture_Maps_Example/meta.json b/community/user/Overture_Maps_Example/meta.json
new file mode 100644
index 0000000..21a17b7
--- /dev/null
+++ b/community/user/Overture_Maps_Example/meta.json
@@ -0,0 +1,150 @@
+{
+ "version": "0.0.3",
+ "job_config": {
+ "version": "0.0.3",
+ "name": null,
+ "steps": [
+ {
+ "type": "udf",
+ "udf": {
+ "type": "geopandas_v2",
+ "name": "ov",
+ "entrypoint": "udf",
+ "parameters": {},
+ "metadata": {
+ "fused:defaultParameters": [
+ {
+ "parameter": "release",
+ "value": "",
+ "type": "string",
+ "suggestedValues": [
+ "2024-08-20-0",
+ "2024-09-18-0",
+ "2024-10-23-0",
+ "2024-11-13-0",
+ "2024-12-18-0",
+ "2025-01-22-0",
+ "2025-03-19-1"
+ ]
+ },
+ {
+ "parameter": "theme",
+ "value": "",
+ "type": "string",
+ "suggestedValues": [
+ "buildings",
+ "base",
+ "places",
+ "transportation",
+ "addresses",
+ "divisions"
+ ]
+ },
+ {
+ "parameter": "overture_type",
+ "value": "",
+ "type": "string",
+ "suggestedValues": [
+ "land_use",
+ "water",
+ "place",
+ "connector",
+ "segment",
+ "building",
+ "address",
+ "infrastructure",
+ "land",
+ "division",
+ "division_area",
+ "division_boundary",
+ "land_cover",
+ "bathymetry"
+ ]
+ },
+ {
+ "parameter": "use_columns",
+ "value": [],
+ "type": "array",
+ "suggestedValues": [
+ "geometry",
+ "id",
+ "names",
+ "sources",
+ "update_time",
+ "categories"
+ ]
+ }
+ ],
+ "fused:vizConfig": {
+ "tileLayer": {
+ "@@type": "TileLayer",
+ "minZoom": 0,
+ "maxZoom": 19,
+ "tileSize": 256,
+ "pickable": true
+ },
+ "rasterLayer": {
+ "@@type": "BitmapLayer"
+ },
+ "vectorLayer": {
+ "@@type": "GeoJsonLayer",
+ "stroked": true,
+ "filled": false,
+ "pickable": true,
+ "lineWidthMinPixels": 1,
+ "getLineColor": {
+ "@@function": "hasProp",
+ "property": "r",
+ "present": "@@=[properties.r, properties.g, properties.b]",
+ "absent": [
+ 200,
+ 250,
+ 0
+ ]
+ },
+ "getFillColor": [
+ 255,
+ 0,
+ 0,
+ 40
+ ]
+ }
+ },
+ "fused:udfType": "vector_tile",
+ "fused:slug": "ov",
+ "fused:name": "ov",
+ "fused:defaultViewState": {
+ "enable": true,
+ "latitude": 51.50786698991621,
+ "longitude": -0.10589130924052784,
+ "zoom": 13.935948485009598,
+ "pitch": 0,
+ "bearing": 0
+ },
+ "fused:assetUrl": "https://fused-magic.s3.us-west-2.amazonaws.com/thumbnails/udfs-staging/Overture_Map_Example2.png",
+ "fused:tags": [
+ {
+ "id": "overture",
+ "label": "overture"
+ },
+ {
+ "id": "coop",
+ "label": "coop"
+ }
+ ],
+ "fused:description": "Buildings footprints, places of interest (POIs), admin boundaries, and transportation globally from [Overture Maps](https://overturemaps.org/).\n\n## Parameters\n\n- `release`: Overture release ID. Defaults to `2024-12-18-0`. Note that `.` should be replaced with `-` in the ID.\n- `type`: One of `infrastructure`, `land`, `land_use`, `water`, `division`, `division_boundary`, `division_area`, `place`, `connector`, `segment`, `address`, `building` (default).\n- `theme`: One of `buildings`, `base`, `places`, `transportation`, `divisions`, `addresses`. If not specified, this will be inferred from the type.\n- `use_columns`: Load only these columns if specified. Default is to load all columns.\n\n## Run this in any Jupyter Notebook\n\n```python\nimport fused\nimport geopandas as gpd\n\nudf = fused.load(\"https://github.com/fusedio/udfs/tree/main/public/Overture_Maps_Example\")\ngdf_output = fused.run(udf, x=2622, y=6333, z=14)\ngdf = gpd.GeoDataFrame(gdf_output, geometry='geometry', crs='epsg:4326')\ngdf.plot()\n```\n",
+ "fused:explorerPin": "1"
+ },
+ "source": "ov.py",
+ "headers": [
+ {
+ "module_name": "utils",
+ "source_file": "utils.py"
+ }
+ ]
+ }
+ }
+ ],
+ "metadata": null
+ }
+}
\ No newline at end of file
diff --git a/community/user/Overture_Maps_Example/ov.py b/community/user/Overture_Maps_Example/ov.py
new file mode 100644
index 0000000..35db0a7
--- /dev/null
+++ b/community/user/Overture_Maps_Example/ov.py
@@ -0,0 +1,27 @@
+@fused.udf
+def udf(
+ bounds: fused.types.Bounds = None,
+ release: str = "2025-03-19-1",
+ theme: str = None,
+ overture_type: str = None,
+ use_columns: list = None,
+ num_parts: int = None,
+ min_zoom: int = None,
+
+ polygon: str = None,
+ point_convert: str = None
+):
+ from utils import get_overture
+
+ gdf = get_overture(
+ bounds=bounds,
+ release=release,
+ theme=theme,
+ overture_type=overture_type,
+ use_columns=use_columns,
+ num_parts=num_parts,
+ min_zoom=min_zoom,
+ polygon=polygon,
+ point_convert=point_convert
+ )
+ return gdf
diff --git a/community/user/Overture_Maps_Example/utils.py b/community/user/Overture_Maps_Example/utils.py
new file mode 100644
index 0000000..0e93d86
--- /dev/null
+++ b/community/user/Overture_Maps_Example/utils.py
@@ -0,0 +1,137 @@
+def get_overture(
+ bounds: fused.types.Bounds = None,
+ release: str = "2025-03-19-1",
+ theme: str = None,
+ overture_type: str = None,
+ use_columns: list = None,
+ num_parts: int = None,
+ min_zoom: int = None,
+ polygon: str = None,
+ point_convert: str = None
+):
+ """Returns Overture data as a GeoDataFrame."""
+ import logging
+ import concurrent.futures
+ import json
+
+ import geopandas as gpd
+ import pandas as pd
+ from shapely.geometry import shape, box
+
+ # Load pinned versions of utility functions.
+ utils = fused.load("https://github.com/fusedio/udfs/tree/d0e8eb0/public/common/").utils
+
+ if release == "2024-02-15-alpha-0":
+ if overture_type == "administrative_boundary":
+ overture_type = "administrativeBoundary"
+ elif overture_type == "land_use":
+ overture_type = "landUse"
+ theme_per_type = {
+ "building": "buildings",
+ "administrativeBoundary": "admins",
+ "place": "places",
+ "landUse": "base",
+ "water": "base",
+ "segment": "transportation",
+ "connector": "transportation",
+ }
+ elif release == "2024-03-12-alpha-0":
+ theme_per_type = {
+ "building": "buildings",
+ "administrative_boundary": "admins",
+ "place": "places",
+ "land_use": "base",
+ "water": "base",
+ "segment": "transportation",
+ "connector": "transportation",
+ }
+ else:
+ theme_per_type = {
+ "address": "addresses",
+ "building": "buildings",
+ "infrastructure": "base",
+ "land": "base",
+ "land_use": "base",
+ "land_cover": "base",
+ "water": "base",
+ "bathymetry": "base",
+ "place": "places",
+ "division": "divisions",
+ "division_area": "divisions",
+ "division_boundary": "divisions",
+ "segment": "transportation",
+ "connector": "transportation",
+ }
+
+ if theme is None:
+ theme = theme_per_type.get(overture_type, "buildings")
+
+ if overture_type is None:
+ type_per_theme = {v: k for k, v in theme_per_type.items()}
+ overture_type = type_per_theme[theme]
+
+ if num_parts is None:
+ if overture_type == "building":
+ if release >= "2025-01-22-0":
+ num_parts = 6
+ else:
+ num_parts = 5
+ else:
+ num_parts = 1
+
+ if min_zoom is None:
+ if theme == "admins" or theme == "divisions":
+ min_zoom = 7
+ elif theme == "base":
+ min_zoom = 9
+ else:
+ min_zoom = 12
+
+ table_path = f"s3://us-west-2.opendata.source.coop/fused/overture/{release}/theme={theme}/type={overture_type}"
+ table_path = table_path.rstrip("/")
+
+ if polygon is not None:
+ polygon=gpd.GeoDataFrame.from_features(json.loads(polygon))
+ tile = polygon.geometry.bounds
+ tile = gpd.GeoDataFrame(
+ {
+ "geometry": [
+ box(
+ bounds[0],
+ bounds[1],
+ bounds[2],
+ bounds[3],
+ )
+ ]
+ }
+ )
+
+ def get_part(part):
+ part_path = f"{table_path}/part={part}/" if num_parts != 1 else table_path
+ try:
+ return utils.table_to_tile(
+ bounds, table=part_path, use_columns=use_columns, min_zoom=min_zoom
+ )
+ except ValueError:
+ return None
+
+ if num_parts > 1:
+ with concurrent.futures.ThreadPoolExecutor(max_workers=num_parts) as pool:
+ dfs = list(pool.map(get_part, range(num_parts)))
+ else:
+ # Don't bother creating a thread pool to do one thing
+ dfs = [get_part(0)]
+
+ dfs = [df for df in dfs if df is not None]
+
+ if len(dfs):
+ gdf = pd.concat(dfs)
+
+ else:
+ logging.warn("Failed to get any data")
+ return None
+
+ if point_convert is not None:
+ gdf["geometry"] = gdf.geometry.centroid
+
+ return gdf