Package org.rumbledb.items.structured

Class HomogeneousItemDataFrame

java.lang.Object
org.rumbledb.items.structured.HomogeneousItemDataFrame
All Implemented Interfaces:
Serializable, RuntimeDataFrame<Item>
public class HomogeneousItemDataFrame extends Object implements RuntimeDataFrame<Item>, Serializable
See Also:

  • Constructor Details

    • HomogeneousItemDataFrame

      public HomogeneousItemDataFrame(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame, ItemType itemType)

    • HomogeneousItemDataFrame

      public HomogeneousItemDataFrame(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame)

  • Method Details

    • emptyDataFrame

      public static HomogeneousItemDataFrame emptyDataFrame()

    • toRDD

      public org.apache.spark.api.java.JavaRDD<Item> toRDD(ExceptionMetadata metadata)
      Converts this JSONiq DataFrame to its logical item representation.
      Specified by:
      toRDD in interface RuntimeDataFrame<Item>
      Parameters:
      metadata - query metadata used if a row cannot be decoded
      Returns:
      an RDD containing the represented items

    • count

      public long count()

    • getKeys

      public List<String> getKeys()

    • getSQLColumnProjection

      public String getSQLColumnProjection(boolean trailingComma)

    • createOrReplaceTempView

      public void createOrReplaceTempView(String name)

    • evaluateSQL

      public HomogeneousItemDataFrame evaluateSQL(String sqlQuery, ItemType outputType)

    • isEmptySequence

      public boolean isEmptySequence()

    • getExactlyOneItem

      public Item getExactlyOneItem()

    • distinct

      public HomogeneousItemDataFrame distinct()

    • union

      public HomogeneousItemDataFrame union(HomogeneousItemDataFrame other)

    • hasKey

      public boolean hasKey(String key)

    • take

      public List<org.apache.spark.sql.Row> take(int n)

    • repartition

      public HomogeneousItemDataFrame repartition(int n)

    • getColumns

      public List<FlworDataFrameColumn> getColumns()
      Returns:
      list of FLWOR columns in the schema

    • containsVariantType

      public static boolean containsVariantType(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataFrame)