org.bytedeco.arrow_dataset

Class InMemoryDataset

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.arrow_dataset.Dataset

org.bytedeco.arrow_dataset.InMemoryDataset

All Implemented Interfaces:

AutoCloseable

@Namespace(value="arrow::dataset")
 @NoOffset
 @Properties(inherit=arrow_dataset.class)
public class InMemoryDataset
extends Dataset

\addtogroup dataset-implementations \{

\brief A Source which yields fragments wrapping a stream of record batches. The record batches must match the schema provided to the source at construction.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InMemoryDataset.RecordBatchGenerator

Nested classes/interfaces inherited from class org.bytedeco.javacpp.Pointer

Pointer.CustomDeallocator, Pointer.Deallocator, Pointer.NativeDeallocator, Pointer.ReferenceCounter

Field Summary

Fields inherited from class org.bytedeco.javacpp.Pointer

address, capacity, limit, position

Constructor Summary

Constructors

Constructor and Description
InMemoryDataset(Pointer p) Pointer cast constructor.
InMemoryDataset(Schema schema, InMemoryDataset.RecordBatchGenerator get_batches) Construct a dataset from a schema and a factory of record batch iterators.
InMemoryDataset(Schema schema, RecordBatchVector batches) Convenience constructor taking a fixed list of batches
InMemoryDataset(Table table) Convenience constructor taking a Table

Method Summary

Modifier and Type	Method and Description
DatasetResult	ReplaceSchema(Schema schema) \brief Return a copy of this Dataset with a different schema.
String	type_name() \brief The name identifying the kind of Dataset

Methods inherited from class org.bytedeco.arrow_dataset.Dataset

GetFragments, GetFragments, NewScan, partition_expression, schema

Methods inherited from class org.bytedeco.javacpp.Pointer

address, asBuffer, asByteBuffer, availablePhysicalBytes, calloc, capacity, capacity, close, deallocate, deallocate, deallocateReferences, deallocator, deallocator, equals, fill, formatBytes, free, getDirectBufferAddress, getPointer, getPointer, getPointer, getPointer, hashCode, interruptDeallocatorThread, isNull, isNull, limit, limit, malloc, maxBytes, maxPhysicalBytes, memchr, memcmp, memcpy, memmove, memset, offsetAddress, offsetof, offsetof, parseBytes, physicalBytes, physicalBytesInaccurate, position, position, put, realloc, referenceCount, releaseReference, retainReference, setNull, sizeof, sizeof, toString, totalBytes, totalCount, totalPhysicalBytes, withDeallocator, zero

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

InMemoryDataset

public InMemoryDataset(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

InMemoryDataset

public InMemoryDataset(@SharedPtr @ByVal
                       Schema schema,
                       @SharedPtr
                       InMemoryDataset.RecordBatchGenerator get_batches)

Construct a dataset from a schema and a factory of record batch iterators.

InMemoryDataset

public InMemoryDataset(@SharedPtr @ByVal
                       Schema schema,
                       @ByVal
                       RecordBatchVector batches)

Convenience constructor taking a fixed list of batches

InMemoryDataset

public InMemoryDataset(@SharedPtr @Cast(value={"","std::shared_ptr<arrow::Table>"})
                       Table table)

Convenience constructor taking a Table

Method Detail

type_name

@StdString
public String type_name()

Description copied from class: Dataset

\brief The name identifying the kind of Dataset

Overrides:

type_name in class Dataset

ReplaceSchema

@ByVal
public DatasetResult ReplaceSchema(@SharedPtr @ByVal
                                           Schema schema)

Description copied from class: Dataset

\brief Return a copy of this Dataset with a different schema. The copy will view the same Fragments. If the new schema is not compatible with the original dataset's schema then an error will be raised.

Overrides:

ReplaceSchema in class Dataset