추상 DataSink 클래스 - AWS Glue

기계 번역으로 제공되는 번역입니다. 제공된 번역과 원본 영어의 내용이 상충하는 경우에는 영어 버전이 우선합니다.

추상 DataSink 클래스

패키지:   com.amazonaws.services.glue

abstract class DataSink

DataSource에 대한 쓰기 아날로그. DataSinkDynamicFrame이 기록될 수 있는 대상과 형식을 요약합니다.

writeDynamicFrame 정의

def writeDynamicFrame( frame : DynamicFrame, callSite : CallSite = CallSite("Not provided", "") ) : DynamicFrame

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

setCatalogInfo 정의

def setCatalogInfo(catalogDatabase: String, catalogTableName : String, catalogId : String = "")

supportsFormat 정의

def supportsFormat( format : String ) : Boolean

setFormat 정의

def setFormat( format : String, options : JsonOptions ) : Unit

withFormat 정의

def withFormat( format : String, options : JsonOptions = JsonOptions.empty ) : DataSink

setAccumulableSize 정의

def setAccumulableSize( size : Int ) : Unit

getOutputErrorRecordsAccumulable 정의

def getOutputErrorRecordsAccumulable : Accumulable[List[OutputError], OutputError]

errorsAsDynamicFrame 정의

def errorsAsDynamicFrame : DynamicFrame

DataSink 객체

object DataSink

recordMetrics 정의

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