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