acoustic-carpenter-78188
11/02/2023, 9:27 PMtask = BlazingSQL(
input_schema=FlyteSchema,
outputs=...,
query=""" SELECT count(*) FROM taxi GROUP BY year(key)""",
use_gpus=False, # True by default
)
Type of Plugin
☑︎ Python/Java interface only plugin
☐ Web Service (e.g. AWS Sagemaker, GCP DataFlow, Qubole etc...)
☐ Kubernetes Operator (e.g. TfOperator, SparkOperator, FlinkK8sOperator, etc...)
☐ Customized Plugin using native kubernetes constructs
☐ Other
flyteorg/flyteacoustic-carpenter-78188
11/02/2023, 9:27 PM