|
Change Parameter Type connectorId : String to connectorId : KafkaConnectorId in method public KafkaSplitManager(connectorId KafkaConnectorId, kafkaConnectorConfig KafkaConnectorConfig, handleResolver KafkaHandleResolver, consumerManager KafkaSimpleConsumerManager) in class com.facebook.presto.kafka.KafkaSplitManager |
From |
To |
|
Change Parameter Type connectorId : String to connectorId : KafkaConnectorId in method public KafkaSimpleConsumerManager(connectorId KafkaConnectorId, kafkaConnectorConfig KafkaConnectorConfig, nodeManager NodeManager) in class com.facebook.presto.kafka.KafkaSimpleConsumerManager |
From |
To |
|
Change Parameter Type connectorId : String to connectorId : KafkaConnectorId in method public KafkaMetadata(connectorId KafkaConnectorId, kafkaConnectorConfig KafkaConnectorConfig, handleResolver KafkaHandleResolver, kafkaTableDescriptionSupplier Supplier<Map<SchemaTableName,KafkaTopicDescription>>, internalFieldDescriptions Set<KafkaInternalFieldDescription>) in class com.facebook.presto.kafka.KafkaMetadata |
From |
To |