org.n52.sos.encode

Class AbstractIoosNetcdfEncoder

java.lang.Object

org.n52.sos.encode.AbstractIoosNetcdfEncoder

All Implemented Interfaces:

Encoder<org.n52.sos.response.BinaryAttachmentResponse,Object>, ObservationEncoder<org.n52.sos.response.BinaryAttachmentResponse,Object>, org.n52.sos.service.ConformanceClass

Direct Known Subclasses:

IoosNetcdfEncoder, IoosNetcdfZipEncoder

public abstract class AbstractIoosNetcdfEncoder
extends Object
implements ObservationEncoder<org.n52.sos.response.BinaryAttachmentResponse,Object>

Field Summary

Fields

Modifier and Type	Field and Description
private static int	CHUNK_SIZE_TIME
private static Set<String>	CONFORMANCE_CLASSES
private static String	DEFINITION
private static double	DOUBLE_FILL_VALUE
private Set<EncoderKey>	ENCODER_KEYS
private static org.slf4j.Logger	LOGGER
private Map<String,Map<String,Set<String>>>	SUPPORTED_RESPONSE_FORMATS
private static Map<org.n52.sos.service.ServiceConstants.SupportedTypeKey,Set<String>>	SUPPORTED_TYPES

Constructor Summary

Constructors

Constructor and Description
AbstractIoosNetcdfEncoder()

Method Summary

Modifier and Type	Method and Description
private static void	addAttributeIfClassifierExists(ucar.nc2.Variable variable, org.n52.sos.ogc.sensorML.System system, String classifierDefinition, String attributeName)
private static void	addAttributeIfIdentifierExists(ucar.nc2.Variable variable, org.n52.sos.ogc.sensorML.System system, String identifierDefinition, String attributeName)
void	addNamespacePrefixToMap(Map<String,String> nameSpacePrefixMap)
org.n52.sos.response.BinaryAttachmentResponse	encode(Object element)
org.n52.sos.response.BinaryAttachmentResponse	encode(Object objectToEncode, Map<org.n52.sos.ogc.sos.SosConstants.HelperValues,String> additionalValues)
private org.n52.sos.response.BinaryAttachmentResponse	encodeGetObsResponse(List<org.n52.sos.ogc.om.OmObservation> sosObservationCollection)
protected abstract org.n52.sos.response.BinaryAttachmentResponse	encodeIoosObsToNetcdf(List<IoosSosObservation> ioosSosObsList)
protected void	encodeSensorDataToNetcdf(File netcdfFile, AbstractSensorDataset sensorDataset)
private String	getCfRole(ucar.nc2.constants.CF.FeatureType featureType)
private static String	getClassifier(org.n52.sos.ogc.sensorML.System system, String classifierDefinition)
Set<String>	getConformanceClasses()
private static org.joda.time.DateTime	getDateTime(org.n52.sos.ogc.gml.time.Time time)
private static org.n52.sos.ds.AbstractDescribeSensorDAO	getDescribeSensorDAO()
private static int[]	getDimShapes(List<ucar.nc2.Dimension> dims)
Set<EncoderKey>	getEncoderKeyType()
protected String	getFilename(AbstractSensorDataset sensorDataset)
private static String	getIdentifier(org.n52.sos.ogc.sensorML.System system, String identifierDefinition)
private String	getNodcTemplateVersion(ucar.nc2.constants.CF.FeatureType featureType)
private static org.n52.sos.ogc.sensorML.SmlResponsibleParty	getResponsibleParty(List<org.n52.sos.ogc.sensorML.SmlContact> contacts, String contactRole)
private static org.n52.sos.ogc.sensorML.SmlResponsibleParty	getResponsibleParty(org.n52.sos.ogc.sensorML.System system, String contactRole)
Set<org.n52.sos.w3c.SchemaLocation>	getSchemaLocations()
private static double	getSecondsSinceEpoch(org.n52.sos.ogc.gml.time.Time time)
private static org.n52.sos.ogc.sensorML.System	getSensorSystem(String procedure)
Set<String>	getSupportedResponseFormats(String service, String version)
Map<org.n52.sos.service.ServiceConstants.SupportedTypeKey,Set<String>>	getSupportedTypes()
private static boolean	hasDimension(List<ucar.nc2.Dimension> dims, ucar.nc2.Dimension dim)
private static void	initArrayWithFillValue(ucar.ma2.Array array, Object fillValue)
boolean	isObservationAndMeasurmentV20Type()
protected static String	makeDateSafe(org.joda.time.DateTime dt)
boolean	shouldObservationsWithSameXBeMerged()
boolean	supportsResultStreamingForMergedValues()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.n52.sos.encode.Encoder

