1.16.20
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