Class WeatherDiscoveryStore

java.lang.Object

ecmwf.common.database.WeatherDiscoveryStore

public final class WeatherDiscoveryStore
extends Object

Coordinates bounded discovery using the standard ECpdsBase SQL requests.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	WeatherDiscoveryStore.Candidate
static final record	WeatherDiscoveryStore.Candidates
static final record	WeatherDiscoveryStore.Progress
static final record	WeatherDiscoveryStore.RejectedHost
static final record	WeatherDiscoveryStore.Result
static final record	WeatherDiscoveryStore.Signal

Constructor Summary

Constructors

Constructor	Description
WeatherDiscoveryStore(ECpdsBase database)

Method Summary

Modifier and Type	Method	Description
WeatherDiscoveryStore.Candidates	candidates(Set<WeatherObservation.Path> approved, Map<String,String> sourceGroups)
WeatherDiscoveryStore.Result	discover(Set<WeatherObservation.Path> approved, WeatherDiscoveryStore.Progress cursor)
WeatherDiscoveryStore.Result	discover(Set<WeatherObservation.Path> approved, WeatherDiscoveryStore.Progress cursor, long deadline)
List<WeatherDiscoveryStore.Candidate>	successfulCandidates(String source, int days, String protocol)

Methods inherited from class Object

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

Constructor Details

WeatherDiscoveryStore

public WeatherDiscoveryStore(ECpdsBase database)

Method Details

successfulCandidates

public List<WeatherDiscoveryStore.Candidate> successfulCandidates(String source,
 int days,
 String protocol)
                                                           throws DataBaseException

Throws:

DataBaseException

discover

public WeatherDiscoveryStore.Result discover(Set<WeatherObservation.Path> approved,
 WeatherDiscoveryStore.Progress cursor)
                                      throws DataBaseException

Throws:

DataBaseException

discover

public WeatherDiscoveryStore.Result discover(Set<WeatherObservation.Path> approved,
 WeatherDiscoveryStore.Progress cursor,
 long deadline)
                                      throws DataBaseException

Throws:

DataBaseException

candidates

public WeatherDiscoveryStore.Candidates candidates(Set<WeatherObservation.Path> approved,
 Map<String,String> sourceGroups)
                                            throws DataBaseException

Throws:

DataBaseException