flink-streaming-java_2.12-1.14.3.jar中文-英文对照文档.zip

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

文件基础信息

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

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

文件大小: 5.71 MB

选择下载方式

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

文件价格：¥2

支付完成后自动开始下载

方式2：兑换码下载

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

文件简介

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

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

使用方法

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

组件信息

简介

名称： Flink : Streaming Java
描述： org.apache.flink - flink-streaming-java_2.12
版本： 1.14.3

Maven依赖

<dependency>
	<groupId>org.apache.flink</groupId>
	<artifactId>flink-streaming-java_2.12</artifactId>
	<version>1.14.3</version>
</dependency>

Gradle依赖

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

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

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

版权声明与来源信息

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

组件 GAV 坐标：org.apache.flink:flink-streaming-java_2.12:1.14.3
原始项目地址：https://central.sonatype.com/artifact/org.apache.flink/flink-streaming-java_2.12/1.14.3
许可证：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.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.source
org.apache.flink.streaming.api.functions.source.datagen
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.operators.collect
org.apache.flink.streaming.api.operators.sort
org.apache.flink.streaming.api.operators.sorted.state
org.apache.flink.streaming.api.operators.source
org.apache.flink.streaming.api.operators.util
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.io.checkpointing
org.apache.flink.streaming.runtime.io.recovery
org.apache.flink.streaming.runtime.metrics
org.apache.flink.streaming.runtime.operators
org.apache.flink.streaming.runtime.operators.sink
org.apache.flink.streaming.runtime.operators.util
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.tasks
org.apache.flink.streaming.runtime.tasks.bufferdebloat
org.apache.flink.streaming.runtime.tasks.mailbox
org.apache.flink.streaming.runtime.translators
org.apache.flink.streaming.runtime.watermarkstatus
org.apache.flink.streaming.util
org.apache.flink.streaming.util.functions
org.apache.flink.streaming.util.graph
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.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.UnionSerializer
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.MultipleConnectedStreams
org.apache.flink.streaming.api.datastream.QueryableStateStream
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
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.StreamExecutionEnvironment
org.apache.flink.streaming.api.environment.StreamExecutionEnvironmentFactory
org.apache.flink.streaming.api.environment.StreamPipelineOptions
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.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.BucketFactory
org.apache.flink.streaming.api.functions.sink.filesystem.BucketLifeCycleListener
org.apache.flink.streaming.api.functions.sink.filesystem.Buckets
org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactoryImpl
org.apache.flink.streaming.api.functions.sink.filesystem.FileLifeCycleListener
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BucketsBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.BulkFormatBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.DefaultBulkFormatBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.DefaultRowFormatBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.RowFormatBuilder
org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSinkHelper
org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction
org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator
org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperatorFactory
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.source.TimestampedInputSplit
org.apache.flink.streaming.api.functions.source.datagen.DataGenerator
org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource
org.apache.flink.streaming.api.functions.source.datagen.RandomGenerator
org.apache.flink.streaming.api.functions.source.datagen.SequenceGenerator
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.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.GlobalStreamExchangeMode
org.apache.flink.streaming.api.graph.JSONGenerator
org.apache.flink.streaming.api.graph.SimpleTransformationTranslator
org.apache.flink.streaming.api.graph.StreamConfig
org.apache.flink.streaming.api.graph.StreamConfig.InputConfig
org.apache.flink.streaming.api.graph.StreamConfig.InputRequirement
org.apache.flink.streaming.api.graph.StreamConfig.NetworkInputConfig
org.apache.flink.streaming.api.graph.StreamConfig.SourceInputConfig
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.StreamGraphUserHashHasher
org.apache.flink.streaming.api.graph.StreamNode
org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator
org.apache.flink.streaming.api.graph.TransformationTranslator
org.apache.flink.streaming.api.graph.TransformationTranslator.Context
org.apache.flink.streaming.api.operators.AbstractInput
org.apache.flink.streaming.api.operators.AbstractStreamOperator
org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory
org.apache.flink.streaming.api.operators.AbstractStreamOperatorV2
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator
org.apache.flink.streaming.api.operators.BackendRestorerProcedure
org.apache.flink.streaming.api.operators.BatchGroupedReduceOperator
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.CoordinatedOperatorFactory
org.apache.flink.streaming.api.operators.CountingOutput
org.apache.flink.streaming.api.operators.Input
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.InternalTimeServiceManager.Provider
org.apache.flink.streaming.api.operators.InternalTimeServiceManagerImpl
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.MultipleInputStreamOperator
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.SourceOperator
org.apache.flink.streaming.api.operators.SourceOperatorFactory
org.apache.flink.streaming.api.operators.StreamFilter
org.apache.flink.streaming.api.operators.StreamFlatMap
org.apache.flink.streaming.api.operators.StreamGroupedReduceOperator
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.StreamOperatorParameters
org.apache.flink.streaming.api.operators.StreamOperatorStateContext
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.CheckpointedStreamOperator
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.BatchCoBroadcastWithKeyedOperator
org.apache.flink.streaming.api.operators.co.BatchCoBroadcastWithNonKeyedOperator
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.BufferEntry
org.apache.flink.streaming.api.operators.co.IntervalJoinOperator.BufferEntrySerializer
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.operators.collect.AbstractCollectResultBuffer
org.apache.flink.streaming.api.operators.collect.CheckpointedCollectResultBuffer
org.apache.flink.streaming.api.operators.collect.ClientAndIterator
org.apache.flink.streaming.api.operators.collect.CollectCoordinationRequest
org.apache.flink.streaming.api.operators.collect.CollectCoordinationResponse
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher
org.apache.flink.streaming.api.operators.collect.CollectResultIterator
org.apache.flink.streaming.api.operators.collect.CollectSinkAddressEvent
org.apache.flink.streaming.api.operators.collect.CollectSinkFunction
org.apache.flink.streaming.api.operators.collect.CollectSinkOperator
org.apache.flink.streaming.api.operators.collect.CollectSinkOperatorCoordinator
org.apache.flink.streaming.api.operators.collect.CollectSinkOperatorCoordinator.Provider
org.apache.flink.streaming.api.operators.collect.CollectSinkOperatorFactory
org.apache.flink.streaming.api.operators.collect.CollectStreamSink
org.apache.flink.streaming.api.operators.collect.UncheckpointedCollectResultBuffer
org.apache.flink.streaming.api.operators.sort.MultiInputSortingDataInput
org.apache.flink.streaming.api.operators.sort.MultiInputSortingDataInput.SelectableSortingInputs
org.apache.flink.streaming.api.operators.sort.SortingDataInput
org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionCheckpointStorage
org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionInternalTimeService
org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionInternalTimeServiceManager
org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionKeyedStateBackend
org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionStateBackend
org.apache.flink.streaming.api.operators.source.NoOpTimestampsAndWatermarks
org.apache.flink.streaming.api.operators.source.ProgressiveTimestampsAndWatermarks
org.apache.flink.streaming.api.operators.source.SourceOutputWithWatermarks
org.apache.flink.streaming.api.operators.source.TimestampsAndWatermarks
org.apache.flink.streaming.api.operators.source.TimestampsAndWatermarksContext
org.apache.flink.streaming.api.operators.source.WatermarkToDataOutput
org.apache.flink.streaming.api.operators.util.SimpleVersionedListState
org.apache.flink.streaming.api.transformations.AbstractBroadcastStateTransformation
org.apache.flink.streaming.api.transformations.AbstractMultipleInputTransformation
org.apache.flink.streaming.api.transformations.BroadcastStateTransformation
org.apache.flink.streaming.api.transformations.CoFeedbackTransformation
org.apache.flink.streaming.api.transformations.FeedbackTransformation
org.apache.flink.streaming.api.transformations.KeyedBroadcastStateTransformation
org.apache.flink.streaming.api.transformations.KeyedMultipleInputTransformation
org.apache.flink.streaming.api.transformations.LegacySinkTransformation
org.apache.flink.streaming.api.transformations.LegacySourceTransformation
org.apache.flink.streaming.api.transformations.MultipleInputTransformation
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.ReduceTransformation
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.StreamExchangeMode
org.apache.flink.streaming.api.transformations.TimestampsAndWatermarksTransformation
org.apache.flink.streaming.api.transformations.TwoInputTransformation
org.apache.flink.streaming.api.transformations.UnionTransformation
org.apache.flink.streaming.api.transformations.WithBoundedness
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.assigners.WindowStagger
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.ProcessingTimeoutTrigger
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.AbstractStreamTaskNetworkInput
org.apache.flink.streaming.runtime.io.BlockingQueueBroker
org.apache.flink.streaming.runtime.io.DataInputStatus
org.apache.flink.streaming.runtime.io.FinishedDataOutput
org.apache.flink.streaming.runtime.io.InputGateUtil
org.apache.flink.streaming.runtime.io.MultipleInputSelectionHandler
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.RecoverableStreamTaskInput
org.apache.flink.streaming.runtime.io.StreamInputProcessor
org.apache.flink.streaming.runtime.io.StreamMultipleInputProcessor
org.apache.flink.streaming.runtime.io.StreamMultipleInputProcessorFactory
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor
org.apache.flink.streaming.runtime.io.StreamTaskExternallyInducedSourceInput
org.apache.flink.streaming.runtime.io.StreamTaskInput
org.apache.flink.streaming.runtime.io.StreamTaskNetworkInput
org.apache.flink.streaming.runtime.io.StreamTaskNetworkInputFactory
org.apache.flink.streaming.runtime.io.StreamTaskSourceInput
org.apache.flink.streaming.runtime.io.StreamTwoInputProcessorFactory
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierHandler
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierTracker
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointedInputGate
org.apache.flink.streaming.runtime.io.checkpointing.InputProcessorUtil
org.apache.flink.streaming.runtime.io.checkpointing.SingleCheckpointBarrierHandler
org.apache.flink.streaming.runtime.io.checkpointing.UpstreamRecoveryTracker
org.apache.flink.streaming.runtime.io.recovery.RescalingStreamTaskNetworkInput
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.GenericWriteAheadSink
org.apache.flink.streaming.runtime.operators.TimestampsAndWatermarksOperator
org.apache.flink.streaming.runtime.operators.TimestampsAndWatermarksOperator.WatermarkEmitter
org.apache.flink.streaming.runtime.operators.sink.CommitterOperatorFactory
org.apache.flink.streaming.runtime.operators.sink.GlobalStreamingCommitterHandler
org.apache.flink.streaming.runtime.operators.sink.SinkOperatorFactory
org.apache.flink.streaming.runtime.operators.util.AssignerWithPeriodicWatermarksAdapter
org.apache.flink.streaming.runtime.operators.util.AssignerWithPeriodicWatermarksAdapter.Strategy
org.apache.flink.streaming.runtime.operators.util.AssignerWithPunctuatedWatermarksAdapter
org.apache.flink.streaming.runtime.operators.util.AssignerWithPunctuatedWatermarksAdapter.Strategy
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.WindowOperatorBuilder
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.tasks.AbstractTwoInputStreamTask
org.apache.flink.streaming.runtime.tasks.AsyncExceptionHandler
org.apache.flink.streaming.runtime.tasks.AsynchronousException
org.apache.flink.streaming.runtime.tasks.ContainingTaskDetails
org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException
org.apache.flink.streaming.runtime.tasks.FinishedOnRestoreInput
org.apache.flink.streaming.runtime.tasks.FinishedOnRestoreMainOperatorOutput
org.apache.flink.streaming.runtime.tasks.FinishedOperatorChain
org.apache.flink.streaming.runtime.tasks.MultipleInputStreamTask
org.apache.flink.streaming.runtime.tasks.OneInputStreamTask
org.apache.flink.streaming.runtime.tasks.OperatorChain
org.apache.flink.streaming.runtime.tasks.OperatorChain.ChainedSource
org.apache.flink.streaming.runtime.tasks.OperatorEventDispatcherImpl
org.apache.flink.streaming.runtime.tasks.ProcessingTimeCallback
org.apache.flink.streaming.runtime.tasks.ProcessingTimeService
org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceAware
org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceFactory
org.apache.flink.streaming.runtime.tasks.ProcessingTimeServiceUtil
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain
org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask
org.apache.flink.streaming.runtime.tasks.SourceOperatorStreamTask.AsyncDataOutputToOutput
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.StreamOperatorWrapper
org.apache.flink.streaming.runtime.tasks.StreamTask
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.StreamTaskFinishedOnRestoreSourceInput
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinator
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.WatermarkGaugeExposingOutput
org.apache.flink.streaming.runtime.tasks.bufferdebloat.BufferDebloater
org.apache.flink.streaming.runtime.tasks.mailbox.GaugePeriodTimer
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.MailboxProcessor.MailboxController
org.apache.flink.streaming.runtime.tasks.mailbox.PeriodTimer
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox.MailboxClosedException
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailbox.State
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl
org.apache.flink.streaming.runtime.translators.AbstractTwoInputTransformationTranslator
org.apache.flink.streaming.runtime.translators.BroadcastStateTransformationTranslator
org.apache.flink.streaming.runtime.translators.KeyedBroadcastStateTransformationTranslator
org.apache.flink.streaming.runtime.translators.LegacySinkTransformationTranslator
org.apache.flink.streaming.runtime.translators.LegacySourceTransformationTranslator
org.apache.flink.streaming.runtime.translators.MultiInputTransformationTranslator
org.apache.flink.streaming.runtime.translators.OneInputTransformationTranslator
org.apache.flink.streaming.runtime.translators.PartitionTransformationTranslator
org.apache.flink.streaming.runtime.translators.ReduceTransformationTranslator
org.apache.flink.streaming.runtime.translators.SideOutputTransformationTranslator
org.apache.flink.streaming.runtime.translators.SinkTransformationTranslator
org.apache.flink.streaming.runtime.translators.SourceTransformationTranslator
org.apache.flink.streaming.runtime.translators.TimestampsAndWatermarksTransformationTranslator
org.apache.flink.streaming.runtime.translators.TwoInputTransformationTranslator
org.apache.flink.streaming.runtime.translators.UnionTransformationTranslator
org.apache.flink.streaming.runtime.watermarkstatus.StatusWatermarkValve
org.apache.flink.streaming.runtime.watermarkstatus.StatusWatermarkValve.InputChannelStatus
org.apache.flink.streaming.runtime.watermarkstatus.WatermarkStatus
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.graph.StreamGraphUtils
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