Package org.apache.iceberg.hadoop
Class HadoopFileIO
- java.lang.Object
-
- org.apache.iceberg.hadoop.HadoopFileIO
-
- All Implemented Interfaces:
java.io.Serializable
,FileIO
public class HadoopFileIO extends java.lang.Object implements FileIO
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description HadoopFileIO(org.apache.hadoop.conf.Configuration hadoopConf)
HadoopFileIO(SerializableSupplier<org.apache.hadoop.conf.Configuration> hadoopConf)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.hadoop.conf.Configuration
conf()
void
deleteFile(java.lang.String path)
Delete the file at the given path.InputFile
newInputFile(java.lang.String path)
Get aInputFile
instance to read bytes from the file at the given path.OutputFile
newOutputFile(java.lang.String path)
Get aOutputFile
instance to write bytes to the file at the given path.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.iceberg.io.FileIO
deleteFile, deleteFile
-
-
-
-
Constructor Detail
-
HadoopFileIO
public HadoopFileIO(org.apache.hadoop.conf.Configuration hadoopConf)
-
HadoopFileIO
public HadoopFileIO(SerializableSupplier<org.apache.hadoop.conf.Configuration> hadoopConf)
-
-
Method Detail
-
conf
public org.apache.hadoop.conf.Configuration conf()
-
newInputFile
public InputFile newInputFile(java.lang.String path)
Description copied from interface:FileIO
Get aInputFile
instance to read bytes from the file at the given path.- Specified by:
newInputFile
in interfaceFileIO
-
newOutputFile
public OutputFile newOutputFile(java.lang.String path)
Description copied from interface:FileIO
Get aOutputFile
instance to write bytes to the file at the given path.- Specified by:
newOutputFile
in interfaceFileIO
-
deleteFile
public void deleteFile(java.lang.String path)
Description copied from interface:FileIO
Delete the file at the given path.- Specified by:
deleteFile
in interfaceFileIO
-
-