Skip to content

Commit 996d67c

Browse files
committed
address review comments
1 parent 70f07dd commit 996d67c

File tree

4 files changed

+10
-86
lines changed

4 files changed

+10
-86
lines changed

presto-clp/src/main/java/com/facebook/presto/plugin/clp/ClpExpression.java

Lines changed: 0 additions & 70 deletions
This file was deleted.

presto-clp/src/main/java/com/facebook/presto/plugin/clp/ClpMetadata.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -120,14 +120,14 @@ public ConnectorTableHandle getTableHandle(ConnectorSession session, SchemaTable
120120
}
121121

122122
@Override
123-
public List<ConnectorTableLayoutResult> getTableLayouts(ConnectorSession session,
124-
ConnectorTableHandle table,
125-
Constraint<ColumnHandle> constraint,
126-
Optional<Set<ColumnHandle>> desiredColumns)
123+
public ConnectorTableLayoutResult getTableLayoutForConstraint(ConnectorSession session,
124+
ConnectorTableHandle table,
125+
Constraint<ColumnHandle> constraint,
126+
Optional<Set<ColumnHandle>> desiredColumns)
127127
{
128128
ClpTableHandle tableHandle = (ClpTableHandle) table;
129129
ConnectorTableLayout layout = new ConnectorTableLayout(new ClpTableLayoutHandle(tableHandle, Optional.empty()));
130-
return ImmutableList.of(new ConnectorTableLayoutResult(layout, constraint.getSummary()));
130+
return new ConnectorTableLayoutResult(layout, constraint.getSummary());
131131
}
132132

133133
@Override

presto-clp/src/test/java/com/facebook/presto/plugin/clp/ClpMetadataDbSetUp.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,6 +13,7 @@
1313
*/
1414
package com.facebook.presto.plugin.clp;
1515

16+
import com.facebook.airlift.log.Logger;
1617
import com.facebook.presto.plugin.clp.metadata.ClpMetadataProvider;
1718
import com.facebook.presto.plugin.clp.metadata.ClpMySqlMetadataProvider;
1819
import com.facebook.presto.plugin.clp.metadata.ClpNodeType;
@@ -32,6 +33,8 @@
3233

3334
public final class ClpMetadataDbSetUp
3435
{
36+
private static final Logger log = Logger.get(ClpMetadataDbSetUp.class);
37+
3538
public static final String metadataDbUrlTemplate =
3639
"jdbc:h2:file:/tmp/%s;MODE=MySQL;DATABASE_TO_UPPER=FALSE";
3740
public static final String metadataDbTablePrefix = "clp_";
@@ -138,7 +141,7 @@ public void tearDown(String dbName)
138141
File lockFile = new File(String.format("/tmp/%s.trace.db", dbName)); // Optional, H2 sometimes creates this
139142
if (dbFile.exists()) {
140143
dbFile.delete();
141-
System.out.println("Deleted database file: " + dbFile.getAbsolutePath());
144+
log.info("Deleted database file: " + dbFile.getAbsolutePath());
142145
}
143146
if (lockFile.exists()) {
144147
lockFile.delete();

presto-clp/src/test/java/com/facebook/presto/plugin/clp/TestClpSplit.java

Lines changed: 1 addition & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020
import org.testng.annotations.BeforeMethod;
2121
import org.testng.annotations.Test;
2222

23-
import java.io.File;
2423
import java.util.ArrayList;
2524
import java.util.HashMap;
2625
import java.util.List;
@@ -64,15 +63,7 @@ public void setUp()
6463
@AfterMethod
6564
public void tearDown()
6665
{
67-
File dbFile = new File("/tmp/split_testdb.mv.db");
68-
File lockFile = new File("/tmp/split_testdb.trace.db"); // Optional, H2 sometimes creates this
69-
if (dbFile.exists()) {
70-
dbFile.delete();
71-
System.out.println("Deleted database file: " + dbFile.getAbsolutePath());
72-
}
73-
if (lockFile.exists()) {
74-
lockFile.delete();
75-
}
66+
clpMetadataDbSetUp.tearDown(databaseName);
7667
}
7768

7869
@Test

0 commit comments

Comments
 (0)