GroupStep work... Moving to another branch so committing what I had left after
from last week.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/b6da5e98
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/b6da5
gremlin-python/ now uses gremlin-tinkergraph-test/ AbstractTinkerGraphProvider
for PythonProvider. So much duplicated code has gone down the drain cause of
AbstarctTinkerGraphProvider. Classy.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/re
So much. withProcessor(Processor). No more Compute. Process.submit(Graph) as we
are now staging it so that every Processor (GraphComputer/GraphAgents) can work
over any Graph. This will all be via Partitioner. withComputer() deprecated.
Lots of cool stuff with Process strategies -- ProcessorTrav
can't really get my head around the best way to do partition attachment
keep playing with different models... each have their problems. Minor commit
with Partitioner.getPartition(Element) to Partition.find(Element).
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http
trivial tweaks. going to take a break.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/d74ee61c
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/d74ee61c
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpo
came up with a much cleaner GiraphGraphComputer usage around workers.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/a170ad97
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/a170ad97
Diff: http://git-wip-u
added a GraphComputerTest that ensures that the GraphComputer configuration
evolves as expected and that it does not alter the Graph configuration.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/517ad3e7
Tree: http:/
added the @dkuppitz example to the AkkaGraphActors test/ package for playing
and benchmarking.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/065bcfb3
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/065bc
okay, more tests exposed. The final issue is nested
group().groupCount().select(keys) style traversals. I believe I have attachment
covered in this situation, but obviously not. I'm blasted done for the day.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-w
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/6353595e/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/computer/GraphComputerTest.java
--
diff --git
a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin
opened up more test cases to AkkaGraphActors. A few that fail don't make sense
too me...but very close to the entire test suite passing.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/696888d7
Tree: http://git-wip-us
Integration tests fully passing now on this brach. There is a problem
(generally outside of this branch) with one of @dkuppitz recent tests to
GraphComputerTest around VertexProgram requirements. Depending on test
execution order, it can fail or succeeed.
Project: http://git-wip-us.apache.org/
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/a3eb72a4/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/actor/ActorProgram.java
--
diff --git
a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process
sync'd master with GraphActors branch. New tests are failing cause of
ProjectedTraverser. Will fix after lunch.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/76eb3d10
Tree: http://git-wip-us.apache.org/repos/asf/tin
added graphNotSupported coverage to GraphComputerTest. Added JavaDocs here and
there while I was waiting for the test suite to complete.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/46ef7669
Tree: http://git-wip-us
I was able to get another test case to pass with akka-gremlin/ --- the problem
was successive cap('a')s were building up successively larger side-effect
values.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/59f9030
small nothing.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/37605ff2
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/37605ff2
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/37605ff2
Branch:
refactored GraphActors packaging -- its not actor/, but actors/. JavaDoc and
various cleanups. Also, about to NOT serialize a traversal but instead use
Bytecode. Next push will do this with TraveraslVertexProgram.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git
revert to master/ representation of GroupStep. TINKERPOP-1590 has the clone
safe model.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/0ccb424b
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/0ccb424b
Dif
HashPartitioner requires a positive hashCode() value. Thus, wrapped calls in
Math.abs().
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/2b36074e
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/2b36074e
Di
Added AkkaConfigFactory which deals with creating an Akka Config. Identical in
nature to SparkConf and Hadoop's Configuration. Akka GryoSerializer pimp'd up a
bit. I had a default pool size of 256. Test cases were slow. Changed to 1 --
BOOMIN fast. Wonder what the nature of serializer reuse is i
more organization and cleaning and learning next up Host and Proxy.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/c69b6c05
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/c69b6c05
Diff: http://git-wip
GryoVersion.3_0 ... epic. @spmallette making my life easy. OrderedTraverser
registered and private no-arg constructor added. More
AkkaActorsProcessActorsTest cases passing. The only ones that are failing have
to do with GroupStep.GroupBiOperator. So lost as to why its a problem. :|
Project: ht
wow. found a bug in my OrderGlobalStep work in the lastest PR that only shows
up in GraphActors.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/9ebdd0d2
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/9eb
finally figured out what is wrong with GroupStep. Just sending over the Barrier
object -- no need to send over the whole traversal during serialization. Phew.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/0c3f6c63
T
Was able to open up a bunch more test cases to AkkaGraphActors. There are a few
that are still busted -- and I believe these are related to nested collections
and complexities with attachment of elements in the collections.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit:
commited to g.withProcessor(Processor.Description). Actors and Computer
implement Processor.Description. Following the VertexProgramStrategy model,
this makes it easy for language variant providers to support any arbitrary
Processor down the line.
Project: http://git-wip-us.apache.org/repos/as
We now have PartitionInputFormat which allows an Hadoop-based GraphComputer to
pull data from any Graph implementation. PartitionInputSplit is basically a
wrapper around Partition so that data access is data-local and thus, for
distributed Graph databases, it will simply Partition.vertices() and
okay. so I created ProcessActorsSuite and our first actors specific test --
GraphActorsTest (currently just makes sure toString() is valid :). Really
organizing things around Configuration... Just like Graphs, Computers and
Actors are defined by Configurations.
Project: http://git-wip-us.apach
OrderedTraverser needs a equals() and hashCode().
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/3ac4f3d6
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/3ac4f3d6
Diff: http://git-wip-us.apache.org/repos/a
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 6c8517d92 -> 74cedc439 (forced update)
starting to fill out GraphActorsTest (like GraphComputerTest). Tweaks to
AkkaConfigFactory for default 'local' settings.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Com
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 15a122c30 -> 6c8517d92
figured out I was setting the resultant traverals side-effects. fixed that up
and now the SideEffectTest travesals pass. So close to all tests passing for
GraphActors.
Project: http://git-wip-us.apache.
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 1c4f6f547 -> 15a122c30
solved my actors race conditition from Friday. I had it such that the master
actor was not part of the termination token ring which was bad. Given that the
master actor does send traversers, it should be
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 f76d5a98e -> 1c4f6f547
what I thought was a fix to my cap().cap() bug was not. race condition where
the second cap() is pulling data before the first cap() fininshes. Has to do
with the order in which messages are received by w
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 23e1b7fe8 -> f76d5a98e
I was able to get another test case to pass with akka-gremlin/ --- the problem
was successive cap('a')s were building up successively larger side-effect
values.
Project: http://git-wip-us.apache.org/rep
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 fc5d93c01 -> 23e1b7fe8
gremlin-python/ now uses gremlin-tinkergraph-test/ AbstractTinkerGraphProvider
for PythonProvider. So much duplicated code has gone down the drain cause of
AbstarctTinkerGraphProvider. Classy.
Project:
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 9349612e8 -> fc5d93c01
Created a new gremlin-tools/ packaged called gremlin-tinkergraph-test/ which
includes an AbstractTinkerGraphProvider to allow providers to more easily
leverage TinkerGraph in their testing. Both spark-gre
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 8b2dcb053 -> 9349612e8
Have SparkGraphComputer integration test over TinkerGraph with HashPartitioner.
All tests pass. BAM. Tomorrow I'm going to create
TinkerGraphPartitionerProvider in tinkergraph-gremlin/ so it can be reused
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 6b6df35d0 -> 8b2dcb053
okay, more tests exposed. The final issue is nested
group().groupCount().select(keys) style traversals. I believe I have attachment
covered in this situation, but obviously not. I'm blasted done for t
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 a2dbe7b0b -> 6b6df35d0
got LocalBarriers with SideEffects working in GraphActors. There are only 3
tests that fail -- having to do with nested group().groupCount()-style things.
Almost done.
Project: http://git-wip-us.apache.
refactored GraphActors packaging -- its not actor/, but actors/. JavaDoc and
various cleanups. Also, about to NOT serialize a traversal but instead use
Bytecode. Next push will do this with TraveraslVertexProgram.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git
revert to master/ representation of GroupStep. TINKERPOP-1590 has the clone
safe model.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/16282914
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/16282914
Dif
okay, so I now have the GryoMapper classes programmically loaded in the
ActorSystem serialiation-bindings. This is slick. We are almost there. Done for
the night. That was a 13 hour day.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/as
added a GraphComputerTest that ensures that the GraphComputer configuration
evolves as expected and that it does not alter the Graph configuration.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/55919886
Tree: http:/
okay. so I created ProcessActorsSuite and our first actors specific test --
GraphActorsTest (currently just makes sure toString() is valid :). Really
organizing things around Configuration... Just like Graphs, Computers and
Actors are defined by Configurations.
Project: http://git-wip-us.apach
added GraphActorsHelper which will configure a GraphActors via its fluent
interface via a provided Configuration. Added a new GraphActorsTest that
ensures worker counts are correct.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tin
ahhh.. a really solid simplification using the Terminate token as the barrier
synchronizer. Lots of other little random clean me ups. Things are looking
brighter at close of business.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/t
GroupStep work... Moving to another branch so committing what I had left after
from last week.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/af5a6f6e
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/af5a6
GryoVersion.3_0 ... epic. @spmallette making my life easy. OrderedTraverser
registered and private no-arg constructor added. More
AkkaActorsProcessActorsTest cases passing. The only ones that are failing have
to do with GroupStep.GroupBiOperator. So lost as to why its a problem. :|
Project: ht
I have Master/Worker serialization working fully now. Prior to this moment, the
master was sent to an Akka server and then it executed its workers locally. Now
the workers are distributed to where their physical Partition is. Furthermore,
ActorProgams are fully serializable via apache.commons.Co
more alignment between GraphActors and GraphComputer.
GraphActors.partitioner().program().submit(). Unlike GraphComputer, there is no
Graph.actors(). HOWEVER -- since GraphActors is Partition-centric, perhaps we
do Graph.partitioner().actors(). eek. hehe..
Project: http://git-wip-us.apache.org
every ActorSystem needs a unique system name. Thus, every GraphActors submit()
needs it. Added UUID creation.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/46a6a3b8
Tree: http://git-wip-us.apache.org/repos/asf/tinke
small nothing.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/ad0f094f
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/ad0f094f
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/ad0f094f
Branch:
OMG. That was a 3+ hour bug. The bug was not in Actors, but in GroupStep
cloning So painful. Renamed Actors to GraphActors so its like
GraphComputer. Renamed ActorStep to TraversalActorProgramStep so its like
TraversalVertexProgramStep. Next up, get rid of GraphComputing and add
PushBased a
added OrderedTraverser to Gryo registration listing Crap, prolly means I
need to do it for GraphSON too...
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/2aa1dc3b
Tree: http://git-wip-us.apache.org/repos/asf/tink
can't really get my head around the best way to do partition attachment
keep playing with different models... each have their problems. Minor commit
with Partitioner.getPartition(Element) to Partition.find(Element).
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http
commited to g.withProcessor(Processor.Description). Actors and Computer
implement Processor.Description. Following the VertexProgramStrategy model,
this makes it easy for language variant providers to support any arbitrary
Processor down the line.
Project: http://git-wip-us.apache.org/repos/as
taking a lunch break --- added more JavaDoc and started honing in on how
withProcessor() will generalize... sorta tricky.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/3bf924b4
Tree: http://git-wip-us.apache.org/rep
through hell and back to get IoRegistries loaded into Akka GryoSerializer.
Phew. Learned a bunch about Akka Config.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/4463d865
Tree: http://git-wip-us.apache.org/repos/asf
We now have PartitionInputFormat which allows an Hadoop-based GraphComputer to
pull data from any Graph implementation. PartitionInputSplit is basically a
wrapper around Partition so that data access is data-local and thus, for
distributed Graph databases, it will simply Partition.vertices() and
smarter distribution of initial GraphStep traversers.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/bd9d0477
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/bd9d0477
Diff: http://git-wip-us.apache.org/rep
HashPartitioner requires a positive hashCode() value. Thus, wrapped calls in
Math.abs().
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/ea577f20
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/ea577f20
Di
We now have AkkaGraphActors configured fully via our Configuration model --
graph.configuration(), actorProgram.configuration(), etc... Generates
appropriate Config for Akka and we are off to the races. More work on Host.
I have some good ideas here... didn't have time to get to it today.
OrderedTraverser needs a equals() and hashCode().
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/61f73b2e
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/61f73b2e
Diff: http://git-wip-us.apache.org/repos/a
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 bc61e6a72 -> a2dbe7b0b (forced update)
more organization and cleaning and learning next up Host and Proxy.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinker
starting to fill out GraphActorsTest (like GraphComputerTest). Tweaks to
AkkaConfigFactory for default 'local' settings.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/48d860f3
Tree: http://git-wip-us.apache.org/repo
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/243ab6a7/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/actors/GraphActors.java
--
diff --git
a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process
Created AkkaGremlinPlugin so you can import akka-gremlin into GremlinConsole
(and GremlinServer--not sure). The concept of an Actor Address now has to
identifies -- the physical location of the actor and the unique (provider
specific) guid of the actor. By knowing the physical location and knowi
got new GraphComputer.configuration() model working for SparkGraphComputer and
GiraphGraphComputer.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/eaf95a5e
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/
what a day. So I have Akka remoting working (not fully). We now have
akka.io.GryoSerializer :). And TraversalActorProgram is smart about detach()
and attach(). Learned a bunch about how to do Partitioner/Partitions in
TinkerPop stuff is coming along nicely. Need a break though...been coding
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/243ab6a7/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/actor/ActorProgram.java
--
diff --git
a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process
added Pushing and Distributing which are currently the two constructs of
GraphComputing. GraphComputing is now deprecated with its corresponding methods
calling the respective Pushing/Distributing methods. Pushing means the step is
using push-based semantics. Distributing means that the step mus
So much. withProcessor(Processor). No more Compute. Process.submit(Graph) as we
are now staging it so that every Processor (GraphComputer/GraphAgents) can work
over any Graph. This will all be via Partitioner. withComputer() deprecated.
Lots of cool stuff with Process strategies -- ProcessorTrav
finally figured out what is wrong with GroupStep. Just sending over the Barrier
object -- no need to send over the whole traversal during serialization. Phew.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/6c212c31
T
came up with a clever idea for maintaining order in a distributed traversal.
OrdereredTraverser is a wrapper around a Traverser where all methods are
delegated to the internal traverser. However, OrderedTraverser has an order()
method which returns an int. This allows an ordered stream of traver
trivial tweaks. going to take a break.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/50367dd2
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/50367dd2
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpo
opened up more test cases to AkkaGraphActors. A few that fail don't make sense
too me...but very close to the entire test suite passing.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/2cd936a3
Tree: http://git-wip-us
Added AkkaConfigFactory which deals with creating an Akka Config. Identical in
nature to SparkConf and Hadoop's Configuration. Akka GryoSerializer pimp'd up a
bit. I had a default pool size of 256. Test cases were slow. Changed to 1 --
BOOMIN fast. Wonder what the nature of serializer reuse is i
Was able to open up a bunch more test cases to AkkaGraphActors. There are a few
that are still busted -- and I believe these are related to nested collections
and complexities with attachment of elements in the collections.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit:
Tweaks to SparkGraphComputer configuration settings. More GraphComputerTest
things. Before the break, I want to have Configuration all stubbed out for
GraphComputer and GraphActors and then this branch is simply a function of
testing GraphActors at scale when we return.
Project: http://git-wip
trying to surpress the logging during testing, but I'm clueles.. Need
@spmallette help.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/49a028e2
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/49a028e2
Dif
having to redesign our concept of Attachable.attach() and detach().
@spmallette's Host interface now has a default method of Host.attach(t).
Moreover, Traverser now has Traverser.attach(Host). Vertex extends Host. Graph
extends Host... and now Partition extends Host. Instead of leaving the logic
lots of cleanup and organization of the interfaces. trying to line up the
GraphActors interfaces as much as possible with GraphComputer interfaces.
JavaDoc'in.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/3a4bda98
added the @dkuppitz example to the AkkaGraphActors test/ package for playing
and benchmarking.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/a65b0bdc
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/a65b0
added StringFactory rules for GraphActors, Partitioner, and Partition. Realized
someting profoundly sucky about DedupGlobalStep. Exposed more test cases to
AkkaGraphActors.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/co
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/67849635/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/computer/GraphComputerTest.java
--
diff --git
a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin
learned about preStart() and postStop() methods in Akka Actors. Lined those up
with actor.terminate() and actor.setup(). JavaDoc here and there nada much.
done for the night.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinker
came up with a much cleaner GiraphGraphComputer usage around workers.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/47a3c5c5
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/47a3c5c5
Diff: http://git-wip-u
split up start and terminate messages.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/aa0ae03a
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/aa0ae03a
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpo
added graphNotSupported coverage to GraphComputerTest. Added JavaDocs here and
there while I was waiting for the test suite to complete.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/9852a60e
Tree: http://git-wip-us
Repository: tinkerpop
Updated Branches:
refs/heads/master 1bc66ab06 -> bfe432eb8
introduced a minor bug into CollectingBarrierStep that would only be noticed by
asynchrnous traversal execution engines. I noticed it in the GraphActors
branch. Also, added a toString() to ProjectedTraverser. CTR
Merge branch 'tp32'
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/bfe432eb
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/bfe432eb
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/bfe432eb
Br
Repository: tinkerpop
Updated Branches:
refs/heads/tp32 600229992 -> 8ad291134
introduced a minor bug into CollectingBarrierStep that would only be noticed by
asynchrnous traversal execution engines. I noticed it in the GraphActors
branch. Also, added a toString() to ProjectedTraverser. CTR.
Repository: tinkerpop
Updated Branches:
refs/heads/TINKERPOP-1564 80adc4273 -> bc61e6a72
wow. found a bug in my OrderGlobalStep work in the lastest PR that only shows
up in GraphActors.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/
what a day. So I have Akka remoting working (not fully). We now have
akka.io.GryoSerializer :). And TraversalActorProgram is smart about detach()
and attach(). Learned a bunch about how to do Partitioner/Partitions in
TinkerPop stuff is coming along nicely. Need a break though...been coding
Added AkkaConfigFactory which deals with creating an Akka Config. Identical in
nature to SparkConf and Hadoop's Configuration. Akka GryoSerializer pimp'd up a
bit. I had a default pool size of 256. Test cases were slow. Changed to 1 --
BOOMIN fast. Wonder what the nature of serializer reuse is i
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/825f5156/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin/process/computer/GraphComputerTest.java
--
diff --git
a/gremlin-test/src/main/java/org/apache/tinkerpop/gremlin
refactored GraphActors packaging -- its not actor/, but actors/. JavaDoc and
various cleanups. Also, about to NOT serialize a traversal but instead use
Bytecode. Next push will do this with TraveraslVertexProgram.
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git
Tweaks to SparkGraphComputer configuration settings. More GraphComputerTest
things. Before the break, I want to have Configuration all stubbed out for
GraphComputer and GraphActors and then this branch is simply a function of
testing GraphActors at scale when we return.
Project: http://git-wip
HashPartitioner requires a positive hashCode() value. Thus, wrapped calls in
Math.abs().
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/63f5c0f2
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/63f5c0f2
Di
1001 - 1100 of 3150 matches
Mail list logo