mirror of
https://github.com/hanzo-ml/spark-operator.git
synced 2026-10-30 20:39:07 +00:00
* Add new field .spec.server.service to SparkConnect Signed-off-by: Yi Chen <[email protected]> * Add support for customing Spark connect server service Signed-off-by: Yi Chen <[email protected]> * Set Kubernetes client to suppress warnings in REST config Signed-off-by: Yi Chen <[email protected]> --------- Signed-off-by: Yi Chen <[email protected]>
287 lines
8.0 KiB
Go
287 lines
8.0 KiB
Go
//go:build !ignore_autogenerated
|
|
|
|
/*
|
|
Copyright 2025 The Kubeflow authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
https://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
// Code generated by controller-gen. DO NOT EDIT.
|
|
|
|
package v1alpha1
|
|
|
|
import (
|
|
"k8s.io/api/core/v1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
runtime "k8s.io/apimachinery/pkg/runtime"
|
|
)
|
|
|
|
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
|
func (in *DynamicAllocation) DeepCopyInto(out *DynamicAllocation) {
|
|
*out = *in
|
|
if in.InitialExecutors != nil {
|
|
in, out := &in.InitialExecutors, &out.InitialExecutors
|
|
*out = new(int32)
|
|
**out = **in
|
|
}
|
|
if in.MinExecutors != nil {
|
|
in, out := &in.MinExecutors, &out.MinExecutors
|
|
*out = new(int32)
|
|
**out = **in
|
|
}
|
|
if in.MaxExecutors != nil {
|
|
in, out := &in.MaxExecutors, &out.MaxExecutors
|
|
*out = new(int32)
|
|
**out = **in
|
|
}
|
|
if in.ShuffleTrackingEnabled != nil {
|
|
in, out := &in.ShuffleTrackingEnabled, &out.ShuffleTrackingEnabled
|
|
*out = new(bool)
|
|
**out = **in
|
|
}
|
|
if in.ShuffleTrackingTimeout != nil {
|
|
in, out := &in.ShuffleTrackingTimeout, &out.ShuffleTrackingTimeout
|
|
*out = new(int64)
|
|
**out = **in
|
|
}
|
|
}
|
|
|
|
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DynamicAllocation.
|
|
func (in *DynamicAllocation) DeepCopy() *DynamicAllocation {
|
|
if in == nil {
|
|
return nil
|
|
}
|
|
out := new(DynamicAllocation)
|
|
in.DeepCopyInto(out)
|
|
return out
|
|
}
|
|
|
|
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
|
func (in *ExecutorSpec) DeepCopyInto(out *ExecutorSpec) {
|
|
*out = *in
|
|
in.SparkPodSpec.DeepCopyInto(&out.SparkPodSpec)
|
|
if in.Instances != nil {
|
|
in, out := &in.Instances, &out.Instances
|
|
*out = new(int32)
|
|
**out = **in
|
|
}
|
|
}
|
|
|
|
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ExecutorSpec.
|
|
func (in *ExecutorSpec) DeepCopy() *ExecutorSpec {
|
|
if in == nil {
|
|
return nil
|
|
}
|
|
out := new(ExecutorSpec)
|
|
in.DeepCopyInto(out)
|
|
return out
|
|
}
|
|
|
|
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
|
func (in *ServerSpec) DeepCopyInto(out *ServerSpec) {
|
|
*out = *in
|
|
in.SparkPodSpec.DeepCopyInto(&out.SparkPodSpec)
|
|
if in.Service != nil {
|
|
in, out := &in.Service, &out.Service
|
|
*out = new(v1.Service)
|
|
(*in).DeepCopyInto(*out)
|
|
}
|
|
}
|
|
|
|
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerSpec.
|
|
func (in *ServerSpec) DeepCopy() *ServerSpec {
|
|
if in == nil {
|
|
return nil
|
|
}
|
|
out := new(ServerSpec)
|
|
in.DeepCopyInto(out)
|
|
return out
|
|
}
|
|
|
|
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
|
func (in *SparkConnect) DeepCopyInto(out *SparkConnect) {
|
|
*out = *in
|
|
out.TypeMeta = in.TypeMeta
|
|
in.ObjectMeta.DeepCopyInto(&out.ObjectMeta)
|
|
in.Spec.DeepCopyInto(&out.Spec)
|
|
in.Status.DeepCopyInto(&out.Status)
|
|
}
|
|
|
|
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkConnect.
|
|
func (in *SparkConnect) DeepCopy() *SparkConnect {
|
|
if in == nil {
|
|
return nil
|
|
}
|
|
out := new(SparkConnect)
|
|
in.DeepCopyInto(out)
|
|
return out
|
|
}
|
|
|
|
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
|
|
func (in *SparkConnect) DeepCopyObject() runtime.Object {
|
|
if c := in.DeepCopy(); c != nil {
|
|
return c
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
|
func (in *SparkConnectList) DeepCopyInto(out *SparkConnectList) {
|
|
*out = *in
|
|
out.TypeMeta = in.TypeMeta
|
|
in.ListMeta.DeepCopyInto(&out.ListMeta)
|
|
if in.Items != nil {
|
|
in, out := &in.Items, &out.Items
|
|
*out = make([]SparkConnect, len(*in))
|
|
for i := range *in {
|
|
(*in)[i].DeepCopyInto(&(*out)[i])
|
|
}
|
|
}
|
|
}
|
|
|
|
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkConnectList.
|
|
func (in *SparkConnectList) DeepCopy() *SparkConnectList {
|
|
if in == nil {
|
|
return nil
|
|
}
|
|
out := new(SparkConnectList)
|
|
in.DeepCopyInto(out)
|
|
return out
|
|
}
|
|
|
|
// DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
|
|
func (in *SparkConnectList) DeepCopyObject() runtime.Object {
|
|
if c := in.DeepCopy(); c != nil {
|
|
return c
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
|
func (in *SparkConnectServerStatus) DeepCopyInto(out *SparkConnectServerStatus) {
|
|
*out = *in
|
|
}
|
|
|
|
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkConnectServerStatus.
|
|
func (in *SparkConnectServerStatus) DeepCopy() *SparkConnectServerStatus {
|
|
if in == nil {
|
|
return nil
|
|
}
|
|
out := new(SparkConnectServerStatus)
|
|
in.DeepCopyInto(out)
|
|
return out
|
|
}
|
|
|
|
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
|
func (in *SparkConnectSpec) DeepCopyInto(out *SparkConnectSpec) {
|
|
*out = *in
|
|
if in.Image != nil {
|
|
in, out := &in.Image, &out.Image
|
|
*out = new(string)
|
|
**out = **in
|
|
}
|
|
if in.HadoopConf != nil {
|
|
in, out := &in.HadoopConf, &out.HadoopConf
|
|
*out = make(map[string]string, len(*in))
|
|
for key, val := range *in {
|
|
(*out)[key] = val
|
|
}
|
|
}
|
|
if in.SparkConf != nil {
|
|
in, out := &in.SparkConf, &out.SparkConf
|
|
*out = make(map[string]string, len(*in))
|
|
for key, val := range *in {
|
|
(*out)[key] = val
|
|
}
|
|
}
|
|
in.Server.DeepCopyInto(&out.Server)
|
|
in.Executor.DeepCopyInto(&out.Executor)
|
|
if in.DynamicAllocation != nil {
|
|
in, out := &in.DynamicAllocation, &out.DynamicAllocation
|
|
*out = new(DynamicAllocation)
|
|
(*in).DeepCopyInto(*out)
|
|
}
|
|
}
|
|
|
|
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkConnectSpec.
|
|
func (in *SparkConnectSpec) DeepCopy() *SparkConnectSpec {
|
|
if in == nil {
|
|
return nil
|
|
}
|
|
out := new(SparkConnectSpec)
|
|
in.DeepCopyInto(out)
|
|
return out
|
|
}
|
|
|
|
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
|
func (in *SparkConnectStatus) DeepCopyInto(out *SparkConnectStatus) {
|
|
*out = *in
|
|
if in.Conditions != nil {
|
|
in, out := &in.Conditions, &out.Conditions
|
|
*out = make([]metav1.Condition, len(*in))
|
|
for i := range *in {
|
|
(*in)[i].DeepCopyInto(&(*out)[i])
|
|
}
|
|
}
|
|
out.Server = in.Server
|
|
if in.Executors != nil {
|
|
in, out := &in.Executors, &out.Executors
|
|
*out = make(map[string]int, len(*in))
|
|
for key, val := range *in {
|
|
(*out)[key] = val
|
|
}
|
|
}
|
|
in.StartTime.DeepCopyInto(&out.StartTime)
|
|
in.LastUpdateTime.DeepCopyInto(&out.LastUpdateTime)
|
|
}
|
|
|
|
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkConnectStatus.
|
|
func (in *SparkConnectStatus) DeepCopy() *SparkConnectStatus {
|
|
if in == nil {
|
|
return nil
|
|
}
|
|
out := new(SparkConnectStatus)
|
|
in.DeepCopyInto(out)
|
|
return out
|
|
}
|
|
|
|
// DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
|
|
func (in *SparkPodSpec) DeepCopyInto(out *SparkPodSpec) {
|
|
*out = *in
|
|
if in.Cores != nil {
|
|
in, out := &in.Cores, &out.Cores
|
|
*out = new(int32)
|
|
**out = **in
|
|
}
|
|
if in.Memory != nil {
|
|
in, out := &in.Memory, &out.Memory
|
|
*out = new(string)
|
|
**out = **in
|
|
}
|
|
if in.Template != nil {
|
|
in, out := &in.Template, &out.Template
|
|
*out = new(v1.PodTemplateSpec)
|
|
(*in).DeepCopyInto(*out)
|
|
}
|
|
}
|
|
|
|
// DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SparkPodSpec.
|
|
func (in *SparkPodSpec) DeepCopy() *SparkPodSpec {
|
|
if in == nil {
|
|
return nil
|
|
}
|
|
out := new(SparkPodSpec)
|
|
in.DeepCopyInto(out)
|
|
return out
|
|
}
|