Remove unused fields and methods from BackgroundHiveSplitLoader
@@ -258,7 +258,6 @@ public class BackgroundHiveSplitLoader
splittable,
session,
OptionalInt.empty(),
- files.getEffectivePredicate(),
files.getColumnCoercions(),
getPathDomain(files.getEffectivePredicate()));
if (!internalHiveSplit.isPresent()) {
@@ -350,7 +349,6 @@ public class BackgroundHiveSplitLoader
splittable,
session,
OptionalInt.of(bucketNumber),
- effectivePredicate,
partition.getColumnCoercions(),
pathDomain);
internalHiveSplit.ifPresent(splitList::add);
@@ -382,7 +380,6 @@ public class BackgroundHiveSplitLoader
splittable,
session,
OptionalInt.of(bucketIndex),
- iterator.getEffectivePredicate(),
partition.getColumnCoercions(),
pathDomain);
internalHiveSplit.ifPresent(splitList::add);
@@ -422,7 +419,6 @@ public class BackgroundHiveSplitLoader
false,
session,
OptionalInt.empty(),
- effectivePredicate,
columnCoercions,
pathDomain);
if (internalHiveSplit.isPresent()) {
@@ -497,7 +493,6 @@ public class BackgroundHiveSplitLoader
boolean splittable,
ConnectorSession session,
OptionalInt bucketNumber,
- TupleDomain<HiveColumnHandle> effectivePredicate,
Map<Integer, HiveTypeName> columnCoercions,
Optional<Domain> pathDomain)
throws IOException
@@ -553,14 +548,6 @@ public class BackgroundHiveSplitLoader
checkArgument(start + length == blocks.get(blocks.size() - 1).getEnd());
}
- private static boolean overlaps(long xStart, long xLength, long yStart, long yLength)
- {
- if (xLength == 0 || yLength == 0) {
- return false;
- }
- return xStart + xLength > yStart && xStart < yStart + yLength;
- }
-
private static boolean allBlocksHaveRealAddress(List<InternalHiveBlock> blocks)
{
return blocks.stream()
@@ -588,15 +575,6 @@ public class BackgroundHiveSplitLoader
.collect(toImmutableList());
}
- private static List<HostAddress> toHostAddress(String[] hosts)
- {
- ImmutableList.Builder<HostAddress> builder = ImmutableList.builder();
- for (String host : hosts) {
- builder.add(HostAddress.fromString(host));
- }
- return builder.build();
- }
-
private static List<HivePartitionKey> getPartitionKeys(Table table, Optional<Partition> partition)
{
if (!partition.isPresent()) {
