class SharedDatasetState extends AnyRef
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- SharedDatasetState
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Instance Constructors
- new SharedDatasetState(columnParams: ColumnParams, schema: StructType, trainParams: TrainParams, sharedState: SharedState)
Value Members
- var arrayProcessedSignal: CountDownLatch
- val chunkSize: Int
- lazy val denseAggregatedColumns: BaseDenseAggregatedColumns
- def getArrayType(rowsIter: Iterator[Row], matrixType: String): (Iterator[Row], Boolean)
- def incrementArrayProcessedSignal(log: Logger): Int
- val matrixType: String
- def merge(ts: BaseChunkedColumns): BaseAggregatedColumns
- def prep(iter: Iterator[Row]): BaseChunkedColumns
- lazy val sparseAggregatedColumns: BaseSparseAggregatedColumns
- val useSingleDataset: Boolean