0.1.dev2184+g1e0cbe7.d20250401
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
| Class | Description |
|---|---|
HiveQuery |
|
HiveQueryCollection |
|
QuboleHiveJob |
flytekit.models.qubole.HiveQuery
class HiveQuery(
query,
timeout_sec,
retry_count,
)Initializes a new HiveQuery.
| Parameter | Type |
|---|---|
query |
|
timeout_sec |
|
retry_count |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
. |
serialize_to_string() |
|
short_string() |
:rtype: Text. |
to_flyte_idl() |
:rtype: _qubole. |
verbose_string() |
:rtype: Text. |
from_flyte_idl()
def from_flyte_idl(
pb2_object,
) -> n: HiveQuery| Parameter | Type |
|---|---|
pb2_object |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl():rtype: _qubole.HiveQuery
verbose_string()
def verbose_string():rtype: Text
Properties
| Property | Type | Description |
|---|---|---|
is_empty |
||
query |
The query string. :rtype: str |
|
retry_count |
:rtype: int |
|
timeout_sec |
:rtype: int |
flytekit.models.qubole.HiveQueryCollection
class HiveQueryCollection(
queries,
)Initializes a new HiveQueryCollection.
| Parameter | Type |
|---|---|
queries |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
. |
serialize_to_string() |
|
short_string() |
:rtype: Text. |
to_flyte_idl() |
:rtype: _qubole. |
verbose_string() |
:rtype: Text. |
from_flyte_idl()
def from_flyte_idl(
pb2_object,
) -> e: HiveQueryCollection| Parameter | Type |
|---|---|
pb2_object |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl():rtype: _qubole.HiveQueryCollection
verbose_string()
def verbose_string():rtype: Text
Properties
| Property | Type | Description |
|---|---|---|
is_empty |
||
queries |
:rtype: list[HiveQuery] |
flytekit.models.qubole.QuboleHiveJob
class QuboleHiveJob(
query,
cluster_label,
tags,
query_collection,
)Initializes a HiveJob.
| Parameter | Type |
|---|---|
query |
|
cluster_label |
|
tags |
|
query_collection |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
. |
serialize_to_string() |
|
short_string() |
:rtype: Text. |
to_flyte_idl() |
:rtype: _qubole. |
verbose_string() |
:rtype: Text. |
from_flyte_idl()
def from_flyte_idl(
p,
) -> e: QuboleHiveJob| Parameter | Type |
|---|---|
p |
serialize_to_string()
def serialize_to_string()short_string()
def short_string():rtype: Text
to_flyte_idl()
def to_flyte_idl():rtype: _qubole.QuboleHiveJob
verbose_string()
def verbose_string():rtype: Text
Properties
| Property | Type | Description |
|---|---|---|
cluster_label |
The cluster label where the query should be executed :rtype: Text |
|
is_empty |
||
query |
The query to be executed :rtype: HiveQuery |
|
query_collection |
The queries to be executed :rtype: HiveQueryCollection |
|
tags |
User tags for the queries :rtype: list[Text] |