| Search.setIndex({"docnames": ["_api/airflow/providers/trino/hooks/index", "_api/airflow/providers/trino/hooks/trino/index", "_api/airflow/providers/trino/index", "_api/airflow/providers/trino/operators/index", "_api/airflow/providers/trino/operators/trino/index", "_api/airflow/providers/trino/transfers/gcs_to_trino/index", "_api/airflow/providers/trino/transfers/index", "_api/tests/system/providers/trino/example_gcs_to_trino/index", "_api/tests/system/providers/trino/example_trino/index", "_api/tests/system/providers/trino/index", "changelog", "commits", "connections", "index", "installing-providers-from-sources", "operators/index", "operators/transfer/gcs_to_trino", "operators/trino", "security"], "filenames": ["_api/airflow/providers/trino/hooks/index.rst", "_api/airflow/providers/trino/hooks/trino/index.rst", "_api/airflow/providers/trino/index.rst", "_api/airflow/providers/trino/operators/index.rst", "_api/airflow/providers/trino/operators/trino/index.rst", "_api/airflow/providers/trino/transfers/gcs_to_trino/index.rst", "_api/airflow/providers/trino/transfers/index.rst", "_api/tests/system/providers/trino/example_gcs_to_trino/index.rst", "_api/tests/system/providers/trino/example_trino/index.rst", "_api/tests/system/providers/trino/index.rst", "changelog.rst", "commits.rst", "connections.rst", "index.rst", "installing-providers-from-sources.rst", "operators/index.rst", "operators/transfer/gcs_to_trino.rst", "operators/trino.rst", "security.rst"], "titles": ["<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.trino.hooks</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.trino.hooks.trino</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.trino</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.trino.operators</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.trino.operators.trino</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.trino.transfers.gcs_to_trino</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">airflow.providers.trino.transfers</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.trino.example_gcs_to_trino</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.trino.example_trino</span></code>", "<code class=\"xref py py-mod docutils literal notranslate\"><span class=\"pre\">tests.system.providers.trino</span></code>", "Changelog", "Package apache-airflow-providers-trino", "Apache Trino Connection", "<code class=\"docutils literal notranslate\"><span class=\"pre\">apache-airflow-providers-trino</span></code>", "Installing from sources", "Trino operator", "Google Cloud Storage to Trino Transfer Operator", "TrinoOperator", "Releasing security patches"], "terms": {"5": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 12, 13, 14, 15, 16, 17, 18], "4": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 12, 13, 14, 15, 16, 17, 18], "0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 12, 13, 14, 15, 16, 17, 18], "2": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 12, 13, 14, 15, 16, 17, 18], "8": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "dev0": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "thi": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "i": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "an": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "experiment": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18], "featur": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 11, 12, 13, 14, 15, 16, 17, 18], "t": 1, "sourc": [1, 2, 4, 5, 7, 8, 12, 16, 17], "generate_trino_client_info": 1, "return": 1, "json": [1, 5, 12, 16], "string": [1, 4, 5, 11, 16, 17], "dag_id": [1, 7, 17], "task_id": [1, 16, 17], "execution_d": 1, "try_numb": 1, "except": [1, 10, 11, 18], "trinoexcept": 1, "base": [1, 4, 5], "trinohook": [1, 10, 11], "arg": 1, "schema": [1, 5, 8, 16, 17], "none": [1, 5, 12, 14], "log_sql": 1, "true": [1, 12], "kwarg": [1, 4, 5], "common": [1, 4, 10, 11, 13], "sql": [1, 4, 10, 11, 12, 13, 16, 17], "dbapihook": [1, 10, 11], "interact": [1, 5, 16], "through": 1, "packag": [1, 10], "ph": 1, "select": [1, 14, 17], "count": 1, "1": [1, 5, 12, 13, 17], "AS": 1, "num": 1, "from": [1, 5, 10, 11, 13, 17, 18], "static_babynam": 1, "get_record": [1, 10, 11], "340698": 1, "conn_name_attr": 1, "trino_conn_id": [1, 4, 5, 12, 17], "default_conn_nam": 1, "trino_default": [1, 4, 5, 12], "conn_typ": 1, "hook_nam": 1, "query_id": 1, "placehold": [1, 10, 11], "get_conn": 1, "connect": [1, 4, 5, 10, 11, 17], "object": [1, 5], "get_isolation_level": 1, "isol": 1, "level": [1, 11], "paramet": [1, 4, 5, 10, 11, 12, 17], "execut": [1, 4, 5, 17], "set": [1, 4, 5, 11, 12], "record": 1, "str": [1, 4, 5], "list": [1, 4, 5, 11, 12, 16, 17], "statement": [1, 4], "iter": [1, 5], "map": 1, "ani": [1, 4, 5, 14, 17], "The": [1, 4, 5, 12, 13, 14, 18], "render": [1, 4, 5], "queri": [1, 4, 10, 11, 12, 16, 17], "get_first": [1, 10, 11], "first": [1, 5, 10], "result": [1, 4], "row": 1, "get_pandas_df": [1, 10], "panda": [1, 10, 11, 13], "datafram": 1, "option": [1, 4, 5, 12, 16], "pass": [1, 10, 11, 12, 17], "io": 1, "read_sql": 1, "method": [1, 4, 10, 11], "insert_row": 1, "tabl": [1, 5, 8, 17], "target_field": 1, "commit_everi": 1, "replac": [1, 11], "fals": [1, 17], "A": [1, 16], "gener": 1, "wai": 1, "insert": [1, 17], "tupl": [1, 16], "name": [1, 5, 11], "target": [1, 4], "column": [1, 5, 16], "fill": [1, 5], "int": 1, "maximum": 1, "number": 1, "one": [1, 12, 14], "transact": 1, "all": [1, 10, 11, 12, 13, 16, 18], "bool": 1, "whether": 1, "instead": [1, 10], "get_openlineage_database_info": 1, "specif": [1, 4, 11], "inform": [1, 4, 11, 18], "openlineag": [1, 10, 11, 13], "get_openlineage_database_dialect": 1, "_": 1, "dialect": 1, "get_openlineage_default_schema": 1, "default": [1, 18], "hook": [2, 10, 11, 12], "oper": [2, 5, 10, 11], "transfer": 2, "gcs_to_trino": [2, 6], "__version__": [2, 11], "contain": [4, 5, 12, 14], "trinooper": [4, 8, 10, 11, 15], "sqlexecutequeryoper": [4, 10, 11], "code": [4, 10, 11, 14], "us": [4, 5, 7, 8, 10, 11, 12, 13, 14, 16, 18], "engin": [4, 12, 16, 17], "deprec": [4, 10, 11], "pleas": [4, 14], "For": [4, 11, 13, 14], "more": [4, 5, 10, 11, 12], "how": [4, 14], "take": [4, 12], "look": 4, "guid": [4, 14], "singl": [4, 16], "refer": [4, 5, 11], "templat": [4, 5], "file": [4, 5, 10, 11, 12, 14, 16], "id": [4, 5, 14], "config": 4, "environ": 4, "autocommit": 4, "what": 4, "": [4, 10, 11, 14], "befor": 4, "handler": [4, 17], "which": [4, 5, 10, 11, 12, 18], "call": 4, "each": 4, "template_field": [4, 5], "sequenc": [4, 5], "template_fields_render": 4, "template_ext": 4, "ui_color": 4, "eded": 4, "on_kil": [4, 10, 11], "overrid": [4, 10, 11, 17], "clean": 4, "up": [4, 11], "subprocess": 4, "when": [4, 5, 12, 13, 18], "task": [4, 10, 11], "instanc": [4, 17], "get": [4, 5, 14, 18], "kill": [4, 10, 11], "thread": 4, "multiprocess": 4, "within": 4, "need": [4, 12, 13, 17], "leav": 4, "ghost": 4, "process": 4, "behind": 4, "googl": [5, 13], "cloud": 5, "storag": 5, "gcstotrinooper": [5, 7, 10, 11, 16], "source_bucket": [5, 16], "source_object": [5, 16], "trino_t": [5, 7, 16], "gcp_conn_id": 5, "google_cloud_default": 5, "schema_field": 5, "schema_object": 5, "impersonation_chain": [5, 10], "model": [5, 17, 18], "baseoper": 5, "load": 5, "csv": 5, "assumpt": 5, "should": [5, 12, 14, 18], "have": [5, 10, 16, 18], "header": [5, 11, 16], "requisit": 5, "alreadi": [5, 14], "creat": [5, 14, 17], "3": [5, 13, 17], "separ": [5, 12, 18], "can": [5, 10, 12, 13, 14, 16, 17, 18], "gc": [5, 10], "bucket": [5, 7, 16], "includ": [5, 11, 16, 18], "path": [5, 12, 16], "upload": 5, "data": [5, 11, 12, 16], "destin": 5, "servic": [5, 16], "If": [5, 10, 12, 14], "field": 5, "account": 5, "imperson": [5, 10, 11], "short": 5, "term": 5, "credenti": 5, "chain": 5, "requir": [5, 10, 12, 18], "access_token": 5, "last": 5, "request": 5, "must": 5, "grant": 5, "origin": [5, 14], "token": [5, 10, 11, 12], "creator": 5, "iam": 5, "role": 5, "ident": 5, "directli": 5, "preced": [5, 12], "context": 5, "deriv": 5, "same": [5, 16], "dictionari": [5, 12], "jinja": 5, "get_template_context": 5, "exampl": [7, 8, 11, 12, 13, 14, 17], "dag": [7, 8, 11, 17], "path_to_fil": [7, 16], "env_id": 7, "gcs_csv_to_trino_t": [7, 16], "test_run": [7, 8], "hive": [8, 16], "citi": [8, 17], "table1": [8, 17], "city1": 8, "table2": [8, 17], "city2": 8, "trino_create_schema": [8, 17], "example_gcs_to_trino": [9, 16], "example_trino": [9, 17], "apach": [10, 14], "airflow": [10, 14, 18], "provid": [10, 14, 16, 17, 18], "trino": [10, 14, 17], "releas": [10, 11, 13], "onli": [10, 18], "avail": [10, 14], "explain": 10, "support": [10, 11, 12, 13], "polici": [10, 18], "bump": [10, 11], "min": [10, 11], "version": [10, 11, 13, 14, 18], "34728": [10, 11], "airflowexcept": [10, 11], "34511": [10, 11], "improv": [10, 11], "modul": [10, 11], "import": [10, 11, 14], "some": [10, 11], "them": [10, 11, 13], "type": [10, 11, 12], "check": [10, 11, 14], "block": [10, 11], "33754": [10, 11], "add": [10, 11], "32910": [10, 11], "consolid": [10, 11], "usag": [10, 11, 17], "33480": [10, 11], "accur": [10, 11], "run": [10, 11, 14, 16, 17], "31846": [10, 11], "info": [10, 11], "class": [10, 11, 13], "docstr": [10, 11], "32536": [10, 11], "abil": [10, 11], "read": [10, 11], "jwt": [10, 11, 12], "31950": [10, 11], "drop": [10, 11, 14], "python": [10, 11, 12, 13, 14], "7": [10, 11], "note": [10, 11, 12], "about": [10, 11, 14, 18], "32015": [10, 11], "minimum": [10, 11, 13], "30917": [10, 11], "In": 10, "param": [10, 11, 17], "delegate_to": [10, 11], "remov": [10, 11, 14], "gcstoprestooper": 10, "achiev": 10, "util": 10, "gcp": [10, 11], "30748": [10, 11], "updat": [10, 11], "doc": [10, 11], "29088": [10, 11], "outdat": [10, 11], "compat": [10, 11], "28507": [10, 11], "_serialize_cel": [10, 11], "prestohook": [10, 11], "27724": [10, 11], "27888": [10, 11], "move": [10, 11], "27196": [10, 11], "non": [10, 11], "work": [10, 11], "dml": [10, 11], "27168": [10, 11], "25717": [10, 11], "certificateauthent": [10, 11], "26246": [10, 11], "lower": [10, 11], "bound": [10, 11], "25789": [10, 11], "sqlitehook": [10, 11], "25939": [10, 11], "hql": [10, 11], "ha": [10, 16], "been": 10, "synchron": [10, 11], "api": [10, 11], "25299": [10, 11], "unifi": [10, 11], "23971": [10, 11], "24836": [10, 11], "test_connect": [10, 11], "24583": [10, 11], "24559": [10, 11], "24415": [10, 11], "authent": [10, 11, 12], "via": [10, 11, 12, 13, 14], "23116": [10, 11], "make": [10, 11], "presto": [10, 11, 16], "23061": [10, 11], "x": [10, 11], "client": [10, 11, 12], "22535": [10, 11], "mistakenli": 10, "ad": 10, "install_requir": 10, "22382": 10, "trove": 10, "classifi": [10, 11], "pypi": [10, 11, 13, 18], "framework": 10, "21704": [10, 11], "10": [10, 11], "properli": [10, 11], "handl": [10, 11], "verifi": [10, 11, 13], "18791": [10, 11], "optimis": 10, "auto": 10, "appli": [10, 11], "apply_default": 10, "decor": 10, "15667": 10, "due": 10, "your": [10, 16, 17], "you": [10, 13, 14, 16, 18], "want": [10, 14, 18], "instal": [10, 18], "upgrad": [10, 18], "least": 10, "otherwis": 10, "automat": 10, "manual": 10, "db": 10, "complet": 10, "migrat": [10, 11], "initi": 10, "detail": [11, 14], "commit": 11, "chang": [11, 18], "high": 11, "changelog": 11, "see": [11, 13], "latest": [11, 18], "2023": 11, "05": 11, "subject": 11, "0c8e30e43b": 11, "659d94f0ae": 11, "09": 11, "21": 11, "08": 11, "21990ed894": 11, "prepar": [11, 18], "1st": 11, "wave": 11, "34201": 11, "9d8c77e447": 11, "27": 11, "26": 11, "c077d19060": 11, "aug": 11, "3rd": 11, "33730": 11, "626d3daa9b": 11, "24": 11, "8e88eb8fa7": 11, "17": [11, 13], "07": 11, "29": 11, "d06b7af69a": 11, "juli": 11, "32875": 11, "60c49ab2df": 11, "19": 11, "e01323635a": 11, "13": 11, "21e8f878a3": 11, "06": 11, "d205": 11, "snowflak": 11, "zendesk": 11, "inclus": 11, "32359": 11, "225e3041d2": 11, "rc2": 11, "32381": 11, "3878fe6fab": 11, "spuriou": 11, "32373": 11, "cb4927a018": 11, "32298": 11, "09d4718d3a": 11, "document": 11, "readm": 11, "structur": 11, "32125": 11, "371833e076": 11, "20": 11, "79bcc2e668": 11, "rc1": 11, "june": 11, "32001": 11, "8b146152d6": 11, "a59076eae": 11, "02": 11, "d400": 11, "pydocstyl": 11, "31427": 11, "45548b9451": 11, "mai": 11, "31416": 11, "abea189022": 11, "18": 11, "31393": 11, "f5aed58d9f": 11, "fix": [11, 18], "circular": 11, "error": 11, "caus": 11, "31379": 11, "d9ff55cf6d": 11, "16": 11, "31252": 11, "0a30706aa7": 11, "03": 11, "airflowproviderdeprecationwarn": 11, "30975": 11, "eef5bc7f16": 11, "full": 11, "autom": 11, "30994": 11, "a7eb32a5b2": 11, "04": 11, "30": 11, "e46ce78b66": 11, "adhoc": 11, "30787": 11, "fbc1382514": 11, "d23a3bbed8": 11, "mechan": [11, 12], "suspend": 11, "30422": 11, "ce6ae2457": 11, "feb": 11, "29379": 11, "3374fdfcbd": 11, "01": 11, "23": 11, "5246c009c5": 11, "jan": 11, "28651": 11, "38e40c6dc4": 11, "2022": [11, 17], "12": [11, 14], "11": [11, 14], "25bdbc8e67": 11, "rc3": 11, "27937": 11, "2e20e9f7eb": 11, "follow": [11, 12, 14, 17, 18], "relas": 11, "novemb": 11, "27774": 11, "80c327bd3b": 11, "e56adc8e41": 11, "15": 11, "12c3c39d1a": 11, "27613": 11, "a3bfa25e67": 11, "allow": [11, 12, 16], "tag": [11, 12, 17], "27213": 11, "5c37b503f1": 11, "31": 11, "26944": 11, "09c045f081": 11, "78b8ea2f22": 11, "2a34dc9e84": 11, "enabl": [11, 12], "normal": 11, "format": 11, "27205": 11, "17b97e755a": 11, "session": 11, "properti": 11, "27095": 11, "ecd4d6654f": 11, "28": 11, "f8db64c35c": 11, "septemb": 11, "26731": 11, "b2766d0515": 11, "06acf40a43": 11, "pep": 11, "563": 11, "postpon": 11, "evalu": 11, "annot": 11, "core": 11, "26289": 11, "25d0baa4e": 11, "bug": [11, 18], "out": [11, 12, 18], "band": [11, 18], "26109": 11, "a74d934991": 11, "ca9229b6f": 11, "e5ac6c7cfb": 11, "new": [11, 18], "august": 11, "25618": 11, "5d4abbd58c": 11, "df00436569": 11, "22": 11, "d2459a241b": 11, "25030": 11, "46bbfdade0": 11, "0de31bd73a": 11, "depend": [11, 18], "insid": 11, "folder": [11, 14], "24672": 11, "510a6bab45": 11, "yaml": 11, "24702": 11, "122d2f69bb": 11, "4f4f37c855": 11, "865406cbab": 11, "dcdcf3a2b8": 11, "24307": 11, "717a7588bc": 11, "descript": 11, "doubl": 11, "24292": 11, "aeabe994b3": 11, "24231": 11, "027b707d21": 11, "explanatori": 11, "contributor": 11, "24229": 11, "7489962e75": 11, "aip": 11, "47": 11, "design": [11, 12], "24118": 11, "75c60923e0": 11, "23631": 11, "ccb5ce934c": 11, "8b6b0848a3": 11, "brees": 11, "build": [11, 14], "pull": 11, "imag": 11, "23104": 11, "5164cdbe98": 11, "6933022e94": 11, "mypi": 11, "main": [11, 14, 18], "22884": 11, "56ab82ed7a": 11, "mid": 11, "april": 11, "22819": 11, "0c30564992": 11, "d7dbfb7e26": 11, "bugfix": [11, 18], "22383": 11, "14": 11, "16adc035b1": 11, "march": 11, "22226": 11, "f5b96315fe": 11, "22056": 11, "942f8fd657": 11, "2807193594": 11, "21630": 11, "1884f2227d": 11, "21479": 11, "d94fa37830": 11, "januari": 11, "delai": 11, "21439": 11, "6c3a67d4fc": 11, "2021": [11, 14], "21257": 11, "602abe8394": 11, "line": 11, "now": 11, "sphinx": 11, "autoapi": 11, "typehint": 11, "20951": 11, "f77417eb0d": 11, "k8": 11, "20614": 11, "97496ba2b4": 11, "decemb": 11, "20523": 11, "dad2f8103b": 11, "20190": 11, "d9567eb106": 11, "octob": 11, "19321": 11, "6bc0f87755": 11, "0a68588479": 11, "17890": 11, "be75dcd39c": 11, "meta": 11, "76ed2a49c6": 11, "lazili": 11, "individu": 11, "manag": [11, 14], "17682": 11, "87f408b1e7": 11, "17116": 11, "b916b75079": 11, "17015": 11, "866a601b76": 11, "pylint": 11, "our": 11, "toolchain": 11, "16682": 11, "bbc627a3da": 11, "16501": 11, "cbf8001d76": 11, "after": 11, "buggfix": 11, "16464": 11, "1fba5402bb": 11, "16405": 11, "9c94b72d44": 11, "16294": 11, "eae22cec9c": 11, "memori": 11, "footprint": 11, "test": [11, 16, 17, 18], "15187": 11, "distribut": [12, 14, 16], "larg": [12, 16], "over": 12, "heterogen": 12, "valu": [12, 17], "multipl": [12, 16, 17], "ensur": 12, "user": [12, 14], "system": [12, 16, 17], "ar": [12, 13, 14, 18], "auth": 12, "host": 12, "local": [12, 14], "yarn": 12, "url": 12, "port": 12, "specifi": [12, 13], "case": [12, 18], "login": 12, "effect": 12, "password": 12, "basic": 12, "differ": [12, 14], "extra": [12, 13], "standard": 12, "cert": 12, "kerbero": 12, "impersonate_as_own": 12, "boolean": 12, "airflow_ctx_dag_own": 12, "jwt__token": 12, "given": 12, "jwt__file": 12, "locat": [12, 17], "disk": 12, "certs__client_cert_path": 12, "certs__client_key_path": 12, "certif": [12, 14], "kei": [12, 14], "kerberos__service_nam": 12, "kerberos__config": 12, "kerberos__mutual_authent": 12, "kerberos__force_preempt": 12, "kerberos__hostname_overrid": 12, "kerberos__sanitize_mutual_error_respons": 12, "kerberos__princip": 12, "kerberos__deleg": 12, "kerberos__ca_bundl": 12, "These": 12, "session_properti": 12, "scale_writ": 12, "task_writer_count": 12, "client_tag": 12, "comma": 12, "sale": 12, "cluster1": 12, "both": 12, "top": [13, 14], "exist": [13, 16, 17], "below": [13, 14], "pip": [13, 14], "318": 13, "those": [13, 14], "might": [13, 18], "order": 13, "checksum": [13, 14], "signatur": [13, 14], "site": 13, "sdist": [13, 14], "asc": [13, 14], "sha512": [13, 14], "wheel": 13, "page": 14, "describ": 14, "download": 14, "offici": 14, "also": 14, "most": 14, "choos": 14, "down": 14, "left": 14, "whl": 14, "softwar": 14, "foundat": 14, "link": 14, "abov": 14, "pgp": 14, "It": 14, "essenti": 14, "sha": 14, "gpg": 14, "well": 14, "relev": 14, "recommend": 14, "directori": 14, "mirror": 14, "pgpk": 14, "ka": 14, "To": [14, 16], "binari": 14, "pgpv": 14, "tar": 14, "gz": 14, "made": 14, "sat": 14, "sep": 14, "49": 14, "54": 14, "bst": 14, "rsa": 14, "cde15c6e4d3a8ec4ecf4ba4b6674e08ad7de406f": 14, "issuer": 14, "kaxilnaik": 14, "org": 14, "good": [14, 18], "kaxil": 14, "naik": 14, "unknown": 14, "aka": 14, "gmail": 14, "com": 14, "warn": 14, "certifi": 14, "trust": 14, "There": 14, "indic": 14, "belong": 14, "owner": 14, "primari": 14, "fingerprint": 14, "cde1": 14, "5c6e": 14, "4d3a": 14, "8ec4": 14, "ecf4": 14, "ba4b": 14, "6674": 14, "e08a": 14, "d7de": 14, "406f": 14, "correct": [14, 17], "do": 14, "worri": 14, "self": 14, "sign": 14, "why": 14, "By": 14, "server": 14, "previou": 14, "step": 14, "know": 14, "valid": 14, "sum": 14, "shasum": 14, "512": 14, "diff": 14, "match": [14, 17], "script": 14, "bin": 14, "bash": 14, "package_vers": 14, "package_nam": 14, "provider_download_dir": 14, "mktemp": 14, "d": 14, "dep": 14, "dest": 14, "curl": 14, "http": 14, "apache_airflow_providers_trino": 14, "py3": 14, "l": 14, "o": 14, "echo": 14, "la": 14, "onc": [14, 17], "instruct": [14, 18], "chapter": 14, "temporari": 14, "store": 16, "variou": 16, "applic": 16, "open": 16, "fast": 16, "analyt": 16, "against": 16, "size": 16, "rang": 16, "gigabyt": 16, "petabyt": 16, "where": [16, 17, 18], "live": 16, "cassandra": 16, "relat": 16, "databas": 16, "even": 16, "proprietari": 16, "combin": 16, "across": 16, "entir": 16, "organ": 16, "assum": 16, "doe": 16, "correspond": 16, "pre": 16, "py": [16, 17], "command": 17, "argument": 17, "schedul": 17, "start_dat": 17, "datetim": 17, "catchup": 17, "f": 17, "IF": 17, "NOT": 17, "WITH": 17, "s3": 17, "irisbkt": 17, "trino_create_t": 17, "cityid": 17, "bigint": 17, "citynam": 17, "varchar": 17, "trino_insert": 17, "INTO": 17, "san": 17, "francisco": 17, "trino_multiple_queri": 17, "jose": 17, "diego": 17, "trino_templated_queri": 17, "trino_parameterized_queri": 17, "syntact": 17, "either": 17, "independ": 18, "itself": 18, "vulner": 18, "publish": 18, "found": 18, "we": 18, "develop": 18, "alwai": 18, "done": 18, "branch": 18, "next": 18, "strict": 18, "semver": 18, "scope": 18, "major": 18, "break": 18, "minor": 18, "patchlevel": 18, "receiv": 18, "so": 18, "rule": 18, "critic": 18, "reason": 18, "stakehold": 18, "decid": 18, "cherri": 18, "pick": 18, "older": 18, "mix": 18, "govern": 18, "interest": 18, "parti": 18}, "objects": {"airflow.providers": [[2, 0, 0, "-", "trino"]], "airflow.providers.trino": [[2, 1, 1, "", "__version__"], [0, 0, 0, "-", "hooks"], [3, 0, 0, "-", "operators"], [6, 0, 0, "-", "transfers"]], "airflow.providers.trino.hooks": [[1, 0, 0, "-", "trino"]], "airflow.providers.trino.hooks.trino": [[1, 1, 1, "", "T"], [1, 2, 1, "", "TrinoException"], [1, 3, 1, "", "TrinoHook"], [1, 6, 1, "", "generate_trino_client_info"]], "airflow.providers.trino.hooks.trino.TrinoHook": [[1, 4, 1, "", "conn_name_attr"], [1, 4, 1, "", "conn_type"], [1, 4, 1, "", "default_conn_name"], [1, 5, 1, "", "get_conn"], [1, 5, 1, "", "get_first"], [1, 5, 1, "", "get_isolation_level"], [1, 5, 1, "", "get_openlineage_database_dialect"], [1, 5, 1, "", "get_openlineage_database_info"], [1, 5, 1, "", "get_openlineage_default_schema"], [1, 5, 1, "", "get_pandas_df"], [1, 5, 1, "", "get_records"], [1, 4, 1, "", "hook_name"], [1, 5, 1, "", "insert_rows"], [1, 4, 1, "", "placeholder"], [1, 4, 1, "", "query_id"]], "airflow.providers.trino.operators": [[4, 0, 0, "-", "trino"]], "airflow.providers.trino.operators.trino": [[4, 3, 1, "", "TrinoOperator"]], "airflow.providers.trino.operators.trino.TrinoOperator": [[4, 5, 1, "", "on_kill"], [4, 4, 1, "", "template_ext"], [4, 4, 1, "", "template_fields"], [4, 4, 1, "", "template_fields_renderers"], [4, 4, 1, "", "ui_color"]], "airflow.providers.trino.transfers": [[5, 0, 0, "-", "gcs_to_trino"]], "airflow.providers.trino.transfers.gcs_to_trino": [[5, 3, 1, "", "GCSToTrinoOperator"]], "airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator": [[5, 5, 1, "", "execute"], [5, 4, 1, "", "template_fields"]], "tests.system.providers": [[9, 0, 0, "-", "trino"]], "tests.system.providers.trino": [[7, 0, 0, "-", "example_gcs_to_trino"], [8, 0, 0, "-", "example_trino"]], "tests.system.providers.trino.example_gcs_to_trino": [[7, 1, 1, "", "BUCKET"], [7, 1, 1, "", "DAG_ID"], [7, 1, 1, "", "ENV_ID"], [7, 1, 1, "", "PATH_TO_FILE"], [7, 1, 1, "", "TRINO_TABLE"], [7, 1, 1, "", "gcs_csv_to_trino_table"], [7, 1, 1, "", "test_run"]], "tests.system.providers.trino.example_trino": [[8, 1, 1, "", "SCHEMA"], [8, 1, 1, "", "TABLE"], [8, 1, 1, "", "TABLE1"], [8, 1, 1, "", "TABLE2"], [8, 1, 1, "", "test_run"], [8, 1, 1, "", "trino_create_schema"]]}, "objtypes": {"0": "py:module", "1": "py:data", "2": "py:exception", "3": "py:class", "4": "py:attribute", "5": "py:method", "6": "py:function"}, "objnames": {"0": ["py", "module", "Python module"], "1": ["py", "data", "Python data"], "2": ["py", "exception", "Python exception"], "3": ["py", "class", "Python class"], "4": ["py", "attribute", "Python attribute"], "5": ["py", "method", "Python method"], "6": ["py", "function", "Python function"]}, "titleterms": {"airflow": [0, 1, 2, 3, 4, 5, 6, 11, 13], "provid": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 11, 13], "trino": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 11, 12, 13, 15, 16], "hook": [0, 1], "submodul": [0, 3, 6, 9], "modul": [1, 4, 5, 7, 8], "content": [1, 2, 4, 5, 7, 8], "class": [1, 4, 5], "function": 1, "attribut": 1, "subpackag": 2, "packag": [2, 11, 13, 14], "oper": [3, 4, 15, 16, 17], "transfer": [5, 6, 16], "gcs_to_trino": 5, "test": [7, 8, 9], "system": [7, 8, 9], "example_gcs_to_trino": 7, "example_trino": 8, "changelog": 10, "5": [10, 11], "4": [10, 11], "0": [10, 11], "misc": 10, "3": [10, 11], "1": [10, 11], "featur": 10, "2": [10, 11], "break": 10, "chang": 10, "bug": 10, "fix": 10, "apach": [11, 12, 13], "connect": 12, "default": 12, "id": 12, "configur": 12, "instal": [13, 14], "requir": 13, "cross": 13, "depend": 13, "download": 13, "offici": 13, "from": [14, 16], "sourc": 14, "releas": [14, 18], "integr": 14, "verifi": 14, "pypi": 14, "googl": 16, "cloud": 16, "storag": 16, "load": 16, "csv": 16, "gc": 16, "tabl": 16, "trinooper": 17, "us": 17, "secur": 18, "patch": 18}, "envversion": {"sphinx.domains.c": 2, "sphinx.domains.changeset": 1, "sphinx.domains.citation": 1, "sphinx.domains.cpp": 8, "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": 57}, "alltitles": {"airflow.providers.trino.hooks": [[0, "module-airflow.providers.trino.hooks"]], "Submodules": [[0, "submodules"], [3, "submodules"], [6, "submodules"], [9, "submodules"]], "airflow.providers.trino.hooks.trino": [[1, "module-airflow.providers.trino.hooks.trino"]], "Module Contents": [[1, "module-contents"], [4, "module-contents"], [5, "module-contents"], [7, "module-contents"], [8, "module-contents"]], "Classes": [[1, "classes"], [4, "classes"], [5, "classes"]], "Functions": [[1, "functions"]], "Attributes": [[1, "attributes"]], "airflow.providers.trino": [[2, "module-airflow.providers.trino"]], "Subpackages": [[2, "subpackages"]], "Package Contents": [[2, "package-contents"]], "airflow.providers.trino.operators": [[3, "module-airflow.providers.trino.operators"]], "airflow.providers.trino.operators.trino": [[4, "module-airflow.providers.trino.operators.trino"]], "airflow.providers.trino.transfers.gcs_to_trino": [[5, "module-airflow.providers.trino.transfers.gcs_to_trino"]], "airflow.providers.trino.transfers": [[6, "module-airflow.providers.trino.transfers"]], "tests.system.providers.trino.example_gcs_to_trino": [[7, "module-tests.system.providers.trino.example_gcs_to_trino"]], "tests.system.providers.trino.example_trino": [[8, "module-tests.system.providers.trino.example_trino"]], "tests.system.providers.trino": [[9, "module-tests.system.providers.trino"]], "Changelog": [[10, "changelog"]], "5.4.0": [[10, "id1"], [11, "id1"]], "Misc": [[10, "misc"], [10, "id3"], [10, "id5"], [10, "id7"], [10, "id11"], [10, "id14"], [10, "id17"], [10, "id19"], [10, "id24"], [10, "id47"], [10, "id50"], [10, "id54"]], "5.3.1": [[10, "id2"], [11, "id2"]], "5.3.0": [[10, "id4"], [11, "id3"]], "Features": [[10, "features"], [10, "id9"], [10, "id21"], [10, "id25"], [10, "id27"], [10, "id29"], [10, "id33"], [10, "id35"], [10, "id40"], [10, "id43"], [10, "id49"]], "5.2.1": [[10, "id6"], [11, "id4"]], "5.2.0": [[10, "id8"], [11, "id5"]], "5.1.1": [[10, "id10"], [11, "id6"]], "5.1.0": [[10, "id12"], [11, "id7"]], "5.0.0": [[10, "id15"], [11, "id8"]], "Breaking changes": [[10, "breaking-changes"], [10, "id32"], [10, "id37"], [10, "id56"]], "4.3.2": [[10, "id16"], [11, "id9"]], "4.3.1": [[10, "id18"], [11, "id10"]], "4.3.0": [[10, "id20"], [11, "id11"]], "Bug Fixes": [[10, "bug-fixes"], [10, "id30"], [10, "id41"], [10, "id45"], [10, "id52"]], "4.2.0": [[10, "id22"], [11, "id12"]], "4.1.0": [[10, "id26"], [11, "id13"]], "4.0.1": [[10, "id28"], [11, "id14"]], "4.0.0": [[10, "id31"], [11, "id15"]], "3.1.0": [[10, "id34"], [11, "id16"]], "3.0.0": [[10, "id36"], [11, "id17"]], "2.3.0": [[10, "id39"], [11, "id18"]], "2.2.0": [[10, "id42"], [11, "id19"]], "2.1.2": [[10, "id44"], [11, "id20"]], "2.1.1": [[10, "id46"], [11, "id21"]], "2.1.0": [[10, "id48"], [11, "id22"]], "2.0.2": [[10, "id51"], [11, "id24"]], "2.0.1": [[10, "id53"], [11, "id25"]], "2.0.0": [[10, "id55"], [11, "id26"]], "1.0.0": [[10, "id57"], [11, "id27"]], "Package apache-airflow-providers-trino": [[11, "package-apache-airflow-providers-trino"], [13, "package-apache-airflow-providers-trino"]], "Apache Trino Connection": [[12, "apache-trino-connection"]], "Default Connection IDs": [[12, "default-connection-ids"]], "Configuring the Connection": [[12, "configuring-the-connection"]], "apache-airflow-providers-trino": [[13, "apache-airflow-providers-trino"]], "Provider package": [[13, "provider-package"]], "Installation": [[13, "installation"]], "Requirements": [[13, "requirements"]], "Cross provider package dependencies": [[13, "cross-provider-package-dependencies"]], "Downloading official packages": [[13, "downloading-official-packages"]], "Installing from sources": [[14, "installing-from-sources"]], "Released packages": [[14, "released-packages"]], "Release integrity": [[14, "release-integrity"]], "Verifying PyPI releases": [[14, "verifying-pypi-releases"]], "Trino operator": [[15, "trino-operator"]], "Google Cloud Storage to Trino Transfer Operator": [[16, "google-cloud-storage-to-trino-transfer-operator"]], "Load CSV from GCS to Trino Table": [[16, "load-csv-from-gcs-to-trino-table"]], "TrinoOperator": [[17, "trinooperator"]], "Using the Operator": [[17, "using-the-operator"]], "Releasing security patches": [[18, "releasing-security-patches"]]}, "indexentries": {"airflow.providers.trino.hooks": [[0, "module-airflow.providers.trino.hooks"]], "module": [[0, "module-airflow.providers.trino.hooks"], [1, "module-airflow.providers.trino.hooks.trino"], [2, "module-airflow.providers.trino"], [3, "module-airflow.providers.trino.operators"], [4, "module-airflow.providers.trino.operators.trino"], [5, "module-airflow.providers.trino.transfers.gcs_to_trino"], [6, "module-airflow.providers.trino.transfers"], [7, "module-tests.system.providers.trino.example_gcs_to_trino"], [8, "module-tests.system.providers.trino.example_trino"], [9, "module-tests.system.providers.trino"]], "t (in module airflow.providers.trino.hooks.trino)": [[1, "airflow.providers.trino.hooks.trino.T"]], "trinoexception": [[1, "airflow.providers.trino.hooks.trino.TrinoException"]], "trinohook (class in airflow.providers.trino.hooks.trino)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook"]], "airflow.providers.trino.hooks.trino": [[1, "module-airflow.providers.trino.hooks.trino"]], "conn_name_attr (airflow.providers.trino.hooks.trino.trinohook attribute)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.conn_name_attr"]], "conn_type (airflow.providers.trino.hooks.trino.trinohook attribute)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.conn_type"]], "default_conn_name (airflow.providers.trino.hooks.trino.trinohook attribute)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.default_conn_name"]], "generate_trino_client_info() (in module airflow.providers.trino.hooks.trino)": [[1, "airflow.providers.trino.hooks.trino.generate_trino_client_info"]], "get_conn() (airflow.providers.trino.hooks.trino.trinohook method)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.get_conn"]], "get_first() (airflow.providers.trino.hooks.trino.trinohook method)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.get_first"]], "get_isolation_level() (airflow.providers.trino.hooks.trino.trinohook method)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.get_isolation_level"]], "get_openlineage_database_dialect() (airflow.providers.trino.hooks.trino.trinohook method)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.get_openlineage_database_dialect"]], "get_openlineage_database_info() (airflow.providers.trino.hooks.trino.trinohook method)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.get_openlineage_database_info"]], "get_openlineage_default_schema() (airflow.providers.trino.hooks.trino.trinohook method)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.get_openlineage_default_schema"]], "get_pandas_df() (airflow.providers.trino.hooks.trino.trinohook method)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.get_pandas_df"]], "get_records() (airflow.providers.trino.hooks.trino.trinohook method)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.get_records"]], "hook_name (airflow.providers.trino.hooks.trino.trinohook attribute)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.hook_name"]], "insert_rows() (airflow.providers.trino.hooks.trino.trinohook method)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.insert_rows"]], "placeholder (airflow.providers.trino.hooks.trino.trinohook attribute)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.placeholder"]], "query_id (airflow.providers.trino.hooks.trino.trinohook attribute)": [[1, "airflow.providers.trino.hooks.trino.TrinoHook.query_id"]], "__version__ (in module airflow.providers.trino)": [[2, "airflow.providers.trino.__version__"]], "airflow.providers.trino": [[2, "module-airflow.providers.trino"]], "airflow.providers.trino.operators": [[3, "module-airflow.providers.trino.operators"]], "trinooperator (class in airflow.providers.trino.operators.trino)": [[4, "airflow.providers.trino.operators.trino.TrinoOperator"]], "airflow.providers.trino.operators.trino": [[4, "module-airflow.providers.trino.operators.trino"]], "on_kill() (airflow.providers.trino.operators.trino.trinooperator method)": [[4, "airflow.providers.trino.operators.trino.TrinoOperator.on_kill"]], "template_ext (airflow.providers.trino.operators.trino.trinooperator attribute)": [[4, "airflow.providers.trino.operators.trino.TrinoOperator.template_ext"]], "template_fields (airflow.providers.trino.operators.trino.trinooperator attribute)": [[4, "airflow.providers.trino.operators.trino.TrinoOperator.template_fields"]], "template_fields_renderers (airflow.providers.trino.operators.trino.trinooperator attribute)": [[4, "airflow.providers.trino.operators.trino.TrinoOperator.template_fields_renderers"]], "ui_color (airflow.providers.trino.operators.trino.trinooperator attribute)": [[4, "airflow.providers.trino.operators.trino.TrinoOperator.ui_color"]], "gcstotrinooperator (class in airflow.providers.trino.transfers.gcs_to_trino)": [[5, "airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator"]], "airflow.providers.trino.transfers.gcs_to_trino": [[5, "module-airflow.providers.trino.transfers.gcs_to_trino"]], "execute() (airflow.providers.trino.transfers.gcs_to_trino.gcstotrinooperator method)": [[5, "airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator.execute"]], "template_fields (airflow.providers.trino.transfers.gcs_to_trino.gcstotrinooperator attribute)": [[5, "airflow.providers.trino.transfers.gcs_to_trino.GCSToTrinoOperator.template_fields"]], "airflow.providers.trino.transfers": [[6, "module-airflow.providers.trino.transfers"]], "bucket (in module tests.system.providers.trino.example_gcs_to_trino)": [[7, "tests.system.providers.trino.example_gcs_to_trino.BUCKET"]], "dag_id (in module tests.system.providers.trino.example_gcs_to_trino)": [[7, "tests.system.providers.trino.example_gcs_to_trino.DAG_ID"]], "env_id (in module tests.system.providers.trino.example_gcs_to_trino)": [[7, "tests.system.providers.trino.example_gcs_to_trino.ENV_ID"]], "path_to_file (in module tests.system.providers.trino.example_gcs_to_trino)": [[7, "tests.system.providers.trino.example_gcs_to_trino.PATH_TO_FILE"]], "trino_table (in module tests.system.providers.trino.example_gcs_to_trino)": [[7, "tests.system.providers.trino.example_gcs_to_trino.TRINO_TABLE"]], "gcs_csv_to_trino_table (in module tests.system.providers.trino.example_gcs_to_trino)": [[7, "tests.system.providers.trino.example_gcs_to_trino.gcs_csv_to_trino_table"]], "test_run (in module tests.system.providers.trino.example_gcs_to_trino)": [[7, "tests.system.providers.trino.example_gcs_to_trino.test_run"]], "tests.system.providers.trino.example_gcs_to_trino": [[7, "module-tests.system.providers.trino.example_gcs_to_trino"]], "schema (in module tests.system.providers.trino.example_trino)": [[8, "tests.system.providers.trino.example_trino.SCHEMA"]], "table (in module tests.system.providers.trino.example_trino)": [[8, "tests.system.providers.trino.example_trino.TABLE"]], "table1 (in module tests.system.providers.trino.example_trino)": [[8, "tests.system.providers.trino.example_trino.TABLE1"]], "table2 (in module tests.system.providers.trino.example_trino)": [[8, "tests.system.providers.trino.example_trino.TABLE2"]], "test_run (in module tests.system.providers.trino.example_trino)": [[8, "tests.system.providers.trino.example_trino.test_run"]], "tests.system.providers.trino.example_trino": [[8, "module-tests.system.providers.trino.example_trino"]], "trino_create_schema (in module tests.system.providers.trino.example_trino)": [[8, "tests.system.providers.trino.example_trino.trino_create_schema"]], "tests.system.providers.trino": [[9, "module-tests.system.providers.trino"]]}}) |