Skip to main content

​
module es_mixin

Mixin class containing Lineage specific methods To be used by OpenMetadata class

​
Global Variables

  • ES_INDEX_MAP

​
class ESMixin

OpenMetadata API methods related to Elasticsearch. To be inherited by OpenMetadata

​
handler es_get_queries_with_lineage

​
method es_search_from_fqn

es_search_from_fqn(
    entity_type: Type[~T],
    fqn_search_string: str,
    from_count: int = 0,
    size: int = 10,
    fields: Optional[str] = None
) → Optional[List[~T]]
Given a service_name and some filters, search for entities using ES Args: entity_type: Entity to look for fqn_search_string: string used to search by FQN. E.g., service.*.schema.table from_count: Records to expect size: Number of records fields: Comma separated list of fields to be returned Returns: List of entities

​
method get_query_with_lineage_filter

get_query_with_lineage_filter(service_name: str) → str

​
method get_reindex_job_status

get_reindex_job_status(job_id: str) → Optional[EventPublisherResult]
Method to fetch the elasticsearch reindex job status

​
method reindex_es

reindex_es(config: CreateEventPublisherJob) → Optional[EventPublisherResult]
Method to trigger elasticsearch reindex