Uses of Class
org.apache.flink.runtime.util.SerializedValue

Packages that use SerializedValue

Package	Description
org.apache.flink.runtime.accumulators
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.client
org.apache.flink.runtime.deployment
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobmanager.accumulators
org.apache.flink.runtime.messages.checkpoint	This package contains the messages that are sent between JobManager and TaskManager to coordinate the checkpoint snapshots of the distributed dataflow.

Uses of SerializedValue in org.apache.flink.runtime.accumulators

Subclasses of SerializedValue in org.apache.flink.runtime.accumulators

Modifier and Type	Class and Description
class	AccumulatorEvent This class encapsulates a map of accumulators for a single job.

Uses of SerializedValue in org.apache.flink.runtime.checkpoint

Methods in org.apache.flink.runtime.checkpoint that return SerializedValue

Modifier and Type	Method and Description
SerializedValue<StateHandle<?>>	StateForTask.getState()

Methods in org.apache.flink.runtime.checkpoint with parameters of type SerializedValue

Modifier and Type	Method and Description
boolean	PendingCheckpoint.acknowledgeTask(ExecutionAttemptID attemptID, SerializedValue<StateHandle<?>> state)

Constructors in org.apache.flink.runtime.checkpoint with parameters of type SerializedValue

Constructor and Description
StateForTask(SerializedValue<StateHandle<?>> state, JobVertexID operatorId, int subtask)

Uses of SerializedValue in org.apache.flink.runtime.client

Methods in org.apache.flink.runtime.client that return types with arguments of type SerializedValue

Modifier and Type	Method and Description
Map<String,SerializedValue<Object>>	SerializedJobExecutionResult.getSerializedAccumulatorResults()

Constructor parameters in org.apache.flink.runtime.client with type arguments of type SerializedValue

Constructor and Description
SerializedJobExecutionResult(org.apache.flink.api.common.JobID jobID, long netRuntime, Map<String,SerializedValue<Object>> accumulators) Creates a new SerializedJobExecutionResult.

Uses of SerializedValue in org.apache.flink.runtime.deployment

Methods in org.apache.flink.runtime.deployment that return SerializedValue

Modifier and Type	Method and Description
SerializedValue<StateHandle<?>>	TaskDeploymentDescriptor.getOperatorState()

Constructors in org.apache.flink.runtime.deployment with parameters of type SerializedValue

Constructor and Description

TaskDeploymentDescriptor(org.apache.flink.api.common.JobID jobID, JobVertexID vertexID, ExecutionAttemptID executionId, String taskName, int indexInSubtaskGroup, int numberOfSubtasks, org.apache.flink.configuration.Configuration jobConfiguration, org.apache.flink.configuration.Configuration taskConfiguration, String invokableClassName, List<ResultPartitionDeploymentDescriptor> producedPartitions, List<InputGateDeploymentDescriptor> inputGates, List<BlobKey> requiredJarFiles, int targetSlotNumber, SerializedValue<StateHandle<?>> operatorState) Constructs a task deployment descriptor.

Uses of SerializedValue in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph with parameters of type SerializedValue

Modifier and Type	Method and Description
void	Execution.setInitialState(SerializedValue<StateHandle<?>> initialState)

Uses of SerializedValue in org.apache.flink.runtime.jobmanager.accumulators

Methods in org.apache.flink.runtime.jobmanager.accumulators that return types with arguments of type SerializedValue

Modifier and Type	Method and Description
Map<String,SerializedValue<Object>>	AccumulatorManager.getJobAccumulatorResultsSerialized(org.apache.flink.api.common.JobID jobID)

Uses of SerializedValue in org.apache.flink.runtime.messages.checkpoint

Methods in org.apache.flink.runtime.messages.checkpoint that return SerializedValue

Modifier and Type	Method and Description
SerializedValue<StateHandle<?>>	AcknowledgeCheckpoint.getState()

Constructors in org.apache.flink.runtime.messages.checkpoint with parameters of type SerializedValue

Constructor and Description
AcknowledgeCheckpoint(org.apache.flink.api.common.JobID job, ExecutionAttemptID taskExecutionId, long checkpointId, SerializedValue<StateHandle<?>> state)