Package org.apache.iceberg.gcp.gcs
Class GCSOutputFile
- java.lang.Object
-
- org.apache.iceberg.gcp.gcs.GCSOutputFile
-
- All Implemented Interfaces:
OutputFile
public class GCSOutputFile extends java.lang.Object implements OutputFile
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description PositionOutputStreamcreate()Create an output stream for the specified location if the target object does not exist in GCS at the time of invocation.PositionOutputStreamcreateOrOverwrite()Create a new file and return aPositionOutputStreamto it.booleanexists()static GCSOutputFilefromLocation(java.lang.String location, com.google.cloud.storage.Storage storage, GCPProperties gcpProperties)protected GCPPropertiesgcpProperties()protected com.google.cloud.storage.BlobgetBlob()java.lang.Stringlocation()InputFiletoInputFile()Return anInputFilefor the location of this output file.java.lang.StringtoString()-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.iceberg.io.OutputFile
location
-
-
-
-
Method Detail
-
fromLocation
public static GCSOutputFile fromLocation(java.lang.String location, com.google.cloud.storage.Storage storage, GCPProperties gcpProperties)
-
create
public PositionOutputStream create()
Create an output stream for the specified location if the target object does not exist in GCS at the time of invocation.- Specified by:
createin interfaceOutputFile- Returns:
- output stream
-
createOrOverwrite
public PositionOutputStream createOrOverwrite()
Description copied from interface:OutputFileCreate a new file and return aPositionOutputStreamto it.If the file already exists, this will not throw an exception and will replace the file.
- Specified by:
createOrOverwritein interfaceOutputFile- Returns:
- an output stream that can report its position
-
toInputFile
public InputFile toInputFile()
Description copied from interface:OutputFileReturn anInputFilefor the location of this output file.- Specified by:
toInputFilein interfaceOutputFile- Returns:
- an input file for the location of this output file
-
location
public java.lang.String location()
-
gcpProperties
protected GCPProperties gcpProperties()
-
exists
public boolean exists()
-
getBlob
protected com.google.cloud.storage.Blob getBlob()
-
toString
public java.lang.String toString()
- Overrides:
toStringin classjava.lang.Object
-
-