public static class RecordInput.Options extends Object
RecordInput
Modifier and Type | Method and Description |
---|---|
RecordInput.Options |
batchSize(Long batchSize) |
RecordInput.Options |
compressionType(String compressionType) |
RecordInput.Options |
fileBufferSize(Long fileBufferSize) |
RecordInput.Options |
fileParallelism(Long fileParallelism) |
RecordInput.Options |
fileRandomSeed(Long fileRandomSeed) |
RecordInput.Options |
fileShuffleShiftRatio(Float fileShuffleShiftRatio) |
public RecordInput.Options fileRandomSeed(Long fileRandomSeed)
fileRandomSeed
- Random seeds used to produce randomized records.public RecordInput.Options fileShuffleShiftRatio(Float fileShuffleShiftRatio)
fileShuffleShiftRatio
- Shifts the list of files after the list is randomly
shuffled.public RecordInput.Options fileBufferSize(Long fileBufferSize)
fileBufferSize
- The randomization shuffling buffer.public RecordInput.Options fileParallelism(Long fileParallelism)
fileParallelism
- How many sstables are opened and concurrently iterated over.public RecordInput.Options batchSize(Long batchSize)
batchSize
- The batch size.public RecordInput.Options compressionType(String compressionType)
compressionType
- The type of compression for the file. Currently ZLIB and
GZIP are supported. Defaults to none.Copyright © 2022. All rights reserved.