Configure Job Clusters in Rift
When defining a
Batch Feature View or
a
Stream Feature View
using Rift, you
can set the batch_compute
parameter using the
RiftBatchConfig
object.
This configures the instance type of the job used to materialize to the online and/or offline store. This must be set to a valid EC2 instance type.
Example​
from tecton import batch_feature_view, RiftBatchConfig
@batch_feature_view(
batch_compute=RiftBatchConfig(
instance_type="m5.2xlarge",
),
...,
)
def my_feature_view():
return ...