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

Packages that use SerializedValue

Package	Description
org.apache.flink.api.common.accumulators
org.apache.flink.runtime.blob
org.apache.flink.runtime.client
org.apache.flink.runtime.deployment
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.rest.messages
org.apache.flink.runtime.rest.messages.json
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.internal
org.apache.flink.streaming.connectors.kafka.internals
org.apache.flink.util

Uses of SerializedValue in org.apache.flink.api.common.accumulators

Method parameters in org.apache.flink.api.common.accumulators with type arguments of type SerializedValue

Modifier and Type	Method and Description
static Map<String,OptionalFailure<Object>>	AccumulatorHelper.deserializeAccumulators(Map<String,SerializedValue<OptionalFailure<Object>>> serializedAccumulators, ClassLoader loader) Takes the serialized accumulator results and tries to deserialize them using the provided class loader.

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

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

Modifier and Type	Method and Description
static <T> Either<SerializedValue<T>,PermanentBlobKey>	BlobWriter.serializeAndTryOffload(T value, JobID jobId, BlobWriter blobWriter) Serializes the given value and offloads it to the BlobServer if its size exceeds the minimum offloading size of the BlobServer.

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<OptionalFailure<Object>>>	SerializedJobExecutionResult.getSerializedAccumulatorResults()

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

Constructor and Description
SerializedJobExecutionResult(JobID jobID, long netRuntime, Map<String,SerializedValue<OptionalFailure<Object>>> accumulators) Creates a new SerializedJobExecutionResult.

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

Fields in org.apache.flink.runtime.deployment declared as SerializedValue

Modifier and Type	Field and Description
SerializedValue<T>	TaskDeploymentDescriptor.NonOffloaded.serializedValue The serialized value.

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

Modifier and Type	Method and Description
SerializedValue<JobInformation>	TaskDeploymentDescriptor.getSerializedJobInformation() Return the sub task's serialized job information.
SerializedValue<TaskInformation>	TaskDeploymentDescriptor.getSerializedTaskInformation() Return the sub task's serialized task information.

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

Constructor and Description
NonOffloaded(SerializedValue<T> serializedValue)

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

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

Modifier and Type	Method and Description
SerializedValue<ExecutionConfig>	JobInformation.getSerializedExecutionConfig()

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

Modifier and Type	Method and Description
Map<String,SerializedValue<OptionalFailure<Object>>>	AccessExecutionGraph.getAccumulatorsSerialized() Returns a map containing the serialized values of user-defined accumulators.
Map<String,SerializedValue<OptionalFailure<Object>>>	ExecutionGraph.getAccumulatorsSerialized() Gets a serialized accumulator map.
Map<String,SerializedValue<OptionalFailure<Object>>>	ArchivedExecutionGraph.getAccumulatorsSerialized()
Either<SerializedValue<JobInformation>,PermanentBlobKey>	ExecutionGraph.getJobInformationOrBlobKey()
Either<SerializedValue<TaskInformation>,PermanentBlobKey>	ExecutionJobVertex.getTaskInformationOrBlobKey()

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

Constructor and Description
JobInformation(JobID jobId, String jobName, SerializedValue<ExecutionConfig> serializedExecutionConfig, Configuration jobConfiguration, Collection<PermanentBlobKey> requiredJarFileBlobKeys, Collection<URL> requiredClasspathURLs)

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

Constructor and Description

ArchivedExecutionGraph(JobID jobID, String jobName, Map<JobVertexID,ArchivedExecutionJobVertex> tasks, List<ArchivedExecutionJobVertex> verticesInCreationOrder, long[] stateTimestamps, JobStatus state, ErrorInfo failureCause, String jsonPlan, StringifiedAccumulatorResult[] archivedUserAccumulators, Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators, ArchivedExecutionConfig executionConfig, boolean isStoppable, CheckpointCoordinatorConfiguration jobCheckpointingConfiguration, CheckpointStatsSnapshot checkpointStatsSnapshot)

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

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

Modifier and Type	Method and Description
SerializedValue<ExecutionConfig>	JobGraph.getSerializedExecutionConfig() Returns the ExecutionConfig

Uses of SerializedValue in org.apache.flink.runtime.jobgraph.tasks

Methods in org.apache.flink.runtime.jobgraph.tasks that return SerializedValue

Modifier and Type	Method and Description
SerializedValue<StateBackend>	JobCheckpointingSettings.getDefaultStateBackend()
SerializedValue<MasterTriggerRestoreHook.Factory[]>	JobCheckpointingSettings.getMasterHooks()

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

Constructor and Description
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, SerializedValue<StateBackend> defaultStateBackend)
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, SerializedValue<StateBackend> defaultStateBackend, SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks)
JobCheckpointingSettings(List<JobVertexID> verticesToTrigger, List<JobVertexID> verticesToAcknowledge, List<JobVertexID> verticesToConfirm, CheckpointCoordinatorConfiguration checkpointCoordinatorConfiguration, SerializedValue<StateBackend> defaultStateBackend, SerializedValue<MasterTriggerRestoreHook.Factory[]> masterHooks)

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

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

Modifier and Type	Method and Description
Map<String,SerializedValue<OptionalFailure<Object>>>	JobResult.getAccumulatorResults()

Method parameters in org.apache.flink.runtime.jobmaster with type arguments of type SerializedValue

Modifier and Type	Method and Description
JobResult.Builder	JobResult.Builder.accumulatorResults(Map<String,SerializedValue<OptionalFailure<Object>>> accumulatorResults)

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

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

Modifier and Type	Method and Description
Map<String,SerializedValue<OptionalFailure<Object>>>	JobAccumulatorsInfo.getSerializedUserAccumulators()

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

Constructor and Description
JobAccumulatorsInfo(List<JobAccumulatorsInfo.JobAccumulator> jobAccumulators, List<JobAccumulatorsInfo.UserTaskAccumulator> userAccumulators, Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators)

Uses of SerializedValue in org.apache.flink.runtime.rest.messages.json

Methods in org.apache.flink.runtime.rest.messages.json that return SerializedValue

Modifier and Type	Method and Description
SerializedValue<?>	SerializedValueDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser p, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext ctxt)

Methods in org.apache.flink.runtime.rest.messages.json with parameters of type SerializedValue

Modifier and Type	Method and Description
void	SerializedValueSerializer.serialize(SerializedValue<?> value, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator gen, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider provider)

Uses of SerializedValue in org.apache.flink.streaming.connectors.kafka

Methods in org.apache.flink.streaming.connectors.kafka with parameters of type SerializedValue

Modifier and Type	Method and Description
protected AbstractFetcher<T,?>	FlinkKafkaConsumer08.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected AbstractFetcher<T,?>	FlinkKafkaConsumer08.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected AbstractFetcher<T,?>	FlinkKafkaConsumer.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected AbstractFetcher<T,?>	FlinkKafkaConsumer.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected AbstractFetcher<T,?>	FlinkKafkaConsumer010.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected AbstractFetcher<T,?>	FlinkKafkaConsumer010.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected AbstractFetcher<T,?>	FlinkKafkaConsumer09.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected AbstractFetcher<T,?>	FlinkKafkaConsumer09.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup consumerMetricGroup, boolean useMetrics)
protected abstract AbstractFetcher<T,?>	FlinkKafkaConsumerBase.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> subscribedPartitionsToStartOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup kafkaMetricGroup, boolean useMetrics) Creates the fetcher that connect to the Kafka brokers, pulls data, deserialized the data, and emits it into the data streams.
protected abstract AbstractFetcher<T,?>	FlinkKafkaConsumerBase.createFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> subscribedPartitionsToStartOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, OffsetCommitMode offsetCommitMode, MetricGroup kafkaMetricGroup, boolean useMetrics) Creates the fetcher that connect to the Kafka brokers, pulls data, deserialized the data, and emits it into the data streams.

Uses of SerializedValue in org.apache.flink.streaming.connectors.kafka.internal

Constructors in org.apache.flink.streaming.connectors.kafka.internal with parameters of type SerializedValue

Constructor and Description
Kafka010Fetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics, FlinkConnectorRateLimiter rateLimiter)
Kafka010Fetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics, FlinkConnectorRateLimiter rateLimiter)
Kafka09Fetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics, FlinkConnectorRateLimiter rateLimiter)
Kafka09Fetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics, FlinkConnectorRateLimiter rateLimiter)
KafkaFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics)
KafkaFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics)

Uses of SerializedValue in org.apache.flink.streaming.connectors.kafka.internals

Constructors in org.apache.flink.streaming.connectors.kafka.internals with parameters of type SerializedValue

Constructor and Description
AbstractFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> seedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, MetricGroup consumerMetricGroup, boolean useMetrics)
AbstractFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> seedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, MetricGroup consumerMetricGroup, boolean useMetrics)
Kafka08Fetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> seedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long autoCommitInterval, MetricGroup consumerMetricGroup, boolean useMetrics)
Kafka08Fetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> seedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, StreamingRuntimeContext runtimeContext, KafkaDeserializationSchema<T> deserializer, Properties kafkaProperties, long autoCommitInterval, MetricGroup consumerMetricGroup, boolean useMetrics)

Uses of SerializedValue in org.apache.flink.util

Methods in org.apache.flink.util that return SerializedValue

Modifier and Type	Method and Description
static <T> SerializedValue<T>	SerializedValue.fromBytes(byte[] serializedData)