feast_spark.api package

Submodules

feast_spark.api.JobService_pb2 module

class feast_spark.api.JobService_pb2.CancelJobRequest

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

job_id

Field feast_spark.api.CancelJobRequest.job_id

class feast_spark.api.JobService_pb2.CancelJobResponse

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

class feast_spark.api.JobService_pb2.GetHealthMetricsRequest

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

project

Field feast_spark.api.GetHealthMetricsRequest.project

table_names

Field feast_spark.api.GetHealthMetricsRequest.table_names

class feast_spark.api.JobService_pb2.GetHealthMetricsResponse

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

failed

Field feast_spark.api.GetHealthMetricsResponse.failed

passed

Field feast_spark.api.GetHealthMetricsResponse.passed

class feast_spark.api.JobService_pb2.GetHistoricalFeaturesRequest

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

entity_source

Field feast_spark.api.GetHistoricalFeaturesRequest.entity_source

feature_refs

Field feast_spark.api.GetHistoricalFeaturesRequest.feature_refs

output_format

Field feast_spark.api.GetHistoricalFeaturesRequest.output_format

output_location

Field feast_spark.api.GetHistoricalFeaturesRequest.output_location

project

Field feast_spark.api.GetHistoricalFeaturesRequest.project

class feast_spark.api.JobService_pb2.GetHistoricalFeaturesResponse

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

id

Field feast_spark.api.GetHistoricalFeaturesResponse.id

job_start_time

Field feast_spark.api.GetHistoricalFeaturesResponse.job_start_time

log_uri

Field feast_spark.api.GetHistoricalFeaturesResponse.log_uri

output_file_uri

Field feast_spark.api.GetHistoricalFeaturesResponse.output_file_uri

class feast_spark.api.JobService_pb2.GetJobRequest

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

job_id

Field feast_spark.api.GetJobRequest.job_id

class feast_spark.api.JobService_pb2.GetJobResponse

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

job

Field feast_spark.api.GetJobResponse.job

class feast_spark.api.JobService_pb2.Job

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

class OfflineToOnlineMeta

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

table_name

Field feast_spark.api.Job.OfflineToOnlineMeta.table_name

class RetrievalJobMeta

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

output_location

Field feast_spark.api.Job.RetrievalJobMeta.output_location

class StreamToOnlineMeta

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

table_name

Field feast_spark.api.Job.StreamToOnlineMeta.table_name

batch_ingestion

Field feast_spark.api.Job.batch_ingestion

error_message

Field feast_spark.api.Job.error_message

hash

Field feast_spark.api.Job.hash

id

Field feast_spark.api.Job.id

log_uri

Field feast_spark.api.Job.log_uri

retrieval

Field feast_spark.api.Job.retrieval

start_time

Field feast_spark.api.Job.start_time

status

Field feast_spark.api.Job.status

stream_ingestion

Field feast_spark.api.Job.stream_ingestion

type

Field feast_spark.api.Job.type

class feast_spark.api.JobService_pb2.ListJobsRequest

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

include_terminated

Field feast_spark.api.ListJobsRequest.include_terminated

project

Field feast_spark.api.ListJobsRequest.project

table_name

Field feast_spark.api.ListJobsRequest.table_name

class feast_spark.api.JobService_pb2.ListJobsResponse

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

jobs

Field feast_spark.api.ListJobsResponse.jobs

class feast_spark.api.JobService_pb2.ScheduleOfflineToOnlineIngestionJobRequest

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

cron_schedule

Field feast_spark.api.ScheduleOfflineToOnlineIngestionJobRequest.cron_schedule

ingestion_timespan

Field feast_spark.api.ScheduleOfflineToOnlineIngestionJobRequest.ingestion_timespan

project

Field feast_spark.api.ScheduleOfflineToOnlineIngestionJobRequest.project

table_name

Field feast_spark.api.ScheduleOfflineToOnlineIngestionJobRequest.table_name

class feast_spark.api.JobService_pb2.ScheduleOfflineToOnlineIngestionJobResponse

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

class feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobRequest

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

end_date

Field feast_spark.api.StartOfflineToOnlineIngestionJobRequest.end_date

project

Field feast_spark.api.StartOfflineToOnlineIngestionJobRequest.project

start_date

Field feast_spark.api.StartOfflineToOnlineIngestionJobRequest.start_date

table_name

Field feast_spark.api.StartOfflineToOnlineIngestionJobRequest.table_name

class feast_spark.api.JobService_pb2.StartOfflineToOnlineIngestionJobResponse

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

id

Field feast_spark.api.StartOfflineToOnlineIngestionJobResponse.id

job_start_time

Field feast_spark.api.StartOfflineToOnlineIngestionJobResponse.job_start_time

log_uri

Field feast_spark.api.StartOfflineToOnlineIngestionJobResponse.log_uri

table_name

Field feast_spark.api.StartOfflineToOnlineIngestionJobResponse.table_name

class feast_spark.api.JobService_pb2.StartStreamToOnlineIngestionJobRequest

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

project

Field feast_spark.api.StartStreamToOnlineIngestionJobRequest.project

table_name

Field feast_spark.api.StartStreamToOnlineIngestionJobRequest.table_name

class feast_spark.api.JobService_pb2.StartStreamToOnlineIngestionJobResponse

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

id

Field feast_spark.api.StartStreamToOnlineIngestionJobResponse.id

job_start_time

Field feast_spark.api.StartStreamToOnlineIngestionJobResponse.job_start_time

log_uri

Field feast_spark.api.StartStreamToOnlineIngestionJobResponse.log_uri

table_name

Field feast_spark.api.StartStreamToOnlineIngestionJobResponse.table_name

class feast_spark.api.JobService_pb2.UnscheduleOfflineToOnlineIngestionJobRequest

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

project

Field feast_spark.api.UnscheduleOfflineToOnlineIngestionJobRequest.project

table_name

Field feast_spark.api.UnscheduleOfflineToOnlineIngestionJobRequest.table_name

class feast_spark.api.JobService_pb2.UnscheduleOfflineToOnlineIngestionJobResponse

Bases: CMessage, Message

DESCRIPTOR = <google.protobuf.pyext._message.MessageDescriptor object>

The google.protobuf.descriptor.Descriptor for this message type.

feast_spark.api.JobService_pb2_grpc module

Client and server classes corresponding to protobuf-defined services.

class feast_spark.api.JobService_pb2_grpc.JobService

Bases: object

Missing associated documentation comment in .proto file.

static CancelJob(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static GetHealthMetrics(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static GetHistoricalFeatures(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static GetJob(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static ListJobs(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static ScheduleOfflineToOnlineIngestionJob(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static StartOfflineToOnlineIngestionJob(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static StartStreamToOnlineIngestionJob(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

static UnscheduleOfflineToOnlineIngestionJob(request, target, options=(), channel_credentials=None, call_credentials=None, insecure=False, compression=None, wait_for_ready=None, timeout=None, metadata=None)

class feast_spark.api.JobService_pb2_grpc.JobServiceServicer

Bases: object

Missing associated documentation comment in .proto file.

CancelJob(request, context)

Cancel a single job

GetHealthMetrics(request, context)

Get ingestion health metrics for a Feature Table

GetHistoricalFeatures(request, context)

Produce a training dataset, return a job id that will provide a file reference

GetJob(request, context)

Get details of a single job

ListJobs(request, context)

List all types of jobs

ScheduleOfflineToOnlineIngestionJob(request, context)

Start scheduled job to ingest data from offline store into online store

StartOfflineToOnlineIngestionJob(request, context)

Start job to ingest data from offline store into online store

StartStreamToOnlineIngestionJob(request, context)

Start job to ingest data from stream into online store

UnscheduleOfflineToOnlineIngestionJob(request, context)

Unschedule job to ingest data from offline store into online store

class feast_spark.api.JobService_pb2_grpc.JobServiceStub(channel)

Bases: object

Missing associated documentation comment in .proto file.

feast_spark.api.JobService_pb2_grpc.add_JobServiceServicer_to_server(servicer, server)

Module contents