Uses of Class
org.apache.druid.timeline.DataSegment
Packages that use DataSegment
Package
Description
-
Uses of DataSegment in org.apache.druid.java.util.common.logger
Method parameters in org.apache.druid.java.util.common.logger with type arguments of type DataSegmentModifier and TypeMethodDescriptionvoidLogger.debugSegments(Collection<DataSegment> segments, String preamble) voidLogger.errorSegments(Throwable throwable, Collection<DataSegment> segments, String preamble) Logs error exception first and then logs the segmentsvoidLogger.errorSegments(Collection<DataSegment> segments, String preamble) voidLogger.infoSegments(Collection<DataSegment> segments, String preamble) voidLogger.warnSegments(Collection<DataSegment> segments, String preamble) -
Uses of DataSegment in org.apache.druid.java.util.emitter.service
Methods in org.apache.druid.java.util.emitter.service with parameters of type DataSegmentModifier and TypeMethodDescriptionstatic SegmentMetadataEventSegmentMetadataEvent.create(DataSegment segment, org.joda.time.DateTime eventTime) -
Uses of DataSegment in org.apache.druid.query
Methods in org.apache.druid.query that return DataSegmentConstructors in org.apache.druid.query with parameters of type DataSegmentModifierConstructorDescriptionDataSegmentAndDescriptor(DataSegment dataSegment, SegmentDescriptor descriptor) -
Uses of DataSegment in org.apache.druid.query.filter
Methods in org.apache.druid.query.filter with parameters of type DataSegmentModifier and TypeMethodDescriptionbooleanCompositeSegmentPruner.include(DataSegment segment) booleanFilterSegmentPruner.include(DataSegment segment) Returns false if theDataSegmentdoes not fit inDimFilter.getDimensionRangeSet(String).booleanSegmentPruner.include(DataSegment segment) Check if aDataSegmentshould be included or not.Method parameters in org.apache.druid.query.filter with type arguments of type DataSegmentModifier and TypeMethodDescriptiondefault <T> Collection<T>SegmentPruner.prune(Iterable<T> input, Function<T, DataSegment> converter) Filter the givenIterableof objects containing aDataSegment(obtained from the converter function), to reduce the overall working set which need to be processed. -
Uses of DataSegment in org.apache.druid.segment
Methods in org.apache.druid.segment that return DataSegmentMethods in org.apache.druid.segment that return types with arguments of type DataSegmentModifier and TypeMethodDescriptionDataSegmentsWithSchemas.getSegments()static Map<org.joda.time.Interval,List<DataSegment>> SegmentUtils.groupSegmentsByInterval(Collection<DataSegment> segments) Method parameters in org.apache.druid.segment with type arguments of type DataSegmentModifier and TypeMethodDescriptionstatic ObjectSegmentUtils.commaSeparatedIdentifiers(Collection<DataSegment> segments) Returns an object whose toString() returns a String with identifiers of the given segments, comma-separated.static Map<org.joda.time.Interval,List<DataSegment>> SegmentUtils.groupSegmentsByInterval(Collection<DataSegment> segments) static StringSegmentUtils.hashIds(List<DataSegment> segments) Hash the IDs of the given segments based on SHA-256 algorithm.Constructors in org.apache.druid.segment with parameters of type DataSegmentModifierConstructorDescriptionDataSegmentWithMetadata(DataSegment dataSegment, SchemaPayloadPlus schemaPayloadPlus) Constructor parameters in org.apache.druid.segment with type arguments of type DataSegmentModifierConstructorDescriptionDataSegmentsWithSchemas(Set<DataSegment> segments, SegmentSchemaMapping segmentSchemaMapping) -
Uses of DataSegment in org.apache.druid.segment.generator
Methods in org.apache.druid.segment.generator that return DataSegment -
Uses of DataSegment in org.apache.druid.segment.loading
Methods in org.apache.druid.segment.loading that return DataSegmentModifier and TypeMethodDescriptionDataSegmentArchiver.archive(DataSegment segment) Perform an archive task on the segment and return the resulting segment or null if there was no action needed.DataSegmentMover.move(DataSegment segment, Map<String, Object> targetLoadSpec) DataSegmentPusher.push(File file, DataSegment segment, boolean useUniquePath) Pushes index files and segment descriptor to deep storage.NoopDataSegmentPusher.push(File file, DataSegment segment, boolean replaceExisting) default DataSegmentDataSegmentPusher.pushToPath(File indexFilesDir, DataSegment segment, String storageDirSuffix) NoopDataSegmentPusher.pushToPath(File file, DataSegment segment, String storageDirSuffix) DataSegmentArchiver.restore(DataSegment segment) Perform the restore from an archived segment and return the resulting segment or null if there was no actionMethods in org.apache.druid.segment.loading with parameters of type DataSegmentModifier and TypeMethodDescriptionDataSegmentArchiver.archive(DataSegment segment) Perform an archive task on the segment and return the resulting segment or null if there was no action needed.BroadcastJoinableMMappedQueryableSegmentizerFactory.factorize(DataSegment dataSegment, File parentDir, boolean lazy, SegmentLazyLoadFailCallback loadFailed) MMappedQueryableSegmentizerFactory.factorize(DataSegment dataSegment, File parentDir, boolean lazy, SegmentLazyLoadFailCallback loadFailed) SegmentizerFactory.factorize(DataSegment segment, File parentDir, boolean lazy, SegmentLazyLoadFailCallback loadFailed) TombstoneSegmentizerFactory.factorize(DataSegment segment, File parentDir, boolean lazy, SegmentLazyLoadFailCallback loadFailed) static StringDataSegmentPusher.getDefaultStorageDir(DataSegment segment, boolean useUniquePath) static StringDataSegmentPusher.getDefaultStorageDirWithExistingUniquePath(DataSegment segment, String uniquePath) default StringDataSegmentPusher.getStorageDir(DataSegment dataSegment) Deprecated.default StringDataSegmentPusher.getStorageDir(DataSegment dataSegment, boolean useUniquePath) voidDataSegmentKiller.kill(DataSegment segment) Removes segment files (index and metadata) from deep storage.default voidDataSegmentKiller.killQuietly(DataSegment segment) A more stoic killer who doesn't throw a tantrum if things get messy.DataSegmentMover.move(DataSegment segment, Map<String, Object> targetLoadSpec) DataSegmentPusher.push(File file, DataSegment segment, boolean useUniquePath) Pushes index files and segment descriptor to deep storage.NoopDataSegmentPusher.push(File file, DataSegment segment, boolean replaceExisting) default DataSegmentDataSegmentPusher.pushToPath(File indexFilesDir, DataSegment segment, String storageDirSuffix) NoopDataSegmentPusher.pushToPath(File file, DataSegment segment, String storageDirSuffix) DataSegmentArchiver.restore(DataSegment segment) Perform the restore from an archived segment and return the resulting segment or null if there was no actionstatic SegmentTombstoneSegmentizerFactory.segmentForTombstone(DataSegment tombstone) Method parameters in org.apache.druid.segment.loading with type arguments of type DataSegmentModifier and TypeMethodDescriptiondefault voidDataSegmentKiller.kill(List<DataSegment> segments) Kills a list of segments from deep storage. -
Uses of DataSegment in org.apache.druid.timeline
Methods in org.apache.druid.timeline that return DataSegmentModifier and TypeMethodDescriptionDataSegment.Builder.build()SegmentStatusInCluster.getDataSegment()DataSegment.withBinaryVersion(int binaryVersion) DataSegment.withDimensions(List<String> dimensions) DataSegment.withIndexingStateFingerprint(String indexingStateFingerprint) DataSegment.withLastCompactionState(CompactionState compactionState) DataSegment.withLoadSpec(Map<String, Object> loadSpec) DataSegment.withMetrics(List<String> metrics) DataSegment.withProjections(List<String> projections) DataSegment.withShardSpec(ShardSpec newSpec) DataSegment.withSize(long size) DataSegment.withVersion(String version) Methods in org.apache.druid.timeline that return types with arguments of type DataSegmentModifier and TypeMethodDescriptionstatic Function<Set<DataSegment>,Set<DataSegment>> CompactionState.addCompactionStateToSegments(PartitionsSpec partitionsSpec, DimensionsSpec dimensionsSpec, List<AggregatorFactory> metricsSpec, CompactionTransformSpec transformSpec, IndexSpec indexSpec, GranularitySpec granularitySpec, List<AggregateProjectionSpec> projections) static Function<Set<DataSegment>,Set<DataSegment>> CompactionState.addCompactionStateToSegments(PartitionsSpec partitionsSpec, DimensionsSpec dimensionsSpec, List<AggregatorFactory> metricsSpec, CompactionTransformSpec transformSpec, IndexSpec indexSpec, GranularitySpec granularitySpec, List<AggregateProjectionSpec> projections) Methods in org.apache.druid.timeline with parameters of type DataSegmentModifier and TypeMethodDescriptionvoidSegmentTimeline.add(DataSegment segment) static DataSegment.BuilderDataSegment.builder(DataSegment segment) intDataSegment.compareTo(DataSegment dataSegment) booleanSegmentTimeline.isOvershadowed(DataSegment segment) booleanDataSegment.overshadows(DataSegment other) voidSegmentTimeline.remove(DataSegment segment) Method parameters in org.apache.druid.timeline with type arguments of type DataSegmentModifier and TypeMethodDescriptionvoidSegmentTimeline.addSegments(Iterator<DataSegment> segments) static SegmentTimelineSegmentTimeline.forSegments(Iterable<DataSegment> segments) static SegmentTimelineSegmentTimeline.forSegments(Iterator<DataSegment> segments) Constructors in org.apache.druid.timeline with parameters of type DataSegmentModifierConstructorDescriptionSegmentStatusInCluster(DataSegment dataSegment, boolean overshadowed, Integer replicationFactor, Long numRows, boolean realtime)
DataSegmentPusher.getStorageDir(DataSegment, boolean)instead.