data/xulugridfile/XuluWritableGridFile.java

package appl.parallel.data.xulugridfile;

import java.awt.Rectangle;
import java.io.File;
import java.io.FileNotFoundException;

import schmitzm.data.WritableGrid;

import edu.bonn.xulu.appl.XuluRegistry;
import edu.bonn.xulu.io.ImportFactory;
import edu.bonn.xulu.plugin.io.grid.WritableGridFactory;
import appl.data.DataLoader;
import appl.data.WritableGridArrayLoader;
import appl.data.WritableGridLLProxy;
import appl.parallel.spmd.split.DataPartition;
import appl.parallel.spmd.split.SplittableGrid;
import appl.parallel.spmd.split.SplittableResource;
import appl.util.RasterMetaData;

/**
 * An implementation of a WritableGrid based on a {@link XuluGridFile}.
 * 
 * @author Dominik Appl
 */
public class XuluWritableGridFile extends WritableGridLLProxy implements SplittableGrid{
        
        private XuluGridFile gridFile;
        private boolean wasWriteAccessed = false;
        private final String directory;
        private int rootID = this.hashCode();
        private final File baseFile;

        /**
         * Opens the GridFile at the given destination
         * @param gridfileName the filename of the XuluGridfile
         * 
         */
        public XuluWritableGridFile(File gridfileName) {
                super(null);
                this.baseFile = gridfileName;
                try {
                        gridFile = new XuluGridFile(gridfileName);
                } catch (FileNotFoundException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                } catch (XuluGridFileException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                this.metaData = gridFile.metaData;
                this.intialDataLoader = new GridFileDataLoader(gridFile);
                this.dataLoader = new GridFileDataLoader(gridFile);
                directory = null;
        }
        
        
        /**
         * Creates NEW a GridFile in the given directory with the given metadata-sample
         * 
         * @param metaData the metadata
         */
        public XuluWritableGridFile(RasterMetaData metaData, String directory) {
                super(metaData);
                this.directory = directory;
                baseFile = new File(directory + File.separatorChar + "xulugridFile"+ this.hashCode() + ".xgrid");
                try {
                        gridFile = new XuluGridFile(baseFile,metaData);
                        this.intialDataLoader = new GridFileDataLoader(gridFile);
                        this.dataLoader = new GridFileDataLoader(gridFile);
                } catch (XuluGridFileException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                        LOG.error(e);
                
                }
                
        }
        
        /** creates a instance out of a {@link XuluGridFile} */
        public XuluWritableGridFile(XuluGridFile xuluGridFile) {
                super(xuluGridFile.getMetaData());
                baseFile = xuluGridFile.getOutputFile();
                gridFile = xuluGridFile;
                this.metaData = xuluGridFile.getMetaData();
                this.intialDataLoader = new GridFileDataLoader(gridFile);
                this.dataLoader = new GridFileDataLoader(gridFile);
                // TODO Auto-generated constructor stub
                this.directory=null;
        }


        /**
         * Creates a new XuluWritableGridFile in the specified directory, with the given metadata. 
         * The ID given in this constuctor will be the RootID of this Grid (used e.g. for 
         * identification in remoteComputing) 
         * 
         * @param newID the to be set as the new RootID (permanent)
         * @param metaData the metadata is used for creation of the bounds and the type of the new {@link XuluGridFile}
         * @param directory the directory in which the file should be created
         * @see SplittableResource#getRootID()
         */
        public XuluWritableGridFile(int newID, RasterMetaData metaData, String directory) {
                this(metaData,directory);
                this.rootID  = newID;
        }


        /* (non-Javadoc)
         * @see appl.parallel.spmd.split.SplittableResource#getLocalLoader()
         */
        public DataLoader getLocalLoader() {
                throw new UnsupportedOperationException("Feature not yet supported!");
        }

        /* (non-Javadoc)
         * @see appl.parallel.spmd.split.SplittableResource#getRootID()
         */
        public int getRootID() {
                return rootID;
        }

        /* (non-Javadoc)
         * @see appl.parallel.spmd.split.SplittableResource#getSplitHeight()
         */
        public int getSplitHeight() {
                return metaData.getHeight();
        }

        /* (non-Javadoc)
         * @see appl.parallel.spmd.split.SplittableResource#getSplitWidth()
         */
        public int getSplitWidth() {
                return metaData.getWidth();
        }

        /* (non-Javadoc)
         * @see appl.parallel.spmd.split.DataPartition#getEmpty(int)
         */
        public DataPartition getEmpty(int newID) {
                if(directory==null)
                   throw new UnsupportedOperationException("Directory == null. Cant create a empty grid!");
                return new XuluWritableGridFile(newID,this.metaData,this.directory);
        }

        /* (non-Javadoc)
         * @see appl.parallel.spmd.split.DataPartition#getPartition(java.awt.Rectangle)
         */
        public DataPartition getPartition(Rectangle partitionBounds) {
                try {
                        return gridFile.getPartitialGrid2D(partitionBounds);
                } catch (XuluGridFileException e) {
                        e.printStackTrace();
                        LOG.error("Could not retrieve partition from underlaying gridfile");
                }
                return null;
        }

        /* (non-Javadoc)
         * @see appl.parallel.spmd.split.DataPartition#getPartitionBounds()
         */
        public Rectangle getPartitionBounds() {
                return new Rectangle(0,0,getWidth(),getHeight());
        }

        /* (non-Javadoc)
         * @see appl.parallel.spmd.split.DataPartition#setPartition(appl.parallel.spmd.split.DataPartition, java.awt.Rectangle)
         */
        public void setPartition(DataPartition partition, Rectangle partitionBounds) {
                try {
                        gridFile.setPartition((WritableGrid) partition, partitionBounds);
                } catch (XuluGridFileException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                
        }

        /* (non-Javadoc)
         * @see appl.data.WritableGridLLProxy#setGridSample(java.lang.Object, double[])
         */
        @Override
        public void setGridSample(Object value, double... coord) {
                throw new UnsupportedOperationException("Writing on cell level is not yet supported. Use setPartition(..) to write to the Grid");
                //wasWriteAccessed =true;
//              super.setGridSample(value, coord);
        }
        
         /* (non-Javadoc)
         * @see appl.data.WritableGridLLProxy#setRasterSample(java.lang.Object, int[])
         */
        public void setRasterSample(Object value, int... cell) {
                 throw new UnsupportedOperationException("Writing on cell level is not yet supported. Use setPartition(..) to write to the Grid");

         }


        /* (non-Javadoc)
         * @see appl.data.WritableGridLLProxy#getGridSample(double[])
         */
        @Override
        public Object getGridSample(double... coord) {
                 throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
        }


        /* (non-Javadoc)
         * @see appl.data.WritableGridLLProxy#getGridSampleAsByte(double[])
         */
        @Override
        public byte getGridSampleAsByte(double... coord) {
                throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
        }


        /* (non-Javadoc)
         * @see appl.data.WritableGridLLProxy#getGridSampleAsDouble(double[])
         */
        @Override
        public double getGridSampleAsDouble(double... coord) {
                throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
        }


        /* (non-Javadoc)
         * @see appl.data.WritableGridLLProxy#getGridSampleAsFloat(double[])
         */
        @Override
        public float getGridSampleAsFloat(double... coord) {
                throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
        }


        /* (non-Javadoc)
         * @see appl.data.WritableGridLLProxy#getGridSampleAsInt(double[])
         */
        @Override
        public int getGridSampleAsInt(double... coord) {
                throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
        }


        /* (non-Javadoc)
         * @see appl.data.WritableGridLLProxy#getGridSampleAsLong(double[])
         */
        @Override
        public long getGridSampleAsLong(double... coord) {
                throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
        }


        /* (non-Javadoc)
         * @see appl.data.WritableGridLLProxy#getGridSampleAsShort(double[])
         */
        @Override
        public short getGridSampleAsShort(double... coord) {
                throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
        }
        /**
         * unloading is not necessary (method does nothing
         * 
         * @see appl.data.LateLoadingProxy#unloadData()
         */
        @Override
        public synchronized void unloadData() {
        }


        public String getGridFileName() {
                return baseFile.getPath();
        }
}
1	mojays	2	package appl.parallel.data.xulugridfile;
2
3			import java.awt.Rectangle;
4			import java.io.File;
5			import java.io.FileNotFoundException;
6
7			import schmitzm.data.WritableGrid;
8
9			import edu.bonn.xulu.appl.XuluRegistry;
10			import edu.bonn.xulu.io.ImportFactory;
11			import edu.bonn.xulu.plugin.io.grid.WritableGridFactory;
12			import appl.data.DataLoader;
13			import appl.data.WritableGridArrayLoader;
14			import appl.data.WritableGridLLProxy;
15			import appl.parallel.spmd.split.DataPartition;
16			import appl.parallel.spmd.split.SplittableGrid;
17			import appl.parallel.spmd.split.SplittableResource;
18			import appl.util.RasterMetaData;
19
20			/**
21			* An implementation of a WritableGrid based on a {@link XuluGridFile}.
22			*
23			* @author Dominik Appl
24			*/
25			public class XuluWritableGridFile extends WritableGridLLProxy implements SplittableGrid{
26
27			private XuluGridFile gridFile;
28			private boolean wasWriteAccessed = false;
29			private final String directory;
30			private int rootID = this.hashCode();
31			private final File baseFile;
32
33			/**
34			* Opens the GridFile at the given destination
35			* @param gridfileName the filename of the XuluGridfile
36			*
37			*/
38			public XuluWritableGridFile(File gridfileName) {
39			super(null);
40			this.baseFile = gridfileName;
41			try {
42			gridFile = new XuluGridFile(gridfileName);
43			} catch (FileNotFoundException e) {
44			// TODO Auto-generated catch block
45			e.printStackTrace();
46			} catch (XuluGridFileException e) {
47			// TODO Auto-generated catch block
48			e.printStackTrace();
49			}
50			this.metaData = gridFile.metaData;
51			this.intialDataLoader = new GridFileDataLoader(gridFile);
52			this.dataLoader = new GridFileDataLoader(gridFile);
53			directory = null;
54			}
55
56
57			/**
58			* Creates NEW a GridFile in the given directory with the given metadata-sample
59			*
60			* @param metaData the metadata
61			*/
62			public XuluWritableGridFile(RasterMetaData metaData, String directory) {
63			super(metaData);
64			this.directory = directory;
65			baseFile = new File(directory + File.separatorChar + "xulugridFile"+ this.hashCode() + ".xgrid");
66			try {
67			gridFile = new XuluGridFile(baseFile,metaData);
68			this.intialDataLoader = new GridFileDataLoader(gridFile);
69			this.dataLoader = new GridFileDataLoader(gridFile);
70			} catch (XuluGridFileException e) {
71			// TODO Auto-generated catch block
72			e.printStackTrace();
73			LOG.error(e);
74
75			}
76
77			}
78
79			/** creates a instance out of a {@link XuluGridFile} */
80			public XuluWritableGridFile(XuluGridFile xuluGridFile) {
81			super(xuluGridFile.getMetaData());
82			baseFile = xuluGridFile.getOutputFile();
83			gridFile = xuluGridFile;
84			this.metaData = xuluGridFile.getMetaData();
85			this.intialDataLoader = new GridFileDataLoader(gridFile);
86			this.dataLoader = new GridFileDataLoader(gridFile);
87			// TODO Auto-generated constructor stub
88			this.directory=null;
89			}
90
91
92			/**
93			* Creates a new XuluWritableGridFile in the specified directory, with the given metadata.
94			* The ID given in this constuctor will be the RootID of this Grid (used e.g. for
95			* identification in remoteComputing)
96			*
97			* @param newID the to be set as the new RootID (permanent)
98			* @param metaData the metadata is used for creation of the bounds and the type of the new {@link XuluGridFile}
99			* @param directory the directory in which the file should be created
100			* @see SplittableResource#getRootID()
101			*/
102			public XuluWritableGridFile(int newID, RasterMetaData metaData, String directory) {
103			this(metaData,directory);
104			this.rootID = newID;
105			}
106
107
108			/* (non-Javadoc)
109			* @see appl.parallel.spmd.split.SplittableResource#getLocalLoader()
110			*/
111			public DataLoader getLocalLoader() {
112			throw new UnsupportedOperationException("Feature not yet supported!");
113			}
114
115			/* (non-Javadoc)
116			* @see appl.parallel.spmd.split.SplittableResource#getRootID()
117			*/
118			public int getRootID() {
119			return rootID;
120			}
121
122			/* (non-Javadoc)
123			* @see appl.parallel.spmd.split.SplittableResource#getSplitHeight()
124			*/
125			public int getSplitHeight() {
126			return metaData.getHeight();
127			}
128
129			/* (non-Javadoc)
130			* @see appl.parallel.spmd.split.SplittableResource#getSplitWidth()
131			*/
132			public int getSplitWidth() {
133			return metaData.getWidth();
134			}
135
136			/* (non-Javadoc)
137			* @see appl.parallel.spmd.split.DataPartition#getEmpty(int)
138			*/
139			public DataPartition getEmpty(int newID) {
140			if(directory==null)
141			throw new UnsupportedOperationException("Directory == null. Cant create a empty grid!");
142			return new XuluWritableGridFile(newID,this.metaData,this.directory);
143			}
144
145			/* (non-Javadoc)
146			* @see appl.parallel.spmd.split.DataPartition#getPartition(java.awt.Rectangle)
147			*/
148			public DataPartition getPartition(Rectangle partitionBounds) {
149			try {
150			return gridFile.getPartitialGrid2D(partitionBounds);
151			} catch (XuluGridFileException e) {
152			e.printStackTrace();
153			LOG.error("Could not retrieve partition from underlaying gridfile");
154			}
155			return null;
156			}
157
158			/* (non-Javadoc)
159			* @see appl.parallel.spmd.split.DataPartition#getPartitionBounds()
160			*/
161			public Rectangle getPartitionBounds() {
162			return new Rectangle(0,0,getWidth(),getHeight());
163			}
164
165			/* (non-Javadoc)
166			* @see appl.parallel.spmd.split.DataPartition#setPartition(appl.parallel.spmd.split.DataPartition, java.awt.Rectangle)
167			*/
168			public void setPartition(DataPartition partition, Rectangle partitionBounds) {
169			try {
170			gridFile.setPartition((WritableGrid) partition, partitionBounds);
171			} catch (XuluGridFileException e) {
172			// TODO Auto-generated catch block
173			e.printStackTrace();
174			}
175
176			}
177
178			/* (non-Javadoc)
179			* @see appl.data.WritableGridLLProxy#setGridSample(java.lang.Object, double[])
180			*/
181			@Override
182			public void setGridSample(Object value, double... coord) {
183			throw new UnsupportedOperationException("Writing on cell level is not yet supported. Use setPartition(..) to write to the Grid");
184			//wasWriteAccessed =true;
185			// super.setGridSample(value, coord);
186			}
187
188			/* (non-Javadoc)
189			* @see appl.data.WritableGridLLProxy#setRasterSample(java.lang.Object, int[])
190			*/
191			public void setRasterSample(Object value, int... cell) {
192			throw new UnsupportedOperationException("Writing on cell level is not yet supported. Use setPartition(..) to write to the Grid");
193
194			}
195
196
197			/* (non-Javadoc)
198			* @see appl.data.WritableGridLLProxy#getGridSample(double[])
199			*/
200			@Override
201			public Object getGridSample(double... coord) {
202			throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
203			}
204
205
206			/* (non-Javadoc)
207			* @see appl.data.WritableGridLLProxy#getGridSampleAsByte(double[])
208			*/
209			@Override
210			public byte getGridSampleAsByte(double... coord) {
211			throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
212			}
213
214
215			/* (non-Javadoc)
216			* @see appl.data.WritableGridLLProxy#getGridSampleAsDouble(double[])
217			*/
218			@Override
219			public double getGridSampleAsDouble(double... coord) {
220			throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
221			}
222
223
224			/* (non-Javadoc)
225			* @see appl.data.WritableGridLLProxy#getGridSampleAsFloat(double[])
226			*/
227			@Override
228			public float getGridSampleAsFloat(double... coord) {
229			throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
230			}
231
232
233			/* (non-Javadoc)
234			* @see appl.data.WritableGridLLProxy#getGridSampleAsInt(double[])
235			*/
236			@Override
237			public int getGridSampleAsInt(double... coord) {
238			throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
239			}
240
241
242			/* (non-Javadoc)
243			* @see appl.data.WritableGridLLProxy#getGridSampleAsLong(double[])
244			*/
245			@Override
246			public long getGridSampleAsLong(double... coord) {
247			throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
248			}
249
250
251			/* (non-Javadoc)
252			* @see appl.data.WritableGridLLProxy#getGridSampleAsShort(double[])
253			*/
254			@Override
255			public short getGridSampleAsShort(double... coord) {
256			throw new UnsupportedOperationException("Reading on cell level is not yet supported. Use getPartition(..) to read from the to the Grid");
257			}
258			/**
259			* unloading is not necessary (method does nothing
260			*
261			* @see appl.data.LateLoadingProxy#unloadData()
262			*/
263			@Override
264			public synchronized void unloadData() {
265			}
266
267
268			public String getGridFileName() {
269			return baseFile.getPath();
270			}
271			}