Package org.apache.druid.client.coordinator

Class CoordinatorClientImpl

java.lang.Object

org.apache.druid.client.coordinator.CoordinatorClientImpl

All Implemented Interfaces:

CoordinatorClient

public class CoordinatorClientImpl
extends Object
implements CoordinatorClient

Constructor Summary

Constructors

Constructor	Description
CoordinatorClientImpl(ServiceClient client, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<org.apache.druid.timeline.DataSegment>	fetchSegment(String dataSource, String segmentId, boolean includeUnused)	Fetches segment metadata for the given dataSource and segmentId.
Iterable<ImmutableSegmentLoadInfo>	fetchServerViewSegments(String dataSource, List<org.joda.time.Interval> intervals)	Fetches segments from the coordinator server view for the given dataSource and intervals.
com.google.common.util.concurrent.ListenableFuture<List<org.apache.druid.timeline.DataSegment>>	fetchUsedSegments(String dataSource, List<org.joda.time.Interval> intervals)	Fetches segment metadata for the given dataSource and intervals.
com.google.common.util.concurrent.ListenableFuture<Boolean>	isHandoffComplete(String dataSource, org.apache.druid.query.SegmentDescriptor descriptor)	Checks if the given segment is handed off or not.
CoordinatorClientImpl	withRetryPolicy(ServiceRetryPolicy retryPolicy)	Returns a new instance backed by a ServiceClient which follows the provided retryPolicy

Methods inherited from class java.lang.Object

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

Constructor Detail

CoordinatorClientImpl

public CoordinatorClientImpl(ServiceClient client,
                             com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

isHandoffComplete

public com.google.common.util.concurrent.ListenableFuture<Boolean> isHandoffComplete(String dataSource,
                                                                                     org.apache.druid.query.SegmentDescriptor descriptor)

Description copied from interface: CoordinatorClient

Checks if the given segment is handed off or not.

Specified by:

isHandoffComplete in interface CoordinatorClient

fetchSegment

public com.google.common.util.concurrent.ListenableFuture<org.apache.druid.timeline.DataSegment> fetchSegment(String dataSource,
                                                                                                              String segmentId,
                                                                                                              boolean includeUnused)

Description copied from interface: CoordinatorClient

Fetches segment metadata for the given dataSource and segmentId. If includeUnused is set to false, the segment is not returned if it is marked as unused.

Specified by:

fetchSegment in interface CoordinatorClient

fetchServerViewSegments

public Iterable<ImmutableSegmentLoadInfo> fetchServerViewSegments(String dataSource,
                                                                  List<org.joda.time.Interval> intervals)

Description copied from interface: CoordinatorClient

Fetches segments from the coordinator server view for the given dataSource and intervals.

Specified by:

fetchServerViewSegments in interface CoordinatorClient

fetchUsedSegments

public com.google.common.util.concurrent.ListenableFuture<List<org.apache.druid.timeline.DataSegment>> fetchUsedSegments(String dataSource,
                                                                                                                         List<org.joda.time.Interval> intervals)

Description copied from interface: CoordinatorClient

Fetches segment metadata for the given dataSource and intervals.

Specified by:

fetchUsedSegments in interface CoordinatorClient

withRetryPolicy

public CoordinatorClientImpl withRetryPolicy(ServiceRetryPolicy retryPolicy)

Description copied from interface: CoordinatorClient

Returns a new instance backed by a ServiceClient which follows the provided retryPolicy

Specified by:

withRetryPolicy in interface CoordinatorClient