Package org.rumbledb.items.structured

Class JSoundDataFrame

java.lang.Object
org.rumbledb.items.structured.JSoundDataFrame
All Implemented Interfaces:
Serializable
public class JSoundDataFrame extends Object implements Serializable
See Also:

  • Constructor Details

    • JSoundDataFrame

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

    • JSoundDataFrame

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

  • Method Details

    • emptyDataFrame

      public static JSoundDataFrame emptyDataFrame()

    • getDataFrame

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

    • javaRDD

      public org.apache.spark.api.java.JavaRDD<org.apache.spark.sql.Row> javaRDD()

    • count

      public long count()

    • getItemType

      public ItemType getItemType()

    • getKeys

      public List<String> getKeys()

    • getSQLColumnProjection

      public String getSQLColumnProjection(boolean trailingComma)

    • createOrReplaceTempView

      public void createOrReplaceTempView(String name)

    • evaluateSQL

      public JSoundDataFrame evaluateSQL(String sqlQuery, ItemType outputType)

    • isEmptySequence

      public boolean isEmptySequence()

    • getExactlyOneItem

      public Item getExactlyOneItem()

    • distinct

      public JSoundDataFrame distinct()

    • union

      public JSoundDataFrame union(JSoundDataFrame other)

    • hasKey

      public boolean hasKey(String key)

    • take

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

    • repartition

      public JSoundDataFrame 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)