installKafkaPlugin(EmbeddedKafka, QueryRunner, Map) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
loadTpchTopicDescription(JsonCodec, String, SchemaTableName) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
loadTpchTopic(EmbeddedKafka, TestingPrestoClient, String, QualifiedObjectName) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
toProperties(Map) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
createEmptyTopicDescription(String, SchemaTableName) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
findUnusedPort() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$installKafkaPlugin$3(FileKafkaClusterMetadataSupplierConfig, Binder) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$installKafkaPlugin$1(Map, Binder) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$installKafkaPlugin$2(KafkaConnectorConfig) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$installKafkaPlugin$0(KafkaConnectorConfig) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |