Added dictionary for per_affiliate, per_awards, per_place, and per_time.
Added dictionaries per_causeOfDeath and per_title. Updated per_founderof.
Inject SparkContext to Pipeline.
Collect SparkContext and its configs at SparkIntegrator.
Fixed error on could not bind to port: Caused by: org.jboss.netty.channel.ChannelException: Failed to bind to: /10.136.72.0:35570
Spark integration works, no more memory issues. We get tons of Triples out of StreamItems and their content\!
Update README.md
s
Fix merge.
Added dictionary for per_affiliate, per_awards, per_place, and per_time.
Inject SparkContext to Pipeline.
Collect SparkContext and its configs at SparkIntegrator.
Test run new redesigned Faucet.
Fixed error on could not bind to port: Caused by: org.jboss.netty.channel.ChannelException: Failed to bind to: /10.136.72.0:35570
Spark integration works, no more memory issues. We get tons of Triples out of StreamItems and their content\!
Fix merge.
Fixing merge.
Update Faucet.scala
Final fix merge.