public class GaussianCellMapper extends org.apache.hadoop.mapreduce.Mapper<GeoWaveInputKey,org.opengis.feature.simple.SimpleFeature,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable>
Modifier and Type | Class and Description |
---|---|
static class |
GaussianCellMapper.LevelStore |
Modifier and Type | Field and Description |
---|---|
protected static String |
CQL_FILTER_KEY |
protected org.opengis.filter.Filter |
filter |
protected String |
inputCrsCode |
protected Map<Integer,GaussianCellMapper.LevelStore> |
levelStoreMap |
protected int |
maxLevel |
protected int |
minLevel |
protected String |
outputCrsCode |
protected org.opengis.referencing.operation.MathTransform |
transform |
protected GaussianFilter.ValueRange[] |
valueRangePerDimension |
Constructor and Description |
---|
GaussianCellMapper() |
Modifier and Type | Method and Description |
---|---|
protected void |
incrementLevelStore(int level,
org.locationtech.jts.geom.Point pt,
org.opengis.feature.simple.SimpleFeature feature,
GaussianFilter.ValueRange[] valueRangePerDimension) |
protected void |
map(GeoWaveInputKey key,
org.opengis.feature.simple.SimpleFeature value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
protected void |
populateLevelStore(org.apache.hadoop.mapreduce.Mapper.Context context,
int numXPosts,
int numYPosts,
int level) |
protected void |
setup(org.apache.hadoop.mapreduce.Mapper.Context context) |
protected static final String CQL_FILTER_KEY
protected int minLevel
protected int maxLevel
protected org.opengis.filter.Filter filter
protected Map<Integer,GaussianCellMapper.LevelStore> levelStoreMap
protected GaussianFilter.ValueRange[] valueRangePerDimension
protected String inputCrsCode
protected String outputCrsCode
protected org.opengis.referencing.operation.MathTransform transform
protected void setup(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
setup
in class org.apache.hadoop.mapreduce.Mapper<GeoWaveInputKey,org.opengis.feature.simple.SimpleFeature,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable>
IOException
InterruptedException
protected void populateLevelStore(org.apache.hadoop.mapreduce.Mapper.Context context, int numXPosts, int numYPosts, int level)
protected void map(GeoWaveInputKey key, org.opengis.feature.simple.SimpleFeature value, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
map
in class org.apache.hadoop.mapreduce.Mapper<GeoWaveInputKey,org.opengis.feature.simple.SimpleFeature,org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable>
IOException
InterruptedException
protected void incrementLevelStore(int level, org.locationtech.jts.geom.Point pt, org.opengis.feature.simple.SimpleFeature feature, GaussianFilter.ValueRange[] valueRangePerDimension)
Copyright © 2013–2020. All rights reserved.