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

Data Insight Mixin

Ingestion Pipeline Mixin

API Reference

Data Assets

AI SDK

SDK

Discovery

Lineage

Data Contracts

Teams And Users

Data Governance

Data Quality

Main Concepts

ES Mixin

module `es_mixin`

Global Variables

class `ESMixin`

handler es_get_queries_with_lineage

method `es_search_from_fqn`

method `get_query_with_lineage_filter`

method `get_reindex_job_status`

method `reindex_es`

​module es_mixin

​Global Variables

​class ESMixin

​handler es_get_queries_with_lineage

​method es_search_from_fqn

​method get_query_with_lineage_filter

​method get_reindex_job_status

​method reindex_es

module `es_mixin`

Global Variables

class `ESMixin`

handler es_get_queries_with_lineage

method `es_search_from_fqn`

method `get_query_with_lineage_filter`

method `get_reindex_job_status`

method `reindex_es`