Changeset 2742

Timestamp:

01/18/2009 05:57:35 PM (1 year ago)

Author:

airbots

Message:

Movie file test and exchange arraylist added

Files:

• HadoopToys/src/edu/unl/TestLoop/TestLoop.java (modified) (8 diffs)

HadoopToys/src/edu/unl/TestLoop/TestLoop.java

@@ -28 +28 @@
-        public static int numIteration=100;                 
-        public static List<ArrayList<String>> atoms=new ArrayList<ArrayList<String>>();
+        public static List<ArrayList<String>> exatoms=new ArrayList<ArrayList<String>>();
-        public static String x,y,z;
+        public static int exstatus;
-        public static String moviePath=null;             //File of simulation movie in HDFS
-
@@ -57 +59 @@
-        Path[] cachedFiles=new Path[0];
-        int atomnumber=0;
-
+
+
+
+
+
+
-        FileSystem fs=null;
-//      FileStatus fis=new fs.FileStatus();
-ovie.
+d.movie
- 
-        try{
@@ -72 +79 @@
-                while((filecontent=fis.readLine())!=null){
-                    StringTokenizer token=new StringTokenizer(filecontent);
-
+//
-                    ArrayList<String> eachline=new ArrayList<String>();
-                    while(token.hasMoreTokens()){
-                        eachline.add(token.nextToken());
-                    }
-
+
+
-                    atomnumber++;
-                }
@@ -91 +99 @@
-                fs=movie.getFileSystem(job);
-                FSDataOutputStream fsos=fs.create(new Path(moviePath));
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-                System.out.println("Error in creat the movie file");
-                }
@@ -99 +123 @@
-                fs=movie.getFileSystem(job);
-                FSDataOutputStream fsos=fs.append(new Path(moviePath));
+                OutputStream os=fsos.getWrappedStream();
+                ObjectOutputStream oos =new ObjectOutputStream(os);
+                for(int l=0;l<atoms.size();l++){
+                String res=null;
+                if(l==0){
+                     double stime=(double)mdIteration*TimeStep;
+                     String title="Simulation Time: t=            "+stime;
+//                   os.write(new byte[](title));
+                     oos.writeBytes(title);
+                }
+                for(int k=0;k<5;k++){
+                     res=res+"  "+((ArrayList)atoms.get(l)).get(k).toString();
+                }
+//              os.write(new byte[](res));
+                oos.writeBytes(res);
+            }
-            }catch(Exception expt){
-                System.out.println("Error in append to the movie file");
-                }
-        }
-
+
+
+
+
+
+
+
-            OutputStream os=fsos.getWrappedStream();
-       
+        
-           
-            for(int l=0;l<atoms.size();l++){
@@ -124 +170 @@
-                System.out.println("Error in Writting the movie file");
-        }
+*/
-}
-        public void mdvverlet(int keyvalue,String atomsymbol){
@@ -136 +183 @@
-                double xvel,yvel,zvel;
-                double xacc,yacc,zacc;
+                int atompos;
-                rx=ry=rz=0;
-                force=0;
-                fsumx=fsumy=fsumz=0;
-
-
-
-
+
+
+
+
+
+
+
+
+
+
-        
-//      Read information of the atom which will interact with the selected one          
-                for(j=1;j<totalatom+1;j++){
-
++1
-                                x_force[j]=(double)0.0;
-                                y_force[j]=(double)0.0;
@@ -214 +268 @@
-                z_acc=fsumz/mass;
-                //get the old velocity
--1
--1
--1
+
+
+
-                //get the old acceleration
--1
--1
--1
+
+
+
-                //get the new velocity
-                x_vel=(double) (xvel+TimeStep*(x_acc+xacc)/2.0);