You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by tj...@apache.org on 2011/09/27 11:35:48 UTC
svn commit: r1176297 [14/19] - in /incubator/hama/branches/HamaV2: ./ api/
api/target/ api/target/classes/ api/target/classes/META-INF/
api/target/lib/ api/target/maven-archiver/
api/target/maven-shared-archive-resources/ api/target/maven-shared-archiv...
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/TEST-org.apache.hama.zookeeper.TestZKTools.xml
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/TEST-org.apache.hama.zookeeper.TestZKTools.xml?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/TEST-org.apache.hama.zookeeper.TestZKTools.xml (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/TEST-org.apache.hama.zookeeper.TestZKTools.xml Tue Sep 27 09:35:21 2011
@@ -0,0 +1,59 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<testsuite failures="0" time="0.008" errors="0" skipped="0" tests="1" name="org.apache.hama.zookeeper.TestZKTools">
+ <properties>
+ <property name="java.runtime.name" value="Java(TM) SE Runtime Environment"/>
+ <property name="sun.boot.library.path" value="/usr/local/jdk1.6.0_22/jre/lib/amd64"/>
+ <property name="java.vm.version" value="17.1-b03"/>
+ <property name="java.vm.vendor" value="Sun Microsystems Inc."/>
+ <property name="java.vendor.url" value="http://java.sun.com/"/>
+ <property name="path.separator" value=":"/>
+ <property name="java.vm.name" value="Java HotSpot(TM) 64-Bit Server VM"/>
+ <property name="file.encoding.pkg" value="sun.io"/>
+ <property name="user.country" value="DE"/>
+ <property name="sun.java.launcher" value="SUN_STANDARD"/>
+ <property name="sun.os.patch.level" value="unknown"/>
+ <property name="java.vm.specification.name" value="Java Virtual Machine Specification"/>
+ <property name="user.dir" value="/home/thomasjungblut/branches/HamaV2/core"/>
+ <property name="java.runtime.version" value="1.6.0_22-b04"/>
+ <property name="java.awt.graphicsenv" value="sun.awt.X11GraphicsEnvironment"/>
+ <property name="basedir" value="/home/thomasjungblut/branches/HamaV2/core"/>
+ <property name="java.endorsed.dirs" value="/usr/local/jdk1.6.0_22/jre/lib/endorsed"/>
+ <property name="os.arch" value="amd64"/>
+ <property name="java.io.tmpdir" value="/tmp"/>
+ <property name="line.separator" value="
+"/>
+ <property name="java.vm.specification.vendor" value="Sun Microsystems Inc."/>
+ <property name="os.name" value="Linux"/>
+ <property name="sun.jnu.encoding" value="UTF-8"/>
+ <property name="java.library.path" value="/usr/local/jdk1.6.0_22/jre/lib/amd64/server:/usr/local/jdk1.6.0_22/jre/lib/amd64:/usr/local/jdk1.6.0_22/jre/../lib/amd64:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib"/>
+ <property name="java.specification.name" value="Java Platform API Specification"/>
+ <property name="java.class.version" value="50.0"/>
+ <property name="sun.management.compiler" value="HotSpot 64-Bit Server Compiler"/>
+ <property name="os.version" value="2.6.38-11-generic"/>
+ <property name="user.home" value="/home/thomasjungblut"/>
+ <property name="user.timezone" value="Europe/Berlin"/>
+ <property name="java.awt.printerjob" value="sun.print.PSPrinterJob"/>
+ <property name="file.encoding" value="UTF-8"/>
+ <property name="java.specification.version" value="1.6"/>
+ <property name="user.name" value="thomasjungblut"/>
+ <property name="java.class.path" value="/tmp/surefirebooter5259485598385329674.jar"/>
+ <property name="java.vm.specification.version" value="1.0"/>
+ <property name="sun.arch.data.model" value="64"/>
+ <property name="java.home" value="/usr/local/jdk1.6.0_22/jre"/>
+ <property name="java.specification.vendor" value="Sun Microsystems Inc."/>
+ <property name="user.language" value="de"/>
+ <property name="java.vm.info" value="mixed mode"/>
+ <property name="java.version" value="1.6.0_22"/>
+ <property name="java.ext.dirs" value="/usr/local/jdk1.6.0_22/jre/lib/ext:/usr/java/packages/lib/ext"/>
+ <property name="sun.boot.class.path" value="/usr/local/jdk1.6.0_22/jre/lib/resources.jar:/usr/local/jdk1.6.0_22/jre/lib/rt.jar:/usr/local/jdk1.6.0_22/jre/lib/sunrsasign.jar:/usr/local/jdk1.6.0_22/jre/lib/jsse.jar:/usr/local/jdk1.6.0_22/jre/lib/jce.jar:/usr/local/jdk1.6.0_22/jre/lib/charsets.jar:/usr/local/jdk1.6.0_22/jre/classes"/>
+ <property name="java.vendor" value="Sun Microsystems Inc."/>
+ <property name="localRepository" value="/home/thomasjungblut/.m2/repository"/>
+ <property name="file.separator" value="/"/>
+ <property name="java.vendor.url.bug" value="http://java.sun.com/cgi-bin/bugreport.cgi"/>
+ <property name="sun.cpu.endian" value="little"/>
+ <property name="sun.io.unicode.encoding" value="UnicodeLittle"/>
+ <property name="sun.desktop" value="gnome"/>
+ <property name="sun.cpu.isalist" value=""/>
+ </properties>
+ <testcase time="0.001" classname="org.apache.hama.zookeeper.TestZKTools" name="testZKProps"/>
+</testsuite>
\ No newline at end of file
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/TEST-org.apache.hama.zookeeper.TestZKTools.xml
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestBSPMasterGroomServer.txt
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestBSPMasterGroomServer.txt?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestBSPMasterGroomServer.txt (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestBSPMasterGroomServer.txt Tue Sep 27 09:35:21 2011
@@ -0,0 +1,4 @@
+-------------------------------------------------------------------------------
+Test set: org.apache.hama.bsp.TestBSPMasterGroomServer
+-------------------------------------------------------------------------------
+Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.018 sec
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestBSPMasterGroomServer.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestBSPMessageBundle.txt
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestBSPMessageBundle.txt?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestBSPMessageBundle.txt (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestBSPMessageBundle.txt Tue Sep 27 09:35:21 2011
@@ -0,0 +1,4 @@
+-------------------------------------------------------------------------------
+Test set: org.apache.hama.bsp.TestBSPMessageBundle
+-------------------------------------------------------------------------------
+Tests run: 2, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.015 sec
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestBSPMessageBundle.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestClusterStatus.txt
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestClusterStatus.txt?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestClusterStatus.txt (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestClusterStatus.txt Tue Sep 27 09:35:21 2011
@@ -0,0 +1,4 @@
+-------------------------------------------------------------------------------
+Test set: org.apache.hama.bsp.TestClusterStatus
+-------------------------------------------------------------------------------
+Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.015 sec
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestClusterStatus.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestMessages.txt
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestMessages.txt?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestMessages.txt (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestMessages.txt Tue Sep 27 09:35:21 2011
@@ -0,0 +1,4 @@
+-------------------------------------------------------------------------------
+Test set: org.apache.hama.bsp.TestMessages
+-------------------------------------------------------------------------------
+Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.015 sec
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.bsp.TestMessages.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.checkpoint.TestCheckpoint.txt
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.checkpoint.TestCheckpoint.txt?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.checkpoint.TestCheckpoint.txt (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.checkpoint.TestCheckpoint.txt Tue Sep 27 09:35:21 2011
@@ -0,0 +1,4 @@
+-------------------------------------------------------------------------------
+Test set: org.apache.hama.checkpoint.TestCheckpoint
+-------------------------------------------------------------------------------
+Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.014 sec
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.checkpoint.TestCheckpoint.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.ipc.TestIPC.txt
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.ipc.TestIPC.txt?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.ipc.TestIPC.txt (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.ipc.TestIPC.txt Tue Sep 27 09:35:21 2011
@@ -0,0 +1,4 @@
+-------------------------------------------------------------------------------
+Test set: org.apache.hama.ipc.TestIPC
+-------------------------------------------------------------------------------
+Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.018 sec
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.ipc.TestIPC.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.ipc.TestRPC.txt
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.ipc.TestRPC.txt?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.ipc.TestRPC.txt (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.ipc.TestRPC.txt Tue Sep 27 09:35:21 2011
@@ -0,0 +1,4 @@
+-------------------------------------------------------------------------------
+Test set: org.apache.hama.ipc.TestRPC
+-------------------------------------------------------------------------------
+Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.025 sec
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.ipc.TestRPC.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestBytes.txt
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestBytes.txt?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestBytes.txt (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestBytes.txt Tue Sep 27 09:35:21 2011
@@ -0,0 +1,4 @@
+-------------------------------------------------------------------------------
+Test set: org.apache.hama.util.TestBytes
+-------------------------------------------------------------------------------
+Tests run: 8, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.024 sec
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestBytes.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestNumeric.txt
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestNumeric.txt?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestNumeric.txt (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestNumeric.txt Tue Sep 27 09:35:21 2011
@@ -0,0 +1,4 @@
+-------------------------------------------------------------------------------
+Test set: org.apache.hama.util.TestNumeric
+-------------------------------------------------------------------------------
+Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.014 sec
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestNumeric.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestRandomVariable.txt
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestRandomVariable.txt?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestRandomVariable.txt (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestRandomVariable.txt Tue Sep 27 09:35:21 2011
@@ -0,0 +1,4 @@
+-------------------------------------------------------------------------------
+Test set: org.apache.hama.util.TestRandomVariable
+-------------------------------------------------------------------------------
+Tests run: 3, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.027 sec
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.util.TestRandomVariable.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.zookeeper.TestZKTools.txt
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.zookeeper.TestZKTools.txt?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.zookeeper.TestZKTools.txt (added)
+++ incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.zookeeper.TestZKTools.txt Tue Sep 27 09:35:21 2011
@@ -0,0 +1,4 @@
+-------------------------------------------------------------------------------
+Test set: org.apache.hama.zookeeper.TestZKTools
+-------------------------------------------------------------------------------
+Tests run: 1, Failures: 0, Errors: 0, Skipped: 0, Time elapsed: 0.021 sec
Propchange: incubator/hama/branches/HamaV2/core/target/surefire-reports/org.apache.hama.zookeeper.TestZKTools.txt
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/DEPENDENCIES
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/DEPENDENCIES?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/DEPENDENCIES (added)
+++ incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/DEPENDENCIES Tue Sep 27 09:35:21 2011
@@ -0,0 +1,103 @@
+// ------------------------------------------------------------------
+// Transitive dependencies of this project determined from the
+// maven pom organized by organization.
+// ------------------------------------------------------------------
+
+Apache Hama Core
+
+
+From: 'an unknown organization'
+ - geronimo-spec-jta geronimo-spec:geronimo-spec-jta:jar:1.0.1B-rc4
+
+ - HSQLDB (http://hsqldb.org/) hsqldb:hsqldb:jar:1.8.0.10
+ License: HSQLDB License (http://hsqldb.org/web/hsqlLicense.html)
+ - JLine (http://jline.sourceforge.net) jline:jline:jar:0.9.94
+ License: BSD (LICENSE.txt)
+ - An open source Java toolkit for Amazon S3 (http://jets3t.s3.amazonaws.com/index.html) net.java.dev.jets3t:jets3t:jar:0.7.1
+ License: Apache License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0)
+ - kosmosfs (http://kosmosfs.sourceforge.net/) net.sf.kosmosfs:kfs:jar:0.3
+ License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
+ - hadoop-core org.apache.hadoop:hadoop-core:jar:0.20.2
+
+ - hadoop-test org.apache.hadoop:hadoop-test:jar:0.20.2
+
+ - servlet-api org.apache.tomcat:servlet-api:jar:6.0.32
+
+ - zookeeper org.apache.zookeeper:zookeeper:jar:3.3.1
+
+ - Eclipse JDT Core (http://www.eclipse.org/jdt/) org.eclipse.jdt:core:jar:3.1.1
+ License: Eclipse Public License v1.0 (http://www.eclipse.org/org/documents/epl-v10.php)
+ - oro oro:oro:jar:2.0.8
+
+ - jasper-compiler tomcat:jasper-compiler:jar:5.5.12
+
+ - jasper-runtime tomcat:jasper-runtime:jar:5.5.12
+
+ - xmlenc Library (http://xmlenc.sourceforge.net) xmlenc:xmlenc:jar:0.52
+ License: The BSD License (http://www.opensource.org/licenses/bsd-license.php)
+
+From: 'Apache MINA Project' (http://mina.apache.org/)
+ - Apache MINA Core (http://mina.apache.org/mina-core) org.apache.mina:mina-core:bundle:2.0.0-M5
+ License: Apache 2.0 License (http://www.apache.org/licenses/LICENSE-2.0)
+
+From: 'Apache Software Foundation' (http://jakarta.apache.org/)
+ - HttpClient (http://jakarta.apache.org/commons/httpclient/) commons-httpclient:commons-httpclient:jar:3.0.1
+ License: Apache License (http://www.apache.org/licenses/LICENSE-2.0)
+
+From: 'Apache Software Foundation' (http://www.apache.org)
+ - Annotation 1.0 (http://geronimo.apache.org/specs/geronimo-annotation_1.0_spec) org.apache.geronimo.specs:geronimo-annotation_1.0_spec:jar:1.0
+ License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
+
+From: 'Apache Software Foundation'
+ - org.apache.tools.ant (http://ant.apache.org/ant/) org.apache.ant:ant:jar:1.7.1
+
+ - ant-launcher (http://ant.apache.org/ant-launcher/) org.apache.ant:ant-launcher:jar:1.7.1
+
+
+From: 'Mort Bay Consulting' (http://www.mortbay.com)
+ - Jetty Server (http://jetty.mortbay.org/project/modules/jetty) org.mortbay.jetty:jetty:jar:6.1.14
+ License: Apache License Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0)
+ - Servlet Annotations (http://jetty.mortbay.org/project/jetty-annotations) org.mortbay.jetty:jetty-annotations:jar:6.1.14
+ License: Apache License Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0)
+ - Jetty Plus (http://jetty.mortbay.org/project/jetty-plus) org.mortbay.jetty:jetty-plus:jar:6.1.14
+ License: Apache License Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0)
+ - Jetty Utilities (http://jetty.mortbay.org/project/jetty-util) org.mortbay.jetty:jetty-util:jar:6.1.14
+ License: Apache License Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0)
+ - Glassfish Jasper (http://jetty.mortbay.org/project/modules/jsp-2.1) org.mortbay.jetty:jsp-2.1:jar:6.1.14
+ License: CDDL 1.0 (https://glassfish.dev.java.net/public/CDDLv1.0.html)
+ - Glassfish Jasper API (http://jetty.mortbay.org/project/modules/jsp-api-2.1) org.mortbay.jetty:jsp-api-2.1:jar:6.1.14
+ License: Apache License Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0)
+ - Servlet Specification 2.5 API (http://jetty.mortbay.org/project/modules/servlet-api-2.5) org.mortbay.jetty:servlet-api-2.5:jar:6.1.14
+ License: CDDL 1.0 (https://glassfish.dev.java.net/public/CDDLv1.0.html)
+
+From: 'QOS.ch' (http://www.qos.ch)
+ - SLF4J API Module (http://www.slf4j.org) org.slf4j:slf4j-api:jar:1.5.2
+
+ - SLF4J LOG4J-12 Binding (http://www.slf4j.org) org.slf4j:slf4j-log4j12:jar:1.5.2
+
+
+From: 'The Apache Software Foundation' (http://jakarta.apache.org)
+ - Codec (http://jakarta.apache.org/commons/codec/) commons-codec:commons-codec:jar:1.3
+ License: The Apache Software License, Version 2.0 (/LICENSE.txt)
+ - EL (http://jakarta.apache.org/commons/el/) commons-el:commons-el:jar:1.0
+ License: The Apache Software License, Version 2.0 (/LICENSE.txt)
+ - Jakarta Commons Net (http://jakarta.apache.org/commons/${pom.artifactId.substring(8)}/) commons-net:commons-net:jar:1.4.1
+ License: The Apache Software License, Version 2.0 (/LICENSE.txt)
+
+From: 'The Apache Software Foundation' (http://www.apache.org/)
+ - ant (http://www.apache.org/ant/) ant:ant:jar:1.6.5
+ License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
+ - Commons CLI (http://commons.apache.org/cli/) commons-cli:commons-cli:jar:1.2
+ License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
+ - Commons Logging (http://commons.apache.org/logging) commons-logging:commons-logging:jar:1.1.1
+ License: The Apache Software License, Version 2.0 (http://www.apache.org/licenses/LICENSE-2.0.txt)
+ - Apache Ftplet API (http://mina.apache.org/ftpserver) org.apache.ftpserver:ftplet-api:bundle:1.0.0
+ License: Apache 2.0 License (http://www.apache.org/licenses/LICENSE-2.0)
+ - Apache FtpServer Core (http://mina.apache.org/ftpserver/ftpserver-core) org.apache.ftpserver:ftpserver-core:bundle:1.0.0
+ License: Apache 2.0 License (http://www.apache.org/licenses/LICENSE-2.0)
+ - Apache FtpServer Deprecated classes (http://mina.apache.org/ftpserver/ftpserver-deprecated) org.apache.ftpserver:ftpserver-deprecated:jar:1.0.0-M2
+ License: Apache 2.0 License (http://www.apache.org/licenses/LICENSE-2.0)
+
+
+
+
Added: incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/LICENSE
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/LICENSE?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/LICENSE (added)
+++ incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/LICENSE Tue Sep 27 09:35:21 2011
@@ -0,0 +1,202 @@
+
+ Apache License
+ Version 2.0, January 2004
+ http://www.apache.org/licenses/
+
+ TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION
+
+ 1. Definitions.
+
+ "License" shall mean the terms and conditions for use, reproduction,
+ and distribution as defined by Sections 1 through 9 of this document.
+
+ "Licensor" shall mean the copyright owner or entity authorized by
+ the copyright owner that is granting the License.
+
+ "Legal Entity" shall mean the union of the acting entity and all
+ other entities that control, are controlled by, or are under common
+ control with that entity. For the purposes of this definition,
+ "control" means (i) the power, direct or indirect, to cause the
+ direction or management of such entity, whether by contract or
+ otherwise, or (ii) ownership of fifty percent (50%) or more of the
+ outstanding shares, or (iii) beneficial ownership of such entity.
+
+ "You" (or "Your") shall mean an individual or Legal Entity
+ exercising permissions granted by this License.
+
+ "Source" form shall mean the preferred form for making modifications,
+ including but not limited to software source code, documentation
+ source, and configuration files.
+
+ "Object" form shall mean any form resulting from mechanical
+ transformation or translation of a Source form, including but
+ not limited to compiled object code, generated documentation,
+ and conversions to other media types.
+
+ "Work" shall mean the work of authorship, whether in Source or
+ Object form, made available under the License, as indicated by a
+ copyright notice that is included in or attached to the work
+ (an example is provided in the Appendix below).
+
+ "Derivative Works" shall mean any work, whether in Source or Object
+ form, that is based on (or derived from) the Work and for which the
+ editorial revisions, annotations, elaborations, or other modifications
+ represent, as a whole, an original work of authorship. For the purposes
+ of this License, Derivative Works shall not include works that remain
+ separable from, or merely link (or bind by name) to the interfaces of,
+ the Work and Derivative Works thereof.
+
+ "Contribution" shall mean any work of authorship, including
+ the original version of the Work and any modifications or additions
+ to that Work or Derivative Works thereof, that is intentionally
+ submitted to Licensor for inclusion in the Work by the copyright owner
+ or by an individual or Legal Entity authorized to submit on behalf of
+ the copyright owner. For the purposes of this definition, "submitted"
+ means any form of electronic, verbal, or written communication sent
+ to the Licensor or its representatives, including but not limited to
+ communication on electronic mailing lists, source code control systems,
+ and issue tracking systems that are managed by, or on behalf of, the
+ Licensor for the purpose of discussing and improving the Work, but
+ excluding communication that is conspicuously marked or otherwise
+ designated in writing by the copyright owner as "Not a Contribution."
+
+ "Contributor" shall mean Licensor and any individual or Legal Entity
+ on behalf of whom a Contribution has been received by Licensor and
+ subsequently incorporated within the Work.
+
+ 2. Grant of Copyright License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ copyright license to reproduce, prepare Derivative Works of,
+ publicly display, publicly perform, sublicense, and distribute the
+ Work and such Derivative Works in Source or Object form.
+
+ 3. Grant of Patent License. Subject to the terms and conditions of
+ this License, each Contributor hereby grants to You a perpetual,
+ worldwide, non-exclusive, no-charge, royalty-free, irrevocable
+ (except as stated in this section) patent license to make, have made,
+ use, offer to sell, sell, import, and otherwise transfer the Work,
+ where such license applies only to those patent claims licensable
+ by such Contributor that are necessarily infringed by their
+ Contribution(s) alone or by combination of their Contribution(s)
+ with the Work to which such Contribution(s) was submitted. If You
+ institute patent litigation against any entity (including a
+ cross-claim or counterclaim in a lawsuit) alleging that the Work
+ or a Contribution incorporated within the Work constitutes direct
+ or contributory patent infringement, then any patent licenses
+ granted to You under this License for that Work shall terminate
+ as of the date such litigation is filed.
+
+ 4. Redistribution. You may reproduce and distribute copies of the
+ Work or Derivative Works thereof in any medium, with or without
+ modifications, and in Source or Object form, provided that You
+ meet the following conditions:
+
+ (a) You must give any other recipients of the Work or
+ Derivative Works a copy of this License; and
+
+ (b) You must cause any modified files to carry prominent notices
+ stating that You changed the files; and
+
+ (c) You must retain, in the Source form of any Derivative Works
+ that You distribute, all copyright, patent, trademark, and
+ attribution notices from the Source form of the Work,
+ excluding those notices that do not pertain to any part of
+ the Derivative Works; and
+
+ (d) If the Work includes a "NOTICE" text file as part of its
+ distribution, then any Derivative Works that You distribute must
+ include a readable copy of the attribution notices contained
+ within such NOTICE file, excluding those notices that do not
+ pertain to any part of the Derivative Works, in at least one
+ of the following places: within a NOTICE text file distributed
+ as part of the Derivative Works; within the Source form or
+ documentation, if provided along with the Derivative Works; or,
+ within a display generated by the Derivative Works, if and
+ wherever such third-party notices normally appear. The contents
+ of the NOTICE file are for informational purposes only and
+ do not modify the License. You may add Your own attribution
+ notices within Derivative Works that You distribute, alongside
+ or as an addendum to the NOTICE text from the Work, provided
+ that such additional attribution notices cannot be construed
+ as modifying the License.
+
+ You may add Your own copyright statement to Your modifications and
+ may provide additional or different license terms and conditions
+ for use, reproduction, or distribution of Your modifications, or
+ for any such Derivative Works as a whole, provided Your use,
+ reproduction, and distribution of the Work otherwise complies with
+ the conditions stated in this License.
+
+ 5. Submission of Contributions. Unless You explicitly state otherwise,
+ any Contribution intentionally submitted for inclusion in the Work
+ by You to the Licensor shall be under the terms and conditions of
+ this License, without any additional terms or conditions.
+ Notwithstanding the above, nothing herein shall supersede or modify
+ the terms of any separate license agreement you may have executed
+ with Licensor regarding such Contributions.
+
+ 6. Trademarks. This License does not grant permission to use the trade
+ names, trademarks, service marks, or product names of the Licensor,
+ except as required for reasonable and customary use in describing the
+ origin of the Work and reproducing the content of the NOTICE file.
+
+ 7. Disclaimer of Warranty. Unless required by applicable law or
+ agreed to in writing, Licensor provides the Work (and each
+ Contributor provides its Contributions) on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
+ implied, including, without limitation, any warranties or conditions
+ of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A
+ PARTICULAR PURPOSE. You are solely responsible for determining the
+ appropriateness of using or redistributing the Work and assume any
+ risks associated with Your exercise of permissions under this License.
+
+ 8. Limitation of Liability. In no event and under no legal theory,
+ whether in tort (including negligence), contract, or otherwise,
+ unless required by applicable law (such as deliberate and grossly
+ negligent acts) or agreed to in writing, shall any Contributor be
+ liable to You for damages, including any direct, indirect, special,
+ incidental, or consequential damages of any character arising as a
+ result of this License or out of the use or inability to use the
+ Work (including but not limited to damages for loss of goodwill,
+ work stoppage, computer failure or malfunction, or any and all
+ other commercial damages or losses), even if such Contributor
+ has been advised of the possibility of such damages.
+
+ 9. Accepting Warranty or Additional Liability. While redistributing
+ the Work or Derivative Works thereof, You may choose to offer,
+ and charge a fee for, acceptance of support, warranty, indemnity,
+ or other liability obligations and/or rights consistent with this
+ License. However, in accepting such obligations, You may act only
+ on Your own behalf and on Your sole responsibility, not on behalf
+ of any other Contributor, and only if You agree to indemnify,
+ defend, and hold each Contributor harmless for any liability
+ incurred by, or claims asserted against, such Contributor by reason
+ of your accepting any such warranty or additional liability.
+
+ END OF TERMS AND CONDITIONS
+
+ APPENDIX: How to apply the Apache License to your work.
+
+ To apply the Apache License to your work, attach the following
+ boilerplate notice, with the fields enclosed by brackets "[]"
+ replaced with your own identifying information. (Don't include
+ the brackets!) The text should be enclosed in the appropriate
+ comment syntax for the file format. We also recommend that a
+ file or class name and description of purpose be included on the
+ same "printed page" as the copyright notice for easier
+ identification within third-party archives.
+
+ Copyright [yyyy] [name of copyright owner]
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/LICENSE
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/NOTICE
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/NOTICE?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/NOTICE (added)
+++ incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/NOTICE Tue Sep 27 09:35:21 2011
@@ -0,0 +1,8 @@
+
+Apache Hama Core
+Copyright 2008-2011 The Apache Software Foundation
+
+This product includes software developed at
+The Apache Software Foundation (http://www.apache.org/).
+
+
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/META-INF/NOTICE
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/HamaCluster.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/HamaCluster.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/HamaCluster.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/HamaClusterTestCase.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/HamaClusterTestCase.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/HamaClusterTestCase.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/HamaTestCase.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/HamaTestCase.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/HamaTestCase.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/MiniBSPCluster$BSPMasterRunner.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/MiniBSPCluster%24BSPMasterRunner.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/MiniBSPCluster$BSPMasterRunner.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/MiniBSPCluster$GroomServerRunner.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/MiniBSPCluster%24GroomServerRunner.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/MiniBSPCluster$GroomServerRunner.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/MiniBSPCluster.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/MiniBSPCluster.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/MiniBSPCluster.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/BSPSerializerWrapper.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/BSPSerializerWrapper.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/BSPSerializerWrapper.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestBSPMasterGroomServer.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestBSPMasterGroomServer.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestBSPMasterGroomServer.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestBSPMessageBundle.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestBSPMessageBundle.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestBSPMessageBundle.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestClusterStatus.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestClusterStatus.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestClusterStatus.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestMessages.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestMessages.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/bsp/TestMessages.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/checkpoint/TestCheckpoint.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/checkpoint/TestCheckpoint.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/checkpoint/TestCheckpoint.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC$ParallelCaller.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC%24ParallelCaller.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC$ParallelCaller.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC$SerialCaller.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC%24SerialCaller.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC$SerialCaller.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC$TestServer.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC%24TestServer.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC$TestServer.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestIPC.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestRPC$TestImpl.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestRPC%24TestImpl.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestRPC$TestImpl.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestRPC$TestProtocol.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestRPC%24TestProtocol.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestRPC$TestProtocol.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestRPC.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestRPC.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/ipc/TestRPC.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/util/TestBytes.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/util/TestBytes.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/util/TestBytes.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/util/TestNumeric.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/util/TestNumeric.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/util/TestNumeric.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/util/TestRandomVariable.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/util/TestRandomVariable.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/util/TestRandomVariable.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/zookeeper/TestZKTools.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/zookeeper/TestZKTools.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/org/apache/hama/zookeeper/TestZKTools.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/testjar/ClassSerializePrinting$HelloBSP.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/testjar/ClassSerializePrinting%24HelloBSP.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/testjar/ClassSerializePrinting$HelloBSP.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/core/target/test-classes/testjar/ClassSerializePrinting.class
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/core/target/test-classes/testjar/ClassSerializePrinting.class?rev=1176297&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/hama/branches/HamaV2/core/target/test-classes/testjar/ClassSerializePrinting.class
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Added: incubator/hama/branches/HamaV2/examples/.classpath
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/examples/.classpath?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/examples/.classpath (added)
+++ incubator/hama/branches/HamaV2/examples/.classpath Tue Sep 27 09:35:21 2011
@@ -0,0 +1,46 @@
+<classpath>
+ <classpathentry kind="src" path="src/main/java" including="**/*.java"/>
+ <classpathentry kind="src" path="target/maven-shared-archive-resources" excluding="**/*.java"/>
+ <classpathentry kind="output" path="target/classes"/>
+ <classpathentry kind="var" path="M2_REPO/ant/ant/1.6.5/ant-1.6.5.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/ant/ant/1.7.1/ant-1.7.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/ant/ant-launcher/1.7.1/ant-launcher-1.7.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/commons-cli/commons-cli/1.2/commons-cli-1.2.jar"/>
+ <classpathentry kind="var" path="M2_REPO/commons-codec/commons-codec/1.3/commons-codec-1.3.jar"/>
+ <classpathentry kind="var" path="M2_REPO/commons-el/commons-el/1.0/commons-el-1.0.jar"/>
+ <classpathentry kind="var" path="M2_REPO/commons-httpclient/commons-httpclient/3.0.1/commons-httpclient-3.0.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/commons-logging/commons-logging/1.1.1/commons-logging-1.1.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/commons-net/commons-net/1.4.1/commons-net-1.4.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/eclipse/jdt/core/3.1.1/core-3.1.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/ftpserver/ftplet-api/1.0.0/ftplet-api-1.0.0.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/ftpserver/ftpserver-core/1.0.0/ftpserver-core-1.0.0.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/ftpserver/ftpserver-deprecated/1.0.0-M2/ftpserver-deprecated-1.0.0-M2.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/geronimo/specs/geronimo-annotation_1.0_spec/1.0/geronimo-annotation_1.0_spec-1.0.jar"/>
+ <classpathentry kind="var" path="M2_REPO/geronimo-spec/geronimo-spec-jta/1.0.1B-rc4/geronimo-spec-jta-1.0.1B-rc4.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/hadoop/hadoop-core/0.20.2/hadoop-core-0.20.2.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/hadoop/hadoop-test/0.20.2/hadoop-test-0.20.2.jar"/>
+ <classpathentry kind="src" path="/hama-core"/>
+ <classpathentry kind="var" path="M2_REPO/hsqldb/hsqldb/1.8.0.10/hsqldb-1.8.0.10.jar"/>
+ <classpathentry kind="var" path="M2_REPO/tomcat/jasper-compiler/5.5.12/jasper-compiler-5.5.12.jar"/>
+ <classpathentry kind="var" path="M2_REPO/tomcat/jasper-runtime/5.5.12/jasper-runtime-5.5.12.jar"/>
+ <classpathentry kind="var" path="M2_REPO/net/java/dev/jets3t/jets3t/0.7.1/jets3t-0.7.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/mortbay/jetty/jetty/6.1.14/jetty-6.1.14.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/mortbay/jetty/jetty-annotations/6.1.14/jetty-annotations-6.1.14.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/mortbay/jetty/jetty-plus/6.1.14/jetty-plus-6.1.14.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/mortbay/jetty/jetty-util/6.1.14/jetty-util-6.1.14.jar"/>
+ <classpathentry kind="var" path="M2_REPO/jline/jline/0.9.94/jline-0.9.94.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/mortbay/jetty/jsp-2.1/6.1.14/jsp-2.1-6.1.14.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/mortbay/jetty/jsp-api-2.1/6.1.14/jsp-api-2.1-6.1.14.jar"/>
+ <classpathentry kind="var" path="M2_REPO/junit/junit/4.8.1/junit-4.8.1.jar"/>
+ <classpathentry kind="var" path="M2_REPO/net/sf/kosmosfs/kfs/0.3/kfs-0.3.jar"/>
+ <classpathentry kind="var" path="M2_REPO/log4j/log4j/1.2.16/log4j-1.2.16.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/mina/mina-core/2.0.0-M5/mina-core-2.0.0-M5.jar"/>
+ <classpathentry kind="var" path="M2_REPO/oro/oro/2.0.8/oro-2.0.8.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/tomcat/servlet-api/6.0.32/servlet-api-6.0.32.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/mortbay/jetty/servlet-api-2.5/6.1.14/servlet-api-2.5-6.1.14.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/slf4j/slf4j-api/1.5.2/slf4j-api-1.5.2.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/slf4j/slf4j-log4j12/1.5.2/slf4j-log4j12-1.5.2.jar"/>
+ <classpathentry kind="var" path="M2_REPO/xmlenc/xmlenc/0.52/xmlenc-0.52.jar"/>
+ <classpathentry kind="var" path="M2_REPO/org/apache/zookeeper/zookeeper/3.3.1/zookeeper-3.3.1.jar"/>
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>
+</classpath>
\ No newline at end of file
Propchange: incubator/hama/branches/HamaV2/examples/.classpath
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/examples/.project
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/examples/.project?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/examples/.project (added)
+++ incubator/hama/branches/HamaV2/examples/.project Tue Sep 27 09:35:21 2011
@@ -0,0 +1,19 @@
+<projectDescription>
+ <name>hama-examples</name>
+ <comment>The Apache Software Foundation provides support for the Apache community of open-source software projects.
+ The Apache projects are characterized by a collaborative, consensus based development process, an open and
+ pragmatic software license, and a desire to create high quality software that leads the way in its field.
+ We consider ourselves not simply a group of projects sharing a server, but rather a community of developers
+ and users. NO_M2ECLIPSE_SUPPORT: Project files created with the maven-eclipse-plugin are not supported in M2Eclipse.</comment>
+ <projects>
+ <project>hama-core</project>
+ </projects>
+ <buildSpec>
+ <buildCommand>
+ <name>org.eclipse.jdt.core.javabuilder</name>
+ </buildCommand>
+ </buildSpec>
+ <natures>
+ <nature>org.eclipse.jdt.core.javanature</nature>
+ </natures>
+</projectDescription>
\ No newline at end of file
Propchange: incubator/hama/branches/HamaV2/examples/.project
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/examples/.settings/org.eclipse.jdt.core.prefs
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/examples/.settings/org.eclipse.jdt.core.prefs?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/examples/.settings/org.eclipse.jdt.core.prefs (added)
+++ incubator/hama/branches/HamaV2/examples/.settings/org.eclipse.jdt.core.prefs Tue Sep 27 09:35:21 2011
@@ -0,0 +1,9 @@
+#Tue Sep 20 19:51:26 CEST 2011
+encoding//src/test/java=UTF-8
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
+eclipse.preferences.version=1
+encoding//src/test/resources=UTF-8
+org.eclipse.jdt.core.compiler.source=1.6
+encoding//src/main/java=UTF-8
+encoding//src/main/resources=UTF-8
+org.eclipse.jdt.core.compiler.compliance=1.6
Added: incubator/hama/branches/HamaV2/examples/pom.xml
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/examples/pom.xml?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/examples/pom.xml (added)
+++ incubator/hama/branches/HamaV2/examples/pom.xml Tue Sep 27 09:35:21 2011
@@ -0,0 +1,76 @@
+<!--
+ Licensed to the Apache Software Foundation (ASF) under one or more
+ contributor license agreements. See the NOTICE file distributed with
+ this work for additional information regarding copyright ownership.
+ The ASF licenses this file to You under the Apache License, Version 2.0
+ (the "License"); you may not use this file except in compliance with
+ the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+-->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
+
+ <parent>
+ <groupId>org.apache.hama</groupId>
+ <artifactId>hama-parent</artifactId>
+ <version>0.4.0-incubating-SNAPSHOT</version>
+ </parent>
+
+ <modelVersion>4.0.0</modelVersion>
+ <groupId>org.apache.hama</groupId>
+ <artifactId>hama-examples</artifactId>
+ <name>Apache Hama Examples</name>
+ <version>0.4.0-incubating-SNAPSHOT</version>
+ <packaging>jar</packaging>
+
+ <dependencies>
+ <dependency>
+ <groupId>org.apache.hama</groupId>
+ <artifactId>hama-core</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ </dependencies>
+ <build>
+ <finalName>hama-examples-${project.version}</finalName>
+ <pluginManagement>
+ <plugins>
+ <plugin>
+ <artifactId>maven-surefire-plugin</artifactId>
+ <configuration>
+ <skipTests>true</skipTests>
+ </configuration>
+ </plugin>
+ </plugins>
+ </pluginManagement>
+ <plugins>
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-shade-plugin</artifactId>
+ <version>1.4</version>
+ <executions>
+ <execution>
+ <phase>package</phase>
+ <goals>
+ <goal>shade</goal>
+ </goals>
+ <configuration>
+ <transformers>
+ <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+ <mainClass>org.apache.hama.examples.ExampleDriver</mainClass>
+ </transformer>
+ </transformers>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+ </plugins>
+ </build>
+</project>
Propchange: incubator/hama/branches/HamaV2/examples/pom.xml
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/ExampleDriver.java
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/ExampleDriver.java?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/ExampleDriver.java (added)
+++ incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/ExampleDriver.java Tue Sep 27 09:35:21 2011
@@ -0,0 +1,42 @@
+/**
+ * Copyright 2007 The Apache Software Foundation
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hama.examples;
+
+import org.apache.hadoop.util.ProgramDriver;
+import org.apache.hama.examples.graph.PageRank;
+import org.apache.hama.examples.graph.ShortestPaths;
+
+public class ExampleDriver {
+
+ public static void main(String[] args) {
+ ProgramDriver pgd = new ProgramDriver();
+ try {
+ pgd.addClass("pi", PiEstimator.class, "Pi Estimator");
+ pgd.addClass("bench", RandBench.class, "Random Communication Benchmark");
+ pgd.addClass("test", SerializePrinting.class, "Serialize Printing Test");
+ pgd.addClass("sssp", ShortestPaths.class, "Single Source Shortest Path");
+ pgd.addClass("pagerank", PageRank.class, "PageRank");
+
+ pgd.driver(args);
+ } catch (Throwable e) {
+ e.printStackTrace();
+ }
+ }
+}
Propchange: incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/ExampleDriver.java
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/PiEstimator.java
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/PiEstimator.java?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/PiEstimator.java (added)
+++ incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/PiEstimator.java Tue Sep 27 09:35:21 2011
@@ -0,0 +1,159 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hama.examples;
+
+import java.io.IOException;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.FileSystem;
+import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.io.DoubleWritable;
+import org.apache.hadoop.io.SequenceFile;
+import org.apache.hadoop.io.SequenceFile.CompressionType;
+import org.apache.hama.HamaConfiguration;
+import org.apache.hama.bsp.BSP;
+import org.apache.hama.bsp.BSPJob;
+import org.apache.hama.bsp.BSPJobClient;
+import org.apache.hama.bsp.BSPPeer;
+import org.apache.hama.bsp.ClusterStatus;
+import org.apache.hama.bsp.DoubleMessage;
+import org.apache.zookeeper.KeeperException;
+
+public class PiEstimator {
+ private static String MASTER_TASK = "master.task.";
+ private static Path TMP_OUTPUT = new Path("/tmp/pi-example/output");
+
+ public static class MyEstimator extends BSP {
+ public static final Log LOG = LogFactory.getLog(MyEstimator.class);
+ private Configuration conf;
+ private String masterTask;
+ private static final int iterations = 10000;
+
+ public void bsp(BSPPeer bspPeer) throws IOException,
+ KeeperException, InterruptedException {
+
+ int in = 0, out = 0;
+ for (int i = 0; i < iterations; i++) {
+ double x = 2.0 * Math.random() - 1.0, y = 2.0 * Math.random() - 1.0;
+ if ((Math.sqrt(x * x + y * y) < 1.0)) {
+ in++;
+ } else {
+ out++;
+ }
+ }
+
+ double data = 4.0 * (double) in / (double) iterations;
+ DoubleMessage estimate = new DoubleMessage(bspPeer.getPeerName(), data);
+
+ bspPeer.send(masterTask, estimate);
+ bspPeer.sync();
+
+ if (bspPeer.getPeerName().equals(masterTask)) {
+ double pi = 0.0;
+ int numPeers = bspPeer.getNumCurrentMessages();
+ DoubleMessage received;
+ while ((received = (DoubleMessage) bspPeer.getCurrentMessage()) != null) {
+ pi += received.getData();
+ }
+
+ pi = pi / numPeers;
+ writeResult(pi);
+ }
+ }
+
+ private void writeResult(double pi) throws IOException {
+ FileSystem fileSys = FileSystem.get(conf);
+
+ SequenceFile.Writer writer = SequenceFile.createWriter(fileSys, conf,
+ TMP_OUTPUT, DoubleWritable.class, DoubleWritable.class,
+ CompressionType.NONE);
+ writer.append(new DoubleWritable(pi), new DoubleWritable(0));
+ writer.close();
+ }
+
+ public Configuration getConf() {
+ return conf;
+ }
+
+ public void setConf(Configuration conf) {
+ this.conf = conf;
+ this.masterTask = conf.get(MASTER_TASK);
+ }
+
+ }
+
+ private static void initTempDir(FileSystem fileSys) throws IOException {
+ if (fileSys.exists(TMP_OUTPUT)) {
+ fileSys.delete(TMP_OUTPUT, true);
+ }
+ }
+
+ private static void printOutput(FileSystem fileSys, HamaConfiguration conf)
+ throws IOException {
+ SequenceFile.Reader reader = new SequenceFile.Reader(fileSys, TMP_OUTPUT,
+ conf);
+ DoubleWritable output = new DoubleWritable();
+ DoubleWritable zero = new DoubleWritable();
+ reader.next(output, zero);
+ reader.close();
+
+ System.out.println("Estimated value of PI is " + output);
+ }
+
+ public static void main(String[] args) throws InterruptedException,
+ IOException, ClassNotFoundException {
+ // BSP job configuration
+ HamaConfiguration conf = new HamaConfiguration();
+
+ BSPJob bsp = new BSPJob(conf, PiEstimator.class);
+ // Set the job name
+ bsp.setJobName("Pi Estimation Example");
+ bsp.setBspClass(MyEstimator.class);
+
+ BSPJobClient jobClient = new BSPJobClient(conf);
+ ClusterStatus cluster = jobClient.getClusterStatus(true);
+
+ if (args.length > 0) {
+ bsp.setNumBspTask(Integer.parseInt(args[0]));
+ } else {
+ // Set to maximum
+ bsp.setNumBspTask(cluster.getMaxTasks());
+ }
+
+ // Choose one as a master
+ for (String hostName : cluster.getActiveGroomNames().keySet()) {
+ conf.set(MASTER_TASK,hostName);
+ break;
+ }
+
+ FileSystem fileSys = FileSystem.get(conf);
+ initTempDir(fileSys);
+
+ long startTime = System.currentTimeMillis();
+
+ if (bsp.waitForCompletion(true)) {
+ printOutput(fileSys, conf);
+
+ System.out.println("Job Finished in "
+ + (double) (System.currentTimeMillis() - startTime) / 1000.0
+ + " seconds");
+ }
+ }
+}
Propchange: incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/PiEstimator.java
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/RandBench.java
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/RandBench.java?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/RandBench.java (added)
+++ incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/RandBench.java Tue Sep 27 09:35:21 2011
@@ -0,0 +1,122 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hama.examples;
+
+import java.io.IOException;
+import java.util.Random;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hama.HamaConfiguration;
+import org.apache.hama.bsp.BSP;
+import org.apache.hama.bsp.BSPJob;
+import org.apache.hama.bsp.BSPJobClient;
+import org.apache.hama.bsp.BSPMessage;
+import org.apache.hama.bsp.BSPPeer;
+import org.apache.hama.bsp.ByteMessage;
+import org.apache.hama.bsp.ClusterStatus;
+import org.apache.hama.util.Bytes;
+import org.apache.zookeeper.KeeperException;
+
+public class RandBench {
+ private static final String SIZEOFMSG = "msg.size";
+ private static final String N_COMMUNICATIONS = "communications.num";
+ private static final String N_SUPERSTEPS = "supersteps.num";
+
+ public static class RandBSP extends BSP {
+ public static final Log LOG = LogFactory.getLog(RandBSP.class);
+ private Configuration conf;
+ private Random r = new Random();
+ private int sizeOfMsg;
+ private int nCommunications;
+ private int nSupersteps;
+
+ @Override
+ public void bsp(BSPPeer bspPeer) throws IOException,
+ KeeperException, InterruptedException {
+ byte[] dummyData = new byte[sizeOfMsg];
+ BSPMessage msg = null;
+ String[] peers = bspPeer.getAllPeerNames();
+ String peerName = bspPeer.getPeerName();
+
+ for (int i = 0; i < nSupersteps; i++) {
+
+ for (int j = 0; j < nCommunications; j++) {
+ String tPeer = peers[r.nextInt(peers.length)];
+ String tag = peerName + " to " + tPeer;
+ msg = new ByteMessage(Bytes.toBytes(tag), dummyData);
+ bspPeer.send(tPeer, msg);
+ }
+
+ bspPeer.sync();
+
+ ByteMessage received;
+ while ((received = (ByteMessage) bspPeer.getCurrentMessage()) != null) {
+ LOG.info(Bytes.toString(received.getTag()) + " : "
+ + received.getData().length);
+ }
+
+ }
+ }
+
+ @Override
+ public void setConf(Configuration conf) {
+ this.conf = conf;
+ this.sizeOfMsg = conf.getInt(SIZEOFMSG, 1);
+ this.nCommunications = conf.getInt(N_COMMUNICATIONS, 1);
+ this.nSupersteps = conf.getInt(N_SUPERSTEPS, 1);
+ }
+
+ @Override
+ public Configuration getConf() {
+ return conf;
+ }
+
+ }
+
+ public static void main(String[] args) throws Exception {
+ if (args.length < 3) {
+ System.out.println("Usage: <sizeOfMsg> <nCommunications> <nSupersteps>");
+ System.exit(-1);
+ }
+
+ // BSP job configuration
+ HamaConfiguration conf = new HamaConfiguration();
+
+ conf.setInt(SIZEOFMSG, Integer.parseInt(args[0]));
+ conf.setInt(N_COMMUNICATIONS, Integer.parseInt(args[1]));
+ conf.setInt(N_SUPERSTEPS, Integer.parseInt(args[2]));
+
+ BSPJob bsp = new BSPJob(conf, RandBench.class);
+ // Set the job name
+ bsp.setJobName("Random Communication Benchmark");
+ bsp.setBspClass(RandBSP.class);
+
+ // Set the task size as a number of GroomServer
+ BSPJobClient jobClient = new BSPJobClient(conf);
+ ClusterStatus cluster = jobClient.getClusterStatus(false);
+ bsp.setNumBspTask(cluster.getMaxTasks());
+
+ long startTime = System.currentTimeMillis();
+ bsp.waitForCompletion(true);
+ System.out.println("Job Finished in "
+ + (double) (System.currentTimeMillis() - startTime) / 1000.0
+ + " seconds");
+ }
+}
Propchange: incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/RandBench.java
------------------------------------------------------------------------------
svn:eol-style = native
Added: incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/SerializePrinting.java
URL: http://svn.apache.org/viewvc/incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/SerializePrinting.java?rev=1176297&view=auto
==============================================================================
--- incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/SerializePrinting.java (added)
+++ incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/SerializePrinting.java Tue Sep 27 09:35:21 2011
@@ -0,0 +1,135 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hama.examples;
+
+import java.io.IOException;
+import java.util.Date;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.FileSystem;
+import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.io.LongWritable;
+import org.apache.hadoop.io.SequenceFile;
+import org.apache.hadoop.io.SequenceFile.CompressionType;
+import org.apache.hadoop.io.Text;
+import org.apache.hama.HamaConfiguration;
+import org.apache.hama.bsp.BSP;
+import org.apache.hama.bsp.BSPJob;
+import org.apache.hama.bsp.BSPJobClient;
+import org.apache.hama.bsp.BSPPeer;
+import org.apache.hama.bsp.ClusterStatus;
+import org.apache.zookeeper.KeeperException;
+
+public class SerializePrinting {
+ private static String TMP_OUTPUT = "/tmp/test-example/";
+
+ public static class HelloBSP extends BSP {
+ public static final Log LOG = LogFactory.getLog(HelloBSP.class);
+ private Configuration conf;
+ private final static int PRINT_INTERVAL = 1000;
+ private FileSystem fileSys;
+ private int num;
+
+ public void bsp(BSPPeer bspPeer) throws IOException, KeeperException,
+ InterruptedException {
+
+ LOG.info(bspPeer.getAllPeerNames());
+ int i = 0;
+ for (String otherPeer : bspPeer.getAllPeerNames()) {
+ String peerName = bspPeer.getPeerName();
+ if (peerName.equals(otherPeer)) {
+ writeLogToFile(peerName, i);
+ }
+
+ Thread.sleep(PRINT_INTERVAL);
+ bspPeer.sync();
+ i++;
+ }
+ }
+
+ private void writeLogToFile(String string, int i) throws IOException {
+ SequenceFile.Writer writer = SequenceFile.createWriter(fileSys, conf,
+ new Path(TMP_OUTPUT + i), LongWritable.class, Text.class,
+ CompressionType.NONE);
+ writer.append(new LongWritable(System.currentTimeMillis()), new Text(
+ "Hello BSP from " + (i + 1) + " of " + num + ": " + string));
+ writer.close();
+ }
+
+ public Configuration getConf() {
+ return conf;
+ }
+
+ public void setConf(Configuration conf) {
+ this.conf = conf;
+ num = Integer.parseInt(conf.get("bsp.peers.num"));
+ try {
+ fileSys = FileSystem.get(conf);
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ }
+
+ private static void printOutput(FileSystem fileSys, ClusterStatus cluster,
+ HamaConfiguration conf) throws IOException {
+ System.out.println("Each task printed the \"Hello World\" as below:");
+ for (int i = 0; i < cluster.getGroomServers(); i++) {
+ SequenceFile.Reader reader = new SequenceFile.Reader(fileSys, new Path(
+ TMP_OUTPUT + i), conf);
+ LongWritable timestamp = new LongWritable();
+ Text message = new Text();
+ reader.next(timestamp, message);
+ System.out.println(new Date(timestamp.get()) + ": " + message);
+ reader.close();
+ }
+ }
+
+ private static void initTempDir(FileSystem fileSys) throws IOException {
+ if (fileSys.exists(new Path(TMP_OUTPUT))) {
+ fileSys.delete(new Path(TMP_OUTPUT), true);
+ }
+ }
+
+ public static void main(String[] args) throws InterruptedException,
+ IOException, ClassNotFoundException {
+ // BSP job configuration
+ HamaConfiguration conf = new HamaConfiguration();
+
+ BSPJob bsp = new BSPJob(conf, SerializePrinting.class);
+ // Set the job name
+ bsp.setJobName("Serialize Printing");
+ bsp.setBspClass(HelloBSP.class);
+
+ // Set the task size as a number of GroomServer
+ BSPJobClient jobClient = new BSPJobClient(conf);
+ ClusterStatus cluster = jobClient.getClusterStatus(false);
+ bsp.setNumBspTask(cluster.getGroomServers());
+
+ FileSystem fileSys = FileSystem.get(conf);
+ initTempDir(fileSys);
+
+ if (bsp.waitForCompletion(true)) {
+ printOutput(fileSys, cluster, conf);
+ }
+ }
+
+}
Propchange: incubator/hama/branches/HamaV2/examples/src/main/java/org/apache/hama/examples/SerializePrinting.java
------------------------------------------------------------------------------
svn:eol-style = native