Package | Description |
---|---|
org.bytedeco.arrow_dataset |
Modifier and Type | Method and Description |
---|---|
ScanOptions |
ScanOptions.batch_readahead(int setter) |
ScanOptions |
ScanOptions.batch_readahead(int setter) |
ScanOptions |
ScanOptions.batch_size(long setter) |
ScanOptions |
ScanOptions.batch_size(long setter) |
ScanOptions |
ScanOptions.dataset_schema(Schema setter) |
ScanOptions |
ScanOptions.dataset_schema(Schema setter) |
ScanOptions |
ScanOptions.filter(Expression setter) |
ScanOptions |
ScanOptions.filter(Expression setter) |
ScanOptions |
ScanOptions.fragment_readahead(int setter) |
ScanOptions |
ScanOptions.fragment_readahead(int setter) |
ScanOptions |
ScanOptions.fragment_scan_options(FragmentScanOptions setter) |
ScanOptions |
ScanOptions.fragment_scan_options(FragmentScanOptions setter) |
ScanOptions |
ScanOptions.getPointer(long i) |
ScanOptions |
ScanOptions.getPointer(long i) |
ScanOptions |
ScanOptions.io_context(IOContext setter) |
ScanOptions |
ScanOptions.io_context(IOContext setter) |
ScanOptions |
Scanner.options()
\brief Get the options for this scan.
|
ScanOptions |
ScanTask.options() |
ScanOptions |
ScanTask.options() |
ScanOptions |
Scanner.options()
\brief Get the options for this scan.
|
ScanOptions |
ScanOptions.pool(MemoryPool setter) |
ScanOptions |
ScanOptions.pool(MemoryPool setter) |
ScanOptions |
ScanOptions.position(long position) |
ScanOptions |
ScanOptions.position(long position) |
ScanOptions |
ScanOptions.projected_schema(Schema setter) |
ScanOptions |
ScanOptions.projected_schema(Schema setter) |
ScanOptions |
ScanOptions.projection(Expression setter) |
ScanOptions |
ScanOptions.projection(Expression setter) |
ScanOptions |
ScanNodeOptions.scan_options() |
ScanOptions |
ScanNodeOptions.scan_options() |
ScanOptions |
ScanOptions.use_async(boolean setter) |
ScanOptions |
ScanOptions.use_async(boolean setter) |
ScanOptions |
ScanOptions.use_threads(boolean setter) |
ScanOptions |
ScanOptions.use_threads(boolean setter) |
Modifier and Type | Method and Description |
---|---|
LongOptionalFuture |
FileFragment.CountRows(Expression predicate,
ScanOptions options) |
LongOptionalFuture |
Fragment.CountRows(Expression predicate,
ScanOptions options)
\brief Count the number of rows in this fragment matching the filter using metadata
only.
|
LongOptionalFuture |
InMemoryFragment.CountRows(Expression predicate,
ScanOptions options) |
LongOptionalFuture |
InMemoryFragment.CountRows(Expression predicate,
ScanOptions options) |
LongOptionalFuture |
Fragment.CountRows(Expression predicate,
ScanOptions options)
\brief Count the number of rows in this fragment matching the filter using metadata
only.
|
LongOptionalFuture |
FileFragment.CountRows(Expression predicate,
ScanOptions options) |
LongOptionalFuture |
CsvFileFormat.CountRows(FileFragment file,
Expression predicate,
ScanOptions options) |
LongOptionalFuture |
FileFormat.CountRows(FileFragment file,
Expression predicate,
ScanOptions options) |
LongOptionalFuture |
IpcFileFormat.CountRows(FileFragment file,
Expression predicate,
ScanOptions options) |
LongOptionalFuture |
ParquetFileFormat.CountRows(FileFragment file,
Expression predicate,
ScanOptions options) |
LongOptionalFuture |
ParquetFileFormat.CountRows(FileFragment file,
Expression predicate,
ScanOptions options) |
LongOptionalFuture |
IpcFileFormat.CountRows(FileFragment file,
Expression predicate,
ScanOptions options) |
LongOptionalFuture |
FileFormat.CountRows(FileFragment file,
Expression predicate,
ScanOptions options) |
LongOptionalFuture |
CsvFileFormat.CountRows(FileFragment file,
Expression predicate,
ScanOptions options) |
FileReaderResult |
ParquetFileFormat.GetReader(FileSource source,
ScanOptions arg1)
\brief Return a FileReader on the given source.
|
FileReaderResult |
ParquetFileFormat.GetReader(FileSource source,
ScanOptions arg1)
\brief Return a FileReader on the given source.
|
ScanNodeOptions |
ScanNodeOptions.scan_options(ScanOptions setter) |
ScanNodeOptions |
ScanNodeOptions.scan_options(ScanOptions setter) |
ScanTaskIteratorResult |
FileFragment.Scan(ScanOptions options) |
ScanTaskIteratorResult |
Fragment.Scan(ScanOptions options)
\brief Scan returns an iterator of ScanTasks, each of which yields
RecordBatches from this Fragment.
|
ScanTaskIteratorResult |
InMemoryFragment.Scan(ScanOptions options) |
ScanTaskIteratorResult |
InMemoryFragment.Scan(ScanOptions options) |
ScanTaskIteratorResult |
Fragment.Scan(ScanOptions options)
\brief Scan returns an iterator of ScanTasks, each of which yields
RecordBatches from this Fragment.
|
ScanTaskIteratorResult |
FileFragment.Scan(ScanOptions options) |
RecordBatchGeneratorResult |
FileFragment.ScanBatchesAsync(ScanOptions options) |
RecordBatchGeneratorResult |
Fragment.ScanBatchesAsync(ScanOptions options)
An asynchronous version of Scan
|
RecordBatchGeneratorResult |
InMemoryFragment.ScanBatchesAsync(ScanOptions options) |
RecordBatchGeneratorResult |
InMemoryFragment.ScanBatchesAsync(ScanOptions options) |
RecordBatchGeneratorResult |
Fragment.ScanBatchesAsync(ScanOptions options)
An asynchronous version of Scan
|
RecordBatchGeneratorResult |
FileFragment.ScanBatchesAsync(ScanOptions options) |
RecordBatchGeneratorResult |
CsvFileFormat.ScanBatchesAsync(ScanOptions scan_options,
FileFragment file) |
RecordBatchGeneratorResult |
FileFormat.ScanBatchesAsync(ScanOptions options,
FileFragment file) |
RecordBatchGeneratorResult |
IpcFileFormat.ScanBatchesAsync(ScanOptions options,
FileFragment file) |
RecordBatchGeneratorResult |
ParquetFileFormat.ScanBatchesAsync(ScanOptions options,
FileFragment file) |
RecordBatchGeneratorResult |
ParquetFileFormat.ScanBatchesAsync(ScanOptions options,
FileFragment file) |
RecordBatchGeneratorResult |
IpcFileFormat.ScanBatchesAsync(ScanOptions options,
FileFragment file) |
RecordBatchGeneratorResult |
FileFormat.ScanBatchesAsync(ScanOptions options,
FileFragment file) |
RecordBatchGeneratorResult |
CsvFileFormat.ScanBatchesAsync(ScanOptions scan_options,
FileFragment file) |
ScanTaskIteratorResult |
CsvFileFormat.ScanFile(ScanOptions options,
FileFragment fragment)
\brief Open a file for scanning
|
ScanTaskIteratorResult |
FileFormat.ScanFile(ScanOptions options,
FileFragment file)
\brief Open a FileFragment for scanning.
|
ScanTaskIteratorResult |
IpcFileFormat.ScanFile(ScanOptions options,
FileFragment fragment)
\brief Open a file for scanning
|
ScanTaskIteratorResult |
ParquetFileFormat.ScanFile(ScanOptions options,
FileFragment file)
\brief Open a file for scanning
|
ScanTaskIteratorResult |
ParquetFileFormat.ScanFile(ScanOptions options,
FileFragment file)
\brief Open a file for scanning
|
ScanTaskIteratorResult |
IpcFileFormat.ScanFile(ScanOptions options,
FileFragment fragment)
\brief Open a file for scanning
|
ScanTaskIteratorResult |
FileFormat.ScanFile(ScanOptions options,
FileFragment file)
\brief Open a FileFragment for scanning.
|
ScanTaskIteratorResult |
CsvFileFormat.ScanFile(ScanOptions options,
FileFragment fragment)
\brief Open a file for scanning
|
Constructor and Description |
---|
InMemoryScanTask(RecordBatchVector record_batches,
ScanOptions options,
Fragment fragment) |
InMemoryScanTask(RecordBatchVector record_batches,
ScanOptions options,
Fragment fragment) |
ScannerBuilder(Dataset dataset,
ScanOptions scan_options) |
ScannerBuilder(Dataset dataset,
ScanOptions scan_options) |
ScannerBuilder(Schema schema,
Fragment fragment,
ScanOptions scan_options) |
ScannerBuilder(Schema schema,
Fragment fragment,
ScanOptions scan_options) |
ScanNodeOptions(Dataset dataset,
ScanOptions scan_options) |
ScanNodeOptions(Dataset dataset,
ScanOptions scan_options) |
ScanNodeOptions(Dataset dataset,
ScanOptions scan_options,
AsyncToggle backpressure_toggle,
boolean require_sequenced_output) |
ScanNodeOptions(Dataset dataset,
ScanOptions scan_options,
AsyncToggle backpressure_toggle,
boolean require_sequenced_output) |
Copyright © 2022. All rights reserved.