Examples of org.apache.pig.penny.Location.asLogical()

    
    private synchronized Tuple processRegistration(Message m) {
        // this method is synchronized to avoid concurrency problems between registering a new location and sending a message
        
        Location src = m.source();
        LogicalLocation logSrc = src.asLogical();
        
        if (!maxPhysicalIds.containsKey(logSrc)) {
            initLLState(logSrc);                    // first time we're seeing this logical location, so initialize some state for it
        }


        assert !synchronous: "We should not be sending synchronous requests from the coordinator";
        Location dst = message.destination();
        if (dst.isLogicalOnly()) {
            if (!maxPhysicalIds.containsKey(dst)) {
                initLLState(dst.asLogical());            // first time we're seeing this logical location, so initialize some state for it
            }
            
            // send to all currently registered physical instances of the logical destination
            for (int physId = 0; physId <= maxPhysicalIds.get(dst); physId++) {
                senderReceiver.sendAsync(message, new PhysicalLocation((LogicalLocation)dst, physId));

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.