diff --git a/caraml-store-sdk/go/protos/feast/core/CoreService.pb.go b/caraml-store-sdk/go/protos/feast/core/CoreService.pb.go
index 7f313d3..ea0fea5 100644
--- a/caraml-store-sdk/go/protos/feast/core/CoreService.pb.go
+++ b/caraml-store-sdk/go/protos/feast/core/CoreService.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast/core/CoreService.proto
 
 package core
diff --git a/caraml-store-sdk/go/protos/feast/core/CoreService_grpc.pb.go b/caraml-store-sdk/go/protos/feast/core/CoreService_grpc.pb.go
index f7050d3..7d081a4 100644
--- a/caraml-store-sdk/go/protos/feast/core/CoreService_grpc.pb.go
+++ b/caraml-store-sdk/go/protos/feast/core/CoreService_grpc.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
 // - protoc-gen-go-grpc v1.3.0
-// - protoc             (unknown)
+// - protoc             v5.27.1
 // source: feast/core/CoreService.proto
 
 package core
@@ -256,7 +256,7 @@ func (c *coreServiceClient) ArchiveOnlineStore(ctx context.Context, in *ArchiveO
 }
 
 // CoreServiceServer is the server API for CoreService service.
-// All implementations should embed UnimplementedCoreServiceServer
+// All implementations must embed UnimplementedCoreServiceServer
 // for forward compatibility
 type CoreServiceServer interface {
 	// Retrieve version information about this Feast deployment
@@ -319,9 +319,10 @@ type CoreServiceServer interface {
 	RegisterOnlineStore(context.Context, *RegisterOnlineStoreRequest) (*RegisterOnlineStoreResponse, error)
 	// Archives an online store to mark it deprecated
 	ArchiveOnlineStore(context.Context, *ArchiveOnlineStoreRequest) (*ArchiveOnlineStoreResponse, error)
+	mustEmbedUnimplementedCoreServiceServer()
 }
 
-// UnimplementedCoreServiceServer should be embedded to have forward compatible implementations.
+// UnimplementedCoreServiceServer must be embedded to have forward compatible implementations.
 type UnimplementedCoreServiceServer struct {
 }
 
@@ -373,6 +374,7 @@ func (UnimplementedCoreServiceServer) RegisterOnlineStore(context.Context, *Regi
 func (UnimplementedCoreServiceServer) ArchiveOnlineStore(context.Context, *ArchiveOnlineStoreRequest) (*ArchiveOnlineStoreResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method ArchiveOnlineStore not implemented")
 }
+func (UnimplementedCoreServiceServer) mustEmbedUnimplementedCoreServiceServer() {}
 
 // UnsafeCoreServiceServer may be embedded to opt out of forward compatibility for this service.
 // Use of this interface is not recommended, as added methods to CoreServiceServer will
diff --git a/caraml-store-sdk/go/protos/feast/core/DataFormat.pb.go b/caraml-store-sdk/go/protos/feast/core/DataFormat.pb.go
index 4644089..7a21bb7 100644
--- a/caraml-store-sdk/go/protos/feast/core/DataFormat.pb.go
+++ b/caraml-store-sdk/go/protos/feast/core/DataFormat.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast/core/DataFormat.proto
 
 package core
diff --git a/caraml-store-sdk/go/protos/feast/core/DataSource.pb.go b/caraml-store-sdk/go/protos/feast/core/DataSource.pb.go
index f1dea91..0ce77ce 100644
--- a/caraml-store-sdk/go/protos/feast/core/DataSource.pb.go
+++ b/caraml-store-sdk/go/protos/feast/core/DataSource.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast/core/DataSource.proto
 
 package core
diff --git a/caraml-store-sdk/go/protos/feast/core/Entity.pb.go b/caraml-store-sdk/go/protos/feast/core/Entity.pb.go
index 1566eea..0aa5918 100644
--- a/caraml-store-sdk/go/protos/feast/core/Entity.pb.go
+++ b/caraml-store-sdk/go/protos/feast/core/Entity.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast/core/Entity.proto
 
 package core
diff --git a/caraml-store-sdk/go/protos/feast/core/Feature.pb.go b/caraml-store-sdk/go/protos/feast/core/Feature.pb.go
index d6d9ec2..8c67fb0 100644
--- a/caraml-store-sdk/go/protos/feast/core/Feature.pb.go
+++ b/caraml-store-sdk/go/protos/feast/core/Feature.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast/core/Feature.proto
 
 package core
diff --git a/caraml-store-sdk/go/protos/feast/core/FeatureTable.pb.go b/caraml-store-sdk/go/protos/feast/core/FeatureTable.pb.go
index 4c28c57..8f27cab 100644
--- a/caraml-store-sdk/go/protos/feast/core/FeatureTable.pb.go
+++ b/caraml-store-sdk/go/protos/feast/core/FeatureTable.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast/core/FeatureTable.proto
 
 package core
diff --git a/caraml-store-sdk/go/protos/feast/core/LegacyJobService.pb.go b/caraml-store-sdk/go/protos/feast/core/LegacyJobService.pb.go
new file mode 100644
index 0000000..f1719bd
--- /dev/null
+++ b/caraml-store-sdk/go/protos/feast/core/LegacyJobService.pb.go
@@ -0,0 +1,112 @@
+// Legacy compatibility endpoint for older version of feast client.
+// The new endpoint is defined in feast_spark/api/JobService.proto
+
+// Code generated by protoc-gen-go. DO NOT EDIT.
+// versions:
+// 	protoc-gen-go v1.30.0
+// 	protoc        v5.27.1
+// source: feast/core/LegacyJobService.proto
+
+package core
+
+import (
+	api "github.com/caraml-dev/caraml-store/caraml-store-sdk/go/protos/feast_spark/api"
+	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
+	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
+	reflect "reflect"
+)
+
+const (
+	// Verify that this generated code is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
+	// Verify that runtime/protoimpl is sufficiently up-to-date.
+	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
+)
+
+var File_feast_core_LegacyJobService_proto protoreflect.FileDescriptor
+
+var file_feast_core_LegacyJobService_proto_rawDesc = []byte{
+	0x0a, 0x21, 0x66, 0x65, 0x61, 0x73, 0x74, 0x2f, 0x63, 0x6f, 0x72, 0x65, 0x2f, 0x4c, 0x65, 0x67,
+	0x61, 0x63, 0x79, 0x4a, 0x6f, 0x62, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72,
+	0x6f, 0x74, 0x6f, 0x12, 0x0a, 0x66, 0x65, 0x61, 0x73, 0x74, 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x1a,
+	0x20, 0x66, 0x65, 0x61, 0x73, 0x74, 0x5f, 0x73, 0x70, 0x61, 0x72, 0x6b, 0x2f, 0x61, 0x70, 0x69,
+	0x2f, 0x4a, 0x6f, 0x62, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74,
+	0x6f, 0x32, 0xe9, 0x02, 0x0a, 0x0a, 0x4a, 0x6f, 0x62, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65,
+	0x12, 0x97, 0x01, 0x0a, 0x20, 0x53, 0x74, 0x61, 0x72, 0x74, 0x4f, 0x66, 0x66, 0x6c, 0x69, 0x6e,
+	0x65, 0x54, 0x6f, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x49, 0x6e, 0x67, 0x65, 0x73, 0x74, 0x69,
+	0x6f, 0x6e, 0x4a, 0x6f, 0x62, 0x12, 0x38, 0x2e, 0x66, 0x65, 0x61, 0x73, 0x74, 0x5f, 0x73, 0x70,
+	0x61, 0x72, 0x6b, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x53, 0x74, 0x61, 0x72, 0x74, 0x4f, 0x66, 0x66,
+	0x6c, 0x69, 0x6e, 0x65, 0x54, 0x6f, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x49, 0x6e, 0x67, 0x65,
+	0x73, 0x74, 0x69, 0x6f, 0x6e, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a,
+	0x39, 0x2e, 0x66, 0x65, 0x61, 0x73, 0x74, 0x5f, 0x73, 0x70, 0x61, 0x72, 0x6b, 0x2e, 0x61, 0x70,
+	0x69, 0x2e, 0x53, 0x74, 0x61, 0x72, 0x74, 0x4f, 0x66, 0x66, 0x6c, 0x69, 0x6e, 0x65, 0x54, 0x6f,
+	0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x49, 0x6e, 0x67, 0x65, 0x73, 0x74, 0x69, 0x6f, 0x6e, 0x4a,
+	0x6f, 0x62, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x76, 0x0a, 0x15, 0x47, 0x65,
+	0x74, 0x48, 0x69, 0x73, 0x74, 0x6f, 0x72, 0x69, 0x63, 0x61, 0x6c, 0x46, 0x65, 0x61, 0x74, 0x75,
+	0x72, 0x65, 0x73, 0x12, 0x2d, 0x2e, 0x66, 0x65, 0x61, 0x73, 0x74, 0x5f, 0x73, 0x70, 0x61, 0x72,
+	0x6b, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x47, 0x65, 0x74, 0x48, 0x69, 0x73, 0x74, 0x6f, 0x72, 0x69,
+	0x63, 0x61, 0x6c, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65,
+	0x73, 0x74, 0x1a, 0x2e, 0x2e, 0x66, 0x65, 0x61, 0x73, 0x74, 0x5f, 0x73, 0x70, 0x61, 0x72, 0x6b,
+	0x2e, 0x61, 0x70, 0x69, 0x2e, 0x47, 0x65, 0x74, 0x48, 0x69, 0x73, 0x74, 0x6f, 0x72, 0x69, 0x63,
+	0x61, 0x6c, 0x46, 0x65, 0x61, 0x74, 0x75, 0x72, 0x65, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e,
+	0x73, 0x65, 0x12, 0x49, 0x0a, 0x06, 0x47, 0x65, 0x74, 0x4a, 0x6f, 0x62, 0x12, 0x1e, 0x2e, 0x66,
+	0x65, 0x61, 0x73, 0x74, 0x5f, 0x73, 0x70, 0x61, 0x72, 0x6b, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x47,
+	0x65, 0x74, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x66,
+	0x65, 0x61, 0x73, 0x74, 0x5f, 0x73, 0x70, 0x61, 0x72, 0x6b, 0x2e, 0x61, 0x70, 0x69, 0x2e, 0x47,
+	0x65, 0x74, 0x4a, 0x6f, 0x62, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x7d, 0x0a,
+	0x20, 0x64, 0x65, 0x76, 0x2e, 0x63, 0x61, 0x72, 0x61, 0x6d, 0x6c, 0x2e, 0x73, 0x74, 0x6f, 0x72,
+	0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x63, 0x6f, 0x6d, 0x70, 0x61,
+	0x74, 0x42, 0x0f, 0x4a, 0x6f, 0x62, 0x53, 0x65, 0x72, 0x76, 0x69, 0x63, 0x65, 0x50, 0x72, 0x6f,
+	0x74, 0x6f, 0x5a, 0x48, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x63,
+	0x61, 0x72, 0x61, 0x6d, 0x6c, 0x2d, 0x64, 0x65, 0x76, 0x2f, 0x63, 0x61, 0x72, 0x61, 0x6d, 0x6c,
+	0x2d, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2f, 0x63, 0x61, 0x72, 0x61, 0x6d, 0x6c, 0x2d, 0x73, 0x74,
+	0x6f, 0x72, 0x65, 0x2d, 0x73, 0x64, 0x6b, 0x2f, 0x67, 0x6f, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f,
+	0x73, 0x2f, 0x66, 0x65, 0x61, 0x73, 0x74, 0x2f, 0x63, 0x6f, 0x72, 0x65, 0x62, 0x06, 0x70, 0x72,
+	0x6f, 0x74, 0x6f, 0x33,
+}
+
+var file_feast_core_LegacyJobService_proto_goTypes = []interface{}{
+	(*api.StartOfflineToOnlineIngestionJobRequest)(nil),  // 0: feast_spark.api.StartOfflineToOnlineIngestionJobRequest
+	(*api.GetHistoricalFeaturesRequest)(nil),             // 1: feast_spark.api.GetHistoricalFeaturesRequest
+	(*api.GetJobRequest)(nil),                            // 2: feast_spark.api.GetJobRequest
+	(*api.StartOfflineToOnlineIngestionJobResponse)(nil), // 3: feast_spark.api.StartOfflineToOnlineIngestionJobResponse
+	(*api.GetHistoricalFeaturesResponse)(nil),            // 4: feast_spark.api.GetHistoricalFeaturesResponse
+	(*api.GetJobResponse)(nil),                           // 5: feast_spark.api.GetJobResponse
+}
+var file_feast_core_LegacyJobService_proto_depIdxs = []int32{
+	0, // 0: feast.core.JobService.StartOfflineToOnlineIngestionJob:input_type -> feast_spark.api.StartOfflineToOnlineIngestionJobRequest
+	1, // 1: feast.core.JobService.GetHistoricalFeatures:input_type -> feast_spark.api.GetHistoricalFeaturesRequest
+	2, // 2: feast.core.JobService.GetJob:input_type -> feast_spark.api.GetJobRequest
+	3, // 3: feast.core.JobService.StartOfflineToOnlineIngestionJob:output_type -> feast_spark.api.StartOfflineToOnlineIngestionJobResponse
+	4, // 4: feast.core.JobService.GetHistoricalFeatures:output_type -> feast_spark.api.GetHistoricalFeaturesResponse
+	5, // 5: feast.core.JobService.GetJob:output_type -> feast_spark.api.GetJobResponse
+	3, // [3:6] is the sub-list for method output_type
+	0, // [0:3] is the sub-list for method input_type
+	0, // [0:0] is the sub-list for extension type_name
+	0, // [0:0] is the sub-list for extension extendee
+	0, // [0:0] is the sub-list for field type_name
+}
+
+func init() { file_feast_core_LegacyJobService_proto_init() }
+func file_feast_core_LegacyJobService_proto_init() {
+	if File_feast_core_LegacyJobService_proto != nil {
+		return
+	}
+	type x struct{}
+	out := protoimpl.TypeBuilder{
+		File: protoimpl.DescBuilder{
+			GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
+			RawDescriptor: file_feast_core_LegacyJobService_proto_rawDesc,
+			NumEnums:      0,
+			NumMessages:   0,
+			NumExtensions: 0,
+			NumServices:   1,
+		},
+		GoTypes:           file_feast_core_LegacyJobService_proto_goTypes,
+		DependencyIndexes: file_feast_core_LegacyJobService_proto_depIdxs,
+	}.Build()
+	File_feast_core_LegacyJobService_proto = out.File
+	file_feast_core_LegacyJobService_proto_rawDesc = nil
+	file_feast_core_LegacyJobService_proto_goTypes = nil
+	file_feast_core_LegacyJobService_proto_depIdxs = nil
+}
diff --git a/caraml-store-sdk/go/protos/feast/core/LegacyJobService_grpc.pb.go b/caraml-store-sdk/go/protos/feast/core/LegacyJobService_grpc.pb.go
new file mode 100644
index 0000000..67f44f5
--- /dev/null
+++ b/caraml-store-sdk/go/protos/feast/core/LegacyJobService_grpc.pb.go
@@ -0,0 +1,193 @@
+// Legacy compatibility endpoint for older version of feast client.
+// The new endpoint is defined in feast_spark/api/JobService.proto
+
+// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
+// versions:
+// - protoc-gen-go-grpc v1.3.0
+// - protoc             v5.27.1
+// source: feast/core/LegacyJobService.proto
+
+package core
+
+import (
+	context "context"
+	api "github.com/caraml-dev/caraml-store/caraml-store-sdk/go/protos/feast_spark/api"
+	grpc "google.golang.org/grpc"
+	codes "google.golang.org/grpc/codes"
+	status "google.golang.org/grpc/status"
+)
+
+// This is a compile-time assertion to ensure that this generated file
+// is compatible with the grpc package it is being compiled against.
+// Requires gRPC-Go v1.32.0 or later.
+const _ = grpc.SupportPackageIsVersion7
+
+const (
+	JobService_StartOfflineToOnlineIngestionJob_FullMethodName = "/feast.core.JobService/StartOfflineToOnlineIngestionJob"
+	JobService_GetHistoricalFeatures_FullMethodName            = "/feast.core.JobService/GetHistoricalFeatures"
+	JobService_GetJob_FullMethodName                           = "/feast.core.JobService/GetJob"
+)
+
+// JobServiceClient is the client API for JobService service.
+//
+// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
+type JobServiceClient interface {
+	// Start job to ingest data from offline store into online store
+	StartOfflineToOnlineIngestionJob(ctx context.Context, in *api.StartOfflineToOnlineIngestionJobRequest, opts ...grpc.CallOption) (*api.StartOfflineToOnlineIngestionJobResponse, error)
+	// Produce a training dataset, return a job id that will provide a file reference
+	GetHistoricalFeatures(ctx context.Context, in *api.GetHistoricalFeaturesRequest, opts ...grpc.CallOption) (*api.GetHistoricalFeaturesResponse, error)
+	// Get details of a single job
+	GetJob(ctx context.Context, in *api.GetJobRequest, opts ...grpc.CallOption) (*api.GetJobResponse, error)
+}
+
+type jobServiceClient struct {
+	cc grpc.ClientConnInterface
+}
+
+func NewJobServiceClient(cc grpc.ClientConnInterface) JobServiceClient {
+	return &jobServiceClient{cc}
+}
+
+func (c *jobServiceClient) StartOfflineToOnlineIngestionJob(ctx context.Context, in *api.StartOfflineToOnlineIngestionJobRequest, opts ...grpc.CallOption) (*api.StartOfflineToOnlineIngestionJobResponse, error) {
+	out := new(api.StartOfflineToOnlineIngestionJobResponse)
+	err := c.cc.Invoke(ctx, JobService_StartOfflineToOnlineIngestionJob_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *jobServiceClient) GetHistoricalFeatures(ctx context.Context, in *api.GetHistoricalFeaturesRequest, opts ...grpc.CallOption) (*api.GetHistoricalFeaturesResponse, error) {
+	out := new(api.GetHistoricalFeaturesResponse)
+	err := c.cc.Invoke(ctx, JobService_GetHistoricalFeatures_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *jobServiceClient) GetJob(ctx context.Context, in *api.GetJobRequest, opts ...grpc.CallOption) (*api.GetJobResponse, error) {
+	out := new(api.GetJobResponse)
+	err := c.cc.Invoke(ctx, JobService_GetJob_FullMethodName, in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+// JobServiceServer is the server API for JobService service.
+// All implementations must embed UnimplementedJobServiceServer
+// for forward compatibility
+type JobServiceServer interface {
+	// Start job to ingest data from offline store into online store
+	StartOfflineToOnlineIngestionJob(context.Context, *api.StartOfflineToOnlineIngestionJobRequest) (*api.StartOfflineToOnlineIngestionJobResponse, error)
+	// Produce a training dataset, return a job id that will provide a file reference
+	GetHistoricalFeatures(context.Context, *api.GetHistoricalFeaturesRequest) (*api.GetHistoricalFeaturesResponse, error)
+	// Get details of a single job
+	GetJob(context.Context, *api.GetJobRequest) (*api.GetJobResponse, error)
+	mustEmbedUnimplementedJobServiceServer()
+}
+
+// UnimplementedJobServiceServer must be embedded to have forward compatible implementations.
+type UnimplementedJobServiceServer struct {
+}
+
+func (UnimplementedJobServiceServer) StartOfflineToOnlineIngestionJob(context.Context, *api.StartOfflineToOnlineIngestionJobRequest) (*api.StartOfflineToOnlineIngestionJobResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method StartOfflineToOnlineIngestionJob not implemented")
+}
+func (UnimplementedJobServiceServer) GetHistoricalFeatures(context.Context, *api.GetHistoricalFeaturesRequest) (*api.GetHistoricalFeaturesResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetHistoricalFeatures not implemented")
+}
+func (UnimplementedJobServiceServer) GetJob(context.Context, *api.GetJobRequest) (*api.GetJobResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method GetJob not implemented")
+}
+func (UnimplementedJobServiceServer) mustEmbedUnimplementedJobServiceServer() {}
+
+// UnsafeJobServiceServer may be embedded to opt out of forward compatibility for this service.
+// Use of this interface is not recommended, as added methods to JobServiceServer will
+// result in compilation errors.
+type UnsafeJobServiceServer interface {
+	mustEmbedUnimplementedJobServiceServer()
+}
+
+func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer) {
+	s.RegisterService(&JobService_ServiceDesc, srv)
+}
+
+func _JobService_StartOfflineToOnlineIngestionJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(api.StartOfflineToOnlineIngestionJobRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(JobServiceServer).StartOfflineToOnlineIngestionJob(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: JobService_StartOfflineToOnlineIngestionJob_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(JobServiceServer).StartOfflineToOnlineIngestionJob(ctx, req.(*api.StartOfflineToOnlineIngestionJobRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _JobService_GetHistoricalFeatures_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(api.GetHistoricalFeaturesRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(JobServiceServer).GetHistoricalFeatures(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: JobService_GetHistoricalFeatures_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(JobServiceServer).GetHistoricalFeatures(ctx, req.(*api.GetHistoricalFeaturesRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _JobService_GetJob_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(api.GetJobRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(JobServiceServer).GetJob(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: JobService_GetJob_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(JobServiceServer).GetJob(ctx, req.(*api.GetJobRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+// JobService_ServiceDesc is the grpc.ServiceDesc for JobService service.
+// It's only intended for direct use with grpc.RegisterService,
+// and not to be introspected or modified (even as a copy)
+var JobService_ServiceDesc = grpc.ServiceDesc{
+	ServiceName: "feast.core.JobService",
+	HandlerType: (*JobServiceServer)(nil),
+	Methods: []grpc.MethodDesc{
+		{
+			MethodName: "StartOfflineToOnlineIngestionJob",
+			Handler:    _JobService_StartOfflineToOnlineIngestionJob_Handler,
+		},
+		{
+			MethodName: "GetHistoricalFeatures",
+			Handler:    _JobService_GetHistoricalFeatures_Handler,
+		},
+		{
+			MethodName: "GetJob",
+			Handler:    _JobService_GetJob_Handler,
+		},
+	},
+	Streams:  []grpc.StreamDesc{},
+	Metadata: "feast/core/LegacyJobService.proto",
+}
diff --git a/caraml-store-sdk/go/protos/feast/core/OnlineStore.pb.go b/caraml-store-sdk/go/protos/feast/core/OnlineStore.pb.go
index e06ceda..54973d3 100644
--- a/caraml-store-sdk/go/protos/feast/core/OnlineStore.pb.go
+++ b/caraml-store-sdk/go/protos/feast/core/OnlineStore.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast/core/OnlineStore.proto
 
 package core
@@ -29,6 +29,8 @@ const (
 	StoreType_BIGTABLE StoreType = 1
 	// redis in-memory database
 	StoreType_REDIS StoreType = 2
+	// HBase database
+	StoreType_HBASE StoreType = 3
 )
 
 // Enum value maps for StoreType.
@@ -37,11 +39,13 @@ var (
 		0: "UNSET",
 		1: "BIGTABLE",
 		2: "REDIS",
+		3: "HBASE",
 	}
 	StoreType_value = map[string]int32{
 		"UNSET":    0,
 		"BIGTABLE": 1,
 		"REDIS":    2,
+		"HBASE":    3,
 	}
 )
 
@@ -154,19 +158,19 @@ var file_feast_core_OnlineStore_proto_rawDesc = []byte{
 	0x61, 0x73, 0x74, 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x2e, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x54, 0x79,
 	0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x64, 0x65, 0x73, 0x63,
 	0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x64,
-	0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x2a, 0x2f, 0x0a, 0x09, 0x53, 0x74,
+	0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x2a, 0x3a, 0x0a, 0x09, 0x53, 0x74,
 	0x6f, 0x72, 0x65, 0x54, 0x79, 0x70, 0x65, 0x12, 0x09, 0x0a, 0x05, 0x55, 0x4e, 0x53, 0x45, 0x54,
 	0x10, 0x00, 0x12, 0x0c, 0x0a, 0x08, 0x42, 0x49, 0x47, 0x54, 0x41, 0x42, 0x4c, 0x45, 0x10, 0x01,
-	0x12, 0x09, 0x0a, 0x05, 0x52, 0x45, 0x44, 0x49, 0x53, 0x10, 0x02, 0x42, 0x7c, 0x0a, 0x1e, 0x64,
-	0x65, 0x76, 0x2e, 0x63, 0x61, 0x72, 0x61, 0x6d, 0x6c, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e,
-	0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x75, 0x66, 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x42, 0x10, 0x4f,
-	0x6e, 0x6c, 0x69, 0x6e, 0x65, 0x53, 0x74, 0x6f, 0x72, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x5a,
-	0x48, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x63, 0x61, 0x72, 0x61,
-	0x6d, 0x6c, 0x2d, 0x64, 0x65, 0x76, 0x2f, 0x63, 0x61, 0x72, 0x61, 0x6d, 0x6c, 0x2d, 0x73, 0x74,
-	0x6f, 0x72, 0x65, 0x2f, 0x63, 0x61, 0x72, 0x61, 0x6d, 0x6c, 0x2d, 0x73, 0x74, 0x6f, 0x72, 0x65,
-	0x2d, 0x73, 0x64, 0x6b, 0x2f, 0x67, 0x6f, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2f, 0x66,
-	0x65, 0x61, 0x73, 0x74, 0x2f, 0x63, 0x6f, 0x72, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f,
-	0x33,
+	0x12, 0x09, 0x0a, 0x05, 0x52, 0x45, 0x44, 0x49, 0x53, 0x10, 0x02, 0x12, 0x09, 0x0a, 0x05, 0x48,
+	0x42, 0x41, 0x53, 0x45, 0x10, 0x03, 0x42, 0x7c, 0x0a, 0x1e, 0x64, 0x65, 0x76, 0x2e, 0x63, 0x61,
+	0x72, 0x61, 0x6d, 0x6c, 0x2e, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
+	0x62, 0x75, 0x66, 0x2e, 0x63, 0x6f, 0x72, 0x65, 0x42, 0x10, 0x4f, 0x6e, 0x6c, 0x69, 0x6e, 0x65,
+	0x53, 0x74, 0x6f, 0x72, 0x65, 0x50, 0x72, 0x6f, 0x74, 0x6f, 0x5a, 0x48, 0x67, 0x69, 0x74, 0x68,
+	0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x63, 0x61, 0x72, 0x61, 0x6d, 0x6c, 0x2d, 0x64, 0x65,
+	0x76, 0x2f, 0x63, 0x61, 0x72, 0x61, 0x6d, 0x6c, 0x2d, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2f, 0x63,
+	0x61, 0x72, 0x61, 0x6d, 0x6c, 0x2d, 0x73, 0x74, 0x6f, 0x72, 0x65, 0x2d, 0x73, 0x64, 0x6b, 0x2f,
+	0x67, 0x6f, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x73, 0x2f, 0x66, 0x65, 0x61, 0x73, 0x74, 0x2f,
+	0x63, 0x6f, 0x72, 0x65, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
 }
 
 var (
diff --git a/caraml-store-sdk/go/protos/feast/core/SparkOverride.pb.go b/caraml-store-sdk/go/protos/feast/core/SparkOverride.pb.go
index 0d05726..b57b76c 100644
--- a/caraml-store-sdk/go/protos/feast/core/SparkOverride.pb.go
+++ b/caraml-store-sdk/go/protos/feast/core/SparkOverride.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast/core/SparkOverride.proto
 
 package core
diff --git a/caraml-store-sdk/go/protos/feast/serving/ServingService.pb.go b/caraml-store-sdk/go/protos/feast/serving/ServingService.pb.go
index 1d33604..191d7e0 100644
--- a/caraml-store-sdk/go/protos/feast/serving/ServingService.pb.go
+++ b/caraml-store-sdk/go/protos/feast/serving/ServingService.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast/serving/ServingService.proto
 
 package serving
diff --git a/caraml-store-sdk/go/protos/feast/serving/ServingService_grpc.pb.go b/caraml-store-sdk/go/protos/feast/serving/ServingService_grpc.pb.go
index 9148f41..a89f2bb 100644
--- a/caraml-store-sdk/go/protos/feast/serving/ServingService_grpc.pb.go
+++ b/caraml-store-sdk/go/protos/feast/serving/ServingService_grpc.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
 // - protoc-gen-go-grpc v1.3.0
-// - protoc             (unknown)
+// - protoc             v5.27.1
 // source: feast/serving/ServingService.proto
 
 package serving
@@ -72,7 +72,7 @@ func (c *servingServiceClient) GetOnlineFeatures(ctx context.Context, in *GetOnl
 }
 
 // ServingServiceServer is the server API for ServingService service.
-// All implementations should embed UnimplementedServingServiceServer
+// All implementations must embed UnimplementedServingServiceServer
 // for forward compatibility
 type ServingServiceServer interface {
 	// Get information about this Feast serving.
@@ -81,9 +81,10 @@ type ServingServiceServer interface {
 	GetOnlineFeaturesV2(context.Context, *GetOnlineFeaturesRequest) (*GetOnlineFeaturesResponseV2, error)
 	// Get online features using optimized response message.
 	GetOnlineFeatures(context.Context, *GetOnlineFeaturesRequest) (*GetOnlineFeaturesResponse, error)
+	mustEmbedUnimplementedServingServiceServer()
 }
 
-// UnimplementedServingServiceServer should be embedded to have forward compatible implementations.
+// UnimplementedServingServiceServer must be embedded to have forward compatible implementations.
 type UnimplementedServingServiceServer struct {
 }
 
@@ -96,6 +97,7 @@ func (UnimplementedServingServiceServer) GetOnlineFeaturesV2(context.Context, *G
 func (UnimplementedServingServiceServer) GetOnlineFeatures(context.Context, *GetOnlineFeaturesRequest) (*GetOnlineFeaturesResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetOnlineFeatures not implemented")
 }
+func (UnimplementedServingServiceServer) mustEmbedUnimplementedServingServiceServer() {}
 
 // UnsafeServingServiceServer may be embedded to opt out of forward compatibility for this service.
 // Use of this interface is not recommended, as added methods to ServingServiceServer will
diff --git a/caraml-store-sdk/go/protos/feast/types/Field.pb.go b/caraml-store-sdk/go/protos/feast/types/Field.pb.go
index f9dd1f7..b7c296b 100644
--- a/caraml-store-sdk/go/protos/feast/types/Field.pb.go
+++ b/caraml-store-sdk/go/protos/feast/types/Field.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast/types/Field.proto
 
 package types
diff --git a/caraml-store-sdk/go/protos/feast/types/Value.pb.go b/caraml-store-sdk/go/protos/feast/types/Value.pb.go
index f1d1ca8..ef4f283 100644
--- a/caraml-store-sdk/go/protos/feast/types/Value.pb.go
+++ b/caraml-store-sdk/go/protos/feast/types/Value.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast/types/Value.proto
 
 package types
diff --git a/caraml-store-sdk/go/protos/feast_spark/api/JobService.pb.go b/caraml-store-sdk/go/protos/feast_spark/api/JobService.pb.go
index 5dfa8f1..375315a 100644
--- a/caraml-store-sdk/go/protos/feast_spark/api/JobService.pb.go
+++ b/caraml-store-sdk/go/protos/feast_spark/api/JobService.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go. DO NOT EDIT.
 // versions:
 // 	protoc-gen-go v1.30.0
-// 	protoc        (unknown)
+// 	protoc        v5.27.1
 // source: feast_spark/api/JobService.proto
 
 package api
diff --git a/caraml-store-sdk/go/protos/feast_spark/api/JobService_grpc.pb.go b/caraml-store-sdk/go/protos/feast_spark/api/JobService_grpc.pb.go
index 385ac0d..fd1fbd0 100644
--- a/caraml-store-sdk/go/protos/feast_spark/api/JobService_grpc.pb.go
+++ b/caraml-store-sdk/go/protos/feast_spark/api/JobService_grpc.pb.go
@@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
 // - protoc-gen-go-grpc v1.3.0
-// - protoc             (unknown)
+// - protoc             v5.27.1
 // source: feast_spark/api/JobService.proto
 
 package api
@@ -168,7 +168,7 @@ func (c *jobServiceClient) GetHealthMetrics(ctx context.Context, in *GetHealthMe
 }
 
 // JobServiceServer is the server API for JobService service.
-// All implementations should embed UnimplementedJobServiceServer
+// All implementations must embed UnimplementedJobServiceServer
 // for forward compatibility
 type JobServiceServer interface {
 	// Start job to ingest data from offline store into online store
@@ -193,9 +193,10 @@ type JobServiceServer interface {
 	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
 	// Get ingestion health metrics for a Feature Table
 	GetHealthMetrics(context.Context, *GetHealthMetricsRequest) (*GetHealthMetricsResponse, error)
+	mustEmbedUnimplementedJobServiceServer()
 }
 
-// UnimplementedJobServiceServer should be embedded to have forward compatible implementations.
+// UnimplementedJobServiceServer must be embedded to have forward compatible implementations.
 type UnimplementedJobServiceServer struct {
 }
 
@@ -232,6 +233,7 @@ func (UnimplementedJobServiceServer) GetJob(context.Context, *GetJobRequest) (*G
 func (UnimplementedJobServiceServer) GetHealthMetrics(context.Context, *GetHealthMetricsRequest) (*GetHealthMetricsResponse, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method GetHealthMetrics not implemented")
 }
+func (UnimplementedJobServiceServer) mustEmbedUnimplementedJobServiceServer() {}
 
 // UnsafeJobServiceServer may be embedded to opt out of forward compatibility for this service.
 // Use of this interface is not recommended, as added methods to JobServiceServer will