- abandonSegment(long, Sink) - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
Unannounces a given sink and removes all local references to it.
- AbstractCuratorServerInventoryView<InventoryType> - Class in org.apache.druid.client
-
- AbstractCuratorServerInventoryView(EmittingLogger, String, String, CuratorFramework, ObjectMapper, TypeReference<InventoryType>) - Constructor for class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- AbstractHttpClientProvider<HttpClientType> - Class in org.apache.druid.guice.http
-
- AbstractHttpClientProvider() - Constructor for class org.apache.druid.guice.http.AbstractHttpClientProvider
-
- AbstractHttpClientProvider(Annotation) - Constructor for class org.apache.druid.guice.http.AbstractHttpClientProvider
-
- AbstractHttpClientProvider(Class<? extends Annotation>) - Constructor for class org.apache.druid.guice.http.AbstractHttpClientProvider
-
- AbstractListenerHandler<ObjType> - Class in org.apache.druid.server.listener.resource
-
This is a simplified handler for announcement listeners.
- AbstractListenerHandler(TypeReference<ObjType>) - Constructor for class org.apache.druid.server.listener.resource.AbstractListenerHandler
-
The standard constructor takes in a type reference for the object and for a list of the object.
- AbstractResourceFilter - Class in org.apache.druid.server.http.security
-
- AbstractResourceFilter(AuthorizerMapper) - Constructor for class org.apache.druid.server.http.security.AbstractResourceFilter
-
- AbstractTierSelectorStrategy - Class in org.apache.druid.client.selector
-
- AbstractTierSelectorStrategy(ServerSelectorStrategy) - Constructor for class org.apache.druid.client.selector.AbstractTierSelectorStrategy
-
- accept(long) - Method in interface org.apache.druid.segment.realtime.plumber.RejectionPolicy
-
- Access - Class in org.apache.druid.server.security
-
- Access(boolean) - Constructor for class org.apache.druid.server.security.Access
-
- Access(boolean, String) - Constructor for class org.apache.druid.server.security.Access
-
- accumulate(CoordinatorStats) - Method in class org.apache.druid.server.coordinator.CoordinatorStats
-
- Action - Enum in org.apache.druid.server.security
-
- add(String, LookupExtractorFactoryContainer) - Method in class org.apache.druid.query.lookup.LookupReferencesManager
-
- add(SegmentIdentifier, InputRow, Supplier<Committer>) - Method in interface org.apache.druid.segment.realtime.appenderator.Appenderator
-
- add(SegmentIdentifier, InputRow, Supplier<Committer>, boolean) - Method in interface org.apache.druid.segment.realtime.appenderator.Appenderator
-
Add a row.
- add(SegmentIdentifier, InputRow, Supplier<Committer>, boolean) - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
- add(InputRow, Supplier<Committer>) - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumber
-
- add(InputRow, String) - Method in class org.apache.druid.segment.realtime.appenderator.BatchAppenderatorDriver
-
Add a row.
- add(InputRow, String, Supplier<Committer>) - Method in class org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver
-
- add(InputRow, String, Supplier<Committer>, boolean, boolean) - Method in class org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver
-
Add a row.
- add(InputRow, Supplier<Committer>) - Method in interface org.apache.druid.segment.realtime.plumber.Plumber
-
- add(InputRow, Supplier<Committer>) - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- add(InputRow, boolean) - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
- add(ServerHolder) - Method in class org.apache.druid.server.coordinator.DruidCluster
-
- addAll(Collection<Map<String, Object>>) - Method in interface org.apache.druid.segment.realtime.firehose.EventReceiver
-
- addAll(InputStream, HttpServletRequest) - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory.EventReceiverFirehose
-
- addAllowOptionsFilter(ServletContextHandler, boolean) - Static method in class org.apache.druid.server.security.AuthenticationUtils
-
- addAuthenticationFilterChain(ServletContextHandler, List<Authenticator>) - Static method in class org.apache.druid.server.security.AuthenticationUtils
-
- addChangeRequest(T) - Method in class org.apache.druid.server.coordination.ChangeRequestHistory
-
Add single segment change update.
- addChangeRequests(List<T>) - Method in class org.apache.druid.server.coordination.ChangeRequestHistory
-
Add batch of segment changes update.
- addDataSegment(DataSegment) - Method in class org.apache.druid.client.DruidServer
-
- addDataSegments(DruidServer) - Method in class org.apache.druid.client.DruidServer
-
- addExprMacro(Binder, Class<? extends ExprMacroTable.ExprMacro>) - Static method in class org.apache.druid.guice.ExpressionModule
-
- addExtensionFilters(ServletContextHandler, Injector) - Static method in class org.apache.druid.server.initialization.jetty.JettyServerInitUtils
-
- addHandler(Binder, Class<? extends Handler>) - Static method in class org.apache.druid.server.initialization.jetty.JettyBindings
-
- addInnerInventory(DruidServer, String, InventoryType) - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- addInnerInventory(DruidServer, String, Set<DataSegment>) - Method in class org.apache.druid.client.BatchServerInventoryView
-
Deprecated.
- addInnerInventory(DruidServer, String, DataSegment) - Method in class org.apache.druid.client.SingleServerInventoryView
-
Deprecated.
- addInventory(ContainerClass, String, InventoryClass) - Method in interface org.apache.druid.curator.inventory.CuratorInventoryManagerStrategy
-
- addLock(String, LockType) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- addLog(String, LogType) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- addNextRow(Supplier<Committer>, Firehose, Plumber, boolean, FireDepartmentMetrics) - Static method in class org.apache.druid.segment.realtime.plumber.Plumbers
-
- addNoopAuthorizationFilters(ServletContextHandler, List<String>) - Static method in class org.apache.druid.server.security.AuthenticationUtils
-
- addOrUpdateCompactionConfig(DataSourceCompactionConfig, String, String, HttpServletRequest) - Method in class org.apache.druid.server.http.CoordinatorCompactionConfigsResource
-
- addPreResponseAuthorizationCheckFilter(ServletContextHandler, List<Authenticator>, ObjectMapper) - Static method in class org.apache.druid.server.security.AuthenticationUtils
-
- addQosFilter(Binder, String, int) - Static method in class org.apache.druid.server.initialization.jetty.JettyBindings
-
- addRows(Iterable<InputRow>) - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory.EventReceiverFirehose
-
- addSecuritySanityCheckFilter(ServletContextHandler, ObjectMapper) - Static method in class org.apache.druid.server.security.AuthenticationUtils
-
- addSegment(DataSegment) - Method in class org.apache.druid.client.DruidDataSource
-
- addSegment(DataSegment, DataSegmentChangeCallback) - Method in interface org.apache.druid.server.coordination.DataSegmentChangeHandler
-
- addSegment(DataSegment, DataSegmentChangeCallback) - Method in class org.apache.druid.server.coordination.SegmentLoadDropHandler
-
- addSegment(String, DataSegment) - Method in class org.apache.druid.server.coordinator.cost.ClusterCostCache.Builder
-
- addSegment(DataSegment) - Method in class org.apache.druid.server.coordinator.cost.SegmentsCostCache.Builder
-
- addSegment(DataSegment) - Method in class org.apache.druid.server.coordinator.cost.ServerCostCache.Builder
-
- addServer(DruidServerMetadata) - Method in class org.apache.druid.client.SegmentLoadInfo
-
- addServerAndUpdateSegment(QueryableDruidServer, DataSegment) - Method in class org.apache.druid.client.selector.ServerSelector
-
- addSingleInventory(DruidServer, DataSegment) - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- addToDataSourceStat(String, String, long) - Method in class org.apache.druid.server.coordinator.CoordinatorStats
-
- addToGlobalStat(String, long) - Method in class org.apache.druid.server.coordinator.CoordinatorStats
-
- addToTieredStat(String, String, long) - Method in class org.apache.druid.server.coordinator.CoordinatorStats
-
- ALL_NODE_TYPES - Static variable in class org.apache.druid.discovery.DruidNodeDiscoveryProvider
-
- allocate(InputRow, String, String, boolean) - Method in interface org.apache.druid.segment.realtime.appenderator.SegmentAllocator
-
Allocates a new segment for a given timestamp.
- allocatePendingSegment(String, String, String, Interval, String, boolean) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
Allocate a new pending segment in the pending segments table.
- allocatePendingSegment(String, String, String, Interval, String, boolean) - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
- ALLOW_ALL_NAME - Static variable in class org.apache.druid.server.security.AuthConfig
-
- ALLOW_ALL_RESULT - Static variable in class org.apache.druid.server.security.AllowAllAuthenticator
-
- AllowAllAuthenticator - Class in org.apache.druid.server.security
-
Should only be used in conjunction with AllowAllAuthorizer.
- AllowAllAuthenticator() - Constructor for class org.apache.druid.server.security.AllowAllAuthenticator
-
- AllowAllAuthorizer - Class in org.apache.druid.server.security
-
- AllowAllAuthorizer() - Constructor for class org.apache.druid.server.security.AllowAllAuthorizer
-
- AllowOptionsResourceFilter - Class in org.apache.druid.server.security
-
- AllowOptionsResourceFilter(boolean) - Constructor for class org.apache.druid.server.security.AllowOptionsResourceFilter
-
- announce(String, byte[]) - Method in class org.apache.druid.curator.announcement.Announcer
-
Like announce(path, bytes, true).
- announce(String, byte[], boolean) - Method in class org.apache.druid.curator.announcement.Announcer
-
Announces the provided bytes at the given path.
- announce(DiscoveryDruidNode) - Method in class org.apache.druid.curator.discovery.CuratorDruidNodeAnnouncer
-
- announce(DruidNode) - Method in class org.apache.druid.curator.discovery.CuratorServiceAnnouncer
-
Deprecated.
- announce(DruidNode) - Method in class org.apache.druid.curator.discovery.NoopServiceAnnouncer
-
Deprecated.
- announce(DruidNode) - Method in interface org.apache.druid.curator.discovery.ServiceAnnouncer
-
Deprecated.
- announce(DiscoveryDruidNode) - Method in interface org.apache.druid.discovery.DruidNodeAnnouncer
-
- announce() - Method in class org.apache.druid.server.coordination.CuratorDataSegmentServerAnnouncer
-
Deprecated.
- announce() - Method in interface org.apache.druid.server.coordination.DataSegmentServerAnnouncer
-
Deprecated.
- announceHistoricalSegments(Set<DataSegment>) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
Attempts to insert a set of segments to the metadata storage.
- announceHistoricalSegments(Set<DataSegment>, DataSourceMetadata, DataSourceMetadata) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
Attempts to insert a set of segments to the metadata storage.
- announceHistoricalSegments(Set<DataSegment>) - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
Attempts to insert a set of segments to the database.
- announceHistoricalSegments(Set<DataSegment>, DataSourceMetadata, DataSourceMetadata) - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
Attempts to insert a set of segments to the metadata storage.
- Announcer - Class in org.apache.druid.curator.announcement
-
Announces things on Zookeeper.
- Announcer(CuratorFramework, ExecutorService) - Constructor for class org.apache.druid.curator.announcement.Announcer
-
- AnnouncerModule - Class in org.apache.druid.guice
-
- AnnouncerModule() - Constructor for class org.apache.druid.guice.AnnouncerModule
-
- announceSegment(DataSegment) - Method in class org.apache.druid.server.coordination.BatchDataSegmentAnnouncer
-
- announceSegment(DataSegment) - Method in interface org.apache.druid.server.coordination.DataSegmentAnnouncer
-
- announceSegment(DataSegment) - Method in class org.apache.druid.server.coordination.NoopDataSegmentAnnouncer
-
- announceSegments(Iterable<DataSegment>) - Method in class org.apache.druid.server.coordination.BatchDataSegmentAnnouncer
-
- announceSegments(Iterable<DataSegment>) - Method in interface org.apache.druid.server.coordination.DataSegmentAnnouncer
-
- announceSegments(Iterable<DataSegment>) - Method in class org.apache.druid.server.coordination.NoopDataSegmentAnnouncer
-
- ANONYMOUS_NAME - Static variable in class org.apache.druid.server.security.AuthConfig
-
- AnonymousAuthenticator - Class in org.apache.druid.server.security
-
Authenticates all requests and directs them to an authorizer.
- AnonymousAuthenticator(String, String, String) - Constructor for class org.apache.druid.server.security.AnonymousAuthenticator
-
- APACHE_DRUID_PACKAGE_NAME - Static variable in class org.apache.druid.server.metrics.MonitorsConfig
-
- append(InputRow, String, Supplier<Committer>, boolean, boolean) - Method in class org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver
-
Add a row.
- Appenderator - Interface in org.apache.druid.segment.realtime.appenderator
-
An Appenderator indexes data.
- appenderator - Variable in class org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver
-
- Appenderator.AppenderatorAddResult - Class in org.apache.druid.segment.realtime.appenderator
-
Result of
Appenderator.add(SegmentIdentifier, InputRow, Supplier, boolean) containing following information
- SegmentIdentifier - identifier of segment to which rows are being added
- int - positive number indicating how many summarized rows exist in this segment so far and
- boolean - true if is set to false and persist is required; false otherwise
- AppenderatorConfig - Interface in org.apache.druid.segment.realtime.appenderator
-
- AppenderatorDriverAddResult - Class in org.apache.druid.segment.realtime.appenderator
-
Result of BaseAppenderatorDriver#append).
- AppenderatorDriverMetadata - Class in org.apache.druid.segment.realtime.appenderator
-
- AppenderatorDriverMetadata(Map<String, List<SegmentWithState>>, Map<String, String>, Object, Map<String, List<SegmentIdentifier>>, Map<String, List<SegmentIdentifier>>) - Constructor for class org.apache.druid.segment.realtime.appenderator.AppenderatorDriverMetadata
-
- AppenderatorDriverMetadata(Map<String, List<SegmentWithState>>, Map<String, String>, Object) - Constructor for class org.apache.druid.segment.realtime.appenderator.AppenderatorDriverMetadata
-
- AppenderatorFactory - Interface in org.apache.druid.segment.realtime.appenderator
-
- AppenderatorImpl - Class in org.apache.druid.segment.realtime.appenderator
-
- AppenderatorPlumber - Class in org.apache.druid.segment.realtime.appenderator
-
- AppenderatorPlumber(DataSchema, RealtimeTuningConfig, FireDepartmentMetrics, DataSegmentAnnouncer, SegmentPublisher, SegmentHandoffNotifier, Appenderator) - Constructor for class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumber
-
- AppenderatorPlumberSchool - Class in org.apache.druid.segment.realtime.appenderator
-
- AppenderatorPlumberSchool(AppenderatorFactory, DataSegmentAnnouncer, SegmentHandoffNotifierFactory, SegmentPublisher) - Constructor for class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumberSchool
-
- Appenderators - Class in org.apache.druid.segment.realtime.appenderator
-
- Appenderators() - Constructor for class org.apache.druid.segment.realtime.appenderator.Appenderators
-
- APPLICATION_SMILE - Static variable in class org.apache.druid.server.QueryResource
-
Deprecated.
- appliesTo(DataSegment, DateTime) - Method in class org.apache.druid.server.coordinator.rules.ForeverBroadcastDistributionRule
-
- appliesTo(Interval, DateTime) - Method in class org.apache.druid.server.coordinator.rules.ForeverBroadcastDistributionRule
-
- appliesTo(DataSegment, DateTime) - Method in class org.apache.druid.server.coordinator.rules.ForeverDropRule
-
- appliesTo(Interval, DateTime) - Method in class org.apache.druid.server.coordinator.rules.ForeverDropRule
-
- appliesTo(DataSegment, DateTime) - Method in class org.apache.druid.server.coordinator.rules.ForeverLoadRule
-
- appliesTo(Interval, DateTime) - Method in class org.apache.druid.server.coordinator.rules.ForeverLoadRule
-
- appliesTo(DataSegment, DateTime) - Method in class org.apache.druid.server.coordinator.rules.IntervalBroadcastDistributionRule
-
- appliesTo(Interval, DateTime) - Method in class org.apache.druid.server.coordinator.rules.IntervalBroadcastDistributionRule
-
- appliesTo(DataSegment, DateTime) - Method in class org.apache.druid.server.coordinator.rules.IntervalDropRule
-
- appliesTo(Interval, DateTime) - Method in class org.apache.druid.server.coordinator.rules.IntervalDropRule
-
- appliesTo(DataSegment, DateTime) - Method in class org.apache.druid.server.coordinator.rules.IntervalLoadRule
-
- appliesTo(Interval, DateTime) - Method in class org.apache.druid.server.coordinator.rules.IntervalLoadRule
-
- appliesTo(DataSegment, DateTime) - Method in class org.apache.druid.server.coordinator.rules.PeriodBroadcastDistributionRule
-
- appliesTo(Interval, DateTime) - Method in class org.apache.druid.server.coordinator.rules.PeriodBroadcastDistributionRule
-
- appliesTo(DataSegment, DateTime) - Method in class org.apache.druid.server.coordinator.rules.PeriodDropRule
-
- appliesTo(Interval, DateTime) - Method in class org.apache.druid.server.coordinator.rules.PeriodDropRule
-
- appliesTo(DataSegment, DateTime) - Method in class org.apache.druid.server.coordinator.rules.PeriodLoadRule
-
- appliesTo(Interval, DateTime) - Method in class org.apache.druid.server.coordinator.rules.PeriodLoadRule
-
- appliesTo(DataSegment, DateTime) - Method in interface org.apache.druid.server.coordinator.rules.Rule
-
- appliesTo(Interval, DateTime) - Method in interface org.apache.druid.server.coordinator.rules.Rule
-
- apply(List<Expr>) - Method in class org.apache.druid.query.expression.LookupExprMacro
-
- apply(Object) - Method in class org.apache.druid.query.lookup.RegisteredLookupExtractionFn
-
- apply(String) - Method in class org.apache.druid.query.lookup.RegisteredLookupExtractionFn
-
- apply(long) - Method in class org.apache.druid.query.lookup.RegisteredLookupExtractionFn
-
- apply(TieredBrokerConfig, Query) - Method in interface org.apache.druid.server.router.JavaScriptTieredBrokerSelectorStrategy.SelectorFunction
-
- applyDataSegmentChangeRequests(long, List<DataSegmentChangeRequest>, HttpServletRequest) - Method in class org.apache.druid.server.http.SegmentListerResource
-
This endpoint is used by HttpLoadQueuePeon to assign segment load/drop requests batch.
- ArbitraryGranularitySpec - Class in org.apache.druid.segment.indexing.granularity
-
- ArbitraryGranularitySpec(Granularity, Boolean, List<Interval>) - Constructor for class org.apache.druid.segment.indexing.granularity.ArbitraryGranularitySpec
-
- ArbitraryGranularitySpec(Granularity, List<Interval>) - Constructor for class org.apache.druid.segment.indexing.granularity.ArbitraryGranularitySpec
-
- archive(DataSegment) - Method in class org.apache.druid.segment.loading.OmniDataSegmentArchiver
-
- asMmxLifecycle(Lifecycle) - Static method in class org.apache.druid.guice.http.LifecycleUtils
-
- asString() - Method in interface org.apache.druid.server.coordination.DataSegmentChangeRequest
-
- asString() - Method in class org.apache.druid.server.coordination.SegmentChangeRequestDrop
-
- asString() - Method in class org.apache.druid.server.coordination.SegmentChangeRequestLoad
-
- asString() - Method in class org.apache.druid.server.coordination.SegmentChangeRequestNoop
-
- AsyncManagementForwardingServlet - Class in org.apache.druid.server
-
- AsyncManagementForwardingServlet(ObjectMapper, Provider<HttpClient>, DruidHttpClientConfig, DruidLeaderSelector, DruidLeaderSelector) - Constructor for class org.apache.druid.server.AsyncManagementForwardingServlet
-
- AsyncQueryForwardingServlet - Class in org.apache.druid.server
-
This class does async query processing and should be merged with QueryResource at some point
- AsyncQueryForwardingServlet(QueryToolChestWarehouse, ObjectMapper, ObjectMapper, QueryHostFinder, Provider<HttpClient>, DruidHttpClientConfig, ServiceEmitter, RequestLogger, GenericQueryMetricsFactory, AuthenticatorMapper) - Constructor for class org.apache.druid.server.AsyncQueryForwardingServlet
-
- AuditManagerProvider - Interface in org.apache.druid.server.audit
-
- authConfig - Variable in class org.apache.druid.server.QueryResource
-
- AuthConfig - Class in org.apache.druid.server.security
-
- AuthConfig() - Constructor for class org.apache.druid.server.security.AuthConfig
-
- AuthConfig(List<String>, List<String>, List<String>, boolean) - Constructor for class org.apache.druid.server.security.AuthConfig
-
- authenticateJDBCContext(Map<String, Object>) - Method in class org.apache.druid.server.security.AllowAllAuthenticator
-
- authenticateJDBCContext(Map<String, Object>) - Method in class org.apache.druid.server.security.AnonymousAuthenticator
-
- authenticateJDBCContext(Map<String, Object>) - Method in interface org.apache.druid.server.security.Authenticator
-
Given a JDBC connection context, authenticate the identity represented by the information in the context.
- AuthenticationResult - Class in org.apache.druid.server.security
-
An AuthenticationResult contains information about a successfully authenticated request.
- AuthenticationResult(String, String, String, Map<String, Object>) - Constructor for class org.apache.druid.server.security.AuthenticationResult
-
- authenticationResultFromRequest(HttpServletRequest) - Static method in class org.apache.druid.server.security.AuthorizationUtils
-
Returns the authentication information for a request.
- AuthenticationUtils - Class in org.apache.druid.server.security
-
- AuthenticationUtils() - Constructor for class org.apache.druid.server.security.AuthenticationUtils
-
- AuthenticationWrappingFilter - Class in org.apache.druid.server.security
-
Used to wrap Filters created by Authenticators, this wrapper filter skips itself if a request already
has an authentication check (so that Authenticator implementations don't have to perform this check themselves)
- AuthenticationWrappingFilter(Filter) - Constructor for class org.apache.druid.server.security.AuthenticationWrappingFilter
-
- Authenticator - Interface in org.apache.druid.server.security
-
- AuthenticatorMapper - Class in org.apache.druid.server.security
-
- AuthenticatorMapper(Map<String, Authenticator>) - Constructor for class org.apache.druid.server.security.AuthenticatorMapper
-
- AuthenticatorMapperModule - Class in org.apache.druid.server.initialization
-
- AuthenticatorMapperModule() - Constructor for class org.apache.druid.server.initialization.AuthenticatorMapperModule
-
- AuthenticatorModule - Class in org.apache.druid.guice.security
-
- AuthenticatorModule() - Constructor for class org.apache.druid.guice.security.AuthenticatorModule
-
- authorizationCheck(HttpServletRequest, Action, String, AuthorizerMapper) - Static method in class org.apache.druid.segment.realtime.firehose.ChatHandlers
-
Check authorization for the given action and dataSource.
- AuthorizationUtils - Class in org.apache.druid.server.security
-
Static utility functions for performing authorization checks.
- AuthorizationUtils() - Constructor for class org.apache.druid.server.security.AuthorizationUtils
-
- authorize(AuthenticationResult) - Method in class org.apache.druid.server.QueryLifecycle
-
Authorize the query.
- authorize(HttpServletRequest) - Method in class org.apache.druid.server.QueryLifecycle
-
Authorize the query.
- authorize(AuthenticationResult, Resource, Action) - Method in class org.apache.druid.server.security.AllowAllAuthorizer
-
- authorize(AuthenticationResult, Resource, Action) - Method in interface org.apache.druid.server.security.Authorizer
-
Check if the entity represented by identity is authorized to perform action on resource.
- authorizeAllResourceActions(AuthenticationResult, Iterable<ResourceAction>, AuthorizerMapper) - Static method in class org.apache.druid.server.security.AuthorizationUtils
-
Check a list of resource-actions to be performed by the identity represented by authenticationResult.
- authorizeAllResourceActions(HttpServletRequest, Iterable<ResourceAction>, AuthorizerMapper) - Static method in class org.apache.druid.server.security.AuthorizationUtils
-
Check a list of resource-actions to be performed as a result of an HTTP request.
- Authorizer - Interface in org.apache.druid.server.security
-
- authorizeResourceAction(HttpServletRequest, ResourceAction, AuthorizerMapper) - Static method in class org.apache.druid.server.security.AuthorizationUtils
-
Check a resource-action using the authorization fields from the request.
- authorizerMapper - Variable in class org.apache.druid.server.QueryResource
-
- AuthorizerMapper - Class in org.apache.druid.server.security
-
- AuthorizerMapper(Map<String, Authorizer>) - Constructor for class org.apache.druid.server.security.AuthorizerMapper
-
- AuthorizerMapperModule - Class in org.apache.druid.server.initialization
-
- AuthorizerMapperModule() - Constructor for class org.apache.druid.server.initialization.AuthorizerMapperModule
-
- AuthorizerModule - Class in org.apache.druid.guice.security
-
- AuthorizerModule() - Constructor for class org.apache.druid.guice.security.AuthorizerModule
-
- AuthTestUtils - Class in org.apache.druid.server.security
-
- AuthTestUtils() - Constructor for class org.apache.druid.server.security.AuthTestUtils
-
- AvaticaConnectionBalancer - Interface in org.apache.druid.server.router
-
An AvaticaConnectionBalancer balances Avatica connections across a collection of servers.
- averageBytes() - Method in class org.apache.druid.client.cache.CacheStats
-
- awaitInitialization(long) - Method in class org.apache.druid.server.coordination.ChangeRequestHttpSyncer
-
- AWSModule - Class in org.apache.druid.guice
-
- AWSModule() - Constructor for class org.apache.druid.guice.AWSModule
-
- Cache - Interface in org.apache.druid.client.cache
-
- Cache.NamedKey - Class in org.apache.druid.client.cache
-
- CacheConfig - Class in org.apache.druid.client.cache
-
- CacheConfig() - Constructor for class org.apache.druid.client.cache.CacheConfig
-
- CacheExecutorFactory - Enum in org.apache.druid.client.cache
-
- CacheModule - Class in org.apache.druid.guice
-
- CacheModule() - Constructor for class org.apache.druid.guice.CacheModule
-
- CacheModule(String) - Constructor for class org.apache.druid.guice.CacheModule
-
- CacheModule.HybridCacheModule - Class in org.apache.druid.guice
-
- CacheMonitor - Class in org.apache.druid.client.cache
-
- CacheMonitor(CachePopulatorStats) - Constructor for class org.apache.druid.client.cache.CacheMonitor
-
- CachePopulator - Interface in org.apache.druid.client.cache
-
- CachePopulatorStats - Class in org.apache.druid.client.cache
-
- CachePopulatorStats() - Constructor for class org.apache.druid.client.cache.CachePopulatorStats
-
- CachePopulatorStats.Snapshot - Class in org.apache.druid.client.cache
-
- CacheProvider - Interface in org.apache.druid.client.cache
-
- CacheStats - Class in org.apache.druid.client.cache
-
- CacheStats(long, long, long, long, long, long, long) - Constructor for class org.apache.druid.client.cache.CacheStats
-
- CacheUtil - Class in org.apache.druid.client
-
- CacheUtil() - Constructor for class org.apache.druid.client.CacheUtil
-
- CachingClusteredClient - Class in org.apache.druid.client
-
- CachingClusteredClient(QueryToolChestWarehouse, TimelineServerView, Cache, ObjectMapper, CachePopulator, CacheConfig, DruidHttpClientConfig) - Constructor for class org.apache.druid.client.CachingClusteredClient
-
- CachingCostBalancerStrategy - Class in org.apache.druid.server.coordinator
-
- CachingCostBalancerStrategy(ClusterCostCache, ListeningExecutorService) - Constructor for class org.apache.druid.server.coordinator.CachingCostBalancerStrategy
-
- CachingCostBalancerStrategyFactory - Class in org.apache.druid.server.coordinator
-
- CachingCostBalancerStrategyFactory(ServerInventoryView, Lifecycle) - Constructor for class org.apache.druid.server.coordinator.CachingCostBalancerStrategyFactory
-
- CachingQueryRunner<T> - Class in org.apache.druid.client
-
- CachingQueryRunner(String, SegmentDescriptor, ObjectMapper, Cache, QueryToolChest, QueryRunner<T>, CachePopulator, CacheConfig) - Constructor for class org.apache.druid.client.CachingQueryRunner
-
- CaffeineCache - Class in org.apache.druid.client.cache
-
- CaffeineCacheConfig - Class in org.apache.druid.client.cache
-
- CaffeineCacheConfig() - Constructor for class org.apache.druid.client.cache.CaffeineCacheConfig
-
- CaffeineCacheProvider - Class in org.apache.druid.client.cache
-
- CaffeineCacheProvider() - Constructor for class org.apache.druid.client.cache.CaffeineCacheProvider
-
- calculateInitialTotalCost(List<ServerHolder>) - Method in class org.apache.druid.server.coordinator.CostBalancerStrategy
-
Calculates the initial cost of the Druid segment configuration.
- calculateNormalization(List<ServerHolder>) - Method in class org.apache.druid.server.coordinator.CostBalancerStrategy
-
Calculates the cost normalization.
- canAppendRow() - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
- cancelQuery(String) - Method in class org.apache.druid.server.QueryManager
-
- cancelQuery(String, HttpServletRequest) - Method in class org.apache.druid.server.QueryResource
-
- canCreateReplicant(String) - Method in class org.apache.druid.server.coordinator.ReplicationThrottler
-
- ChangeRequestHistory<T> - Class in org.apache.druid.server.coordination
-
This class keeps a bounded list of segment updates made on the server such as adding/dropping segments.
- ChangeRequestHistory() - Constructor for class org.apache.druid.server.coordination.ChangeRequestHistory
-
- ChangeRequestHistory(int) - Constructor for class org.apache.druid.server.coordination.ChangeRequestHistory
-
- ChangeRequestHistory.Counter - Class in org.apache.druid.server.coordination
-
- ChangeRequestHttpSyncer<T> - Class in org.apache.druid.server.coordination
-
- ChangeRequestHttpSyncer(ObjectMapper, HttpClient, ScheduledExecutorService, URL, String, TypeReference<ChangeRequestsSnapshot<T>>, long, long, ChangeRequestHttpSyncer.Listener<T>) - Constructor for class org.apache.druid.server.coordination.ChangeRequestHttpSyncer
-
- ChangeRequestHttpSyncer.Listener<T> - Interface in org.apache.druid.server.coordination
-
- ChangeRequestsSnapshot<T> - Class in org.apache.druid.server.coordination
-
Return type of SegmentChangeRequestHistory.getRequestsSince(counter).
- ChangeRequestsSnapshot(boolean, String, ChangeRequestHistory.Counter, List<T>) - Constructor for class org.apache.druid.server.coordination.ChangeRequestsSnapshot
-
- ChatHandler - Interface in org.apache.druid.segment.realtime.firehose
-
- ChatHandlerProvider - Interface in org.apache.druid.segment.realtime.firehose
-
- ChatHandlerResource - Class in org.apache.druid.segment.realtime.firehose
-
- ChatHandlerResource(ChatHandlerProvider, DataSourceTaskIdHolder) - Constructor for class org.apache.druid.segment.realtime.firehose.ChatHandlerResource
-
- ChatHandlers - Class in org.apache.druid.segment.realtime.firehose
-
- ChatHandlers() - Constructor for class org.apache.druid.segment.realtime.firehose.ChatHandlers
-
- ChatHandlerServerModule - Class in org.apache.druid.server.initialization.jetty
-
- ChatHandlerServerModule(Properties) - Constructor for class org.apache.druid.server.initialization.jetty.ChatHandlerServerModule
-
- checkFirehoseV2() - Method in class org.apache.druid.segment.realtime.FireDepartment
-
- checkpoint(Integer, String, DataSourceMetadata, DataSourceMetadata) - Method in interface org.apache.druid.indexing.overlord.supervisor.Supervisor
-
The definition of checkpoint is not very strict as currently it does not affect data or control path.
- chooseBestServer(DataSegment, Iterable<ServerHolder>, boolean) - Method in class org.apache.druid.server.coordinator.CostBalancerStrategy
-
For assignment, we want to move to the lowest cost server that isn't already serving the segment.
- chooseNode(Set<String>, byte[]) - Method in class org.apache.druid.server.router.RendezvousHasher
-
- cleanup(DataSegment) - Method in interface org.apache.druid.segment.loading.SegmentLoader
-
- cleanup(DataSegment) - Method in class org.apache.druid.segment.loading.SegmentLoaderLocalCacheManager
-
- clear() - Method in interface org.apache.druid.segment.realtime.appenderator.Appenderator
-
Drop all in-memory and on-disk data, and forget any previously-remembered commit metadata.
- clear() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
- clear() - Method in class org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver
-
- clearDedupCache() - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
- Client - Annotation Type in org.apache.druid.guice.annotations
-
- ClientAppendQuery - Class in org.apache.druid.client.indexing
-
- ClientAppendQuery(String, List<DataSegment>) - Constructor for class org.apache.druid.client.indexing.ClientAppendQuery
-
- ClientCompactQuery - Class in org.apache.druid.client.indexing
-
- ClientCompactQuery(String, List<DataSegment>, boolean, Long, ClientCompactQueryTuningConfig, Map<String, Object>) - Constructor for class org.apache.druid.client.indexing.ClientCompactQuery
-
- ClientCompactQueryTuningConfig - Class in org.apache.druid.client.indexing
-
- ClientCompactQueryTuningConfig(Integer, Integer, IndexSpec, Integer, Long) - Constructor for class org.apache.druid.client.indexing.ClientCompactQueryTuningConfig
-
- ClientInfoResource - Class in org.apache.druid.server
-
- ClientInfoResource(FilteredServerInventoryView, TimelineServerView, SegmentMetadataQueryConfig, AuthConfig, AuthorizerMapper) - Constructor for class org.apache.druid.server.ClientInfoResource
-
- ClientKillQuery - Class in org.apache.druid.client.indexing
-
- ClientKillQuery(String, Interval) - Constructor for class org.apache.druid.client.indexing.ClientKillQuery
-
- ClientMergeQuery - Class in org.apache.druid.client.indexing
-
- ClientMergeQuery(String, List<DataSegment>, List<AggregatorFactory>) - Constructor for class org.apache.druid.client.indexing.ClientMergeQuery
-
- ClientQuerySegmentWalker - Class in org.apache.druid.server
-
- ClientQuerySegmentWalker(ServiceEmitter, CachingClusteredClient, QueryToolChestWarehouse, RetryQueryRunnerConfig, ObjectMapper, ServerConfig, Cache, CacheConfig) - Constructor for class org.apache.druid.server.ClientQuerySegmentWalker
-
- ClientSSLContextBuilder() - Constructor for class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- ClippedFirehoseFactory - Class in org.apache.druid.segment.realtime.firehose
-
Creates firehoses clipped to a particular time interval.
- ClippedFirehoseFactory(FirehoseFactory, Interval) - Constructor for class org.apache.druid.segment.realtime.firehose.ClippedFirehoseFactory
-
- close(String) - Method in interface org.apache.druid.client.cache.Cache
-
- close(String) - Method in class org.apache.druid.client.cache.CaffeineCache
-
- close(String) - Method in class org.apache.druid.client.cache.HybridCache
-
- close(String) - Method in class org.apache.druid.client.cache.MapCache
-
- close(String) - Method in class org.apache.druid.client.cache.MemcachedCache
-
- close() - Method in class org.apache.druid.client.JsonParserIterator
-
- close() - Method in class org.apache.druid.query.lookup.MapLookupExtractorFactory
-
- close() - Method in interface org.apache.druid.segment.realtime.appenderator.Appenderator
-
Stop any currently-running processing and clean up after ourselves.
- close() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
- close() - Method in class org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver
-
Closes this driver.
- close() - Method in class org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver
-
- close() - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory.EventReceiverFirehose
-
- close() - Method in class org.apache.druid.segment.realtime.firehose.IngestSegmentFirehose
-
- close() - Method in class org.apache.druid.segment.realtime.firehose.PredicateFirehose
-
- close() - Method in class org.apache.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifier
-
- close() - Method in interface org.apache.druid.segment.realtime.plumber.SegmentHandoffNotifier
-
Perform any final processing and clean up after ourselves.
- closeNow() - Method in interface org.apache.druid.segment.realtime.appenderator.Appenderator
-
Stop all processing, abandoning current pushes, currently running persist may be allowed to finish if they persist
critical metadata otherwise shutdown immediately.
- closeNow() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
Unannounce the segments and wait for outstanding persists to finish.
- ClusterCostCache - Class in org.apache.druid.server.coordinator.cost
-
- ClusterCostCache.Builder - Class in org.apache.druid.server.coordinator.cost
-
- ClusterResource - Class in org.apache.druid.server.http
-
- ClusterResource(DruidNodeDiscoveryProvider) - Constructor for class org.apache.druid.server.http.ClusterResource
-
- CombiningFirehoseFactory - Class in org.apache.druid.segment.realtime.firehose
-
Creates firehose that combines data from different Firehoses.
- CombiningFirehoseFactory(List<FirehoseFactory>) - Constructor for class org.apache.druid.segment.realtime.firehose.CombiningFirehoseFactory
-
- commit() - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory.EventReceiverFirehose
-
- commit() - Method in class org.apache.druid.segment.realtime.firehose.IngestSegmentFirehose
-
- commit() - Method in class org.apache.druid.segment.realtime.firehose.PredicateFirehose
-
- Committed - Class in org.apache.druid.segment.realtime.appenderator
-
- Committed(Map<String, Integer>, Object) - Constructor for class org.apache.druid.segment.realtime.appenderator.Committed
-
- Committers - Class in org.apache.druid.segment.realtime.plumber
-
- Committers() - Constructor for class org.apache.druid.segment.realtime.plumber.Committers
-
- CompactionSegmentIterator - Interface in org.apache.druid.server.coordinator.helper
-
- CompactionSegmentSearchPolicy - Interface in org.apache.druid.server.coordinator.helper
-
- compactSegments(List<DataSegment>, boolean, long, int, ClientCompactQueryTuningConfig, Map<String, Object>) - Method in class org.apache.druid.client.indexing.HttpIndexingServiceClient
-
- compactSegments(List<DataSegment>, boolean, long, int, ClientCompactQueryTuningConfig, Map<String, Object>) - Method in interface org.apache.druid.client.indexing.IndexingServiceClient
-
- compareAndSwap(List<MetadataCASUpdate>) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- compareTo(Object) - Method in class org.apache.druid.client.DruidServer
-
- compareTo(ServerHolder) - Method in class org.apache.druid.server.coordinator.ServerHolder
-
- comparingByName() - Static method in interface org.apache.druid.server.http.InventoryViewUtils
-
- ComposingEmitterConfig - Class in org.apache.druid.server.emitter
-
- ComposingEmitterConfig() - Constructor for class org.apache.druid.server.emitter.ComposingEmitterConfig
-
- ComposingEmitterModule - Class in org.apache.druid.server.emitter
-
- ComposingEmitterModule() - Constructor for class org.apache.druid.server.emitter.ComposingEmitterModule
-
- ComposingRequestLogger(List<RequestLogger>) - Constructor for class org.apache.druid.server.log.ComposingRequestLoggerProvider.ComposingRequestLogger
-
- ComposingRequestLoggerProvider - Class in org.apache.druid.server.log
-
- ComposingRequestLoggerProvider() - Constructor for class org.apache.druid.server.log.ComposingRequestLoggerProvider
-
- ComposingRequestLoggerProvider.ComposingRequestLogger - Class in org.apache.druid.server.log
-
- compress(byte[]) - Method in class org.apache.druid.client.cache.LZ4Transcoder
-
- compress(String, byte[]) - Method in class org.apache.druid.curator.PotentiallyGzippedCompressionProvider
-
- computeBaseDir(DataSchema) - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- computeCorruptedFileDumpDir(File, DataSchema) - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- computeCost(DataSegment, ServerHolder, boolean) - Method in class org.apache.druid.server.coordinator.CachingCostBalancerStrategy
-
- computeCost(String, DataSegment) - Method in class org.apache.druid.server.coordinator.cost.ClusterCostCache
-
- computeCost(DataSegment, ServerHolder, boolean) - Method in class org.apache.druid.server.coordinator.CostBalancerStrategy
-
- computeCost(DataSegment, ServerHolder, boolean) - Method in class org.apache.druid.server.coordinator.DiskNormalizedCostBalancerStrategy
-
Averages the cost obtained from CostBalancerStrategy.
- computeJointSegmentsCost(DataSegment, DataSegment) - Static method in class org.apache.druid.server.coordinator.CostBalancerStrategy
-
This defines the unnormalized cost function between two segments.
- computePersistDir(DataSchema, Interval) - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- computeResultLevelCacheKey(String) - Static method in class org.apache.druid.client.ResultLevelCacheUtil
-
- computeSegmentCacheKey(String, SegmentDescriptor, byte[]) - Static method in class org.apache.druid.client.CacheUtil
-
- concatenateForRewrite(String, String, String) - Static method in class org.apache.druid.server.JettyUtils
-
Concatenate URI parts, in a way that is useful for proxy servlets.
- config - Variable in class org.apache.druid.metadata.SQLMetadataStorageActionHandlerFactory
-
- CONFIG_KEY - Static variable in class org.apache.druid.server.coordinator.CoordinatorCompactionConfig
-
- CONFIG_KEY - Static variable in class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- CONFIG_KEY - Static variable in class org.apache.druid.server.coordinator.DatasourceWhitelist
-
- ConfigResourceFilter - Class in org.apache.druid.server.http.security
-
Use this ResourceFilter at end points where Druid Cluster configuration is read or written
Here are some example paths where this filter is used -
- druid/worker/v1
- druid/indexer/v1
- druid/coordinator/v1/config
Note - Currently the resource name for all end points is set to "CONFIG" however if more fine grained access control
is required the resource name can be set to specific config properties.
- ConfigResourceFilter(AuthorizerMapper) - Constructor for class org.apache.druid.server.http.security.ConfigResourceFilter
-
- configure(Binder) - Method in class org.apache.druid.curator.CuratorModule
-
- configure(Binder) - Method in class org.apache.druid.curator.discovery.DiscoveryModule
-
- configure(Binder) - Method in class org.apache.druid.guice.AnnouncerModule
-
- configure(Binder) - Method in class org.apache.druid.guice.AWSModule
-
- configure(Binder) - Method in class org.apache.druid.guice.CacheModule
-
- configure(Binder) - Method in class org.apache.druid.guice.CacheModule.HybridCacheModule
-
- configure(Binder) - Method in class org.apache.druid.guice.CoordinatorDiscoveryModule
-
- configure(Binder) - Method in class org.apache.druid.guice.DruidProcessingConfigModule
-
- configure(Binder) - Method in class org.apache.druid.guice.DruidProcessingModule
-
- configure(Binder) - Method in class org.apache.druid.guice.ExpressionModule
-
- configure(Binder) - Method in class org.apache.druid.guice.FirehoseModule
-
- configure(Injector) - Method in class org.apache.druid.guice.http.AbstractHttpClientProvider
-
- configure(Binder) - Method in class org.apache.druid.guice.http.HttpClientModule
-
- configure(Binder) - Method in class org.apache.druid.guice.http.JettyHttpClientModule
-
- configure(Binder) - Method in class org.apache.druid.guice.IndexingServiceDiscoveryModule
-
- configure(Binder) - Method in class org.apache.druid.guice.JavaScriptModule
-
- configure(Binder) - Method in class org.apache.druid.guice.LocalDataStorageDruidModule
-
- configure(Binder) - Method in class org.apache.druid.guice.MetadataConfigModule
-
- configure(Binder) - Method in class org.apache.druid.guice.QueryableModule
-
- configure(Binder) - Method in class org.apache.druid.guice.QueryRunnerFactoryModule
-
- configure(Binder) - Method in class org.apache.druid.guice.QueryToolChestModule
-
- configure(Binder) - Method in class org.apache.druid.guice.RouterProcessingModule
-
- configure(Binder) - Method in class org.apache.druid.guice.security.AuthenticatorModule
-
- configure(Binder) - Method in class org.apache.druid.guice.security.AuthorizerModule
-
- configure(Binder) - Method in class org.apache.druid.guice.security.DruidAuthModule
-
- configure(Binder) - Method in class org.apache.druid.guice.security.EscalatorModule
-
- configure(Binder) - Method in class org.apache.druid.guice.ServerModule
-
- configure(Binder) - Method in class org.apache.druid.guice.ServerViewModule
-
- configure(Binder) - Method in class org.apache.druid.guice.SQLMetadataStorageDruidModule
-
- configure(Binder) - Method in class org.apache.druid.guice.StartupLoggingModule
-
- configure(Binder) - Method in class org.apache.druid.guice.StorageNodeModule
-
- configure(Binder) - Method in class org.apache.druid.initialization.Log4jShutterDownerModule
-
- configure(Binder) - Method in class org.apache.druid.metadata.storage.derby.DerbyMetadataStorageDruidModule
-
- configure(Binder) - Method in class org.apache.druid.query.lookup.LookupModule
-
- configure(Binder) - Method in class org.apache.druid.server.emitter.ComposingEmitterModule
-
- configure(Binder) - Method in class org.apache.druid.server.emitter.EmitterModule
-
- configure(Binder) - Method in class org.apache.druid.server.emitter.HttpEmitterModule
-
- configure(Binder) - Method in class org.apache.druid.server.emitter.LogEmitterModule
-
- configure(Binder) - Method in class org.apache.druid.server.emitter.NoopEmitterModule
-
- configure(Binder) - Method in class org.apache.druid.server.emitter.ParametrizedUriEmitterModule
-
- configure(Binder) - Method in class org.apache.druid.server.initialization.AuthenticatorMapperModule
-
- configure(Binder) - Method in class org.apache.druid.server.initialization.AuthorizerMapperModule
-
- configure(Binder) - Method in class org.apache.druid.server.initialization.jetty.ChatHandlerServerModule
-
- configure(Binder) - Method in class org.apache.druid.server.metrics.MetricsModule
-
- configure(Binder) - Method in class org.apache.druid.server.ZkPathsModule
-
- configureServlets() - Method in class org.apache.druid.server.initialization.jetty.JettyServerModule
-
- connect() - Method in class org.apache.druid.segment.realtime.FireDepartment
-
- connect(Object) - Method in class org.apache.druid.segment.realtime.FireDepartment
-
- connect(InputRowParser, File) - Method in class org.apache.druid.segment.realtime.firehose.ClippedFirehoseFactory
-
- connect(InputRowParser, File) - Method in class org.apache.druid.segment.realtime.firehose.CombiningFirehoseFactory
-
- connect(InputRowParser<Map<String, Object>>, File) - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory
-
- connect(InputRowParser, File) - Method in class org.apache.druid.segment.realtime.firehose.FixedCountFirehoseFactory
-
- connect(InputRowParser, File) - Method in class org.apache.druid.segment.realtime.firehose.TimedShutoffFirehoseFactory
-
- ConnectionCountServerSelectorStrategy - Class in org.apache.druid.client.selector
-
- ConnectionCountServerSelectorStrategy() - Constructor for class org.apache.druid.client.selector.ConnectionCountServerSelectorStrategy
-
- connector - Variable in class org.apache.druid.metadata.SQLMetadataStorageActionHandlerFactory
-
- connectorIsTransientException(Throwable) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- ConsistentHashAvaticaConnectionBalancer - Class in org.apache.druid.server.router
-
- ConsistentHashAvaticaConnectionBalancer() - Constructor for class org.apache.druid.server.router.ConsistentHashAvaticaConnectionBalancer
-
- ConsistentHasher - Class in org.apache.druid.server.router
-
Distributes objects across a set of node keys using consistent hashing.
- ConsistentHasher(HashFunction) - Constructor for class org.apache.druid.server.router.ConsistentHasher
-
- contains(String) - Method in class org.apache.druid.server.coordinator.DatasourceWhitelist
-
- containsSegment(DataSegment) - Method in class org.apache.druid.client.DruidDataSource
-
- Coordinator - Annotation Type in org.apache.druid.client.coordinator
-
- coordinator - Variable in class org.apache.druid.server.coordinator.helper.DruidCoordinatorBalancer
-
- CoordinatorBasedSegmentHandoffNotifier - Class in org.apache.druid.segment.realtime.plumber
-
- CoordinatorBasedSegmentHandoffNotifier(String, CoordinatorClient, CoordinatorBasedSegmentHandoffNotifierConfig) - Constructor for class org.apache.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifier
-
- CoordinatorBasedSegmentHandoffNotifierConfig - Class in org.apache.druid.segment.realtime.plumber
-
- CoordinatorBasedSegmentHandoffNotifierConfig() - Constructor for class org.apache.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifierConfig
-
- CoordinatorBasedSegmentHandoffNotifierFactory - Class in org.apache.druid.segment.realtime.plumber
-
- CoordinatorBasedSegmentHandoffNotifierFactory(CoordinatorClient, CoordinatorBasedSegmentHandoffNotifierConfig) - Constructor for class org.apache.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifierFactory
-
- CoordinatorClient - Class in org.apache.druid.client.coordinator
-
- CoordinatorClient(ObjectMapper, DruidLeaderClient) - Constructor for class org.apache.druid.client.coordinator.CoordinatorClient
-
- CoordinatorCompactionConfig - Class in org.apache.druid.server.coordinator
-
- CoordinatorCompactionConfig(List<DataSourceCompactionConfig>, Double, Integer) - Constructor for class org.apache.druid.server.coordinator.CoordinatorCompactionConfig
-
- CoordinatorCompactionConfigsResource - Class in org.apache.druid.server.http
-
- CoordinatorCompactionConfigsResource(JacksonConfigManager) - Constructor for class org.apache.druid.server.http.CoordinatorCompactionConfigsResource
-
- CoordinatorDiscoveryModule - Class in org.apache.druid.guice
-
- CoordinatorDiscoveryModule() - Constructor for class org.apache.druid.guice.CoordinatorDiscoveryModule
-
- CoordinatorDynamicConfig - Class in org.apache.druid.server.coordinator
-
This class is for users to change their configurations while their Druid cluster is running.
- CoordinatorDynamicConfig(long, long, int, int, int, int, int, boolean, Object, boolean, Object, int) - Constructor for class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- CoordinatorDynamicConfig.Builder - Class in org.apache.druid.server.coordinator
-
- CoordinatorDynamicConfigsResource - Class in org.apache.druid.server.http
-
- CoordinatorDynamicConfigsResource(JacksonConfigManager, AuditManager) - Constructor for class org.apache.druid.server.http.CoordinatorDynamicConfigsResource
-
- CoordinatorIndexingServiceHelper - Annotation Type in org.apache.druid.guice.annotations
-
- CoordinatorOverlordServiceConfig - Class in org.apache.druid.server.coordinator
-
- CoordinatorOverlordServiceConfig(Boolean, String) - Constructor for class org.apache.druid.server.coordinator.CoordinatorOverlordServiceConfig
-
- CoordinatorRedirectInfo - Class in org.apache.druid.server.http
-
- CoordinatorRedirectInfo(DruidCoordinator) - Constructor for class org.apache.druid.server.http.CoordinatorRedirectInfo
-
- CoordinatorResource - Class in org.apache.druid.server.http
-
- CoordinatorResource(DruidCoordinator) - Constructor for class org.apache.druid.server.http.CoordinatorResource
-
- CoordinatorRuleManager - Class in org.apache.druid.server.router
-
- CoordinatorRuleManager(ObjectMapper, Supplier<TieredBrokerConfig>, DruidLeaderClient) - Constructor for class org.apache.druid.server.router.CoordinatorRuleManager
-
- CoordinatorRunnable(List<DruidCoordinatorHelper>, int) - Constructor for class org.apache.druid.server.coordinator.DruidCoordinator.CoordinatorRunnable
-
- CoordinatorSelectorConfig - Class in org.apache.druid.client.coordinator
-
- CoordinatorSelectorConfig() - Constructor for class org.apache.druid.client.coordinator.CoordinatorSelectorConfig
-
- CoordinatorServerView - Class in org.apache.druid.client
-
ServerView of coordinator for the state of segments being loaded in the cluster.
- CoordinatorServerView(ServerInventoryView) - Constructor for class org.apache.druid.client.CoordinatorServerView
-
- CoordinatorStats - Class in org.apache.druid.server.coordinator
-
- CoordinatorStats() - Constructor for class org.apache.druid.server.coordinator.CoordinatorStats
-
- cost(DataSegment) - Method in class org.apache.druid.server.coordinator.cost.SegmentsCostCache
-
- CostBalancerStrategy - Class in org.apache.druid.server.coordinator
-
- CostBalancerStrategy(ListeningExecutorService) - Constructor for class org.apache.druid.server.coordinator.CostBalancerStrategy
-
- CostBalancerStrategyFactory - Class in org.apache.druid.server.coordinator
-
- CostBalancerStrategyFactory() - Constructor for class org.apache.druid.server.coordinator.CostBalancerStrategyFactory
-
- Counter(long) - Constructor for class org.apache.druid.server.coordination.ChangeRequestHistory.Counter
-
- Counter(long, long) - Constructor for class org.apache.druid.server.coordination.ChangeRequestHistory.Counter
-
- create(CaffeineCacheConfig) - Static method in class org.apache.druid.client.cache.CaffeineCache
-
- create(CaffeineCacheConfig, Executor) - Static method in class org.apache.druid.client.cache.CaffeineCache
-
- create(long) - Static method in class org.apache.druid.client.cache.MapCache
-
- create(MemcachedCacheConfig) - Static method in class org.apache.druid.client.cache.MemcachedCache
-
- create() - Method in class org.apache.druid.client.cache.MemcachedOperationQueueFactory
-
- create(String, MetadataStorageActionHandlerTypes<A, B, C, D>) - Method in class org.apache.druid.metadata.DerbyMetadataStorageActionHandlerFactory
-
- create(String, MetadataStorageActionHandlerTypes<EntryType, StatusType, LogType, LockType>) - Method in class org.apache.druid.metadata.MySQLMetadataStorageActionHandlerFactory
-
- create(String, MetadataStorageActionHandlerTypes<EntryType, StatusType, LogType, LockType>) - Method in class org.apache.druid.metadata.PostgreSQLMetadataStorageActionHandlerFactory
-
- create(String, MetadataStorageActionHandlerTypes<EntryType, StatusType, LogType, LockType>) - Method in class org.apache.druid.metadata.SQLServerMetadataStorageActionHandlerFactory
-
- create(Map<SegmentIdentifier, Integer>, Object) - Static method in class org.apache.druid.segment.realtime.appenderator.Committed
-
- create(Period) - Method in class org.apache.druid.segment.realtime.plumber.MessageTimeRejectionPolicyFactory
-
- create(Period) - Method in class org.apache.druid.segment.realtime.plumber.NoopRejectionPolicyFactory
-
- create(Period) - Method in interface org.apache.druid.segment.realtime.plumber.RejectionPolicyFactory
-
- create(Period) - Method in class org.apache.druid.segment.realtime.plumber.ServerTimeRejectionPolicyFactory
-
- createAuditTable() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createBalancerStrategy(ListeningExecutorService) - Method in interface org.apache.druid.server.coordinator.BalancerStrategyFactory
-
- createBalancerStrategy(ListeningExecutorService) - Method in class org.apache.druid.server.coordinator.CachingCostBalancerStrategyFactory
-
- createBalancerStrategy(ListeningExecutorService) - Method in class org.apache.druid.server.coordinator.CostBalancerStrategyFactory
-
- createBalancerStrategy(ListeningExecutorService) - Method in class org.apache.druid.server.coordinator.DiskNormalizedCostBalancerStrategyFactory
-
- createBalancerStrategy(ListeningExecutorService) - Method in class org.apache.druid.server.coordinator.RandomBalancerStrategyFactory
-
- createBindingChoices(Binder, String) - Method in class org.apache.druid.guice.SQLMetadataStorageDruidModule
-
This function only needs to be called by the default SQL metadata storage module
Other modules should default to calling super.configure(...) alone
- createChunk(T) - Method in class org.apache.druid.timeline.partition.LinearShardSpec
-
- createChunk(T) - Method in class org.apache.druid.timeline.partition.NumberedShardSpec
-
- createChunk(T) - Method in class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- createCompletedTaskInfoQuery(Handle, DateTime, Integer, String) - Method in class org.apache.druid.metadata.DerbyMetadataStorageActionHandler
-
- createCompletedTaskInfoQuery(Handle, DateTime, Integer, String) - Method in class org.apache.druid.metadata.MySQLMetadataStorageActionHandler
-
- createCompletedTaskInfoQuery(Handle, DateTime, Integer, String) - Method in class org.apache.druid.metadata.PostgreSQLMetadataStorageActionHandler
-
- createCompletedTaskInfoQuery(Handle, DateTime, Integer, String) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- createCompletedTaskInfoQuery(Handle, DateTime, Integer, String) - Method in class org.apache.druid.metadata.SQLServerMetadataStorageActionHandler
-
- createConfigTable(String) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createConfigTable() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createContext(String, boolean) - Method in class org.apache.druid.server.QueryResource
-
- createDataSourceTable(String) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createDataSourceTable() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createDefaultExecutor() - Static method in class org.apache.druid.curator.cache.PathChildrenCacheFactory.Builder
-
- createDefaultRule(IDBI, String, String, ObjectMapper) - Static method in class org.apache.druid.metadata.SQLMetadataRuleManager
-
- createEntryTable(String) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createEscalatedAuthenticationResult() - Method in interface org.apache.druid.server.security.Escalator
-
- createEscalatedAuthenticationResult() - Method in class org.apache.druid.server.security.NoopEscalator
-
- createEscalatedClient(HttpClient) - Method in interface org.apache.druid.server.security.Escalator
-
Return a client that sends requests with the format/information necessary to authenticate successfully
against this Escalator's authentication scheme using the identity of the internal system user.
- createEscalatedClient(HttpClient) - Method in class org.apache.druid.server.security.NoopEscalator
-
- createExecutor() - Method in enum org.apache.druid.client.cache.CacheExecutorFactory
-
- createExecutor() - Method in class org.apache.druid.client.cache.CaffeineCacheConfig
-
- createHttpClient() - Method in class org.apache.druid.server.AsyncManagementForwardingServlet
-
- createHttpClient() - Method in class org.apache.druid.server.AsyncQueryForwardingServlet
-
- createHttpClient() - Method in class org.apache.druid.server.http.OverlordProxyServlet
-
- createIfNotExists(CuratorFramework, String, CreateMode, byte[], int) - Static method in class org.apache.druid.curator.CuratorUtils
-
Create znode if it does not already exist.
- createLockTable(String, String) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createLogTable(String, String) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createOffline(DataSchema, AppenderatorConfig, FireDepartmentMetrics, DataSegmentPusher, ObjectMapper, IndexIO, IndexMerger) - Static method in class org.apache.druid.segment.realtime.appenderator.Appenderators
-
- createOrSet(CuratorFramework, String, CreateMode, byte[], int) - Static method in class org.apache.druid.curator.CuratorUtils
-
Create znode if it does not already exist.
- createOrUpdateLookup(String, String, String, String, InputStream, HttpServletRequest) - Method in class org.apache.druid.server.http.LookupCoordinatorResource
-
- createPendingSegmentsTable(String) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createPendingSegmentsTable() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createRealtime(DataSchema, AppenderatorConfig, FireDepartmentMetrics, DataSegmentPusher, ObjectMapper, IndexIO, IndexMerger, QueryRunnerFactoryConglomerate, DataSegmentAnnouncer, ServiceEmitter, ExecutorService, Cache, CacheConfig, CachePopulatorStats) - Static method in class org.apache.druid.segment.realtime.appenderator.Appenderators
-
- createRulesTable(String) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createRulesTable() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createRunningSpec() - Method in class org.apache.druid.indexing.overlord.supervisor.NoopSupervisorSpec
-
- createRunningSpec() - Method in interface org.apache.druid.indexing.overlord.supervisor.SupervisorSpec
-
- createSegmentHandoffNotifier(String) - Method in class org.apache.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifierFactory
-
- createSegmentHandoffNotifier(String) - Method in class org.apache.druid.segment.realtime.plumber.NoopSegmentHandoffNotifierFactory
-
- createSegmentHandoffNotifier(String) - Method in interface org.apache.druid.segment.realtime.plumber.SegmentHandoffNotifierFactory
-
- createSegmentTable(String) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createSegmentTable() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createSelector(String) - Method in class org.apache.druid.curator.discovery.ServerDiscoveryFactory
-
Deprecated.
- createSSLContext(String, String, String, String, PasswordProvider, String, String, String, String, PasswordProvider, PasswordProvider) - Static method in class org.apache.druid.server.security.TLSUtils
-
- createSupervisor() - Method in class org.apache.druid.indexing.overlord.supervisor.NoopSupervisorSpec
-
- createSupervisor() - Method in interface org.apache.druid.indexing.overlord.supervisor.SupervisorSpec
-
- createSupervisorsTable(String) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createSupervisorsTable() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createSuspendedSpec() - Method in class org.apache.druid.indexing.overlord.supervisor.NoopSupervisorSpec
-
- createSuspendedSpec() - Method in interface org.apache.druid.indexing.overlord.supervisor.SupervisorSpec
-
- createTable(String, Iterable<String>) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- createTaskTables() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- CuratorConfig - Class in org.apache.druid.curator
-
- CuratorConfig() - Constructor for class org.apache.druid.curator.CuratorConfig
-
- CuratorDataSegmentServerAnnouncer - Class in org.apache.druid.server.coordination
-
Deprecated.
- CuratorDataSegmentServerAnnouncer(DruidServerMetadata, ZkPathsConfig, Announcer, ObjectMapper) - Constructor for class org.apache.druid.server.coordination.CuratorDataSegmentServerAnnouncer
-
Deprecated.
- CuratorDiscoveryConfig - Class in org.apache.druid.server.initialization
-
- CuratorDiscoveryConfig() - Constructor for class org.apache.druid.server.initialization.CuratorDiscoveryConfig
-
- CuratorDruidLeaderSelector - Class in org.apache.druid.curator.discovery
-
- CuratorDruidLeaderSelector(CuratorFramework, DruidNode, String) - Constructor for class org.apache.druid.curator.discovery.CuratorDruidLeaderSelector
-
- CuratorDruidNodeAnnouncer - Class in org.apache.druid.curator.discovery
-
- CuratorDruidNodeAnnouncer(Announcer, ZkPathsConfig, ObjectMapper) - Constructor for class org.apache.druid.curator.discovery.CuratorDruidNodeAnnouncer
-
- CuratorDruidNodeDiscoveryProvider - Class in org.apache.druid.curator.discovery
-
- CuratorDruidNodeDiscoveryProvider(CuratorFramework, ZkPathsConfig, ObjectMapper) - Constructor for class org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider
-
- CuratorInventoryManager<ContainerClass,InventoryClass> - Class in org.apache.druid.curator.inventory
-
Deprecated.
- CuratorInventoryManager(CuratorFramework, InventoryManagerConfig, ExecutorService, CuratorInventoryManagerStrategy<ContainerClass, InventoryClass>) - Constructor for class org.apache.druid.curator.inventory.CuratorInventoryManager
-
Deprecated.
- CuratorInventoryManagerStrategy<ContainerClass,InventoryClass> - Interface in org.apache.druid.curator.inventory
-
- CuratorLoadQueuePeon - Class in org.apache.druid.server.coordinator
-
Deprecated.
- CuratorModule - Class in org.apache.druid.curator
-
- CuratorModule() - Constructor for class org.apache.druid.curator.CuratorModule
-
- CuratorServiceAnnouncer - Class in org.apache.druid.curator.discovery
-
Deprecated.
- CuratorServiceAnnouncer(ServiceDiscovery<Void>) - Constructor for class org.apache.druid.curator.discovery.CuratorServiceAnnouncer
-
Deprecated.
- CuratorServiceUtils - Class in org.apache.druid.curator.discovery
-
Deprecated.
- CuratorServiceUtils() - Constructor for class org.apache.druid.curator.discovery.CuratorServiceUtils
-
Deprecated.
- CuratorUtils - Class in org.apache.druid.curator
-
- CuratorUtils() - Constructor for class org.apache.druid.curator.CuratorUtils
-
- currentlyMovingSegments - Variable in class org.apache.druid.server.coordinator.helper.DruidCoordinatorBalancer
-
- CustomExceptionMapper - Class in org.apache.druid.server.initialization.jetty
-
- CustomExceptionMapper() - Constructor for class org.apache.druid.server.initialization.jetty.CustomExceptionMapper
-
- CustomTierSelectorStrategy - Class in org.apache.druid.client.selector
-
- CustomTierSelectorStrategy(ServerSelectorStrategy, CustomTierSelectorStrategyConfig) - Constructor for class org.apache.druid.client.selector.CustomTierSelectorStrategy
-
- CustomTierSelectorStrategyConfig - Class in org.apache.druid.client.selector
-
- CustomTierSelectorStrategyConfig() - Constructor for class org.apache.druid.client.selector.CustomTierSelectorStrategyConfig
-
- CustomVersioningPolicy - Class in org.apache.druid.segment.realtime.plumber
-
- CustomVersioningPolicy(String) - Constructor for class org.apache.druid.segment.realtime.plumber.CustomVersioningPolicy
-
- DATA_SOURCE_BINDING - Static variable in class org.apache.druid.server.metrics.DataSourceTaskIdHolder
-
- DataNodeService - Class in org.apache.druid.discovery
-
Metadata announced by any node that serves segments.
- DataNodeService(String, long, ServerType, int) - Constructor for class org.apache.druid.discovery.DataNodeService
-
- DataSchema - Class in org.apache.druid.segment.indexing
-
- DataSchema(String, Map<String, Object>, AggregatorFactory[], GranularitySpec, TransformSpec, ObjectMapper) - Constructor for class org.apache.druid.segment.indexing.DataSchema
-
- DataSegmentAnnouncer - Interface in org.apache.druid.server.coordination
-
- DataSegmentAnnouncerProvider - Interface in org.apache.druid.server.coordination
-
- DataSegmentChangeCallback - Interface in org.apache.druid.server.coordination
-
- DataSegmentChangeHandler - Interface in org.apache.druid.server.coordination
-
- DataSegmentChangeRequest - Interface in org.apache.druid.server.coordination
-
- DataSegmentChangeRequestAndStatus(DataSegmentChangeRequest, SegmentLoadDropHandler.Status) - Constructor for class org.apache.druid.server.coordination.SegmentLoadDropHandler.DataSegmentChangeRequestAndStatus
-
- DataSegmentServerAnnouncer - Interface in org.apache.druid.server.coordination
-
Deprecated.
- DATASOURCE_READ_RA_GENERATOR - Static variable in class org.apache.druid.server.security.AuthorizationUtils
-
Function for the common pattern of generating a resource-action for reading from a datasource, using the
datasource name.
- DATASOURCE_WRITE_RA_GENERATOR - Static variable in class org.apache.druid.server.security.AuthorizationUtils
-
Function for the common pattern of generating a resource-action for reading from a datasource, using the
datasource name.
- DataSourceCompactionConfig - Class in org.apache.druid.server.coordinator
-
- DataSourceCompactionConfig(String, Boolean, Integer, Long, Long, Integer, Period, ClientCompactQueryTuningConfig, Map<String, Object>) - Constructor for class org.apache.druid.server.coordinator.DataSourceCompactionConfig
-
- DataSourceMetadata - Interface in org.apache.druid.indexing.overlord
-
Commit metadata for a dataSource.
- DatasourceResourceFilter - Class in org.apache.druid.server.http.security
-
Use this ResourceFilter when the datasource information is present after "datasources" segment in the request Path
Here are some example paths where this filter is used -
- druid/coordinator/v1/datasources/{dataSourceName}/...
- DatasourceResourceFilter(AuthorizerMapper) - Constructor for class org.apache.druid.server.http.security.DatasourceResourceFilter
-
- DatasourcesResource - Class in org.apache.druid.server.http
-
- DatasourcesResource(CoordinatorServerView, MetadataSegmentManager, IndexingServiceClient, AuthConfig, AuthorizerMapper) - Constructor for class org.apache.druid.server.http.DatasourcesResource
-
- DataSourceState() - Constructor for class org.apache.druid.server.SegmentManager.DataSourceState
-
- DataSourceTaskIdHolder - Class in org.apache.druid.server.metrics
-
- DataSourceTaskIdHolder() - Constructor for class org.apache.druid.server.metrics.DataSourceTaskIdHolder
-
- DatasourceWhitelist - Class in org.apache.druid.server.coordinator
-
- DatasourceWhitelist(Set<String>) - Constructor for class org.apache.druid.server.coordinator.DatasourceWhitelist
-
- DbSegmentPublisherConfig - Class in org.apache.druid.segment.realtime
-
- DbSegmentPublisherConfig() - Constructor for class org.apache.druid.segment.realtime.DbSegmentPublisherConfig
-
- deadContainer(ContainerClass) - Method in interface org.apache.druid.curator.inventory.CuratorInventoryManagerStrategy
-
- decompress(byte[]) - Method in class org.apache.druid.client.cache.LZ4Transcoder
-
- decompress(String, byte[]) - Method in class org.apache.druid.curator.PotentiallyGzippedCompressionProvider
-
- decorate(DimensionSelector) - Method in class org.apache.druid.query.dimension.LookupDimensionSpec
-
- decorateProxyRequest(HttpServletRequest, HttpServletResponse, Request) - Method in interface org.apache.druid.server.security.Authenticator
-
This is used to add some Headers or Authentication token/results that can be used by down stream target host.
- dedup() - Method in class org.apache.druid.segment.realtime.FireDepartmentMetrics
-
- DEFAULT_ALL_HOST_TIMEOUT - Static variable in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- DEFAULT_BROKER_SERVICE_NAME - Static variable in class org.apache.druid.server.router.TieredBrokerConfig
-
- DEFAULT_COORDINATOR_SERVICE_NAME - Static variable in class org.apache.druid.server.router.TieredBrokerConfig
-
- DEFAULT_GZIP_INFLATE_BUFFER_SIZE - Static variable in class org.apache.druid.server.initialization.ServerConfig
-
- DEFAULT_HOST_TIMEOUT - Static variable in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- DEFAULT_LOG_PARSE_EXCEPTIONS - Static variable in interface org.apache.druid.segment.indexing.TuningConfig
-
- DEFAULT_MAX_BYTES_IN_MEMORY - Static variable in interface org.apache.druid.segment.indexing.TuningConfig
-
- DEFAULT_MAX_PARSE_EXCEPTIONS - Static variable in interface org.apache.druid.segment.indexing.TuningConfig
-
- DEFAULT_MAX_ROWS_IN_MEMORY - Static variable in interface org.apache.druid.segment.indexing.TuningConfig
-
- DEFAULT_MAX_SAVED_PARSE_EXCEPTIONS - Static variable in interface org.apache.druid.segment.indexing.TuningConfig
-
- DEFAULT_MAX_ZNODE_BYTES - Static variable in class org.apache.druid.curator.CuratorUtils
-
- DEFAULT_NUM_REPLICANTS - Static variable in class org.apache.druid.client.DruidServer
-
- DEFAULT_PRIORITY - Static variable in class org.apache.druid.client.DruidServer
-
- DEFAULT_RETRY_COUNT - Static variable in class org.apache.druid.segment.loading.LocalDataSegmentPuller
-
- DEFAULT_SERVICE_NAME - Static variable in class org.apache.druid.client.coordinator.CoordinatorSelectorConfig
-
- DEFAULT_SERVICE_NAME - Static variable in class org.apache.druid.client.indexing.IndexingServiceSelectorConfig
-
- DEFAULT_TARGET_COMPACTION_SIZE_BYTES - Static variable in class org.apache.druid.server.coordinator.DataSourceCompactionConfig
-
- DEFAULT_TIER - Static variable in class org.apache.druid.client.DruidServer
-
- DefaultOfflineAppenderatorFactory - Class in org.apache.druid.segment.realtime.appenderator
-
- DefaultOfflineAppenderatorFactory(DataSegmentPusher, ObjectMapper, IndexIO, IndexMerger) - Constructor for class org.apache.druid.segment.realtime.appenderator.DefaultOfflineAppenderatorFactory
-
- defaultPath(String) - Method in class org.apache.druid.server.initialization.ZkPathsConfig
-
- DefaultRealtimeAppenderatorFactory - Class in org.apache.druid.segment.realtime.appenderator
-
- DefaultRealtimeAppenderatorFactory(ServiceEmitter, QueryRunnerFactoryConglomerate, DataSegmentAnnouncer, ExecutorService, DataSegmentPusher, ObjectMapper, IndexIO, IndexMerger, Cache, CacheConfig, CachePopulatorStats) - Constructor for class org.apache.druid.segment.realtime.appenderator.DefaultRealtimeAppenderatorFactory
-
- delete(String) - Method in class org.apache.druid.server.listener.resource.AbstractListenerHandler
-
Delete the object for a particular id
- deleteAllRecords(String) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- deleteCompactionConfig(String, String, String, HttpServletRequest) - Method in class org.apache.druid.server.http.CoordinatorCompactionConfigsResource
-
- deleteDataSource(String, String, String) - Method in class org.apache.druid.server.http.DatasourcesResource
-
Deprecated.
- deleteDataSourceMetadata(String) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
Removes entry for 'dataSource' from the dataSource metadata table.
- deleteDataSourceMetadata(String) - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
- deleteDatasourceSegment(String, String) - Method in class org.apache.druid.server.http.DatasourcesResource
-
- deleteDataSourceSpecificInterval(String, String) - Method in class org.apache.druid.server.http.DatasourcesResource
-
- deleteLookup(String, String, String, String, HttpServletRequest) - Method in class org.apache.druid.server.http.LookupCoordinatorResource
-
- deleteLookup(String, String, AuditInfo) - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManager
-
- deletePendingSegments(String, Interval) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
Delete pending segments created in the given interval for the given dataSource from the pending segments table.
- deletePendingSegments(String, Interval) - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
- deleteSegments(Set<DataSegment>) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
- deleteSegments(Set<DataSegment>) - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
- delta(CachePopulatorStats.Snapshot) - Method in class org.apache.druid.client.cache.CachePopulatorStats.Snapshot
-
- delta(CacheStats) - Method in class org.apache.druid.client.cache.CacheStats
-
- deltaSync(List<T>) - Method in interface org.apache.druid.server.coordination.ChangeRequestHttpSyncer.Listener
-
- DerbyConnector - Class in org.apache.druid.metadata.storage.derby
-
- DerbyConnector(MetadataStorage, Supplier<MetadataStorageConnectorConfig>, Supplier<MetadataStorageTablesConfig>) - Constructor for class org.apache.druid.metadata.storage.derby.DerbyConnector
-
- DerbyConnector(MetadataStorage, Supplier<MetadataStorageConnectorConfig>, Supplier<MetadataStorageTablesConfig>, DBI) - Constructor for class org.apache.druid.metadata.storage.derby.DerbyConnector
-
- DerbyMetadataStorage - Class in org.apache.druid.metadata.storage.derby
-
- DerbyMetadataStorage(MetadataStorageConnectorConfig) - Constructor for class org.apache.druid.metadata.storage.derby.DerbyMetadataStorage
-
- DerbyMetadataStorageActionHandler<EntryType,StatusType,LogType,LockType> - Class in org.apache.druid.metadata
-
- DerbyMetadataStorageActionHandlerFactory - Class in org.apache.druid.metadata
-
- DerbyMetadataStorageActionHandlerFactory(SQLMetadataConnector, MetadataStorageTablesConfig, ObjectMapper) - Constructor for class org.apache.druid.metadata.DerbyMetadataStorageActionHandlerFactory
-
- DerbyMetadataStorageDruidModule - Class in org.apache.druid.metadata.storage.derby
-
- DerbyMetadataStorageDruidModule() - Constructor for class org.apache.druid.metadata.storage.derby.DerbyMetadataStorageDruidModule
-
- DerbyMetadataStorageProvider - Class in org.apache.druid.metadata.storage.derby
-
- DerbyMetadataStorageProvider(MetadataStorageConnectorConfig) - Constructor for class org.apache.druid.metadata.storage.derby.DerbyMetadataStorageProvider
-
- deserializeContainer(byte[]) - Method in interface org.apache.druid.curator.inventory.CuratorInventoryManagerStrategy
-
- deserializeInventory(byte[]) - Method in interface org.apache.druid.curator.inventory.CuratorInventoryManagerStrategy
-
- destroy() - Method in class org.apache.druid.server.AsyncQueryForwardingServlet
-
- destroy() - Method in class org.apache.druid.server.http.RedirectFilter
-
- destroy() - Method in class org.apache.druid.server.initialization.jetty.LimitRequestsFilter
-
- destroy() - Method in class org.apache.druid.server.security.AllowOptionsResourceFilter
-
- destroy() - Method in class org.apache.druid.server.security.AuthenticationWrappingFilter
-
- destroy() - Method in class org.apache.druid.server.security.PreResponseAuthorizationCheckFilter
-
- destroy() - Method in class org.apache.druid.server.security.SecuritySanityCheckFilter
-
- destroy() - Method in class org.apache.druid.server.security.UnsecuredResourceFilter
-
- DirectDruidClient<T> - Class in org.apache.druid.client
-
- DirectDruidClient(QueryToolChestWarehouse, QueryWatcher, ObjectMapper, HttpClient, String, String, ServiceEmitter) - Constructor for class org.apache.druid.client.DirectDruidClient
-
- discoverNodesInTier(String) - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManager
-
- discoverTiers() - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManager
-
- DISCOVERY_SERVICE_KEY - Static variable in class org.apache.druid.discovery.DataNodeService
-
- DISCOVERY_SERVICE_KEY - Static variable in class org.apache.druid.discovery.LookupNodeService
-
- DISCOVERY_SERVICE_KEY - Static variable in class org.apache.druid.discovery.WorkerNodeService
-
- discoveryAnnouncementBinder(Binder) - Static method in class org.apache.druid.guice.DruidBinders
-
- DiscoveryDruidNode - Class in org.apache.druid.discovery
-
Representation of all information related to discovery of a node and all the other metadata associated with
the node per nodeType such as broker, historical etc.
- DiscoveryDruidNode(DruidNode, String, Map<String, DruidService>) - Constructor for class org.apache.druid.discovery.DiscoveryDruidNode
-
- DiscoveryModule - Class in org.apache.druid.curator.discovery
-
The DiscoveryModule allows for the registration of Keys of DruidNode objects, which it intends to be
automatically announced at the end of the lifecycle start.
- DiscoveryModule() - Constructor for class org.apache.druid.curator.discovery.DiscoveryModule
-
- DiscoverySelector<T> - Interface in org.apache.druid.client.selector
-
- DiskNormalizedCostBalancerStrategy - Class in org.apache.druid.server.coordinator
-
- DiskNormalizedCostBalancerStrategy(ListeningExecutorService) - Constructor for class org.apache.druid.server.coordinator.DiskNormalizedCostBalancerStrategy
-
- DiskNormalizedCostBalancerStrategyFactory - Class in org.apache.druid.server.coordinator
-
- DiskNormalizedCostBalancerStrategyFactory() - Constructor for class org.apache.druid.server.coordinator.DiskNormalizedCostBalancerStrategyFactory
-
- doAudit(AuditEntry) - Method in class org.apache.druid.server.audit.SQLAuditManager
-
- doAudit(AuditEntry, Handle) - Method in class org.apache.druid.server.audit.SQLAuditManager
-
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.druid.server.http.RedirectFilter
-
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.druid.server.initialization.jetty.LimitRequestsFilter
-
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.druid.server.security.AllowOptionsResourceFilter
-
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.druid.server.security.AuthenticationWrappingFilter
-
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.druid.server.security.PreResponseAuthorizationCheckFilter
-
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.druid.server.security.SecuritySanityCheckFilter
-
- doFilter(ServletRequest, ServletResponse, FilterChain) - Method in class org.apache.druid.server.security.UnsecuredResourceFilter
-
- doGet(HttpServletRequest) - Method in class org.apache.druid.server.StatusResource
-
- doLocal(String) - Method in class org.apache.druid.server.http.CoordinatorRedirectInfo
-
- doLocal(String) - Method in interface org.apache.druid.server.http.RedirectInfo
-
- doMonitor(ServiceEmitter) - Method in interface org.apache.druid.client.cache.Cache
-
Custom metrics not covered by CacheStats may be emitted by this method.
- doMonitor(ServiceEmitter) - Method in class org.apache.druid.client.cache.CacheMonitor
-
- doMonitor(ServiceEmitter) - Method in class org.apache.druid.client.cache.CaffeineCache
-
- doMonitor(ServiceEmitter) - Method in class org.apache.druid.client.cache.HybridCache
-
- doMonitor(ServiceEmitter) - Method in class org.apache.druid.client.cache.MapCache
-
- doMonitor(ServiceEmitter) - Method in class org.apache.druid.client.cache.MemcachedCache
-
- doMonitor(ServiceEmitter) - Method in class org.apache.druid.segment.realtime.RealtimeMetricsMonitor
-
- doMonitor(ServiceEmitter) - Method in class org.apache.druid.server.emitter.HttpEmittingMonitor
-
- doMonitor(ServiceEmitter) - Method in class org.apache.druid.server.initialization.jetty.JettyServerModule.JettyMonitor
-
- doMonitor(ServiceEmitter) - Method in class org.apache.druid.server.metrics.EventReceiverFirehoseMonitor
-
- doMonitor(ServiceEmitter) - Method in class org.apache.druid.server.metrics.HistoricalMetricsMonitor
-
- doMonitor(ServiceEmitter) - Method in class org.apache.druid.server.metrics.QueryCountStatsMonitor
-
- doPost(InputStream, String, HttpServletRequest) - Method in class org.apache.druid.server.QueryResource
-
- doService(HttpServletRequest, HttpServletResponse) - Method in class org.apache.druid.server.AsyncQueryForwardingServlet
-
- doTaskChat(String, HttpHeaders) - Method in class org.apache.druid.segment.realtime.firehose.ChatHandlerResource
-
- drainTo(Collection<? super E>) - Method in class org.apache.druid.client.cache.BytesBoundedLinkedQueue
-
- drainTo(Collection<? super E>, int) - Method in class org.apache.druid.client.cache.BytesBoundedLinkedQueue
-
- drop(SegmentIdentifier) - Method in interface org.apache.druid.segment.realtime.appenderator.Appenderator
-
Drop all data associated with a particular pending segment.
- drop(SegmentIdentifier) - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
- DropRule - Class in org.apache.druid.server.coordinator.rules
-
DropRules indicate when segments should be completely removed from the cluster.
- DropRule() - Constructor for class org.apache.druid.server.coordinator.rules.DropRule
-
- dropSegment(SegmentIdentifier) - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumber
-
- dropSegment(DataSegment, LoadPeonCallback) - Method in class org.apache.druid.server.coordinator.CuratorLoadQueuePeon
-
Deprecated.
- dropSegment(DataSegment, LoadPeonCallback) - Method in class org.apache.druid.server.coordinator.HttpLoadQueuePeon
-
- dropSegment(DataSegment, LoadPeonCallback) - Method in class org.apache.druid.server.coordinator.LoadQueuePeon
-
Deprecated.
- dropSegment(DataSegment) - Method in class org.apache.druid.server.SegmentManager
-
- DRUID_ALLOW_UNSECURED_PATH - Static variable in class org.apache.druid.server.security.AuthConfig
-
- DRUID_AUTHENTICATION_RESULT - Static variable in class org.apache.druid.server.security.AuthConfig
-
HTTP attribute that holds an AuthenticationResult, with info about a successful authentication check.
- DRUID_AUTHORIZATION_CHECKED - Static variable in class org.apache.druid.server.security.AuthConfig
-
HTTP attribute set when a static method in AuthorizationUtils performs an authorization check on the request.
- DRUID_GLOBAL_CACHE_PREFIX - Static variable in class org.apache.druid.guice.CacheModule
-
- DruidAuthModule - Class in org.apache.druid.guice.security
-
- DruidAuthModule() - Constructor for class org.apache.druid.guice.security.DruidAuthModule
-
- DruidBinders - Class in org.apache.druid.guice
-
- DruidBinders() - Constructor for class org.apache.druid.guice.DruidBinders
-
- DruidBroker - Class in org.apache.druid.server.coordination.broker
-
- DruidBroker(FilteredServerInventoryView, DruidNode, ServiceAnnouncer) - Constructor for class org.apache.druid.server.coordination.broker.DruidBroker
-
- DruidCluster - Class in org.apache.druid.server.coordinator
-
Contains a representation of the current state of the cluster by tier.
- DruidCluster() - Constructor for class org.apache.druid.server.coordinator.DruidCluster
-
- DruidCluster(Set<ServerHolder>, Map<String, NavigableSet<ServerHolder>>) - Constructor for class org.apache.druid.server.coordinator.DruidCluster
-
- DruidCoordinator - Class in org.apache.druid.server.coordinator
-
- DruidCoordinator(DruidCoordinatorConfig, ZkPathsConfig, JacksonConfigManager, MetadataSegmentManager, ServerInventoryView, MetadataRuleManager, CuratorFramework, ServiceEmitter, ScheduledExecutorFactory, IndexingServiceClient, LoadQueueTaskMaster, ServiceAnnouncer, DruidNode, Set<DruidCoordinatorHelper>, BalancerStrategyFactory, LookupCoordinatorManager, DruidLeaderSelector) - Constructor for class org.apache.druid.server.coordinator.DruidCoordinator
-
- DruidCoordinator.CoordinatorRunnable - Class in org.apache.druid.server.coordinator
-
- DruidCoordinatorBalancer - Class in org.apache.druid.server.coordinator.helper
-
- DruidCoordinatorBalancer(DruidCoordinator) - Constructor for class org.apache.druid.server.coordinator.helper.DruidCoordinatorBalancer
-
- DruidCoordinatorCleanupOvershadowed - Class in org.apache.druid.server.coordinator.helper
-
- DruidCoordinatorCleanupOvershadowed(DruidCoordinator) - Constructor for class org.apache.druid.server.coordinator.helper.DruidCoordinatorCleanupOvershadowed
-
- DruidCoordinatorCleanupPendingSegments - Class in org.apache.druid.server.coordinator
-
- DruidCoordinatorCleanupPendingSegments(IndexingServiceClient) - Constructor for class org.apache.druid.server.coordinator.DruidCoordinatorCleanupPendingSegments
-
- DruidCoordinatorCleanupUnneeded - Class in org.apache.druid.server.coordinator.helper
-
- DruidCoordinatorCleanupUnneeded(DruidCoordinator) - Constructor for class org.apache.druid.server.coordinator.helper.DruidCoordinatorCleanupUnneeded
-
- DruidCoordinatorConfig - Class in org.apache.druid.server.coordinator
-
- DruidCoordinatorConfig() - Constructor for class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- DruidCoordinatorHelper - Interface in org.apache.druid.server.coordinator.helper
-
- DruidCoordinatorLogger - Class in org.apache.druid.server.coordinator.helper
-
- DruidCoordinatorLogger(DruidCoordinator) - Constructor for class org.apache.druid.server.coordinator.helper.DruidCoordinatorLogger
-
- DruidCoordinatorRuleRunner - Class in org.apache.druid.server.coordinator.helper
-
- DruidCoordinatorRuleRunner(DruidCoordinator) - Constructor for class org.apache.druid.server.coordinator.helper.DruidCoordinatorRuleRunner
-
- DruidCoordinatorRuleRunner(ReplicationThrottler, DruidCoordinator) - Constructor for class org.apache.druid.server.coordinator.helper.DruidCoordinatorRuleRunner
-
- DruidCoordinatorRuntimeParams - Class in org.apache.druid.server.coordinator
-
- DruidCoordinatorRuntimeParams.Builder - Class in org.apache.druid.server.coordinator
-
- DruidCoordinatorSegmentCompactor - Class in org.apache.druid.server.coordinator.helper
-
- DruidCoordinatorSegmentCompactor(IndexingServiceClient) - Constructor for class org.apache.druid.server.coordinator.helper.DruidCoordinatorSegmentCompactor
-
- DruidCoordinatorSegmentInfoLoader - Class in org.apache.druid.server.coordinator.helper
-
- DruidCoordinatorSegmentInfoLoader(DruidCoordinator) - Constructor for class org.apache.druid.server.coordinator.helper.DruidCoordinatorSegmentInfoLoader
-
- DruidCoordinatorSegmentKiller - Class in org.apache.druid.server.coordinator.helper
-
- DruidCoordinatorSegmentKiller(MetadataSegmentManager, IndexingServiceClient, DruidCoordinatorConfig) - Constructor for class org.apache.druid.server.coordinator.helper.DruidCoordinatorSegmentKiller
-
- DruidCoordinatorSegmentMerger - Class in org.apache.druid.server.coordinator.helper
-
- DruidCoordinatorSegmentMerger(IndexingServiceClient, JacksonConfigManager) - Constructor for class org.apache.druid.server.coordinator.helper.DruidCoordinatorSegmentMerger
-
- DruidDataSource - Class in org.apache.druid.client
-
- DruidDataSource(String, Map<String, String>) - Constructor for class org.apache.druid.client.DruidDataSource
-
- DruidGuiceContainer(Injector, Set<Class<?>>) - Constructor for class org.apache.druid.server.initialization.jetty.JettyServerModule.DruidGuiceContainer
-
- DruidHttpClientConfig - Class in org.apache.druid.guice.http
-
- DruidHttpClientConfig() - Constructor for class org.apache.druid.guice.http.DruidHttpClientConfig
-
- DruidLeaderClient - Class in org.apache.druid.discovery
-
This class facilitates interaction with Coordinator/Overlord leader nodes.
- DruidLeaderClient(HttpClient, DruidNodeDiscoveryProvider, String, String, ServerDiscoverySelector) - Constructor for class org.apache.druid.discovery.DruidLeaderClient
-
- DruidLeaderSelector - Interface in org.apache.druid.discovery
-
Interface for supporting Overlord and Coordinator Leader Elections in TaskMaster and DruidCoordinator
which expect appropriate implementation available in guice annotated with @IndexingService and @Coordinator
respectively.
- DruidLeaderSelector.Listener - Interface in org.apache.druid.discovery
-
- DruidMonitorSchedulerConfig - Class in org.apache.druid.server.metrics
-
- DruidMonitorSchedulerConfig() - Constructor for class org.apache.druid.server.metrics.DruidMonitorSchedulerConfig
-
- DruidNode - Class in org.apache.druid.server
-
- DruidNode(String, String, Integer, Integer, boolean, boolean) - Constructor for class org.apache.druid.server.DruidNode
-
- DruidNode(String, String, Integer, Integer, Integer, Boolean, boolean) - Constructor for class org.apache.druid.server.DruidNode
-
host = null , port = null -> host = _default_, port = -1
host = "abc:123", port = null -> host = abc, port = 123
host = "abc:fff", port = null -> throw IAE (invalid ipv6 host)
host = "2001:db8:85a3::8a2e:370:7334", port = null -> host = 2001:db8:85a3::8a2e:370:7334, port = _auto_
host = "[2001:db8:85a3::8a2e:370:7334]", port = null -> host = 2001:db8:85a3::8a2e:370:7334, port = _auto_
host = "abc" , port = null -> host = abc, port = _auto_
host = "abc" , port = 123 -> host = abc, port = 123
host = "abc:123 , port = 123 -> host = abc, port = 123
host = "abc:123 , port = 456 -> throw IAE (conflicting port)
host = "abc:fff , port = 456 -> throw IAE (invalid ipv6 host)
host = "[2001:db8:85a3::8a2e:370:7334]:123", port = null -> host = 2001:db8:85a3::8a2e:370:7334, port = 123
host = "[2001:db8:85a3::8a2e:370:7334]", port = 123 -> host = 2001:db8:85a3::8a2e:370:7334, port = 123
host = "2001:db8:85a3::8a2e:370:7334", port = 123 -> host = 2001:db8:85a3::8a2e:370:7334, port = 123
host = null , port = 123 -> host = _default_, port = 123
- DruidNodeAnnouncer - Interface in org.apache.druid.discovery
-
DiscoveryDruidNode announcer for internal discovery.
- DruidNodeDiscovery - Interface in org.apache.druid.discovery
-
Interface for discovering Druid Nodes announced by DruidNodeAnnouncer.
- DruidNodeDiscovery.Listener - Interface in org.apache.druid.discovery
-
Listener for watching nodes in a DruidNodeDiscovery instance obtained via DruidNodeDiscoveryProvider.getXXX().
- DruidNodeDiscoveryProvider - Class in org.apache.druid.discovery
-
Provider of DruidNodeDiscovery instances.
- DruidNodeDiscoveryProvider() - Constructor for class org.apache.druid.discovery.DruidNodeDiscoveryProvider
-
- DruidProcessingConfigModule - Class in org.apache.druid.guice
-
- DruidProcessingConfigModule() - Constructor for class org.apache.druid.guice.DruidProcessingConfigModule
-
- DruidProcessingModule - Class in org.apache.druid.guice
-
- DruidProcessingModule() - Constructor for class org.apache.druid.guice.DruidProcessingModule
-
- DruidServer - Class in org.apache.druid.client
-
- DruidServer(DruidNode, DruidServerConfig, ServerType) - Constructor for class org.apache.druid.client.DruidServer
-
- DruidServer(String, String, String, long, ServerType, String, int) - Constructor for class org.apache.druid.client.DruidServer
-
- DruidServerConfig - Class in org.apache.druid.client
-
- DruidServerConfig() - Constructor for class org.apache.druid.client.DruidServerConfig
-
- DruidServerMetadata - Class in org.apache.druid.server.coordination
-
- DruidServerMetadata(String, String, String, long, ServerType, String, int) - Constructor for class org.apache.druid.server.coordination.DruidServerMetadata
-
- DruidService - Class in org.apache.druid.discovery
-
Metadata of a service announced by node.
- DruidService() - Constructor for class org.apache.druid.discovery.DruidService
-
- DruidSysMonitor - Class in org.apache.druid.server.metrics
-
- DruidSysMonitor(SegmentLoaderConfig) - Constructor for class org.apache.druid.server.metrics.DruidSysMonitor
-
- DUPLICATE - Static variable in interface org.apache.druid.segment.realtime.plumber.Plumber
-
- GENERIC_QUERY_METRICS_FACTORY_PROPERTY - Static variable in class org.apache.druid.guice.QueryToolChestModule
-
- get() - Method in class org.apache.druid.client.BatchServerInventoryViewProvider
-
- get(Cache.NamedKey) - Method in interface org.apache.druid.client.cache.Cache
-
- get(Cache.NamedKey) - Method in class org.apache.druid.client.cache.CaffeineCache
-
- get() - Method in class org.apache.druid.client.cache.CaffeineCacheProvider
-
- get(Cache.NamedKey) - Method in class org.apache.druid.client.cache.HybridCache
-
- get() - Method in class org.apache.druid.client.cache.HybridCacheProvider
-
- get() - Method in class org.apache.druid.client.cache.LocalCacheProvider
-
Deprecated.
- get(Cache.NamedKey) - Method in class org.apache.druid.client.cache.MapCache
-
- get(Cache.NamedKey) - Method in class org.apache.druid.client.cache.MemcachedCache
-
- get() - Method in class org.apache.druid.client.cache.MemcachedCacheProvider
-
- get() - Method in class org.apache.druid.client.FilteredBatchServerInventoryViewProvider
-
- get() - Method in class org.apache.druid.client.FilteredHttpServerInventoryViewProvider
-
- get() - Method in class org.apache.druid.client.FilteredSingleServerInventoryViewProvider
-
- get() - Method in class org.apache.druid.client.HttpServerInventoryViewProvider
-
- get() - Method in class org.apache.druid.client.SingleServerInventoryProvider
-
- get() - Method in class org.apache.druid.guice.FireDepartmentsProvider
-
- get() - Method in class org.apache.druid.guice.http.HttpClientModule.HttpClientProvider
-
- get() - Method in class org.apache.druid.guice.http.JettyHttpClientModule.HttpClientProvider
-
- get() - Method in class org.apache.druid.guice.NoopSegmentPublisherProvider
-
- get() - Method in interface org.apache.druid.metadata.MetadataRuleManagerProvider
-
- get() - Method in interface org.apache.druid.metadata.MetadataSegmentManagerProvider
-
- get() - Method in interface org.apache.druid.metadata.MetadataSegmentPublisherProvider
-
- get() - Method in class org.apache.druid.metadata.NoopMetadataStorageProvider
-
- get() - Method in class org.apache.druid.metadata.SQLMetadataRuleManagerProvider
-
- get() - Method in class org.apache.druid.metadata.SQLMetadataSegmentManagerProvider
-
- get() - Method in class org.apache.druid.metadata.SQLMetadataSegmentPublisherProvider
-
- get() - Method in class org.apache.druid.metadata.storage.derby.DerbyMetadataStorageProvider
-
- get() - Method in class org.apache.druid.offheap.OffheapBufferGenerator
-
- get(String) - Method in class org.apache.druid.query.lookup.LookupReferencesManager
-
- get() - Method in class org.apache.druid.query.lookup.MapLookupExtractorFactory
-
- get(String) - Method in interface org.apache.druid.segment.realtime.firehose.ChatHandlerProvider
-
Retrieves a chat handler.
- get(String) - Method in class org.apache.druid.segment.realtime.firehose.NoopChatHandlerProvider
-
- get(String) - Method in class org.apache.druid.segment.realtime.firehose.ServiceAnnouncingChatHandlerProvider
-
- get() - Method in interface org.apache.druid.server.audit.AuditManagerProvider
-
- get() - Method in class org.apache.druid.server.audit.SQLAuditManagerProvider
-
- get() - Method in class org.apache.druid.server.coordination.BatchDataSegmentAnnouncerProvider
-
- get(String) - Method in class org.apache.druid.server.listener.resource.AbstractListenerHandler
-
Get the object for a particular id
- get() - Method in class org.apache.druid.server.log.ComposingRequestLoggerProvider
-
- get() - Method in class org.apache.druid.server.log.EmittingRequestLoggerProvider
-
- get() - Method in class org.apache.druid.server.log.FileRequestLoggerProvider
-
- get() - Method in class org.apache.druid.server.log.FilteredRequestLoggerProvider
-
- get() - Method in class org.apache.druid.server.log.LoggingRequestLoggerProvider
-
- get() - Method in class org.apache.druid.server.log.NoopRequestLoggerProvider
-
- get() - Method in class org.apache.druid.server.router.TieredBrokerSelectorStrategiesProvider
-
- getAction(ContainerRequest) - Method in class org.apache.druid.server.http.security.AbstractResourceFilter
-
- getAction() - Method in class org.apache.druid.server.security.ResourceAction
-
- getActiveRequestsCount() - Method in class org.apache.druid.server.initialization.jetty.LimitRequestsFilter
-
- getActiveTaskInfo(String) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getAdapter() - Method in class org.apache.druid.segment.realtime.firehose.WindowedStorageAdapter
-
- getAddress() - Method in interface org.apache.druid.client.selector.Server
-
- getAggregators() - Method in class org.apache.druid.client.indexing.ClientMergeQuery
-
- getAggregators() - Method in class org.apache.druid.segment.indexing.DataSchema
-
- getAlertThreshold() - Method in class org.apache.druid.metadata.MetadataRuleManagerConfig
-
- getAlertTimeout() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getAll() - Method in class org.apache.druid.curator.discovery.ServerDiscoverySelector
-
Deprecated.
- getAll() - Method in interface org.apache.druid.metadata.MetadataSupervisorManager
-
- getAll() - Method in class org.apache.druid.metadata.SQLMetadataSupervisorManager
-
- getAll() - Method in class org.apache.druid.server.listener.resource.AbstractListenerHandler
-
- getAll() - Method in class org.apache.druid.server.listener.resource.ListenerResource
-
- getAllBrokers() - Method in class org.apache.druid.server.router.TieredBrokerHostSelector
-
- getAllDatasourceNames() - Method in interface org.apache.druid.metadata.MetadataSegmentManager
-
- getAllDatasourceNames() - Method in class org.apache.druid.metadata.SQLMetadataSegmentManager
-
- getAllHostTimeout() - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- getAllLookupsState() - Method in class org.apache.druid.query.lookup.LookupReferencesManager
-
- getAllLookupsStatus(boolean) - Method in class org.apache.druid.server.http.LookupCoordinatorResource
-
- getAllNodes() - Method in interface org.apache.druid.discovery.DruidNodeDiscovery
-
- getAllNodesStatus(boolean) - Method in class org.apache.druid.server.http.LookupCoordinatorResource
-
- getAllRules() - Method in interface org.apache.druid.metadata.MetadataRuleManager
-
- getAllRules() - Method in class org.apache.druid.metadata.SQLMetadataRuleManager
-
- getAllServers() - Method in class org.apache.druid.client.selector.ServerSelector
-
- getAllServers() - Method in class org.apache.druid.server.coordinator.DruidCluster
-
- getAllServers() - Method in class org.apache.druid.server.router.QueryHostFinder
-
- getAllTiers() - Method in class org.apache.druid.server.lookup.cache.LookupNodeDiscovery
-
- getAndIncrementSegment() - Method in class org.apache.druid.segment.realtime.FireHydrant
-
- getAndResetFailedAssignCount() - Method in class org.apache.druid.server.coordinator.CuratorLoadQueuePeon
-
Deprecated.
- getAndResetFailedAssignCount() - Method in class org.apache.druid.server.coordinator.HttpLoadQueuePeon
-
- getAndResetFailedAssignCount() - Method in class org.apache.druid.server.coordinator.LoadQueuePeon
-
Deprecated.
- getAnnounceBytes() - Method in class org.apache.druid.server.listener.announcer.ListenerResourceAnnouncer
-
Deprecated.
- getAnnounceIntervalMillis() - Method in class org.apache.druid.segment.loading.SegmentLoaderConfig
-
- getAnnouncementPath(String) - Method in class org.apache.druid.server.listener.announcer.ListeningAnnouncerConfig
-
Build a path for the particular named listener.
- getAnnouncementsPath() - Method in class org.apache.druid.server.initialization.ZkPathsConfig
-
- getAnnouncer(CuratorFramework) - Method in class org.apache.druid.guice.AnnouncerModule
-
- getAppenderatorFactory() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumberSchool
-
- getArtifact() - Method in class org.apache.druid.server.StatusResource.ModuleVersion
-
- getAuditHistoryMillis() - Method in class org.apache.druid.server.audit.SQLAuditManagerConfig
-
- getAuditTable() - Method in class org.apache.druid.server.audit.SQLAuditManager
-
- getAuthChallengeHeader() - Method in class org.apache.druid.server.security.AllowAllAuthenticator
-
- getAuthChallengeHeader() - Method in class org.apache.druid.server.security.AnonymousAuthenticator
-
- getAuthChallengeHeader() - Method in interface org.apache.druid.server.security.Authenticator
-
Return a WWW-Authenticate challenge scheme string appropriate for this Authenticator's authentication mechanism.
- getAuthenticatedBy() - Method in class org.apache.druid.server.security.AuthenticationResult
-
- getAuthenticator() - Method in class org.apache.druid.guice.security.AuthenticatorModule
-
- getAuthenticatorChain() - Method in class org.apache.druid.server.security.AuthConfig
-
- getAuthenticatorChain() - Method in class org.apache.druid.server.security.AuthenticatorMapper
-
- getAuthenticatorMap() - Method in class org.apache.druid.server.security.AuthenticatorMapper
-
- getAuthorizer() - Method in class org.apache.druid.guice.security.AuthorizerModule
-
- getAuthorizer(String) - Method in class org.apache.druid.server.security.AuthorizerMapper
-
- getAuthorizerMap() - Method in class org.apache.druid.server.security.AuthorizerMapper
-
- getAuthorizerMapper() - Method in class org.apache.druid.server.http.security.AbstractResourceFilter
-
- getAuthorizerName() - Method in class org.apache.druid.server.security.AuthenticationResult
-
- getAuthorizers() - Method in class org.apache.druid.server.security.AuthConfig
-
- getAuthScheme() - Method in class org.apache.druid.curator.CuratorConfig
-
- getAvailabilityGroups() - Method in class org.apache.druid.client.indexing.IndexingWorkerInfo
-
- getAvailableCapacity() - Method in class org.apache.druid.client.indexing.IndexingWorkerInfo
-
- getAvailableSegments() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getAvailableSize() - Method in class org.apache.druid.server.coordinator.ServerHolder
-
- getAWSCredentialsProvider(AWSCredentialsConfig) - Method in class org.apache.druid.guice.AWSModule
-
- getBalancerComputeThreads() - Method in class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- getBalancerReferenceTimestamp() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getBalancerStrategy() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getBase() - Method in class org.apache.druid.server.initialization.ZkPathsConfig
-
- getBaseDir() - Method in class org.apache.druid.segment.realtime.firehose.LocalFirehoseFactory
-
- getBasePersistDirectory() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getBasePersistDirectory() - Method in interface org.apache.druid.segment.realtime.appenderator.AppenderatorConfig
-
- getBlacklistedUntil() - Method in class org.apache.druid.client.indexing.IndexingWorkerInfo
-
- getBrokers() - Method in class org.apache.druid.server.http.RouterResource
-
- getBrokerServiceName(TieredBrokerConfig, Query) - Method in class org.apache.druid.server.router.JavaScriptTieredBrokerSelectorStrategy
-
- getBrokerServiceName(TieredBrokerConfig, Query) - Method in class org.apache.druid.server.router.PriorityTieredBrokerSelectorStrategy
-
- getBrokerServiceName(TieredBrokerConfig, Query) - Method in interface org.apache.druid.server.router.TieredBrokerSelectorStrategy
-
- getBrokerServiceName(TieredBrokerConfig, Query) - Method in class org.apache.druid.server.router.TimeBoundaryTieredBrokerSelectorStrategy
-
- getBufferSize() - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory
-
- getBuildV9Directly() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
Deprecated.
- getBulk(Iterable<Cache.NamedKey>) - Method in interface org.apache.druid.client.cache.Cache
-
Resulting map should not contain any null values (i.e.
- getBulk(Iterable<Cache.NamedKey>) - Method in class org.apache.druid.client.cache.CaffeineCache
-
- getBulk(Iterable<Cache.NamedKey>) - Method in class org.apache.druid.client.cache.HybridCache
-
- getBulk(Iterable<Cache.NamedKey>) - Method in class org.apache.druid.client.cache.MapCache
-
- getBulk(Iterable<Cache.NamedKey>) - Method in class org.apache.druid.client.cache.MemcachedCache
-
- getBytesInMemory() - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
- getBytesReceived() - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory.EventReceiverFirehose
-
- getBytesReceived() - Method in interface org.apache.druid.server.metrics.EventReceiverFirehoseMetric
-
Return the number of bytes received by the firehose.
- getBytesSize(E) - Method in class org.apache.druid.client.cache.BytesBoundedLinkedQueue
-
- getCacheBulkMergeLimit() - Method in class org.apache.druid.client.cache.CacheConfig
-
- getCacheKey() - Method in class org.apache.druid.query.dimension.LookupDimensionSpec
-
- getCacheKey() - Method in class org.apache.druid.query.lookup.RegisteredLookupExtractionFn
-
- getCachePopulator(ObjectMapper, CachePopulatorStats, CacheConfig) - Method in class org.apache.druid.guice.DruidProcessingModule
-
- getCallerMetadata() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorDriverMetadata
-
- getCandidates(int) - Method in class org.apache.druid.client.selector.ServerSelector
-
- getCapacity() - Method in class org.apache.druid.client.indexing.IndexingWorker
-
- getCapacity() - Method in class org.apache.druid.discovery.WorkerNodeService
-
- getCapacity() - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory.EventReceiverFirehose
-
- getCapacity() - Method in interface org.apache.druid.server.metrics.EventReceiverFirehoseMetric
-
Return the capacity of the buffer.
- getCertAlias() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getChunkNum() - Method in class org.apache.druid.client.InputStreamHolder
-
- getClassLoaderForExtension(File, boolean) - Static method in class org.apache.druid.initialization.Initialization
-
- getClient() - Method in class org.apache.druid.client.selector.QueryableDruidServer
-
- getClusterServers(boolean) - Method in class org.apache.druid.server.http.ClusterResource
-
- getClusterServers(String, boolean) - Method in class org.apache.druid.server.http.ClusterResource
-
- getClusterServers(String, String) - Method in class org.apache.druid.server.http.ServersResource
-
- getClusterTiers(String) - Method in class org.apache.druid.server.coordinator.SegmentReplicantLookup
-
- getColocatedDataSources() - Method in class org.apache.druid.server.coordinator.rules.BroadcastDistributionRule
-
- getColocatedDataSources() - Method in class org.apache.druid.server.coordinator.rules.ForeverBroadcastDistributionRule
-
- getColocatedDataSources() - Method in class org.apache.druid.server.coordinator.rules.IntervalBroadcastDistributionRule
-
- getColocatedDataSources() - Method in class org.apache.druid.server.coordinator.rules.PeriodBroadcastDistributionRule
-
- getCommitMetadata() - Method in class org.apache.druid.segment.realtime.appenderator.SegmentsAndMetadata
-
- getCommittedHydrants(String) - Method in class org.apache.druid.segment.realtime.appenderator.Committed
-
- getCompactConfig() - Method in class org.apache.druid.server.http.CoordinatorCompactionConfigsResource
-
- getCompactionConfig() - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- getCompactionConfig(String) - Method in class org.apache.druid.server.http.CoordinatorCompactionConfigsResource
-
- getCompactionConfigs() - Method in class org.apache.druid.server.coordinator.CoordinatorCompactionConfig
-
- getCompactionTaskSlotRatio() - Method in class org.apache.druid.server.coordinator.CoordinatorCompactionConfig
-
- getComparator() - Method in class org.apache.druid.client.selector.CustomTierSelectorStrategy
-
- getComparator() - Method in class org.apache.druid.client.selector.HighestPriorityTierSelectorStrategy
-
- getComparator() - Method in class org.apache.druid.client.selector.LowestPriorityTierSelectorStrategy
-
- getComparator() - Method in interface org.apache.druid.client.selector.TierSelectorStrategy
-
- getCompletedTaskInfo(DateTime, Integer, String) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getCompressionCodec() - Method in class org.apache.druid.guice.http.DruidHttpClientConfig
-
- getCompressionLevel() - Method in class org.apache.druid.server.initialization.ServerConfig
-
- getConfig() - Method in class org.apache.druid.curator.inventory.CuratorInventoryManager
-
Deprecated.
- getConfig() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- getConfig() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumber
-
- getConfig() - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- getConfigKey() - Method in class org.apache.druid.guice.http.AbstractHttpClientProvider
-
- getConfigProvider() - Method in class org.apache.druid.guice.http.AbstractHttpClientProvider
-
- getConnector() - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getConnectorPath() - Method in class org.apache.druid.server.initialization.ZkPathsConfig
-
- getConsoleStatic() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getContainerPath() - Method in interface org.apache.druid.curator.inventory.InventoryManagerConfig
-
The ContainerPath is the path where the InventoryManager should look for new containers of inventory.
- getContext() - Method in class org.apache.druid.client.indexing.ClientCompactQuery
-
- getContext() - Method in class org.apache.druid.server.security.AuthenticationResult
-
- getCoordinatorCompactionConfig() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getCoordinatorDynamicConfig() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getCoordinatorIndexingPeriod() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getCoordinatorKillDurationToRetain() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getCoordinatorKillMaxSegments() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getCoordinatorKillPeriod() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getCoordinatorPath() - Method in class org.apache.druid.server.initialization.ZkPathsConfig
-
- getCoordinatorPeriod() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getCoordinatorServiceName() - Method in class org.apache.druid.server.router.TieredBrokerConfig
-
- getCoordinatorStartDelay() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getCoordinatorStats() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getCount() - Method in class org.apache.druid.segment.realtime.firehose.FixedCountFirehoseFactory
-
- getCount() - Method in class org.apache.druid.segment.realtime.FireHydrant
-
- getCounter() - Method in class org.apache.druid.server.coordination.ChangeRequestHistory.Counter
-
- getCounter() - Method in class org.apache.druid.server.coordination.ChangeRequestsSnapshot
-
- getCreatedTime() - Method in class org.apache.druid.server.log.EmittingRequestLogger.RequestLogEvent
-
- getCrlPath() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getCurrCapacityUsed() - Method in class org.apache.druid.client.indexing.IndexingWorkerInfo
-
- getCurrentBufferSize() - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory.EventReceiverFirehose
-
- getCurrentBufferSize() - Method in interface org.apache.druid.server.metrics.EventReceiverFirehoseMetric
-
Return the current number of InputRow that are stored in the buffer.
- getCurrentLeader() - Method in class org.apache.druid.curator.discovery.CuratorDruidLeaderSelector
-
- getCurrentLeader() - Method in interface org.apache.druid.discovery.DruidLeaderSelector
-
Get ID of current Leader.
- getCurrentLeader() - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- getCurrentTime() - Method in class org.apache.druid.server.ClientInfoResource
-
- getCurrHydrant() - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
- getCurrMaxTime() - Method in interface org.apache.druid.segment.realtime.plumber.RejectionPolicy
-
- getCurrServerSize() - Method in class org.apache.druid.server.coordinator.ServerHolder
-
- getCurrSize() - Method in class org.apache.druid.client.DruidServer
-
- getCurrSize() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getDatabaseDataSources(String, String, HttpServletRequest) - Method in class org.apache.druid.server.http.MetadataResource
-
- getDatabaseRuleManager() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getDatabaseSegmentDataSource(String) - Method in class org.apache.druid.server.http.MetadataResource
-
- getDatabaseSegmentDataSourceSegment(String, String) - Method in class org.apache.druid.server.http.MetadataResource
-
- getDatabaseSegmentDataSourceSegments(String, String) - Method in class org.apache.druid.server.http.MetadataResource
-
- getDatabaseSegmentDataSourceSegments(String, String, List<Interval>) - Method in class org.apache.druid.server.http.MetadataResource
-
- getDatabaseSegments(HttpServletRequest) - Method in class org.apache.druid.server.http.MetadataResource
-
- getDataNodeService(NodeTypeConfig, DruidServerConfig) - Method in class org.apache.druid.guice.StorageNodeModule
-
- getDataSchema() - Method in class org.apache.druid.segment.indexing.IngestionSpec
-
- getDataSchema() - Method in class org.apache.druid.segment.realtime.FireDepartment
-
Provides the data schema for the feed that this FireDepartment is in charge of.
- getDataSegment() - Method in class org.apache.druid.segment.realtime.appenderator.SegmentWithState
-
- getDataSource(String) - Method in class org.apache.druid.client.DruidServer
-
- getDataSource(String) - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getDataSource() - Method in class org.apache.druid.client.indexing.ClientAppendQuery
-
- getDataSource() - Method in class org.apache.druid.client.indexing.ClientCompactQuery
-
- getDataSource() - Method in class org.apache.druid.client.indexing.ClientKillQuery
-
- getDataSource() - Method in class org.apache.druid.client.indexing.ClientMergeQuery
-
- getDatasource(MetadataStorageConnectorConfig) - Method in class org.apache.druid.metadata.SQLFirehoseDatabaseConnector
-
- getDatasource() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- getDataSource() - Method in class org.apache.druid.segment.indexing.DataSchema
-
- getDataSource() - Method in interface org.apache.druid.segment.realtime.appenderator.Appenderator
-
Return the name of the dataSource associated with this Appenderator.
- getDataSource() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
- getDataSource() - Method in class org.apache.druid.segment.realtime.appenderator.SegmentIdentifier
-
- getDatasource(String, String, String) - Method in class org.apache.druid.server.ClientInfoResource
-
- getDataSource() - Method in class org.apache.druid.server.coordinator.DataSourceCompactionConfig
-
- getDataSource() - Method in class org.apache.druid.server.metrics.DataSourceTaskIdHolder
-
- getDataSourceCounts() - Method in class org.apache.druid.server.SegmentManager
-
Returns a map of dataSource to the number of segments managed by this segmentManager.
- getDatasourceDimensions(String, String) - Method in class org.apache.druid.server.ClientInfoResource
-
Deprecated.
- getDataSourceMetadata(String) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
Read dataSource metadata.
- getDataSourceMetadata(String) - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
Read dataSource metadata.
- getDatasourceMetrics(String, String) - Method in class org.apache.druid.server.ClientInfoResource
-
Deprecated.
- getDatasourceRuleHistory(String, Integer) - Method in class org.apache.druid.server.http.CoordinatorDynamicConfigsResource
-
- getDatasourceRuleHistory(String, String, Integer) - Method in class org.apache.druid.server.http.RulesResource
-
- getDatasourceRuleHistory(String, Integer) - Method in class org.apache.druid.server.http.RulesResource
-
- getDatasourceRules(String, String) - Method in class org.apache.druid.server.http.RulesResource
-
- getDataSources() - Method in class org.apache.druid.client.DruidServer
-
- getDataSources() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getDataSources() - Method in class org.apache.druid.indexing.overlord.supervisor.NoopSupervisorSpec
-
- getDataSources() - Method in interface org.apache.druid.indexing.overlord.supervisor.SupervisorSpec
-
- getDataSources(HttpServletRequest) - Method in class org.apache.druid.server.ClientInfoResource
-
- getDataSources(String) - Method in class org.apache.druid.server.coordinator.CoordinatorStats
-
- getDataSources() - Method in class org.apache.druid.server.coordinator.DatasourceWhitelist
-
- getDataSources() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getDataSources(InventoryView) - Static method in interface org.apache.druid.server.http.InventoryViewUtils
-
- getDataSourceSizes() - Method in class org.apache.druid.server.SegmentManager
-
Returns a map of dataSource to the total byte size of segments managed by this segmentManager.
- getDataSourceStat(String, String) - Method in class org.apache.druid.server.coordinator.CoordinatorStats
-
- getDBI() - Method in class org.apache.druid.metadata.SQLFirehoseDatabaseConnector
-
- getDBI() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- getDBI() - Method in class org.apache.druid.metadata.storage.derby.DerbyConnector
-
- getDebugInfo() - Method in class org.apache.druid.client.HttpServerInventoryView
-
- getDebugInfo() - Method in class org.apache.druid.client.HttpServerInventoryViewResource
-
- getDebugInfo() - Method in class org.apache.druid.server.coordination.ChangeRequestHttpSyncer
-
This method returns the debugging information for printing, must not be used for any other purpose.
- getDedupColumn() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getDefaultBrokerServiceName() - Method in class org.apache.druid.server.router.TieredBrokerConfig
-
- getDefaultHost() - Static method in class org.apache.druid.server.DruidNode
-
- getDefaultLookup() - Method in class org.apache.druid.server.router.TieredBrokerHostSelector
-
- getDefaultQueryTimeout() - Method in class org.apache.druid.server.initialization.ServerConfig
-
- getDefaultResourceConfig(Map<String, Object>, WebConfig) - Method in class org.apache.druid.server.initialization.jetty.JettyServerModule.DruidGuiceContainer
-
- getDefaultRule() - Method in class org.apache.druid.metadata.MetadataRuleManagerConfig
-
- getDefaultRule() - Method in class org.apache.druid.server.router.TieredBrokerConfig
-
- getDefaultServiceName() - Method in class org.apache.druid.server.router.TieredBrokerHostSelector
-
- getDelegate() - Method in class org.apache.druid.segment.realtime.firehose.ClippedFirehoseFactory
-
- getDelegate() - Method in class org.apache.druid.segment.realtime.firehose.FixedCountFirehoseFactory
-
- getDelegateFactory() - Method in class org.apache.druid.segment.realtime.firehose.TimedShutoffFirehoseFactory
-
- getDelegateFactoryList() - Method in class org.apache.druid.segment.realtime.firehose.CombiningFirehoseFactory
-
- getDescription() - Method in class org.apache.druid.server.coordinator.BytesAccumulatingResponseHandler
-
- getDimension() - Method in class org.apache.druid.query.dimension.LookupDimensionSpec
-
- getDimension() - Method in class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- getDispatcherType() - Method in class org.apache.druid.server.initialization.jetty.ResponseHeaderFilterHolder
-
- getDispatcherType() - Method in interface org.apache.druid.server.initialization.jetty.ServletFilterHolder
-
The dispatcher type that this Filter should apply to
- getDispatcherType() - Method in class org.apache.druid.server.security.AllowAllAuthenticator
-
- getDispatcherType() - Method in class org.apache.druid.server.security.AnonymousAuthenticator
-
- getDomainDimensions() - Method in class org.apache.druid.timeline.partition.LinearShardSpec
-
- getDomainDimensions() - Method in class org.apache.druid.timeline.partition.NumberedShardSpec
-
- getDomainDimensions() - Method in class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- getDropSegmentDelayMillis() - Method in class org.apache.druid.segment.loading.SegmentLoaderConfig
-
- getDruidCluster() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getDruidNode() - Method in class org.apache.druid.discovery.DiscoveryDruidNode
-
- getDruidServers() - Method in class org.apache.druid.client.BrokerServerView
-
- getDruidServers() - Method in interface org.apache.druid.client.TimelineServerView
-
- getDuration() - Method in class org.apache.druid.client.indexing.QueryStatus
-
- getDuration() - Method in class org.apache.druid.client.indexing.TaskStatus
-
- getDynamicConfigs() - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- getDynamicConfigs() - Method in class org.apache.druid.server.http.CoordinatorDynamicConfigsResource
-
- getEc2Client(AWSCredentialsProvider) - Method in class org.apache.druid.guice.AWSModule
-
- getEffectiveSSLContext(HttpEmitterSSLClientConfig, SSLContext) - Static method in class org.apache.druid.server.emitter.HttpEmitterModule
-
- getEmissionPeriod() - Method in class org.apache.druid.server.metrics.DruidMonitorSchedulerConfig
-
- getEmitter() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getEmitter(ComposingEmitterConfig, Injector) - Method in class org.apache.druid.server.emitter.ComposingEmitterModule
-
- getEmitter(Supplier<HttpEmitterConfig>, Supplier<HttpEmitterSSLClientConfig>, SSLContext, Lifecycle, ObjectMapper) - Method in class org.apache.druid.server.emitter.HttpEmitterModule
-
- getEmitter(Supplier<ParametrizedUriEmitterConfig>, Supplier<ParametrizedUriEmitterSSLClientConfig>, SSLContext, Lifecycle, ObjectMapper) - Method in class org.apache.druid.server.emitter.ParametrizedUriEmitterModule
-
- getEmitterPeriod() - Method in class org.apache.druid.server.metrics.DruidMonitorSchedulerConfig
-
- getEmitters() - Method in class org.apache.druid.server.emitter.ComposingEmitterConfig
-
- getEnableAcl() - Method in class org.apache.druid.curator.CuratorConfig
-
- getEnableCompression() - Method in class org.apache.druid.curator.CuratorConfig
-
- getEnd() - Method in class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- getEntry(String) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getEntryTable() - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getEntryType() - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getExcludeCipherSuites() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getExcludeProtocols() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getExpiration() - Method in class org.apache.druid.client.cache.MemcachedCacheConfig
-
- getExpireAfter() - Method in class org.apache.druid.client.cache.CaffeineCacheConfig
-
- getExtensionFilesToLoad(ExtensionsConfig) - Static method in class org.apache.druid.initialization.Initialization
-
Find all the extension files that should be loaded by druid.
- getExtractionFn() - Method in class org.apache.druid.query.dimension.LookupDimensionSpec
-
- getExtractionType() - Method in class org.apache.druid.query.lookup.RegisteredLookupExtractionFn
-
- getFailedQueryCount() - Method in class org.apache.druid.server.AsyncQueryForwardingServlet
-
- getFailedQueryCount() - Method in interface org.apache.druid.server.metrics.QueryCountStatsProvider
-
- getFailedQueryCount() - Method in class org.apache.druid.server.QueryResource
-
- getFailureCause() - Method in class org.apache.druid.server.coordination.SegmentLoadDropHandler.Status
-
- getFeed() - Method in class org.apache.druid.server.log.EmittingRequestLogger.RequestLogEvent
-
- getFilter() - Method in class org.apache.druid.segment.realtime.firehose.LocalFirehoseFactory
-
- getFilter() - Method in class org.apache.druid.server.initialization.jetty.ResponseHeaderFilterHolder
-
- getFilter() - Method in interface org.apache.druid.server.initialization.jetty.ServletFilterHolder
-
Get the Filter object that should be added to the servlet.
- getFilter() - Method in class org.apache.druid.server.security.AllowAllAuthenticator
-
- getFilter() - Method in class org.apache.druid.server.security.AnonymousAuthenticator
-
- getFilter() - Method in interface org.apache.druid.server.security.Authenticator
-
Create a Filter that performs authentication checks on incoming HTTP requests.
- getFilterClass() - Method in class org.apache.druid.server.initialization.jetty.ResponseHeaderFilterHolder
-
- getFilterClass() - Method in interface org.apache.druid.server.initialization.jetty.ServletFilterHolder
-
Get the class of the Filter object that should be added to the servlet.
- getFilterClass() - Method in class org.apache.druid.server.security.AllowAllAuthenticator
-
- getFilterClass() - Method in class org.apache.druid.server.security.AnonymousAuthenticator
-
- getFirehoseFactory() - Method in class org.apache.druid.segment.indexing.RealtimeIOConfig
-
- getFirehoseFactoryV2() - Method in class org.apache.druid.segment.indexing.RealtimeIOConfig
-
- getForNodeType(String) - Method in class org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider
-
- getForNodeType(String) - Method in class org.apache.druid.discovery.DruidNodeDiscoveryProvider
-
Get DruidNodeDiscovery instance to discover nodes of given nodeType.
- getForService(String) - Method in class org.apache.druid.discovery.DruidNodeDiscoveryProvider
-
Get DruidNodeDiscovery instance to discover nodes that announce given service in its metadata.
- getFreeMemory() - Method in class org.apache.druid.server.StatusResource.Memory
-
- getFreeSpacePercent() - Method in class org.apache.druid.segment.loading.StorageLocationConfig
-
- getFromExtensions(ExtensionsConfig, Class<T>) - Static method in class org.apache.druid.initialization.Initialization
-
Look for implementations for the given class from both classpath and extensions directory, using
ServiceLoader.
- getFromServer() - Method in class org.apache.druid.server.coordinator.BalancerSegmentHolder
-
- getFromServer() - Method in class org.apache.druid.server.http.SegmentToDrop
-
- getFromServer() - Method in class org.apache.druid.server.http.SegmentToMove
-
- getFunction() - Method in class org.apache.druid.server.router.JavaScriptTieredBrokerSelectorStrategy
-
- getGenerationTime() - Method in class org.apache.druid.indexing.overlord.supervisor.SupervisorReport
-
- getGlobalStat(String) - Method in class org.apache.druid.server.coordinator.CoordinatorStats
-
- getGracefulShutdownTimeout() - Method in class org.apache.druid.server.initialization.ServerConfig
-
- getGranularitySpec() - Method in class org.apache.druid.segment.indexing.DataSchema
-
- getHadoopDependencyFilesToLoad(List<String>, ExtensionsConfig) - Static method in class org.apache.druid.initialization.Initialization
-
Find all the hadoop dependencies that should be loaded by druid
- getHandoffConditionTimeout() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getHash() - Method in class org.apache.druid.server.coordination.ChangeRequestHistory.Counter
-
- getHealth() - Method in class org.apache.druid.server.StatusResource
-
This is an unsecured endpoint, defined as such in UNSECURED_PATHS in the service initiailization files
(e.g.
- getHiddenProperties() - Method in class org.apache.druid.client.DruidServerConfig
-
- getHistoricals() - Method in class org.apache.druid.server.coordinator.DruidCluster
-
- getHistoricalsByTier(String) - Method in class org.apache.druid.server.coordinator.DruidCluster
-
- getHost() - Method in class org.apache.druid.client.DruidServer
-
- getHost() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getHost() - Method in class org.apache.druid.client.indexing.IndexingWorker
-
- getHost() - Method in interface org.apache.druid.client.selector.Server
-
- getHost() - Method in class org.apache.druid.server.coordination.DruidServerMetadata
-
- getHost() - Method in class org.apache.druid.server.DruidNode
-
- getHost() - Method in class org.apache.druid.server.log.EmittingRequestLogger.RequestLogEvent
-
- getHostAndPort() - Method in class org.apache.druid.client.DruidServer
-
- getHostAndPort() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getHostAndPort() - Method in class org.apache.druid.server.coordination.DruidServerMetadata
-
- getHostAndPort() - Method in class org.apache.druid.server.DruidNode
-
Returns host and port together as something that can be used as part of a URI.
- getHostAndPort() - Method in class org.apache.druid.server.http.HostAndPortWithScheme
-
- getHostAndPortToUse() - Method in class org.apache.druid.server.DruidNode
-
- getHostAndTlsPort() - Method in class org.apache.druid.client.DruidServer
-
- getHostAndTlsPort() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getHostAndTlsPort() - Method in class org.apache.druid.server.coordination.DruidServerMetadata
-
- getHostAndTlsPort() - Method in class org.apache.druid.server.DruidNode
-
- getHosts() - Method in class org.apache.druid.client.cache.MemcachedCacheConfig
-
- getHosts() - Method in class org.apache.druid.curator.ExhibitorConfig
-
- getHostText() - Method in class org.apache.druid.server.http.HostAndPortWithScheme
-
- getHostTimeout() - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- getHttpEmittingSSLClientConfig() - Method in class org.apache.druid.server.emitter.ParametrizedUriEmitterSSLClientConfig
-
- getHttpLoadQueuePeonBatchSize() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getHttpLoadQueuePeonHostTimeout() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getHttpLoadQueuePeonRepeatDelay() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getHydrants() - Method in class org.apache.druid.segment.realtime.appenderator.Committed
-
- getId() - Method in class org.apache.druid.client.indexing.QueryStatus
-
- getId() - Method in class org.apache.druid.client.indexing.TaskStatus
-
- getId() - Method in class org.apache.druid.indexing.overlord.supervisor.NoopSupervisorSpec
-
- getId() - Method in class org.apache.druid.indexing.overlord.supervisor.SupervisorReport
-
- getId() - Method in interface org.apache.druid.indexing.overlord.supervisor.SupervisorSpec
-
- getIdentifierAsString() - Method in class org.apache.druid.segment.realtime.appenderator.SegmentIdentifier
-
- getIdentity() - Method in class org.apache.druid.server.security.AuthenticationResult
-
- getIncludeCipherSuites() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getIncludeProtocols() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getIncrementedSegment() - Method in class org.apache.druid.segment.realtime.FireHydrant
-
- getIndex() - Method in class org.apache.druid.segment.realtime.FireHydrant
-
- getIndexSpec() - Method in class org.apache.druid.client.indexing.ClientCompactQueryTuningConfig
-
- getIndexSpec() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getIndexSpec() - Method in interface org.apache.druid.segment.realtime.appenderator.AppenderatorConfig
-
- getInflateBufferSize() - Method in class org.apache.druid.server.initialization.ServerConfig
-
- getInfoDir() - Method in class org.apache.druid.segment.loading.SegmentLoaderConfig
-
- getInitialDelay() - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- getInitialDelay(long) - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- getInitParameters() - Method in class org.apache.druid.server.initialization.jetty.ResponseHeaderFilterHolder
-
- getInitParameters() - Method in interface org.apache.druid.server.initialization.jetty.ServletFilterHolder
-
Get Filter initialization parameters.
- getInitParameters() - Method in class org.apache.druid.server.security.AllowAllAuthenticator
-
- getInitParameters() - Method in class org.apache.druid.server.security.AnonymousAuthenticator
-
- getInjector() - Method in class org.apache.druid.server.GuiceServletConfig
-
- getInputSegmentSizeBytes() - Method in class org.apache.druid.server.coordinator.DataSourceCompactionConfig
-
- getInputStream(URI) - Method in class org.apache.druid.segment.loading.LocalDataSegmentPuller
-
- getInstance() - Static method in class org.apache.druid.server.security.NoopEscalator
-
- getIntermediatePersistPeriod() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getIntermediatePersistPeriod() - Method in interface org.apache.druid.segment.realtime.appenderator.AppenderatorConfig
-
Period that sets frequency to persist to local storage if no other thresholds are met
- getIntermediatePersistPeriod() - Method in class org.apache.druid.segment.realtime.FireDepartmentConfig
-
- getIntermediateResultsPool(DruidProcessingConfig) - Method in class org.apache.druid.guice.DruidProcessingModule
-
- getIntermediateResultsPool() - Method in class org.apache.druid.guice.RouterProcessingModule
-
- getInternalDiscoveryPath() - Method in class org.apache.druid.server.initialization.ZkPathsConfig
-
- getInterruptedQueryCount() - Method in class org.apache.druid.server.AsyncQueryForwardingServlet
-
- getInterruptedQueryCount() - Method in interface org.apache.druid.server.metrics.QueryCountStatsProvider
-
- getInterruptedQueryCount() - Method in class org.apache.druid.server.QueryResource
-
- getInterval() - Method in class org.apache.druid.client.indexing.ClientKillQuery
-
- getInterval() - Method in class org.apache.druid.query.LocatedSegmentDescriptor
-
- getInterval() - Method in class org.apache.druid.segment.realtime.appenderator.SegmentIdentifier
-
- getInterval() - Method in class org.apache.druid.segment.realtime.firehose.ClippedFirehoseFactory
-
- getInterval() - Method in class org.apache.druid.segment.realtime.firehose.WindowedStorageAdapter
-
- getInterval() - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
- getInterval() - Method in class org.apache.druid.server.coordinator.rules.IntervalBroadcastDistributionRule
-
- getInterval() - Method in class org.apache.druid.server.coordinator.rules.IntervalDropRule
-
- getInterval() - Method in class org.apache.druid.server.coordinator.rules.IntervalLoadRule
-
- getIntervals() - Method in class org.apache.druid.segment.indexing.granularity.UniformGranularitySpec
-
- getIntervals(HttpServletRequest) - Method in class org.apache.druid.server.http.IntervalsResource
-
- getIntrospectHandler() - Method in class org.apache.druid.query.lookup.MapLookupExtractorFactory
-
- getInventory() - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- getInventory() - Method in class org.apache.druid.client.CoordinatorServerView
-
- getInventory() - Method in class org.apache.druid.client.HttpServerInventoryView
-
- getInventory() - Method in interface org.apache.druid.client.InventoryView
-
- getInventory() - Method in class org.apache.druid.curator.inventory.CuratorInventoryManager
-
Deprecated.
- getInventory() - Method in interface org.apache.druid.metadata.MetadataSegmentManager
-
- getInventory() - Method in class org.apache.druid.metadata.SQLMetadataSegmentManager
-
- getInventoryManagerConfig() - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- getInventoryPath() - Method in interface org.apache.druid.curator.inventory.InventoryManagerConfig
-
The InventoryPath is the path where the InventoryManager should look for new inventory.
- getInventoryValue(String) - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- getInventoryValue(String) - Method in class org.apache.druid.client.CoordinatorServerView
-
- getInventoryValue(String) - Method in class org.apache.druid.client.HttpServerInventoryView
-
- getInventoryValue(String) - Method in interface org.apache.druid.client.InventoryView
-
- getInventoryValue(String) - Method in class org.apache.druid.curator.inventory.CuratorInventoryManager
-
Deprecated.
- getInventoryValue(String) - Method in interface org.apache.druid.metadata.MetadataSegmentManager
-
- getInventoryValue(String) - Method in class org.apache.druid.metadata.SQLMetadataSegmentManager
-
- getIOConfig() - Method in class org.apache.druid.segment.indexing.IngestionSpec
-
- getIOConfig() - Method in class org.apache.druid.segment.realtime.FireDepartment
-
- getIp() - Method in class org.apache.druid.client.indexing.IndexingWorker
-
- getIp() - Method in class org.apache.druid.discovery.WorkerNodeService
-
- getJacksonJsonProvider(ObjectMapper) - Method in class org.apache.druid.server.initialization.jetty.JettyServerModule
-
- getJacksonModules() - Method in class org.apache.druid.guice.ExpressionModule
-
- getJacksonModules() - Method in class org.apache.druid.guice.FirehoseModule
-
- getJacksonModules() - Method in class org.apache.druid.guice.LocalDataStorageDruidModule
-
- getJacksonModules() - Method in class org.apache.druid.guice.QueryableModule
-
- getJacksonModules() - Method in class org.apache.druid.guice.security.DruidAuthModule
-
- getJacksonModules() - Method in class org.apache.druid.guice.ServerModule
-
- getJacksonModules() - Method in class org.apache.druid.query.lookup.LookupModule
-
- getJacksonModules() - Method in class org.apache.druid.server.emitter.ComposingEmitterModule
-
- getJacksonModules() - Method in class org.apache.druid.server.initialization.AuthenticatorMapperModule
-
- getJacksonModules() - Method in class org.apache.druid.server.initialization.AuthorizerMapperModule
-
- getJacksonSmileProvider(ObjectMapper) - Method in class org.apache.druid.server.initialization.jetty.JettyServerModule
-
- getJettyMonitor(DataSourceTaskIdHolder) - Method in class org.apache.druid.server.initialization.jetty.JettyServerModule
-
- getJettyRequestLogHandler() - Static method in class org.apache.druid.server.initialization.jetty.JettyServerInitUtils
-
- getJsonMapper() - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getJvmCpuMonitor(DataSourceTaskIdHolder) - Method in class org.apache.druid.server.metrics.MetricsModule
-
- getJvmMonitor(DataSourceTaskIdHolder) - Method in class org.apache.druid.server.metrics.MetricsModule
-
- getJvmThreadsMonitor(DataSourceTaskIdHolder) - Method in class org.apache.druid.server.metrics.MetricsModule
-
- getKeyManagerFactoryAlgorithm() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getKeyManagerPasswordProvider() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getKeys() - Method in class org.apache.druid.query.lookup.MapLookupExtractorFactory.MapLookupIntrospectionHandler
-
- getKeyStorePasswordProvider() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getKeyStorePath() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getKeyStoreType() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getKillDataSourceWhitelist() - Method in class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- getKillPendingSegmentsSkipList() - Method in class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- getKnownLookups() - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManager
-
- getLastCompletedTaskTime() - Method in class org.apache.druid.client.indexing.IndexingWorkerInfo
-
- getLastCompleteTask() - Method in class org.apache.druid.client.indexing.HttpIndexingServiceClient
-
- getLastCompleteTask() - Method in interface org.apache.druid.client.indexing.IndexingServiceClient
-
- getLastCounter() - Method in class org.apache.druid.server.coordination.ChangeRequestHistory
-
- getLastKnownLookupsStateOnNodes() - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManager
-
- getLastSegmentIds() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorDriverMetadata
-
- getLatest() - Method in interface org.apache.druid.metadata.MetadataSupervisorManager
-
- getLatest() - Method in class org.apache.druid.metadata.SQLMetadataSupervisorManager
-
- getLatestVersion(URI, Pattern) - Method in class org.apache.druid.segment.loading.LocalFileTimestampVersionFinder
-
Matches based on a pattern in the file name.
- getLeader() - Method in class org.apache.druid.server.http.CoordinatorResource
-
- getLeaderHttpClient(HttpClient, DruidNodeDiscoveryProvider, ServerDiscoverySelector) - Method in class org.apache.druid.guice.CoordinatorDiscoveryModule
-
- getLeaderHttpClient(HttpClient, DruidNodeDiscoveryProvider, ServerDiscoverySelector) - Method in class org.apache.druid.guice.IndexingServiceDiscoveryModule
-
- getLength() - Method in class org.apache.druid.client.InputStreamHolder
-
- getLifecycleProvider() - Method in class org.apache.druid.guice.http.AbstractHttpClientProvider
-
- getLifetime() - Method in class org.apache.druid.server.coordinator.BalancerSegmentHolder
-
- getLine(ObjectMapper) - Method in class org.apache.druid.server.RequestLogLine
-
- getListenersPath() - Method in class org.apache.druid.server.listener.announcer.ListeningAnnouncerConfig
-
- getLiveSegmentsPath() - Method in class org.apache.druid.server.initialization.ZkPathsConfig
-
- getLoadedImplementations(Class<T>) - Static method in class org.apache.druid.initialization.Initialization
-
- getLoadedReplicants(String) - Method in class org.apache.druid.server.coordinator.SegmentReplicantLookup
-
- getLoadedReplicants(String, String) - Method in class org.apache.druid.server.coordinator.SegmentReplicantLookup
-
- getLoadingReplicants(String, String) - Method in class org.apache.druid.server.coordinator.SegmentReplicantLookup
-
- getLoadingReplicants(String) - Method in class org.apache.druid.server.coordinator.SegmentReplicantLookup
-
- getLoadManagementPeons() - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- getLoadManagementPeons() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getLoadQueue(String, String) - Method in class org.apache.druid.server.http.CoordinatorResource
-
- getLoadQueuePath() - Method in class org.apache.druid.server.initialization.ZkPathsConfig
-
- getLoadQueuePeonRepeatDelay() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getLoadQueuePeonType() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getLoadQueueSize() - Method in class org.apache.druid.server.coordinator.CuratorLoadQueuePeon
-
Deprecated.
- getLoadQueueSize() - Method in class org.apache.druid.server.coordinator.HttpLoadQueuePeon
-
- getLoadQueueSize() - Method in class org.apache.druid.server.coordinator.LoadQueuePeon
-
Deprecated.
- getLoadQueueSize() - Method in class org.apache.druid.server.coordinator.ServerHolder
-
- getLoadStatus() - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- getLoadStatus() - Method in class org.apache.druid.server.http.BrokerResource
-
- getLoadStatus(String, String) - Method in class org.apache.druid.server.http.CoordinatorResource
-
- getLoadStatus() - Method in class org.apache.druid.server.http.HistoricalResource
-
- getLoadTimeoutDelay() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorConfig
-
- getLocations() - Method in class org.apache.druid.query.LocatedSegmentDescriptor
-
- getLocations() - Method in class org.apache.druid.segment.loading.SegmentLoaderConfig
-
- getLocator() - Method in class org.apache.druid.client.cache.MemcachedCacheConfig
-
- getLockId(String, LockType) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getLocks(String) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getLogs(String) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getLookup() - Method in class org.apache.druid.query.dimension.LookupDimensionSpec
-
- getLookup() - Method in class org.apache.druid.query.lookup.RegisteredLookupExtractionFn
-
- getLookup(String, String) - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManager
-
Try to find a lookupName spec for the specified lookupName.
- getLookup(List<ShardSpec>) - Method in class org.apache.druid.timeline.partition.HashBasedNumberedShardSpec
-
- getLookup(List<ShardSpec>) - Method in class org.apache.druid.timeline.partition.LinearShardSpec
-
- getLookup(List<ShardSpec>) - Method in class org.apache.druid.timeline.partition.NumberedShardSpec
-
- getLookup(List<ShardSpec>) - Method in class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- getLookupExtractorFactory() - Method in class org.apache.druid.server.lookup.cache.LookupExtractorFactoryMapContainer
-
- getLookupNodeService(LookupListeningAnnouncerConfig) - Method in class org.apache.druid.query.lookup.LookupModule
-
- getLookupStateForNode(HostAndPortWithScheme) - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManager.LookupsCommunicator
-
- getLookupStatusForTier(String, boolean) - Method in class org.apache.druid.server.http.LookupCoordinatorResource
-
- getLookupTier() - Method in class org.apache.druid.discovery.LookupNodeService
-
- getMap() - Method in class org.apache.druid.query.lookup.MapLookupExtractorFactory.MapLookupIntrospectionHandler
-
- getMapperForRequest(String) - Method in class org.apache.druid.server.QueryResource
-
- getMaskProperties() - Method in class org.apache.druid.server.log.StartupLoggingConfig
-
- getMaxBytesInMemory() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getMaxBytesInMemory() - Method in interface org.apache.druid.segment.realtime.appenderator.AppenderatorConfig
-
Maximum number of bytes (estimated) to store in memory before persisting to local storage
- getMaxBytesInMemoryOrDefault(long) - Static method in class org.apache.druid.segment.indexing.TuningConfigs
-
- getMaxBytesPerNode() - Method in class org.apache.druid.server.initialization.BatchDataSegmentAnnouncerConfig
-
- getMaxCompactionTaskSlots() - Method in class org.apache.druid.server.coordinator.CoordinatorCompactionConfig
-
- getMaxEntrySize() - Method in class org.apache.druid.client.cache.CacheConfig
-
- getMaxIdleTime() - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory
-
- getMaxIdleTime() - Method in class org.apache.druid.server.initialization.ServerConfig
-
- getMaxMemory() - Method in class org.apache.druid.server.StatusResource.Memory
-
- getMaxNumSegmentsToCompact() - Method in class org.apache.druid.server.coordinator.DataSourceCompactionConfig
-
- getMaxObjectSize() - Method in class org.apache.druid.client.cache.MemcachedCacheConfig
-
- getMaxOperationQueueSize() - Method in class org.apache.druid.client.cache.MemcachedCacheConfig
-
- getMaxPendingPersists() - Method in class org.apache.druid.client.indexing.ClientCompactQueryTuningConfig
-
- getMaxPendingPersists() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getMaxPendingPersists() - Method in interface org.apache.druid.segment.realtime.appenderator.AppenderatorConfig
-
- getMaxQueryTimeout() - Method in class org.apache.druid.server.initialization.ServerConfig
-
- getMaxQueuedBytes() - Method in class org.apache.druid.guice.http.DruidHttpClientConfig
-
- getMaxRequestHeaderSize() - Method in class org.apache.druid.server.initialization.ServerConfig
-
- getMaxRowsInMemory() - Method in class org.apache.druid.client.indexing.ClientCompactQueryTuningConfig
-
- getMaxRowsInMemory() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getMaxRowsInMemory() - Method in interface org.apache.druid.segment.realtime.appenderator.AppenderatorConfig
-
Maximum number of rows in memory before persisting to local storage
- getMaxRowsInMemory() - Method in class org.apache.druid.segment.realtime.FireDepartmentConfig
-
- getMaxRowsPerSegment() - Method in interface org.apache.druid.segment.realtime.appenderator.AppenderatorConfig
-
Maximum number of rows in a single segment before pushing to deep storage
- getMaxScatterGatherBytes() - Method in class org.apache.druid.server.initialization.ServerConfig
-
- getMaxSegmentsInNodeLoadingQueue() - Method in class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- getMaxSegmentsToMove() - Method in class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- getMaxSize() - Method in class org.apache.druid.client.DruidServer
-
- getMaxSize() - Method in class org.apache.druid.client.DruidServerConfig
-
- getMaxSize() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getMaxSize() - Method in class org.apache.druid.discovery.DataNodeService
-
- getMaxSize() - Method in class org.apache.druid.segment.loading.StorageLocationConfig
-
- getMaxSize() - Method in class org.apache.druid.server.coordination.DruidServerMetadata
-
- getMaxSize() - Method in class org.apache.druid.server.coordinator.ServerHolder
-
- getMaxTotalRows() - Method in class org.apache.druid.client.indexing.ClientCompactQueryTuningConfig
-
- getMaxTotalRows() - Method in interface org.apache.druid.segment.realtime.appenderator.AppenderatorConfig
-
Maximum number of rows across all segments before pushing to deep storage
- getMemcachedPrefix() - Method in class org.apache.druid.client.cache.MemcachedCacheConfig
-
- getMemory() - Method in class org.apache.druid.server.StatusResource.Status
-
- getMergeBufferPool(DruidProcessingConfig) - Method in class org.apache.druid.guice.DruidProcessingModule
-
- getMergeBufferPool(DruidProcessingConfig) - Method in class org.apache.druid.guice.RouterProcessingModule
-
- getMergeBytesLimit() - Method in class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- getMergeSegmentsLimit() - Method in class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- getMergeThreadPriority() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getMessage() - Method in class org.apache.druid.server.security.Access
-
- getMetadata() - Method in class org.apache.druid.client.DruidServer
-
- getMetadata() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getMetadata(DruidNode, NodeTypeConfig, DruidServerConfig) - Method in class org.apache.druid.guice.StorageNodeModule
-
- getMetadata() - Method in class org.apache.druid.segment.realtime.appenderator.Committed
-
- getMetrics() - Method in class org.apache.druid.segment.realtime.FireDepartment
-
- getMetrics(String) - Method in class org.apache.druid.segment.realtime.RealtimeManager
-
- getMetrics() - Method in class org.apache.druid.server.metrics.EventReceiverFirehoseRegister
-
- getMillisToWaitBeforeDeleting() - Method in class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- getModules() - Method in class org.apache.druid.server.StatusResource.Status
-
- getMonitors() - Method in class org.apache.druid.server.metrics.MonitorsConfig
-
- getMonitorScheduler(Supplier<DruidMonitorSchedulerConfig>, MonitorsConfig, Set<Class<? extends Monitor>>, ServiceEmitter, Injector) - Method in class org.apache.druid.server.metrics.MetricsModule
-
- getName() - Method in class org.apache.druid.client.DruidDataSource
-
- getName() - Method in class org.apache.druid.client.DruidServer
-
- getName() - Method in class org.apache.druid.client.ImmutableDruidDataSource
-
- getName() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getName() - Method in class org.apache.druid.discovery.DataNodeService
-
- getName() - Method in class org.apache.druid.discovery.DruidService
-
- getName() - Method in class org.apache.druid.discovery.LookupNodeService
-
- getName() - Method in class org.apache.druid.discovery.WorkerNodeService
-
- getName() - Method in class org.apache.druid.query.dimension.LookupDimensionSpec
-
- getName() - Method in class org.apache.druid.server.coordination.DruidServerMetadata
-
- getName() - Method in class org.apache.druid.server.security.Resource
-
- getName() - Method in class org.apache.druid.server.StatusResource.ModuleVersion
-
- getNodesInTier(String) - Method in class org.apache.druid.server.lookup.cache.LookupNodeDiscovery
-
- getNodesStatusInTier(String) - Method in class org.apache.druid.server.http.LookupCoordinatorResource
-
- getNodeType() - Method in class org.apache.druid.discovery.DiscoveryDruidNode
-
- getNodeType() - Method in class org.apache.druid.guice.NodeTypeConfig
-
- getNumBackgroundThreads() - Method in class org.apache.druid.client.cache.CacheConfig
-
- getNumberOfSegmentsInQueue() - Method in class org.apache.druid.server.coordinator.CuratorLoadQueuePeon
-
Deprecated.
- getNumberOfSegmentsInQueue() - Method in class org.apache.druid.server.coordinator.HttpLoadQueuePeon
-
- getNumberOfSegmentsInQueue() - Method in class org.apache.druid.server.coordinator.LoadQueuePeon
-
Deprecated.
- getNumberOfSegmentsInQueue() - Method in class org.apache.druid.server.coordinator.ServerHolder
-
- getNumBootstrapThreads() - Method in class org.apache.druid.segment.loading.SegmentLoaderConfig
-
- getNumConnections() - Method in class org.apache.druid.client.cache.MemcachedCacheConfig
-
- getNumConnections() - Method in class org.apache.druid.guice.http.DruidHttpClientConfig
-
- getNumEntries() - Method in class org.apache.druid.client.cache.CacheStats
-
- getNumError() - Method in class org.apache.druid.client.cache.CachePopulatorStats.Snapshot
-
- getNumErrors() - Method in class org.apache.druid.client.cache.CacheStats
-
- getNumEvictions() - Method in class org.apache.druid.client.cache.CacheStats
-
- getNumHits() - Method in class org.apache.druid.client.cache.CacheStats
-
- getNumLoadingThreads() - Method in class org.apache.druid.segment.loading.SegmentLoaderConfig
-
- getNumMaxThreads() - Method in class org.apache.druid.guice.http.DruidHttpClientConfig
-
- getNumMisses() - Method in class org.apache.druid.client.cache.CacheStats
-
- getNumOk() - Method in class org.apache.druid.client.cache.CachePopulatorStats.Snapshot
-
- getNumOpenConnections() - Method in class org.apache.druid.client.DirectDruidClient
-
- getNumOversized() - Method in class org.apache.druid.client.cache.CachePopulatorStats.Snapshot
-
- getNumReplicants(String) - Method in class org.apache.druid.server.coordinator.rules.ForeverLoadRule
-
- getNumReplicants(String) - Method in class org.apache.druid.server.coordinator.rules.IntervalLoadRule
-
- getNumReplicants(String) - Method in class org.apache.druid.server.coordinator.rules.LoadRule
-
- getNumReplicants(String) - Method in class org.apache.druid.server.coordinator.rules.PeriodLoadRule
-
- getNumRequestsQueued() - Method in class org.apache.druid.guice.http.DruidHttpClientConfig
-
- getNumRows() - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
- getNumRowsInMemory() - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
- getNumRowsInSegment() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorDriverAddResult
-
- getNumSegments() - Method in class org.apache.druid.server.SegmentManager.DataSourceState
-
- getNumThreads() - Method in class org.apache.druid.client.HttpServerInventoryViewConfig
-
- getNumThreads() - Method in class org.apache.druid.server.initialization.ServerConfig
-
- getNumTimeouts() - Method in class org.apache.druid.client.cache.CacheStats
-
- getObject() - Method in class org.apache.druid.indexing.overlord.ObjectMetadata
-
- getObjectMapper() - Method in class org.apache.druid.server.QueryResource.ResponseContext
-
- getOrderedAvailableDataSegments() - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- getOutputName() - Method in class org.apache.druid.query.dimension.LookupDimensionSpec
-
- getOutputType() - Method in class org.apache.druid.query.dimension.LookupDimensionSpec
-
- getOverlordPath() - Method in class org.apache.druid.server.initialization.ZkPathsConfig
-
- getOverlordService() - Method in class org.apache.druid.server.coordinator.CoordinatorOverlordServiceConfig
-
- getParseException() - Method in class org.apache.druid.segment.realtime.appenderator.Appenderator.AppenderatorAddResult
-
- getParseException() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorDriverAddResult
-
- getParser() - Method in class org.apache.druid.segment.indexing.DataSchema
-
- getParser() - Method in class org.apache.druid.segment.realtime.firehose.LocalFirehoseFactory
-
- getParserMap() - Method in class org.apache.druid.segment.indexing.DataSchema
-
- getPartitionDimensions() - Method in class org.apache.druid.timeline.partition.HashBasedNumberedShardSpec
-
- getPartitionNum() - Method in class org.apache.druid.timeline.partition.LinearShardSpec
-
- getPartitionNum() - Method in class org.apache.druid.timeline.partition.NumberedShardSpec
-
- getPartitionNum() - Method in class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- getPartitionNumber() - Method in class org.apache.druid.query.LocatedSegmentDescriptor
-
- getPartitions() - Method in class org.apache.druid.timeline.partition.NumberedShardSpec
-
- getPath() - Method in class org.apache.druid.segment.loading.LocalLoadSpec
-
- getPath() - Method in class org.apache.druid.segment.loading.StorageLocationConfig
-
- getPath() - Method in class org.apache.druid.server.initialization.CuratorDiscoveryConfig
-
- getPath() - Method in class org.apache.druid.server.initialization.jetty.ResponseHeaderFilterHolder
-
- getPath() - Method in interface org.apache.druid.server.initialization.jetty.ServletFilterHolder
-
The path that this Filter should apply to
- getPath() - Method in class org.apache.druid.server.security.AllowAllAuthenticator
-
- getPath() - Method in class org.apache.druid.server.security.AnonymousAuthenticator
-
- getPathForHadoop() - Method in class org.apache.druid.segment.loading.LocalDataSegmentPusher
-
- getPathForHadoop(String) - Method in class org.apache.druid.segment.loading.LocalDataSegmentPusher
-
Deprecated.
- getPayload() - Method in class org.apache.druid.indexing.overlord.supervisor.SupervisorReport
-
- getPayloadType() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
SQL type to use for payload data (e.g.
- getPendingDeleteSnapshot() - Method in class org.apache.druid.server.coordination.SegmentLoadDropHandler
-
- getPendingTasks() - Method in class org.apache.druid.client.indexing.HttpIndexingServiceClient
-
- getPendingTasks() - Method in interface org.apache.druid.client.indexing.IndexingServiceClient
-
- getPeon() - Method in class org.apache.druid.server.coordinator.ServerHolder
-
- getPercentUsed() - Method in class org.apache.druid.server.coordinator.ServerHolder
-
- getPeriod() - Method in class org.apache.druid.server.coordinator.rules.PeriodBroadcastDistributionRule
-
- getPeriod() - Method in class org.apache.druid.server.coordinator.rules.PeriodDropRule
-
- getPeriod() - Method in class org.apache.druid.server.coordinator.rules.PeriodLoadRule
-
- getPeriod() - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- getPersistThreadPriority() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getPlaintextPort() - Method in class org.apache.druid.server.DruidNode
-
- getPlumberSchool() - Method in class org.apache.druid.segment.indexing.RealtimeIOConfig
-
- getPollDuration() - Method in class org.apache.druid.metadata.MetadataRuleManagerConfig
-
- getPollDuration() - Method in class org.apache.druid.metadata.MetadataSegmentManagerConfig
-
- getPollDuration() - Method in class org.apache.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifierConfig
-
- getPollingMs() - Method in class org.apache.druid.curator.ExhibitorConfig
-
- getPollPeriod() - Method in class org.apache.druid.server.router.TieredBrokerConfig
-
- getPopulateL2() - Method in class org.apache.druid.client.cache.HybridCacheConfig
-
- getPort() - Method in interface org.apache.druid.client.selector.Server
-
- getPort() - Method in class org.apache.druid.server.http.HostAndPortWithScheme
-
- getPortOrDefault(int) - Method in class org.apache.druid.server.http.HostAndPortWithScheme
-
- getPortToUse() - Method in class org.apache.druid.server.DruidNode
-
- getPriorities() - Method in class org.apache.druid.client.selector.CustomTierSelectorStrategyConfig
-
- getPriority() - Method in class org.apache.druid.client.DruidServer
-
- getPriority() - Method in class org.apache.druid.client.DruidServerConfig
-
- getPriority() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getPriority() - Method in class org.apache.druid.discovery.DataNodeService
-
- getPriority() - Method in class org.apache.druid.server.coordination.DruidServerMetadata
-
- getProcessingExecutorService(DruidProcessingConfig, ExecutorServiceMonitor, Lifecycle) - Method in class org.apache.druid.guice.DruidProcessingModule
-
- getProcessingExecutorService(DruidProcessingConfig) - Method in class org.apache.druid.guice.RouterProcessingModule
-
- getProperties() - Method in class org.apache.druid.client.DruidDataSource
-
- getProperties() - Method in class org.apache.druid.client.ImmutableDruidDataSource
-
- getProperties() - Method in class org.apache.druid.server.StatusResource
-
- getPropertiesPath() - Method in class org.apache.druid.server.initialization.ZkPathsConfig
-
- getProtocol() - Method in class org.apache.druid.client.cache.MemcachedCacheConfig
-
- getProtocol() - Method in class org.apache.druid.server.emitter.HttpEmitterSSLClientConfig
-
- getProtocol() - Method in class org.apache.druid.server.initialization.jetty.JettyMonitoringConnectionFactory
-
- getProtocols() - Method in class org.apache.druid.server.initialization.jetty.JettyMonitoringConnectionFactory
-
- getPublishTimeout() - Method in class org.apache.druid.client.indexing.ClientCompactQueryTuningConfig
-
- getQuery() - Method in class org.apache.druid.server.log.EmittingRequestLogger.RequestLogEvent
-
- getQuery() - Method in class org.apache.druid.server.QueryLifecycle
-
- getQuery() - Method in class org.apache.druid.server.RequestLogLine
-
- getQueryableDataSources(String, String, HttpServletRequest) - Method in class org.apache.druid.server.http.DatasourcesResource
-
- getQueryDatasources(String) - Method in class org.apache.druid.server.QueryManager
-
- getQueryGranularity() - Method in class org.apache.druid.segment.indexing.granularity.ArbitraryGranularitySpec
-
- getQueryGranularity() - Method in interface org.apache.druid.segment.indexing.granularity.GranularitySpec
-
- getQueryGranularity() - Method in class org.apache.druid.segment.indexing.granularity.UniformGranularitySpec
-
- getQueryRunner(DruidServer) - Method in class org.apache.druid.client.BrokerServerView
-
- getQueryRunner(DruidServer) - Method in interface org.apache.druid.client.TimelineServerView
-
- getQueryRunner(Query<T>) - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumber
-
- getQueryRunner(Query<T>) - Method in interface org.apache.druid.segment.realtime.plumber.Plumber
-
- getQueryRunner(Query<T>) - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- getQueryRunnerForIntervals(Query<T>, Iterable<Interval>) - Method in class org.apache.druid.client.CachingClusteredClient
-
- getQueryRunnerForIntervals(Query<T>, Iterable<Interval>) - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
- getQueryRunnerForIntervals(Query<T>, Iterable<Interval>) - Method in class org.apache.druid.segment.realtime.appenderator.SinkQuerySegmentWalker
-
- getQueryRunnerForIntervals(Query<T>, Iterable<Interval>) - Method in class org.apache.druid.segment.realtime.RealtimeManager
-
- getQueryRunnerForIntervals(Query<T>, Iterable<Interval>) - Method in class org.apache.druid.server.ClientQuerySegmentWalker
-
- getQueryRunnerForIntervals(Query<T>, Iterable<Interval>) - Method in class org.apache.druid.server.coordination.ServerManager
-
- getQueryRunnerForSegments(Query<T>, Iterable<SegmentDescriptor>) - Method in class org.apache.druid.client.CachingClusteredClient
-
- getQueryRunnerForSegments(Query<T>, Iterable<SegmentDescriptor>) - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
- getQueryRunnerForSegments(Query<T>, Iterable<SegmentDescriptor>) - Method in class org.apache.druid.segment.realtime.appenderator.SinkQuerySegmentWalker
-
- getQueryRunnerForSegments(Query<T>, Iterable<SegmentDescriptor>) - Method in class org.apache.druid.segment.realtime.RealtimeManager
-
- getQueryRunnerForSegments(Query<T>, Iterable<SegmentDescriptor>) - Method in class org.apache.druid.server.ClientQuerySegmentWalker
-
- getQueryRunnerForSegments(Query<T>, Iterable<SegmentDescriptor>) - Method in class org.apache.druid.server.coordination.ServerManager
-
- getQueryStats() - Method in class org.apache.druid.server.log.EmittingRequestLogger.RequestLogEvent
-
- getQueryStats() - Method in class org.apache.druid.server.RequestLogLine
-
- getQueryTargets(InputStream, String, int, HttpServletRequest) - Method in class org.apache.druid.server.BrokerQueryResource
-
- getQueryTargets(String, String, int, HttpServletRequest) - Method in class org.apache.druid.server.ClientInfoResource
-
- getQueueSize() - Method in class org.apache.druid.server.initialization.ServerConfig
-
- getQuoteString() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- getQuoteString() - Method in class org.apache.druid.metadata.storage.derby.DerbyConnector
-
- getReadBufferSize() - Method in class org.apache.druid.client.cache.MemcachedCacheConfig
-
- getReadiness() - Method in class org.apache.druid.server.http.HistoricalResource
-
- getReadTimeout() - Method in class org.apache.druid.guice.http.DruidHttpClientConfig
-
- getRealtimes() - Method in class org.apache.druid.server.coordinator.DruidCluster
-
- getRedirectURL(String, String) - Method in class org.apache.druid.server.http.CoordinatorRedirectInfo
-
- getRedirectURL(String, String) - Method in interface org.apache.druid.server.http.RedirectInfo
-
- getRejectionPolicy() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumber
-
- getRejectionPolicy() - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- getRejectionPolicyFactory() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getRemainingSegmentSizeBytes(String) - Method in class org.apache.druid.server.coordinator.helper.DruidCoordinatorSegmentCompactor
-
- getRemoteAddr() - Method in class org.apache.druid.server.log.EmittingRequestLogger.RequestLogEvent
-
- getRemoteAddr() - Method in class org.apache.druid.server.RequestLogLine
-
- getReplaceMissingValueWith() - Method in class org.apache.druid.query.lookup.RegisteredLookupExtractionFn
-
- getReplicantLifetime() - Method in class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- getReplicationManager() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getReplicationStatus() - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- getReplicationThrottleLimit() - Method in class org.apache.druid.server.coordinator.CoordinatorDynamicConfig
-
- getReq() - Method in class org.apache.druid.server.http.security.AbstractResourceFilter
-
- getRequest() - Method in class org.apache.druid.server.coordination.SegmentLoadDropHandler.DataSegmentChangeRequestAndStatus
-
- getRequestBuffersize() - Method in class org.apache.druid.guice.http.DruidHttpClientConfig
-
- getRequestFilter() - Method in class org.apache.druid.server.http.security.AbstractResourceFilter
-
- getRequests() - Method in class org.apache.druid.server.coordination.ChangeRequestsSnapshot
-
- getRequestsSince(ChangeRequestHistory.Counter) - Method in class org.apache.druid.server.coordination.ChangeRequestHistory
-
Returns a Future that , on completion, returns list of segment updates and associated counter.
- getResetCause() - Method in class org.apache.druid.server.coordination.ChangeRequestsSnapshot
-
- getResource(String) - Method in class org.apache.druid.initialization.ExtensionFirstClassLoader
-
- getResource() - Method in class org.apache.druid.server.security.ResourceAction
-
- getResources(String) - Method in class org.apache.druid.initialization.ExtensionFirstClassLoader
-
- getResponseContext() - Method in class org.apache.druid.server.QueryLifecycle.QueryResponse
-
- getResponseFilter() - Method in class org.apache.druid.server.http.security.AbstractResourceFilter
-
- getRestPort() - Method in class org.apache.druid.curator.ExhibitorConfig
-
- getRestUriPath() - Method in class org.apache.druid.curator.ExhibitorConfig
-
- getResultLevelCacheLimit() - Method in class org.apache.druid.client.cache.CacheConfig
-
- getResults() - Method in class org.apache.druid.server.QueryLifecycle.QueryResponse
-
- getRetryCondition() - Method in class org.apache.druid.segment.realtime.firehose.HttpFirehoseFactory
-
- getRowCount(SegmentIdentifier) - Method in interface org.apache.druid.segment.realtime.appenderator.Appenderator
-
Returns the number of rows in a particular pending segment.
- getRowCount(SegmentIdentifier) - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
- getRules(String) - Method in interface org.apache.druid.metadata.MetadataRuleManager
-
- getRules(String) - Method in class org.apache.druid.metadata.SQLMetadataRuleManager
-
- getRules(String) - Method in class org.apache.druid.server.coordinator.rules.RuleMap
-
- getRules() - Method in class org.apache.druid.server.http.RulesResource
-
- getRulesEndpoint() - Method in class org.apache.druid.server.router.TieredBrokerConfig
-
- getRulesWithDefault(String) - Method in interface org.apache.druid.metadata.MetadataRuleManager
-
- getRulesWithDefault(String) - Method in class org.apache.druid.metadata.SQLMetadataRuleManager
-
- getRulesWithDefault(String) - Method in class org.apache.druid.server.router.CoordinatorRuleManager
-
- getRunningTasks() - Method in class org.apache.druid.client.indexing.HttpIndexingServiceClient
-
- getRunningTasks() - Method in interface org.apache.druid.client.indexing.IndexingServiceClient
-
- getRunningTasks() - Method in class org.apache.druid.client.indexing.IndexingWorkerInfo
-
- getScheduledExecutorFactory(Lifecycle) - Method in class org.apache.druid.guice.ServerModule
-
- getSchema() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumber
-
- getSchema() - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- getScheme() - Method in class org.apache.druid.client.DruidServer
-
- getScheme() - Method in class org.apache.druid.client.indexing.IndexingWorker
-
- getScheme() - Method in interface org.apache.druid.client.selector.Server
-
- getScheme() - Method in class org.apache.druid.server.http.HostAndPortWithScheme
-
- getSecuredDataSources(HttpServletRequest, InventoryView, AuthorizerMapper) - Static method in interface org.apache.druid.server.http.InventoryViewUtils
-
- getSegment(String) - Method in class org.apache.druid.client.DruidDataSource
-
- getSegment(String) - Method in class org.apache.druid.client.DruidServer
-
- getSegment(String) - Method in class org.apache.druid.client.ImmutableDruidDataSource
-
- getSegment(String) - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getSegment() - Method in class org.apache.druid.client.ImmutableSegmentLoadInfo
-
- getSegment() - Method in class org.apache.druid.client.selector.ServerSelector
-
- getSegment(DataSegment) - Method in interface org.apache.druid.segment.loading.SegmentLoader
-
- getSegment(DataSegment) - Method in class org.apache.druid.segment.loading.SegmentLoaderLocalCacheManager
-
- getSegment() - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
- getSegment() - Method in class org.apache.druid.server.coordination.SegmentChangeRequestDrop
-
- getSegment() - Method in class org.apache.druid.server.coordination.SegmentChangeRequestLoad
-
- getSegment() - Method in class org.apache.druid.server.coordinator.BalancerSegmentHolder
-
- getSegmentAvailability() - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- getSegmentChangesSince(ChangeRequestHistory.Counter) - Method in class org.apache.druid.server.coordination.BatchDataSegmentAnnouncer
-
Returns Future that lists the segment load/drop requests since given counter.
- getSegmentDataInterval() - Method in class org.apache.druid.segment.realtime.FireHydrant
-
- getSegmentDataSourceIntervals(String, String, String) - Method in class org.apache.druid.server.http.DatasourcesResource
-
- getSegmentDataSourceSegment(String, String) - Method in class org.apache.druid.server.http.DatasourcesResource
-
- getSegmentDataSourceSegments(String, String) - Method in class org.apache.druid.server.http.DatasourcesResource
-
- getSegmentDataSourceSpecificInterval(String, String, String, String) - Method in class org.apache.druid.server.http.DatasourcesResource
-
- getSegmentDataSourceSpecificInterval(String, String, boolean) - Method in class org.apache.druid.server.http.DatasourcesResource
-
Provides serverView for a datasource and Interval which gives details about servers hosting segments for an interval
Used by the realtime tasks to fetch a view of the interval they are interested in.
- getSegmentDataSourceTiers(String) - Method in class org.apache.druid.server.http.DatasourcesResource
-
- getSegmentFiles(DataSegment, File) - Method in class org.apache.druid.segment.loading.LocalDataSegmentPuller
-
- getSegmentFiles(File, File) - Method in class org.apache.druid.segment.loading.LocalDataSegmentPuller
-
- getSegmentFiles(DataSegment) - Method in interface org.apache.druid.segment.loading.SegmentLoader
-
- getSegmentFiles(DataSegment) - Method in class org.apache.druid.segment.loading.SegmentLoaderLocalCacheManager
-
- getSegmentGranularity() - Method in class org.apache.druid.segment.indexing.granularity.ArbitraryGranularitySpec
-
- getSegmentGranularity() - Method in interface org.apache.druid.segment.indexing.granularity.GranularitySpec
-
- getSegmentGranularity() - Method in class org.apache.druid.segment.indexing.granularity.UniformGranularitySpec
-
- getSegmentIdentifier() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorDriverAddResult
-
- getSegmentIdentifier() - Method in class org.apache.druid.segment.realtime.appenderator.SegmentWithState
-
- getSegmentIdentifier() - Method in class org.apache.druid.segment.realtime.FireHydrant
-
- getSegmentName() - Method in class org.apache.druid.server.http.SegmentToDrop
-
- getSegmentName() - Method in class org.apache.druid.server.http.SegmentToMove
-
- getSegmentReplicantLookup() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getSegments() - Method in class org.apache.druid.client.DruidDataSource
-
- getSegments() - Method in class org.apache.druid.client.DruidServer
-
- getSegments() - Method in class org.apache.druid.client.ImmutableDruidDataSource
-
- getSegments() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getSegments() - Method in class org.apache.druid.client.indexing.ClientAppendQuery
-
- getSegments() - Method in class org.apache.druid.client.indexing.ClientCompactQuery
-
- getSegments() - Method in class org.apache.druid.client.indexing.ClientMergeQuery
-
- getSegments() - Method in class org.apache.druid.indexing.overlord.SegmentPublishResult
-
- getSegments() - Method in interface org.apache.druid.segment.realtime.appenderator.Appenderator
-
Returns a list of all currently active segments.
- getSegments() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorDriverMetadata
-
- getSegments() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
- getSegments() - Method in class org.apache.druid.segment.realtime.appenderator.SegmentsAndMetadata
-
- getSegments(long, long, long, HttpServletRequest) - Method in class org.apache.druid.server.http.SegmentListerResource
-
This endpoint is used by HttpServerInventoryView to keep an up-to-date list of segments served by
historical/realtime nodes.
- getSegmentsMarkedToDrop() - Method in class org.apache.druid.server.coordinator.CuratorLoadQueuePeon
-
Deprecated.
- getSegmentsMarkedToDrop() - Method in class org.apache.druid.server.coordinator.HttpLoadQueuePeon
-
- getSegmentsMarkedToDrop() - Method in class org.apache.druid.server.coordinator.LoadQueuePeon
-
Deprecated.
- getSegmentsPerNode() - Method in class org.apache.druid.server.initialization.BatchDataSegmentAnnouncerConfig
-
- getSegmentsToDrop() - Method in class org.apache.druid.server.coordinator.CuratorLoadQueuePeon
-
Deprecated.
- getSegmentsToDrop() - Method in class org.apache.druid.server.coordinator.HttpLoadQueuePeon
-
- getSegmentsToDrop() - Method in class org.apache.druid.server.coordinator.LoadQueuePeon
-
Deprecated.
- getSegmentsToLoad() - Method in class org.apache.druid.server.coordinator.CuratorLoadQueuePeon
-
Deprecated.
- getSegmentsToLoad() - Method in class org.apache.druid.server.coordinator.HttpLoadQueuePeon
-
- getSegmentsToLoad() - Method in class org.apache.druid.server.coordinator.LoadQueuePeon
-
Deprecated.
- getSegmentsView() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumber
-
- getSegmentTable() - Method in class org.apache.druid.segment.realtime.DbSegmentPublisherConfig
-
- getSegmentWriteOutMediumFactory() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getSegmentWriteOutMediumFactory() - Method in interface org.apache.druid.segment.realtime.appenderator.AppenderatorConfig
-
- getSequenceName(Interval, String, ShardSpec) - Static method in class org.apache.druid.segment.realtime.appenderator.Appenderators
-
- getSerialType() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
Auto-incrementing SQL type to use for IDs
Must be an integer type, which values will be automatically set by the database
The resulting string will be interpolated into the table creation statement, e.g.
- getSerialType() - Method in class org.apache.druid.metadata.storage.derby.DerbyConnector
-
- getServedSegmentsPath() - Method in class org.apache.druid.server.initialization.ZkPathsConfig
-
Deprecated.
- getServer() - Method in class org.apache.druid.client.selector.QueryableDruidServer
-
- getServer() - Method in class org.apache.druid.server.coordinator.ServerHolder
-
- getServer(String, String) - Method in class org.apache.druid.server.http.ServersResource
-
- getServer(Injector, Lifecycle, DruidNode, ServerConfig, TLSServerConfig) - Method in class org.apache.druid.server.initialization.jetty.ChatHandlerServerModule
-
- getServer(Injector, Lifecycle, DruidNode, ServerConfig, TLSServerConfig) - Method in class org.apache.druid.server.initialization.jetty.JettyServerModule
-
- getServerDiscoveryFactory(ServiceDiscovery<Void>) - Method in class org.apache.druid.curator.discovery.DiscoveryModule
-
- getServerHttpTimeout() - Method in class org.apache.druid.server.coordination.ChangeRequestHttpSyncer
-
- getServers() - Method in class org.apache.druid.client.ImmutableSegmentLoadInfo
-
- getServerSegment(String, String) - Method in class org.apache.druid.server.http.ServersResource
-
- getServerSegments(String, String) - Method in class org.apache.druid.server.http.ServersResource
-
- getServerTimeout() - Method in class org.apache.druid.client.HttpServerInventoryViewConfig
-
- getServerUnstabilityTimeout() - Method in class org.apache.druid.client.HttpServerInventoryViewConfig
-
- getService() - Method in class org.apache.druid.server.log.EmittingRequestLogger.RequestLogEvent
-
- getServiceAnnouncer(CuratorServiceAnnouncer, Injector, Set<KeyHolder<DruidNode>>, Lifecycle) - Method in class org.apache.druid.curator.discovery.DiscoveryModule
-
- getServiceDiscovery(CuratorFramework, CuratorDiscoveryConfig, Lifecycle) - Method in class org.apache.druid.curator.discovery.DiscoveryModule
-
- getServiceEmitter(Supplier<DruidNode>, Emitter, Map<String, String>) - Method in class org.apache.druid.server.emitter.EmitterModule
-
- getServiceName() - Method in class org.apache.druid.client.coordinator.CoordinatorSelectorConfig
-
- getServiceName() - Method in class org.apache.druid.client.indexing.IndexingServiceSelectorConfig
-
- getServiceName() - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory
-
- getServiceName() - Method in class org.apache.druid.server.DruidNode
-
- getServiceProvider(CoordinatorSelectorConfig, ServerDiscoveryFactory) - Method in class org.apache.druid.guice.CoordinatorDiscoveryModule
-
- getServiceProvider(IndexingServiceSelectorConfig, ServerDiscoveryFactory) - Method in class org.apache.druid.guice.IndexingServiceDiscoveryModule
-
- getServices() - Method in class org.apache.druid.discovery.DiscoveryDruidNode
-
- getServiceScheme() - Method in class org.apache.druid.server.DruidNode
-
- getShardSpec() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getShardSpec() - Method in class org.apache.druid.segment.realtime.appenderator.SegmentIdentifier
-
- getShutoffTime() - Method in class org.apache.druid.segment.realtime.firehose.TimedShutoffFirehoseFactory
-
- getShutterDowner(Log4jShutdown) - Method in class org.apache.druid.initialization.Log4jShutterDownerModule
-
- getSinks() - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- getSize() - Method in class org.apache.druid.query.LocatedSegmentDescriptor
-
- getSizeInBytes() - Method in class org.apache.druid.client.cache.CacheStats
-
- getSizeInBytes() - Method in class org.apache.druid.client.cache.CaffeineCacheConfig
-
- getSizeUsed() - Method in class org.apache.druid.server.coordinator.ServerHolder
-
- getSkipOffsetFromLatest() - Method in class org.apache.druid.server.coordinator.DataSourceCompactionConfig
-
- getSortedHistoricalsByTier() - Method in class org.apache.druid.server.coordinator.DruidCluster
-
- getSpec() - Method in class org.apache.druid.indexing.overlord.supervisor.VersionedSupervisorSpec
-
- getSpecFile() - Method in class org.apache.druid.guice.RealtimeManagerConfig
-
- getSpecificIntervals(String, String, String, HttpServletRequest) - Method in class org.apache.druid.server.http.IntervalsResource
-
- getSpecificLookup(String, String) - Method in class org.apache.druid.server.http.LookupCoordinatorResource
-
- getSpecificLookupStatus(String, String, boolean) - Method in class org.apache.druid.server.http.LookupCoordinatorResource
-
- getSpecificNodeStatus(String, HostAndPort) - Method in class org.apache.druid.server.http.LookupCoordinatorResource
-
- getSpecificTier(String, boolean) - Method in class org.apache.druid.server.http.LookupCoordinatorResource
-
- getSslContextBinding() - Method in class org.apache.druid.guice.http.AbstractHttpClientProvider
-
- getSslContextKey() - Method in class org.apache.druid.guice.http.AbstractHttpClientProvider
-
- getStart() - Method in class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- getStartTime() - Method in class org.apache.druid.server.coordinator.DruidCoordinatorRuntimeParams
-
- getState() - Method in class org.apache.druid.segment.realtime.appenderator.SegmentWithState
-
- getState() - Method in class org.apache.druid.server.coordination.SegmentLoadDropHandler.Status
-
- getStats() - Method in interface org.apache.druid.client.cache.Cache
-
- getStats() - Method in class org.apache.druid.client.cache.CaffeineCache
-
- getStats() - Method in class org.apache.druid.client.cache.HybridCache
-
- getStats() - Method in class org.apache.druid.client.cache.MapCache
-
- getStats() - Method in class org.apache.druid.client.cache.MemcachedCache
-
- getStats() - Method in interface org.apache.druid.indexing.overlord.supervisor.Supervisor
-
- getStats() - Method in class org.apache.druid.server.QueryStats
-
- getStatus() - Method in class org.apache.druid.client.indexing.TaskStatusResponse
-
- getStatus() - Method in interface org.apache.druid.indexing.overlord.supervisor.Supervisor
-
- getStatus(String) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getStatus() - Method in class org.apache.druid.server.coordination.SegmentLoadDropHandler.DataSegmentChangeRequestAndStatus
-
- getStatus() - Method in class org.apache.druid.server.coordinator.BytesAccumulatingResponseHandler
-
- getStatusCode() - Method in class org.apache.druid.client.indexing.QueryStatus
-
- getStatusCode() - Method in class org.apache.druid.client.indexing.TaskStatus
-
- getStatusQueueMaxSize() - Method in class org.apache.druid.segment.loading.SegmentLoaderConfig
-
- getStatusType() - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getStorageDirectory() - Method in class org.apache.druid.segment.loading.LocalDataSegmentPusherConfig
-
- getStrategies() - Method in class org.apache.druid.server.router.TieredBrokerConfig
-
- getStream() - Method in class org.apache.druid.client.InputStreamHolder
-
- getStreamingFetchSize() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
Returns the value that should be passed to statement.setFetchSize to ensure results
are streamed back from the database instead of fetching the entire result set in memory.
- getStreamingFetchSize() - Method in class org.apache.druid.metadata.storage.derby.DerbyConnector
-
- getSuccessfulQueryCount() - Method in class org.apache.druid.server.AsyncQueryForwardingServlet
-
- getSuccessfulQueryCount() - Method in interface org.apache.druid.server.metrics.QueryCountStatsProvider
-
- getSuccessfulQueryCount() - Method in class org.apache.druid.server.QueryResource
-
- getSysMonitor(DataSourceTaskIdHolder) - Method in class org.apache.druid.server.metrics.MetricsModule
-
- getTargetCompactionSizeBytes() - Method in class org.apache.druid.client.indexing.ClientCompactQuery
-
- getTargetCompactionSizeBytes() - Method in class org.apache.druid.server.coordinator.DataSourceCompactionConfig
-
- getTargetLocations(TimelineServerView, String, List<Interval>, int) - Static method in class org.apache.druid.client.ServerViewUtil
-
- getTargetLocations(TimelineServerView, DataSource, List<Interval>, int) - Static method in class org.apache.druid.client.ServerViewUtil
-
- getTask() - Method in class org.apache.druid.client.indexing.TaskStatusResponse
-
- getTaskContext() - Method in class org.apache.druid.server.coordinator.DataSourceCompactionConfig
-
- getTaskId() - Method in class org.apache.druid.server.metrics.DataSourceTaskIdHolder
-
- getTaskInfo(String) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- getTaskPriority() - Method in class org.apache.druid.server.coordinator.DataSourceCompactionConfig
-
- getTaskStatus(String) - Method in class org.apache.druid.client.indexing.HttpIndexingServiceClient
-
- getTaskStatus(String) - Method in interface org.apache.druid.client.indexing.IndexingServiceClient
-
- getTheDataSource(String, String) - Method in class org.apache.druid.server.http.DatasourcesResource
-
- getThreadPoolSize() - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- getTier() - Method in class org.apache.druid.client.DruidServer
-
- getTier() - Method in class org.apache.druid.client.DruidServerConfig
-
- getTier() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getTier() - Method in class org.apache.druid.discovery.DataNodeService
-
- getTier() - Method in class org.apache.druid.server.coordination.DruidServerMetadata
-
- getTierDatasources(String, String) - Method in class org.apache.druid.server.http.TiersResource
-
- getTieredReplicants() - Method in class org.apache.druid.server.coordinator.rules.ForeverLoadRule
-
- getTieredReplicants() - Method in class org.apache.druid.server.coordinator.rules.IntervalLoadRule
-
- getTieredReplicants() - Method in class org.apache.druid.server.coordinator.rules.LoadRule
-
- getTieredReplicants() - Method in class org.apache.druid.server.coordinator.rules.PeriodLoadRule
-
- getTieredStat(String, String) - Method in class org.apache.druid.server.coordinator.CoordinatorStats
-
- getTierListenerPath(String) - Static method in class org.apache.druid.query.lookup.LookupModule
-
- getTierNames() - Method in class org.apache.druid.server.coordinator.DruidCluster
-
- getTiers(String) - Method in class org.apache.druid.server.coordinator.CoordinatorStats
-
- getTiers(boolean) - Method in class org.apache.druid.server.http.LookupCoordinatorResource
-
- getTiers(String) - Method in class org.apache.druid.server.http.TiersResource
-
- getTierToBrokerMap() - Method in class org.apache.druid.server.router.TieredBrokerConfig
-
- getTimeline(DataSource) - Method in class org.apache.druid.client.BrokerServerView
-
- getTimeline(DataSource) - Method in class org.apache.druid.client.CoordinatorServerView
-
- getTimeline(DataSource) - Method in interface org.apache.druid.client.TimelineServerView
-
- getTimeline() - Method in class org.apache.druid.server.SegmentManager.DataSourceState
-
- getTimeline(String) - Method in class org.apache.druid.server.SegmentManager
-
- getTimeout() - Method in class org.apache.druid.client.cache.MemcachedCacheConfig
-
- getTimestamp() - Method in class org.apache.druid.server.RequestLogLine
-
- getTlsPort() - Method in class org.apache.druid.server.DruidNode
-
- getToServer() - Method in class org.apache.druid.server.http.SegmentToMove
-
- getTotalMemory() - Method in class org.apache.druid.server.StatusResource.Memory
-
- getTotalNumRowsInAppenderator() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorDriverAddResult
-
- getTotalReplicants(String) - Method in class org.apache.druid.server.coordinator.SegmentReplicantLookup
-
- getTotalReplicants(String, String) - Method in class org.apache.druid.server.coordinator.SegmentReplicantLookup
-
- getTotalRowCount() - Method in interface org.apache.druid.segment.realtime.appenderator.Appenderator
-
Returns the number of total rows in this appenderator of all segments pending push.
- getTotalRowCount() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
- getTotalSegmentSize() - Method in class org.apache.druid.server.SegmentManager.DataSourceState
-
- getTotalWorkerCapacity() - Method in class org.apache.druid.client.indexing.HttpIndexingServiceClient
-
- getTotalWorkerCapacity() - Method in interface org.apache.druid.client.indexing.IndexingServiceClient
-
- getTransformSpec() - Method in class org.apache.druid.segment.indexing.DataSchema
-
- getTrustStoreAlgorithm() - Method in class org.apache.druid.server.emitter.HttpEmitterSSLClientConfig
-
- getTrustStoreAlgorithm() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getTrustStorePasswordProvider() - Method in class org.apache.druid.server.emitter.HttpEmitterSSLClientConfig
-
- getTrustStorePasswordProvider() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getTrustStorePath() - Method in class org.apache.druid.server.emitter.HttpEmitterSSLClientConfig
-
- getTrustStorePath() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getTrustStoreType() - Method in class org.apache.druid.server.emitter.HttpEmitterSSLClientConfig
-
- getTrustStoreType() - Method in class org.apache.druid.server.initialization.TLSServerConfig
-
- getTuningConfig() - Method in class org.apache.druid.client.indexing.ClientCompactQuery
-
- getTuningConfig() - Method in class org.apache.druid.segment.indexing.IngestionSpec
-
- getTuningConfig() - Method in class org.apache.druid.segment.realtime.FireDepartment
-
- getTuningConfig() - Method in class org.apache.druid.server.coordinator.DataSourceCompactionConfig
-
- getType() - Method in class org.apache.druid.client.DruidServer
-
- getType() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getType() - Method in class org.apache.druid.client.indexing.ClientAppendQuery
-
- getType() - Method in class org.apache.druid.client.indexing.ClientCompactQuery
-
- getType() - Method in class org.apache.druid.client.indexing.ClientCompactQueryTuningConfig
-
- getType() - Method in class org.apache.druid.client.indexing.ClientKillQuery
-
- getType() - Method in class org.apache.druid.client.indexing.ClientMergeQuery
-
- getType() - Method in class org.apache.druid.discovery.DataNodeService
-
- getType() - Method in class org.apache.druid.server.coordination.DruidServerMetadata
-
- getType() - Method in class org.apache.druid.server.coordinator.rules.ForeverBroadcastDistributionRule
-
- getType() - Method in class org.apache.druid.server.coordinator.rules.ForeverDropRule
-
- getType() - Method in class org.apache.druid.server.coordinator.rules.ForeverLoadRule
-
- getType() - Method in class org.apache.druid.server.coordinator.rules.IntervalBroadcastDistributionRule
-
- getType() - Method in class org.apache.druid.server.coordinator.rules.IntervalDropRule
-
- getType() - Method in class org.apache.druid.server.coordinator.rules.IntervalLoadRule
-
- getType() - Method in class org.apache.druid.server.coordinator.rules.PeriodBroadcastDistributionRule
-
- getType() - Method in class org.apache.druid.server.coordinator.rules.PeriodDropRule
-
- getType() - Method in class org.apache.druid.server.coordinator.rules.PeriodLoadRule
-
- getType() - Method in interface org.apache.druid.server.coordinator.rules.Rule
-
- getType() - Method in class org.apache.druid.server.security.Resource
-
- getUnannouncePropagationDelay() - Method in class org.apache.druid.server.initialization.ServerConfig
-
- getUnsecuredPaths() - Method in class org.apache.druid.server.security.AuthConfig
-
- getUnusedConnectionTimeout() - Method in class org.apache.druid.guice.http.DruidHttpClientConfig
-
- getUnusedSegmentIntervals(String, Interval, int) - Method in interface org.apache.druid.metadata.MetadataSegmentManager
-
Returns top N unused segment intervals in given interval when ordered by segment start time, end time.
- getUnusedSegmentIntervals(String, Interval, int) - Method in class org.apache.druid.metadata.SQLMetadataSegmentManager
-
- getUnusedSegmentsForInterval(String, Interval) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
Get all segments which include ONLY data within the given interval and are not flagged as used.
- getUnusedSegmentsForInterval(String, Interval) - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
- getUris() - Method in class org.apache.druid.segment.realtime.firehose.HttpFirehoseFactory
-
- getURL() - Method in class org.apache.druid.client.ImmutableDruidServer
-
- getURLsForClasspath(String) - Static method in class org.apache.druid.initialization.Initialization
-
- getUsedMemory() - Method in class org.apache.druid.server.StatusResource.Memory
-
- getUsedSegmentAndCreatedDateForInterval(String, Interval) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
Get all used segments and the created_date of these segments in a given datasource and interval
- getUsedSegmentAndCreatedDateForInterval(String, Interval) - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
- getUsedSegmentsForInterval(String, Interval) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
Get all segments which may include any data in the interval and are flagged as used.
- getUsedSegmentsForIntervals(String, List<Interval>) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
Get all segments which may include any data in the interval and are flagged as used.
- getUsedSegmentsForIntervals(String, List<Interval>) - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
- getUseL2() - Method in class org.apache.druid.client.cache.HybridCacheConfig
-
- getUseSsl() - Method in class org.apache.druid.curator.ExhibitorConfig
-
- getValidationQuery() - Method in class org.apache.druid.metadata.SQLFirehoseDatabaseConnector
-
- getValidationQuery() - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- getValidationQuery() - Method in class org.apache.druid.metadata.storage.derby.DerbyConnector
-
- getValues() - Method in class org.apache.druid.query.lookup.MapLookupExtractorFactory.MapLookupIntrospectionHandler
-
- getVersion() - Method in class org.apache.druid.client.indexing.IndexingWorker
-
- getVersion() - Method in class org.apache.druid.discovery.WorkerNodeService
-
- getVersion() - Method in class org.apache.druid.indexing.overlord.supervisor.VersionedSupervisorSpec
-
- getVersion() - Method in class org.apache.druid.query.LocatedSegmentDescriptor
-
- getVersion(URI) - Method in class org.apache.druid.segment.loading.LocalDataSegmentPuller
-
Returns the "version" (aka last modified timestamp) of the URI of interest
- getVersion() - Method in class org.apache.druid.segment.realtime.appenderator.SegmentIdentifier
-
- getVersion(Interval) - Method in class org.apache.druid.segment.realtime.plumber.CustomVersioningPolicy
-
- getVersion() - Method in class org.apache.druid.segment.realtime.plumber.CustomVersioningPolicy
-
- getVersion(Interval) - Method in class org.apache.druid.segment.realtime.plumber.IntervalStartVersioningPolicy
-
- getVersion() - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
- getVersion(Interval) - Method in interface org.apache.druid.segment.realtime.plumber.VersioningPolicy
-
- getVersion() - Method in class org.apache.druid.server.lookup.cache.LookupExtractorFactoryMapContainer
-
- getVersion() - Method in class org.apache.druid.server.StatusResource.ModuleVersion
-
- getVersion() - Method in class org.apache.druid.server.StatusResource.Status
-
- getVersioningPolicy() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getWaitingTasks() - Method in class org.apache.druid.client.indexing.HttpIndexingServiceClient
-
- getWaitingTasks() - Method in interface org.apache.druid.client.indexing.IndexingServiceClient
-
- getWatchedDataSources() - Method in class org.apache.druid.client.BrokerSegmentWatcherConfig
-
- getWatchedTiers() - Method in class org.apache.druid.client.BrokerSegmentWatcherConfig
-
- getWindowPeriod() - Method in class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- getWorker() - Method in class org.apache.druid.client.indexing.IndexingWorkerInfo
-
- getZkHosts() - Method in class org.apache.druid.curator.CuratorConfig
-
- getZkPwd() - Method in class org.apache.druid.curator.CuratorConfig
-
- getZkSessionTimeoutMs() - Method in class org.apache.druid.curator.CuratorConfig
-
- getZkUser() - Method in class org.apache.druid.curator.CuratorConfig
-
- giveMePeon(ImmutableDruidServer) - Method in class org.apache.druid.server.coordinator.LoadQueueTaskMaster
-
- global() - Static method in class org.apache.druid.guice.http.HttpClientModule
-
- global() - Static method in class org.apache.druid.guice.http.JettyHttpClientModule
-
- go(Request) - Method in class org.apache.druid.discovery.DruidLeaderClient
-
- go(Request, HttpResponseHandler<FullResponseHolder, FullResponseHolder>) - Method in class org.apache.druid.discovery.DruidLeaderClient
-
Executes a Request object aimed at the leader.
- go(DataSegmentChangeHandler, DataSegmentChangeCallback) - Method in interface org.apache.druid.server.coordination.DataSegmentChangeRequest
-
- go(DataSegmentChangeHandler, DataSegmentChangeCallback) - Method in class org.apache.druid.server.coordination.SegmentChangeRequestDrop
-
- go(DataSegmentChangeHandler, DataSegmentChangeCallback) - Method in class org.apache.druid.server.coordination.SegmentChangeRequestLoad
-
- go(DataSegmentChangeHandler, DataSegmentChangeCallback) - Method in class org.apache.druid.server.coordination.SegmentChangeRequestNoop
-
- goAsync(Request, HttpResponseHandler<Intermediate, Final>) - Method in class org.apache.druid.discovery.DruidLeaderClient
-
Executes the request object aimed at the leader and process the response with given handler
Note: this method doesn't do retrying on errors or handle leader changes occurred during communication
- GranularitySpec - Interface in org.apache.druid.segment.indexing.granularity
-
Tells the indexer how to group events based on timestamp.
- GROUPBY_QUERY_METRICS_FACTORY_PROPERTY - Static variable in class org.apache.druid.guice.QueryToolChestModule
-
- GuiceServletConfig - Class in org.apache.druid.server
-
- GuiceServletConfig(Injector) - Constructor for class org.apache.druid.server.GuiceServletConfig
-
- RandomBalancerStrategy - Class in org.apache.druid.server.coordinator
-
- RandomBalancerStrategy() - Constructor for class org.apache.druid.server.coordinator.RandomBalancerStrategy
-
- RandomBalancerStrategyFactory - Class in org.apache.druid.server.coordinator
-
- RandomBalancerStrategyFactory() - Constructor for class org.apache.druid.server.coordinator.RandomBalancerStrategyFactory
-
- RandomServerSelectorStrategy - Class in org.apache.druid.client.selector
-
- RandomServerSelectorStrategy() - Constructor for class org.apache.druid.client.selector.RandomServerSelectorStrategy
-
- RealtimeIOConfig - Class in org.apache.druid.segment.indexing
-
- RealtimeIOConfig(FirehoseFactory, PlumberSchool, FirehoseFactoryV2) - Constructor for class org.apache.druid.segment.indexing.RealtimeIOConfig
-
- RealtimeManager - Class in org.apache.druid.segment.realtime
-
- RealtimeManager(List<FireDepartment>, QueryRunnerFactoryConglomerate, DataSegmentServerAnnouncer) - Constructor for class org.apache.druid.segment.realtime.RealtimeManager
-
- RealtimeManagerConfig - Class in org.apache.druid.guice
-
- RealtimeManagerConfig() - Constructor for class org.apache.druid.guice.RealtimeManagerConfig
-
- RealtimeMetricsMonitor - Class in org.apache.druid.segment.realtime
-
RealtimeMetricsMonitor is only used by RealtimeIndexTask, this monitor only supports FireDepartmentMetrics.
- RealtimeMetricsMonitor(List<FireDepartment>) - Constructor for class org.apache.druid.segment.realtime.RealtimeMetricsMonitor
-
- RealtimeMetricsMonitor(List<FireDepartment>, Map<String, String[]>) - Constructor for class org.apache.druid.segment.realtime.RealtimeMetricsMonitor
-
- RealtimePlumber - Class in org.apache.druid.segment.realtime.plumber
-
- RealtimePlumber(DataSchema, RealtimeTuningConfig, FireDepartmentMetrics, ServiceEmitter, QueryRunnerFactoryConglomerate, DataSegmentAnnouncer, ExecutorService, DataSegmentPusher, SegmentPublisher, SegmentHandoffNotifier, IndexMerger, IndexIO, Cache, CacheConfig, CachePopulatorStats, ObjectMapper) - Constructor for class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- RealtimePlumberSchool - Class in org.apache.druid.segment.realtime.plumber
-
- RealtimePlumberSchool(ServiceEmitter, QueryRunnerFactoryConglomerate, DataSegmentPusher, DataSegmentAnnouncer, SegmentPublisher, SegmentHandoffNotifierFactory, ExecutorService, IndexMergerV9, IndexIO, Cache, CacheConfig, CachePopulatorStats, ObjectMapper) - Constructor for class org.apache.druid.segment.realtime.plumber.RealtimePlumberSchool
-
- RealtimeTuningConfig - Class in org.apache.druid.segment.indexing
-
- RealtimeTuningConfig(Integer, Long, Period, Period, File, VersioningPolicy, RejectionPolicyFactory, Integer, ShardSpec, IndexSpec, Boolean, int, int, Boolean, Long, Long, SegmentWriteOutMediumFactory, String) - Constructor for class org.apache.druid.segment.indexing.RealtimeTuningConfig
-
- RedirectFilter - Class in org.apache.druid.server.http
-
- RedirectFilter(RedirectInfo) - Constructor for class org.apache.druid.server.http.RedirectFilter
-
- RedirectInfo - Interface in org.apache.druid.server.http
-
- reduceLifetime() - Method in class org.apache.druid.server.coordinator.BalancerSegmentHolder
-
- reduceLifetimes(String) - Method in class org.apache.druid.server.coordinator.helper.DruidCoordinatorBalancer
-
- register(Binder, Annotation) - Static method in class org.apache.druid.curator.discovery.DiscoveryModule
-
Requests that the annotated DruidNode instance be injected and published as part of the lifecycle.
- register(Binder, Class<? extends Annotation>) - Static method in class org.apache.druid.curator.discovery.DiscoveryModule
-
Requests that the annotated DruidNode instance be injected and published as part of the lifecycle.
- register(String, ChatHandler) - Method in interface org.apache.druid.segment.realtime.firehose.ChatHandlerProvider
-
Registers a chat handler which provides an API for others to talk to objects in the indexing service.
- register(String, ChatHandler, boolean) - Method in interface org.apache.druid.segment.realtime.firehose.ChatHandlerProvider
-
Registers a chat handler which provides an API for others to talk to objects in the indexing service.
- register(String, ChatHandler) - Method in class org.apache.druid.segment.realtime.firehose.NoopChatHandlerProvider
-
- register(String, ChatHandler, boolean) - Method in class org.apache.druid.segment.realtime.firehose.NoopChatHandlerProvider
-
- register(String, ChatHandler) - Method in class org.apache.druid.segment.realtime.firehose.ServiceAnnouncingChatHandlerProvider
-
- register(String, ChatHandler, boolean) - Method in class org.apache.druid.segment.realtime.firehose.ServiceAnnouncingChatHandlerProvider
-
- register(String, EventReceiverFirehoseMetric) - Method in class org.apache.druid.server.metrics.EventReceiverFirehoseRegister
-
- register(Binder, Class<? extends Monitor>) - Static method in class org.apache.druid.server.metrics.MetricsModule
-
- registerDefault(Binder) - Static method in class org.apache.druid.curator.discovery.DiscoveryModule
-
Requests that the un-annotated DruidNode instance be injected and published as part of the lifecycle.
- RegisteredLookupExtractionFn - Class in org.apache.druid.query.lookup
-
- RegisteredLookupExtractionFn(LookupReferencesManager, String, boolean, String, Boolean, Boolean) - Constructor for class org.apache.druid.query.lookup.RegisteredLookupExtractionFn
-
- registerHandoff(SegmentsAndMetadata) - Method in class org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver
-
Register the segments in the given
SegmentsAndMetadata to be handed off and execute a background task which
waits until the hand off completes.
- registerKey(Binder, Key<DruidNode>) - Static method in class org.apache.druid.curator.discovery.DiscoveryModule
-
Requests that the keyed DruidNode instance be injected and published as part of the lifecycle.
- registerListener(DruidLeaderSelector.Listener) - Method in class org.apache.druid.curator.discovery.CuratorDruidLeaderSelector
-
- registerListener(DruidLeaderSelector.Listener) - Method in interface org.apache.druid.discovery.DruidLeaderSelector
-
Register the listener for watching leadership notifications.
- registerListener(DruidNodeDiscovery.Listener) - Method in interface org.apache.druid.discovery.DruidNodeDiscovery
-
- registerQuery(Query, ListenableFuture) - Method in class org.apache.druid.server.QueryManager
-
- registerReplicantCreation(String, String, String) - Method in class org.apache.druid.server.coordinator.ReplicationThrottler
-
- registerSegmentCallback(Executor, ServerView.SegmentCallback) - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- registerSegmentCallback(Executor, ServerView.SegmentCallback, Predicate<Pair<DruidServerMetadata, DataSegment>>) - Method in class org.apache.druid.client.BatchServerInventoryView
-
Deprecated.
- registerSegmentCallback(Executor, ServerView.SegmentCallback) - Method in class org.apache.druid.client.BrokerServerView
-
- registerSegmentCallback(Executor, ServerView.SegmentCallback, Predicate<Pair<DruidServerMetadata, DataSegment>>) - Method in interface org.apache.druid.client.FilteredServerInventoryView
-
- registerSegmentCallback(Executor, ServerView.SegmentCallback, Predicate<Pair<DruidServerMetadata, DataSegment>>) - Method in class org.apache.druid.client.HttpServerInventoryView
-
- registerSegmentCallback(Executor, ServerView.SegmentCallback) - Method in class org.apache.druid.client.HttpServerInventoryView
-
- registerSegmentCallback(Executor, ServerView.SegmentCallback) - Method in interface org.apache.druid.client.ServerView
-
- registerSegmentCallback(Executor, ServerView.SegmentCallback, Predicate<Pair<DruidServerMetadata, DataSegment>>) - Method in class org.apache.druid.client.SingleServerInventoryView
-
Deprecated.
- registerSegmentHandoffCallback(SegmentDescriptor, Executor, Runnable) - Method in class org.apache.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifier
-
- registerSegmentHandoffCallback(SegmentDescriptor, Executor, Runnable) - Method in interface org.apache.druid.segment.realtime.plumber.SegmentHandoffNotifier
-
register a handOffCallback to be called when segment handoff is complete.
- registerServerRemovedCallback(Executor, ServerView.ServerRemovedCallback) - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- registerServerRemovedCallback(Executor, ServerView.ServerRemovedCallback) - Method in class org.apache.druid.client.BrokerServerView
-
- registerServerRemovedCallback(Executor, ServerView.ServerRemovedCallback) - Method in interface org.apache.druid.client.FilteredServerInventoryView
-
- registerServerRemovedCallback(Executor, ServerView.ServerRemovedCallback) - Method in class org.apache.druid.client.HttpServerInventoryView
-
- registerServerRemovedCallback(Executor, ServerView.ServerRemovedCallback) - Method in interface org.apache.druid.client.ServerView
-
- registerTimelineCallback(Executor, TimelineServerView.TimelineCallback) - Method in class org.apache.druid.client.BrokerServerView
-
- registerTimelineCallback(Executor, TimelineServerView.TimelineCallback) - Method in interface org.apache.druid.client.TimelineServerView
-
Register a callback for state changes in the timeline managed by this TimelineServerView.
- RejectionPolicy - Interface in org.apache.druid.segment.realtime.plumber
-
- RejectionPolicyFactory - Interface in org.apache.druid.segment.realtime.plumber
-
- remainingCapacity() - Method in class org.apache.druid.client.cache.BytesBoundedLinkedQueue
-
- remainingSegmentSizeBytes() - Method in interface org.apache.druid.server.coordinator.helper.CompactionSegmentIterator
-
Return a map of (dataSource, total size of remaining segments) for all dataSources.
- remainingSegmentSizeBytes() - Method in class org.apache.druid.server.coordinator.helper.NewestSegmentFirstIterator
-
- remainingSegmentSizeBytesForCompaction(String) - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- remainingSegmentSizeForCompaction(String) - Method in class org.apache.druid.server.http.CoordinatorResource
-
- RemoteChatHandler - Annotation Type in org.apache.druid.guice.annotations
-
- remove() - Method in class org.apache.druid.client.JsonParserIterator
-
- remove(String) - Method in class org.apache.druid.query.lookup.LookupReferencesManager
-
- removeDataSegment(String) - Method in class org.apache.druid.client.DruidServer
-
- removeDatasource(String) - Method in interface org.apache.druid.metadata.MetadataSegmentManager
-
- removeDatasource(String) - Method in class org.apache.druid.metadata.SQLMetadataSegmentManager
-
- removeInnerInventory(DruidServer, String) - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- removeInnerInventory(DruidServer, String) - Method in class org.apache.druid.client.BatchServerInventoryView
-
Deprecated.
- removeInnerInventory(DruidServer, String) - Method in class org.apache.druid.client.SingleServerInventoryView
-
Deprecated.
- removeInventory(ContainerClass, String) - Method in interface org.apache.druid.curator.inventory.CuratorInventoryManagerStrategy
-
- removeLock(long) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- removeMagicResponseContextFields(Map<String, Object>) - Static method in class org.apache.druid.client.DirectDruidClient
-
- removePartition(String) - Method in class org.apache.druid.client.DruidDataSource
-
- removeSegment(String, String) - Method in interface org.apache.druid.metadata.MetadataSegmentManager
-
- removeSegment(String, String) - Method in class org.apache.druid.metadata.SQLMetadataSegmentManager
-
- removeSegment(DataSegment, DataSegmentChangeCallback) - Method in interface org.apache.druid.server.coordination.DataSegmentChangeHandler
-
- removeSegment(DataSegment, DataSegmentChangeCallback) - Method in class org.apache.druid.server.coordination.SegmentLoadDropHandler
-
- removeSegment(String, DataSegment) - Method in class org.apache.druid.server.coordinator.cost.ClusterCostCache.Builder
-
- removeSegment(DataSegment) - Method in class org.apache.druid.server.coordinator.cost.SegmentsCostCache.Builder
-
- removeSegment(DataSegment) - Method in class org.apache.druid.server.coordinator.cost.ServerCostCache.Builder
-
- removeSegment(DataSegment) - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- removeServer(DruidServerMetadata) - Method in class org.apache.druid.client.SegmentLoadInfo
-
- removeServer(QueryableDruidServer) - Method in class org.apache.druid.client.selector.ServerSelector
-
- removeServer(String) - Method in class org.apache.druid.server.coordinator.cost.ClusterCostCache.Builder
-
- removeSingleInventory(DruidServer, String) - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- RendezvousHashAvaticaConnectionBalancer - Class in org.apache.druid.server.router
-
- RendezvousHashAvaticaConnectionBalancer() - Constructor for class org.apache.druid.server.router.RendezvousHashAvaticaConnectionBalancer
-
- RendezvousHasher - Class in org.apache.druid.server.router
-
Distributes objects across a set of node keys using rendezvous hashing
See https://en.wikipedia.org/wiki/Rendezvous_hashing
- RendezvousHasher() - Constructor for class org.apache.druid.server.router.RendezvousHasher
-
- replaceLock(String, long, LockType) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- replaces(LookupExtractorFactory) - Method in class org.apache.druid.query.lookup.MapLookupExtractorFactory
-
For MapLookups, the replaces consideration is very easy, it simply considers if the other is the same as this one
- replaces(LookupExtractorFactoryMapContainer) - Method in class org.apache.druid.server.lookup.cache.LookupExtractorFactoryMapContainer
-
- ReplicationThrottler - Class in org.apache.druid.server.coordinator
-
The ReplicationThrottler is used to throttle the number of replicants that are created.
- ReplicationThrottler(int, int) - Constructor for class org.apache.druid.server.coordinator.ReplicationThrottler
-
- reportMessageMaxTimestamp(long) - Method in class org.apache.druid.segment.realtime.FireDepartmentMetrics
-
- REQUEST_ENTITY_TYPE_REF - Static variable in class org.apache.druid.server.coordinator.HttpLoadQueuePeon
-
- RequestLogger - Interface in org.apache.druid.server.log
-
- RequestLoggerProvider - Interface in org.apache.druid.server.log
-
A Marker interface for things that can provide a RequestLogger.
- RequestLogLine - Class in org.apache.druid.server
-
- RequestLogLine(DateTime, String, Query, QueryStats) - Constructor for class org.apache.druid.server.RequestLogLine
-
- reset(DataSourceMetadata) - Method in interface org.apache.druid.indexing.overlord.supervisor.Supervisor
-
- reset(Map<String, DataSourceCompactionConfig>, Map<String, VersionedIntervalTimeline<String, DataSegment>>) - Method in interface org.apache.druid.server.coordinator.helper.CompactionSegmentSearchPolicy
-
Reset the current states of this policy.
- reset(Map<String, DataSourceCompactionConfig>, Map<String, VersionedIntervalTimeline<String, DataSegment>>) - Method in class org.apache.druid.server.coordinator.helper.NewestSegmentFirstPolicy
-
- resetDataSourceMetadata(String, DataSourceMetadata) - Method in interface org.apache.druid.indexing.overlord.IndexerMetadataStorageCoordinator
-
Resets dataSourceMetadata entry for 'dataSource' to the one supplied.
- resetDataSourceMetadata(String, DataSourceMetadata) - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
- Resource - Class in org.apache.druid.server.security
-
- Resource(String, ResourceType) - Constructor for class org.apache.druid.server.security.Resource
-
- ResourceAction - Class in org.apache.druid.server.security
-
- ResourceAction(Resource, Action) - Constructor for class org.apache.druid.server.security.ResourceAction
-
- ResourceType - Enum in org.apache.druid.server.security
-
- RESPONSE_CTX_HEADER_LEN_LIMIT - Static variable in class org.apache.druid.server.QueryResource
-
- RESPONSE_ENTITY_TYPE_REF - Static variable in class org.apache.druid.server.coordinator.HttpLoadQueuePeon
-
- ResponseHeaderFilterHolder - Class in org.apache.druid.server.initialization.jetty
-
- ResponseHeaderFilterHolder(String, Map<String, String>) - Constructor for class org.apache.druid.server.initialization.jetty.ResponseHeaderFilterHolder
-
- restore(DataSegment) - Method in class org.apache.druid.segment.loading.OmniDataSegmentArchiver
-
- ResultLevelCacheUtil - Class in org.apache.druid.client
-
- ResultLevelCacheUtil() - Constructor for class org.apache.druid.client.ResultLevelCacheUtil
-
- ResultLevelCachingQueryRunner<T> - Class in org.apache.druid.query
-
- ResultLevelCachingQueryRunner(QueryRunner, QueryToolChest, Query<T>, ObjectMapper, Cache, CacheConfig) - Constructor for class org.apache.druid.query.ResultLevelCachingQueryRunner
-
- ResultLevelCachingQueryRunner.ResultLevelCachePopulator - Class in org.apache.druid.query
-
- retryTransaction(TransactionCallback<T>, int, int) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- RetryTransactionException - Exception in org.apache.druid.metadata
-
Exception thrown by SQL connector code when it wants a transaction to be retried.
- RetryTransactionException(String) - Constructor for exception org.apache.druid.metadata.RetryTransactionException
-
- retryWithHandle(HandleCallback<T>, Predicate<Throwable>) - Method in class org.apache.druid.metadata.SQLFirehoseDatabaseConnector
-
- retryWithHandle(HandleCallback<T>, Predicate<Throwable>) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- retryWithHandle(HandleCallback<T>) - Method in class org.apache.druid.metadata.SQLMetadataConnector
-
- rewriteTarget(HttpServletRequest) - Method in class org.apache.druid.server.AsyncManagementForwardingServlet
-
- rewriteTarget(HttpServletRequest) - Method in class org.apache.druid.server.AsyncQueryForwardingServlet
-
- rewriteTarget(HttpServletRequest) - Method in class org.apache.druid.server.http.OverlordProxyServlet
-
- rewriteURI(HttpServletRequest, String, String) - Method in class org.apache.druid.server.AsyncQueryForwardingServlet
-
- Router - Annotation Type in org.apache.druid.server.router
-
- RouterProcessingModule - Class in org.apache.druid.guice
-
This module is used to fulfill dependency injection of query processing and caching resources: buffer pools and
thread pools on Router Druid node type.
- RouterProcessingModule() - Constructor for class org.apache.druid.guice.RouterProcessingModule
-
- RouterResource - Class in org.apache.druid.server.http
-
- RouterResource(TieredBrokerHostSelector) - Constructor for class org.apache.druid.server.http.RouterResource
-
- rowOutput() - Method in class org.apache.druid.segment.realtime.FireDepartmentMetrics
-
- Rule - Interface in org.apache.druid.server.coordinator.rules
-
- RuleMap - Class in org.apache.druid.server.coordinator.rules
-
- RuleMap(Map<String, List<Rule>>, List<Rule>) - Constructor for class org.apache.druid.server.coordinator.rules.RuleMap
-
- Rules - Class in org.apache.druid.server.coordinator.rules
-
- RulesResource - Class in org.apache.druid.server.http
-
- RulesResource(MetadataRuleManager, AuditManager) - Constructor for class org.apache.druid.server.http.RulesResource
-
- RulesResourceFilter - Class in org.apache.druid.server.http.security
-
Use this ResourceFilter when the datasource information is present after "rules" segment in the request Path
Here are some example paths where this filter is used -
- druid/coordinator/v1/rules/
- RulesResourceFilter(AuthorizerMapper) - Constructor for class org.apache.druid.server.http.security.RulesResourceFilter
-
- run(QueryPlus<T>, Map<String, Object>) - Method in class org.apache.druid.client.CachingQueryRunner
-
- run(QueryPlus<T>, Map<String, Object>) - Method in class org.apache.druid.client.DirectDruidClient
-
- run(QueryPlus, Map) - Method in class org.apache.druid.query.ResultLevelCachingQueryRunner
-
- run() - Method in class org.apache.druid.server.coordinator.DruidCoordinator.CoordinatorRunnable
-
- run(DruidCoordinatorRuntimeParams) - Method in class org.apache.druid.server.coordinator.DruidCoordinatorCleanupPendingSegments
-
- run(DruidCoordinatorRuntimeParams) - Method in class org.apache.druid.server.coordinator.helper.DruidCoordinatorBalancer
-
- run(DruidCoordinatorRuntimeParams) - Method in class org.apache.druid.server.coordinator.helper.DruidCoordinatorCleanupOvershadowed
-
- run(DruidCoordinatorRuntimeParams) - Method in class org.apache.druid.server.coordinator.helper.DruidCoordinatorCleanupUnneeded
-
- run(DruidCoordinatorRuntimeParams) - Method in interface org.apache.druid.server.coordinator.helper.DruidCoordinatorHelper
-
Implementations of this method run various activities performed by the coordinator.
- run(DruidCoordinatorRuntimeParams) - Method in class org.apache.druid.server.coordinator.helper.DruidCoordinatorLogger
-
- run(DruidCoordinatorRuntimeParams) - Method in class org.apache.druid.server.coordinator.helper.DruidCoordinatorRuleRunner
-
- run(DruidCoordinatorRuntimeParams) - Method in class org.apache.druid.server.coordinator.helper.DruidCoordinatorSegmentCompactor
-
- run(DruidCoordinatorRuntimeParams) - Method in class org.apache.druid.server.coordinator.helper.DruidCoordinatorSegmentInfoLoader
-
- run(DruidCoordinatorRuntimeParams) - Method in class org.apache.druid.server.coordinator.helper.DruidCoordinatorSegmentKiller
-
- run(DruidCoordinatorRuntimeParams) - Method in class org.apache.druid.server.coordinator.helper.DruidCoordinatorSegmentMerger
-
- run(DruidCoordinator, DruidCoordinatorRuntimeParams, DataSegment) - Method in class org.apache.druid.server.coordinator.rules.BroadcastDistributionRule
-
- run(DruidCoordinator, DruidCoordinatorRuntimeParams, DataSegment) - Method in class org.apache.druid.server.coordinator.rules.DropRule
-
- run(DruidCoordinator, DruidCoordinatorRuntimeParams, DataSegment) - Method in class org.apache.druid.server.coordinator.rules.LoadRule
-
- run(DruidCoordinator, DruidCoordinatorRuntimeParams, DataSegment) - Method in interface org.apache.druid.server.coordinator.rules.Rule
-
- run(QueryPlus<T>, Map<String, Object>) - Method in class org.apache.druid.server.SetAndVerifyContextQueryRunner
-
- runSegmentCallbacks(Function<ServerView.SegmentCallback, ServerView.CallbackAction>) - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- runSimple(Query<T>, AuthenticationResult, String) - Method in class org.apache.druid.server.QueryLifecycle
-
For callers where simplicity is desired over flexibility.
- runTask(Object) - Method in class org.apache.druid.client.indexing.HttpIndexingServiceClient
-
- runTask(Object) - Method in interface org.apache.druid.client.indexing.IndexingServiceClient
-
- SCHEME - Static variable in class org.apache.druid.guice.LocalDataStorageDruidModule
-
- SEARCH_QUERY_METRICS_FACTORY_PROPERTY - Static variable in class org.apache.druid.guice.QueryToolChestModule
-
- SecuritySanityCheckFilter - Class in org.apache.druid.server.security
-
- SecuritySanityCheckFilter(ObjectMapper) - Constructor for class org.apache.druid.server.security.SecuritySanityCheckFilter
-
- SEGMENT_COMPARATOR - Static variable in class org.apache.druid.server.coordinator.DruidCoordinator
-
- SEGMENT_LIST_RESP_TYPE_REF - Static variable in class org.apache.druid.client.HttpServerInventoryView
-
- segmentAdded(DruidServerMetadata, DataSegment) - Method in class org.apache.druid.client.ServerView.BaseSegmentCallback
-
- segmentAdded(DruidServerMetadata, DataSegment) - Method in interface org.apache.druid.client.ServerView.SegmentCallback
-
Called when a segment is added to a server.
- segmentAdded(DruidServerMetadata, DataSegment) - Method in interface org.apache.druid.client.TimelineServerView.TimelineCallback
-
Called when a segment on a particular server has been added to the timeline.
- SegmentAllocator - Interface in org.apache.druid.segment.realtime.appenderator
-
- segmentCallbackRemoved(ServerView.SegmentCallback) - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- segmentCallbackRemoved(ServerView.SegmentCallback) - Method in class org.apache.druid.client.BatchServerInventoryView
-
Deprecated.
- segmentCallbackRemoved(ServerView.SegmentCallback) - Method in class org.apache.druid.client.SingleServerInventoryView
-
Deprecated.
- SegmentChangeRequestDrop - Class in org.apache.druid.server.coordination
-
- SegmentChangeRequestDrop(DataSegment) - Constructor for class org.apache.druid.server.coordination.SegmentChangeRequestDrop
-
- SegmentChangeRequestLoad - Class in org.apache.druid.server.coordination
-
- SegmentChangeRequestLoad(DataSegment) - Constructor for class org.apache.druid.server.coordination.SegmentChangeRequestLoad
-
- SegmentChangeRequestNoop - Class in org.apache.druid.server.coordination
-
- SegmentChangeRequestNoop() - Constructor for class org.apache.druid.server.coordination.SegmentChangeRequestNoop
-
- SegmentHandoffNotifier - Interface in org.apache.druid.segment.realtime.plumber
-
- SegmentHandoffNotifierFactory - Interface in org.apache.druid.segment.realtime.plumber
-
- SegmentIdentifier - Class in org.apache.druid.segment.realtime.appenderator
-
- SegmentIdentifier(String, Interval, String, ShardSpec) - Constructor for class org.apache.druid.segment.realtime.appenderator.SegmentIdentifier
-
- SegmentListerResource - Class in org.apache.druid.server.http
-
Endpoints exposed here are to be used only for druid internal management of segments by Coordinators, Brokers etc.
- SegmentListerResource(ObjectMapper, ObjectMapper, BatchDataSegmentAnnouncer, SegmentLoadDropHandler) - Constructor for class org.apache.druid.server.http.SegmentListerResource
-
- SegmentLoadDropHandler - Class in org.apache.druid.server.coordination
-
- SegmentLoadDropHandler(ObjectMapper, SegmentLoaderConfig, DataSegmentAnnouncer, DataSegmentServerAnnouncer, SegmentManager) - Constructor for class org.apache.druid.server.coordination.SegmentLoadDropHandler
-
- SegmentLoadDropHandler.DataSegmentChangeRequestAndStatus - Class in org.apache.druid.server.coordination
-
- SegmentLoadDropHandler.Status - Class in org.apache.druid.server.coordination
-
- SegmentLoadDropHandler.Status.STATE - Enum in org.apache.druid.server.coordination
-
- SegmentLoader - Interface in org.apache.druid.segment.loading
-
- SegmentLoaderConfig - Class in org.apache.druid.segment.loading
-
- SegmentLoaderConfig() - Constructor for class org.apache.druid.segment.loading.SegmentLoaderConfig
-
- SegmentLoaderLocalCacheManager - Class in org.apache.druid.segment.loading
-
- SegmentLoaderLocalCacheManager(IndexIO, SegmentLoaderConfig, ObjectMapper) - Constructor for class org.apache.druid.segment.loading.SegmentLoaderLocalCacheManager
-
- SegmentLoadInfo - Class in org.apache.druid.client
-
- SegmentLoadInfo(DataSegment) - Constructor for class org.apache.druid.client.SegmentLoadInfo
-
- SegmentManager - Class in org.apache.druid.server
-
This class is responsible for managing data sources and their states like timeline, total segment size, and number of
segments.
- SegmentManager(SegmentLoader) - Constructor for class org.apache.druid.server.SegmentManager
-
- SegmentManager.DataSourceState - Class in org.apache.druid.server
-
Represent the state of a data source including the timeline, total segment size, and number of segments.
- SegmentNotWritableException - Exception in org.apache.druid.segment.realtime.appenderator
-
- SegmentNotWritableException(String, Object...) - Constructor for exception org.apache.druid.segment.realtime.appenderator.SegmentNotWritableException
-
- SegmentPublisher - Interface in org.apache.druid.segment.realtime
-
- SegmentPublisherProvider - Interface in org.apache.druid.metadata
-
- SegmentPublishResult - Class in org.apache.druid.indexing.overlord
-
Result of an operation that attempts to publish segments.
- SegmentPublishResult(Set<DataSegment>, boolean) - Constructor for class org.apache.druid.indexing.overlord.SegmentPublishResult
-
- segmentRemoved(DruidServerMetadata, DataSegment) - Method in class org.apache.druid.client.ServerView.BaseSegmentCallback
-
- segmentRemoved(DruidServerMetadata, DataSegment) - Method in interface org.apache.druid.client.ServerView.SegmentCallback
-
Called when a segment is removed from a server.
- segmentRemoved(DataSegment) - Method in interface org.apache.druid.client.TimelineServerView.TimelineCallback
-
Called when a segment has been removed from all servers and is no longer present in the timeline.
- SegmentReplicantLookup - Class in org.apache.druid.server.coordinator
-
A lookup for the number of replicants of a given segment for a certain tier.
- segmentReplicatable() - Method in class org.apache.druid.client.DruidServer
-
- segmentReplicatable() - Method in class org.apache.druid.server.coordination.DruidServerMetadata
-
- segments - Variable in class org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver
-
- SegmentsAndMetadata - Class in org.apache.druid.segment.realtime.appenderator
-
- SegmentsAndMetadata(List<DataSegment>, Object) - Constructor for class org.apache.druid.segment.realtime.appenderator.SegmentsAndMetadata
-
- SegmentsCostCache - Class in org.apache.druid.server.coordinator.cost
-
- SegmentsCostCache.Builder - Class in org.apache.druid.server.coordinator.cost
-
- SegmentToDrop - Class in org.apache.druid.server.http
-
- SegmentToDrop(String, String) - Constructor for class org.apache.druid.server.http.SegmentToDrop
-
- SegmentToMove - Class in org.apache.druid.server.http
-
- SegmentToMove(String, String, String) - Constructor for class org.apache.druid.server.http.SegmentToMove
-
- segmentViewInitialized() - Method in class org.apache.druid.client.ServerView.BaseSegmentCallback
-
- segmentViewInitialized() - Method in interface org.apache.druid.client.ServerView.SegmentCallback
-
- SegmentWithState - Class in org.apache.druid.segment.realtime.appenderator
-
- SegmentWithState(SegmentIdentifier, SegmentWithState.SegmentState, DataSegment) - Constructor for class org.apache.druid.segment.realtime.appenderator.SegmentWithState
-
- SegmentWithState.SegmentState - Enum in org.apache.druid.segment.realtime.appenderator
-
- select(Query<T>) - Method in class org.apache.druid.server.router.TieredBrokerHostSelector
-
- SELECT_QUERY_METRICS_FACTORY_PROPERTY - Static variable in class org.apache.druid.guice.QueryToolChestModule
-
- sendJsonError(HttpServletResponse, int, String, OutputStream) - Static method in class org.apache.druid.server.security.PreResponseAuthorizationCheckFilter
-
- sendJsonError(HttpServletResponse, int, String, OutputStream) - Static method in class org.apache.druid.server.security.SecuritySanityCheckFilter
-
- sendProxyRequest(HttpServletRequest, HttpServletResponse, Request) - Method in class org.apache.druid.server.AsyncManagementForwardingServlet
-
- sendProxyRequest(HttpServletRequest, HttpServletResponse, Request) - Method in class org.apache.druid.server.AsyncQueryForwardingServlet
-
- sendProxyRequest(HttpServletRequest, HttpServletResponse, Request) - Method in class org.apache.druid.server.http.OverlordProxyServlet
-
- serializeDataTimeAsLong(ObjectMapper) - Method in class org.apache.druid.server.QueryResource
-
- serializeDateTimeAsLongJsonMapper - Variable in class org.apache.druid.server.QueryResource
-
- serializeDateTimeAsLongSmileMapper - Variable in class org.apache.druid.server.QueryResource
-
- Server - Interface in org.apache.druid.client.selector
-
- ServerConfig - Class in org.apache.druid.server.initialization
-
- ServerConfig() - Constructor for class org.apache.druid.server.initialization.ServerConfig
-
- ServerCostCache - Class in org.apache.druid.server.coordinator.cost
-
- ServerCostCache.Builder - Class in org.apache.druid.server.coordinator.cost
-
- ServerDiscoveryFactory - Class in org.apache.druid.curator.discovery
-
Deprecated.
- ServerDiscoveryFactory(ServiceDiscovery<Void>) - Constructor for class org.apache.druid.curator.discovery.ServerDiscoveryFactory
-
Deprecated.
- ServerDiscoverySelector - Class in org.apache.druid.curator.discovery
-
Deprecated.
- ServerDiscoverySelector(ServiceProvider, String) - Constructor for class org.apache.druid.curator.discovery.ServerDiscoverySelector
-
Deprecated.
- ServerHolder - Class in org.apache.druid.server.coordinator
-
- ServerHolder(ImmutableDruidServer, LoadQueuePeon) - Constructor for class org.apache.druid.server.coordinator.ServerHolder
-
- ServerInventoryView - Interface in org.apache.druid.client
-
Marker interface for making batch/single/http server inventory view configurable.
- ServerInventoryViewProvider - Interface in org.apache.druid.client
-
- ServerManager - Class in org.apache.druid.server.coordination
-
- ServerManager(QueryRunnerFactoryConglomerate, ServiceEmitter, ExecutorService, CachePopulator, ObjectMapper, Cache, CacheConfig, SegmentManager, ServerConfig) - Constructor for class org.apache.druid.server.coordination.ServerManager
-
- ServerModule - Class in org.apache.druid.guice
-
- ServerModule() - Constructor for class org.apache.druid.guice.ServerModule
-
- serverRemoved(DruidServer) - Method in interface org.apache.druid.client.ServerView.ServerRemovedCallback
-
Called when a server is removed.
- ServerSelector - Class in org.apache.druid.client.selector
-
- ServerSelector(DataSegment, TierSelectorStrategy) - Constructor for class org.apache.druid.client.selector.ServerSelector
-
- ServerSelectorStrategy - Interface in org.apache.druid.client.selector
-
- ServersResource - Class in org.apache.druid.server.http
-
- ServersResource(InventoryView) - Constructor for class org.apache.druid.server.http.ServersResource
-
- ServerTimeRejectionPolicyFactory - Class in org.apache.druid.segment.realtime.plumber
-
- ServerTimeRejectionPolicyFactory() - Constructor for class org.apache.druid.segment.realtime.plumber.ServerTimeRejectionPolicyFactory
-
- ServerType - Enum in org.apache.druid.server.coordination
-
This enum represents types of druid services that hold segments.
- ServerView - Interface in org.apache.druid.client
-
- ServerView.BaseSegmentCallback - Class in org.apache.druid.client
-
- ServerView.CallbackAction - Enum in org.apache.druid.client
-
- ServerView.SegmentCallback - Interface in org.apache.druid.client
-
- ServerView.ServerRemovedCallback - Interface in org.apache.druid.client
-
- ServerViewModule - Class in org.apache.druid.guice
-
- ServerViewModule() - Constructor for class org.apache.druid.guice.ServerViewModule
-
- ServerViewUtil - Class in org.apache.druid.client
-
- ServerViewUtil() - Constructor for class org.apache.druid.client.ServerViewUtil
-
- service(HttpServletRequest, HttpServletResponse) - Method in class org.apache.druid.server.AsyncManagementForwardingServlet
-
- service(HttpServletRequest, HttpServletResponse) - Method in class org.apache.druid.server.AsyncQueryForwardingServlet
-
- serviceAnnouncementDELETE(String) - Method in class org.apache.druid.server.listener.resource.ListenerResource
-
- serviceAnnouncementGET(String) - Method in class org.apache.druid.server.listener.resource.ListenerResource
-
- serviceAnnouncementHandleUpdates(InputStream, HttpServletRequest) - Method in class org.apache.druid.server.listener.resource.ListenerResource
-
- serviceAnnouncementPOST(String, InputStream, HttpServletRequest) - Method in class org.apache.druid.server.listener.resource.ListenerResource
-
- serviceAnnouncementPOSTAll(InputStream, HttpServletRequest) - Method in class org.apache.druid.server.listener.resource.ListenerResource
-
- ServiceAnnouncer - Interface in org.apache.druid.curator.discovery
-
Deprecated.
- ServiceAnnouncingChatHandlerProvider - Class in org.apache.druid.segment.realtime.firehose
-
Provides a way for the outside world to talk to objects in the indexing service.
- ServiceAnnouncingChatHandlerProvider(DruidNode, ServiceAnnouncer, ServerConfig) - Constructor for class org.apache.druid.segment.realtime.firehose.ServiceAnnouncingChatHandlerProvider
-
- ServletFilterHolder - Interface in org.apache.druid.server.initialization.jetty
-
A ServletFilterHolder is a class that holds all of the information required to attach a Filter to a Servlet.
- setAllHostTimeout(Duration) - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- SetAndVerifyContextQueryRunner<T> - Class in org.apache.druid.server
-
Use this QueryRunner to set and verify Query contexts.
- SetAndVerifyContextQueryRunner(ServerConfig, QueryRunner<T>) - Constructor for class org.apache.druid.server.SetAndVerifyContextQueryRunner
-
- setAuthorizerMapper(AuthorizerMapper) - Method in class org.apache.druid.server.http.security.AbstractResourceFilter
-
- setCache(Cache) - Method in class org.apache.druid.client.cache.CacheMonitor
-
- setCertAlias(String) - Method in class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- setCompactionTaskLimit(Double, Integer, String, String, HttpServletRequest) - Method in class org.apache.druid.server.http.CoordinatorCompactionConfigsResource
-
- setContextMDC - Variable in class org.apache.druid.server.log.LoggingRequestLoggerProvider
-
- setDatasourceRules(String, List<Rule>, String, String, HttpServletRequest) - Method in class org.apache.druid.server.http.RulesResource
-
- setDimension(String) - Method in class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- setDynamicConfigs(CoordinatorDynamicConfig.Builder, String, String, HttpServletRequest) - Method in class org.apache.druid.server.http.CoordinatorDynamicConfigsResource
-
- setEnableAcl(Boolean) - Method in class org.apache.druid.curator.CuratorConfig
-
- setEnableCompression(Boolean) - Method in class org.apache.druid.curator.CuratorConfig
-
- setEnd(String) - Method in class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- setFreeSpacePercent(Double) - Method in class org.apache.druid.segment.loading.StorageLocationConfig
-
- setHostTimeout(Duration) - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- setKeyManagerFactoryPasswordProvider(PasswordProvider) - Method in class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- setKeyStoreAlgorithm(String) - Method in class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- setKeyStorePasswordProvider(PasswordProvider) - Method in class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- setKeyStorePath(String) - Method in class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- setKeyStoreType(String) - Method in class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- setMaxSize(long) - Method in class org.apache.druid.segment.loading.StorageLocationConfig
-
- setMDC - Variable in class org.apache.druid.server.log.LoggingRequestLoggerProvider
-
- setPartitionNum(int) - Method in class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- setPath(File) - Method in class org.apache.druid.segment.loading.StorageLocationConfig
-
- setPeriod(long) - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- setProtocol(String) - Method in class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- setReq(HttpServletRequest) - Method in class org.apache.druid.server.http.security.AbstractResourceFilter
-
- setSinkCount(long) - Method in class org.apache.druid.segment.realtime.FireDepartmentMetrics
-
- setStart(String) - Method in class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- setState(SegmentWithState.SegmentState) - Method in class org.apache.druid.segment.realtime.appenderator.SegmentWithState
-
- setStatus(String, boolean, StatusType) - Method in class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- setThreadPoolSize(int) - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManagerConfig
-
- setTrustStoreAlgorithm(String) - Method in class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- setTrustStorePasswordProvider(PasswordProvider) - Method in class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- setTrustStorePath(String) - Method in class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- setTrustStoreType(String) - Method in class org.apache.druid.server.security.TLSUtils.ClientSSLContextBuilder
-
- setZkHosts(String) - Method in class org.apache.druid.curator.CuratorConfig
-
- setZkSessionTimeoutMs(Integer) - Method in class org.apache.druid.curator.CuratorConfig
-
- shouldRetryPredicate() - Method in class org.apache.druid.segment.loading.LocalDataSegmentPuller
-
- shutdown(String, HttpServletRequest) - Method in class org.apache.druid.segment.realtime.firehose.EventReceiverFirehoseFactory.EventReceiverFirehose
-
- shutdownExecutors() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumber
-
- shutdownExecutors() - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- SingleDimensionShardSpec - Class in org.apache.druid.timeline.partition
-
Class uses getters/setters to work around http://jira.codehaus.org/browse/MSHADE-92
Adjust to JsonCreator and final fields when resolved.
- SingleDimensionShardSpec() - Constructor for class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- SingleDimensionShardSpec(String, String, String, int) - Constructor for class org.apache.druid.timeline.partition.SingleDimensionShardSpec
-
- SingleServerInventoryProvider - Class in org.apache.druid.client
-
- SingleServerInventoryProvider() - Constructor for class org.apache.druid.client.SingleServerInventoryProvider
-
- SingleServerInventoryView - Class in org.apache.druid.client
-
Deprecated.
- SingleServerInventoryView(ZkPathsConfig, CuratorFramework, ObjectMapper, Predicate<Pair<DruidServerMetadata, DataSegment>>) - Constructor for class org.apache.druid.client.SingleServerInventoryView
-
Deprecated.
- Sink - Class in org.apache.druid.segment.realtime.plumber
-
- Sink(Interval, DataSchema, ShardSpec, String, int, long, boolean, String) - Constructor for class org.apache.druid.segment.realtime.plumber.Sink
-
- Sink(Interval, DataSchema, ShardSpec, String, int, long, boolean, String, List<FireHydrant>) - Constructor for class org.apache.druid.segment.realtime.plumber.Sink
-
- sinkCount() - Method in class org.apache.druid.segment.realtime.FireDepartmentMetrics
-
- SinkQuerySegmentWalker - Class in org.apache.druid.segment.realtime.appenderator
-
- SinkQuerySegmentWalker(String, VersionedIntervalTimeline<String, Sink>, ObjectMapper, ServiceEmitter, QueryRunnerFactoryConglomerate, ExecutorService, Cache, CacheConfig, CachePopulatorStats) - Constructor for class org.apache.druid.segment.realtime.appenderator.SinkQuerySegmentWalker
-
- size() - Method in class org.apache.druid.client.cache.BytesBoundedLinkedQueue
-
- smileMapper - Variable in class org.apache.druid.server.http.SegmentListerResource
-
- smileMapper - Variable in class org.apache.druid.server.QueryResource
-
- snapshot() - Method in class org.apache.druid.client.cache.CachePopulatorStats
-
- snapshot() - Method in class org.apache.druid.segment.realtime.FireDepartmentMetrics
-
- SQLAuditManager - Class in org.apache.druid.server.audit
-
- SQLAuditManager(SQLMetadataConnector, Supplier<MetadataStorageTablesConfig>, ServiceEmitter, ObjectMapper, SQLAuditManagerConfig) - Constructor for class org.apache.druid.server.audit.SQLAuditManager
-
- SQLAuditManagerConfig - Class in org.apache.druid.server.audit
-
- SQLAuditManagerConfig() - Constructor for class org.apache.druid.server.audit.SQLAuditManagerConfig
-
- SQLAuditManagerProvider - Class in org.apache.druid.server.audit
-
- SQLAuditManagerProvider(Supplier<MetadataStorageTablesConfig>, SQLMetadataConnector, Lifecycle, ServiceEmitter, ObjectMapper, SQLAuditManagerConfig) - Constructor for class org.apache.druid.server.audit.SQLAuditManagerProvider
-
- SQLFirehoseDatabaseConnector - Class in org.apache.druid.metadata
-
- SQLFirehoseDatabaseConnector() - Constructor for class org.apache.druid.metadata.SQLFirehoseDatabaseConnector
-
- SqlFirehoseFactory - Class in org.apache.druid.segment.realtime.firehose
-
- SqlFirehoseFactory(List<String>, Long, Long, Long, Long, boolean, SQLFirehoseDatabaseConnector, ObjectMapper) - Constructor for class org.apache.druid.segment.realtime.firehose.SqlFirehoseFactory
-
- SQLMetadataConnector - Class in org.apache.druid.metadata
-
- SQLMetadataConnector(Supplier<MetadataStorageConnectorConfig>, Supplier<MetadataStorageTablesConfig>) - Constructor for class org.apache.druid.metadata.SQLMetadataConnector
-
- SQLMetadataRuleManager - Class in org.apache.druid.metadata
-
- SQLMetadataRuleManager(ObjectMapper, MetadataRuleManagerConfig, MetadataStorageTablesConfig, SQLMetadataConnector, AuditManager) - Constructor for class org.apache.druid.metadata.SQLMetadataRuleManager
-
- SQLMetadataRuleManagerProvider - Class in org.apache.druid.metadata
-
- SQLMetadataRuleManagerProvider(ObjectMapper, MetadataRuleManagerConfig, MetadataStorageTablesConfig, SQLMetadataConnector, Lifecycle, SQLAuditManager) - Constructor for class org.apache.druid.metadata.SQLMetadataRuleManagerProvider
-
- SQLMetadataSegmentManager - Class in org.apache.druid.metadata
-
- SQLMetadataSegmentManager(ObjectMapper, Supplier<MetadataSegmentManagerConfig>, Supplier<MetadataStorageTablesConfig>, SQLMetadataConnector) - Constructor for class org.apache.druid.metadata.SQLMetadataSegmentManager
-
- SQLMetadataSegmentManagerProvider - Class in org.apache.druid.metadata
-
- SQLMetadataSegmentManagerProvider(ObjectMapper, Supplier<MetadataSegmentManagerConfig>, Supplier<MetadataStorageTablesConfig>, SQLMetadataConnector, Lifecycle) - Constructor for class org.apache.druid.metadata.SQLMetadataSegmentManagerProvider
-
- SQLMetadataSegmentPublisher - Class in org.apache.druid.metadata
-
- SQLMetadataSegmentPublisher(ObjectMapper, MetadataStorageTablesConfig, SQLMetadataConnector) - Constructor for class org.apache.druid.metadata.SQLMetadataSegmentPublisher
-
- SQLMetadataSegmentPublisherProvider - Class in org.apache.druid.metadata
-
- SQLMetadataSegmentPublisherProvider() - Constructor for class org.apache.druid.metadata.SQLMetadataSegmentPublisherProvider
-
- SQLMetadataStorageActionHandler<EntryType,StatusType,LogType,LockType> - Class in org.apache.druid.metadata
-
- SQLMetadataStorageActionHandler(SQLMetadataConnector, ObjectMapper, MetadataStorageActionHandlerTypes<EntryType, StatusType, LogType, LockType>, String, String, String, String) - Constructor for class org.apache.druid.metadata.SQLMetadataStorageActionHandler
-
- SQLMetadataStorageActionHandlerFactory - Class in org.apache.druid.metadata
-
- SQLMetadataStorageActionHandlerFactory(SQLMetadataConnector, MetadataStorageTablesConfig, ObjectMapper) - Constructor for class org.apache.druid.metadata.SQLMetadataStorageActionHandlerFactory
-
- SQLMetadataStorageDruidModule - Class in org.apache.druid.guice
-
- SQLMetadataStorageDruidModule(String) - Constructor for class org.apache.druid.guice.SQLMetadataStorageDruidModule
-
- SQLMetadataStorageUpdaterJobHandler - Class in org.apache.druid.indexer
-
- SQLMetadataStorageUpdaterJobHandler(SQLMetadataConnector) - Constructor for class org.apache.druid.indexer.SQLMetadataStorageUpdaterJobHandler
-
- SQLMetadataSupervisorManager - Class in org.apache.druid.metadata
-
- SQLMetadataSupervisorManager(ObjectMapper, SQLMetadataConnector, Supplier<MetadataStorageTablesConfig>) - Constructor for class org.apache.druid.metadata.SQLMetadataSupervisorManager
-
- SQLServerMetadataStorageActionHandler<EntryType,StatusType,LogType,LockType> - Class in org.apache.druid.metadata
-
- SQLServerMetadataStorageActionHandler(SQLMetadataConnector, ObjectMapper, MetadataStorageActionHandlerTypes<EntryType, StatusType, LogType, LockType>, String, String, String, String) - Constructor for class org.apache.druid.metadata.SQLServerMetadataStorageActionHandler
-
- SQLServerMetadataStorageActionHandlerFactory - Class in org.apache.druid.metadata
-
- SQLServerMetadataStorageActionHandlerFactory(SQLMetadataConnector, MetadataStorageTablesConfig, ObjectMapper) - Constructor for class org.apache.druid.metadata.SQLServerMetadataStorageActionHandlerFactory
-
- start() - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- start() - Method in class org.apache.druid.client.HttpServerInventoryView
-
- start() - Method in class org.apache.druid.curator.announcement.Announcer
-
- start() - Method in class org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider
-
- start() - Method in class org.apache.druid.curator.discovery.ServerDiscoverySelector
-
Deprecated.
- start() - Method in class org.apache.druid.curator.inventory.CuratorInventoryManager
-
Deprecated.
- start() - Method in class org.apache.druid.discovery.DruidLeaderClient
-
- start() - Method in interface org.apache.druid.indexing.overlord.supervisor.Supervisor
-
- start() - Method in class org.apache.druid.initialization.Log4jShutterDownerModule.Log4jShutterDowner
-
- start() - Method in class org.apache.druid.metadata.IndexerSQLMetadataStorageCoordinator
-
- start() - Method in interface org.apache.druid.metadata.MetadataRuleManager
-
- start() - Method in interface org.apache.druid.metadata.MetadataSegmentManager
-
- start() - Method in class org.apache.druid.metadata.MetadataStorage
-
- start() - Method in interface org.apache.druid.metadata.MetadataSupervisorManager
-
- start() - Method in class org.apache.druid.metadata.SQLMetadataRuleManager
-
- start() - Method in class org.apache.druid.metadata.SQLMetadataSegmentManager
-
- start() - Method in class org.apache.druid.metadata.SQLMetadataSupervisorManager
-
- start() - Method in class org.apache.druid.metadata.storage.derby.DerbyConnector
-
- start() - Method in class org.apache.druid.metadata.storage.derby.DerbyMetadataStorage
-
- start() - Method in class org.apache.druid.query.lookup.LookupReferencesManager
-
- start() - Method in class org.apache.druid.query.lookup.MapLookupExtractorFactory
-
- start() - Method in class org.apache.druid.segment.realtime.plumber.CoordinatorBasedSegmentHandoffNotifier
-
- start() - Method in interface org.apache.druid.segment.realtime.plumber.SegmentHandoffNotifier
-
Perform any initial setup.
- start() - Method in class org.apache.druid.segment.realtime.RealtimeManager
-
- start() - Method in class org.apache.druid.server.coordination.broker.DruidBroker
-
- start() - Method in class org.apache.druid.server.coordination.ChangeRequestHttpSyncer
-
- start() - Method in class org.apache.druid.server.coordination.SegmentLoadDropHandler
-
- start() - Method in class org.apache.druid.server.coordination.ZkCoordinator
-
Deprecated.
- start() - Method in class org.apache.druid.server.coordinator.CachingCostBalancerStrategyFactory
-
- start() - Method in class org.apache.druid.server.coordinator.CuratorLoadQueuePeon
-
Deprecated.
- start() - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- start() - Method in class org.apache.druid.server.coordinator.HttpLoadQueuePeon
-
- start() - Method in class org.apache.druid.server.coordinator.LoadQueuePeon
-
Deprecated.
- start() - Method in class org.apache.druid.server.listener.announcer.ListenerResourceAnnouncer
-
Deprecated.
- start() - Method in class org.apache.druid.server.log.ComposingRequestLoggerProvider.ComposingRequestLogger
-
- start() - Method in class org.apache.druid.server.log.FileRequestLogger
-
- start() - Method in interface org.apache.druid.server.log.RequestLogger
-
- start() - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManager
-
- start() - Method in class org.apache.druid.server.router.CoordinatorRuleManager
-
- start() - Method in class org.apache.druid.server.router.TieredBrokerHostSelector
-
- startJob() - Method in interface org.apache.druid.segment.realtime.appenderator.Appenderator
-
Perform any initial setup.
- startJob() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorImpl
-
- startJob() - Method in class org.apache.druid.segment.realtime.appenderator.AppenderatorPlumber
-
- startJob() - Method in class org.apache.druid.segment.realtime.appenderator.BaseAppenderatorDriver
-
Perform any initial setup and return currently persisted commit metadata.
- startJob() - Method in class org.apache.druid.segment.realtime.appenderator.BatchAppenderatorDriver
-
This method always returns null because batch ingestion doesn't support restoring tasks on failures.
- startJob() - Method in class org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver
-
- startJob() - Method in class org.apache.druid.segment.realtime.plumber.FlushingPlumber
-
- startJob() - Method in interface org.apache.druid.segment.realtime.plumber.Plumber
-
Perform any initial setup.
- startJob() - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- startPersistThread() - Method in class org.apache.druid.segment.realtime.plumber.RealtimePlumber
-
- StartupLoggingConfig - Class in org.apache.druid.server.log
-
- StartupLoggingConfig() - Constructor for class org.apache.druid.server.log.StartupLoggingConfig
-
- StartupLoggingModule - Class in org.apache.druid.guice
-
- StartupLoggingModule() - Constructor for class org.apache.druid.guice.StartupLoggingModule
-
- StateResourceFilter - Class in org.apache.druid.server.http.security
-
Use this ResourceFilter at end points where Druid Cluster State is read or written
Here are some example paths where this filter is used -
- druid/broker/v1
- druid/coordinator/v1
- druid/historical/v1
- druid/indexer/v1
- druid/coordinator/v1/rules
- druid/coordinator/v1/tiers
- druid/worker/v1
- druid/coordinator/v1/servers
- status
Note - Currently the resource name for all end points is set to "STATE" however if more fine grained access control
is required the resource name can be set to specific state properties.
- StateResourceFilter(AuthorizerMapper) - Constructor for class org.apache.druid.server.http.security.StateResourceFilter
-
- Status(Collection<DruidModule>) - Constructor for class org.apache.druid.server.StatusResource.Status
-
- StatusResource - Class in org.apache.druid.server
-
- StatusResource(Properties, DruidServerConfig) - Constructor for class org.apache.druid.server.StatusResource
-
- StatusResource.Memory - Class in org.apache.druid.server
-
- StatusResource.ModuleVersion - Class in org.apache.druid.server
-
- StatusResource.Status - Class in org.apache.druid.server
-
- stop() - Method in class org.apache.druid.client.AbstractCuratorServerInventoryView
-
- stop() - Method in class org.apache.druid.client.HttpServerInventoryView
-
- stop() - Method in class org.apache.druid.curator.announcement.Announcer
-
- stop() - Method in class org.apache.druid.curator.discovery.CuratorDruidNodeDiscoveryProvider
-
- stop() - Method in class org.apache.druid.curator.discovery.ServerDiscoverySelector
-
Deprecated.
- stop() - Method in class org.apache.druid.curator.inventory.CuratorInventoryManager
-
Deprecated.
- stop() - Method in class org.apache.druid.discovery.DruidLeaderClient
-
- stop(boolean) - Method in interface org.apache.druid.indexing.overlord.supervisor.Supervisor
-
- stop() - Method in class org.apache.druid.initialization.Log4jShutterDownerModule.Log4jShutterDowner
-
- stop() - Method in interface org.apache.druid.metadata.MetadataRuleManager
-
- stop() - Method in interface org.apache.druid.metadata.MetadataSegmentManager
-
- stop() - Method in class org.apache.druid.metadata.MetadataStorage
-
- stop() - Method in class org.apache.druid.metadata.SQLMetadataRuleManager
-
- stop() - Method in class org.apache.druid.metadata.SQLMetadataSegmentManager
-
- stop() - Method in class org.apache.druid.metadata.storage.derby.DerbyConnector
-
- stop() - Method in class org.apache.druid.metadata.storage.derby.DerbyMetadataStorage
-
- stop() - Method in class org.apache.druid.query.lookup.LookupReferencesManager
-
- stop() - Method in class org.apache.druid.segment.realtime.RealtimeManager
-
- stop() - Method in class org.apache.druid.server.coordination.broker.DruidBroker
-
- stop() - Method in class org.apache.druid.server.coordination.ChangeRequestHttpSyncer
-
- stop() - Method in class org.apache.druid.server.coordination.SegmentLoadDropHandler
-
- stop() - Method in class org.apache.druid.server.coordination.ZkCoordinator
-
Deprecated.
- stop() - Method in class org.apache.druid.server.coordinator.CachingCostBalancerStrategyFactory
-
- stop() - Method in class org.apache.druid.server.coordinator.CuratorLoadQueuePeon
-
Deprecated.
- stop() - Method in class org.apache.druid.server.coordinator.DruidCoordinator
-
- stop() - Method in class org.apache.druid.server.coordinator.HttpLoadQueuePeon
-
- stop() - Method in class org.apache.druid.server.coordinator.LoadQueuePeon
-
Deprecated.
- stop() - Method in class org.apache.druid.server.listener.announcer.ListenerResourceAnnouncer
-
Deprecated.
- stop() - Method in class org.apache.druid.server.log.ComposingRequestLoggerProvider.ComposingRequestLogger
-
- stop() - Method in class org.apache.druid.server.log.FileRequestLogger
-
- stop() - Method in interface org.apache.druid.server.log.RequestLogger
-
- stop() - Method in class org.apache.druid.server.lookup.cache.LookupCoordinatorManager
-
- stop() - Method in class org.apache.druid.server.router.CoordinatorRuleManager
-
- stop() - Method in class org.apache.druid.server.router.TieredBrokerHostSelector
-
- stopBeingLeader() - Method in interface org.apache.druid.discovery.DruidLeaderSelector.Listener
-
Notification that this node should stop activities which are done by the leader.
- storageDirectory - Variable in class org.apache.druid.segment.loading.LocalDataSegmentPusherConfig
-
- StorageLocationConfig - Class in org.apache.druid.segment.loading
-
- StorageLocationConfig() - Constructor for class org.apache.druid.segment.loading.StorageLocationConfig
-
- StorageNodeModule - Class in org.apache.druid.guice
-
- StorageNodeModule() - Constructor for class org.apache.druid.guice.StorageNodeModule
-
- StreamAppenderatorDriver - Class in org.apache.druid.segment.realtime.appenderator
-
This class is specialized for streaming ingestion.
- StreamAppenderatorDriver(Appenderator, SegmentAllocator, SegmentHandoffNotifierFactory, UsedSegmentChecker, DataSegmentKiller, ObjectMapper, FireDepartmentMetrics) - Constructor for class org.apache.druid.segment.realtime.appenderator.StreamAppenderatorDriver
-
Create a driver.
- success(ChangeRequestHistory.Counter, List<T>) - Static method in class org.apache.druid.server.coordination.ChangeRequestsSnapshot
-
- SUCCESS - Static variable in class org.apache.druid.server.coordination.SegmentLoadDropHandler.Status
-
- Supervisor - Interface in org.apache.druid.indexing.overlord.supervisor
-
- SupervisorReport<T> - Class in org.apache.druid.indexing.overlord.supervisor
-
- SupervisorReport(String, DateTime, T) - Constructor for class org.apache.druid.indexing.overlord.supervisor.SupervisorReport
-
- SupervisorSpec - Interface in org.apache.druid.indexing.overlord.supervisor
-
- supplierFromFirehose(Firehose) - Static method in class org.apache.druid.segment.realtime.plumber.Committers
-
- supplierFromFirehoseV2(FirehoseV2) - Static method in class org.apache.druid.segment.realtime.plumber.Committers
-
- supplierFromRunnable(Runnable) - Static method in class org.apache.druid.segment.realtime.plumber.Committers
-
- swap() - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
If currHydrant is A, creates a new index B, sets currHydrant to B and returns A.
- swappable() - Method in class org.apache.druid.segment.realtime.plumber.Sink
-
- swapSegment(Segment) - Method in class org.apache.druid.segment.realtime.FireHydrant
-
- validateTieredReplicants(Map<String, Integer>) - Static method in class org.apache.druid.server.coordinator.rules.LoadRule
-
- valueOf(String) - Static method in enum org.apache.druid.client.cache.CacheExecutorFactory
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.druid.client.indexing.QueryStatus.Status
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.druid.client.ServerView.CallbackAction
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.druid.segment.realtime.appenderator.SegmentWithState.SegmentState
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.druid.server.coordination.SegmentLoadDropHandler.Status.STATE
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.druid.server.coordination.ServerType
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.druid.server.security.Action
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.druid.server.security.ResourceType
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.apache.druid.client.cache.CacheExecutorFactory
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.druid.client.indexing.QueryStatus.Status
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.druid.client.ServerView.CallbackAction
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.druid.segment.realtime.appenderator.SegmentWithState.SegmentState
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.druid.server.coordination.SegmentLoadDropHandler.Status.STATE
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.druid.server.coordination.ServerType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.druid.server.security.Action
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.druid.server.security.ResourceType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- VersionedSupervisorSpec - Class in org.apache.druid.indexing.overlord.supervisor
-
- VersionedSupervisorSpec(SupervisorSpec, String) - Constructor for class org.apache.druid.indexing.overlord.supervisor.VersionedSupervisorSpec
-
- VersioningPolicy - Interface in org.apache.druid.segment.realtime.plumber
-