Watch keynotes, product sessions, workshops, and more from Google I/O See playlist

RecordInput.Options

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

Public Methods

public RecordInput.Options batchSize (Long batchSize)

Parameters
batchSize The batch size.

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.