Skip to content

Commit

Permalink
Replace toList with toUnmodifiableList() collector
Browse files Browse the repository at this point in the history
SPI cannot use Guava's toImmutableList
  • Loading branch information
skrzypo987 authored and hashhar committed Jul 7, 2021
1 parent 70e849c commit c7adc54
Show file tree
Hide file tree
Showing 5 changed files with 11 additions and 14 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -45,7 +45,7 @@
import static java.lang.String.format;
import static java.util.Collections.emptyList;
import static java.util.Collections.emptyMap;
import static java.util.stream.Collectors.toList;
import static java.util.stream.Collectors.toUnmodifiableList;

public interface ConnectorMetadata
{
Expand Down Expand Up @@ -393,7 +393,7 @@ default Optional<ConnectorNewTableLayout> getInsertLayout(ConnectorSession sessi
.collect(Collectors.toMap(Map.Entry::getValue, Map.Entry::getKey));
List<String> partitionColumns = partitioning.getPartitioningColumns().stream()
.map(columnNamesByHandle::get)
.collect(toList());
.collect(toUnmodifiableList());

return new ConnectorNewTableLayout(partitioning.getPartitioningHandle(), partitionColumns);
});
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,12 +40,10 @@
import static io.trino.spi.predicate.Utils.TUPLE_DOMAIN_TYPE_OPERATORS;
import static io.trino.spi.predicate.Utils.handleThrowable;
import static java.lang.String.format;
import static java.util.Collections.unmodifiableCollection;
import static java.util.Collections.unmodifiableSet;
import static java.util.Objects.requireNonNull;
import static java.util.stream.Collectors.joining;
import static java.util.stream.Collectors.toCollection;
import static java.util.stream.Collectors.toList;
import static java.util.stream.Collectors.toUnmodifiableList;

/**
Expand Down Expand Up @@ -128,9 +126,9 @@ public Set<ValueEntry> getEntries()

public Collection<Object> getValues()
{
return unmodifiableCollection(entries.stream()
return entries.stream()
.map(ValueEntry::getValue)
.collect(toList()));
.collect(toUnmodifiableList());
}

public int getValuesCount()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -40,8 +40,8 @@
import static java.util.Collections.emptyMap;
import static java.util.Collections.unmodifiableList;
import static java.util.Objects.requireNonNull;
import static java.util.stream.Collectors.toList;
import static java.util.stream.Collectors.toMap;
import static java.util.stream.Collectors.toUnmodifiableList;

/**
* Defines a set of valid tuples according to the constraints on each of its constituent columns
Expand Down Expand Up @@ -184,7 +184,7 @@ public Optional<List<ColumnDomain<T>>> getColumnDomains()
{
return domains.map(map -> map.entrySet().stream()
.map(entry -> new ColumnDomain<>(entry.getKey(), entry.getValue()))
.collect(toList()));
.collect(toUnmodifiableList()));
}

private static <T> boolean containsNoneDomain(Map<T, Domain> domains)
Expand Down
7 changes: 3 additions & 4 deletions core/trino-spi/src/main/java/io/trino/spi/type/RowType.java
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@
import java.util.List;
import java.util.Optional;
import java.util.function.Function;
import java.util.stream.Collectors;

import static io.trino.spi.function.InvocationConvention.InvocationArgumentConvention.BLOCK_POSITION;
import static io.trino.spi.function.InvocationConvention.InvocationArgumentConvention.BOXED_NULLABLE;
Expand Down Expand Up @@ -116,7 +115,7 @@ private RowType(TypeSignature typeSignature, List<Field> fields)
this.fields = fields;
this.fieldTypes = fields.stream()
.map(Field::getType)
.collect(Collectors.toList());
.collect(toUnmodifiableList());

this.comparable = fields.stream().allMatch(field -> field.getType().isComparable());
this.orderable = fields.stream().allMatch(field -> field.getType().isOrderable());
Expand All @@ -131,7 +130,7 @@ public static RowType anonymous(List<Type> types)
{
List<Field> fields = types.stream()
.map(type -> new Field(Optional.empty(), type))
.collect(Collectors.toList());
.collect(toUnmodifiableList());

return new RowType(makeSignature(fields), fields);
}
Expand Down Expand Up @@ -172,7 +171,7 @@ private static TypeSignature makeSignature(List<Field> fields)
List<TypeSignatureParameter> parameters = fields.stream()
.map(field -> new NamedTypeSignature(field.getName().map(RowFieldName::new), field.getType().getTypeSignature()))
.map(TypeSignatureParameter::namedTypeParameter)
.collect(Collectors.toList());
.collect(toUnmodifiableList());

return new TypeSignature(ROW, parameters);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -22,12 +22,12 @@
import java.util.List;
import java.util.Locale;
import java.util.Objects;
import java.util.stream.Collectors;

import static io.trino.spi.type.StandardTypes.TIME_WITH_TIME_ZONE;
import static io.trino.spi.type.TypeSignatureParameter.typeParameter;
import static java.lang.String.format;
import static java.util.Arrays.asList;
import static java.util.stream.Collectors.toUnmodifiableList;

@Immutable
public final class TypeSignature
Expand Down Expand Up @@ -200,7 +200,7 @@ public static TypeSignature parametricType(String name, TypeSignature... paramet
name,
Arrays.asList(parameters).stream()
.map(TypeSignatureParameter::typeParameter)
.collect(Collectors.toList()));
.collect(toUnmodifiableList()));
}

public static TypeSignature functionType(TypeSignature first, TypeSignature... rest)
Expand Down

0 comments on commit c7adc54

Please sign in to comment.