uk.ac.starlink.table.RowSequence
, ConeQueryRowSequence
, ConeResultRowSequence
public class ParallelResultRowSequence extends java.lang.Object implements ConeResultRowSequence
Modifier and Type | Field | Description |
---|---|---|
static int |
DEFAULT_MAXPAR |
Default maximum value for the number of threads that should be
permitted for a query.
|
static java.lang.String |
MAXPAR_PROP |
Name of system property "service.maxparallel" which may be used to adjust the
maximum parallelism.
|
Constructor | Description |
---|---|
ParallelResultRowSequence(ConeQueryRowSequence querySeq,
ConeSearcher coneSearcher,
ConeErrorPolicy errAct,
Coverage coverage,
boolean bestOnly,
boolean distFilter,
java.lang.String distanceCol,
int parallelism) |
Constructor.
|
Modifier and Type | Method | Description |
---|---|---|
void |
close() |
|
java.lang.Object |
getCell(int icol) |
|
uk.ac.starlink.table.StarTable |
getConeResult() |
Returns the result of the cone search for the current row of this
sequence.
|
double |
getDec() |
Get central declination for the current row's cone search request
in degrees.
|
long |
getIndex() |
Get the index in the underlying table to which the current row relates.
|
static int |
getMaxParallelism() |
Returns the maximum parallelism value which should permitted in this JVM.
|
double |
getRa() |
Get central right ascension for the current row's cone search request
in degrees.
|
double |
getRadius() |
Get search radius for the current row's cone search request
in degrees.
|
java.lang.Object[] |
getRow() |
|
boolean |
next() |
public static final int DEFAULT_MAXPAR
MAXPAR_PROP
,
getMaxParallelism()
,
Constant Field Valuespublic static final java.lang.String MAXPAR_PROP
DEFAULT_MAXPAR
,
getMaxParallelism()
,
Constant Field Valuespublic ParallelResultRowSequence(ConeQueryRowSequence querySeq, ConeSearcher coneSearcher, ConeErrorPolicy errAct, Coverage coverage, boolean bestOnly, boolean distFilter, java.lang.String distanceCol, int parallelism)
querySeq
- sequence providing cone search query parametersconeSearcher
- cone search implementationerrAct
- defines action on cone search invocation errorcoverage
- coverage for results, or nullbestOnly
- whether all results or just best are requireddistFilter
- true to perform post-query filtering on results
based on the distance between the query position
and the result row positiondistanceCol
- name of column to hold distance information
in output table, or nullparallelism
- number of concurrent querying threadspublic boolean next() throws java.io.IOException
next
in interface uk.ac.starlink.table.RowSequence
java.io.IOException
public java.lang.Object getCell(int icol) throws java.io.IOException
getCell
in interface uk.ac.starlink.table.RowSequence
java.io.IOException
public java.lang.Object[] getRow() throws java.io.IOException
getRow
in interface uk.ac.starlink.table.RowSequence
java.io.IOException
public double getRa() throws java.io.IOException
ConeQueryRowSequence
getRa
in interface ConeQueryRowSequence
java.io.IOException
public double getDec() throws java.io.IOException
ConeQueryRowSequence
getDec
in interface ConeQueryRowSequence
java.io.IOException
public double getRadius() throws java.io.IOException
ConeQueryRowSequence
getRadius
in interface ConeQueryRowSequence
java.io.IOException
public long getIndex() throws java.io.IOException
ConeQueryRowSequence
next
.getIndex
in interface ConeQueryRowSequence
java.io.IOException
public uk.ac.starlink.table.StarTable getConeResult() throws java.io.IOException
ConeResultRowSequence
ConeMatcher.getConeResult(uk.ac.starlink.ttools.cone.ConeSearcher, uk.ac.starlink.ttools.cone.ConeErrorPolicy, boolean, boolean, java.lang.String, double, double, double)
.
If no records in the cone are found, the return value may either be null or (preferably) an empty table with the correct columns.
getConeResult
in interface ConeResultRowSequence
java.io.IOException
public void close() throws java.io.IOException
close
in interface uk.ac.starlink.table.RowSequence
java.io.IOException
public static int getMaxParallelism()
MAXPAR_PROP
system
property.
Note that this method is not used by this class, i.e. the maximum
is not imposed here, it should be imposed by calling code.Copyright © 2018 Central Laboratory of the Research Councils. All Rights Reserved.