columnar

Type Members

1. case class CallbackColumnInsert(_schema: StructType) extends SparkPlan with LeafExecNode with CodegenSupportOnExecutor with Product with Serializable

   

   This class is an adapter over the iterator model as provided by generated code to closure callbacks model as required by StratifiedSampler.append

2. case class ColumnBatch(numRows: Int, buffers: Array[ByteBuffer], statsData: Array[Byte], deltaIndexes: Array[Int]) extends Product with Serializable

   

3. final class ColumnBatchCreator extends Logging

   

4. class ColumnBatchIterator extends PRValuesIterator[ByteBuffer]

   

5. final class ColumnBatchIteratorOnRS extends ResultSetIterator[ByteBuffer]

   

6. trait ColumnBatchRowsBuffer extends AnyRef

   

7. case class ColumnDeleteExec(child: SparkPlan, columnTable: String, partitionColumns: Seq[String], partitionExpressions: Seq[Expression], numBuckets: Int, isPartitioned: Boolean, tableSchema: StructType, externalStore: ExternalStore, appendableRelation: JDBCAppendableRelation, keyColumns: Seq[Attribute], connProps: ConnectionProperties) extends SparkPlan with ColumnExec with Product with Serializable

   

   Generated code plan for deletes into a column table.

   Generated code plan for deletes into a column table. This extends RowExec to generate the combined code for row buffer deletes.

8. trait ColumnExec extends SparkPlan with RowExec

   

   Base class for bulk column table insert, update, put, delete operations.

9. case class ColumnInsertExec(child: SparkPlan, partitionColumns: Seq[String], partitionExpressions: Seq[Expression], numBuckets: Int, isPartitioned: Boolean, relation: Option[DestroyRelation], batchParams: (Int, Int, String), columnTable: String, onExecutor: Boolean, tableSchema: StructType, externalStore: ExternalStore, useMemberVariables: Boolean) extends SparkPlan with TableExec with Product with Serializable

   

   Generated code plan for bulk insertion into a column table.

10. case class ColumnPutIntoExec(insertPlan: SparkPlan, updatePlan: SparkPlan) extends SparkPlan with BinaryExecNode with Product with Serializable

    

11. case class ColumnUpdateExec(child: SparkPlan, columnTable: String, partitionColumns: Seq[String], partitionExpressions: Seq[Expression], numBuckets: Int, isPartitioned: Boolean, tableSchema: StructType, externalStore: ExternalStore, columnRelation: BaseColumnFormatRelation, updateColumns: Seq[Attribute], updateExpressions: Seq[Expression], keyColumns: Seq[Attribute], connProps: ConnectionProperties) extends SparkPlan with ColumnExec with Product with Serializable

    

    Generated code plan for updates into a column table.

    Generated code plan for updates into a column table. This extends RowExec to generate the combined code for row buffer updates.

12. abstract class ColumnarIterator extends Iterator[InternalRow]

    

    An Iterator to walk through the InternalRows from a CachedBatch

13. trait ExternalStore extends Serializable with Logging

    

14. case class InMemoryRelation(output: Seq[Attribute], useCompression: Boolean, batchSize: Int, storageLevel: StorageLevel, child: SparkPlan, tableName: Option[String])(_cachedColumnBuffers: RDD[CachedBatch] = null, batchStats: LongAccumulator = ...) extends LeafNode with MultiInstanceRelation with Product with Serializable

    

15. case class InMemoryTableScanExec(attributes: Seq[Attribute], predicates: Seq[Expression], relation: InMemoryRelation) extends SparkPlan with LeafExecNode with Product with Serializable

    

16. abstract case class JDBCAppendableRelation(table: String, provider: String, mode: SaveMode, userSchema: StructType, origOptions: CaseInsensitiveMutableHashMap[String], externalStore: ExternalStore, sqlContext: SQLContext) extends BaseRelation with PrunedUnsafeFilteredScan with InsertableRelation with PlanInsertableRelation with DestroyRelation with IndexableRelation with Logging with NativeTableRowLevelSecurityRelation with Serializable with Product

    

    A LogicalPlan implementation for an external column table whose contents are retrieved using a JDBC URL or DataSource.

17. class MutableUnsafeRow extends InternalRow with BaseGenericInternalRow

    

    An helper class to update the fields of UnsafeRow, used by ColumnAccessor

    An helper class to update the fields of UnsafeRow, used by ColumnAccessor

    WARNING: These setter MUST be called in increasing order of ordinals.

18. case class NumBatchRows(varName: String) extends LeafExpression with Product with Serializable

    

19. abstract class ResultSetIterator[A] extends Iterator[A] with Logging with BucketsBasedIterator

    

20. case class StartsWithForStats(upper: Expression, lower: Expression, pattern: Expression) extends Expression with Product with Serializable