OpenDGPS OpenDGPS
OpenDGPS
/ genericMappingFunctions.py
Created
October 7, 2016 10:34
Using a generic definition auf map and filter functions to rearrange a DataFrame in pyspark. Surprisingly it is fast even if it's create a new array on each row.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import os | |
| import json | |
| import findspark | |
| findspark.init() | |
| import pyspark | |
| from datetime import datetime | |
| from pivottablejs import pivot_ui | |
| try: | |
| conf = pyspark.SparkConf().setMaster("local[4]") |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| from typing import Any | |
| import httpx | |
| from mcp.server.fastmcp import FastMCP | |
| mcp = FastMCP("tmdb_agent") | |
| async def make_tmdb_request(url: str) -> dict[str, Any] | None: | |
| """Make a request to the TMDB API with proper error handling.""" | |
| headers = { | |
| "accept": "application/json", |