Skip to content

Commit 0d136f9

Browse files
committed
Move RewriteDataFilesProcedure to procedure package
And fix the error message thrown when target table does not exist
1 parent e823b20 commit 0d136f9

File tree

2 files changed

+10
-2
lines changed

2 files changed

+10
-2
lines changed

presto-iceberg/src/main/java/com/facebook/presto/iceberg/IcebergCommonModule.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,7 @@
4848
import com.facebook.presto.iceberg.procedure.ManifestFileCacheInvalidationProcedure;
4949
import com.facebook.presto.iceberg.procedure.RegisterTableProcedure;
5050
import com.facebook.presto.iceberg.procedure.RemoveOrphanFiles;
51+
import com.facebook.presto.iceberg.procedure.RewriteDataFilesProcedure;
5152
import com.facebook.presto.iceberg.procedure.RollbackToSnapshotProcedure;
5253
import com.facebook.presto.iceberg.procedure.RollbackToTimestampProcedure;
5354
import com.facebook.presto.iceberg.procedure.SetCurrentSnapshotProcedure;

presto-iceberg/src/main/java/com/facebook/presto/iceberg/RewriteDataFilesProcedure.java renamed to presto-iceberg/src/main/java/com/facebook/presto/iceberg/procedure/RewriteDataFilesProcedure.java

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,11 +11,18 @@
1111
* See the License for the specific language governing permissions and
1212
* limitations under the License.
1313
*/
14-
package com.facebook.presto.iceberg;
14+
package com.facebook.presto.iceberg.procedure;
1515

1616
import com.facebook.airlift.json.JsonCodec;
1717
import com.facebook.presto.common.predicate.TupleDomain;
1818
import com.facebook.presto.common.type.TypeManager;
19+
import com.facebook.presto.iceberg.CommitTaskData;
20+
import com.facebook.presto.iceberg.IcebergColumnHandle;
21+
import com.facebook.presto.iceberg.IcebergDistributedProcedureHandle;
22+
import com.facebook.presto.iceberg.IcebergProcedureContext;
23+
import com.facebook.presto.iceberg.IcebergTableHandle;
24+
import com.facebook.presto.iceberg.IcebergTableLayoutHandle;
25+
import com.facebook.presto.iceberg.PartitionData;
1926
import com.facebook.presto.spi.ConnectorDistributedProcedureHandle;
2027
import com.facebook.presto.spi.ConnectorSession;
2128
import com.facebook.presto.spi.classloader.ThreadContextClassLoader;
@@ -90,7 +97,7 @@ public DistributedProcedure get()
9097
private ConnectorDistributedProcedureHandle beginCallDistributedProcedure(ConnectorSession session, IcebergProcedureContext procedureContext, IcebergTableLayoutHandle layoutHandle, Object[] arguments)
9198
{
9299
try (ThreadContextClassLoader ignored = new ThreadContextClassLoader(getClass().getClassLoader())) {
93-
Table icebergTable = procedureContext.getTable().orElseThrow(() -> new VerifyException("No partition data for partitioned table"));
100+
Table icebergTable = procedureContext.getTable().orElseThrow(() -> new VerifyException("Target table does not exist"));
94101
IcebergTableHandle tableHandle = layoutHandle.getTable();
95102

96103
TupleDomain<IcebergColumnHandle> predicate = layoutHandle.getValidPredicate();

0 commit comments

Comments
 (0)