Return-Path: Delivered-To: apmail-incubator-cassandra-commits-archive@minotaur.apache.org Received: (qmail 44621 invoked from network); 2 Mar 2009 23:34:52 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 2 Mar 2009 23:34:52 -0000 Received: (qmail 76973 invoked by uid 500); 2 Mar 2009 23:34:52 -0000 Delivered-To: apmail-incubator-cassandra-commits-archive@incubator.apache.org Received: (qmail 76964 invoked by uid 500); 2 Mar 2009 23:34:52 -0000 Mailing-List: contact cassandra-commits-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: cassandra-dev@incubator.apache.org Delivered-To: mailing list cassandra-commits@incubator.apache.org Received: (qmail 76953 invoked by uid 99); 2 Mar 2009 23:34:52 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Mar 2009 15:34:52 -0800 X-ASF-Spam-Status: No, hits=-1996.5 required=10.0 tests=ALL_TRUSTED,URIBL_BLACK X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 02 Mar 2009 23:34:41 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 9D4BE2388A1E; Mon, 2 Mar 2009 23:34:21 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r749477 - in /incubator/cassandra/trunk: build.xml src/org/apache/cassandra/service/StorageService.java src/org/apache/cassandra/test/DBTest.java src/org/apache/cassandra/test/TestRunner.java Date: Mon, 02 Mar 2009 23:34:21 -0000 To: cassandra-commits@incubator.apache.org From: pmalik@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20090302233421.9D4BE2388A1E@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: pmalik Date: Mon Mar 2 23:34:21 2009 New Revision: 749477 URL: http://svn.apache.org/viewvc?rev=749477&view=rev Log: Add build script and make sure it works Added: incubator/cassandra/trunk/build.xml Modified: incubator/cassandra/trunk/src/org/apache/cassandra/service/StorageService.java incubator/cassandra/trunk/src/org/apache/cassandra/test/DBTest.java incubator/cassandra/trunk/src/org/apache/cassandra/test/TestRunner.java Added: incubator/cassandra/trunk/build.xml URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/build.xml?rev=749477&view=auto ============================================================================== --- incubator/cassandra/trunk/build.xml (added) +++ incubator/cassandra/trunk/build.xml Mon Mar 2 23:34:21 2009 @@ -0,0 +1,133 @@ + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + Building Grammar ${build.src}/org/apache/cassandra/infrastructure/cli/Cli.g .... + + + + + + + + Building Grammar ${build.src}/org/apache/cassandra/infrastructure/cql/compiler/parse/Cql.g .... + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + Modified: incubator/cassandra/trunk/src/org/apache/cassandra/service/StorageService.java URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/org/apache/cassandra/service/StorageService.java?rev=749477&r1=749476&r2=749477&view=diff ============================================================================== --- incubator/cassandra/trunk/src/org/apache/cassandra/service/StorageService.java (original) +++ incubator/cassandra/trunk/src/org/apache/cassandra/service/StorageService.java Mon Mar 2 23:34:21 2009 @@ -70,11 +70,6 @@ import org.apache.cassandra.locator.RackAwareStrategy; import org.apache.cassandra.locator.RackUnawareStrategy; import org.apache.cassandra.locator.TokenMetadata; -import org.apache.cassandra.mapreduce.JobTracker; -import org.apache.cassandra.mapreduce.MapAssignmentVerbHandler; -import org.apache.cassandra.mapreduce.MapCompletionVerbHandler; -import org.apache.cassandra.mapreduce.ReduceAssignmentVerbHandler; -import org.apache.cassandra.mapreduce.TaskTracker; import org.apache.cassandra.net.CompactEndPointSerializationHelper; import org.apache.cassandra.net.EndPoint; import org.apache.cassandra.net.IVerbHandler; @@ -337,10 +332,6 @@ MessagingService.getMessagingInstance().registerVerbHandlers(StorageService.dataFileVerbHandler_, new DataFileVerbHandler() ); MessagingService.getMessagingInstance().registerVerbHandlers(StorageService.mbrshipCleanerVerbHandler_, new MembershipCleanerVerbHandler() ); MessagingService.getMessagingInstance().registerVerbHandlers(StorageService.bsMetadataVerbHandler_, new BootstrapMetadataVerbHandler() ); - MessagingService.getMessagingInstance().registerVerbHandlers(StorageService.jobConfigurationVerbHandler_, new JobTracker.JobConfigurationVerbHandler()); - MessagingService.getMessagingInstance().registerVerbHandlers(StorageService.mapAssignmentVerbHandler_, new MapAssignmentVerbHandler() ); - MessagingService.getMessagingInstance().registerVerbHandlers(StorageService.reduceAssignmentVerbHandler_, new ReduceAssignmentVerbHandler() ); - MessagingService.getMessagingInstance().registerVerbHandlers(StorageService.mapCompletionVerbHandler_, new MapCompletionVerbHandler() ); MessagingService.getMessagingInstance().registerVerbHandlers(StorageService.calloutDeployVerbHandler_, new CalloutDeployVerbHandler() ); MessagingService.getMessagingInstance().registerVerbHandlers(StorageService.touchVerbHandler_, new TouchVerbHandler()); @@ -517,12 +508,12 @@ // match (e.g. somehost.vip vs somehost.vip.domain.com) if ( DatabaseDescriptor.getJobTrackerAddress().equals( StorageService.tcpAddr_.getHost() ) ) { - JobTracker.instance().start(); - TaskTracker.instance().start(); +// JobTracker.instance().start(); +// TaskTracker.instance().start(); } else { - TaskTracker.instance().start(); +// TaskTracker.instance().start(); } } Modified: incubator/cassandra/trunk/src/org/apache/cassandra/test/DBTest.java URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/org/apache/cassandra/test/DBTest.java?rev=749477&r1=749476&r2=749477&view=diff ============================================================================== --- incubator/cassandra/trunk/src/org/apache/cassandra/test/DBTest.java (original) +++ incubator/cassandra/trunk/src/org/apache/cassandra/test/DBTest.java Mon Mar 2 23:34:21 2009 @@ -38,7 +38,6 @@ import org.apache.cassandra.io.IFileWriter; import org.apache.cassandra.io.SSTable; import org.apache.cassandra.io.SequenceFile; -import org.apache.cassandra.mapreduce.SequentialScanner; import org.apache.cassandra.net.EndPoint; import org.apache.cassandra.service.StorageService; import org.apache.cassandra.utils.BloomFilter; @@ -113,13 +112,14 @@ private static void doSequentialScannerTest() throws Throwable { - SequentialScanner scanner = new SequentialScanner("Mailbox"); +/* SequentialScanner scanner = new SequentialScanner("Mailbox"); while ( scanner.hasNext() ) { Row row = scanner.next(); System.out.println( row.getColumnFamily("Test") ); System.out.println( row.getColumnFamily("Test2") ); } + */ } public static void doTest() Modified: incubator/cassandra/trunk/src/org/apache/cassandra/test/TestRunner.java URL: http://svn.apache.org/viewvc/incubator/cassandra/trunk/src/org/apache/cassandra/test/TestRunner.java?rev=749477&r1=749476&r2=749477&view=diff ============================================================================== --- incubator/cassandra/trunk/src/org/apache/cassandra/test/TestRunner.java (original) +++ incubator/cassandra/trunk/src/org/apache/cassandra/test/TestRunner.java Mon Mar 2 23:34:21 2009 @@ -69,7 +69,6 @@ import org.apache.cassandra.io.DataOutputBuffer; import org.apache.cassandra.io.IFileWriter; import org.apache.cassandra.io.SequenceFile; -import org.apache.cassandra.mapreduce.SequentialScanner; import org.apache.cassandra.net.EndPoint; import org.apache.cassandra.net.IVerbHandler; import org.apache.cassandra.net.Message; @@ -257,7 +256,7 @@ public void run() { - try +/* try { SequentialScanner scanner = new SequentialScanner("Mailbox"); @@ -271,6 +270,7 @@ { ex.printStackTrace(); } + */ } }