parallel/data/WritableGridArrayPartition.java

package appl.parallel.data;

import java.awt.Rectangle;
import java.awt.image.DataBuffer;

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