(no title)
kvnkho | 4 years ago
For example, with a python function
```python
# schema: , c:int
def add_new_col(df:pd.DataFrame) -> pd.DataFrame:
df['c'] = 1
return df
query = """SELECT FROM df TRANSFORM USING add_new_col"""fsql(query).run()
# to run on Spark
fsql(query).run(SparkExecutionEngine)
```
No comments yet.