Package uk.ac.starlink.table
Class RowRunner
java.lang.Object
uk.ac.starlink.table.RowRunner
Manages potentially parallel processing of StarTable row data.
- Since:
- 5 Aug 2020
- Author:
- Mark Taylor
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final RowRunner
General purpose instance; will be parallel for suitable environments.static final uk.ac.starlink.util.SplitPolicy
Default split policy.static final RowRunner
Testing instance; force parallel processing even for small tables.static final RowRunner
Sequential-only instance; no parallel processing. -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription<A> A
collect
(RowCollector<A> collector, StarTable table) Performs a collection operation on table rows.createRowSplittable
(StarTable table) Acquires a splittable row sequence from a table.uk.ac.starlink.util.SplitProcessor
<RowSplittable> Returns the processor on which this runner is based.
-
Field Details
-
DFLT_POLICY
public static final uk.ac.starlink.util.SplitPolicy DFLT_POLICYDefault split policy. -
DEFAULT
General purpose instance; will be parallel for suitable environments. -
SEQUENTIAL
Sequential-only instance; no parallel processing. -
PARTEST
Testing instance; force parallel processing even for small tables.
-
-
Constructor Details
-
RowRunner
public RowRunner(uk.ac.starlink.util.SplitProcessor<?> processor) Constructor.- Parameters:
processor
- processor that manages the executions
-
-
Method Details
-
collect
Performs a collection operation on table rows.- Parameters:
collector
- collector defining operationtable
- table supplying data- Returns:
- result of collection
- Throws:
IOException
-
createRowSplittable
Acquires a splittable row sequence from a table. The default implementation just callsStarTable.getRowSplittable()
, but this may be overridden if required.- Parameters:
table
- input table- Returns:
- potentially splittable row sequence
- Throws:
IOException
-
getSplitProcessor
Returns the processor on which this runner is based.- Returns:
- processor
-