Re: Adding Spark Context (sc) to predict method?

2017-10-06 Thread Shane Johnson
rocessed that I could access in the predict method. The problem with this is that new events would not influence the predictions as the combinedRDD would only be updated until the next retrain. Thank for your support. Shane *Shane Johnson | 801.360.3350* LinkedIn <https://www.linkedin.co

Re: Adding Spark Context (sc) to predict method?

2017-10-05 Thread Shane Johnson
> roundtrip time of involving Spark in your predict method might not be > feasible. (If you use `pio batchpredict` that could be an exception.) > > Regards, > Donald > > On Thu, Oct 5, 2017 at 3:59 PM, Shane Johnson < > shanewaldenjohn...@gmail.com> wrote: > >> Tha

Re: Adding Spark Context (sc) to predict method?

2017-10-05 Thread Shane Johnson
Thanks Daniel! I'll go look for that in the docs. On Thu, Oct 5, 2017 at 3:23 PM Shane Johnson wrote: > Thanks Daniel. I may be missing what you are saying. I actually think I > need the Spark Context for what I am trying to do. I am wanting to extend > the predict method to use

Re: Adding Spark Context (sc) to predict method?

2017-10-05 Thread Shane Johnson
Query. To do this I need to have a sc or I cannot get the properties from the EventStore. Does that make sense. If I remove the Spark Context it does indeed work but not for what I am trying to do. Thanks *Shane Johnson | 801.360.3350* LinkedIn <https://www.linkedin.com/in/shanewjohnson>

Re: Adding Spark Context (sc) to predict method?

2017-10-05 Thread Shane Johnson
Thanks Daniel. I had the P2Algorithm working before I had to query the EventStore within the predict method. Do you think this is still the issue with the context that I had it working before attempting to add the SparkContext? *Shane Johnson | 801.360.3350* LinkedIn <https://www.linkedin.com

Adding Spark Context (sc) to predict method?

2017-10-05 Thread Shane Johnson
e$] [error] one error found [INFO] [Engine$] [error] (compile:compileIncremental) Compilation failed [INFO] [Engine$] [error] Total time: 6 s, completed Oct 5, 2017 2:44:51 PM *Shane Johnson | 801.360.3350 <(801)%20360-3350>* LinkedIn <https://www.linkedin.com/in/shanewjohnson> | Facebook <https://www.facebook.com/shane.johnson.71653>

Re: Extracting Strings from JString with PEventStore.aggregateProperties

2017-10-03 Thread Shane Johnson
} Output: Opportunity(006J00RNvVYIA1,,75000.0,005J006a1Y1IAI,Closed,001 J01wndthIAA) Opportunity(006J00SQopgIAD,,14947.0,005J006a1Y1IAI,Closed,001 J01xjXi0IAE) *Shane Johnson | 801.360.3350* LinkedIn <https://www.linkedin.com/in/shanewjohnson> | Facebook <http

Extracting Strings from JString with PEventStore.aggregateProperties

2017-10-03 Thread Shane Johnson
,,75000.0,005J006a1Y1IAI,Closed,001 J01wndthIAA) Opportunity(006J00SQopgIAD,,14947.0,005J006a1Y1IAI,,001 J01xjXi0IAE) Thank you in advance for any advise or direction you can provide. Best, Shane Shane Johnson | 801.360.3350 <(801)%20360-3350> LinkedIn <https://www.linkedin.com/in/shanewjohnson> | Facebook <https://www.facebook.com/shane.johnson.71653>

Securing Event Server on Heroku?

2017-08-31 Thread Shane Johnson
predictions. Is there an add-on on Heroku or would it be necessary to extend the scala code to look for a secret key. I would prefer to not extend the scala and have authentication happen at the heroku level if possible. Thank you in advance! *Shane Johnson | 801.360.3350* LinkedIn <ht

Re: Passing an array of objects to get predictions?

