Expose connector property for TPCH partitioning
@@ -85,7 +85,7 @@ public class TpchConnectorFactory
@Override
public ConnectorMetadata getMetadata(ConnectorTransactionHandle transaction)
{
- return new TpchMetadata(catalogName, columnNaming, predicatePushdownEnabled, partitioningEnabled);
+ return new TpchMetadata(catalogName, columnNaming, predicatePushdownEnabled, isPartitioningEnabled(properties));
}
@Override
@@ -117,4 +117,9 @@ public class TpchConnectorFactory
throw new IllegalArgumentException("Invalid property tpch.splits-per-node");
}
}
+
+ private boolean isPartitioningEnabled(Map<String, String> properties)
+ {
+ return Boolean.parseBoolean(properties.getOrDefault("tpch.partitioning-enabled", String.valueOf(partitioningEnabled)));
+ }
}
