Index
All Classes and Interfaces|All Packages|Serialized Form
A
- addFlowActivity(String, String, long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- aggregate(TimelineEntity, TimelineAggregationTrack) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineWriterImpl
- APPLICATION - Enum constant in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.CollectionType
- applyConfigFilter(TimelineFilterList, Map<String, String>) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
C
- close() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb.CosmosDBDocumentStoreReader
- close() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.TimelineCollectionReader
- close() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.cosmosdb.CosmosDBDocumentStoreWriter
- close() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.TimelineCollectionWriter
- CollectionType - Enum Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.collection
-
Specifies the different collections that are currently used for storing documents.
- constructFlowActivityDocId(TimelineCollectorContext, long) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Creates a composite key for storing
FlowActivityDocument. - constructFlowRunDocId(TimelineCollectorContext) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Creates a composite key for storing
FlowRunDocument. - constructTimelineEntityDocId(TimelineCollectorContext, String) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Creates a composite key for storing
TimelineEntityDocument. - constructTimelineEntityDocId(TimelineCollectorContext, String, String) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Creates a composite key for storing
TimelineEntityDocument. - COSMOS_DB - Enum constant in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.lib.DocumentStoreVendor
- CosmosDBDocumentStoreReader<TimelineDoc extends TimelineDocument> - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb
-
This is the Document Store Reader implementation for
DocumentStoreVendor.COSMOS_DB. - CosmosDBDocumentStoreReader(Configuration) - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb.CosmosDBDocumentStoreReader
- CosmosDBDocumentStoreWriter<TimelineDoc extends TimelineDocument> - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.cosmosdb
-
This is the Document Store Writer implementation for
DocumentStoreVendor.COSMOS_DB. - CosmosDBDocumentStoreWriter(Configuration) - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.cosmosdb.CosmosDBDocumentStoreWriter
- createCollection(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.cosmosdb.CosmosDBDocumentStoreWriter
- createCollection(String) - Method in interface org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.DocumentStoreWriter
- createCosmosDBAsyncClient(Configuration) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Creates CosmosDB Async Document Client.
- createDatabase() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.cosmosdb.CosmosDBDocumentStoreWriter
- createDatabase() - Method in interface org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.DocumentStoreWriter
- createDocumentStoreReader(Configuration) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.lib.DocumentStoreFactory
-
Creates a DocumentStoreReader for a
DocumentStoreVendor. - createDocumentStoreWriter(Configuration) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.lib.DocumentStoreFactory
-
Creates a DocumentStoreWriter for a
DocumentStoreVendor. - createEntityToBeReturned(TimelineEntityDocument, TimelineFilterList, TimelineFilterList) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Creates the final entity to be returned as the result.
- createEntityToBeReturned(TimelineEntityDocument, TimelineDataToRetrieve) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Creates the final entity to be returned as the result.
- createTimelineSchema(String[]) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreCollectionCreator
D
- DocumentStoreCollectionCreator - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore
-
This creates the Collection for a
DocumentStoreVendorbackend configured for storing application timeline information. - DocumentStoreCollectionCreator() - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreCollectionCreator
- DocumentStoreFactory - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.lib
-
Factory methods for instantiating a timeline Document Store reader or writer.
- DocumentStoreNotSupportedException - Exception in org.apache.hadoop.yarn.server.timelineservice.documentstore.lib
-
Indicates that the document store vendor that was configured does not belong to one of the
DocumentStoreVendor. - DocumentStoreNotSupportedException(String) - Constructor for exception org.apache.hadoop.yarn.server.timelineservice.documentstore.lib.DocumentStoreNotSupportedException
-
Constructs exception with the specified detail message.
- DocumentStoreReader<Document extends TimelineDocument> - Interface in org.apache.hadoop.yarn.server.timelineservice.documentstore.reader
-
Every
DocumentStoreVendorhave to implement this for creating reader to its backend. - DocumentStoreTimelineReaderImpl - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore
-
This is a generic document store timeline reader for reading the timeline entity information.
- DocumentStoreTimelineReaderImpl() - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineReaderImpl
- DocumentStoreTimelineWriterImpl - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore
-
This is a generic document store timeline writer for storing the timeline entity information.
- DocumentStoreTimelineWriterImpl() - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineWriterImpl
- DocumentStoreUtils - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore
-
This class consists of all the utils required for reading or writing documents for a
DocumentStoreVendor. - DocumentStoreVendor - Enum Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.lib
-
Represents the different vendors for DocumentStore.
- DocumentStoreWriter<Document> - Interface in org.apache.hadoop.yarn.server.timelineservice.documentstore.writer
-
Every
DocumentStoreVendorhave to implement this for creating writer to its backend.
E
- ELASTIC_SEARCH - Enum constant in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.lib.DocumentStoreVendor
- ENTITY - Enum constant in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.CollectionType
- equals(Object) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- equals(Object) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- equals(Object) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivitySubDoc
- equals(String) - Method in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.CollectionType
F
- fetchEntityTypes(String, TimelineReaderContext) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb.CosmosDBDocumentStoreReader
- fetchEntityTypes(String, TimelineReaderContext) - Method in interface org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.DocumentStoreReader
- fetchEntityTypes(TimelineReaderContext) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.TimelineCollectionReader
-
Fetches the list of Entity Types i.e (YARN_CONTAINER, YARN_APPLICATION_ATTEMPT etc.) for an application Id.
- fetchEvent(TimelineEntity, String) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Retrieves a
TimelineEventfromTimelineEntity.events. - fetchTimelineEntity() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- fetchTimelineEvent() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- fetchTimelineMetric() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- fetchTimelineMetrics() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- FLOW_ACTIVITY - Enum constant in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.CollectionType
- FLOW_RUN - Enum constant in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.CollectionType
- FlowActivityDocument - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity
-
This doc represents the
FlowActivityEntitywhich is used for showing all the flow runs with limited information. - FlowActivityDocument() - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- FlowActivityDocument(String, String, long) - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- FlowActivitySubDoc - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity
-
This is a sub doc which represents each flow.
- FlowActivitySubDoc() - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivitySubDoc
- FlowActivitySubDoc(String, String, long) - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivitySubDoc
- FlowRunDocument - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun
-
This doc represents the flow run information for every job.
- FlowRunDocument() - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- FlowRunDocument(TimelineCollectorContext, Set<TimelineMetric>) - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- flush() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineWriterImpl
- flush() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.TimelineCollectionWriter
G
- getClusterId() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- getCollectionName() - Method in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.CollectionType
- getConfigs() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getContext() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getCosmosDBDatabaseName(Configuration) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
- getCreatedTime() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getCreatedTime() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- getCreatedTime() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- getCreatedTime() - Method in interface org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.TimelineDocument
- getDayTimestamp() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- getEntities(TimelineReaderContext, TimelineEntityFilters, TimelineDataToRetrieve) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineReaderImpl
- getEntity(TimelineReaderContext, TimelineDataToRetrieve) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineReaderImpl
- getEntityTypes(TimelineReaderContext) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineReaderImpl
- getEvents() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getFlowActivities() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- getFlowName() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- getFlowName() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivitySubDoc
- getFlowName() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- getFlowRunId() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivitySubDoc
- getFlowRunId() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- getFlowVersion() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getFlowVersion() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivitySubDoc
- getFlowVersion() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- getHealthStatus() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineReaderImpl
- getHealthStatus() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineWriterImpl
- getId() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getId() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- getId() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- getId() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- getId() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- getId() - Method in interface org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.TimelineDocument
- getInfo() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getInfo() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- getIsRelatedToEntities() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getMaxEndTime() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- getMetrics() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getMetrics() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- getMinStartTime() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- getRealtimeAggregationOp() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
-
Get the real time aggregation operation of this metric.
- getRelatesToEntities() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getSingleDataTimestamp() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
-
Get single data timestamp of the metric.
- getSingleDataValue() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
-
Get single data value of the metric.
- getStoreType(String) - Static method in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.lib.DocumentStoreVendor
- getStoreVendor(Configuration) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Retrieves
DocumentStoreVendorconfigured. - getSubApplicationUser() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getTimestamp() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- getTopOfTheDayTimestamp(long) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Returns the timestamp of the day's start (which is midnight 00:00:00 AM) for a given input timestamp.
- getType() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- getType() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- getType() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- getType() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- getType() - Method in interface org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.TimelineDocument
- getUser() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- getUsername() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- getValues() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- getValuesJAXB() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
H
- hashCode() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- hashCode() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- hashCode() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivitySubDoc
I
- isNullOrEmpty(String...) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Checks if the string is null or empty.
- isValid() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- isValid() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
M
- merge(Document) - Method in interface org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.TimelineDocument
- merge(TimelineEntityDocument) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
-
Merge the TimelineEntityDocument that is passed with the current document for upsert.
- merge(FlowActivityDocument) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
-
Merge the
FlowActivityDocumentthat is passed with the current document for upsert. - merge(FlowRunDocument) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
-
Merge the
FlowRunDocumentthat is passed with the current document for upsert. - MONGO_DB - Enum constant in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.lib.DocumentStoreVendor
N
- NoDocumentFoundException - Exception in org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document
-
Indicates that the document that was requested is not found from the Document Store.
- NoDocumentFoundException(String) - Constructor for exception org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.NoDocumentFoundException
-
Constructs exception with the specified detail message.
O
- org.apache.hadoop.yarn.server.timelineservice.documentstore - package org.apache.hadoop.yarn.server.timelineservice.documentstore
-
Package org.apache.hadoop.yarn.server.timelineservice.documentstore contains DocumentStore Reader and Writer Implementation of TimelineService for reading and writing documents from DocumentStore.
- org.apache.hadoop.yarn.server.timelineservice.documentstore.collection - package org.apache.hadoop.yarn.server.timelineservice.documentstore.collection
-
Package org.apache.hadoop.yarn.server.timelineservice.
- org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document - package org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document
-
Package org.apache.hadoop.yarn.server.timelineservice.
- org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity - package org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity
-
Package org.apache.hadoop.yarn.server.timelineservice.
- org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity - package org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity
-
Package org.apache.hadoop.yarn.server.timelineservice.
- org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun - package org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun
-
Package org.apache.hadoop.yarn.server.timelineservice.
- org.apache.hadoop.yarn.server.timelineservice.documentstore.lib - package org.apache.hadoop.yarn.server.timelineservice.documentstore.lib
-
Package org.apache.hadoop.yarn.server.timelineservice.
- org.apache.hadoop.yarn.server.timelineservice.documentstore.reader - package org.apache.hadoop.yarn.server.timelineservice.documentstore.reader
-
Package org.apache.hadoop.yarn.server.timelineservice.documentstore.reader contains the implementation of different DocumentStore reader clients for DocumentVendor.
- org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb - package org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb
-
Package org.apache.hadoop.yarn.server.timelineservice.documentstore .reader.cosmosdb DocumentStore Reader implementation for CosmosDB.
- org.apache.hadoop.yarn.server.timelineservice.documentstore.writer - package org.apache.hadoop.yarn.server.timelineservice.documentstore.writer
-
Package org.apache.hadoop.yarn.server.timelineservice.documentstore.writer contains the implementation of different DocumentStore writer clients for DocumentVendor.
- org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.cosmosdb - package org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.cosmosdb
-
Package org.apache.hadoop.yarn.server.timelineservice.documentstore .writer.cosmosdb DocumentStore writer implementation for CosmosDB.
R
- readDocument(String, TimelineReaderContext, Class<Document>) - Method in interface org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.DocumentStoreReader
- readDocument(String, TimelineReaderContext, Class<TimelineDoc>) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb.CosmosDBDocumentStoreReader
- readDocument(TimelineReaderContext) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.TimelineCollectionReader
-
Read a document from
DocumentStoreVendorbackend for aCollectionType. - readDocumentList(String, TimelineReaderContext, Class<Document>, long) - Method in interface org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.DocumentStoreReader
- readDocumentList(String, TimelineReaderContext, Class<TimelineDoc>, long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb.CosmosDBDocumentStoreReader
- readDocuments(TimelineReaderContext, long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.TimelineCollectionReader
-
Read a list of documents from
DocumentStoreVendorbackend for aCollectionType.
S
- serviceInit(Configuration) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineReaderImpl
- serviceInit(Configuration) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineWriterImpl
- serviceStart() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineWriterImpl
- serviceStop() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineReaderImpl
- serviceStop() - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineWriterImpl
- setClusterId(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- setConfigs(Map<String, String>) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setContext(TimelineContext) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setCreatedTime(long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setCreatedTime(long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- setCreatedTime(long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- setCreatedTime(long) - Method in interface org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.TimelineDocument
- setDayTimestamp(long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- setEvents(Map<String, Set<TimelineEventSubDoc>>) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setFlowActivities(Set<FlowActivitySubDoc>) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- setFlowName(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- setFlowName(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- setFlowRunId(Long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- setFlowVersion(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setFlowVersion(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- setId(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setId(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- setId(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- setId(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- setId(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- setIdentifier(TimelineEntity.Identifier) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setIdPrefix(long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setInfo(Map<String, Object>) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setInfo(Map<String, Object>) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- setIsRelatedToEntities(Map<String, Set<String>>) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setMaxEndTime(long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- setMetrics(Map<String, Set<TimelineMetricSubDoc>>) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setMetrics(Map<String, TimelineMetricSubDoc>) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- setMinStartTime(long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- setRealtimeAggregationOp(TimelineMetricOperation) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
-
Set the real time aggregation operation of this metric.
- setRelatesToEntities(Map<String, Set<String>>) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setSingleDataTimestamp(long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- setSingleDataValue(Number) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- setSubApplicationUser(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setTimestamp(long) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- setType(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- setType(TimelineMetric.Type) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- setUser(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowactivity.FlowActivityDocument
- setUsername(String) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.flowrun.FlowRunDocument
- setValues(Map<Long, Number>) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
T
- TimelineCollectionReader - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.reader
-
This is a generic Collection reader for reading documents belonging to a
CollectionTypeunder a specificDocumentStoreVendorbackend. - TimelineCollectionReader(Configuration) - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.TimelineCollectionReader
- TimelineCollectionWriter<Document extends TimelineDocument> - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.writer
-
This is a generic Collection Writer that can be used for writing documents belonging to different
CollectionTypeunder a specificDocumentStoreVendorbackend. - TimelineCollectionWriter(CollectionType, Configuration) - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.TimelineCollectionWriter
- TimelineDocument<Document> - Interface in org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document
-
This is an interface for all the Timeline Documents.
- TimelineEntityDocument - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity
-
This is a generic class which contains all the meta information of some conceptual entity and its related events.
- TimelineEntityDocument() - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- TimelineEntityDocument(TimelineEntity) - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEntityDocument
- TimelineEventSubDoc - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity
-
This class represents a Sub Document for
TimelineEventwhen creating a newTimelineEntityDocument. - TimelineEventSubDoc() - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- TimelineEventSubDoc(TimelineEvent) - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineEventSubDoc
- TimelineMetricSubDoc - Class in org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity
-
This class represents a Sub Document for
TimelineMetricthat will be used when creating newTimelineEntityDocument. - TimelineMetricSubDoc() - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- TimelineMetricSubDoc(TimelineMetric) - Constructor for class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.document.entity.TimelineMetricSubDoc
- transformMetrics(TimelineFilterList, Map<String, Set<TimelineMetricSubDoc>>) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
V
- validateCosmosDBConf(Configuration) - Static method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreUtils
-
Checks whether the cosmosdb conf are set properly in yarn-site.xml conf.
- valueOf(String) - Static method in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.CollectionType
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.lib.DocumentStoreVendor
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.collection.CollectionType
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class org.apache.hadoop.yarn.server.timelineservice.documentstore.lib.DocumentStoreVendor
-
Returns an array containing the constants of this enum class, in the order they are declared.
W
- write(TimelineCollectorContext, TimelineDomain) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineWriterImpl
- write(TimelineCollectorContext, TimelineEntities, UserGroupInformation) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.DocumentStoreTimelineWriterImpl
- writeDocument(Document) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.TimelineCollectionWriter
- writeDocument(Document, CollectionType) - Method in interface org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.DocumentStoreWriter
- writeDocument(TimelineDoc, CollectionType) - Method in class org.apache.hadoop.yarn.server.timelineservice.documentstore.writer.cosmosdb.CosmosDBDocumentStoreWriter
All Classes and Interfaces|All Packages|Serialized Form