Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@cassandra.apache.org
Received-SPF: pass (nike.apache.org: domain of bburruss@real.com designates
 207.188.23.4 as permitted sender)
Message-ID: <4BA1022F.9050701@real.com>
Date: Wed, 17 Mar 2010 09:24:15 -0700
From: "B. Todd Burruss" <bburruss@real.com>
User-Agent: Thunderbird 2.0.0.23 (X11/20090817)
MIME-Version: 1.0
To: "user@cassandra.apache.org" <user@cassandra.apache.org>
Subject: Re: Dividing the client load between machines in Cassandra
References: <991ae7f81003161430r705a00fu85949dd1dd327f6@mail.gmail.com>
	 <e06563881003161448q6eee006akffff45b6b6b7d805@mail.gmail.com>
	 <4B9FFE45.4040709@real.com>
	 <e06563881003161507y31dc9265i8bf95fca40e9d08e@mail.gmail.com>
 <991ae7f81003161532i4913e247h742140aca95a5673@mail.gmail.com>
In-Reply-To: <991ae7f81003161532i4913e247h742140aca95a5673@mail.gmail.com>
Content-Type: text/plain; charset="ISO-8859-1"; format=flowed
Content-Transfer-Encoding: 7bit
Old-Return-Path: bburruss@real.com

below is the commented out code i once used.  i think it is from the 0.5 
days, so it might not even work now.  not sure.  the bootstrapHostArr is 
simply a list of host information used to bootstrap the process.  
connectToHost is a method used to generate a Cassandra.Client object.  
there is sample code on cassandra wiki for doing this.  good luck!

// can't use this on cassandra because the tokens returned are for the 
"internal cassandra server comm", not the thrift IPs
//        String    hostList = null;
//        for ( HostInfo hi : bootstrapHostArr ) {
//            Cassandra.Client    client = null;
//            try {
//                client = connectToHost( hi.getHostName(), hi.getPort() );
//                hostList = client.get_string_property( "token map" );
//                break;
//            }
//            catch ( TTransportException e ) {
//                logger.error( "cannot connect to bootstrap node - will 
try another if available : " + hi.getNameAndPort() );
//            }
//            catch ( TException e ) {
//                logger.error( "cannot retrieve host list from node - 
will try another if available : " + hi.getNameAndPort() );
//            }
//            finally {
//                if ( null != client ) {
//                    disconnectFromCluster( client );
//                }
//            }
//        }
//   
//        if ( null != hostList ) {           
//            ArrayList<String>    newArr;
//            try {
//                JSONObject    jsonObj = new JSONObject( hostList );
//                String[]    ringArr = JSONObject.getNames( jsonObj );
//                newArr = new ArrayList<String>( ringArr.length );
//               
//                for ( int i=0;i < ringArr.length;i++ ) {
//                    String    hostName = jsonObj.getString( ringArr[i] );
//                    if ( !hostIgnoreSet.contains(hostName) ) {
//                        newArr.add( hostName );
//                    }
//                }
//            }
//            catch ( JSONException e ) {
//                throw new ClusterRuntimeException( "Could not parse 
JSON returned from Cassandra - don't know what to do?  ARRRRGGGG" );
//            }


Sonny Heer wrote:
> Is there some example code on how to do this?
>
> On Tue, Mar 16, 2010 at 3:07 PM, Jonathan Ellis <jbellis@gmail.com> wrote:
>   
>> token map is an internal representation, so returning the internal IPs
>> is correct, even though this makes it slightly more difficult to use
>> for thrift clients.
>>
>> On Tue, Mar 16, 2010 at 4:55 PM, B. Todd Burruss <bburruss@real.com> wrote:
>>     
>>> if you choose #3 - get_string_property("token map") - keep in mind that the
>>> IPs returned from this call are the IPs used for "ListenAddress" param in
>>> storage-conf.xml.  In my case we have two NICs and I set this to be an IP
>>> that is only for "node to node" communication.  The "ThriftAddress" param is
>>> the one i really want.  maybe this has been changed, "fixed" ;), haven't
>>> tested in a while.
>>>
>>> Jonathan Ellis wrote:
>>>       
>>>> http://wiki.apache.org/cassandra/FAQ#node_clients_connect_to
>>>>
>>>> On Tue, Mar 16, 2010 at 4:30 PM, Sonny Heer <sonnyheer@gmail.com> wrote:
>>>>
>>>>         
>>>>> How can I accomplish this?
>>>>>
>>>>> The way I'm doing it now it is creating a TSocket connection using a
>>>>> static IP of one of the boxes on Cassandra:
>>>>>       TTransport tr = new TSocket(host, port.intValue());
>>>>>       TProtocol proto = new TBinaryProtocol(tr);
>>>>>       Cassandra.Client client = new Cassandra.Client(proto);
>>>>>       tr.open();
>>>>>
>>>>> With a larger cluster I would imagine there is another preferred
>>>>> solution with no single point of failure (e.g. that one box  goes
>>>>> down).
>>>>>
>>>>>
>>>>>