Re: [TP4 Benchmarking] Pipes vs. Single-Threaded RxJava vs. Multi-Threaded RxJava

2019-04-10 Thread Marko Rodriguez
Hello, > I hadn't put together that each compilation could have its own processor. > Very cool. Yea. This is an important aspect of TP4. We do something similar in TP3, it is just not so overt — and its not configurable. In TP3, for example, SparkGraphComputer uses Spark to do “global traversal

Re: [TP4 Benchmarking] Pipes vs. Single-Threaded RxJava vs. Multi-Threaded RxJava

2019-04-09 Thread Ted Wilmes
I hadn't put together that each compilation could have its own processor. Very cool. Thanks for the benchmarking numbers. I had a tp3 inspired JMH-based module in progress when I saw your results so I added the two test traversals in. It doesn't do any parameterization of input sizes at this point

[TP4 Benchmarking] Pipes vs. Single-Threaded RxJava vs. Multi-Threaded RxJava

2019-04-08 Thread Marko Rodriguez
Hi, I implemented Multi-threaded RxJava this morning — its called ParallelRxJava. Single-threaded is called SerialRxJava. The RxJavaProcessor factory will generate either depending on the Map.of() configuration: https://github.com/apache/tinkerpop/blob/tp4/java/machine/processor/rxjav