Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Classe Scala DynamicRecord in AWS Glue

Pacchetto: com.amazonaws.services.glue

class DynamicRecord extends Serializable with Writable with Cloneable

Un DynamicRecord è una struttura di dati autodescrittiva che rappresenta una riga di dati nel set di dati in fase di elaborazione. È autodescrittiva nel senso che puoi ottenere lo schema della riga rappresentata da DynamicRecord controllando il record stesso. Un DynamicRecord è simile a un Row in Apache Spark.

Def addField

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

Aggiunge un DynamicNode al percorso specificato.

Def dropField

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

Rilascia un DynamicNode dal percorso specificato e restituisce il nodo rilasciato se non c'è un array nel percorso specificato.

Restituisce una scala.Option Option (DynamicNode).

Def setError

def setError( error : Error )

Imposta il record come un record di errore, come specificato dal parametro error.

Restituisce una DynamicRecord.

Def isError

def isError

Verifica se il record è un record di errore.

Def getError

def getError

Ottiene Error se il record è un record di errore. Restituisce scala.Some Some (Error) se il record è un record di errore o altrimenti scala.None.

Def clearError

def clearError

Imposta Error su scala.None.None.

Def scrittura

override def write( out : DataOutput ) : Unit 

Def readFields

override def readFields( in : DataInput ) : Unit 

Def clone

override def clone : DynamicRecord 

Clona questo record in un nuovo DynamicRecord e lo restituisce.

Def schema

def schema

Ottiene lo Schema controllando il record.

Def getRoot

def getRoot : ObjectNode 

Ottiene la radice ObjectNode per il record.

Def toJson

def toJson : String 

Ottiene la stringa JSON per il record.

Def getFieldNode

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

Ottiene il valore del campo nel path specificato come opzione di DynamicNode.

Restituisce scala.Some Some (DynamicNode) se il campo esiste, altrimenti scala.None.None.

Def getField

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

Ottiene il valore del campo nel path specificato come opzione di DynamicNode.

Restituisce scala.Some Some (valore).

Def hashCode

override def hashCode : Int 

Def equals

override def equals( other : Any )

Oggetto DynamicRecord

object DynamicRecord

Applicazione di def

def apply( row : Row,
           schema : SparkStructType )

Applica il metodo per convertire un Apache Spark SQL Row in un DynamicRecord.

Restituisce una DynamicRecord.

Proprietà 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
}