2017-06-16 Thread Shane Johnson
direction? Happy to file a feature request. How do I get access to JIRA? Best, Shane *Shane Johnson | 801.360.3350* LinkedIn <https://www.linkedin.com/in/shanewjohnson> | Facebook <https://www.facebook.com/shane.johnson.71653> On Fri, Jun 16, 2017 at 10:10 AM, Donald Szeto wrote:

Passing an array of objects to get predictions?

2017-06-16 Thread Shane Johnson
n 2 at com.google.gson.internal.bind.ReflectiveTypeAdapterFactory$Adapter.read(ReflectiveTypeAdapterFactory.java:176) I expected to get the error but am hoping someone could point me in the right direction on where to extend the Scala code to interpret an Array of Objects into the Query object and then return multiple scores. Thanks in advance if anyone has worked on this. *Shane Johnson | 801.360.3350* LinkedIn <https://www.linkedin.com/in/shanewjohnson> | Facebook <https://www.facebook.com/shane.johnson.71653>

Re: pio train fails in Intelij - [Error] com.esotericsoftware.kryo.Kryo.setInstantiatorStrategy(Lorg/objenesis/strategy/InstantiatorStrategy;)V

2017-05-23 Thread Shane Johnson
Daniel, Thank you for your mentorship. I am using both of your methods - pio shell (:paste and :load) - ensime and I am cruising. I appreciate your help getting me past a roadblock and will continue developing with sublime! Thanks *Shane Johnson | 801.360.3350* LinkedIn <ht

Re: pio train fails in Intelij - [Error] com.esotericsoftware.kryo.Kryo.setInstantiatorStrategy(Lorg/objenesis/strategy/InstantiatorStrategy;)V

2017-05-22 Thread Shane Johnson
ew it when you run `pio build`. Your mentorship is very much appreciated. class TrainingData( val ratings: RDD[Rating] ) extends Serializable { override def toString = { s"ratings: [${ratings.count()}] (${ratings.take(2).toList}...)" } } *Shane Johnson | 801.360.3

pio train fails in Intelij - [Error] com.esotericsoftware.kryo.Kryo.setInstantiatorStrategy(Lorg/objenesis/strategy/InstantiatorStrategy;)V

2017-05-22 Thread Shane Johnson
DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:147) *Shane Johnson | 801.360.3350* LinkedIn <https://www.linkedin.com/in/shanewjohnson> | Facebook <https://www.facebook.com/shane.johnson.71653>

Re: 32 ERROR Storage$: Error initializing storage client for source PGSQL

2017-05-22 Thread Shane Johnson
gt; JInt(6)), 2014-09-09T16:17:42.937-08:00, 2014-09-10T13:12:04.937-08:00))) *Shane Johnson | 801.360.3350* LinkedIn <https://www.linkedin.com/in/shanewjohnson> | Facebook <https://www.facebook.com/shane.johnson.71653> On Mon, May 22, 2017 at 1:03 PM, Mars Hall wrote: > Shane,

Re: 32 ERROR Storage$: Error initializing storage client for source PGSQL

2017-05-20 Thread Shane Johnson
g the PIO shell with the Apache Spark Shell." # compute the $ASSEMPLY_JAR, the location of the assemply jar, with # bin/compute-classpath.sh . ${PIO_HOME}/bin/compute-classpath.sh shift $SPARK_HOME/bin/spark-shell --jars $ASSEMBLY_JAR $@ $PSQL_JAR *Shane Johnson | 801.360.3350 <

Re: 32 ERROR Storage$: Error initializing storage client for source PGSQL

2017-05-20 Thread Shane Johnson
ttps://issues.apache.org/jira/browse/PIO-72 > > *Mars > > ( <> .. <> ) > > > On May 20, 2017, at 09:43, Shane Johnson > wrote: > > > > Team, > > > > I am trying to follow the event modeling "MyTestApp" tutorial and am > havin