Search.setIndex({"docnames": ["_api/airflow/providers/apache/druid/hooks/druid/index", "_api/airflow/providers/apache/druid/hooks/index", "_api/airflow/providers/apache/druid/index", "_api/airflow/providers/apache/druid/operators/druid/index", "_api/airflow/providers/apache/druid/operators/druid_check/index", "_api/airflow/providers/apache/druid/operators/index", "_api/airflow/providers/apache/druid/transfers/hive_to_druid/index", "_api/airflow/providers/apache/druid/transfers/index", "_api/tests/system/providers/apache/druid/example_druid_dag/index", "_api/tests/system/providers/apache/druid/index", "commits", "index", "installing-providers-from-sources", "operators"], "filenames": ["_api/airflow/providers/apache/druid/hooks/druid/index.rst", "_api/airflow/providers/apache/druid/hooks/index.rst", "_api/airflow/providers/apache/druid/index.rst", "_api/airflow/providers/apache/druid/operators/druid/index.rst", "_api/airflow/providers/apache/druid/operators/druid_check/index.rst", "_api/airflow/providers/apache/druid/operators/index.rst", "_api/airflow/providers/apache/druid/transfers/hive_to_druid/index.rst", "_api/airflow/providers/apache/druid/transfers/index.rst", "_api/tests/system/providers/apache/druid/example_druid_dag/index.rst", "_api/tests/system/providers/apache/druid/index.rst", "commits.rst", "index.rst", "installing-providers-from-sources.rst", "operators.rst"], "titles": ["<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.druid.hooks.druid</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.druid.hooks</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.druid</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.druid.operators.druid</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.druid.operators.druid_check</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.druid.operators</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.druid.transfers.hive_to_druid</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.apache.druid.transfers</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.apache.druid.example_druid_dag</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.apache.druid</span></code>", "Package apache-airflow-providers-apache-druid", "<code class=\"docutils literal notranslate\"><span class=\"pre\">apache-airflow-providers-apache-druid</span></code>", "Installing from sources", "Apache Druid Operators"], "terms": {"druidhook": 0, "druid_ingest_conn_id": [0, 3, 6, 13], "druid_ingest_default": [0, 3, 6], "timeout": [0, 3, 10, 11], "1": [0, 3, 6], "max_ingestion_tim": [0, 3, 10, 11], "none": [0, 3, 6, 12], "sourc": [0, 3, 4, 6, 8, 11, 13], "base": [0, 3, 4, 6], "basehook": 0, "connect": [0, 3, 6, 10, 11, 13], "overlord": [0, 3, 13], "ingest": [0, 3, 6, 10, 11, 13], "To": [0, 12, 13], "cluster": 0, "i": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "secur": 0, "basic": 0, "extens": 0, "add": [0, 10, 11], "usernam": 0, "password": 0, "paramet": [0, 3, 6, 10, 11, 13], "str": [0, 3, 6], "The": [0, 3, 6, 11, 12], "id": [0, 3, 6, 12, 13], "machin": 0, "which": [0, 3, 6, 13], "accept": [0, 3, 13], "index": [0, 3, 8, 13], "job": [0, 3, 6, 13], "int": [0, 3, 6], "interv": [0, 3, 6, 13], "between": [0, 3], "poll": [0, 3], "statu": [0, 3], "must": [0, 3, 13], "greater": [0, 3], "than": [0, 3], "equal": [0, 3], "option": [0, 3, 6], "maximum": [0, 3], "time": [0, 3, 6], "befor": [0, 3, 6], "assum": [0, 3], "fail": [0, 3, 10, 11], "get_conn_url": 0, "get": [0, 12], "url": 0, "get_auth": 0, "return": 0, "from": [0, 6, 10, 11], "tab": 0, "request": 0, "auth": 0, "httpbasicauth": 0, "object": [0, 6], "If": [0, 11, 12], "detail": [0, 10, 11, 12], "have": [0, 10, 11], "been": 0, "set": 0, "submit_indexing_job": 0, "json_index_spec": 0, "submit": [0, 3, 8, 10, 11, 13], "druiddbapihook": 0, "arg": [0, 10], "schema": 0, "log_sql": 0, "true": 0, "kwarg": [0, 3, 4, 6], "common": [0, 4, 10, 11], "sql": [0, 4, 6, 10, 11], "dbapihook": 0, "interact": [0, 10], "broker": 0, "thi": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "pure": 0, "user": [0, 12], "queri": [0, 6], "For": [0, 6, 10, 11, 12, 13], "pleas": [0, 4, 12, 13], "us": [0, 3, 4, 6, 8, 10, 11, 12], "conn_name_attr": 0, "druid_broker_conn_id": [0, 4], "default_conn_nam": 0, "druid_broker_default": [0, 4], "conn_typ": 0, "hook_nam": 0, "supports_autocommit": 0, "fals": 0, "get_conn": 0, "establish": 0, "get_uri": 0, "uri": 0, "e": [0, 6], "g": [0, 6], "localhost": 0, "8082": 0, "v2": [0, 10], "abstract": 0, "set_autocommit": 0, "conn": 0, "autocommit": 0, "flag": 0, "insert_row": 0, "tabl": [0, 6], "row": [0, 6], "target_field": 0, "commit_everi": 0, "1000": 0, "replac": [0, 10], "A": [0, 6], "gener": [0, 10], "wai": 0, "insert": 0, "tupl": [0, 6], "new": [0, 10], "transact": 0, "creat": [0, 3, 6, 12], "everi": 0, "name": [0, 10], "target": [0, 6], "iter": 0, "column": [0, 6], "fill": 0, "number": [0, 6, 10], "one": [0, 12], "0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 12, 13], "all": [0, 6, 10, 11], "bool": 0, "whether": 0, "instead": [0, 6], "3": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 12, 13], "2": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 12, 13], "4": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "dev0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "an": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "experiment": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13], "featur": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 12, 13], "hook": [2, 10], "oper": [2, 6, 10, 11], "druid_check": [2, 5], "transfer": [2, 10], "hive_to_druid": [2, 7], "druidoper": [3, 8, 10, 11], "json_index_fil": [3, 13], "model": [3, 6], "baseoper": [3, 6], "allow": 3, "task": [3, 10, 11, 13], "directli": [3, 6, 13], "filepath": [3, 13], "specif": [3, 10, 13], "second": 3, "template_field": [3, 6, 10], "sequenc": [3, 6, 10], "template_ext": [3, 6], "json": [3, 6, 8, 10, 13], "template_fields_render": [3, 6, 10, 11], "execut": [3, 6], "context": [3, 6], "main": [3, 6, 11, 12], "method": [3, 6], "deriv": [3, 6], "when": [3, 6, 10, 11], "same": [3, 6], "dictionari": [3, 6], "render": [3, 6, 10, 11], "jinja": [3, 6], "templat": [3, 6, 10, 11], "refer": [3, 6], "get_template_context": [3, 6], "more": [3, 6, 10, 11, 13], "druidcheckoper": 4, "sqlcheckoper": 4, "deprec": 4, "contain": [6, 12], "move": [6, 10, 11], "data": [6, 10], "hive": [6, 11], "load_check_interv": 6, "5": 6, "default_target_partition_s": 6, "5000000": 6, "hivetodruidoper": 6, "druid_datasourc": 6, "ts_dim": 6, "metric_spec": 6, "hive_cli_conn_id": 6, "hive_cli_default": 6, "metastore_conn_id": 6, "metastore_default": 6, "hadoop_dependency_coordin": 6, "num_shard": 6, "target_partition_s": 6, "query_granular": 6, "segment_granular": 6, "dai": 6, "hive_tblproperti": 6, "job_properti": 6, "del": 6, "note": [6, 10], "now": [6, 10], "load": 6, "memori": 6, "being": 6, "push": 6, "so": 6, "should": [6, 12], "smallish": 6, "amount": 6, "against": 6, "databas": 6, "datasourc": [6, 13], "you": [6, 11, 12, 13], "want": [6, 11, 12], "timestamp": 6, "dimens": 6, "list": [6, 10, 11], "ani": [6, 12], "metric": 6, "defin": 6, "your": [6, 11], "metastor": 6, "coordin": 6, "squeez": 6, "segment": 6, "pass": 6, "float": 6, "specifi": [6, 11], "shard": 6, "includ": [6, 10], "partit": 6, "minimum": [6, 11], "granular": 6, "abl": 6, "result": 6, "insid": [6, 10], "valu": 6, "minut": 6, "mean": 6, "aggreg": 6, "That": 6, "ar": [6, 11, 12], "collis": 6, "togeth": 6, "store": 6, "individu": [6, 10], "millisecond": 6, "chunk": 6, "multipl": 6, "can": [6, 11, 12], "per": [6, 10], "exampl": [6, 8, 10, 11, 12, 13], "segmentgranular": 6, "event": 6, "fall": 6, "further": 6, "other": 6, "configur": [6, 13], "input": 6, "size": 6, "dict": 6, "addit": 6, "properti": 6, "tblproperti": 6, "stage": 6, "construct_ingest_queri": 6, "static_path": 6, "build": [6, 10, 12], "hdf": 6, "tsv": 6, "path": 6, "where": 6, "avail": [6, 11, 12], "airflow": [8, 12, 13], "dag": [8, 10, 11], "file": [8, 10, 11, 12], "env_id": 8, "dag_id": 8, "example_druid_oper": 8, "submit_job": [8, 13], "test_run": 8, "example_druid_dag": [9, 13], "commit": 10, "chang": 10, "version": [10, 11, 12], "high": 10, "level": 10, "changelog": 10, "see": [10, 11], "inform": [10, 13], "latest": 10, "2022": 10, "07": 10, "29": 10, "subject": 10, "acab8f52dd": 10, "old": [10, 11], "25350": [10, 11], "13": 10, "d2459a241b": 10, "document": [10, 11], "juli": 10, "": [10, 12], "releas": [10, 11], "25030": 10, "46bbfdade0": 10, "class": [10, 11], "24836": [10, 11], "0de31bd73a": 10, "06": 10, "depend": 10, "folder": [10, 12], "24672": 10, "510a6bab45": 10, "28": 10, "remov": [10, 11, 12], "yaml": 10, "24702": 10, "09": [10, 13], "dcdcf3a2b8": 10, "updat": [10, 11], "rc2": 10, "mai": 10, "24307": 10, "717a7588bc": 10, "descript": 10, "doubl": 10, "min": 10, "24292": 10, "aeabe994b3": 10, "prepar": 10, "doc": 10, "24231": 10, "b4a5783a2a": 10, "chore": [10, 11], "refactor": [10, 11], "clean": [10, 11], "24219": [10, 11], "027b707d21": 10, "05": 10, "explanatori": 10, "contributor": 10, "about": [10, 12], "24229": 10, "ddc26c4f3e": 10, "aip": 10, "47": 10, "migrat": [10, 11], "design": 10, "22439": 10, "24207": 10, "03": 10, "22": 10, "d7dbfb7e26": 10, "bugfix": 10, "22383": 10, "14": 10, "16adc035b1": 10, "classifi": [10, 11], "march": 10, "22226": 10, "f5b96315fe": 10, "feb": 10, "22056": 10, "02": [10, 13], "08": 10, "d94fa37830": 10, "fix": 10, "januari": 10, "delai": 10, "21439": 10, "6c3a67d4fc": 10, "2021": [10, 12, 13], "21257": 10, "39e395f981": 10, "04": 10, "field": [10, 11], "21237": [10, 11], "602abe8394": 10, "01": [10, 13], "20": 10, "type": [10, 13], "line": 10, "sphinx": 10, "autoapi": 10, "support": [10, 11], "typehint": 10, "20951": 10, "12": [10, 12], "31": 10, "f77417eb0d": 10, "k8": 10, "pypi": [10, 11], "compat": 10, "20614": 10, "97496ba2b4": 10, "decemb": 10, "20523": 10, "83f8e178ba": 10, "even": 10, "ext": 10, "20608": 10, "d56e7b56bb": 10, "30": 10, "mypi": 10, "friendli": 10, "20571": 10, "485ff6cc64": 10, "error": [10, 11], "20422": 10, "c1bbe3c5bc": 10, "21": 10, "19984": [10, 11], "64a902d3e0": 10, "20270": 10, "11": [10, 12], "853576d901": 10, "novemb": 10, "19882": 10, "5cd8085d27": 10, "19420": [10, 11], "ae044884d1": 10, "cleanup": 10, "start_dat": 10, "default": 10, "18657": 10, "d9567eb106": 10, "10": [10, 11], "octob": 10, "19321": 10, "f8c31b5bf7": 10, "docstr": [10, 11], "18693": [10, 11], "840ea3efb9": 10, "septemb": 10, "18613": 10, "2643345e4b": 10, "26": 10, "guid": [10, 12], "18527": [10, 11], "0a68588479": 10, "august": 10, "17890": 10, "be75dcd39c": 10, "23": 10, "meta": 10, "76ed2a49c6": 10, "19": 10, "import": [10, 11, 12], "lazili": 10, "manag": [10, 12], "17682": 10, "97428efc41": 10, "mess": 10, "up": 10, "17380": 10, "87f408b1e7": 10, "17116": 10, "acb7a9020b": 10, "attribut": [10, 11], "retriev": [10, 11], "17095": [10, 11], "d02ded65ea": 10, "15": 10, "wrongli": 10, "escap": 10, "charact": 10, "amazon": 10, "17020": 10, "b916b75079": 10, "17015": 10, "866a601b76": 10, "pylint": 10, "our": 10, "toolchain": 10, "16682": 10, "18": 10, "bbc627a3da": 10, "16501": 10, "cbf8001d76": 10, "16": 10, "synchron": 10, "after": 10, "buggfix": 10, "16464": 10, "1fba5402bb": 10, "june": 10, "16405": 10, "9c94b72d44": 10, "16294": 10, "476d0f6e3d": 10, "bump": 10, "pyupgrad": 10, "15991": 10, "37681bca00": 10, "auto": [10, 11], "appli": [10, 11], "apply_default": [10, 11], "decor": [10, 11], "15667": [10, 11], "807ad32ce5": 10, "pip": [10, 11, 12], "15576": 10, "40a2476a5d": 10, "15518": 10, "266384a63f": 10, "string": 10, "concaten": 10, "f": 10, "15200": 10, "68e4c4dcb0": 10, "backport": 10, "14886": 10, "b753c7fa60": 10, "ad": [10, 11], "hoc": 10, "four": 10, "previous": 10, "exclud": 10, "14655": 10, "59065400ff": 10, "14418": [10, 11], "589d6dec92": 10, "27": 10, "next": 10, "wave": 10, "14487": 10, "33214d9326": 10, "bigqueri": [10, 11], "qubol": [10, 11], "check": [10, 11, 12], "12677": [10, 11], "88bdcfa0df": 10, "14013": 10, "ac2f72c98d": 10, "implement": 10, "tool": 10, "13767": 10, "a9ac2b040b": 10, "switch": 10, "flynt": 10, "13732": 10, "295d66f914": 10, "2020": 10, "grammar": 10, "warn": [10, 12], "13380": 10, "6cf76d7ac0": 10, "typo": 10, "upgrad": [10, 11], "command": 10, "13148": 10, "5090fb0c89": 10, "script": [10, 12], "integr": 10, "13073": 10, "32971a1a2d": 10, "12955": 10, "b40dffa085": 10, "renam": 10, "rema": 10, "modul": 10, "match": [10, 12], "12917": 10, "c34ef853c8": 10, "separ": 10, "out": 10, "12444": 10, "0080354502": 10, "readm": [10, 11], "0b2": 10, "batch": 10, "12449": 10, "ae7cb4a1e2": 10, "17": 10, "wrong": 10, "hash": 10, "12390": 10, "6889a333cf": 10, "improv": 10, "ref": 10, "12366": 10, "3a72fc8247": 10, "12361": 10, "7825e8f590": 10, "instal": 10, "12304": 10, "dd2095f4a8": 10, "simplifi": 10, "express": 10, "12216": 10, "85a18e13d9": 10, "point": 10, "project": 10, "page": [10, 12], "cross": 10, "12212": 10, "59eb5de78c": 10, "come": 10, "0beta1": 10, "12206": 10, "b2a28d1590": 10, "dev": 10, "12082": 10, "41bf172c1d": 10, "12093": 10, "4e8f9cc8d0": 10, "enabl": 10, "black": 10, "python": [10, 11, 12], "formmatt": 10, "9550": 10, "8c42cf1b00": 10, "6": 10, "11447": 10, "5a439e84eb": 10, "2a1": 10, "11855": 10, "872b1566a1": 10, "25": 10, "setup": 10, "11826": 10, "349b0811c3": 10, "d200": 10, "pydocstyl": 10, "11688": 10, "16e7129719": 10, "11487": 10, "0a0e1af800": 10, "broken": 10, "markdown": 10, "link": [10, 12], "toc": 10, "11249": 10, "ca4238eb4d": 10, "month": 10, "11242": 10, "5220e4c384": 10, "11238": 10, "f3e87c5030": 10, "d202": 10, "11032": 10, "9549274d11": 10, "8b1": 10, "10818": 10, "fdd9b6f65b": 10, "10543": 10, "3696c34c28": 10, "24": 10, "word": 10, "10528": 10, "ee7ca128a1": 10, "refernc": 10, "10483": 10, "7c206a82a6": 10, "assig": 10, "augment": 10, "assign": 10, "10468": 10, "3b3287d7ac": 10, "enforc": 10, "keyword": 10, "onli": [10, 11], "argument": 10, "10170": 10, "33f0cd2657": 10, "keep": 10, "function": 10, "signatur": [10, 11, 12], "9784": 10, "4d74ac2111": 10, "increas": 10, "http": [10, 11, 12], "9729": 10, "d0e7db4024": 10, "fresh": 10, "9408": 10, "12af6a0800": 10, "final": 10, "23rc1": 10, "9404": 10, "c7e5bce57f": 10, "candid": 10, "9370": 10, "f6bd817a3a": 10, "introduc": 10, "9320": 10, "0b0e4f7a4c": 10, "rc3": 10, "relas": 10, "9026": 10, "00642a46d0": 10, "remain": 10, "8994": 10, "375d1ca229": 10, "8898": 10, "12c5e5d8a": 10, "8891": 10, "f3521fb0e3": 10, "regener": 10, "8886": 10, "92585ca4cb": 10, "autom": 10, "8807": 10, "4bde99f132": 10, "make": 10, "7802": 10, "7e6372a681": 10, "call": 10, "super": 10, "7820": 10, "97a429f9d0": 10, "6714": 10, "magic": 10, "comment": 10, "utf": 10, "8": 10, "7338": 10, "057f3ae3a4": 10, "6670": 10, "6669": 10, "contrib": 10, "7286": 10, "086d731ce0": 10, "6510": 10, "7127": 10, "0481b9a957": 10, "6539": 10, "7142": 10, "api": 11, "repositori": 11, "top": [11, 12], "exist": 11, "below": [11, 12, 13], "via": [11, 12], "pydruid": 11, "those": [11, 12], "might": 11, "need": [11, 13], "order": 11, "them": 11, "extra": 11, "verifi": 11, "checksum": [11, 12], "site": 11, "sdist": [11, 12], "asc": [11, 12], "sha512": [11, 12], "wheel": 11, "explain": 11, "polici": 11, "github": 11, "com": [11, 12], "blob": 11, "md": 11, "mistakenli": 11, "install_requir": 11, "22382": 11, "trove": 11, "framework": 11, "optimis": 11, "due": 11, "first": [11, 13], "least": 11, "otherwis": 11, "automat": 11, "manual": 11, "run": [11, 12], "db": 11, "complet": 11, "initi": 11, "describ": 12, "download": 12, "apach": 12, "provid": [12, 13], "druid": 12, "offici": 12, "also": [12, 13], "most": 12, "choos": 12, "differ": 12, "select": 12, "drop": 12, "down": 12, "left": 12, "whl": 12, "origin": 12, "softwar": 12, "foundat": 12, "code": 12, "abov": 12, "how": 12, "pgp": 12, "kei": 12, "It": 12, "essenti": 12, "sha": 12, "gpg": 12, "well": 12, "relev": 12, "distribut": 12, "recommend": 12, "directori": 12, "mirror": 12, "pgpk": 12, "ka": 12, "binari": 12, "follow": 12, "pgpv": 12, "tar": 12, "gz": 12, "made": 12, "sat": 12, "sep": 12, "49": 12, "54": 12, "bst": 12, "rsa": 12, "cde15c6e4d3a8ec4ecf4ba4b6674e08ad7de406f": 12, "issuer": 12, "kaxilnaik": 12, "org": 12, "good": 12, "kaxil": 12, "naik": 12, "unknown": 12, "aka": 12, "gmail": 12, "certifi": 12, "trust": 12, "There": [12, 13], "indic": 12, "belong": 12, "owner": 12, "primari": 12, "fingerprint": 12, "cde1": 12, "5c6e": 12, "4d3a": 12, "8ec4": 12, "ecf4": 12, "ba4b": 12, "6674": 12, "e08a": 12, "d7de": 12, "406f": 12, "correct": 12, "do": 12, "worri": 12, "certif": 12, "self": 12, "sign": 12, "why": 12, "By": 12, "server": 12, "previou": 12, "step": 12, "know": 12, "valid": 12, "alreadi": 12, "sum": 12, "shasum": 12, "512": 12, "diff": 12, "local": 12, "bin": 12, "bash": 12, "package_vers": 12, "package_nam": 12, "provider_download_dir": 12, "mktemp": 12, "d": 12, "dep": 12, "dest": 12, "curl": 12, "apache_airflow_providers_apache_druid": 12, "py3": 12, "l": 12, "o": 12, "echo": 12, "la": 12, "onc": 12, "instruct": 12, "chapter": 12, "temporari": 12, "content": 13, "definit": 13, "take": 13, "look": 13, "test": 13, "system": 13, "py": 13, "task_id": 13, "spark_submit_job": 13, "json_index": 13, "json_index_str": 13, "index_hadoop": 13, "datasource_prd": 13, "spec": 13, "dataschema": 13, "granularityspec": 13}, "objects": {"airflow.providers.apache": [[2, 0, 0, "-", "druid"]], "airflow.providers.apache.druid": [[1, 0, 0, "-", "hooks"], [5, 0, 0, "-", "operators"], [7, 0, 0, "-", "transfers"]], "airflow.providers.apache.druid.hooks": [[0, 0, 0, "-", "druid"]], "airflow.providers.apache.druid.hooks.druid": [[0, 1, 1, "", "DruidDbApiHook"], [0, 1, 1, "", "DruidHook"]], "airflow.providers.apache.druid.hooks.druid.DruidDbApiHook": [[0, 2, 1, "", "conn_name_attr"], [0, 2, 1, "", "conn_type"], [0, 2, 1, "", "default_conn_name"], [0, 3, 1, "", "get_conn"], [0, 3, 1, "", "get_uri"], [0, 2, 1, "", "hook_name"], [0, 3, 1, "", "insert_rows"], [0, 3, 1, "", "set_autocommit"], [0, 2, 1, "", "supports_autocommit"]], "airflow.providers.apache.druid.hooks.druid.DruidHook": [[0, 3, 1, "", "get_auth"], [0, 3, 1, "", "get_conn_url"], [0, 3, 1, "", "submit_indexing_job"]], "airflow.providers.apache.druid.operators": [[3, 0, 0, "-", "druid"], [4, 0, 0, "-", "druid_check"]], "airflow.providers.apache.druid.operators.druid": [[3, 1, 1, "", "DruidOperator"]], "airflow.providers.apache.druid.operators.druid.DruidOperator": [[3, 3, 1, "", "execute"], [3, 2, 1, "", "template_ext"], [3, 2, 1, "", "template_fields"], [3, 2, 1, "", "template_fields_renderers"]], "airflow.providers.apache.druid.operators.druid_check": [[4, 1, 1, "", "DruidCheckOperator"]], "airflow.providers.apache.druid.transfers": [[6, 0, 0, "-", "hive_to_druid"]], "airflow.providers.apache.druid.transfers.hive_to_druid": [[6, 4, 1, "", "DEFAULT_TARGET_PARTITION_SIZE"], [6, 1, 1, "", "HiveToDruidOperator"], [6, 4, 1, "", "LOAD_CHECK_INTERVAL"]], "airflow.providers.apache.druid.transfers.hive_to_druid.HiveToDruidOperator": [[6, 3, 1, "", "construct_ingest_query"], [6, 3, 1, "", "execute"], [6, 2, 1, "", "template_ext"], [6, 2, 1, "", "template_fields"], [6, 2, 1, "", "template_fields_renderers"]], "tests.system.providers.apache": [[9, 0, 0, "-", "druid"]], "tests.system.providers.apache.druid": [[8, 0, 0, "-", "example_druid_dag"]], "tests.system.providers.apache.druid.example_druid_dag": [[8, 4, 1, "", "DAG_ID"], [8, 4, 1, "", "ENV_ID"], [8, 4, 1, "", "submit_job"], [8, 4, 1, "", "test_run"]]}, "objtypes": {"0": "py:module", "1": "py:class", "2": "py:attribute", "3": "py:method", "4": "py:data"}, "objnames": {"0": ["py", "module", "Python module"], "1": ["py", "class", "Python class"], "2": ["py", "attribute", "Python attribute"], "3": ["py", "method", "Python method"], "4": ["py", "data", "Python data"]}, "titleterms": {"airflow": [0, 1, 2, 3, 4, 5, 6, 7, 10, 11], "provid": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11], "apach": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 13], "druid": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 13], "hook": [0, 1], "modul": [0, 3, 4, 6, 8], "content": [0, 3, 4, 6, 8, 11], "class": [0, 3, 4, 6], "submodul": [1, 5, 7, 9], "subpackag": 2, "oper": [3, 4, 5, 13], "druid_check": 4, "transfer": [6, 7], "hive_to_druid": 6, "attribut": 6, "test": [8, 9], "system": [8, 9], "example_druid_dag": 8, "packag": [10, 11, 12], "3": [10, 11], "2": [10, 11], "0": [10, 11], "1": [10, 11], "guid": 11, "refer": [11, 13], "resourc": 11, "commit": 11, "instal": [11, 12], "requir": 11, "cross": 11, "depend": 11, "download": 11, "offici": 11, "changelog": 11, "featur": 11, "break": 11, "chang": 11, "misc": 11, "bug": 11, "fix": 11, "bugfix": 11, "from": 12, "sourc": 12, "releas": 12, "integr": 12, "verifi": 12, "pypi": 12, "prerequisit": 13, "druidoper": 13, "us": 13}, "envversion": {"sphinx.domains.c": 2, "sphinx.domains.changeset": 1, "sphinx.domains.citation": 1, "sphinx.domains.cpp": 6, "sphinx.domains.index": 1, "sphinx.domains.javascript": 2, "sphinx.domains.math": 2, "sphinx.domains.python": 3, "sphinx.domains.rst": 2, "sphinx.domains.std": 2, "sphinx.ext.viewcode": 1, "sphinx.ext.intersphinx": 1, "sphinx": 56}})