AWS Glue Scala DynamicRecord 클래스

패키지:   com.amazonaws.services.glue

class DynamicRecord extends Serializable with Writable with Cloneable

DynamicRecord는 진행된 데이터 세트의 데이터 행을 나타내는 자체적으로 설명되는 데이터 구조입니다. 기록 자체를 검사한 DynamicRecord에 의해 보여지는 스키마 행을 얻을 수 있다는 의미에서 자체 설명적입니다. DynamicRecord는 Apache Spark의 Row와 유사합니다.

def addField

def addField( path : String,
              dynamicNode : DynamicNode
            ) : Unit 

지정된 경로로 DynamicNode를 추가합니다.

def dropField

 def dropField(path: String, underRename: Boolean = false): Option[DynamicNode]

지정된 경로로부터 DynamicNode을 드롭하고 지정된 경로에 배열이 없으면 드롭된 노트를 반환합니다.

scala.Option Option(DynamicNode)을 반환합니다.

def setError

def setError( error : Error )

error 파라미터에 의해 지정되어 이 기록을 오류 기록으로 설정합니다.

DynamicRecord을 반환합니다.

def isError

def isError

이 기록이 오류 기록인지 확인합니다.

def getError

def getError

이 기록이 오류 기록이면 Error를 얻습니다. 이 기록이 오류 기록이면 scala.Some Some(오류)를 반환하고 그렇지 않으면 scala.None입니다.

def clearError

def clearError

Error을 scala.None.None로 설정합니다.

def write

override def write( out : DataOutput ) : Unit 

def readFields

override def readFields( in : DataInput ) : Unit 

def clone

override def clone : DynamicRecord 

이 레코드를 새 DynamicRecord로 복제하고 반환합니다.

def schema

def schema

이 기록을 검사하여 Schema를 얻습니다.

def getRoot

def getRoot : ObjectNode 

이 레코드의 루트 ObjectNode를 얻습니다.

def toJson

def toJson : String 

이 레코드의 JSON 문자열을 얻습니다.

def getFieldNode

def getFieldNode( path : String ) : Option[DynamicNode] 

DynamicNode의 옵션으로 지정된 path의 필드 값을 가져옵니다.

필드가 존재하는 경우 scala.Some Some(DynamicNode)을 반환하고, 그렇지 않으면 scala.None.None입니다.

def getField

def getField( path : String ) : Option[Any] 

DynamicNode의 옵션으로 지정된 path의 필드 값을 가져옵니다.

scala.Some Some(값)을 반환합니다.

def hashCode

override def hashCode : Int 

def equals

override def equals( other : Any )

DynamicRecord 객체

object DynamicRecord

정의 적용

def apply( row : Row,
           schema : SparkStructType )

Apache Spark SQL Row를 DynamicRecord로 변환하는 방법을 적용합니다.

DynamicRecord을 반환합니다.

RecordTraverser 특성

trait RecordTraverser {
  def nullValue(): Unit
  def byteValue(value: Byte): Unit
  def binaryValue(value: Array[Byte]): Unit
  def booleanValue(value: Boolean): Unit
  def shortValue(value: Short) : Unit
  def intValue(value: Int) : Unit
  def longValue(value: Long) : Unit
  def floatValue(value: Float): Unit
  def doubleValue(value: Double): Unit
  def decimalValue(value: BigDecimal): Unit
  def stringValue(value: String): Unit
  def dateValue(value: Date): Unit
  def timestampValue(value: Timestamp): Unit
  def objectStart(length: Int): Unit
  def objectKey(key: String): Unit
  def objectEnd(): Unit
  def mapStart(length: Int): Unit
  def mapKey(key: String): Unit
  def mapEnd(): Unit
  def arrayStart(length: Int): Unit
  def arrayEnd(): Unit
}