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.

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.

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.

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
}