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
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
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