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 |