@@ -58,6 +58,7 @@ public String keyPrefix() {
5858 }
5959
6060 static class MyScanBuilder extends JavaSimpleScanBuilder {
61+
6162 private final String path ;
6263 private final Configuration conf ;
6364
@@ -96,6 +97,7 @@ public PartitionReaderFactory createReaderFactory() {
9697 }
9798
9899 static class MyWriteBuilder implements WriteBuilder , SupportsTruncate {
100+
99101 private final String path ;
100102 private final String queryId ;
101103 private boolean needTruncate = false ;
@@ -118,6 +120,7 @@ public Write build() {
118120 }
119121
120122 static class MyWrite implements Write {
123+
121124 private final String path ;
122125 private final String queryId ;
123126 private final boolean needTruncate ;
@@ -146,6 +149,7 @@ public BatchWrite toBatch() {
146149 }
147150
148151 static class MyBatchWrite implements BatchWrite {
152+
149153 private final String queryId ;
150154 private final String path ;
151155 private final Configuration conf ;
@@ -203,6 +207,7 @@ public void abort(WriterCommitMessage[] messages) {
203207 }
204208
205209 static class MyTable extends JavaSimpleBatchTable implements SupportsWrite {
210+
206211 private final String path ;
207212 private final Configuration conf = SparkHadoopUtil .get ().conf ();
208213
@@ -235,6 +240,7 @@ public Table getTable(CaseInsensitiveStringMap options) {
235240 }
236241
237242 static class JavaCSVInputPartitionReader implements InputPartition {
243+
238244 private String path ;
239245
240246 JavaCSVInputPartitionReader (String path ) {
@@ -251,6 +257,7 @@ public void setPath(String path) {
251257 }
252258
253259 static class JavaCSVReaderFactory implements PartitionReaderFactory {
260+
254261 private final SerializableConfiguration conf ;
255262
256263 JavaCSVReaderFactory (SerializableConfiguration conf ) {
@@ -301,6 +308,7 @@ public void close() throws IOException {
301308 }
302309
303310 static class JavaCSVDataWriterFactory implements DataWriterFactory {
311+
304312 private final String path ;
305313 private final String jobId ;
306314 private final SerializableConfiguration conf ;
@@ -325,6 +333,7 @@ public DataWriter<InternalRow> createWriter(int partitionId, long taskId) {
325333 }
326334
327335 static class JavaCSVDataWriter implements DataWriter <InternalRow > {
336+
328337 private final FileSystem fs ;
329338 private final Path file ;
330339 private final FSDataOutputStream out ;
@@ -356,6 +365,7 @@ public void abort() throws IOException {
356365 }
357366
358367 @ Override
359- public void close () {}
368+ public void close () {
369+ }
360370 }
361371}
0 commit comments