Reorder PhoenixMergeSink constructor params

Follow the params order in the `JdbcPageSink`
trinodb · Sep 4, 2024 · 7a7fdc1 · 7a7fdc1
1 parent 8be6961
commit 7a7fdc1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/plugin/trino-phoenix5/src/main/java/io/trino/plugin/phoenix5/PhoenixMergeSink.java b/plugin/trino-phoenix5/src/main/java/io/trino/plugin/phoenix5/PhoenixMergeSink.java
@@ -60,11 +60,11 @@ public class PhoenixMergeSink
     private final ConnectorPageSink deleteSink;
 
     public PhoenixMergeSink(
-            PhoenixClient phoenixClient,
-            RemoteQueryModifier remoteQueryModifier,
             ConnectorSession session,
             ConnectorMergeTableHandle mergeHandle,
+            PhoenixClient phoenixClient,
             ConnectorPageSinkId pageSinkId,
+            RemoteQueryModifier remoteQueryModifier,
             QueryBuilder queryBuilder)
     {
         PhoenixMergeTableHandle phoenixMergeTableHandle = (PhoenixMergeTableHandle) mergeHandle;

diff --git a/plugin/trino-phoenix5/src/main/java/io/trino/plugin/phoenix5/PhoenixPageSinkProvider.java b/plugin/trino-phoenix5/src/main/java/io/trino/plugin/phoenix5/PhoenixPageSinkProvider.java
@@ -61,6 +61,6 @@ public ConnectorPageSink createPageSink(ConnectorTransactionHandle transactionHa
     @Override
     public ConnectorMergeSink createMergeSink(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorMergeTableHandle mergeHandle, ConnectorPageSinkId pageSinkId)
     {
-        return new PhoenixMergeSink(jdbcClient, remoteQueryModifier, session, mergeHandle, pageSinkId, queryBuilder);
+        return new PhoenixMergeSink(session, mergeHandle, jdbcClient, pageSinkId, remoteQueryModifier, queryBuilder);
     }
 }