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
Rubriques
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