Package org.onebusaway.collections

Examples of org.onebusaway.collections.Range

271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
    }
    return false;
  }

  private double computeRangeForStanox(int idA, int idB) {
    Range x = new Range();
    Range y = new Range();
    updateRangeForStanox(idA, x, y);
    updateRangeForStanox(idB, x, y);
    if (x.isEmpty()) {
      return 0;
    }
    double dx = x.getRange();
    double dy = y.getRange();
    return Math.sqrt(dx * dx + dy * dy);
  }
View Full Code Here
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
        regionToStyle.put(area, style);
      }
     
      Pair<Range> ranges = rangesByArea.get(area);
      if (ranges == null) {
        ranges = Tuples.pair(new Range(), new Range());
        rangesByArea.put(area, ranges);
      }
      Range xRange = ranges.getFirst();
      Range yRange = ranges.getSecond();
       
      for (String tiploc : model.getTiplocsForStanox(stanox)) {
        StationElement station = model.getStationForTiploc(tiploc);
        if (station != null) {
          writer.println(area + "," + style + "," + from + "," + to + ","
              + region + "," + stanox + "," + tiploc + "," + station.getLat()
              + "," + station.getLon() + "," + station.getName());
          xRange.addValue(station.getEasting());
          yRange.addValue(station.getNorthing());
        }
      }
    }
   
    Max<String> maxRange = new Max<String>();
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
    remainingNodes.addAll(_nodesById.values());
    while (!remainingNodes.isEmpty()) {
      Node first = remainingNodes.iterator().next();
      Set<Node> cluster = exploreCluster(first, remainingNodes);

      Range xRange = new Range();
      Range yRange = new Range();
      for (Node node : cluster) {
        xRange.addValue(node.x);
        yRange.addValue(node.y);
      }
      double dx = xRange.getRange();
      double dy = yRange.getRange();
      double d = Math.sqrt(dx * dx + dy * dy);
      if (d < minClusterSize) {
        _log.info("pruning cluster: nodes=" + cluster.size() + " distance=" + d);
        for (Node node : cluster) {
          _nodesById.remove(node.id);
View Full Code Here
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
  private ScheduleDeviationHistory constructHistory(AgencyAndId tripId,
      BlockLocationArchiveRecordMap recordsByInstance) {

    List<SortedMap<Integer, Double>> traces = new ArrayList<SortedMap<Integer, Double>>();
    Range tRange = new Range();

    sortAndArrangeTraces(recordsByInstance, traces, tRange);

    int step = computeSamplingStep(traces);

    int from = (int) (Math.ceil(tRange.getMin() / step) * step);
    int to = (int) (Math.floor(tRange.getMax() / step) * step);

    SortedMap<Integer, Double> mus = new TreeMap<Integer, Double>();
    SortedMap<Integer, Double> sigmas = new TreeMap<Integer, Double>();

    computeMeanAndStandardDeviationForTraces(traces, from, to, step, mus,
View Full Code Here
98
99
100
101
102
103
104
105
  public Range getTimeRange() {
    if (_elements.isEmpty())
      throw new NoSuchElementException();
    VehicleLocationCacheElement first = _elements.get(0);
    VehicleLocationCacheElement last = _elements.get(_elements.size() - 1);
    return new Range(first.getRecord().getTimeOfRecord(),
        last.getRecord().getTimeOfRecord());
  }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
    StopEntry stop = _graph.getStopEntryForId(stopId, true);

    List<BlockStopTimeIndex> indices = _blockIndexService.getStopTimeIndicesForStop(stop);

    Range interval = new Range();

    for (BlockStopTimeIndex index : indices) {
      extendIntervalWithIndex(serviceDate, interval, index);
    }
View Full Code Here
764
765
766
767
768
769
770
771
772
773
774
775
776
      List<VehicleLocationCacheElements> inRange = new ArrayList<VehicleLocationCacheElements>();
      long offset = _predictionCacheMaxOffset * 1000;
      for (VehicleLocationCacheElements elements : entries) {
        if (elements.isEmpty())
          continue;
        Range range = elements.getTimeRange();
        long tFrom = (long) (range.getMin() - offset);
        long tTo = (long) (range.getMax() + offset);
        if (tFrom <= time.getCurrentTime() && time.getCurrentTime() <= tTo)
          inRange.add(elements);
      }
      if (!inRange.isEmpty())
        return inRange;
View Full Code Here
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
    values = noNans(values);

    if (values.length == 0)
      return new ScheduleDeviationHistogram(new int[0], new int[0]);

    Range r = new Range();
    for (double v : values)
      r.addValue(v);

    if (r.getRange() == 0)
      return new ScheduleDeviationHistogram(new int[] {(int) values[0]},
          new int[] {values.length});
   
    int halfStep = stepSizeInSeconds / 2;

    int from = (int) (Math.floor((r.getMin()-halfStep) / stepSizeInSeconds) * stepSizeInSeconds) + halfStep;
    int to = (int) (Math.ceil((r.getMax()+halfStep) / stepSizeInSeconds) * stepSizeInSeconds) - halfStep;
    int columns = (to - from) / stepSizeInSeconds;

    int[] scheduleDeviations = new int[columns];
    int[] counts = new int[columns];

View Full Code Here
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
  }

  private List<StopTimeInstance> getStopTimeInstancesForStopAndServiceDate(
      StopEntry stop, ServiceDate serviceDate) {

    Range interval = _stopTimeService.getDepartureForStopAndServiceDate(
        stop.getId(), serviceDate);

    if (interval.isEmpty())
      return Collections.emptyList();

    long tFrom = (long) interval.getMin();
    long tTo = (long) interval.getMax();

    return _stopTimeService.getStopTimeInstancesInTimeRange(stop, new Date(
        tFrom), new Date(tTo), EFrequencyStopTimeBehavior.INCLUDE_INTERPOLATED);
  }
View Full Code Here
TOP

Related Classes of org.onebusaway.collections.Range

  • org.onebusaway.transit_data_federation.bundle.tasks.history.BlockLocationHistoryTask
  • org.onebusaway.transit_data_federation.bundle.tasks.transfer_pattern.TransferPatternsTask
  • org.onebusaway.transit_data_federation.impl.realtime.BlockLocationServiceImpl
  • org.onebusaway.transit_data_federation.impl.realtime.history.RealTimeHistoryServiceImpl
  • org.onebusaway.transit_data_federation.impl.StopTimeServiceImpl
  • org.onebusaway.transit_data_federation.services.realtime.VehicleLocationCacheElements
  • org.onebusaway.uk.network_rail.gtfs_realtime.graph.ConstructBerthToStanoxGraphMain
  • org.onebusaway.uk.network_rail.gtfs_realtime.graph.RailwayGraph
  • org.onebusaway.uk.network_rail.gtfs_realtime.graph.VisualizeBerthLocationsMain
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.