GroupAssigmentJobRunner extends GeoWaveAnalyticJobRunner { @Override public int run(final Configuration config, final PropertyManagement runTimeProperties) throws Exception { final DataStorePluginOptions dataStoreOptions = ((PersistableStore) runTimeProperties.getProperty( StoreParam.INPUT_STORE)).getDataStoreOptions(); GeoWaveInputFormat.setStoreOptions(config, dataStoreOptions); runTimeProperties.setConfig( new ParameterEnum[] { CentroidParameters.Centroid.EXTRACTOR_CLASS, CentroidParameters.Centroid.WRAPPER_FACTORY_CLASS,}, config, GroupAssignmentMapReduce.class); NestedGroupCentroidAssignment.setParameters(config, getScope(), runTimeProperties); CentroidManagerGeoWave.setParameters(config, getScope(), runTimeProperties); NestedGroupCentroidAssignment.setZoomLevel(config, getScope(), zoomLevel); return super.run(config, runTimeProperties); } GroupAssigmentJobRunner(); void setZoomLevel(final int zoomLevel); @Override void configure(final Job job); @Override Class<?> getScope(); @Override int run(final Configuration config, final PropertyManagement runTimeProperties); @Override Collection<ParameterEnum<?>> getParameters();  }
@Test public void test() throws Exception { runner.run(runTimeProperties); }