From cf56f8f3acbeac0ddff9ee3131ad7abe2a919ba3 Mon Sep 17 00:00:00 2001 From: Prashant Malik Date: Mon, 2 Mar 2009 23:34:21 +0000 Subject: [PATCH] Add build script and make sure it works git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@749477 13f79535-47bb-0310-9956-ffa450edef68 --- build.xml | 133 ++++++++++++++++++ .../cassandra/service/StorageService.java | 15 +- src/org/apache/cassandra/test/DBTest.java | 4 +- src/org/apache/cassandra/test/TestRunner.java | 4 +- 4 files changed, 140 insertions(+), 16 deletions(-) create mode 100644 build.xml diff --git a/build.xml b/build.xml new file mode 100644 index 0000000000..f396668f9f --- /dev/null +++ b/build.xml @@ -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 .... + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + diff --git a/src/org/apache/cassandra/service/StorageService.java b/src/org/apache/cassandra/service/StorageService.java index 10fe532cbe..aee3c46b6f 100644 --- a/src/org/apache/cassandra/service/StorageService.java +++ b/src/org/apache/cassandra/service/StorageService.java @@ -70,11 +70,6 @@ import org.apache.cassandra.locator.IReplicaPlacementStrategy; 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 @@ public final class StorageService implements IEndPointStateChangeSubscriber, Sto 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 @@ public final class StorageService implements IEndPointStateChangeSubscriber, Sto // 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(); } } diff --git a/src/org/apache/cassandra/test/DBTest.java b/src/org/apache/cassandra/test/DBTest.java index 3ba8eb9206..2cb579df80 100644 --- a/src/org/apache/cassandra/test/DBTest.java +++ b/src/org/apache/cassandra/test/DBTest.java @@ -38,7 +38,6 @@ import org.apache.cassandra.io.IFileReader; 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 @@ public class DBTest 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() diff --git a/src/org/apache/cassandra/test/TestRunner.java b/src/org/apache/cassandra/test/TestRunner.java index 9736a9a2a9..a09683439c 100644 --- a/src/org/apache/cassandra/test/TestRunner.java +++ b/src/org/apache/cassandra/test/TestRunner.java @@ -69,7 +69,6 @@ import org.apache.cassandra.io.DataInputBuffer; 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 @@ class Scanner implements Runnable public void run() { - try +/* try { SequentialScanner scanner = new SequentialScanner("Mailbox"); @@ -271,6 +270,7 @@ class Scanner implements Runnable { ex.printStackTrace(); } + */ } }