Feast Spark SDK
latest
Feast Spark SDK
»
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
R
|
S
|
T
|
U
|
W
A
add_HealthServicer_to_server() (in module feast_spark.third_party.grpc.health.v1.HealthService_pb2_grpc)
add_job() (feast_spark.pyspark.launchers.standalone.local.JobCache method)
add_JobServiceServicer_to_server() (in module feast_spark.api.JobService_pb2_grpc)
B
batch_ingestion (feast_spark.api.JobService_pb2.Job attribute)
BATCH_INGESTION (feast_spark.pyspark.abc.SparkJobType attribute)
BatchIngestionJob (class in feast_spark.pyspark.abc)
BatchIngestionJobParameters (class in feast_spark.pyspark.abc)
BIGTABLE_INSTANCE (feast_spark.constants.ConfigOptions attribute)
BIGTABLE_PROJECT (feast_spark.constants.ConfigOptions attribute)
block_polling() (feast_spark.pyspark.launchers.gcloud.dataproc.DataprocJobMixin method)
BQ_STAGING_DATASET (feast_spark.constants.ConfigOptions attribute)
BQ_STAGING_PROJECT (feast_spark.constants.ConfigOptions attribute)
C
cancel() (feast_spark.pyspark.abc.SparkJob method)
(feast_spark.pyspark.launchers.aws.emr.EmrJobMixin method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocJobMixin method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobMixin method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterJobMixin method)
(feast_spark.remote_job.RemoteJobMixin method)
CancelJob() (feast_spark.api.JobService_pb2_grpc.JobService static method)
(feast_spark.api.JobService_pb2_grpc.JobServiceServicer method)
(feast_spark.job_service.JobServiceServicer method)
CancelJobRequest (class in feast_spark.api.JobService_pb2)
CancelJobResponse (class in feast_spark.api.JobService_pb2)
CASSANDRA_HOST (feast_spark.constants.ConfigOptions attribute)
CASSANDRA_PORT (feast_spark.constants.ConfigOptions attribute)
Check() (feast_spark.job_service.HealthServicerImpl method)
(feast_spark.third_party.grpc.health.v1.HealthService_pb2_grpc.Health static method)
(feast_spark.third_party.grpc.health.v1.HealthService_pb2_grpc.HealthServicer method)
check_if_started() (feast_spark.pyspark.launchers.standalone.local.StandaloneClusterJobMixin method)
CHECKPOINT_PATH (feast_spark.constants.ConfigOptions attribute)
Client (class in feast_spark)
(class in feast_spark.client)
,
[1]
cluster_id (feast_spark.pyspark.launchers.aws.emr_utils.EmrJobRef property)
COMPLETED (feast_spark.pyspark.abc.SparkJobStatus attribute)
config (feast_spark.Client property)
(feast_spark.client.Client property)
,
[1]
ConfigOptions (class in feast_spark.constants)
cron_schedule (feast_spark.api.JobService_pb2.ScheduleOfflineToOnlineIngestionJobRequest attribute)
D
dataproc_cancel() (feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher method)
DATAPROC_CLUSTER_NAME (feast_spark.constants.ConfigOptions attribute)
DATAPROC_EXECUTOR_CORES (feast_spark.constants.ConfigOptions attribute)
DATAPROC_EXECUTOR_INSTANCES (feast_spark.constants.ConfigOptions attribute)
DATAPROC_EXECUTOR_MEMORY (feast_spark.constants.ConfigOptions attribute)
DATAPROC_PROJECT (feast_spark.constants.ConfigOptions attribute)
DATAPROC_REGION (feast_spark.constants.ConfigOptions attribute)
dataproc_submit() (feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher method)
DataprocBatchIngestionJob (class in feast_spark.pyspark.launchers.gcloud.dataproc)
DataprocClusterLauncher (class in feast_spark.pyspark.launchers.gcloud)
(class in feast_spark.pyspark.launchers.gcloud.dataproc)
DataprocJobMixin (class in feast_spark.pyspark.launchers.gcloud.dataproc)
DataprocRetrievalJob (class in feast_spark.pyspark.launchers.gcloud)
(class in feast_spark.pyspark.launchers.gcloud.dataproc)
DataprocStreamingIngestionJob (class in feast_spark.pyspark.launchers.gcloud.dataproc)
DEADLETTER_PATH (feast_spark.constants.ConfigOptions attribute)
defaults() (feast_spark.constants.ConfigOptions method)
DESCRIPTOR (feast_spark.api.JobService_pb2.CancelJobRequest attribute)
(feast_spark.api.JobService_pb2.CancelJobResponse attribute)
(feast_spark.api.JobService_pb2.GetHealthMetricsRequest attribute)
(feast_spark.api.JobService_pb2.GetHealthMetricsResponse attribute)
(feast_spark.api.JobService_pb2.GetHistoricalFeaturesRequest attribute)
(feast_spark.api.JobService_pb2.GetHistoricalFeaturesResponse attribute)
(feast_spark.api.JobService_pb2.GetJobRequest attribute)
(feast_spark.api.JobService_pb2.GetJobResponse attribute)
(feast_spark.api.JobService_pb2.Job attribute)
(feast_spark.api.JobService_pb2.Job.OfflineToOnlineMeta attribute)
(feast_spark.api.JobService_pb2.Job.RetrievalJobMeta attribute)
(feast_spark.api.JobService_pb2.Job.StreamToOnlineMeta attribute)
(feast_spark.api.JobService_pb2.ListJobsRequest attribute)
(feast_spark.api.JobService_pb2.ListJobsResponse attribute)
(feast_spark.api.JobService_pb2.ScheduleOfflineToOnlineIngestionJobRequest attribute)
(feast_spark.api.JobService_pb2.ScheduleOfflineToOnlineIngestionJobResponse attribute)
(feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobRequest attribute)
(feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobResponse attribute)
(feast_spark.api.JobService_pb2.StartStreamToOnlineIngestionJobRequest attribute)
(feast_spark.api.JobService_pb2.StartStreamToOnlineIngestionJobResponse attribute)
(feast_spark.api.JobService_pb2.UnscheduleOfflineToOnlineIngestionJobRequest attribute)
(feast_spark.api.JobService_pb2.UnscheduleOfflineToOnlineIngestionJobResponse attribute)
(feast_spark.third_party.grpc.health.v1.HealthService_pb2.HealthCheckRequest attribute)
(feast_spark.third_party.grpc.health.v1.HealthService_pb2.HealthCheckResponse attribute)
E
EMR_CLUSTER_ID (feast_spark.constants.ConfigOptions attribute)
EMR_CLUSTER_TEMPLATE_PATH (feast_spark.constants.ConfigOptions attribute)
EMR_LOG_LOCATION (feast_spark.constants.ConfigOptions attribute)
EMR_REGION (feast_spark.constants.ConfigOptions attribute)
EmrBatchIngestionJob (class in feast_spark.pyspark.launchers.aws)
(class in feast_spark.pyspark.launchers.aws.emr)
EmrClusterLauncher (class in feast_spark.pyspark.launchers.aws)
(class in feast_spark.pyspark.launchers.aws.emr)
EmrJobMixin (class in feast_spark.pyspark.launchers.aws.emr)
EmrJobRef (class in feast_spark.pyspark.launchers.aws.emr_utils)
EmrRetrievalJob (class in feast_spark.pyspark.launchers.aws)
(class in feast_spark.pyspark.launchers.aws.emr)
EmrStreamIngestionJob (class in feast_spark.pyspark.launchers.aws)
(class in feast_spark.pyspark.launchers.aws.emr)
end_date (feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobRequest attribute)
ensure_stream_ingestion_jobs() (in module feast_spark.job_service)
entity_source (feast_spark.api.JobService_pb2.GetHistoricalFeaturesRequest attribute)
error_message (feast_spark.api.JobService_pb2.Job attribute)
EXTERNAL_JARS (feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher attribute)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher attribute)
extra_metadata (feast_spark.pyspark.launchers.k8s.k8s_utils.JobInfo property)
F
failed (feast_spark.api.JobService_pb2.GetHealthMetricsResponse attribute)
FAILED (feast_spark.pyspark.abc.SparkJobStatus attribute)
feast_spark
module
feast_spark.api
module
feast_spark.api.JobService_pb2
module
feast_spark.api.JobService_pb2_grpc
module
feast_spark.cli
module
feast_spark.client
module
,
[1]
feast_spark.constants
module
feast_spark.contrib
module
feast_spark.contrib.validation
module
feast_spark.job_service
module
feast_spark.pyspark
module
feast_spark.pyspark.abc
module
feast_spark.pyspark.launcher
module
feast_spark.pyspark.launchers
module
feast_spark.pyspark.launchers.aws
module
feast_spark.pyspark.launchers.aws.emr
module
feast_spark.pyspark.launchers.aws.emr_utils
module
feast_spark.pyspark.launchers.gcloud
module
feast_spark.pyspark.launchers.gcloud.dataproc
module
feast_spark.pyspark.launchers.k8s
module
feast_spark.pyspark.launchers.k8s.k8s
module
feast_spark.pyspark.launchers.k8s.k8s_utils
module
feast_spark.pyspark.launchers.standalone
module
feast_spark.pyspark.launchers.standalone.local
module
feast_spark.remote_job
module
feast_spark.third_party
module
feast_spark.third_party.grpc
module
feast_spark.third_party.grpc.health
module
feast_spark.third_party.grpc.health.v1
module
feast_spark.third_party.grpc.health.v1.HealthService_pb2
module
feast_spark.third_party.grpc.health.v1.HealthService_pb2_grpc
module
feature_refs (feast_spark.api.JobService_pb2.GetHistoricalFeaturesRequest attribute)
feature_store (feast_spark.Client property)
(feast_spark.client.Client property)
,
[1]
FEATURE_TABLE_LABEL_KEY (feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher attribute)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher attribute)
G
get_arguments() (feast_spark.pyspark.abc.BatchIngestionJobParameters method)
(feast_spark.pyspark.abc.IngestionJobParameters method)
(feast_spark.pyspark.abc.RetrievalJobParameters method)
(feast_spark.pyspark.abc.ScheduledBatchIngestionJobParameters method)
(feast_spark.pyspark.abc.SparkJobParameters method)
(feast_spark.pyspark.abc.StreamIngestionJobParameters method)
get_class_name() (feast_spark.pyspark.abc.IngestionJobParameters method)
(feast_spark.pyspark.abc.SparkJobParameters method)
get_destination_path() (feast_spark.pyspark.abc.RetrievalJobParameters method)
get_error_message() (feast_spark.pyspark.abc.SparkJob method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocJobMixin method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobMixin method)
(feast_spark.remote_job.RemoteJobMixin method)
get_extra_jar_paths() (feast_spark.pyspark.abc.StreamIngestionJobParameters method)
get_extra_packages() (feast_spark.pyspark.abc.RetrievalJobParameters method)
(feast_spark.pyspark.abc.SparkJobParameters method)
get_feature_table() (feast_spark.pyspark.abc.BatchIngestionJob method)
(feast_spark.pyspark.abc.StreamIngestionJob method)
(feast_spark.pyspark.launchers.aws.emr.EmrBatchIngestionJob method)
(feast_spark.pyspark.launchers.aws.emr.EmrStreamIngestionJob method)
(feast_spark.pyspark.launchers.aws.EmrBatchIngestionJob method)
(feast_spark.pyspark.launchers.aws.EmrStreamIngestionJob method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocBatchIngestionJob method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocStreamingIngestionJob method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesBatchIngestionJob method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesStreamIngestionJob method)
(feast_spark.pyspark.launchers.k8s.KubernetesBatchIngestionJob method)
(feast_spark.pyspark.launchers.k8s.KubernetesStreamIngestionJob method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterBatchIngestionJob method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterStreamingIngestionJob method)
(feast_spark.remote_job.RemoteBatchIngestionJob method)
(feast_spark.remote_job.RemoteStreamIngestionJob method)
get_feature_table_name() (feast_spark.pyspark.abc.IngestionJobParameters method)
get_hash() (feast_spark.pyspark.abc.StreamIngestionJob method)
(feast_spark.pyspark.launchers.aws.emr.EmrStreamIngestionJob method)
(feast_spark.pyspark.launchers.aws.EmrStreamIngestionJob method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocStreamingIngestionJob method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesStreamIngestionJob method)
(feast_spark.pyspark.launchers.k8s.KubernetesStreamIngestionJob method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterStreamingIngestionJob method)
(feast_spark.remote_job.RemoteStreamIngestionJob method)
get_health_metrics() (feast_spark.Client method)
(feast_spark.client.Client method)
,
[1]
(in module feast_spark.pyspark.launcher)
get_historical_features() (feast_spark.Client method)
(feast_spark.client.Client method)
,
[1]
get_historical_features_df() (feast_spark.Client method)
(feast_spark.client.Client method)
,
[1]
get_id() (feast_spark.pyspark.abc.SparkJob method)
(feast_spark.pyspark.launchers.aws.emr.EmrJobMixin method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocJobMixin method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobMixin method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterJobMixin method)
(feast_spark.remote_job.RemoteJobMixin method)
get_job_by_id() (feast_spark.Client method)
(feast_spark.client.Client method)
,
[1]
(feast_spark.pyspark.abc.JobLauncher method)
(feast_spark.pyspark.launchers.aws.emr.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.aws.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.standalone.local.JobCache method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterLauncher method)
(feast_spark.pyspark.launchers.standalone.StandaloneClusterLauncher method)
(in module feast_spark.pyspark.launcher)
get_job_hash() (feast_spark.pyspark.abc.StreamIngestionJobParameters method)
get_job_schedule() (feast_spark.pyspark.abc.ScheduledBatchIngestionJobParameters method)
get_job_type() (feast_spark.pyspark.abc.BatchIngestionJobParameters method)
(feast_spark.pyspark.abc.RetrievalJobParameters method)
(feast_spark.pyspark.abc.ScheduledBatchIngestionJobParameters method)
(feast_spark.pyspark.abc.SparkJobParameters method)
(feast_spark.pyspark.abc.StreamIngestionJobParameters method)
get_log_uri() (feast_spark.pyspark.abc.SparkJob method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocJobMixin method)
(feast_spark.remote_job.RemoteJobMixin method)
get_main_file_path() (feast_spark.pyspark.abc.IngestionJobParameters method)
(feast_spark.pyspark.abc.RetrievalJobParameters method)
(feast_spark.pyspark.abc.SparkJobParameters method)
get_name() (feast_spark.pyspark.abc.BatchIngestionJobParameters method)
(feast_spark.pyspark.abc.RetrievalJobParameters method)
(feast_spark.pyspark.abc.ScheduledBatchIngestionJobParameters method)
(feast_spark.pyspark.abc.SparkJobParameters method)
(feast_spark.pyspark.abc.StreamIngestionJobParameters method)
get_output_file_uri() (feast_spark.pyspark.abc.RetrievalJob method)
(feast_spark.pyspark.launchers.aws.emr.EmrRetrievalJob method)
(feast_spark.pyspark.launchers.aws.EmrRetrievalJob method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocRetrievalJob method)
(feast_spark.pyspark.launchers.gcloud.DataprocRetrievalJob method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesRetrievalJob method)
(feast_spark.pyspark.launchers.k8s.KubernetesRetrievalJob method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterRetrievalJob method)
(feast_spark.pyspark.launchers.standalone.StandaloneClusterRetrievalJob method)
(feast_spark.remote_job.RemoteRetrievalJob method)
get_project() (feast_spark.pyspark.abc.IngestionJobParameters method)
(feast_spark.pyspark.abc.RetrievalJobParameters method)
(feast_spark.pyspark.launchers.aws.emr.EmrBatchIngestionJob method)
(feast_spark.pyspark.launchers.aws.EmrBatchIngestionJob method)
get_remote_job_from_proto() (in module feast_spark.remote_job)
get_start_time() (feast_spark.pyspark.abc.SparkJob method)
(feast_spark.pyspark.launchers.aws.emr.EmrJobMixin method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocJobMixin method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobMixin method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterJobMixin method)
(feast_spark.remote_job.RemoteJobMixin method)
get_status() (feast_spark.pyspark.abc.SparkJob method)
(feast_spark.pyspark.launchers.aws.emr.EmrJobMixin method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocJobMixin method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobMixin method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterJobMixin method)
(feast_spark.remote_job.RemoteJobMixin method)
get_stream_to_online_ingestion_params() (in module feast_spark.pyspark.launcher)
GetHealthMetrics() (feast_spark.api.JobService_pb2_grpc.JobService static method)
(feast_spark.api.JobService_pb2_grpc.JobServiceServicer method)
(feast_spark.job_service.JobServiceServicer method)
GetHealthMetricsRequest (class in feast_spark.api.JobService_pb2)
GetHealthMetricsResponse (class in feast_spark.api.JobService_pb2)
GetHistoricalFeatures() (feast_spark.api.JobService_pb2_grpc.JobService static method)
(feast_spark.api.JobService_pb2_grpc.JobServiceServicer method)
(feast_spark.job_service.JobServiceServicer method)
GetHistoricalFeaturesRequest (class in feast_spark.api.JobService_pb2)
GetHistoricalFeaturesResponse (class in feast_spark.api.JobService_pb2)
GetJob() (feast_spark.api.JobService_pb2_grpc.JobService static method)
(feast_spark.api.JobService_pb2_grpc.JobServiceServicer method)
(feast_spark.job_service.JobServiceServicer method)
GetJobRequest (class in feast_spark.api.JobService_pb2)
GetJobResponse (class in feast_spark.api.JobService_pb2)
H
hash (feast_spark.api.JobService_pb2.Job attribute)
hash_by_id (feast_spark.pyspark.launchers.standalone.local.JobCache attribute)
Health (class in feast_spark.third_party.grpc.health.v1.HealthService_pb2_grpc)
HealthCheckRequest (class in feast_spark.third_party.grpc.health.v1.HealthService_pb2)
HealthCheckResponse (class in feast_spark.third_party.grpc.health.v1.HealthService_pb2)
HealthServicer (class in feast_spark.third_party.grpc.health.v1.HealthService_pb2_grpc)
HealthServicerImpl (class in feast_spark.job_service)
HealthStub (class in feast_spark.third_party.grpc.health.v1.HealthService_pb2_grpc)
HISTORICAL_FEATURE_OUTPUT_FORMAT (feast_spark.constants.ConfigOptions attribute)
HISTORICAL_FEATURE_OUTPUT_LOCATION (feast_spark.constants.ConfigOptions attribute)
historical_feature_retrieval() (feast_spark.pyspark.abc.JobLauncher method)
(feast_spark.pyspark.launchers.aws.emr.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.aws.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterLauncher method)
(feast_spark.pyspark.launchers.standalone.StandaloneClusterLauncher method)
HISTORICAL_RETRIEVAL (feast_spark.pyspark.abc.SparkJobType attribute)
I
id (feast_spark.api.JobService_pb2.GetHistoricalFeaturesResponse attribute)
(feast_spark.api.JobService_pb2.Job attribute)
(feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobResponse attribute)
(feast_spark.api.JobService_pb2.StartStreamToOnlineIngestionJobResponse attribute)
IN_PROGRESS (feast_spark.pyspark.abc.SparkJobStatus attribute)
include_terminated (feast_spark.api.JobService_pb2.ListJobsRequest attribute)
INGESTION_DROP_INVALID_ROWS (feast_spark.constants.ConfigOptions attribute)
ingestion_timespan (feast_spark.api.JobService_pb2.ScheduleOfflineToOnlineIngestionJobRequest attribute)
IngestionJobParameters (class in feast_spark.pyspark.abc)
intercept_service() (feast_spark.job_service.LoggingInterceptor method)
is_whitelisted() (feast_spark.job_service.JobServiceServicer method)
J
Job (class in feast_spark.api.JobService_pb2)
job (feast_spark.api.JobService_pb2.GetJobResponse attribute)
Job.OfflineToOnlineMeta (class in feast_spark.api.JobService_pb2)
Job.RetrievalJobMeta (class in feast_spark.api.JobService_pb2)
Job.StreamToOnlineMeta (class in feast_spark.api.JobService_pb2)
job_by_id (feast_spark.pyspark.launchers.standalone.local.JobCache attribute)
job_error_message (feast_spark.pyspark.launchers.k8s.k8s_utils.JobInfo property)
job_hash (feast_spark.pyspark.launchers.aws.emr_utils.JobInfo property)
JOB_HASH_LABEL_KEY (feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher attribute)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher attribute)
job_id (feast_spark.api.JobService_pb2.CancelJobRequest attribute)
(feast_spark.api.JobService_pb2.GetJobRequest attribute)
(feast_spark.pyspark.launchers.k8s.k8s_utils.JobInfo property)
job_ref (feast_spark.pyspark.launchers.aws.emr_utils.JobInfo property)
JOB_SERVICE_ENABLE_CONTROL_LOOP (feast_spark.constants.ConfigOptions attribute)
JOB_SERVICE_ENABLE_SSL (feast_spark.constants.ConfigOptions attribute)
JOB_SERVICE_PAUSE_BETWEEN_JOBS (feast_spark.constants.ConfigOptions attribute)
JOB_SERVICE_PROMETHEUS_METRIC_PORT (feast_spark.constants.ConfigOptions attribute)
JOB_SERVICE_RETRY_FAILED_JOBS (feast_spark.constants.ConfigOptions attribute)
JOB_SERVICE_SERVER_SSL_CERT (feast_spark.constants.ConfigOptions attribute)
JOB_SERVICE_URL (feast_spark.constants.ConfigOptions attribute)
job_start_time (feast_spark.api.JobService_pb2.GetHistoricalFeaturesResponse attribute)
(feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobResponse attribute)
(feast_spark.api.JobService_pb2.StartStreamToOnlineIngestionJobResponse attribute)
job_type (feast_spark.pyspark.launchers.aws.emr_utils.JobInfo property)
(feast_spark.pyspark.launchers.k8s.k8s_utils.JobInfo property)
JOB_TYPE_LABEL_KEY (feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher attribute)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher attribute)
JobCache (class in feast_spark.pyspark.launchers.standalone.local)
JobInfo (class in feast_spark.pyspark.launchers.aws.emr_utils)
(class in feast_spark.pyspark.launchers.k8s.k8s_utils)
JobLauncher (class in feast_spark.pyspark.abc)
JobNotFoundException
jobs (feast_spark.api.JobService_pb2.ListJobsResponse attribute)
JobService (class in feast_spark.api.JobService_pb2_grpc)
JobServiceServicer (class in feast_spark.api.JobService_pb2_grpc)
(class in feast_spark.job_service)
JobServiceStub (class in feast_spark.api.JobService_pb2_grpc)
K
KubernetesBatchIngestionJob (class in feast_spark.pyspark.launchers.k8s)
(class in feast_spark.pyspark.launchers.k8s.k8s)
KubernetesJobLauncher (class in feast_spark.pyspark.launchers.k8s)
(class in feast_spark.pyspark.launchers.k8s.k8s)
KubernetesJobMixin (class in feast_spark.pyspark.launchers.k8s.k8s)
KubernetesRetrievalJob (class in feast_spark.pyspark.launchers.k8s)
(class in feast_spark.pyspark.launchers.k8s.k8s)
KubernetesStreamIngestionJob (class in feast_spark.pyspark.launchers.k8s)
(class in feast_spark.pyspark.launchers.k8s.k8s)
L
labels (feast_spark.pyspark.launchers.k8s.k8s_utils.JobInfo property)
list_jobs() (feast_spark.Client method)
(feast_spark.client.Client method)
,
[1]
(feast_spark.pyspark.abc.JobLauncher method)
(feast_spark.pyspark.launchers.aws.emr.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.aws.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.standalone.local.JobCache method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterLauncher method)
(feast_spark.pyspark.launchers.standalone.StandaloneClusterLauncher method)
(in module feast_spark.pyspark.launcher)
ListJobs() (feast_spark.api.JobService_pb2_grpc.JobService static method)
(feast_spark.api.JobService_pb2_grpc.JobServiceServicer method)
(feast_spark.job_service.JobServiceServicer method)
ListJobsRequest (class in feast_spark.api.JobService_pb2)
ListJobsResponse (class in feast_spark.api.JobService_pb2)
lock (feast_spark.pyspark.launchers.standalone.local.JobCache attribute)
LOCK_EXPIRY (feast_spark.constants.ConfigOptions attribute)
LOCK_MGR_REDIS_HOST (feast_spark.constants.ConfigOptions attribute)
LOCK_MGR_REDIS_PORT (feast_spark.constants.ConfigOptions attribute)
log_uri (feast_spark.api.JobService_pb2.GetHistoricalFeaturesResponse attribute)
(feast_spark.api.JobService_pb2.Job attribute)
(feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobResponse attribute)
(feast_spark.api.JobService_pb2.StartStreamToOnlineIngestionJobResponse attribute)
LoggingInterceptor (class in feast_spark.job_service)
M
metrics_redis (feast_spark.Client property)
(feast_spark.client.Client property)
,
[1]
module
feast_spark
feast_spark.api
feast_spark.api.JobService_pb2
feast_spark.api.JobService_pb2_grpc
feast_spark.cli
feast_spark.client
,
[1]
feast_spark.constants
feast_spark.contrib
feast_spark.contrib.validation
feast_spark.job_service
feast_spark.pyspark
feast_spark.pyspark.abc
feast_spark.pyspark.launcher
feast_spark.pyspark.launchers
feast_spark.pyspark.launchers.aws
feast_spark.pyspark.launchers.aws.emr
feast_spark.pyspark.launchers.aws.emr_utils
feast_spark.pyspark.launchers.gcloud
feast_spark.pyspark.launchers.gcloud.dataproc
feast_spark.pyspark.launchers.k8s
feast_spark.pyspark.launchers.k8s.k8s
feast_spark.pyspark.launchers.k8s.k8s_utils
feast_spark.pyspark.launchers.standalone
feast_spark.pyspark.launchers.standalone.local
feast_spark.remote_job
feast_spark.third_party
feast_spark.third_party.grpc
feast_spark.third_party.grpc.health
feast_spark.third_party.grpc.health.v1
feast_spark.third_party.grpc.health.v1.HealthService_pb2
feast_spark.third_party.grpc.health.v1.HealthService_pb2_grpc
N
namespace (feast_spark.pyspark.launchers.k8s.k8s_utils.JobInfo property)
O
offline_to_online_ingestion() (feast_spark.pyspark.abc.JobLauncher method)
(feast_spark.pyspark.launchers.aws.emr.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.aws.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterLauncher method)
(feast_spark.pyspark.launchers.standalone.StandaloneClusterLauncher method)
output_file_uri (feast_spark.api.JobService_pb2.GetHistoricalFeaturesResponse attribute)
(feast_spark.pyspark.launchers.aws.emr_utils.JobInfo property)
output_format (feast_spark.api.JobService_pb2.GetHistoricalFeaturesRequest attribute)
output_location (feast_spark.api.JobService_pb2.GetHistoricalFeaturesRequest attribute)
(feast_spark.api.JobService_pb2.Job.RetrievalJobMeta attribute)
P
passed (feast_spark.api.JobService_pb2.GetHealthMetricsResponse attribute)
project (feast_spark.api.JobService_pb2.GetHealthMetricsRequest attribute)
(feast_spark.api.JobService_pb2.GetHistoricalFeaturesRequest attribute)
(feast_spark.api.JobService_pb2.ListJobsRequest attribute)
(feast_spark.api.JobService_pb2.ScheduleOfflineToOnlineIngestionJobRequest attribute)
(feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobRequest attribute)
(feast_spark.api.JobService_pb2.StartStreamToOnlineIngestionJobRequest attribute)
(feast_spark.api.JobService_pb2.UnscheduleOfflineToOnlineIngestionJobRequest attribute)
(feast_spark.pyspark.launchers.aws.emr_utils.JobInfo property)
PROJECT_LABEL_KEY (feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher attribute)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher attribute)
R
REDIS_HOST (feast_spark.constants.ConfigOptions attribute)
REDIS_PASSWORD (feast_spark.constants.ConfigOptions attribute)
REDIS_PORT (feast_spark.constants.ConfigOptions attribute)
REDIS_SSL (feast_spark.constants.ConfigOptions attribute)
RemoteBatchIngestionJob (class in feast_spark.remote_job)
RemoteJobMixin (class in feast_spark.remote_job)
RemoteRetrievalJob (class in feast_spark.remote_job)
RemoteStreamIngestionJob (class in feast_spark.remote_job)
reset_job_cache() (in module feast_spark.pyspark.launchers.standalone)
(in module feast_spark.pyspark.launchers.standalone.local)
resolve_launcher() (in module feast_spark.pyspark.launcher)
retrieval (feast_spark.api.JobService_pb2.Job attribute)
RetrievalJob (class in feast_spark.pyspark.abc)
RetrievalJobParameters (class in feast_spark.pyspark.abc)
S
S3_ENDPOINT_URL (feast_spark.constants.ConfigOptions attribute)
schedule_offline_to_online_ingestion() (feast_spark.Client method)
(feast_spark.client.Client method)
,
[1]
(feast_spark.pyspark.abc.JobLauncher method)
(feast_spark.pyspark.launchers.aws.emr.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.aws.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterLauncher method)
(feast_spark.pyspark.launchers.standalone.StandaloneClusterLauncher method)
(in module feast_spark.pyspark.launcher)
SCHEDULED_BATCH_INGESTION (feast_spark.pyspark.abc.SparkJobType attribute)
ScheduledBatchIngestionJobParameters (class in feast_spark.pyspark.abc)
ScheduleOfflineToOnlineIngestionJob() (feast_spark.api.JobService_pb2_grpc.JobService static method)
(feast_spark.api.JobService_pb2_grpc.JobServiceServicer method)
(feast_spark.job_service.JobServiceServicer method)
ScheduleOfflineToOnlineIngestionJobRequest (class in feast_spark.api.JobService_pb2)
ScheduleOfflineToOnlineIngestionJobResponse (class in feast_spark.api.JobService_pb2)
service (feast_spark.third_party.grpc.health.v1.HealthService_pb2.HealthCheckRequest attribute)
SPARK_BQ_MATERIALIZATION_DATASET (feast_spark.constants.ConfigOptions attribute)
SPARK_BQ_MATERIALIZATION_PROJECT (feast_spark.constants.ConfigOptions attribute)
SPARK_HOME (feast_spark.constants.ConfigOptions attribute)
SPARK_INGESTION_JAR (feast_spark.constants.ConfigOptions attribute)
SPARK_K8S_BATCH_INGESTION_TEMPLATE_PATH (feast_spark.constants.ConfigOptions attribute)
SPARK_K8S_HISTORICAL_RETRIEVAL_TEMPLATE_PATH (feast_spark.constants.ConfigOptions attribute)
SPARK_K8S_JOB_TEMPLATE_PATH (feast_spark.constants.ConfigOptions attribute)
SPARK_K8S_NAMESPACE (feast_spark.constants.ConfigOptions attribute)
SPARK_K8S_STREAM_INGESTION_TEMPLATE_PATH (feast_spark.constants.ConfigOptions attribute)
SPARK_K8S_USE_INCLUSTER_CONFIG (feast_spark.constants.ConfigOptions attribute)
SPARK_LAUNCHER (feast_spark.constants.ConfigOptions attribute)
SPARK_METRICS_REDIS_HOST (feast_spark.constants.ConfigOptions attribute)
SPARK_METRICS_REDIS_PORT (feast_spark.constants.ConfigOptions attribute)
SPARK_STAGING_LOCATION (feast_spark.constants.ConfigOptions attribute)
SPARK_STANDALONE_MASTER (feast_spark.constants.ConfigOptions attribute)
SPARK_STREAMING_TRIGGERING_INTERVAL (feast_spark.constants.ConfigOptions attribute)
spark_submit() (feast_spark.pyspark.launchers.standalone.local.StandaloneClusterLauncher method)
(feast_spark.pyspark.launchers.standalone.StandaloneClusterLauncher method)
spark_submit_script_path (feast_spark.pyspark.launchers.standalone.local.StandaloneClusterLauncher property)
(feast_spark.pyspark.launchers.standalone.StandaloneClusterLauncher property)
SparkJob (class in feast_spark.pyspark.abc)
SparkJobFailure
SparkJobParameters (class in feast_spark.pyspark.abc)
SparkJobStatus (class in feast_spark.pyspark.abc)
SparkJobType (class in feast_spark.pyspark.abc)
stage_dataframe() (in module feast_spark.pyspark.launcher)
stage_entities_to_bq_with_partition() (in module feast_spark.client)
,
[1]
StandaloneClusterBatchIngestionJob (class in feast_spark.pyspark.launchers.standalone.local)
StandaloneClusterJobMixin (class in feast_spark.pyspark.launchers.standalone.local)
StandaloneClusterLauncher (class in feast_spark.pyspark.launchers.standalone)
(class in feast_spark.pyspark.launchers.standalone.local)
StandaloneClusterRetrievalJob (class in feast_spark.pyspark.launchers.standalone)
(class in feast_spark.pyspark.launchers.standalone.local)
StandaloneClusterStreamingIngestionJob (class in feast_spark.pyspark.launchers.standalone.local)
start_control_loop() (in module feast_spark.job_service)
start_date (feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobRequest attribute)
start_historical_feature_retrieval_job() (in module feast_spark.pyspark.launcher)
start_historical_feature_retrieval_spark_session() (in module feast_spark.pyspark.launcher)
start_job_service() (in module feast_spark.job_service)
start_offline_to_online_ingestion() (feast_spark.Client method)
(feast_spark.client.Client method)
,
[1]
(in module feast_spark.pyspark.launcher)
start_prometheus_serving() (in module feast_spark.job_service)
start_stream_to_online_ingestion() (feast_spark.Client method)
(feast_spark.client.Client method)
,
[1]
(feast_spark.pyspark.abc.JobLauncher method)
(feast_spark.pyspark.launchers.aws.emr.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.aws.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterLauncher method)
(feast_spark.pyspark.launchers.standalone.StandaloneClusterLauncher method)
(in module feast_spark.pyspark.launcher)
start_time (feast_spark.api.JobService_pb2.Job attribute)
(feast_spark.pyspark.launchers.k8s.k8s_utils.JobInfo property)
STARTING (feast_spark.pyspark.abc.SparkJobStatus attribute)
StartOfflineToOnlineIngestionJob() (feast_spark.api.JobService_pb2_grpc.JobService static method)
(feast_spark.api.JobService_pb2_grpc.JobServiceServicer method)
(feast_spark.job_service.JobServiceServicer method)
StartOfflineToOnlineIngestionJobRequest (class in feast_spark.api.JobService_pb2)
StartOfflineToOnlineIngestionJobResponse (class in feast_spark.api.JobService_pb2)
StartStreamToOnlineIngestionJob() (feast_spark.api.JobService_pb2_grpc.JobService static method)
(feast_spark.api.JobService_pb2_grpc.JobServiceServicer method)
(feast_spark.job_service.JobServiceServicer method)
StartStreamToOnlineIngestionJobRequest (class in feast_spark.api.JobService_pb2)
StartStreamToOnlineIngestionJobResponse (class in feast_spark.api.JobService_pb2)
state (feast_spark.pyspark.launchers.aws.emr_utils.JobInfo property)
(feast_spark.pyspark.launchers.k8s.k8s_utils.JobInfo property)
STATSD_ENABLED (feast_spark.constants.ConfigOptions attribute)
STATSD_HOST (feast_spark.constants.ConfigOptions attribute)
STATSD_PORT (feast_spark.constants.ConfigOptions attribute)
status (feast_spark.api.JobService_pb2.Job attribute)
(feast_spark.third_party.grpc.health.v1.HealthService_pb2.HealthCheckResponse attribute)
STENCIL_TOKEN (feast_spark.constants.ConfigOptions attribute)
STENCIL_URL (feast_spark.constants.ConfigOptions attribute)
step_id (feast_spark.pyspark.launchers.aws.emr_utils.EmrJobRef property)
stream_ingestion (feast_spark.api.JobService_pb2.Job attribute)
STREAM_INGESTION (feast_spark.pyspark.abc.SparkJobType attribute)
StreamIngestionJob (class in feast_spark.pyspark.abc)
StreamIngestionJobParameters (class in feast_spark.pyspark.abc)
T
table_name (feast_spark.api.JobService_pb2.Job.OfflineToOnlineMeta attribute)
(feast_spark.api.JobService_pb2.Job.StreamToOnlineMeta attribute)
(feast_spark.api.JobService_pb2.ListJobsRequest attribute)
(feast_spark.api.JobService_pb2.ScheduleOfflineToOnlineIngestionJobRequest attribute)
(feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobRequest attribute)
(feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobResponse attribute)
(feast_spark.api.JobService_pb2.StartStreamToOnlineIngestionJobRequest attribute)
(feast_spark.api.JobService_pb2.StartStreamToOnlineIngestionJobResponse attribute)
(feast_spark.api.JobService_pb2.UnscheduleOfflineToOnlineIngestionJobRequest attribute)
(feast_spark.pyspark.launchers.aws.emr_utils.JobInfo property)
table_names (feast_spark.api.JobService_pb2.GetHealthMetricsRequest attribute)
table_reference_from_string() (in module feast_spark.pyspark.launcher)
to_pascal_case() (feast_spark.pyspark.abc.SparkJobType method)
type (feast_spark.api.JobService_pb2.Job attribute)
U
unschedule_offline_to_online_ingestion() (feast_spark.Client method)
(feast_spark.client.Client method)
,
[1]
(feast_spark.pyspark.abc.JobLauncher method)
(feast_spark.pyspark.launchers.aws.emr.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.aws.EmrClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.dataproc.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.gcloud.DataprocClusterLauncher method)
(feast_spark.pyspark.launchers.k8s.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.k8s.KubernetesJobLauncher method)
(feast_spark.pyspark.launchers.standalone.local.StandaloneClusterLauncher method)
(feast_spark.pyspark.launchers.standalone.StandaloneClusterLauncher method)
(in module feast_spark.pyspark.launcher)
UnscheduleOfflineToOnlineIngestionJob() (feast_spark.api.JobService_pb2_grpc.JobService static method)
(feast_spark.api.JobService_pb2_grpc.JobServiceServicer method)
(feast_spark.job_service.JobServiceServicer method)
UnscheduleOfflineToOnlineIngestionJobRequest (class in feast_spark.api.JobService_pb2)
UnscheduleOfflineToOnlineIngestionJobResponse (class in feast_spark.api.JobService_pb2)
W
wait_termination() (feast_spark.remote_job.RemoteJobMixin method)
WHITELISTED_FEATURE_TABLES_PATH (feast_spark.constants.ConfigOptions attribute)
WHITELISTED_JOB_TYPES (feast_spark.constants.ConfigOptions attribute)
WHITELISTED_PROJECTS (feast_spark.constants.ConfigOptions attribute)
Read the Docs
v: latest
Versions
latest
stable
Downloads
pdf
On Read the Docs
Project Home
Builds