Class CreateCollectionPrimitive
java.lang.Object
org.rumbledb.runtime.update.primitives.CreateCollectionPrimitive
- All Implemented Interfaces:
UpdatePrimitive
-
Constructor Summary
ConstructorsConstructorDescriptionCreateCollectionPrimitive
(String collectionName, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> contents, boolean isTable, ExceptionMetadata metadata) -
Method Summary
Modifier and TypeMethodDescriptionvoid
apply()
void
void
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
boolean
boolean
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.rumbledb.runtime.update.primitives.UpdatePrimitive
arrayIndexingApplyDelta, arrayIndexingUpdateSchemaDelta, getCollectionName, getContent, getContentList, getIntSelector, getRowOrder, getRowOrderRangeBase, getRowOrderRangeMax, getSelector, getTarget, getTargetDataFrame, isDeleteArray, isDeleteObject, isDeleteTuple, isEditTuple, isInsertAfterIntoCollection, isInsertArray, isInsertBeforeIntoCollection, isInsertFirstIntoCollection, isInsertLastIntoCollection, isInsertObject, isInsertTuple, isRenameObject, isReplaceArray, isReplaceObject, isTruncateCollection, updatesSchemaDelta
-
Constructor Details
-
CreateCollectionPrimitive
public CreateCollectionPrimitive(String collectionName, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> contents, boolean isTable, ExceptionMetadata metadata)
-
-
Method Details
-
isCreateCollection
public boolean isCreateCollection()- Specified by:
isCreateCollection
in interfaceUpdatePrimitive
-
getCollectionPath
- Specified by:
getCollectionPath
in interfaceUpdatePrimitive
-
hasSelector
public boolean hasSelector()- Specified by:
hasSelector
in interfaceUpdatePrimitive
-
getContentDataFrame
public org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> getContentDataFrame()- Specified by:
getContentDataFrame
in interfaceUpdatePrimitive
-
apply
public void apply()- Specified by:
apply
in interfaceUpdatePrimitive
-
applyItem
public void applyItem()- Specified by:
applyItem
in interfaceUpdatePrimitive
-
applyDelta
public void applyDelta()- Specified by:
applyDelta
in interfaceUpdatePrimitive
-