Serialized Form

Package org.apache.flink.autoscaler.exceptions

Class org.apache.flink.autoscaler.exceptions.NotReadyException extends java.lang.RuntimeException implements Serializable

Package org.apache.flink.autoscaler.metrics

Class org.apache.flink.autoscaler.metrics.MetricNotFoundException extends java.lang.RuntimeException implements Serializable

Package org.apache.flink.autoscaler.utils

Class org.apache.flink.autoscaler.utils.AutoScalerSerDeModule extends com.fasterxml.jackson.databind.module.SimpleModule implements Serializable

Package org.apache.flink.kubernetes.operator.api

Class org.apache.flink.kubernetes.operator.api.AbstractFlinkResource extends io.fabric8.kubernetes.client.CustomResource<SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>> implements Serializable

Class org.apache.flink.kubernetes.operator.api.FlinkDeployment extends AbstractFlinkResource<FlinkDeploymentSpec,FlinkDeploymentStatus> implements Serializable

Class org.apache.flink.kubernetes.operator.api.FlinkDeploymentList extends io.fabric8.kubernetes.api.model.DefaultKubernetesResourceList<FlinkDeployment> implements Serializable

Class org.apache.flink.kubernetes.operator.api.FlinkSessionJob extends AbstractFlinkResource<FlinkSessionJobSpec,FlinkSessionJobStatus> implements Serializable

Class org.apache.flink.kubernetes.operator.api.FlinkSessionJobList extends io.fabric8.kubernetes.api.model.DefaultKubernetesResourceList<FlinkSessionJob> implements Serializable

Package org.apache.flink.kubernetes.operator.api.validation

Class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker.CompatibilityError extends java.lang.RuntimeException implements Serializable

Package org.apache.flink.kubernetes.operator.exception

Class org.apache.flink.kubernetes.operator.exception.DeploymentFailedException extends java.lang.RuntimeException implements Serializable

serialVersionUID:

-1070179896083579221L

Serialized Fields

reason

java.lang.String reason

Class org.apache.flink.kubernetes.operator.exception.MissingJobManagerException extends java.lang.RuntimeException implements Serializable

Class org.apache.flink.kubernetes.operator.exception.MissingSessionJobException extends java.lang.RuntimeException implements Serializable

Class org.apache.flink.kubernetes.operator.exception.ReconciliationException extends java.lang.RuntimeException implements Serializable

serialVersionUID:

2260638990044248181L

Class org.apache.flink.kubernetes.operator.exception.RecoveryFailureException extends java.lang.RuntimeException implements Serializable

Serialized Fields

reason

java.lang.String reason

Class org.apache.flink.kubernetes.operator.exception.StatusConflictException extends java.lang.RuntimeException implements Serializable

serialVersionUID:

2260638990044248181L

Class org.apache.flink.kubernetes.operator.exception.UnknownJobException extends java.lang.RuntimeException implements Serializable

Class org.apache.flink.kubernetes.operator.exception.ValidationException extends java.lang.RuntimeException implements Serializable

Package org.apache.flink.runtime.jobgraph

Class org.apache.flink.runtime.jobgraph.InputOutputFormatContainer.FormatUserCodeTable extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

inputFormats

java.util.Map<org.apache.flink.runtime.jobgraph.OperatorID,org.apache.flink.api.common.operators.util.UserCodeWrapper<? extends org.apache.flink.api.common.io.InputFormat<?,?>>> inputFormats

outputFormats

java.util.Map<org.apache.flink.runtime.jobgraph.OperatorID,org.apache.flink.api.common.operators.util.UserCodeWrapper<? extends org.apache.flink.api.common.io.OutputFormat<?>>> outputFormats

Class org.apache.flink.runtime.jobgraph.InputOutputFormatVertex extends org.apache.flink.runtime.jobgraph.JobVertex implements Serializable

serialVersionUID:

1L

Serialized Fields

formatDescriptions

java.util.Map<org.apache.flink.runtime.jobgraph.OperatorID,java.lang.String> formatDescriptions

Class org.apache.flink.runtime.jobgraph.IntermediateDataSet extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

consumers

java.util.List<org.apache.flink.runtime.jobgraph.JobEdge> consumers

distributionPattern

org.apache.flink.runtime.jobgraph.DistributionPattern distributionPattern

id

org.apache.flink.runtime.jobgraph.IntermediateDataSetID id

isBroadcast

boolean isBroadcast

producer

org.apache.flink.runtime.jobgraph.JobVertex producer

resultType

org.apache.flink.runtime.io.network.partition.ResultPartitionType resultType

Class org.apache.flink.runtime.jobgraph.IntermediateDataSetID extends org.apache.flink.util.AbstractID implements Serializable

serialVersionUID:

1L

Class org.apache.flink.runtime.jobgraph.IntermediateResultPartitionID extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

intermediateDataSetID

org.apache.flink.runtime.jobgraph.IntermediateDataSetID intermediateDataSetID

partitionNum

int partitionNum

Class org.apache.flink.runtime.jobgraph.JobEdge extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

distributionPattern

org.apache.flink.runtime.jobgraph.DistributionPattern distributionPattern

downstreamSubtaskStateMapper

org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper downstreamSubtaskStateMapper

isBroadcast

boolean isBroadcast

isForward

boolean isForward

operatorLevelCachingDescription

java.lang.String operatorLevelCachingDescription

preProcessingOperationName

java.lang.String preProcessingOperationName

shipStrategyName

java.lang.String shipStrategyName

source

org.apache.flink.runtime.jobgraph.IntermediateDataSet source

target

org.apache.flink.runtime.jobgraph.JobVertex target

upstreamSubtaskStateMapper

org.apache.flink.runtime.io.network.api.writer.SubtaskStateMapper upstreamSubtaskStateMapper

Class org.apache.flink.runtime.jobgraph.JobGraph extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

approximateLocalRecovery

boolean approximateLocalRecovery

classpaths

java.util.List<java.net.URL> classpaths

dynamic

boolean dynamic

jobConfiguration

org.apache.flink.configuration.Configuration jobConfiguration

jobID

org.apache.flink.api.common.JobID jobID

jobName

java.lang.String jobName

jobStatusHooks

java.util.List<org.apache.flink.runtime.executiongraph.JobStatusHook> jobStatusHooks

jobType

org.apache.flink.runtime.jobgraph.JobType jobType

savepointRestoreSettings

org.apache.flink.runtime.jobgraph.SavepointRestoreSettings savepointRestoreSettings

serializedExecutionConfig

org.apache.flink.util.SerializedValue<org.apache.flink.api.common.ExecutionConfig> serializedExecutionConfig

snapshotSettings

org.apache.flink.runtime.jobgraph.tasks.JobCheckpointingSettings snapshotSettings

taskVertices

java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,org.apache.flink.runtime.jobgraph.JobVertex> taskVertices

userArtifacts

java.util.Map<java.lang.String,org.apache.flink.api.common.cache.DistributedCache.DistributedCacheEntry> userArtifacts

userJarBlobKeys

java.util.List<org.apache.flink.runtime.blob.PermanentBlobKey> userJarBlobKeys

userJars

java.util.List<org.apache.flink.core.fs.Path> userJars

Class org.apache.flink.runtime.jobgraph.JobResourceRequirements extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

vertexResources

java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,JobVertexResourceRequirements> vertexResources

Class org.apache.flink.runtime.jobgraph.JobVertex extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

coLocationGroup

org.apache.flink.runtime.jobmanager.scheduler.CoLocationGroupImpl coLocationGroup

configuration

org.apache.flink.configuration.Configuration configuration

id

org.apache.flink.runtime.jobgraph.JobVertexID id

inputs

java.util.List<org.apache.flink.runtime.jobgraph.JobEdge> inputs

inputSplitSource

org.apache.flink.core.io.InputSplitSource<?> inputSplitSource

intermediateDataSetIdsToConsume

java.util.List<org.apache.flink.runtime.jobgraph.IntermediateDataSetID> intermediateDataSetIdsToConsume

invokableClassName

java.lang.String invokableClassName

isStoppable

boolean isStoppable

maxParallelism

int maxParallelism

minResources

org.apache.flink.api.common.operators.ResourceSpec minResources

name

java.lang.String name

operatorCoordinators

java.util.List<org.apache.flink.util.SerializedValue<org.apache.flink.runtime.operators.coordination.OperatorCoordinator.Provider>> operatorCoordinators

operatorDescription

java.lang.String operatorDescription

operatorIDs

java.util.List<org.apache.flink.runtime.OperatorIDPair> operatorIDs

operatorName

java.lang.String operatorName

operatorPrettyName

java.lang.String operatorPrettyName

parallelism

int parallelism

parallelismConfigured

boolean parallelismConfigured

preferredResources

org.apache.flink.api.common.operators.ResourceSpec preferredResources

resultOptimizerProperties

java.lang.String resultOptimizerProperties

results

java.util.Map<org.apache.flink.runtime.jobgraph.IntermediateDataSetID,org.apache.flink.runtime.jobgraph.IntermediateDataSet> results

slotSharingGroup

org.apache.flink.runtime.jobmanager.scheduler.SlotSharingGroup slotSharingGroup

supportsConcurrentExecutionAttempts

boolean supportsConcurrentExecutionAttempts

Class org.apache.flink.runtime.jobgraph.JobVertexID extends org.apache.flink.util.AbstractID implements Serializable

serialVersionUID:

1L

Class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

parallelism

JobVertexResourceRequirements.Parallelism parallelism

Class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements.Parallelism extends java.lang.Object implements Serializable

Serialized Fields

lowerBound

int lowerBound

upperBound

int upperBound

Class org.apache.flink.runtime.jobgraph.OperatorID extends org.apache.flink.util.AbstractID implements Serializable

serialVersionUID:

1L

Class org.apache.flink.runtime.jobgraph.SavepointRestoreSettings extends java.lang.Object implements Serializable

serialVersionUID:

87377506900849777L

Serialized Fields

allowNonRestoredState

boolean allowNonRestoredState

restoreMode

org.apache.flink.runtime.jobgraph.RestoreMode restoreMode

restorePath

java.lang.String restorePath

Package org.apache.flink.runtime.rest.messages.job.metrics

Class org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetricsResponseBody.Deserializer extends org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.StdDeserializer<org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetricsResponseBody> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetricsResponseBody.Serializer extends org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ser.std.StdSerializer<org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetricsResponseBody> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.runtime.rest.messages.job.metrics.MetricCollectionResponseBody.Deserializer extends org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.StdDeserializer<org.apache.flink.runtime.rest.messages.job.metrics.MetricCollectionResponseBody> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.runtime.rest.messages.job.metrics.MetricCollectionResponseBody.Serializer extends org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ser.std.StdSerializer<org.apache.flink.runtime.rest.messages.job.metrics.MetricCollectionResponseBody> implements Serializable

serialVersionUID:

1L