序列化表格

程序包 org.apache.seatunnel.translation.flink.metric

类org.apache.seatunnel.translation.flink.metric.FlinkCounter扩展Object实现可序列化

序列化字段

longCounter

org.apache.flink.api.common.accumulators.LongCounter longCounter

name

String name

类org.apache.seatunnel.translation.flink.metric.FlinkMeter扩展Object实现可序列化

序列化字段

meter

org.apache.flink.metrics.Meter meter

name

String name

程序包 org.apache.seatunnel.translation.flink.sink

类org.apache.seatunnel.translation.flink.sink.FlinkSink扩展Object实现可序列化

序列化字段

catalogTable

org.apache.seatunnel.api.table.catalog.CatalogTable catalogTable

sink

org.apache.seatunnel.api.sink.SeaTunnelSink<org.apache.seatunnel.api.table.type.SeaTunnelRow,WriterStateT,CommT,GlobalCommT> sink

类org.apache.seatunnel.translation.flink.sink.FlinkSinkWriterContext扩展Object实现可序列化

序列化字段

eventListener

org.apache.seatunnel.api.event.EventListener eventListener

writerContext

org.apache.flink.api.connector.sink.Sink.InitContext writerContext

类org.apache.seatunnel.translation.flink.sink.FlinkWriterState扩展Object实现可序列化

序列化字段

checkpointId

long checkpointId

state

StateT state

程序包 org.apache.seatunnel.translation.flink.source

类org.apache.seatunnel.translation.flink.source.FlinkSource扩展Object实现可序列化

序列化字段

envConfig

org.apache.seatunnel.shade.com.typesafe.config.Config envConfig

source

org.apache.seatunnel.api.source.SeaTunnelSource<org.apache.seatunnel.api.table.type.SeaTunnelRow,SplitT extends org.apache.seatunnel.api.source.SourceSplit,EnumStateT extends Serializable> source

类org.apache.seatunnel.translation.flink.source.NoMoreElementEvent扩展Object实现可序列化

序列化字段

subTaskIndex

int subTaskIndex

类org.apache.seatunnel.translation.flink.source.SourceEventWrapper扩展Object实现可序列化

序列化字段

sourceEvent

org.apache.seatunnel.api.source.SourceEvent sourceEvent