edu.iu.dsc.tws.rsched.schedulers.k8s

Class RequestObjectBuilder

java.lang.Object

edu.iu.dsc.tws.rsched.schedulers.k8s.RequestObjectBuilder

public final class RequestObjectBuilder
extends java.lang.Object

build objects to submit to Kubernetes master

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	uploadMethod

Method Summary

Modifier and Type	Method and Description
static void	constructAffinity(V1PodSpec podSpec)
static V1Container	constructContainer(ComputeResource computeResource, int containerIndex) construct a container
static java.util.List<V1EnvVar>	constructEnvironmentVariables(java.lang.String containerName, int workerPort, int jvmMem) set environment variables for containers
static V1PodTemplateSpec	constructPodTemplate(ComputeResource computeResource) construct pod template
static V1ConfigMap	createConfigMap(JobAPI.Job job) create a ConfigMap object It will have start counts for workers
static V1Service	createHeadlessServiceObject(java.lang.String serviceName)
static V1Service	createJobServiceObject()
static V1Service	createNodePortServiceObject() create service for NodePort
static V1Volume	createPersistentVolume(java.lang.String claimName)
static V1PersistentVolumeClaim	createPersistentVolumeClaimObject(int numberOfWorkers)
static V1PersistentVolume	createPersistentVolumeObject(java.lang.String pvName) we initially used this method to create PersistentVolumes we no longer use this method it is just here in case we may need it for some reason at one point
static V1Volume	createSecretVolume(java.lang.String secretName)
static V1StatefulSet	createStatefulSetForWorkers(ComputeResource computeResource) create StatefulSet object for a job
static V1Volume	createVolatileVolume(double volumeSize)
static java.util.ArrayList<V1EnvVar>	getCommonEnvVars() add common environment variables to both jm and workers
static java.lang.String	getJobMasterIP()
static void	init(Config cnfg, java.lang.String jID, long jpFileSize, long jobSubmitTime, java.lang.String encodedNodeInfoStr)
static void	setNodeAffinity(V1Affinity affinity)
static void	setUniformMappingAffinity(V1Affinity affinity)
static void	setUploadMethod(java.lang.String uploadType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

uploadMethod

public static java.lang.String uploadMethod

Method Detail

init

public static void init(Config cnfg,
                        java.lang.String jID,
                        long jpFileSize,
                        long jobSubmitTime,
                        java.lang.String encodedNodeInfoStr)

setUploadMethod

public static void setUploadMethod(java.lang.String uploadType)

getJobMasterIP

public static java.lang.String getJobMasterIP()

createStatefulSetForWorkers

public static V1StatefulSet createStatefulSetForWorkers(ComputeResource computeResource)

create StatefulSet object for a job

constructPodTemplate

public static V1PodTemplateSpec constructPodTemplate(ComputeResource computeResource)

construct pod template

constructAffinity

public static void constructAffinity(V1PodSpec podSpec)

createVolatileVolume

public static V1Volume createVolatileVolume(double volumeSize)

createPersistentVolume

public static V1Volume createPersistentVolume(java.lang.String claimName)

createSecretVolume

public static V1Volume createSecretVolume(java.lang.String secretName)

constructContainer

public static V1Container constructContainer(ComputeResource computeResource,
                                             int containerIndex)

construct a container

constructEnvironmentVariables

public static java.util.List<V1EnvVar> constructEnvironmentVariables(java.lang.String containerName,
                                                                     int workerPort,
                                                                     int jvmMem)

set environment variables for containers

getCommonEnvVars

public static java.util.ArrayList<V1EnvVar> getCommonEnvVars()

add common environment variables to both jm and workers

setNodeAffinity

public static void setNodeAffinity(V1Affinity affinity)

setUniformMappingAffinity

public static void setUniformMappingAffinity(V1Affinity affinity)

createJobServiceObject

public static V1Service createJobServiceObject()

createHeadlessServiceObject

public static V1Service createHeadlessServiceObject(java.lang.String serviceName)

createNodePortServiceObject

public static V1Service createNodePortServiceObject()

create service for NodePort

Returns:

createPersistentVolumeObject

public static V1PersistentVolume createPersistentVolumeObject(java.lang.String pvName)

we initially used this method to create PersistentVolumes we no longer use this method it is just here in case we may need it for some reason at one point

createPersistentVolumeClaimObject

public static V1PersistentVolumeClaim createPersistentVolumeClaimObject(int numberOfWorkers)

createConfigMap

public static V1ConfigMap createConfigMap(JobAPI.Job job)

create a ConfigMap object It will have start counts for workers

Returns: