Project structure changed, reflecting cascading.* modules.

Author: Daniel Kunnath

.gitignore

@@ -0,0 +1,8 @@
+build.properties
+.DS_Store
+build
+.idea/**/*
+*.iml
+*.iws
+*.ipr
+out

build.xml

@@ -1,4 +1,4 @@
-package com.gameattain.dpa;
+package cascading.mongodb;
 
 import org.apache.hadoop.mapreduce.*;
 
@@ -10,6 +10,7 @@
  */
 public class MongoDBOutputFormat extends OutputFormat
 {
+    public static final String OUTPUT_COLLECTION = "";
 
     public RecordWriter getRecordWriter(TaskAttemptContext taskAttemptContext) throws IOException, InterruptedException {
         return null;  //To change body of implemented methods use File | Settings | File Templates.

lib/bson.jar

@@ -1,4 +1,4 @@
-package com.gameattain.dpa;
+package cascading.mongodb;
 
 import cascading.scheme.Scheme;
 import cascading.tap.Tap;
@@ -31,8 +31,8 @@ public void sourceInit(Tap tap, JobConf jobConf) throws IOException {
     }
 
     public void sinkInit(Tap tap, JobConf jobConf) throws IOException {
-        jobConf.setOutputFormat(MongoDBOutputFormat.class);
-        jobConf.setOutputKeyClass();
+//        jobConf.setOutputFormat(MongoDBOutputFormat.class);
+//        jobConf.setOutputKeyClass();
         jobConf.setOutputValueClass(BasicDBObject.class);
     }
 
@@ -66,4 +66,4 @@ private void setSourceSink(Fields keyFields, Fields[] columnFields) {
         setSourceFields(allFields);
         setSinkFields(allFields);
     }                           
-}
+}

lib/cascading-core-wip-1.1-116.jar

@@ -1,4 +1,4 @@
-package com.gameattain.dpa;
+package cascading.mongodb;
 
 import cascading.tap.SinkMode;
 import cascading.tap.Tap;
@@ -80,6 +80,8 @@ private Mongo getMongo() throws UnknownHostException
         {
             m = new Mongo(hostname, port);
         }
+
+        return m;
     }
 
     private DB getDB()
@@ -90,6 +92,7 @@ private DB getDB()
             db = m.getDB(database);
         }
 
+        return db;
     }
 
     @Override

lib/cascading-test-wip-1.1-116.jar

@@ -0,0 +1,22 @@
+package cascading.mongodb;
+
+import cascading.CascadingTestCase;
+import org.junit.Test;
+
+/**
+ * Created by IntelliJ IDEA.
+ * User: djktno
+ * Date: May 24, 2010
+ * Time: 4:10:09 PM
+ * To change this template use File | Settings | File Templates.
+ */
+public class MongoTapTest extends CascadingTestCase
+{
+    private static String tuple = "document\tvoid\tstatus\tgame";
+
+    @Test
+    public void testTapConfiguration()
+    {
+        
+    }
+}