au.gov.amsa.geo.distance

Class DistanceTravelledCalculator

java.lang.Object

au.gov.amsa.geo.distance.DistanceTravelledCalculator

public class DistanceTravelledCalculator
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DistanceTravelledCalculator.CalculationResult

Constructor Summary

Constructors

Constructor and Description
DistanceTravelledCalculator(Options options, DistanceCalculationMetrics metrics)

Method Summary

Modifier and Type	Method and Description
static rx.Observable<CellValue>	calculateDensityByCellFromFiles(Options options, rx.Observable<java.io.File> files, int horizontal, int vertical, DistanceCalculationMetrics metrics)
rx.Observable<CellAndDistance>	calculateDistanceByCellFromFiles(rx.Observable<java.io.File> files) Returns distinct cells and the the total nautical miles travelled in that cell.
static DistanceTravelledCalculator.CalculationResult	calculateTrafficDensity(Options options, rx.Observable<java.io.File> files)
static DistanceTravelledCalculator.CalculationResult	calculateTrafficDensity(Options options, rx.Observable<java.io.File> files, int horizontal, int vertical)
DistanceCalculationMetrics	getMetrics()
static rx.Observable<Options>	partition(Options options, int horizontal, int vertical) Returns a sequence of Options that are same as the source apart from the Bounds which are partitioned according to horizontal and vertical parameters.
static void	saveCalculationResultAsNetcdf(Options options, DistanceTravelledCalculator.CalculationResult calculationResult, java.lang.String filename)
static void	saveCalculationResultAsText(Options options, DistanceTravelledCalculator.CalculationResult calculationResult, java.lang.String filename)

Methods inherited from class java.lang.Object

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

Constructor Detail

DistanceTravelledCalculator

public DistanceTravelledCalculator(Options options,
                                   DistanceCalculationMetrics metrics)

Method Detail

calculateDistanceByCellFromFiles

public rx.Observable<CellAndDistance> calculateDistanceByCellFromFiles(rx.Observable<java.io.File> files)

Returns distinct cells and the the total nautical miles travelled in that cell. Uses RxJava Observables to maximize throughput and will scale to use all available processors and to handle a large number of files (number of open file handles should be limited by number of available processors).

Parameters:

files -

Returns:

getMetrics

public DistanceCalculationMetrics getMetrics()

calculateDensityByCellFromFiles

public static rx.Observable<CellValue> calculateDensityByCellFromFiles(Options options,
                                                                       rx.Observable<java.io.File> files,
                                                                       int horizontal,
                                                                       int vertical,
                                                                       DistanceCalculationMetrics metrics)

calculateTrafficDensity

public static DistanceTravelledCalculator.CalculationResult calculateTrafficDensity(Options options,
                                                                                    rx.Observable<java.io.File> files)

calculateTrafficDensity

public static DistanceTravelledCalculator.CalculationResult calculateTrafficDensity(Options options,
                                                                                    rx.Observable<java.io.File> files,
                                                                                    int horizontal,
                                                                                    int vertical)

saveCalculationResultAsText

public static void saveCalculationResultAsText(Options options,
                                               DistanceTravelledCalculator.CalculationResult calculationResult,
                                               java.lang.String filename)

saveCalculationResultAsNetcdf

public static void saveCalculationResultAsNetcdf(Options options,
                                                 DistanceTravelledCalculator.CalculationResult calculationResult,
                                                 java.lang.String filename)

partition

public static rx.Observable<Options> partition(Options options,
                                               int horizontal,
                                               int vertical)

Returns a sequence of Options that are same as the source apart from the Bounds which are partitioned according to horizontal and vertical parameters. For map-reduce purposes we need to be able to partition the bounds of Options. Passing horizontal=1 and vertical=1 will return one item only being a copy of the source Options.

Parameters:

options -

horizontal - number of regions (with longitude)

vertical - number of regions (with latitude)

Returns: