You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2014/01/16 18:30:19 UTC
[23/51] [abbrv] git commit: Pruned old code. Created a new Connection
by downcasting the entity associated with the connection Changed the iterator
so that it will return ConnectionEntityRefImpl objects.
Pruned old code.
Created a new Connection by downcasting the entity associated with the connection
Changed the iterator so that it will return ConnectionEntityRefImpl objects.
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/2dde4ea4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/2dde4ea4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/2dde4ea4
Branch: refs/heads/two-dot-o
Commit: 2dde4ea4202084cf8444b3e6d4482dd9bcfc9e58
Parents: 4a28f6b
Author: GERey <gr...@apigee.com>
Authored: Wed Jan 15 13:09:39 2014 -0800
Committer: GERey <gr...@apigee.com>
Committed: Wed Jan 15 13:09:39 2014 -0800
----------------------------------------------------------------------
.../persistence/cassandra/RelationManagerImpl.java | 11 ++---------
1 file changed, 2 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/2dde4ea4/stack/core/src/main/java/org/usergrid/persistence/cassandra/RelationManagerImpl.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/usergrid/persistence/cassandra/RelationManagerImpl.java b/stack/core/src/main/java/org/usergrid/persistence/cassandra/RelationManagerImpl.java
index 4f565c7..da11ddd 100644
--- a/stack/core/src/main/java/org/usergrid/persistence/cassandra/RelationManagerImpl.java
+++ b/stack/core/src/main/java/org/usergrid/persistence/cassandra/RelationManagerImpl.java
@@ -1086,22 +1086,15 @@ public class RelationManagerImpl implements RelationManager {
PagingResultsIterator itr =
- new PagingResultsIterator( getConnectingEntities( headEntity, null, null, Level.REFS ) );
+ new PagingResultsIterator( getConnectedEntities(headEntity, null, null, Level.REFS) );
ConnectionRefImpl connection;
while ( itr.hasNext() ) {
- connection = ( ConnectionRefImpl ) itr.next();
+ connection = new ConnectionRefImpl( new SimpleEntityRef((EntityRef)itr.next()));
batchUpdateEntityConnection( batch, true, connection, timestampUuid );
}
- //
- // List<ConnectionRefImpl> connections = getConnectionsWithEntity(headEntity.getUuid());
- // if (connections != null) {
- // for (ConnectionRefImpl connection : connections) {
- // batchUpdateEntityConnection(batch, true, connection, timestampUuid);
- // }
- // }
}