Skip to content
Merged

Fix typo #12239

Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -189,14 +189,14 @@ public Map<String, Catalog> getCatalogs(TransactionId transactionId)
@Override
public Optional<CatalogName> getCatalogName(TransactionId transactionId, String catalogName)
{
return getTransactionMetadata(transactionId).getCalogName(catalogName);
return getTransactionMetadata(transactionId).getCatalogName(catalogName);
}

@Override
public Optional<CatalogMetadata> getOptionalCatalogMetadata(TransactionId transactionId, String catalogName)
{
TransactionMetadata transactionMetadata = getTransactionMetadata(transactionId);
return transactionMetadata.getCalogName(catalogName)
return transactionMetadata.getCatalogName(catalogName)
.map(transactionMetadata::getTransactionCatalogMetadata);
}

Expand All @@ -220,7 +220,7 @@ public CatalogMetadata getCatalogMetadataForWrite(TransactionId transactionId, S
TransactionMetadata transactionMetadata = getTransactionMetadata(transactionId);

// there is no need to ask for a connector specific id since the overlay connectors are read only
CatalogName catalog = transactionMetadata.getCalogName(catalogName)
CatalogName catalog = transactionMetadata.getCatalogName(catalogName)
.orElseThrow(() -> new TrinoException(NOT_FOUND, "Catalog does not exist: " + catalogName));

return getCatalogMetadataForWrite(transactionId, catalog);
Expand Down Expand Up @@ -389,7 +389,7 @@ private synchronized Map<String, Catalog> getCatalogs()
return ImmutableMap.copyOf(catalogs);
}

private synchronized Optional<CatalogName> getCalogName(String catalogName)
private synchronized Optional<CatalogName> getCatalogName(String catalogName)
{
Optional<Catalog> catalog = catalogByName.get(catalogName);
if (catalog == null) {
Expand Down