@Test public void testIngest() throws Exception { JAIExt.initJAIEXT(); final Landsat8BasicCommandLineOptions analyzeOptions = new Landsat8BasicCommandLineOptions(); analyzeOptions.setNBestScenes(1); analyzeOptions.setCqlFilter( "BBOX(shape,-76.6,42.34,-76.4,42.54) and band='BQA' and sizeMB < 1"); analyzeOptions.setUseCachedScenes(true); analyzeOptions.setWorkspaceDir(Tests.WORKSPACE_DIR); final Landsat8DownloadCommandLineOptions downloadOptions = new Landsat8DownloadCommandLineOptions(); downloadOptions.setOverwriteIfExists(false); final Landsat8RasterIngestCommandLineOptions ingestOptions = new Landsat8RasterIngestCommandLineOptions(); ingestOptions.setRetainImages(true); ingestOptions.setCreatePyramid(true); ingestOptions.setCreateHistogram(true); ingestOptions.setScale(100); final VectorOverrideCommandLineOptions vectorOverrideOptions = new VectorOverrideCommandLineOptions(); vectorOverrideOptions.setVectorStore("memorystore2"); vectorOverrideOptions.setVectorIndex("spatialindex,spatempindex"); final IngestRunner runner = new IngestRunner( analyzeOptions, downloadOptions, ingestOptions, vectorOverrideOptions, Arrays.asList("memorystore", "spatialindex")); final ManualOperationParams params = new ManualOperationParams(); params.getContext().put( ConfigOptions.PROPERTIES_FILE_CONTEXT, new File( IngestRunnerTest.class.getClassLoader().getResource( "geowave-config.properties").toURI())); createIndices(params, "memorystore"); createIndices(params, "memorystore2"); runner.runInternal(params); try (CloseableIterator<Object> results = getStorePluginOptions(params, "memorystore").createDataStore().query( QueryBuilder.newBuilder().build())) { assertTrue("Store is not empty", results.hasNext()); } }
@Override protected void runInternal(final OperationParams params) throws Exception { try { super.runInternal(params); } finally { if (sceneWriter != null) { sceneWriter.close(); } if (bandWriter != null) { bandWriter.close(); } } }
IngestRunner extends RasterIngestRunner { @Override protected void runInternal(final OperationParams params) throws Exception { try { super.runInternal(params); } finally { if (sceneWriter != null) { sceneWriter.close(); } if (bandWriter != null) { bandWriter.close(); } } } }
IngestRunner extends RasterIngestRunner { @Override protected void runInternal(final OperationParams params) throws Exception { try { super.runInternal(params); } finally { if (sceneWriter != null) { sceneWriter.close(); } if (bandWriter != null) { bandWriter.close(); } } } IngestRunner(
      final Landsat8BasicCommandLineOptions analyzeOptions,
      final Landsat8DownloadCommandLineOptions downloadOptions,
      final Landsat8RasterIngestCommandLineOptions ingestOptions,
      final VectorOverrideCommandLineOptions vectorOverrideOptions,
      final List<String> parameters); }
IngestRunner extends RasterIngestRunner { @Override protected void runInternal(final OperationParams params) throws Exception { try { super.runInternal(params); } finally { if (sceneWriter != null) { sceneWriter.close(); } if (bandWriter != null) { bandWriter.close(); } } } IngestRunner(
      final Landsat8BasicCommandLineOptions analyzeOptions,
      final Landsat8DownloadCommandLineOptions downloadOptions,
      final Landsat8RasterIngestCommandLineOptions ingestOptions,
      final VectorOverrideCommandLineOptions vectorOverrideOptions,
      final List<String> parameters);  }
IngestRunner extends RasterIngestRunner { @Override protected void runInternal(final OperationParams params) throws Exception { try { super.runInternal(params); } finally { if (sceneWriter != null) { sceneWriter.close(); } if (bandWriter != null) { bandWriter.close(); } } } IngestRunner(
      final Landsat8BasicCommandLineOptions analyzeOptions,
      final Landsat8DownloadCommandLineOptions downloadOptions,
      final Landsat8RasterIngestCommandLineOptions ingestOptions,
      final VectorOverrideCommandLineOptions vectorOverrideOptions,
      final List<String> parameters);   }