data/splittable/SplittableLLProxyGrid.java

package appl.parallel.data.splittable;

import java.awt.Rectangle;
import java.io.Serializable;

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.WritableGridPartition;
import appl.parallel.util.PartitionUtil;
import de.appl.util.RasterMetaData;
import de.schmitzm.geotools.data.WritableGrid;
import edu.bonn.xulu.appl.XuluRegistry;
import edu.bonn.xulu.io.ImportFactory;
import edu.bonn.xulu.plugin.io.grid.WritableGridFactory;

/**
 * @version 1.0
 */
public class SplittableLLProxyGrid extends WritableGridLLProxy implements
                SplittableGrid, Serializable {

        private final int id;

        public SplittableLLProxyGrid(ImportFactory importFac,
                        RasterMetaData metaData, Object inputPara, XuluRegistry reg) {
                super(importFac, metaData, inputPara, reg);
                id = this.hashCode();
        }

        public SplittableLLProxyGrid(WritableGridFactory targetFactory,
                        RasterMetaData metaData) {
                super(targetFactory, metaData);
                id = this.hashCode();
        }

        public SplittableLLProxyGrid(RasterMetaData metaData, int id) {
                super(metaData);
                this.id = id;
        }

        /*
         * (non-Javadoc)
         *
         * @see appl.parallel.spmd.split.SplittableResource#getFileSystemLoader()
         */
        public DataLoader getLocalLoader() {
                return this.intialDataLoader;
        }

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

        /*
         * (non-Javadoc)
         *
         * @see appl.parallel.spmd.split.SplittableResource#getPartition(java.awt.Rectangle)
         */
        public WritableGridPartition getPartition(Rectangle partitionBounds) {
                if (!loaded)
                        tryLoadingGrid();
                return PartitionUtil.getPartitialGrid2D(this, partitionBounds,
                                getRootID());
        }

        /**
         * Overwrites the data at the location specified by the {@link Rectangle}
         * with the given partition-data.
         *
         * @param partition
         *            the grid to be inserted which MUST be an instance of
         *            {@link WritableGrid}!
         * @param partitionBounds
         *            the target location of the data
         * @see appl.parallel.spmd.split.DataPartition#setPartition(DataPartition,
         *      java.awt.Rectangle)
         */
        public void setPartition(DataPartition partition, Rectangle partitionBounds) {
                if (!loaded)
                        tryLoadingGrid();
                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.SplittableResource#getSplitHeight()
         */
        public int getSplitHeight() {
                return this.getHeight();
        }

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

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

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

}
1	package appl.parallel.data.splittable;
2
3	import java.awt.Rectangle;
4	import java.io.Serializable;
5
6	import appl.data.DataLoader;
7	import appl.data.WritableGridLLProxy;
8	import appl.parallel.spmd.split.DataPartition;
9	import appl.parallel.spmd.split.SplittableGrid;
10	import appl.parallel.spmd.split.WritableGridPartition;
11	import appl.parallel.util.PartitionUtil;
12	import de.appl.util.RasterMetaData;
13	import de.schmitzm.geotools.data.WritableGrid;
14	import edu.bonn.xulu.appl.XuluRegistry;
15	import edu.bonn.xulu.io.ImportFactory;
16	import edu.bonn.xulu.plugin.io.grid.WritableGridFactory;
17
18	/**
19	* @version 1.0
20	*/
21	public class SplittableLLProxyGrid extends WritableGridLLProxy implements
22	SplittableGrid, Serializable {
23
24	private final int id;
25
26	public SplittableLLProxyGrid(ImportFactory importFac,
27	RasterMetaData metaData, Object inputPara, XuluRegistry reg) {
28	super(importFac, metaData, inputPara, reg);
29	id = this.hashCode();
30	}
31
32	public SplittableLLProxyGrid(WritableGridFactory targetFactory,
33	RasterMetaData metaData) {
34	super(targetFactory, metaData);
35	id = this.hashCode();
36	}
37
38	public SplittableLLProxyGrid(RasterMetaData metaData, int id) {
39	super(metaData);
40	this.id = id;
41	}
42
43	/*
44	* (non-Javadoc)
45	*
46	* @see appl.parallel.spmd.split.SplittableResource#getFileSystemLoader()
47	*/
48	public DataLoader getLocalLoader() {
49	return this.intialDataLoader;
50	}
51
52	/*
53	* (non-Javadoc)
54	*
55	* @see appl.parallel.spmd.split.SplittableResource#getID()
56	*/
57	public int getRootID() {
58	return this.id;
59	}
60
61	/*
62	* (non-Javadoc)
63	*
64	* @see appl.parallel.spmd.split.SplittableResource#getPartition(java.awt.Rectangle)
65	*/
66	public WritableGridPartition getPartition(Rectangle partitionBounds) {
67	if (!loaded)
68	tryLoadingGrid();
69	return PartitionUtil.getPartitialGrid2D(this, partitionBounds,
70	getRootID());
71	}
72
73	/**
74	* Overwrites the data at the location specified by the {@link Rectangle}
75	* with the given partition-data.
76	*
77	* @param partition
78	* the grid to be inserted which MUST be an instance of
79	* {@link WritableGrid}!
80	* @param partitionBounds
81	* the target location of the data
82	* @see appl.parallel.spmd.split.DataPartition#setPartition(DataPartition,
83	* java.awt.Rectangle)
84	*/
85	public void setPartition(DataPartition partition, Rectangle partitionBounds) {
86	if (!loaded)
87	tryLoadingGrid();
88	if (!(partition instanceof WritableGrid))
89	throw new UnsupportedOperationException(
90	"The partition must be an instance of WritableGrid!");
91	PartitionUtil.setPartition(this, (WritableGrid) partition,
92	partitionBounds);
93	}
94
95	/*
96	* (non-Javadoc)
97	*
98	* @see appl.parallel.spmd.split.SplittableResource#getSplitHeight()
99	*/
100	public int getSplitHeight() {
101	return this.getHeight();
102	}
103
104	/*
105	* (non-Javadoc)
106	*
107	* @see appl.parallel.spmd.split.SplittableResource#getSplitWidth()
108	*/
109	public int getSplitWidth() {
110	return this.getWidth();
111	}
112
113	/*
114	* (non-Javadoc)
115	*
116	* @see appl.parallel.spmd.split.DataPartition#getPartitionBounds()
117	*/
118	public Rectangle getPartitionBounds() {
119	return new Rectangle(0, 0, this.getWidth(), this.getHeight());
120	}
121
122	/*
123	* (non-Javadoc)
124	*
125	* @see appl.parallel.spmd.split.DataPartition#getEmpty()
126	*/
127	public DataPartition getEmpty(int id) {
128	return new SplittableLLProxyGrid(this.metaData, id);
129	}
130
131	}