Interface SegmentWrangler


public interface SegmentWrangler
Utility for creating Segment objects for concrete datasources.
See Also:
  • to register factories
  • Method Details

    • getSegmentsForIntervals

      Iterable<Segment> getSegmentsForIntervals(DataSource dataSource, Iterable<org.joda.time.Interval> intervals)
      Gets Segments for a particular datasource and set of intervals. These are expected to exist for any datasource where DataSource#isConcrete and DataSource.isGlobal() are both true (corresponding to datasources where any Druid server could scan its data). Note: there are no SegmentWranglers for 'table' datasources (Druid's distributed datasources) because those are special and handled in their own special way.
      Returns:
      Segments that, collectively, contain data for dataSource. May be empty if dataSource does not exist or has no data in the provided intervals. May contain data outside the provided intervals, so callers should filter it down further, e.g. through the "interval" parameter of CursorBuildSpec for CursorFactory.makeCursorHolder(CursorBuildSpec)