Package org.apache.druid.segment

Class WrappedSegment

java.lang.Object

org.apache.druid.segment.WrappedSegment

All Implemented Interfaces:

Closeable, AutoCloseable, Segment

Direct Known Subclasses:

FilteredSegment, UnnestSegment

public abstract class WrappedSegment
extends Object
implements Segment

Simple Segment implementation for a segment that wraps a base segment such as UnnestSegment or FilteredSegment

Field Summary

Fields

Modifier and Type	Field	Description
protected final Segment	delegate

Constructor Summary

Constructors

Constructor	Description
WrappedSegment(Segment delegate)

Method Summary

Modifier and Type	Method	Description
void	close()
org.joda.time.Interval	getDataInterval()
SegmentId	getId()	Returns the SegmentId of this segment, if it is backed by a real table, otherwise returns null.
boolean	isTombstone()
void	validateOrElseThrow(PolicyEnforcer policyEnforcer)	Validates if the segment complies with the policy restrictions on tables.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.segment.Segment

as, getDebugString

Field Details

delegate

protected final Segment delegate

Constructor Details

WrappedSegment

public WrappedSegment(Segment delegate)

Method Details

getId

public SegmentId getId()

Description copied from interface: Segment

Returns the SegmentId of this segment, if it is backed by a real table, otherwise returns null.

Specified by:

getId in interface Segment

getDataInterval

public org.joda.time.Interval getDataInterval()

Specified by:

getDataInterval in interface Segment

validateOrElseThrow

public void validateOrElseThrow(PolicyEnforcer policyEnforcer)

Description copied from interface: Segment

Validates if the segment complies with the policy restrictions on tables.

This should be called right before the segment is about to be processed by the query stack, and after ExecutionVertex.createSegmentMapFunction(PolicyEnforcer).

Specified by:

validateOrElseThrow in interface Segment

isTombstone

public boolean isTombstone()

Specified by:

isTombstone in interface Segment

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException