本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
Abstract DataSink 類別
主題
Package: com.amazonaws.services.glue
abstract class DataSink
對 DataSource
的寫入類比。DataSink
會封裝 DynamicFrame
可寫入的目的地和格式。
Def writeDynamicFrame
def writeDynamicFrame( frame : DynamicFrame,
callSite : CallSite = CallSite("Not provided", "")
) : DynamicFrame
Def pyWriteDynamicFrame
def pyWriteDynamicFrame( frame : DynamicFrame,
site : String = "Not provided",
info : String = "" )
Def writeDataFrame
def writeDataFrame(frame: DataFrame,
glueContext: GlueContext,
callSite: CallSite = CallSite("Not provided", "")
): DataFrame
Def pyWriteDataFrame
def pyWriteDataFrame(frame: DataFrame,
glueContext: GlueContext,
site: String = "Not provided",
info: String = ""
): DataFrame
Def setCatalogInfo
def setCatalogInfo(catalogDatabase: String,
catalogTableName : String,
catalogId : String = "")
Def supportsFormat
def supportsFormat( format : String ) : Boolean
Def setFormat
def setFormat( format : String,
options : JsonOptions
) : Unit
Def withFormat
def withFormat( format : String,
options : JsonOptions = JsonOptions.empty
) : DataSink
Def setAccumulableSize
def setAccumulableSize( size : Int ) : Unit
Def getOutputErrorRecordsAccumulable
def getOutputErrorRecordsAccumulable : Accumulable[List[OutputError], OutputError]
Def errorsAsDynamicFrame
def errorsAsDynamicFrame : DynamicFrame
DataSink 物件
object DataSink
Def recordMetrics
def recordMetrics( frame : DynamicFrame,
ctxt : String
) : DynamicFrame