| return Objects.hash(schema,topic,properties,returnType,proctimeAttribute,rowtimeAttributeDescriptors,startupMode,specificStartupOffsets); | return Objects.hash(schema,proctimeAttribute,rowtimeAttributeDescriptors,fieldMapping,topic,properties,deserializationSchema,startupMode,specificStartupOffsets); | Objects.hash(schema,topic,properties,returnType,proctimeAttribute,rowtimeAttributeDescriptors,startupMode,specificStartupOffsets) | Objects.hash(schema,proctimeAttribute,rowtimeAttributeDescriptors,fieldMapping,topic,properties,deserializationSchema,startupMode,specificStartupOffsets) | flink | ee40335ffa40fb32a692fa6be70946d9a70301b2 | org.apache.flink.streaming.connectors.kafka.KafkaTableSource | | | _1 | proctimeAttribute |
|---|
| _2 | proctimeAttribute |
|---|
| | v6 | topic |
|---|
| TCIVar | proctimeAttribute |
|---|
| v0 | startupMode |
|---|
| v1 | specificStartupOffsets |
|---|
| v3 | rowtimeAttributeDescriptors |
|---|
| v4 | properties |
|---|
| v5 | schema |
|---|
| | | v6 | topic |
|---|
| TCIVar | proctimeAttribute |
|---|
| v0 | startupMode |
|---|
| v1 | specificStartupOffsets |
|---|
| v3 | rowtimeAttributeDescriptors |
|---|
| v4 | properties |
|---|
| v5 | schema |
|---|
| Uses | False |