public class ArchiveStreamCombiner extends Object implements ArchiveDataQueryResult
Modifier and Type | Class and Description |
---|---|
private static class |
ArchiveStreamCombiner.CombinedStream |
private static class |
ArchiveStreamCombiner.RelativeCombinedStream |
Modifier and Type | Field and Description |
---|---|
private List<Integer> |
_numStreamsToCombine |
private List<ArchiveDataSpecification> |
_originalSpecs |
private ArchiveDataQueryResult |
_rawResult |
Constructor and Description |
---|
ArchiveStreamCombiner() |
Modifier and Type | Method and Description |
---|---|
void |
addQuery(int size,
ArchiveDataSpecification spec)
Wird mehrmals aufgerufen.
|
private ArchiveDataStream[] |
combineStreams(ArchiveDataStream[] streams) |
String |
getErrorMessage()
Bestimmt eine Fehlernachricht, falls die entsprechende Archivanfrage nicht erfolgreich war.
|
ArchiveDataStream[] |
getStreams()
Bestimmt die Ergebnisdatenströme der entsprechenden Archivdatenspezifikationen aus der Archivanfrage.
|
boolean |
isRequestSuccessful()
Bestimmt, ob die Archivanfrage erfolgreich war.
|
void |
setRawResult(ArchiveDataQueryResult rawResult) |
private ArchiveDataQueryResult _rawResult
private List<ArchiveDataSpecification> _originalSpecs
public ArchiveDataStream[] getStreams() throws InterruptedException, IllegalStateException
ArchiveDataQueryResult
getStreams
in interface ArchiveDataQueryResult
InterruptedException
- Falls der aufrufende Thread unterbrochen wurde, während auf die entsprechende
Antwortnachricht aus dem Archivsystem gewartet wurde.IllegalStateException
- Falls die Archivanfrage nicht erfolgreich war und keine Ergebnisdatenströme bestimmt
werden können.ArchiveRequestManager.request(ArchiveQueryPriority,ArchiveDataSpecification)
,
ArchiveRequestManager.request(ArchiveQueryPriority, java.util.List)
private ArchiveDataStream[] combineStreams(ArchiveDataStream[] streams)
public boolean isRequestSuccessful() throws InterruptedException
ArchiveQueryResult
ArchiveQueryResult.getErrorMessage()
abgerufen werden kann.isRequestSuccessful
in interface ArchiveQueryResult
true
, falls die Anfrage erfolgreich war, sonst false
.InterruptedException
- Falls der aufrufende Thread unterbrochen wurde, während auf die entsprechende
Antwortnachricht aus dem Archivsystem gewartet wurde.public String getErrorMessage() throws InterruptedException
ArchiveQueryResult
getErrorMessage
in interface ArchiveQueryResult
InterruptedException
- Falls der aufrufende Thread unterbrochen wurde, während auf die entsprechende
Antwortnachricht aus dem Archivsystem gewartet wurde.public void setRawResult(ArchiveDataQueryResult rawResult)
public void addQuery(int size, ArchiveDataSpecification spec)
size
- Anzahl zu bündelnder Streams, bei Anfragen ohne Pid 1spec
- Originale Anfrage