Package org.rumbledb.runtime.update.primitives

Class Collection

java.lang.Object

org.rumbledb.runtime.update.primitives.Collection

All Implemented Interfaces:

Serializable

public class Collection
extends Object
implements Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
Collection(String collectionPath)	Constructor for Collection using physical path.
Collection(Mode mode, String collectionPath)	Constructor for Collection using logical path.

Method Summary

Modifier and Type	Method	Description
String	getLogicalName()
Mode	getMode()
String	getPhysicalName()
void	insertUnordered(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> contents)	Inserts the given contents into the collection according to its mode.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Collection

public Collection(Mode mode,
 String collectionPath)

Constructor for Collection using logical path.

Parameters:

mode - The storage mode of the collection (HIVE, DELTA, etc.)

collectionPath - The logical path of the collection

Collection

public Collection(String collectionPath)

Constructor for Collection using physical path.

Parameters:

collectionPath - The physical path of the collection

Method Details

getMode

public Mode getMode()

Returns:

The storage mode of the collection

getLogicalName

public String getLogicalName()

Returns:

The logical name of the collection

getPhysicalName

public String getPhysicalName()

Returns:

The physical name of the collection

insertUnordered

public void insertUnordered(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> contents)

Inserts the given contents into the collection according to its mode. This method does not handle ordering of the inserted contents.

Parameters:

contents - The dataset to insert into the collection