Thanks.
Also you may want to update the
bank.registerTempTable("bank")
to
bank.createOrReplaceTempView("bank")
in the spark tutorial.
The first method has been deprecated.
Your example is really great because it shows data ingestion over the
internet.
One really gets a very good idea of latency.
On Mon, 30 Mar 2020, 08:29 Jeff Zhang, <zjf...@gmail.com> wrote:
> type tab will enable code completion
>
> Som Lima <somplastic...@gmail.com> 于2020年3月30日周一 下午3:14写道：
>
>> Hi,
>>
>> As you can see I have my own spark session.
>> Can you please tell me how to turn own code completion.
>> I did have it working for a while, I am not sure which setting it was.
>> Thank you.
>>
>>
>>
>> mport org.apache.spark.sql.SparkSession
>> sc.stop()
>>
>> val spark = SparkSession.builder().master("spark://192.168.0.38:7077
>> ").appName("Spark Session Test app ").getOrCreate();
>>
>> println("SparkContext:")
>> println("APP Name :"+spark.sparkContext.appName);
>> println("Deploy Mode :"+spark.sparkContext.deployMode);
>> println("Master :"+spark.sparkContext.master);
>>
>> SparkContext: APP Name :Spark Session Test app Deploy Mode :client Master
>> :spark://192.168.0.38:7077 import org.apache.spark.sql.SparkSession spark
>> : org.apache.spark.sql.SparkSession =
>> org.apache.spark.sql.SparkSession@2e4f355f
>>
>> spark
>> res5: org.apache.spark.sql.SparkSession =
>> org.apache.spark.sql.SparkSession@2e4f355f
>>
>>
>
> --
> Best Regards
>
> Jeff Zhang
>
