data-keyvalue:1.0.1.RELEASE'
compile 'com.stratio.deep:deep-aerospike:0.8.0'
compile 'org.apache.spark:spark-sql_2.11:1.4.1'
compile 'org.apache.spark:spark-mllib_2.11:1.4.1'
testCompile('org.springframework.boot:spring-boot-starter-test')
tes
vePush(PushAnalysisService.java:99)
>at
> com.matchinguu.analytiher.service.WeatherPushContractsGenerator.computePushContracts(WeatherPushContractsGenerator.java:193)
>at
> com.matchinguu.analytics.weather.service.WeatherAnalyzer.finalize(WeatherAnalyzer.java:49)
>
Even If I m using this query then also give NullPointerException:
"SELECT clientId FROM activePush"
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Issue-wihle-applying-filters-conditions-in-DataFrame-in-Spark-tp26560p26562.html
Sent from the Ap
6-03-22 13:40:15.613] boot - 10493 INFO [Thread-3] --- Utils: Shutdown
hook called
[2016-03-22 13:40:15.614] boot - 10493 INFO [Thread-3] --- Utils: Deleting
directory /tmp/spark-4c3f436a-dd1f-423f-b353-80ae8f34fdde
--
View this message in context:
http://apache-spark-user-list.1001560.n3
pplication.run(SpringApplication.java:322)
>
> springframework.boot.SpringApplication.run(SpringApplication.java:970)
> at
> org.springframework.boot.SpringApplication.run(SpringApplication.java:959)
> at
>
> com.matchinguu.analytics.AnalyticalEngineApplication.main(Analyt
e me that how to apply where clause conditions/filters in
DataFrame? I have also a plan to create multiple DataFrames and to apply
JOIN operation between them, it will be good if u give me some good examples
about it.
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/
