Clase DynamicRecord Scala de AWS Glue - AWS Adherencia

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Clase DynamicRecord Scala de AWS Glue

Paquete: com.amazonaws.services.glue

class DynamicRecord extends Serializable with Writable with Cloneable

Un objeto DynamicRecord es una estructura de datos autodescriptiva que representa una fila de datos en el conjunto de datos que se está procesando. Es autodescriptiva en el sentido de que se puede obtener el esquema de la fila representado mediante el objeto DynamicRecord si se inspecciona el registro. Un objeto DynamicRecord es similar a Row en Apache Spark.

Def addField

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

Agrega un objeto DynamicNode a la ruta especificada.

  • path: ruta del campo que se va a agregar.

  • dynamicNode: DynamicNode que se agregará a la ruta especificada.

Def dropField

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

Descarta un objeto DynamicNode de la ruta especifica y devuelve el nodo descartado si no hay una matriz en la ruta especificada.

  • path: ruta al campo que se descartará.

  • underRename: true si se llama a dropField como parte de una transformación de cambio de nombre; de lo contrario, false (false de forma predeterminada).

Devuelve scala.Option Option (DynamicNode).

Def setError

def setError( error : Error )

Establece este registro como un registro de error, tal y como se especifica mediante el parámetro error.

Devuelve DynamicRecord.

Def isError

def isError

Comprueba si es un registro de error.

Def getError

def getError

Obtiene el Error si es un registro de error. Devuelve scala.Some Some (Error) si es un registro de error; de lo contrario, scala.None.

Def clearError

def clearError

Configure el Error en 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

Clona este registro en un nuevo objeto DynamicRecord y lo devuelve.

Def schema

def schema

Obtiene el objeto Schema mediante la inspección del registro.

Def getRoot

def getRoot : ObjectNode

Obtiene el objeto ObjectNode raíz del registro.

Def toJson

def toJson : String

Obtiene la cadena JSON del registro.

Def getFieldNode

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

Obtiene el valor del campo en la path especificada como una opción de DynamicNode.

Devuelve scala.Some Some (DynamicNode) si el campo existe; de lo contrario, scala.None.None.

Def getField

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

Obtiene el valor del campo en la path especificada como una opción de DynamicNode.

Devuelve scala.Some Some (valor).

Def hashCode

override def hashCode : Int

Def equals

override def equals( other : Any )

Objeto DynamicRecord

object DynamicRecord

Def apply

def apply( row : Row, schema : SparkStructType )

Aplique el método para convertir un objeto Row de Apache Spark SQL en un objeto DynamicRecord.

  • row: un objeto Row de Spark SQL.

  • schema: el objeto Schema de la fila.

Devuelve DynamicRecord.

Característica 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 }