Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
Abstrakte DataSink-Klasse
Themen
Paket: com.amazonaws.services.glue
abstract class DataSink
Der Schreiber ist analog zu einem DataSource
. DataSink
fasst ein Ziel und ein Format zusammen, in das ein DynamicFrame
geschrieben werden kann.
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-Objekt
object DataSink
def recordMetrics
def recordMetrics( frame : DynamicFrame,
ctxt : String
) : DynamicFrame