Classe abstraite DataSink - AWS Glue

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Classe abstraite DataSink

Package : com.amazonaws.services.glue

abstract class DataSink

L'enregistreur analogue à un encapsule un DataSource. DataSink encapsule une destination et un format dans lequel un DynamicFrame peut être écrit.

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

Objet DataSink

object DataSink

def recordMetrics

def recordMetrics( frame : DynamicFrame, ctxt : String ) : DynamicFrame