|
23 | 23 | import java.util.Map; |
24 | 24 | import java.util.Set; |
25 | 25 | import javax.annotation.Nullable; |
26 | | - |
27 | 26 | import org.apache.iceberg.*; |
28 | 27 | import org.apache.iceberg.catalog.Namespace; |
29 | 28 | import org.apache.iceberg.catalog.TableIdentifier; |
@@ -100,27 +99,26 @@ public static void run(RESTCatalog catalog, String target, boolean json, Option. |
100 | 99 | } |
101 | 100 |
|
102 | 101 | private static Table.Data gatherTableData( |
103 | | - RESTCatalog catalog, |
104 | | - TableIdentifier tableId, |
105 | | - Set<Describe.Option> optionsSet) throws IOException { |
| 102 | + RESTCatalog catalog, TableIdentifier tableId, Set<Describe.Option> optionsSet) |
| 103 | + throws IOException { |
106 | 104 |
|
107 | 105 | org.apache.iceberg.Table table = catalog.loadTable(tableId); |
108 | 106 | Snapshot snapshot = table.currentSnapshot(); |
109 | 107 | Table.Snapshot snapshotInfo = null; |
110 | 108 | if (snapshot != null) { |
111 | 109 | snapshotInfo = |
112 | | - new Table.Snapshot( |
113 | | - snapshot.sequenceNumber(), |
114 | | - snapshot.snapshotId(), |
115 | | - snapshot.parentId(), |
116 | | - snapshot.timestampMillis(), |
117 | | - Instant.ofEpochMilli(snapshot.timestampMillis()).toString(), |
118 | | - Instant.ofEpochMilli(snapshot.timestampMillis()) |
119 | | - .atZone(ZoneId.systemDefault()) |
120 | | - .format(DateTimeFormatter.ISO_OFFSET_DATE_TIME), |
121 | | - snapshot.operation(), |
122 | | - snapshot.summary(), |
123 | | - snapshot.manifestListLocation()); |
| 110 | + new Table.Snapshot( |
| 111 | + snapshot.sequenceNumber(), |
| 112 | + snapshot.snapshotId(), |
| 113 | + snapshot.parentId(), |
| 114 | + snapshot.timestampMillis(), |
| 115 | + Instant.ofEpochMilli(snapshot.timestampMillis()).toString(), |
| 116 | + Instant.ofEpochMilli(snapshot.timestampMillis()) |
| 117 | + .atZone(ZoneId.systemDefault()) |
| 118 | + .format(DateTimeFormatter.ISO_OFFSET_DATE_TIME), |
| 119 | + snapshot.operation(), |
| 120 | + snapshot.summary(), |
| 121 | + snapshot.manifestListLocation()); |
124 | 122 | } |
125 | 123 |
|
126 | 124 | List<Table.Metrics> metrics = null; |
|
0 commit comments