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.