Skip to content

Commit

Permalink
Remove unnecessary conversion methods
Browse files Browse the repository at this point in the history
  • Loading branch information
elharo authored and tdcmeehan committed May 29, 2024
1 parent 88e5c77 commit 88bc1c3
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -178,7 +178,7 @@ private PlanNode addSamplingFilter(PlanNode tableScanNode, Optional<VariableRefe
tableName = ((TableScanNode) tableScanNode).getTable().getConnectorHandle().toString();
}
else {
tableName = "plan node: " + String.valueOf(tableScanNode.getId());
tableName = "plan node: " + tableScanNode.getId();
}

sampledFields.add(String.format("%s from %s", rowExpression, tableName));
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -279,9 +279,9 @@ private ScanParams setScanParams()
if (redisJedisManager.getRedisConnectorConfig().isKeyPrefixSchemaTable()) {
String keyMatch = "";
if (!split.getSchemaName().equals("default")) {
keyMatch = split.getSchemaName() + Character.toString(redisJedisManager.getRedisConnectorConfig().getRedisKeyDelimiter());
keyMatch = split.getSchemaName() + redisJedisManager.getRedisConnectorConfig().getRedisKeyDelimiter();
}
keyMatch = keyMatch + split.getTableName() + Character.toString(redisJedisManager.getRedisConnectorConfig().getRedisKeyDelimiter()) + "*";
keyMatch = keyMatch + split.getTableName() + redisJedisManager.getRedisConnectorConfig().getRedisKeyDelimiter() + "*";
scanParams.match(keyMatch);
}
return scanParams;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ protected Type _deserialize(String value, DeserializationContext context)
{
Type type = metadata.getType(parseTypeSignature(value));
if (type == null) {
throw new IllegalArgumentException(String.valueOf("Unknown type " + value));
throw new IllegalArgumentException("Unknown type " + value);
}
return type;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -811,7 +811,7 @@ private void enableTestFunctionNamespaces(List<String> catalogNames, Map<String,
{
checkState(testFunctionNamespacesHandle.get() == null, "Test function namespaces already enabled");

String databaseName = String.valueOf(nanoTime()) + "_" + ThreadLocalRandom.current().nextInt();
String databaseName = nanoTime() + "_" + ThreadLocalRandom.current().nextInt();
Map<String, String> properties = ImmutableMap.<String, String>builder()
.put("database-name", databaseName)
.putAll(additionalProperties)
Expand Down

0 comments on commit 88bc1c3

Please sign in to comment.