parallel/data/WritableGridArrayPartition.java

package appl.parallel.data;

import java.awt.Rectangle;

import appl.data.DataProxy;
import appl.parallel.spmd.split.DataPartition;
import appl.parallel.spmd.split.WritableGridPartition;
import appl.parallel.util.PartitionUtil;
import de.appl.util.RasterMetaData;
import de.schmitzm.geotools.data.WritableGrid;
import de.schmitzm.geotools.data.WritableGridArray;

/** 
 * A WritableGridArrayPartition extends the {@link WritableGridArray} so that
 * it can be used in parallel computation. Every partition represents a 
 * rectangle-shaped part of a father-grid. It has information about its bounds
 * and about its father-grid. The partition may be used for data transfer
 * between computing resources. It is very fast, because it is not proxyied
 * by a {@link DataProxy}, but uses the {@link WritableGridArray} directly. 
 * 
 * @see WritableGridArrayPartition
 * 
 * @author Dominik Appl
 */
public abstract class WritableGridArrayPartition {

        /**
         * For Float data types
         * 
         * @see WritableGridArray.Float
         * @author Dominik Appl
         */
        public static class Float extends WritableGridArray.Float implements
                        WritableGridPartition {

                private final int rootID;

                private final Rectangle thisPartition;

                private final RasterMetaData metaData;

                public Float(RasterMetaData metaData, int rootID,
                                Rectangle thisPartition) {
                        super(metaData.getMinX(), metaData.getMinY(), metaData.getWidth(),
                                        metaData.getHeight(), metaData.getX(), metaData.getY(),
                                        metaData.getRealWidth(), metaData.getRealHeight(), metaData
                                                        .getCoordinateReferenceSystem(), null);
                        this.metaData = metaData;
                        this.rootID = rootID;
                        this.thisPartition = thisPartition;
                }

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#getBounds(java.awt.Rectangle)
                 */
                public Rectangle getPartitionBounds() {
                        return thisPartition;

                }

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#getPartition(java.awt.Rectangle)
                 */
                public DataPartition getPartition(Rectangle partitionBounds) {
                        return PartitionUtil.getPartitialGrid2D(this, partitionBounds,
                                        rootID);
                }

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

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#setPartition(appl.parallel.spmd.split.DataPartition,
                 *      java.awt.Rectangle)
                 */
                public void setPartition(DataPartition partition,
                                Rectangle partitionBounds) {
                        if (!(partition instanceof WritableGrid))
                                throw new UnsupportedOperationException(
                                                "The partition must be an instance of WritableGrid!");
                        PartitionUtil.setPartition(this, (WritableGrid) partition,
                                        partitionBounds);

                }

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#getEmpty(int id)
                 */
                public DataPartition getEmpty(int id) {
                        return new WritableGridArrayPartition.Float(this.metaData, id,
                                        thisPartition);
                }
        }
        
        /**
         * For Double data types
         * 
         * @see WritableGridArray.Double
         * @author Dominik Appl
         */
        public static class Double extends WritableGridArray.Float implements
                        WritableGridPartition {

                private final int rootID;

                private final Rectangle thisPartition;

                private final RasterMetaData metaData;

                
                public Double(RasterMetaData metaData, int rootID,
                                Rectangle thisPartition) {
                        super(metaData.getMinX(), metaData.getMinY(), metaData.getWidth(),
                                        metaData.getHeight(), metaData.getX(), metaData.getY(),
                                        metaData.getRealWidth(), metaData.getRealHeight(), metaData
                                                        .getCoordinateReferenceSystem(), null);
                        this.metaData = metaData;
                        this.rootID = rootID;
                        this.thisPartition = thisPartition;
                }

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#getBounds(java.awt.Rectangle)
                 */
                public Rectangle getPartitionBounds() {
                        return thisPartition;

                }

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#getPartition(java.awt.Rectangle)
                 */
                public DataPartition getPartition(Rectangle partitionBounds) {
                        return PartitionUtil.getPartitialGrid2D(this, partitionBounds,
                                        rootID);
                }

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

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#setPartition(appl.parallel.spmd.split.DataPartition,
                 *      java.awt.Rectangle)
                 */
                public void setPartition(DataPartition partition,
                                Rectangle partitionBounds) {
                        if (!(partition instanceof WritableGrid))
                                throw new UnsupportedOperationException(
                                                "The partition must be an instance of WritableGrid!");
                        PartitionUtil.setPartition(this, (WritableGrid) partition,
                                        partitionBounds);

                }

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#getEmpty(int id)
                 */
                public DataPartition getEmpty(int id) {
                        return new WritableGridArrayPartition.Double(this.metaData, id,
                                        thisPartition);
                }
        }
        
        /**
         * For Integer data types
         * 
         * @see WritableGridArray.Integer
         * @author Dominik Appl
         */
        public static class Integer extends WritableGridArray.Integer implements
                        WritableGridPartition {

                private final int rootID;

                private final Rectangle thisPartition;

                private final RasterMetaData metaData;

                public Integer(RasterMetaData metaData, int rootID,
                                Rectangle thisPartition) {
                        super(metaData.getMinX(), metaData.getMinY(), metaData.getWidth(),
                                        metaData.getHeight(), metaData.getX(), metaData.getY(),
                                        metaData.getRealWidth(), metaData.getRealHeight(), metaData
                                                        .getCoordinateReferenceSystem(), null);
                        this.metaData = metaData;
                        this.rootID = rootID;
                        this.thisPartition = thisPartition;
                }

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#getBounds(java.awt.Rectangle)
                 */
                public Rectangle getPartitionBounds() {
                        return thisPartition;

                }

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#getPartition(java.awt.Rectangle)
                 */
                public DataPartition getPartition(Rectangle partitionBounds) {
                        return PartitionUtil.getPartitialGrid2D(this, partitionBounds,
                                        rootID);
                }

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

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#setPartition(appl.parallel.spmd.split.DataPartition,
                 *      java.awt.Rectangle)
                 */
                public void setPartition(DataPartition partition,
                                Rectangle partitionBounds) {
                        if (!(partition instanceof WritableGrid))
                                throw new UnsupportedOperationException(
                                                "The partition must be an instance of WritableGrid!");
                        PartitionUtil.setPartition(this, (WritableGrid) partition,
                                        partitionBounds);

                }

                /*
                 * (non-Javadoc)
                 * 
                 * @see appl.parallel.spmd.split.DataPartition#getEmpty(int id)
                 */
                public DataPartition getEmpty(int id) {
                        return new WritableGridArrayPartition.Integer(this.metaData, id,
                                        thisPartition);
                }
        }

}
1	package appl.parallel.data;
2
3	import java.awt.Rectangle;
4
5	import appl.data.DataProxy;
6	import appl.parallel.spmd.split.DataPartition;
7	import appl.parallel.spmd.split.WritableGridPartition;
8	import appl.parallel.util.PartitionUtil;
9	import de.appl.util.RasterMetaData;
10	import de.schmitzm.geotools.data.WritableGrid;
11	import de.schmitzm.geotools.data.WritableGridArray;
12
13	/**
14	* A WritableGridArrayPartition extends the {@link WritableGridArray} so that
15	* it can be used in parallel computation. Every partition represents a
16	* rectangle-shaped part of a father-grid. It has information about its bounds
17	* and about its father-grid. The partition may be used for data transfer
18	* between computing resources. It is very fast, because it is not proxyied
19	* by a {@link DataProxy}, but uses the {@link WritableGridArray} directly.
20	*
21	* @see WritableGridArrayPartition
22	*
23	* @author Dominik Appl
24	*/
25	public abstract class WritableGridArrayPartition {
26
27	/**
28	* For Float data types
29	*
30	* @see WritableGridArray.Float
31	* @author Dominik Appl
32	*/
33	public static class Float extends WritableGridArray.Float implements
34	WritableGridPartition {
35
36	private final int rootID;
37
38	private final Rectangle thisPartition;
39
40	private final RasterMetaData metaData;
41
42	public Float(RasterMetaData metaData, int rootID,
43	Rectangle thisPartition) {
44	super(metaData.getMinX(), metaData.getMinY(), metaData.getWidth(),
45	metaData.getHeight(), metaData.getX(), metaData.getY(),
46	metaData.getRealWidth(), metaData.getRealHeight(), metaData
47	.getCoordinateReferenceSystem(), null);
48	this.metaData = metaData;
49	this.rootID = rootID;
50	this.thisPartition = thisPartition;
51	}
52
53	/*
54	* (non-Javadoc)
55	*
56	* @see appl.parallel.spmd.split.DataPartition#getBounds(java.awt.Rectangle)
57	*/
58	public Rectangle getPartitionBounds() {
59	return thisPartition;
60
61	}
62
63	/*
64	* (non-Javadoc)
65	*
66	* @see appl.parallel.spmd.split.DataPartition#getPartition(java.awt.Rectangle)
67	*/
68	public DataPartition getPartition(Rectangle partitionBounds) {
69	return PartitionUtil.getPartitialGrid2D(this, partitionBounds,
70	rootID);
71	}
72
73	/*
74	* (non-Javadoc)
75	*
76	* @see appl.parallel.spmd.split.DataPartition#getRootID()
77	*/
78	public int getRootID() {
79	return rootID;
80	}
81
82	/*
83	* (non-Javadoc)
84	*
85	* @see appl.parallel.spmd.split.DataPartition#setPartition(appl.parallel.spmd.split.DataPartition,
86	* java.awt.Rectangle)
87	*/
88	public void setPartition(DataPartition partition,
89	Rectangle partitionBounds) {
90	if (!(partition instanceof WritableGrid))
91	throw new UnsupportedOperationException(
92	"The partition must be an instance of WritableGrid!");
93	PartitionUtil.setPartition(this, (WritableGrid) partition,
94	partitionBounds);
95
96	}
97
98	/*
99	* (non-Javadoc)
100	*
101	* @see appl.parallel.spmd.split.DataPartition#getEmpty(int id)
102	*/
103	public DataPartition getEmpty(int id) {
104	return new WritableGridArrayPartition.Float(this.metaData, id,
105	thisPartition);
106	}
107	}
108
109	/**
110	* For Double data types
111	*
112	* @see WritableGridArray.Double
113	* @author Dominik Appl
114	*/
115	public static class Double extends WritableGridArray.Float implements
116	WritableGridPartition {
117
118	private final int rootID;
119
120	private final Rectangle thisPartition;
121
122	private final RasterMetaData metaData;
123
124
125	public Double(RasterMetaData metaData, int rootID,
126	Rectangle thisPartition) {
127	super(metaData.getMinX(), metaData.getMinY(), metaData.getWidth(),
128	metaData.getHeight(), metaData.getX(), metaData.getY(),
129	metaData.getRealWidth(), metaData.getRealHeight(), metaData
130	.getCoordinateReferenceSystem(), null);
131	this.metaData = metaData;
132	this.rootID = rootID;
133	this.thisPartition = thisPartition;
134	}
135
136	/*
137	* (non-Javadoc)
138	*
139	* @see appl.parallel.spmd.split.DataPartition#getBounds(java.awt.Rectangle)
140	*/
141	public Rectangle getPartitionBounds() {
142	return thisPartition;
143
144	}
145
146	/*
147	* (non-Javadoc)
148	*
149	* @see appl.parallel.spmd.split.DataPartition#getPartition(java.awt.Rectangle)
150	*/
151	public DataPartition getPartition(Rectangle partitionBounds) {
152	return PartitionUtil.getPartitialGrid2D(this, partitionBounds,
153	rootID);
154	}
155
156	/*
157	* (non-Javadoc)
158	*
159	* @see appl.parallel.spmd.split.DataPartition#getRootID()
160	*/
161	public int getRootID() {
162	return rootID;
163	}
164
165	/*
166	* (non-Javadoc)
167	*
168	* @see appl.parallel.spmd.split.DataPartition#setPartition(appl.parallel.spmd.split.DataPartition,
169	* java.awt.Rectangle)
170	*/
171	public void setPartition(DataPartition partition,
172	Rectangle partitionBounds) {
173	if (!(partition instanceof WritableGrid))
174	throw new UnsupportedOperationException(
175	"The partition must be an instance of WritableGrid!");
176	PartitionUtil.setPartition(this, (WritableGrid) partition,
177	partitionBounds);
178
179	}
180
181	/*
182	* (non-Javadoc)
183	*
184	* @see appl.parallel.spmd.split.DataPartition#getEmpty(int id)
185	*/
186	public DataPartition getEmpty(int id) {
187	return new WritableGridArrayPartition.Double(this.metaData, id,
188	thisPartition);
189	}
190	}
191
192	/**
193	* For Integer data types
194	*
195	* @see WritableGridArray.Integer
196	* @author Dominik Appl
197	*/
198	public static class Integer extends WritableGridArray.Integer implements
199	WritableGridPartition {
200
201	private final int rootID;
202
203	private final Rectangle thisPartition;
204
205	private final RasterMetaData metaData;
206
207	public Integer(RasterMetaData metaData, int rootID,
208	Rectangle thisPartition) {
209	super(metaData.getMinX(), metaData.getMinY(), metaData.getWidth(),
210	metaData.getHeight(), metaData.getX(), metaData.getY(),
211	metaData.getRealWidth(), metaData.getRealHeight(), metaData
212	.getCoordinateReferenceSystem(), null);
213	this.metaData = metaData;
214	this.rootID = rootID;
215	this.thisPartition = thisPartition;
216	}
217
218	/*
219	* (non-Javadoc)
220	*
221	* @see appl.parallel.spmd.split.DataPartition#getBounds(java.awt.Rectangle)
222	*/
223	public Rectangle getPartitionBounds() {
224	return thisPartition;
225
226	}
227
228	/*
229	* (non-Javadoc)
230	*
231	* @see appl.parallel.spmd.split.DataPartition#getPartition(java.awt.Rectangle)
232	*/
233	public DataPartition getPartition(Rectangle partitionBounds) {
234	return PartitionUtil.getPartitialGrid2D(this, partitionBounds,
235	rootID);
236	}
237
238	/*
239	* (non-Javadoc)
240	*
241	* @see appl.parallel.spmd.split.DataPartition#getRootID()
242	*/
243	public int getRootID() {
244	return rootID;
245	}
246
247	/*
248	* (non-Javadoc)
249	*
250	* @see appl.parallel.spmd.split.DataPartition#setPartition(appl.parallel.spmd.split.DataPartition,
251	* java.awt.Rectangle)
252	*/
253	public void setPartition(DataPartition partition,
254	Rectangle partitionBounds) {
255	if (!(partition instanceof WritableGrid))
256	throw new UnsupportedOperationException(
257	"The partition must be an instance of WritableGrid!");
258	PartitionUtil.setPartition(this, (WritableGrid) partition,
259	partitionBounds);
260
261	}
262
263	/*
264	* (non-Javadoc)
265	*
266	* @see appl.parallel.spmd.split.DataPartition#getEmpty(int id)
267	*/
268	public DataPartition getEmpty(int id) {
269	return new WritableGridArrayPartition.Integer(this.metaData, id,
270	thisPartition);
271	}
272	}
273
274	}