Abstract DataSink 類別 - AWS Glue

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

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