flytekit.models.qubole

This is a deprecated module. Model files for plugins should go alongside the microlib. See plugins/flytekit-kf-pytorch/flytekitplugins/kfpytorch/models.py as an example.

Directory

Classes

flytekit.models.qubole.HiveQuery

def HiveQuery(
    query,
    timeout_sec,
    retry_count,
):

Initializes a new HiveQuery.

Methods

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
):

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

to_flyte_idl()

def to_flyte_idl()

verbose_string()

def verbose_string()

Properties

flytekit.models.qubole.HiveQueryCollection

def HiveQueryCollection(
    queries,
):

Initializes a new HiveQueryCollection.

Methods

from_flyte_idl()

def from_flyte_idl(
    pb2_object,
):

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

to_flyte_idl()

def to_flyte_idl()

verbose_string()

def verbose_string()

Properties

flytekit.models.qubole.QuboleHiveJob

def QuboleHiveJob(
    query,
    cluster_label,
    tags,
    query_collection,
):

Initializes a HiveJob.

Methods

from_flyte_idl()

def from_flyte_idl(
    p,
):

serialize_to_string()

def serialize_to_string()

short_string()

def short_string()

to_flyte_idl()

def to_flyte_idl()

verbose_string()

def verbose_string()

Properties