The page you navigated to () does not exist, so we brought you to the closest page to it.
You have switched from the to the variant of this site. There is no equivalent of . We have taken you to the closest page in the variant.
1.16.16
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
Parameters
class HiveQuery(
query,
timeout_sec,
retry_count,
)Initializes a new HiveQuery.
| Parameter | Type | Description |
|---|---|---|
query |
||
timeout_sec |
||
retry_count |
Properties
| Property | Type | Description |
|---|---|---|
is_empty |
None |
|
query |
None |
The query string. |
retry_count |
None |
|
timeout_sec |
None |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
|
to_flyte_idl() |
from_flyte_idl()
def from_flyte_idl(
pb2_object,
)| Parameter | Type | Description |
|---|---|---|
pb2_object |
Returns: HiveQuery
serialize_to_string()
def serialize_to_string()short_string()
def short_string()Returns: Text
to_flyte_idl()
def to_flyte_idl()Returns: _qubole.HiveQuery
flytekit.models.qubole.HiveQueryCollection
Parameters
class HiveQueryCollection(
queries,
)Initializes a new HiveQueryCollection.
| Parameter | Type | Description |
|---|---|---|
queries |
Properties
| Property | Type | Description |
|---|---|---|
is_empty |
None |
|
queries |
None |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
|
to_flyte_idl() |
from_flyte_idl()
def from_flyte_idl(
pb2_object,
)| Parameter | Type | Description |
|---|---|---|
pb2_object |
Returns: HiveQueryCollection
serialize_to_string()
def serialize_to_string()short_string()
def short_string()Returns: Text
to_flyte_idl()
def to_flyte_idl()Returns: _qubole.HiveQueryCollection
flytekit.models.qubole.QuboleHiveJob
Parameters
class QuboleHiveJob(
query,
cluster_label,
tags,
query_collection,
)Initializes a HiveJob.
| Parameter | Type | Description |
|---|---|---|
query |
||
cluster_label |
||
tags |
||
query_collection |
Properties
| Property | Type | Description |
|---|---|---|
cluster_label |
None |
The cluster label where the query should be executed |
is_empty |
None |
|
query |
None |
The query to be executed |
query_collection |
None |
The queries to be executed |
tags |
None |
User tags for the queries |
Methods
| Method | Description |
|---|---|
from_flyte_idl() |
|
serialize_to_string() |
|
short_string() |
|
to_flyte_idl() |
from_flyte_idl()
def from_flyte_idl(
p,
)| Parameter | Type | Description |
|---|---|---|
p |
Returns: QuboleHiveJob
serialize_to_string()
def serialize_to_string()short_string()
def short_string()Returns: Text
to_flyte_idl()
def to_flyte_idl()Returns: _qubole.QuboleHiveJob