Application: gvSIG desktop » gvSIG raster

/* gvSIG. Desktop Geographic Information System.

 *

 * Copyright ? 2007-2016 gvSIG Association

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,

 * MA  02110-1301, USA.

 *

 * For any additional information, do not hesitate to contact us

 * at info AT gvsig.com, or visit our website www.gvsig.com.

 */

package org.gvsig.fmap.dal.raster.impl;

import java.util.Iterator;

import org.cresques.cts.ICoordTrans;

import org.cresques.cts.IProjection;

import org.gvsig.fmap.dal.DataStore;

import org.gvsig.fmap.dal.exception.DataException;

import org.gvsig.fmap.dal.raster.api.RasterQuery;

import org.gvsig.fmap.dal.raster.api.RasterSet;

import org.gvsig.fmap.dal.raster.api.RasterStore;

import org.gvsig.fmap.dal.raster.api.exceptions.RasterSetInitializeException;

import org.gvsig.fmap.dal.raster.spi.RasterStoreProvider;

import org.gvsig.fmap.geom.primitive.Envelope;

import org.gvsig.fmap.geom.primitive.Point;

import org.gvsig.raster.lib.buffer.api.Band;

import org.gvsig.raster.lib.buffer.api.Band.BandByte;

import org.gvsig.raster.lib.buffer.api.Band.BandDouble;

import org.gvsig.raster.lib.buffer.api.Band.BandFloat;

import org.gvsig.raster.lib.buffer.api.Band.BandInt;

import org.gvsig.raster.lib.buffer.api.Band.BandShort;

import org.gvsig.raster.lib.buffer.api.Buffer;

import org.gvsig.raster.lib.buffer.api.FilterList;

import org.gvsig.raster.lib.buffer.api.NoData;

import org.gvsig.raster.lib.buffer.api.exceptions.BandException;

import org.gvsig.raster.lib.buffer.api.exceptions.BufferException;

import org.gvsig.raster.lib.buffer.api.statistics.Statistics;

import org.gvsig.tools.exception.BaseException;

import org.gvsig.tools.locator.LocatorException;

import org.gvsig.tools.observer.Observable;

import org.gvsig.tools.observer.Observer;

import org.gvsig.tools.task.SimpleTaskStatus;

import org.gvsig.tools.visitor.VisitCanceledException;

import org.gvsig.tools.visitor.Visitor;

import org.gvsig.tools.visitor.impl.AbstractIndexedVisitable;

/**

 * Implements RasterSet

 * 

 * @author dmartinezizquierdo

 *

 */

public class DefaultRasterSet extends AbstractIndexedVisitable implements RasterSet, Observer {

    private DefaultRasterStore store;

    protected RasterQuery query;

    protected Buffer buffer;

    /**

     * Creates a RasterSet with the raster filtered by the query

     * 

     * @param store

     * @param query

     * @throws DataException

     */

    public DefaultRasterSet(RasterStore store, RasterQuery query) throws DataException {

        this.store = (DefaultRasterStore) store;

        this.query = query;

        RasterStoreProvider provider = this.store.getProvider();

        try {

            buffer = provider.createBuffer(query);

            // Filter buffer by raster query

            if (query != null) {

                if (query.getClip() != null) {

                    buffer = buffer.clip(query.getClip());

                }

            }

        } catch (BufferException e) {

            throw new RasterSetInitializeException(e);

        }

        this.store.addObserver(this);

    }

    @Override

    public void filter(FilterList filterList) {

        this.buffer.filter(filterList);

    }

    @Override

    public int getBandCount() {

        return this.buffer.getBandCount();

    }

    @Override

    public Band[] getBands() {

        return this.buffer.getBands();

    }

    @Override

    public int getColumns() {

        return this.buffer.getColumns();

    }

    @Override

    public int getRows() {

        return this.buffer.getRows();

    }

    @Override

    public Envelope getEnvelope() {

        return this.buffer.getEnvelope();

    }

    @Override

    public IProjection getProjection() {

        return this.buffer.getProjection();

    }

    @Override

    public boolean isInside(int cellX, int cellY) {

        return this.buffer.isInside(cellX, cellY);

    }

    @Override

    public boolean isInside(Point point) {

        return this.buffer.isInside(point);

    }

    @Override

    public void addBand(Band band) {

        this.buffer.addBand(band);

    }

    @Override

    public void setBand(int pos, Band band) throws BandException {

        this.buffer.setBand(pos, band);

    }

    @Override

    public void removeBand(int pos) {

        this.buffer.removeBand(pos);

    }

    @Override

    public Band getBand(int pos) {

        return this.buffer.getBand(pos);

    }

    @Override

    public BandByte getBandByte(int pos) {

        return this.buffer.getBandByte(pos);

    }

    @Override

    public BandShort getBandShort(int pos) {

        return this.buffer.getBandShort(pos);

    }

    @Override

    public BandInt getBandInt(int pos) {

        return this.buffer.getBandInt(pos);

    }

    @Override

    public BandFloat getBandFloat(int pos) {

        return this.buffer.getBandFloat(pos);

    }

    @Override

    public BandDouble getBandDouble(int pos) {

        return this.buffer.getBandDouble(pos);

    }

    @Override

    public void switchBands(int[] positions) {

        this.buffer.switchBands(positions);

    }

    @Override

    public void switchBands(int pos1, int pos2) {

        this.buffer.switchBands(pos1, pos2);

    }

    @Override

    public Buffer createInterpolated(int rows, int columns, int interpolationMode,

        SimpleTaskStatus status) throws LocatorException, BufferException {

        return this.buffer.createInterpolated(rows, columns, interpolationMode, status);

    }

    @Override

    public Buffer convert(ICoordTrans ct, SimpleTaskStatus status) throws BufferException {

        return this.buffer.convert(ct, status);

    }

    @Override

    public int[] getBandTypes() {

        return this.buffer.getBandTypes();

    }

    @Override

    public NoData[] getBandNoData() {

        return this.buffer.getBandNoData();

    }

    @Override

    public Buffer clip(Envelope envelope) throws BufferException {

        return this.buffer.clip(envelope);

    }

    @Override

    public double getPixelSizeX() {

        return this.buffer.getPixelSizeX();

    }

    @Override

    public double getPixelSizeY() {

        return this.buffer.getPixelSizeY();

    }

    @Override

    public Statistics getStatistics(SimpleTaskStatus status) {

        return this.buffer.getStatistics(status);

    }

    @Override

    public void addObserver(Observer o) {

        this.buffer.addObserver(o);

    }

    @Override

    public void deleteObserver(Observer o) {

        this.buffer.deleteObserver(o);

    }

    @Override

    public void deleteObservers() {

        this.buffer.deleteObservers();

    }

    @Override

    public Iterator<Band> iterator() {

        return this.buffer.iterator();

    }

    @Override

    public boolean isFromStore(DataStore store) {

        return this.store.equals(store);

    }

    @Override

    public void dispose() {

        this.store.deleteObserver(this);

        this.store = null;

        this.query = null;

        this.buffer = null;

    }

    @Override

    public void update(Observable observable, Object notification) {

        // Do nothing

    }

    @Override

    protected void doAccept(Visitor visitor, long firstValueIndex) throws VisitCanceledException,

        BaseException {

        DefaultRasterKernel kernel = new DefaultRasterKernel(this.buffer);

        for (int row = 0; row < this.buffer.getRows(); row++) {

            for (int column = 0; column < this.buffer.getColumns(); column++) {

                kernel.set(row, column);

                visitor.visit(kernel);

            }

        }

    }

}