@Internal public final class FileCopyFunction extends Object implements OutputFormat<Path>
OutputFormat.InitializationContext
Constructor and Description |
---|
FileCopyFunction(String path) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Method that marks the end of the life-cycle of parallel output instance.
|
void |
configure(Configuration parameters)
Configures this output format.
|
void |
open(int taskNumber,
int numTasks)
Opens a parallel instance of the output format to store the result of its parallel instance.
|
void |
writeRecord(Path sourcePath)
Adds a record to the output.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
open
public FileCopyFunction(String path)
path
- the destination path to copy filepublic void open(int taskNumber, int numTasks) throws IOException
OutputFormat
When this method is called, the output format it guaranteed to be configured.
open
in interface OutputFormat<Path>
taskNumber
- The number of the parallel instance.numTasks
- The number of parallel tasks.IOException
- Thrown, if the output could not be opened due to an I/O problem.public void writeRecord(Path sourcePath) throws IOException
OutputFormat
When this method is called, the output format it guaranteed to be opened.
writeRecord
in interface OutputFormat<Path>
sourcePath
- The records to add to the output.IOException
- Thrown, if the records could not be added due to an I/O problem.public void configure(Configuration parameters)
OutputFormat
This method is always called first on a newly instantiated output format.
configure
in interface OutputFormat<Path>
parameters
- The configuration with all parameters.public void close() throws IOException
OutputFormat
When this method is called, the output format it guaranteed to be opened.
close
in interface OutputFormat<Path>
IOException
- Thrown, if the input could not be closed properly.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.