getContentType

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

DEFINITION

private static final String DEFINITION

See Also:

Constant Field Values

DOUBLE_FILL_VALUE

private static final double DOUBLE_FILL_VALUE

See Also:

Constant Field Values

CHUNK_SIZE_TIME

private static final int CHUNK_SIZE_TIME

See Also:

Constant Field Values

SUPPORTED_TYPES

private static final Map<org.n52.sos.service.ServiceConstants.SupportedTypeKey,Set<String>> SUPPORTED_TYPES

CONFORMANCE_CLASSES

private static final Set<String> CONFORMANCE_CLASSES

SUPPORTED_RESPONSE_FORMATS

private final Map<String,Map<String,Set<String>>> SUPPORTED_RESPONSE_FORMATS

ENCODER_KEYS

private final Set<EncoderKey> ENCODER_KEYS

Constructor Detail

AbstractIoosNetcdfEncoder

public AbstractIoosNetcdfEncoder()

Method Detail

getEncoderKeyType

public Set<EncoderKey> getEncoderKeyType()

Specified by:

getEncoderKeyType in interface Encoder<org.n52.sos.response.BinaryAttachmentResponse,Object>

getSupportedTypes

public Map<org.n52.sos.service.ServiceConstants.SupportedTypeKey,Set<String>> getSupportedTypes()

Specified by:

getSupportedTypes in interface Encoder<org.n52.sos.response.BinaryAttachmentResponse,Object>

getConformanceClasses

public Set<String> getConformanceClasses()

Specified by:

getConformanceClasses in interface org.n52.sos.service.ConformanceClass

addNamespacePrefixToMap

public void addNamespacePrefixToMap(Map<String,String> nameSpacePrefixMap)

Specified by:

addNamespacePrefixToMap in interface Encoder<org.n52.sos.response.BinaryAttachmentResponse,Object>

isObservationAndMeasurmentV20Type

public boolean isObservationAndMeasurmentV20Type()

Specified by:

isObservationAndMeasurmentV20Type in interface ObservationEncoder<org.n52.sos.response.BinaryAttachmentResponse,Object>

getSupportedResponseFormats

public Set<String> getSupportedResponseFormats(String service,
                                               String version)

Specified by:

getSupportedResponseFormats in interface ObservationEncoder<org.n52.sos.response.BinaryAttachmentResponse,Object>

shouldObservationsWithSameXBeMerged

public boolean shouldObservationsWithSameXBeMerged()

Specified by:

shouldObservationsWithSameXBeMerged in interface ObservationEncoder<org.n52.sos.response.BinaryAttachmentResponse,Object>

getSchemaLocations

public Set<org.n52.sos.w3c.SchemaLocation> getSchemaLocations()

Specified by:

getSchemaLocations in interface Encoder<org.n52.sos.response.BinaryAttachmentResponse,Object>

encode

public org.n52.sos.response.BinaryAttachmentResponse encode(Object element)
                                                     throws org.n52.sos.ogc.ows.OwsExceptionReport

Specified by:

encode in interface Encoder<org.n52.sos.response.BinaryAttachmentResponse,Object>

Throws:

org.n52.sos.ogc.ows.OwsExceptionReport

encode

public org.n52.sos.response.BinaryAttachmentResponse encode(Object objectToEncode,
                                                            Map<org.n52.sos.ogc.sos.SosConstants.HelperValues,String> additionalValues)
                                                     throws org.n52.sos.ogc.ows.OwsExceptionReport

Specified by:

encode in interface Encoder<org.n52.sos.response.BinaryAttachmentResponse,Object>

Throws:

org.n52.sos.ogc.ows.OwsExceptionReport

encodeGetObsResponse

private org.n52.sos.response.BinaryAttachmentResponse encodeGetObsResponse(List<org.n52.sos.ogc.om.OmObservation> sosObservationCollection)
                                                                    throws org.n52.sos.ogc.ows.OwsExceptionReport

