flink-streaming-java_2.11-1.10.0.jar中文-英文对照文档.zip

org.apache.flinkflink-streaming-java_2.111.10.0API文档接口文档中文文档中英对照JavaJavaDoc操作手册Maven依赖Gradle依赖Java开发使用指南离线文档Java编程寒水馨

文件基础信息

文件名称: flink-streaming-java_2.11-1.10.0.jar中文-英文对照文档.zip

文件类型: Java 组件中文文档

文件大小: 4.69 MB

选择下载方式

方式1：微信扫码支付下载

文件价格：¥1.5

支付完成后自动开始下载

方式2：兑换码下载

前往链动小铺购买【Java 组件中文文档兑换码】

文件简介

flink-streaming-java_2.11-1.10.0.jar中文-英文对照文档.zip 中包含以下内容

中文-英文对照文档：位于压缩包内的“文档”文件夹中
说明文件：使用说明.txt、README.md
Maven依赖：flink-streaming-java_2.11-1.10.0.jar Maven依赖信息(可用于项目pom.xml).txt
Gradle依赖：flink-streaming-java_2.11-1.10.0.jar Gradle依赖信息(可用于项目build.gradle).txt
jar包下载地址：flink-streaming-java_2.11-1.10.0.jar下载地址(官方地址+国内镜像地址).txt
源码下载地址：flink-streaming-java_2.11-1.10.0-sources.jar下载地址(官方地址+国内镜像地址).txt

使用方法

解压 flink-streaming-java_2.11-1.10.0.jar中文-英文对照文档.zip，找到解压后的文件夹>文档>index.html，双击index.html即可用浏览器打开查看。
为了防止解压后路径太长导致浏览器无法打开，推荐在解压时选择“解压到当前文件夹”（放心，自带文件夹，文件不会散落一地）。
有时，一套Java组件会有多个jar，所以在下载前，请仔细阅读本篇描述，以确保这就是你需要的文件。

组件信息

简介

名称： flink-streaming-java
描述： org.apache.flink - flink-streaming-java_2.11
版本： 1.10.0

Maven依赖

<dependency>
	<groupId>org.apache.flink</groupId>
	<artifactId>flink-streaming-java_2.11</artifactId>
	<version>1.10.0</version>
</dependency>

Gradle依赖

Gradle:
	implementation group: 'org.apache.flink', name: 'flink-streaming-java_2.11', version: '1.10.0'
Gradle (Short):
	implementation 'org.apache.flink:flink-streaming-java_2.11:1.10.0'
Gradle (Kotlin):
	implementation("org.apache.flink:flink-streaming-java_2.11:1.10.0")

寒水馨 Java 组件中文文档系列说明

文档为 Java 组件的中文翻译文档
文档由 寒水馨 翻译整理，非官方版本
本系列文档获取地址：https://hanshuixin.org
本文档为人性化翻译，精心制作，请放心使用
本文档为双语同时展示，一行原文、一行译文，可逐行对照，避免了原文/译文来回切换的麻烦
有原文可参照，不再担心翻译偏差误导
边学技术、边学英语
只翻译了该翻译的内容，如：注释、说明、描述、用法讲解等
不该翻译的内容保持原样，如：类名、方法名、包名、类型、关键字、代码等

版权声明与来源信息

本翻译文档基于以下开源项目制作，严格遵守各项目的开源许可证，并在此列出其版权归属与许可证信息。

组件 GAV 坐标：org.apache.flink:flink-streaming-java_2.11:1.10.0
原始项目地址：https://central.sonatype.com/artifact/org.apache.flink/flink-streaming-java_2.11/1.10.0
许可证：The Apache Software License, Version 2.0
许可证链接：https://www.apache.org/licenses/LICENSE-2.0.txt
所有原始代码及注释版权归其原作者所有

本组件包含的 Java package（包）

org.apache.flink.streaming.api
org.apache.flink.streaming.api.checkpoint
org.apache.flink.streaming.api.collector.selector
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.environment
org.apache.flink.streaming.api.functions
org.apache.flink.streaming.api.functions.aggregation
org.apache.flink.streaming.api.functions.async
org.apache.flink.streaming.api.functions.co
org.apache.flink.streaming.api.functions.query
org.apache.flink.streaming.api.functions.sink
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.functions.timestamps
org.apache.flink.streaming.api.functions.windowing
org.apache.flink.streaming.api.functions.windowing.delta
org.apache.flink.streaming.api.functions.windowing.delta.extractor
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.api.operators.async.queue
org.apache.flink.streaming.api.operators.co
org.apache.flink.streaming.api.transformations
org.apache.flink.streaming.api.watermark
org.apache.flink.streaming.api.windowing.assigners
org.apache.flink.streaming.api.windowing.evictors
org.apache.flink.streaming.api.windowing.time
org.apache.flink.streaming.api.windowing.triggers
org.apache.flink.streaming.api.windowing.windows
org.apache.flink.streaming.experimental
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.metrics
org.apache.flink.streaming.runtime.operators
org.apache.flink.streaming.runtime.operators.windowing
org.apache.flink.streaming.runtime.operators.windowing.functions
org.apache.flink.streaming.runtime.partitioner
org.apache.flink.streaming.runtime.streamrecord
org.apache.flink.streaming.runtime.streamstatus
org.apache.flink.streaming.runtime.tasks
org.apache.flink.streaming.runtime.tasks.mailbox
org.apache.flink.streaming.util
org.apache.flink.streaming.util.functions
org.apache.flink.streaming.util.keys
org.apache.flink.streaming.util.serialization
org.apache.flink.streaming.util.typeutils

本组件包含的 Java class（类）

org.apache.flink.streaming.api.CheckpointingMode
org.apache.flink.streaming.api.SimpleTimerService
org.apache.flink.streaming.api.TimeCharacteristic
org.apache.flink.streaming.api.TimeDomain
org.apache.flink.streaming.api.TimerService
org.apache.flink.streaming.api.checkpoint.CheckpointedFunction
org.apache.flink.streaming.api.checkpoint.ExternallyInducedSource
org.apache.flink.streaming.api.checkpoint.ExternallyInducedSource.CheckpointTrigger
org.apache.flink.streaming.api.checkpoint.ListCheckpointed
org.apache.flink.streaming.api.checkpoint.WithMasterCheckpointHook
org.apache.flink.streaming.api.collector.selector.CopyingDirectedOutput
org.apache.flink.streaming.api.collector.selector.DirectedOutput
org.apache.flink.streaming.api.collector.selector.OutputSelector
org.apache.flink.streaming.api.datastream.AllWindowedStream
org.apache.flink.streaming.api.datastream.AsyncDataStream
org.apache.flink.streaming.api.datastream.AsyncDataStream.OutputMode
org.apache.flink.streaming.api.datastream.BroadcastConnectedStream
org.apache.flink.streaming.api.datastream.BroadcastStream
org.apache.flink.streaming.api.datastream.CoGroupedStreams
org.apache.flink.streaming.api.datastream.CoGroupedStreams.TaggedUnion
org.apache.flink.streaming.api.datastream.CoGroupedStreams.UnionSerializerConfigSnapshot
org.apache.flink.streaming.api.datastream.CoGroupedStreams.UnionSerializerSnapshot
org.apache.flink.streaming.api.datastream.CoGroupedStreams.WithWindow
org.apache.flink.streaming.api.datastream.ConnectedStreams
org.apache.flink.streaming.api.datastream.DataStream
org.apache.flink.streaming.api.datastream.DataStreamSink
org.apache.flink.streaming.api.datastream.DataStreamSource
org.apache.flink.streaming.api.datastream.DataStreamUtils
org.apache.flink.streaming.api.datastream.IterativeStream
org.apache.flink.streaming.api.datastream.IterativeStream.ConnectedIterativeStreams
org.apache.flink.streaming.api.datastream.JoinedStreams
org.apache.flink.streaming.api.datastream.JoinedStreams.WithWindow
org.apache.flink.streaming.api.datastream.KeyedStream
org.apache.flink.streaming.api.datastream.KeyedStream.IntervalJoin
org.apache.flink.streaming.api.datastream.KeyedStream.IntervalJoined
org.apache.flink.streaming.api.datastream.QueryableStateStream
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
org.apache.flink.streaming.api.datastream.SplitStream
org.apache.flink.streaming.api.datastream.StreamProjection
org.apache.flink.streaming.api.datastream.UnsupportedTimeCharacteristicException
org.apache.flink.streaming.api.datastream.WindowedStream
org.apache.flink.streaming.api.environment.CheckpointConfig
org.apache.flink.streaming.api.environment.CheckpointConfig.ExternalizedCheckpointCleanup
org.apache.flink.streaming.api.environment.ExecutionCheckpointingOptions
org.apache.flink.streaming.api.environment.LocalStreamEnvironment
org.apache.flink.streaming.api.environment.RemoteStreamEnvironment
org.apache.flink.streaming.api.environment.StreamContextEnvironment
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
org.apache.flink.streaming.api.environment.StreamExecutionEnvironmentFactory
org.apache.flink.streaming.api.environment.StreamPipelineOptions
org.apache.flink.streaming.api.environment.StreamPlanEnvironment
org.apache.flink.streaming.api.functions.AscendingTimestampExtractor
org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks
org.apache.flink.streaming.api.functions.AssignerWithPunctuatedWatermarks
org.apache.flink.streaming.api.functions.IngestionTimeExtractor
org.apache.flink.streaming.api.functions.KeyedProcessFunction
org.apache.flink.streaming.api.functions.ProcessFunction
org.apache.flink.streaming.api.functions.TimestampAssigner
org.apache.flink.streaming.api.functions.TimestampExtractor
org.apache.flink.streaming.api.functions.aggregation.AggregationFunction
org.apache.flink.streaming.api.functions.aggregation.AggregationFunction.AggregationType
org.apache.flink.streaming.api.functions.aggregation.ComparableAggregator
org.apache.flink.streaming.api.functions.aggregation.Comparator
org.apache.flink.streaming.api.functions.aggregation.SumAggregator
org.apache.flink.streaming.api.functions.aggregation.SumFunction
org.apache.flink.streaming.api.functions.async.AsyncFunction
org.apache.flink.streaming.api.functions.async.ResultFuture
org.apache.flink.streaming.api.functions.async.RichAsyncFunction
org.apache.flink.streaming.api.functions.co.BaseBroadcastProcessFunction
org.apache.flink.streaming.api.functions.co.BroadcastProcessFunction
org.apache.flink.streaming.api.functions.co.CoFlatMapFunction
org.apache.flink.streaming.api.functions.co.CoMapFunction
org.apache.flink.streaming.api.functions.co.CoProcessFunction
org.apache.flink.streaming.api.functions.co.KeyedBroadcastProcessFunction
org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction
org.apache.flink.streaming.api.functions.co.ProcessJoinFunction
org.apache.flink.streaming.api.functions.co.RichCoFlatMapFunction
org.apache.flink.streaming.api.functions.co.RichCoMapFunction
org.apache.flink.streaming.api.functions.query.QueryableAppendingStateOperator
org.apache.flink.streaming.api.functions.query.QueryableValueStateOperator
org.apache.flink.streaming.api.functions.sink.DiscardingSink
org.apache.flink.streaming.api.functions.sink.OutputFormatSinkFunction
org.apache.flink.streaming.api.functions.sink.PrintSinkFunction
org.apache.flink.streaming.api.functions.sink.RichSinkFunction
org.apache.flink.streaming.api.functions.sink.SinkContextUtil
org.apache.flink.streaming.api.functions.sink.SinkFunction
org.apache.flink.streaming.api.functions.sink.SinkFunction.Context
org.apache.flink.streaming.api.functions.sink.SocketClientSink
org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction
org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction.State
org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction.StateSerializer
org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction.StateSerializerConfigSnapshot
org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction.StateSerializerSnapshot
org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunction.TransactionHolder
org.apache.flink.streaming.api.functions.sink.WriteFormat
org.apache.flink.streaming.api.functions.sink.WriteFormatAsCsv
org.apache.flink.streaming.api.functions.sink.WriteFormatAsText
org.apache.flink.streaming.api.functions.sink.WriteSinkFunction
org.apache.flink.streaming.api.functions.sink.WriteSinkFunctionByMillis
org.apache.flink.streaming.api.functions.sink.filesystem.Bucket
org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner
org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner.Context
org.apache.flink.streaming.api.functions.sink.filesystem.Buckets
org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig
org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig.OutputFileConfigBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.PartFileInfo
org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BulkFormatBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.RowFormatBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners.BasePathBucketAssigner
org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners.DateTimeBucketAssigner
org.apache.flink.streaming.api.functions.sink.filesystem.bucketassigners.SimpleVersionedStringSerializer
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy.PolicyBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.PolicyBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.OnCheckpointRollingPolicy
org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction
org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator
org.apache.flink.streaming.api.functions.source.FileMonitoringFunction
org.apache.flink.streaming.api.functions.source.FileMonitoringFunction.WatchType
org.apache.flink.streaming.api.functions.source.FileProcessingMode
org.apache.flink.streaming.api.functions.source.FileReadFunction
org.apache.flink.streaming.api.functions.source.FromElementsFunction
org.apache.flink.streaming.api.functions.source.FromIteratorFunction
org.apache.flink.streaming.api.functions.source.FromSplittableIteratorFunction
org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction
org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase
org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase
org.apache.flink.streaming.api.functions.source.ParallelSourceFunction
org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction
org.apache.flink.streaming.api.functions.source.RichSourceFunction
org.apache.flink.streaming.api.functions.source.SocketTextStreamFunction
org.apache.flink.streaming.api.functions.source.SourceFunction
org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext
org.apache.flink.streaming.api.functions.source.StatefulSequenceSource
org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit
org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor
org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.FailingHandler
org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.IgnoringHandler
org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.LoggingHandler
org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor.MonotonyViolationHandler
org.apache.flink.streaming.api.functions.timestamps.BoundedOutOfOrdernessTimestampExtractor
org.apache.flink.streaming.api.functions.windowing.AggregateApplyAllWindowFunction
org.apache.flink.streaming.api.functions.windowing.AggregateApplyWindowFunction
org.apache.flink.streaming.api.functions.windowing.AllWindowFunction
org.apache.flink.streaming.api.functions.windowing.FoldApplyAllWindowFunction
org.apache.flink.streaming.api.functions.windowing.FoldApplyProcessAllWindowFunction
org.apache.flink.streaming.api.functions.windowing.FoldApplyProcessWindowFunction
org.apache.flink.streaming.api.functions.windowing.FoldApplyWindowFunction
org.apache.flink.streaming.api.functions.windowing.InternalProcessApplyAllWindowContext
org.apache.flink.streaming.api.functions.windowing.InternalProcessApplyWindowContext
org.apache.flink.streaming.api.functions.windowing.PassThroughAllWindowFunction
org.apache.flink.streaming.api.functions.windowing.PassThroughWindowFunction
org.apache.flink.streaming.api.functions.windowing.ProcessAllWindowFunction
org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction
org.apache.flink.streaming.api.functions.windowing.ReduceApplyAllWindowFunction
org.apache.flink.streaming.api.functions.windowing.ReduceApplyProcessAllWindowFunction
org.apache.flink.streaming.api.functions.windowing.ReduceApplyProcessWindowFunction
org.apache.flink.streaming.api.functions.windowing.ReduceApplyWindowFunction
org.apache.flink.streaming.api.functions.windowing.RichAllWindowFunction
org.apache.flink.streaming.api.functions.windowing.RichProcessAllWindowFunction
org.apache.flink.streaming.api.functions.windowing.RichProcessWindowFunction
org.apache.flink.streaming.api.functions.windowing.RichWindowFunction
org.apache.flink.streaming.api.functions.windowing.WindowFunction
org.apache.flink.streaming.api.functions.windowing.delta.CosineDistance
org.apache.flink.streaming.api.functions.windowing.delta.DeltaFunction
org.apache.flink.streaming.api.functions.windowing.delta.EuclideanDistance
org.apache.flink.streaming.api.functions.windowing.delta.ExtractionAwareDeltaFunction
org.apache.flink.streaming.api.functions.windowing.delta.extractor.ArrayFromTuple
org.apache.flink.streaming.api.functions.windowing.delta.extractor.ConcatenatedExtract
org.apache.flink.streaming.api.functions.windowing.delta.extractor.Extractor
org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldFromArray
org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldFromTuple
org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldsFromArray
org.apache.flink.streaming.api.functions.windowing.delta.extractor.FieldsFromTuple
org.apache.flink.streaming.api.graph.JSONGenerator
org.apache.flink.streaming.api.graph.StreamConfig
org.apache.flink.streaming.api.graph.StreamEdge
org.apache.flink.streaming.api.graph.StreamGraph
org.apache.flink.streaming.api.graph.StreamGraphGenerator
org.apache.flink.streaming.api.graph.StreamGraphHasher
org.apache.flink.streaming.api.graph.StreamGraphHasherV2
org.apache.flink.streaming.api.graph.StreamGraphTranslator
org.apache.flink.streaming.api.graph.StreamGraphUserHashHasher
org.apache.flink.streaming.api.graph.StreamNode
org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator
org.apache.flink.streaming.api.operators.AbstractStreamOperator
org.apache.flink.streaming.api.operators.AbstractStreamOperator.CountingOutput
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator
org.apache.flink.streaming.api.operators.BackendRestorerProcedure
org.apache.flink.streaming.api.operators.BoundedMultiInput
org.apache.flink.streaming.api.operators.BoundedOneInput
org.apache.flink.streaming.api.operators.ChainingStrategy
org.apache.flink.streaming.api.operators.InputFormatOperatorFactory
org.apache.flink.streaming.api.operators.InputSelectable
org.apache.flink.streaming.api.operators.InputSelection
org.apache.flink.streaming.api.operators.InputSelection.Builder
org.apache.flink.streaming.api.operators.InternalTimeServiceManager
org.apache.flink.streaming.api.operators.InternalTimer
org.apache.flink.streaming.api.operators.InternalTimerService
org.apache.flink.streaming.api.operators.InternalTimerServiceImpl
org.apache.flink.streaming.api.operators.InternalTimerServiceSerializationProxy
org.apache.flink.streaming.api.operators.InternalTimersSnapshot
org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters
org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.InternalTimersSnapshotReader
org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.InternalTimersSnapshotWriter
org.apache.flink.streaming.api.operators.InternalTimersSnapshotReaderWriters.LegacyTimerSerializer
org.apache.flink.streaming.api.operators.KeyContext
org.apache.flink.streaming.api.operators.KeyedProcessOperator
org.apache.flink.streaming.api.operators.LegacyKeyedProcessOperator
org.apache.flink.streaming.api.operators.MailboxExecutor
org.apache.flink.streaming.api.operators.OnWatermarkCallback
org.apache.flink.streaming.api.operators.OneInputStreamOperator
org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory
org.apache.flink.streaming.api.operators.OperatorSnapshotFinalizer
org.apache.flink.streaming.api.operators.OperatorSnapshotFutures
org.apache.flink.streaming.api.operators.Output
org.apache.flink.streaming.api.operators.OutputFormatOperatorFactory
org.apache.flink.streaming.api.operators.OutputTypeConfigurable
org.apache.flink.streaming.api.operators.ProcessOperator
org.apache.flink.streaming.api.operators.SetupableStreamOperator
org.apache.flink.streaming.api.operators.SimpleInputFormatOperatorFactory
org.apache.flink.streaming.api.operators.SimpleOperatorFactory
org.apache.flink.streaming.api.operators.SimpleOutputFormatOperatorFactory
org.apache.flink.streaming.api.operators.SimpleUdfStreamOperatorFactory
org.apache.flink.streaming.api.operators.SourceReaderOperator
org.apache.flink.streaming.api.operators.StreamFilter
org.apache.flink.streaming.api.operators.StreamFlatMap
org.apache.flink.streaming.api.operators.StreamGroupedFold
org.apache.flink.streaming.api.operators.StreamGroupedReduce
org.apache.flink.streaming.api.operators.StreamMap
org.apache.flink.streaming.api.operators.StreamOperator
org.apache.flink.streaming.api.operators.StreamOperatorFactory
org.apache.flink.streaming.api.operators.StreamOperatorFactoryUtil
org.apache.flink.streaming.api.operators.StreamOperatorStateContext
org.apache.flink.streaming.api.operators.StreamProject
org.apache.flink.streaming.api.operators.StreamSink
org.apache.flink.streaming.api.operators.StreamSource
org.apache.flink.streaming.api.operators.StreamSourceContexts
org.apache.flink.streaming.api.operators.StreamTaskStateInitializer
org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl
org.apache.flink.streaming.api.operators.StreamingRuntimeContext
org.apache.flink.streaming.api.operators.TimerHeapInternalTimer
org.apache.flink.streaming.api.operators.TimerSerializer
org.apache.flink.streaming.api.operators.TimerSerializer.TimerSerializerConfigSnapshot
org.apache.flink.streaming.api.operators.TimerSerializerSnapshot
org.apache.flink.streaming.api.operators.TimestampedCollector
org.apache.flink.streaming.api.operators.Triggerable
org.apache.flink.streaming.api.operators.TwoInputStreamOperator
org.apache.flink.streaming.api.operators.UdfStreamOperatorFactory
org.apache.flink.streaming.api.operators.YieldingOperatorFactory
org.apache.flink.streaming.api.operators.async.AsyncWaitOperator
org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorFactory
org.apache.flink.streaming.api.operators.async.queue.OrderedStreamElementQueue
org.apache.flink.streaming.api.operators.async.queue.StreamElementQueue
org.apache.flink.streaming.api.operators.async.queue.UnorderedStreamElementQueue
org.apache.flink.streaming.api.operators.co.CoBroadcastWithKeyedOperator
org.apache.flink.streaming.api.operators.co.CoBroadcastWithNonKeyedOperator
org.apache.flink.streaming.api.operators.co.CoProcessOperator
org.apache.flink.streaming.api.operators.co.CoStreamFlatMap
org.apache.flink.streaming.api.operators.co.CoStreamMap
org.apache.flink.streaming.api.operators.co.IntervalJoinOperator
org.apache.flink.streaming.api.operators.co.IntervalJoinOperator.BufferEntrySerializerSnapshot
org.apache.flink.streaming.api.operators.co.IntervalJoinOperator.BufferSerializerConfigSnapshot
org.apache.flink.streaming.api.operators.co.KeyedCoProcessOperator
org.apache.flink.streaming.api.operators.co.LegacyKeyedCoProcessOperator
org.apache.flink.streaming.api.transformations.CoFeedbackTransformation
org.apache.flink.streaming.api.transformations.FeedbackTransformation
org.apache.flink.streaming.api.transformations.OneInputTransformation
org.apache.flink.streaming.api.transformations.PartitionTransformation
org.apache.flink.streaming.api.transformations.PhysicalTransformation
org.apache.flink.streaming.api.transformations.SelectTransformation
org.apache.flink.streaming.api.transformations.ShuffleMode
org.apache.flink.streaming.api.transformations.SideOutputTransformation
org.apache.flink.streaming.api.transformations.SinkTransformation
org.apache.flink.streaming.api.transformations.SourceTransformation
org.apache.flink.streaming.api.transformations.SplitTransformation
org.apache.flink.streaming.api.transformations.TwoInputTransformation
org.apache.flink.streaming.api.transformations.UnionTransformation
org.apache.flink.streaming.api.watermark.Watermark
org.apache.flink.streaming.api.windowing.assigners.BaseAlignedWindowAssigner
org.apache.flink.streaming.api.windowing.assigners.DynamicEventTimeSessionWindows
org.apache.flink.streaming.api.windowing.assigners.DynamicProcessingTimeSessionWindows
org.apache.flink.streaming.api.windowing.assigners.EventTimeSessionWindows
org.apache.flink.streaming.api.windowing.assigners.GlobalWindows
org.apache.flink.streaming.api.windowing.assigners.GlobalWindows.NeverTrigger
org.apache.flink.streaming.api.windowing.assigners.MergingWindowAssigner
org.apache.flink.streaming.api.windowing.assigners.MergingWindowAssigner.MergeCallback
org.apache.flink.streaming.api.windowing.assigners.ProcessingTimeSessionWindows
org.apache.flink.streaming.api.windowing.assigners.SessionWindowTimeGapExtractor
org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows
org.apache.flink.streaming.api.windowing.assigners.SlidingProcessingTimeWindows
org.apache.flink.streaming.api.windowing.assigners.SlidingTimeWindows
org.apache.flink.streaming.api.windowing.assigners.TumblingEventTimeWindows
org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindows
org.apache.flink.streaming.api.windowing.assigners.TumblingTimeWindows
org.apache.flink.streaming.api.windowing.assigners.WindowAssigner
org.apache.flink.streaming.api.windowing.assigners.WindowAssigner.WindowAssignerContext
org.apache.flink.streaming.api.windowing.evictors.CountEvictor
org.apache.flink.streaming.api.windowing.evictors.DeltaEvictor
org.apache.flink.streaming.api.windowing.evictors.Evictor
org.apache.flink.streaming.api.windowing.evictors.Evictor.EvictorContext
org.apache.flink.streaming.api.windowing.evictors.TimeEvictor
org.apache.flink.streaming.api.windowing.time.Time
org.apache.flink.streaming.api.windowing.triggers.ContinuousEventTimeTrigger
org.apache.flink.streaming.api.windowing.triggers.ContinuousProcessingTimeTrigger
org.apache.flink.streaming.api.windowing.triggers.CountTrigger
org.apache.flink.streaming.api.windowing.triggers.DeltaTrigger
org.apache.flink.streaming.api.windowing.triggers.EventTimeTrigger
org.apache.flink.streaming.api.windowing.triggers.ProcessingTimeTrigger
org.apache.flink.streaming.api.windowing.triggers.PurgingTrigger
org.apache.flink.streaming.api.windowing.triggers.Trigger
org.apache.flink.streaming.api.windowing.triggers.Trigger.OnMergeContext
org.apache.flink.streaming.api.windowing.triggers.Trigger.TriggerContext
org.apache.flink.streaming.api.windowing.triggers.TriggerResult
org.apache.flink.streaming.api.windowing.windows.GlobalWindow
org.apache.flink.streaming.api.windowing.windows.GlobalWindow.Serializer
org.apache.flink.streaming.api.windowing.windows.GlobalWindow.Serializer.GlobalWindowSerializerSnapshot
org.apache.flink.streaming.api.windowing.windows.TimeWindow
org.apache.flink.streaming.api.windowing.windows.TimeWindow.Serializer
org.apache.flink.streaming.api.windowing.windows.TimeWindow.Serializer.TimeWindowSerializerSnapshot
org.apache.flink.streaming.api.windowing.windows.Window
org.apache.flink.streaming.experimental.CollectSink
org.apache.flink.streaming.experimental.SocketStreamIterator
org.apache.flink.streaming.runtime.io.AbstractDataOutput
org.apache.flink.streaming.runtime.io.BlockingQueueBroker
org.apache.flink.streaming.runtime.io.BufferStorage
org.apache.flink.streaming.runtime.io.CachedBufferStorage
org.apache.flink.streaming.runtime.io.CheckpointBarrierAligner
org.apache.flink.streaming.runtime.io.CheckpointBarrierHandler
org.apache.flink.streaming.runtime.io.CheckpointBarrierTracker
org.apache.flink.streaming.runtime.io.CheckpointedInputGate
org.apache.flink.streaming.runtime.io.EmptyBufferStorage
org.apache.flink.streaming.runtime.io.InputGateUtil
org.apache.flink.streaming.runtime.io.InputProcessorUtil
org.apache.flink.streaming.runtime.io.InputStatus
org.apache.flink.streaming.runtime.io.LinkedBufferStorage
org.apache.flink.streaming.runtime.io.PushingAsyncDataInput
org.apache.flink.streaming.runtime.io.PushingAsyncDataInput.DataOutput
org.apache.flink.streaming.runtime.io.RecordWriterOutput
org.apache.flink.streaming.runtime.io.StreamInputProcessor
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor
org.apache.flink.streaming.runtime.io.StreamTaskInput
org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput
org.apache.flink.streaming.runtime.io.StreamTaskSourceInput
org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor
org.apache.flink.streaming.runtime.io.TwoInputSelectionHandler
org.apache.flink.streaming.runtime.metrics.MinWatermarkGauge
org.apache.flink.streaming.runtime.metrics.WatermarkGauge
org.apache.flink.streaming.runtime.operators.CheckpointCommitter
org.apache.flink.streaming.runtime.operators.ExtractTimestampsOperator
org.apache.flink.streaming.runtime.operators.GenericWriteAheadSink
org.apache.flink.streaming.runtime.operators.TimestampsAndPeriodicWatermarksOperator
org.apache.flink.streaming.runtime.operators.TimestampsAndPunctuatedWatermarksOperator
org.apache.flink.streaming.runtime.operators.windowing.EvictingWindowOperator
org.apache.flink.streaming.runtime.operators.windowing.KeyMap
org.apache.flink.streaming.runtime.operators.windowing.KeyMap.Entry
org.apache.flink.streaming.runtime.operators.windowing.KeyMap.LazyFactory
org.apache.flink.streaming.runtime.operators.windowing.KeyMap.TraversalEvaluator
org.apache.flink.streaming.runtime.operators.windowing.MergingWindowSet
org.apache.flink.streaming.runtime.operators.windowing.MergingWindowSet.MergeFunction
org.apache.flink.streaming.runtime.operators.windowing.TimestampedValue
org.apache.flink.streaming.runtime.operators.windowing.WindowOperator
org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.Timer
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalAggregateProcessAllWindowFunction
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalAggregateProcessWindowFunction
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableAllWindowFunction
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableProcessAllWindowFunction
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableProcessWindowFunction
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalIterableWindowFunction
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalProcessAllWindowContext
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalProcessWindowContext
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueAllWindowFunction
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueProcessAllWindowFunction
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueProcessWindowFunction
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalSingleValueWindowFunction
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalWindowFunction
org.apache.flink.streaming.runtime.operators.windowing.functions.InternalWindowFunction.InternalWindowContext
org.apache.flink.streaming.runtime.partitioner.BroadcastPartitioner
org.apache.flink.streaming.runtime.partitioner.ConfigurableStreamPartitioner
org.apache.flink.streaming.runtime.partitioner.CustomPartitionerWrapper
org.apache.flink.streaming.runtime.partitioner.ForwardPartitioner
org.apache.flink.streaming.runtime.partitioner.GlobalPartitioner
org.apache.flink.streaming.runtime.partitioner.KeyGroupStreamPartitioner
org.apache.flink.streaming.runtime.partitioner.RebalancePartitioner
org.apache.flink.streaming.runtime.partitioner.RescalePartitioner
org.apache.flink.streaming.runtime.partitioner.ShufflePartitioner
org.apache.flink.streaming.runtime.partitioner.StreamPartitioner
org.apache.flink.streaming.runtime.streamrecord.LatencyMarker
org.apache.flink.streaming.runtime.streamrecord.StreamElement
org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer
org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer.StreamElementSerializerConfigSnapshot
org.apache.flink.streaming.runtime.streamrecord.StreamElementSerializer.StreamElementSerializerSnapshot
org.apache.flink.streaming.runtime.streamrecord.StreamRecord
org.apache.flink.streaming.runtime.streamstatus.StatusWatermarkValve
org.apache.flink.streaming.runtime.streamstatus.StatusWatermarkValve.InputChannelStatus
org.apache.flink.streaming.runtime.streamstatus.StreamStatus
org.apache.flink.streaming.runtime.streamstatus.StreamStatusMaintainer
org.apache.flink.streaming.runtime.streamstatus.StreamStatusProvider
org.apache.flink.streaming.runtime.tasks.AbstractTwoInputStreamTask
org.apache.flink.streaming.runtime.tasks.AsyncExceptionHandler
org.apache.flink.streaming.runtime.tasks.AsynchronousException
org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException
org.apache.flink.streaming.runtime.tasks.OneInputStreamTask
org.apache.flink.streaming.runtime.tasks.OperatorChain
org.apache.flink.streaming.runtime.tasks.OperatorChain.WatermarkGaugeExposingOutput
org.apache.flink.streaming.runtime.tasks.ProcessingTimeCallback
org.apache.flink.streaming.runtime.tasks.ProcessingTimeService
org.apache.flink.streaming.runtime.tasks.SourceReaderStreamTask
org.apache.flink.streaming.runtime.tasks.SourceStreamTask
org.apache.flink.streaming.runtime.tasks.StreamIterationHead
org.apache.flink.streaming.runtime.tasks.StreamIterationTail
org.apache.flink.streaming.runtime.tasks.StreamTask
org.apache.flink.streaming.runtime.tasks.StreamTask.AsyncCheckpointRunnable
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor
org.apache.flink.streaming.runtime.tasks.StreamTaskException
org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService
org.apache.flink.streaming.runtime.tasks.TestProcessingTimeService
org.apache.flink.streaming.runtime.tasks.TimerException
org.apache.flink.streaming.runtime.tasks.TimerService
org.apache.flink.streaming.runtime.tasks.TwoInputStreamTask
org.apache.flink.streaming.runtime.tasks.mailbox.Mail
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxDefaultAction
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxDefaultAction.Controller
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxDefaultAction.Suspension
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorFactory
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox.State
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl
org.apache.flink.streaming.util.LatencyStats
org.apache.flink.streaming.util.LatencyStats.Granularity
org.apache.flink.streaming.util.functions.StreamingFunctionUtils
org.apache.flink.streaming.util.keys.KeySelectorUtil
org.apache.flink.streaming.util.keys.KeySelectorUtil.ArrayKeySelector
org.apache.flink.streaming.util.keys.KeySelectorUtil.ComparableKeySelector
org.apache.flink.streaming.util.keys.KeySelectorUtil.OneKeySelector
org.apache.flink.streaming.util.serialization.AbstractDeserializationSchema
org.apache.flink.streaming.util.serialization.DeserializationSchema
org.apache.flink.streaming.util.serialization.SerializationSchema
org.apache.flink.streaming.util.serialization.SimpleStringSchema
org.apache.flink.streaming.util.serialization.TypeInformationSerializationSchema
org.apache.flink.streaming.util.typeutils.FieldAccessor
org.apache.flink.streaming.util.typeutils.FieldAccessorFactory