Package | Description |
---|---|
com.actian.dataflow.operators.io.orc | |
com.actian.dataflow.operators.io.parquet | |
com.pervasive.datarush.operators.io |
Provides base file I/O components including encoders and decoders.
|
com.pervasive.datarush.operators.io.avro |
Provides operators for reading and writing files in Avro format.
|
com.pervasive.datarush.operators.io.binary | |
com.pervasive.datarush.operators.io.mdf | |
com.pervasive.datarush.operators.io.staging |
Provides operators for reading and writing DataRush staging datasets.
|
com.pervasive.datarush.operators.io.textfile |
Provides operators for reading and writing text data.
|
Modifier and Type | Method and Description |
---|---|
FileMetadata |
ORCFormat.readMetadata(FileClient fileClient,
ByteSource source) |
Constructor and Description |
---|
ReadORC(ByteSource source)
Reads the specified data source using default
options.
|
Modifier and Type | Method and Description |
---|---|
FileMetadata |
ParquetFormat.readMetadata(FileClient fileClient,
ByteSource source) |
Constructor and Description |
---|
ReadParquet(ByteSource source)
Reads the specified data source using default options.
|
Modifier and Type | Class and Description |
---|---|
class |
BasicByteSource
A data source identified by a
Path . |
class |
ConcatenatedByteSource
A data source which concatenates multiple sources.
|
class |
GlobbingByteSource
A data source representing the concatenation of
all files matching a pattern.
|
Modifier and Type | Method and Description |
---|---|
ByteSource |
GlobbingByteSource.authorize(FileClient client) |
ByteSource |
ConcatenatedByteSource.authorize(FileClient client) |
ByteSource |
ByteSource.authorize(FileClient client)
Creates a new source with the same properties, but using the
specified authorization.
|
ByteSource |
BasicByteSource.authorize(FileClient client) |
static ByteSource |
ConcatenatedByteSource.getConcatenatedSource(List<Path> paths)
Creates a source which is the concatenation of the specified paths,
in order.
|
static ByteSource |
ConcatenatedByteSource.getConcatenatedSource(List<Path> paths,
UnreadableSourceAction onUnreadable)
Creates a source which is the concatenation of the specified paths,
in order.
|
ByteSource |
ReadSource.getSource()
Gets the data source for the reader.
|
ByteSource |
AbstractReader.getSource()
Gets the source being read.
|
ByteSource |
GlobbingByteSource.validate() |
ByteSource |
ConcatenatedByteSource.validate() |
ByteSource |
ByteSource.validate()
Performs validation of the source configuration.
|
ByteSource |
BasicByteSource.validate() |
Modifier and Type | Method and Description |
---|---|
List<ByteSource> |
ConcatenatedByteSource.getSources()
Gets the sources which comprise the combined source.
|
Modifier and Type | Method and Description |
---|---|
FileMetadata |
DataFormat.readMetadata(FileClient fileClient,
ByteSource source)
Reads the metadata associated with the format.
|
void |
ReadSource.setSource(ByteSource source)
Sets the data source for the reader.
|
void |
AbstractReader.setSource(ByteSource source)
Sets the data source to the specified source.
|
Constructor and Description |
---|
AbstractReader(ByteSource source)
Reads the specified data source using default
options.
|
ReadSource(ByteSource source,
DataFormat format)
Reads the specified source using the given format.
|
Constructor and Description |
---|
ConcatenatedByteSource(List<? extends ByteSource> sources)
Creates a data source representing the concatenation of
the specified sources.
|
Modifier and Type | Method and Description |
---|---|
FileMetadata |
AvroFormat.readMetadata(FileClient fileClient,
ByteSource source) |
Constructor and Description |
---|
ReadAvro(ByteSource source)
Reads the specified data source using default
options.
|
Modifier and Type | Method and Description |
---|---|
FileMetadata |
BinaryFormat.readMetadata(FileClient fileClient,
ByteSource source) |
Modifier and Type | Method and Description |
---|---|
static com.pervasive.datarush.operators.io.mdf.internal.MDF<?> |
MDFUtil.getMDFFileWrapper(MDFUtil.MDFVersion version,
FileClient fileClient,
ByteSource source) |
FileMetadata |
MDFFormat.readMetadata(FileClient fileClient,
ByteSource source) |
Constructor and Description |
---|
ReadMDF(ByteSource source)
Reads the specified data source using default
options.
|
Constructor and Description |
---|
ReadStagingDataset(ByteSource source)
Reads the specified data source using default
options.
|
Modifier and Type | Method and Description |
---|---|
FileMetadata |
LogDataFormat.readMetadata(FileClient fileClient,
ByteSource source) |
FileMetadata |
JSONFormat.readMetadata(FileClient fileClient,
ByteSource source) |
FileMetadata |
FixedTextFormat.readMetadata(FileClient fileClient,
ByteSource source) |
FileMetadata |
DelimitedTextFormat.readMetadata(FileClient fileClient,
ByteSource source) |
FileMetadata |
ARFFDataFormat.readMetadata(FileClient fileClient,
ByteSource source) |
Constructor and Description |
---|
AbstractTextReader(ByteSource source)
Reads the specified data source using default
options.
|
ReadARFF(ByteSource source)
Reads the specified data source using default
options.
|
ReadDelimitedText(ByteSource source)
Reads the specified data source using default
options.
|
ReadFixedText(ByteSource source)
Reads the specified data source using default
options.
|
ReadJSON(ByteSource source)
Reads the specified data source using default options.
|
ReadLog(ByteSource source)
Reads the specified data source using default
options.
|
Copyright © 2020 Actian Corporation. All rights reserved.