InfluxDB and PySpark