Class EarthdataHDFPointMapper

  • All Implemented Interfaces:
    Serializable, org.apache.spark.api.java.function.FlatMapFunction<Iterator<String>,​org.locationtech.jts.geom.Geometry>

    public class EarthdataHDFPointMapper
    extends Object
    implements org.apache.spark.api.java.function.FlatMapFunction<Iterator<String>,​org.locationtech.jts.geom.Geometry>
    The Class EarthdataHDFPointMapper.
    See Also:
    Serialized Form
    • Constructor Detail

      • EarthdataHDFPointMapper

        public EarthdataHDFPointMapper​(int offset,
                                       int increment,
                                       String rootGroupName,
                                       String[] dataVariableList,
                                       String dataVariableName,
                                       boolean switchCoordinateXY)
        Instantiates a new earthdata HDF point mapper.
        Parameters:
        offset - the offset
        increment - the increment
        rootGroupName - the root group name
        dataVariableList - the data variable list
        dataVariableName - the data variable name
        switchCoordinateXY - the switch coordinate XY
      • EarthdataHDFPointMapper

        public EarthdataHDFPointMapper​(int offset,
                                       int increment,
                                       String rootGroupName,
                                       String[] dataVariableList,
                                       String dataVariableName)
        Instantiates a new earthdata HDF point mapper.
        Parameters:
        offset - the offset
        increment - the increment
        rootGroupName - the root group name
        dataVariableList - the data variable list
        dataVariableName - the data variable name
      • EarthdataHDFPointMapper

        public EarthdataHDFPointMapper​(int offset,
                                       int increment,
                                       String rootGroupName,
                                       String[] dataVariableList,
                                       String dataVariableName,
                                       boolean switchCoordinateXY,
                                       String urlPrefix)
        Instantiates a new earthdata HDF point mapper.
        Parameters:
        offset - the offset
        increment - the increment
        rootGroupName - the root group name
        dataVariableList - the data variable list
        dataVariableName - the data variable name
        switchCoordinateXY - the switch coordinate XY
        urlPrefix - the url prefix
      • EarthdataHDFPointMapper

        public EarthdataHDFPointMapper​(int offset,
                                       int increment,
                                       String rootGroupName,
                                       String[] dataVariableList,
                                       String dataVariableName,
                                       String urlPrefix)
        Instantiates a new earthdata HDF point mapper.
        Parameters:
        offset - the offset
        increment - the increment
        rootGroupName - the root group name
        dataVariableList - the data variable list
        dataVariableName - the data variable name
        urlPrefix - the url prefix
    • Method Detail

      • call

        public Iterator<org.locationtech.jts.geom.Geometry> call​(Iterator<String> stringIterator)
                                                          throws Exception
        Specified by:
        call in interface org.apache.spark.api.java.function.FlatMapFunction<Iterator<String>,​org.locationtech.jts.geom.Geometry>
        Throws:
        Exception