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.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 |
---|---|
void |
ORCFormat.writeMetadata(FileMetadata metadata,
FileClient fileClient,
ByteSink target) |
Modifier and Type | Method and Description |
---|---|
void |
ParquetFormat.writeMetadata(FileMetadata metadata,
FileClient fileClient,
ByteSink target) |
Modifier and Type | Class and Description |
---|---|
class |
BasicByteSink
A data source identified by a
Path . |
Modifier and Type | Method and Description |
---|---|
ByteSink |
ByteSink.authorize(FileClient client)
Creates a new sink with the same properties, but using the
specified authorization.
|
ByteSink |
BasicByteSink.authorize(FileClient client) |
ByteSink |
ByteSink.fragmentForPartition(int partitionId)
Creates a new subordinate sink.
|
ByteSink |
BasicByteSink.fragmentForPartition(int fragmentId) |
ByteSink |
WriteSink.getTarget()
Gets the target sink for the reader.
|
ByteSink |
AbstractWriter.getTarget()
Gets the data sink for the writer.
|
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractRecordFormatter.initialize(ByteSink sink,
WriteMode mode)
Prepares the formatter for writing to the provided sink.
|
void |
WriteSink.setTarget(ByteSink target)
Sets the target sink for the reader.
|
void |
AbstractWriter.setTarget(ByteSink sink)
Sets the data sink for the writer.
|
void |
DataFormat.DataFormatter.writeData(ByteSink sink,
WriteMode mode)
Called to write records to the provided
sink in the specified mode.
|
void |
AbstractRecordFormatter.writeData(ByteSink sink,
WriteMode mode)
Simple implementation of a control loop formatting records.
|
void |
DataFormat.writeMetadata(FileMetadata metadata,
FileClient fileClient,
ByteSink target)
Writes the provided metadata associated with the format.
|
Constructor and Description |
---|
AbstractWriter(ByteSink target,
WriteMode mode)
Writes to the specified target sink in the given
mode.
|
WriteSink(ByteSink target,
DataFormat format)
Reads the specified target using the given format.
|
Modifier and Type | Method and Description |
---|---|
void |
AvroFormat.writeMetadata(FileMetadata metadata,
FileClient fileClient,
ByteSink target) |
Constructor and Description |
---|
WriteAvro(ByteSink target,
WriteMode mode)
Writes to the specified target sink in the given
mode.
|
Constructor and Description |
---|
WriteStagingDataset(ByteSink target,
WriteMode mode)
Writes to the specified target sink using default
options.
|
Modifier and Type | Method and Description |
---|---|
void |
LogDataFormat.writeMetadata(FileMetadata metadata,
FileClient fileClient,
ByteSink target) |
void |
FixedTextFormat.writeMetadata(FileMetadata metadata,
FileClient fileClient,
ByteSink target) |
void |
DelimitedTextFormat.writeMetadata(FileMetadata metadata,
FileClient fileClient,
ByteSink target) |
void |
ARFFDataFormat.writeMetadata(FileMetadata metadata,
FileClient fileClient,
ByteSink target) |
Constructor and Description |
---|
AbstractTextWriter(ByteSink target,
WriteMode mode)
Writes text to the specified target sink in the
given mode.
|
WriteARFF(ByteSink target,
WriteMode mode)
Writes ARFF data to the specified target sink in the
given mode.
|
WriteDelimitedText(ByteSink target,
WriteMode mode)
Writes delimited text to the specified target sink in the
given mode.
|
WriteFixedText(ByteSink target,
WriteMode mode)
Writes text to the specified target sink in the
given mode.
|
Copyright © 2016 Actian Corporation. All rights reserved.