add

hello.py

-from __future__ import absolute_import
-from __future__ import division
-from __future__ import print_function
-from pyspark.streaming.kafka import KafkaUtils
-from pyspark import SparkContext
-from pyspark.sql import SQLContext
-from pyspark.streaming import StreamingContext
-from pyspark import SparkConf
-import json
-import msgpack
 import pymysql
-import smtplib
-from email.mime.text import MIMEText
-from email.utils import formataddr
-from email.mime.multipart import MIMEMultipart
-from email.mime.application import MIMEApplication
-import redis
+from pyspark.conf import SparkConf
+import pytispark.pytispark as pti
+from pyspark.sql import SparkSession
 import datetime
+import pandas as pd
+import time
+from pyspark import StorageLevel
 
 
 def ctr(x):