public static class
RecordInput.Options
Optional attributes for RecordInput
Public Methods
| 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)
|
Inherited Methods
| boolean |
equals(Object arg0)
|
| final Class<?> |
getClass()
|
| int |
hashCode()
|
| final void |
notify()
|
| final void |
notifyAll()
|
| String |
toString()
|
| final void |
wait(long arg0, int arg1)
|
| final void |
wait(long arg0)
|
| final void |
wait()
|
Public Methods
public RecordInput.Options compressionType (String compressionType)
Parameters
| compressionType | The type of compression for the file. Currently ZLIB and GZIP are supported. Defaults to none. |
|---|
public RecordInput.Options fileBufferSize (Long fileBufferSize)
Parameters
| fileBufferSize | The randomization shuffling buffer. |
|---|
public RecordInput.Options fileParallelism (Long fileParallelism)
Parameters
| fileParallelism | How many sstables are opened and concurrently iterated over. |
|---|
public RecordInput.Options fileRandomSeed (Long fileRandomSeed)
Parameters
| fileRandomSeed | Random seeds used to produce randomized records. |
|---|
public RecordInput.Options fileShuffleShiftRatio (Float fileShuffleShiftRatio)
Parameters
| fileShuffleShiftRatio | Shifts the list of files after the list is randomly shuffled. |
|---|