ome.smuggler.core.service.imports.impl

Class ImportTrigger

java.lang.Object

ome.smuggler.core.service.imports.impl.ImportTrigger

All Implemented Interfaces:

ImportRequestor

public class ImportTrigger
extends java.lang.Object
implements ImportRequestor

Implements the ImportRequestor.

Constructor Summary

Constructors

Constructor and Description
ImportTrigger(ImportEnv env)

Method Summary

Modifier and Type	Method and Description
ImportBatch	enqueue(java.util.stream.Stream<ImportInput> requests) Adds the import requests to the queue and returns immediately.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface ome.smuggler.core.service.imports.ImportRequestor

enqueue

Constructor Detail

ImportTrigger

public ImportTrigger(ImportEnv env)

Method Detail

enqueue

public ImportBatch enqueue(java.util.stream.Stream<ImportInput> requests)

Description copied from interface: ImportRequestor

Adds the import requests to the queue and returns immediately. The requests will subsequently be fetched from the import queue and serviced as needed. What is added to the queue is an instance of QueuedImport for each import request.

Specified by:

enqueue in interface ImportRequestor

Parameters:

requests - detail what to import.

Returns:

an object with all the QueuedImports, each having its own ImportId through which you can get hold of the corresponding import run, for example to get some feedback on progress.