List of makeKey() Examples

Examples of makeKey()

com.springsource.insight.intercept.endpoint.EndPointName.makeKey()
com.thinkaurelius.titan.core.DefaultTypeMaker.makeKey()
Creates a new property key with default settings against the provided {@link KeyMaker}. @param factory TypeMaker through which the property key is created @return A new property key for the given name @throws IllegalArgumentException if the name is already in use or if other configured values are invalid.
com.thinkaurelius.titan.core.TitanGraph.makeKey()
Returns a {@link KeyMaker} instance to define a new {@link TitanKey} with the given name.By defining types explicitly (rather than implicitly through usage) one can control various aspects of the key and associated consistency constraints.
@return a {@link KeyMaker} instance @see KeyMaker @see TitanKey
com.thinkaurelius.titan.core.TitanTransaction.makeKey()
Returns a {@link KeyMaker} instance to define a new {@link TitanKey} with the given name.By defining types explicitly (rather than implicitly through usage) one can control various aspects of the key and associated consistency constraints.
The key constructed with this maker will be created in the context of this transaction. @return a {@link KeyMaker} linked to this transaction. @see KeyMaker @see TitanKey
com.thinkaurelius.titan.graphdb.blueprints.TitanBlueprintsGraph.makeKey()
com.thinkaurelius.titan.graphdb.database.StandardTitanGraph.makeKey()
gnu.javax.crypto.cipher.DES.makeKey()
net.windwards.dnsfrontend.api.Backend.makeKey()
org.lab41.dendrite.metagraph.DendriteGraph.makeKey()
org.lab41.dendrite.metagraph.DendriteGraphTx.makeKey()
voldemort.store.slop.Slop.makeKey()

Examples of voldemort.store.slop.Slop.makeKey()

                assertEquals("entry value should match", 0, store.get(nextSlop.getKey(), null)
                                                                 .size());
            }


            // did it get deleted correctly
            assertEquals("slop should have gone", 0, slopStoreNode0.get(nextSlop.makeKey(), null)
                                                                   .size());
        }


        entryIterator = entrySet1.listIterator();
        while(entryIterator.hasNext()) {

View Full Code Here

Examples of voldemort.store.slop.Slop.makeKey()

        entryIterator = entrySet1.listIterator();
        while(entryIterator.hasNext()) {
            Versioned<Slop> versionedSlop = entryIterator.next();
            Slop nextSlop = versionedSlop.getValue();
            // did it get deleted correctly
            assertNotSame("slop should be there", 0, slopStoreNode0.get(nextSlop.makeKey(), null)
                                                                   .size());
        }


        // Check counts
        SlopStorageEngine slopEngine = getVoldemortServer(0).getStoreRepository().getSlopStore();

View Full Code Here

Examples of voldemort.store.slop.Slop.makeKey()

                assertEquals("entry value should match", 0, store.get(nextSlop.getKey(), null)
                                                                 .size());
            }


            // did it get deleted correctly
            assertEquals("slop should have gone", 0, slopStoreNode0.get(nextSlop.makeKey(), null)
                                                                   .size());
        }


    }
}

View Full Code Here

Examples of voldemort.store.slop.Slop.makeKey()

                             value.getValue(),
                             null,
                             failedNodeId,
                             new Date());


        ByteArray slopKey = slop.makeKey();
        Versioned<byte[]> slopValue = new Versioned<byte[]>(slopSerializer.toBytes(slop),
                                                            value.getVersion());


        Node failedNode = adminClient.getAdminClientCluster().getNodeById(failedNodeId);
        HandoffToAnyStrategy slopRoutingStrategy = new HandoffToAnyStrategy(adminClient.getAdminClientCluster(),

View Full Code Here

Examples of voldemort.store.slop.Slop.makeKey()

                            } else {
                                logger.error("Unknown slop operation: " + slop.getOperation());
                                continue;
                            }
                            failureDetector.recordSuccess(node, deltaMs(startNs));
                            slopStore.delete(slop.makeKey(), versioned.getVersion());


                            slopsPushed++;
                            // Increment succeeded
                            Long succeeded = succeededByNode.get(nodeId);
                            succeededByNode.put(nodeId, succeeded + 1L);

View Full Code Here

Examples of voldemort.store.slop.Slop.makeKey()

                            throttler.maybeThrottle(nBytes);


                        } catch(ObsoleteVersionException e) {


                            // okay it is old, just delete it
                            slopStore.delete(slop.makeKey(), versioned.getVersion());
                            slopsPushed++;


                            // Increment succeeded
                            Long succeeded = succeededByNode.get(nodeId);
                            succeededByNode.put(nodeId, succeeded + 1L);

View Full Code Here

Examples of voldemort.store.slop.Slop.makeKey()

                for(Integer destinationNodeId: vservers.keySet()) {
                    if(!destinationNodeId.equals(slopHostId)) {
                        ByteArray key = generateRandomKey(cluster, destinationNodeId, storeDef.getReplicationFactor());
                        serverKeys.get(destinationNodeId).add(new Pair<ByteArray, Integer>(key, slopHostId));
                        Slop slop = new Slop(storeDef.getName(), Slop.Operation.PUT, key.get(), key.get(), destinationNodeId, new Date());
                        slopStore.put(slop.makeKey(), new Versioned<byte[]>(slopSerializer.toBytes(slop), new VectorClock()), null);
                    }
                }
            }
        }

View Full Code Here

Examples of voldemort.store.slop.Slop.makeKey()

                for(Integer destinationNodeId: vservers.keySet()) {
                    if(!destinationNodeId.equals(slopHostId)) {
                        ByteArray key = generateRandomKey(cluster, destinationNodeId, storeDef.getReplicationFactor());
                        serverKeys.get(destinationNodeId).add(new Pair<ByteArray, Integer>(key, slopHostId));
                        Slop slop = new Slop(storeDef.getName(), Slop.Operation.PUT, key.get(), key.get(), destinationNodeId, new Date());
                        slopStore.put(slop.makeKey(), new Versioned<byte[]>(slopSerializer.toBytes(slop), new VectorClock()), null);
                    }
                }
            }
        }

View Full Code Here

0 1 2 3 4

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.