org.locationtech.geomesa.jobs.mapreduce
Gets splits for a job.
Gets splits for a job.
Our delegated AccumuloInputFormat creates a split for each range - because we set a lot of ranges in geomesa, that creates too many mappers. Instead, we try to group the ranges by tservers. We use the number of shards in the schema as a proxy for number of tservers.
Input format that allows processing of simple features from GeoMesa based on a CQL query