Throws:

org.n52.sos.ogc.ows.OwsExceptionReport

encodeIoosObsToNetcdf

protected abstract org.n52.sos.response.BinaryAttachmentResponse encodeIoosObsToNetcdf(List<IoosSosObservation> ioosSosObsList)
                                                                                throws org.n52.sos.ogc.ows.OwsExceptionReport

Throws:

org.n52.sos.ogc.ows.OwsExceptionReport

encodeSensorDataToNetcdf

protected void encodeSensorDataToNetcdf(File netcdfFile,
                                        AbstractSensorDataset sensorDataset)
                                 throws org.n52.sos.ogc.ows.OwsExceptionReport

Throws:

org.n52.sos.ogc.ows.OwsExceptionReport

getNodcTemplateVersion

private String getNodcTemplateVersion(ucar.nc2.constants.CF.FeatureType featureType)
                               throws org.n52.sos.exception.CodedException

Throws:

org.n52.sos.exception.CodedException

getCfRole

private String getCfRole(ucar.nc2.constants.CF.FeatureType featureType)
                  throws org.n52.sos.exception.CodedException

Throws:

org.n52.sos.exception.CodedException

getDateTime

private static org.joda.time.DateTime getDateTime(org.n52.sos.ogc.gml.time.Time time)
                                           throws org.n52.sos.exception.CodedException

Throws:

org.n52.sos.exception.CodedException

getSecondsSinceEpoch

private static double getSecondsSinceEpoch(org.n52.sos.ogc.gml.time.Time time)
                                    throws org.n52.sos.exception.CodedException

Throws:

org.n52.sos.exception.CodedException

getDimShapes

private static int[] getDimShapes(List<ucar.nc2.Dimension> dims)

hasDimension

private static boolean hasDimension(List<ucar.nc2.Dimension> dims,
                                    ucar.nc2.Dimension dim)

initArrayWithFillValue

private static void initArrayWithFillValue(ucar.ma2.Array array,
                                           Object fillValue)

getSensorSystem

private static org.n52.sos.ogc.sensorML.System getSensorSystem(String procedure)
                                                        throws org.n52.sos.ogc.ows.OwsExceptionReport

Throws:

org.n52.sos.ogc.ows.OwsExceptionReport

getDescribeSensorDAO

private static org.n52.sos.ds.AbstractDescribeSensorDAO getDescribeSensorDAO()
                                                                      throws org.n52.sos.exception.CodedException

Throws:

org.n52.sos.exception.CodedException

getIdentifier

private static String getIdentifier(org.n52.sos.ogc.sensorML.System system,
                                    String identifierDefinition)

addAttributeIfIdentifierExists

private static void addAttributeIfIdentifierExists(ucar.nc2.Variable variable,
                                                   org.n52.sos.ogc.sensorML.System system,
                                                   String identifierDefinition,
                                                   String attributeName)

getClassifier

private static String getClassifier(org.n52.sos.ogc.sensorML.System system,
                                    String classifierDefinition)

addAttributeIfClassifierExists

private static void addAttributeIfClassifierExists(ucar.nc2.Variable variable,
                                                   org.n52.sos.ogc.sensorML.System system,
                                                   String classifierDefinition,
                                                   String attributeName)

getResponsibleParty

private static org.n52.sos.ogc.sensorML.SmlResponsibleParty getResponsibleParty(org.n52.sos.ogc.sensorML.System system,
                                                                                String contactRole)

getResponsibleParty

private static org.n52.sos.ogc.sensorML.SmlResponsibleParty getResponsibleParty(List<org.n52.sos.ogc.sensorML.SmlContact> contacts,
                                                                                String contactRole)

makeDateSafe

protected static String makeDateSafe(org.joda.time.DateTime dt)

supportsResultStreamingForMergedValues

public boolean supportsResultStreamingForMergedValues()

Specified by:

supportsResultStreamingForMergedValues in interface ObservationEncoder<org.n52.sos.response.BinaryAttachmentResponse,Object>

getFilename

protected String getFilename(AbstractSensorDataset sensorDataset)
                      throws org.n52.sos.ogc.ows.OwsExceptionReport

Throws:

org.n52.sos.ogc.ows.OwsExceptionReport