#!/usr/bin/env python
# coding: utf-8

# In[1]:


import sys
sys.path.append("..")


# In[2]:


from pyspark.sql import SparkSession
spark = SparkSession.builder.appName('abc').getOrCreate()


# In[3]:


df=spark.read.csv('data/foo.csv',header=True)


# In[4]:


from optimus import Optimus
op = Optimus(spark)


# In[5]:


df.table()