package clickhouse
Ordering
- Alphabetic
Visibility
- Public
- Protected
Type Members
- trait ClickHouseFileBuilder[-R] extends FileBuilder[R]
A FileBuilder able to build files that can be loaded to ClickHouse.
A FileBuilder able to build files that can be loaded to ClickHouse.
- R
type of the records written to files being built.
- trait ClickHouseFileBuilderFactory[R] extends FileBuilderFactory[R, ClickHouseFileBuilder[R]]
- case class ClickHouseFileRecordBatch(file: File, format: ClickHouseFormat, compression: ClickHouseCompression, recordRanges: Seq[StreamRange], rowCount: Long) extends FileRecordBatch with Product with Serializable
A file containing a batch of records in some ClickHouse supported format that can be loaded to ClickHouse.
- class ClickHouseFileRecordBatcher[R] extends FileRecordBatcher[R, ClickHouseFileRecordBatch, ClickHouseFileBuilder[R]]
- class ClickHouseFileStorage extends InDataOffsetBatchStorage[ClickHouseFileRecordBatch] with Logging
A ClickHouse storage implementation, stores offsets in rows of data.
A ClickHouse storage implementation, stores offsets in rows of data. Queries ClickHouse upon initialization in order to retrieve committed stream positions.
Value Members
- object ClickHouseFileRecordBatcher
- object ClickHouseFileStorage