Package | Description |
---|---|
com.pervasive.datarush.azure | |
com.pervasive.datarush.io |
Provides classes and interfaces performing file-like I/O operations.
|
com.pervasive.datarush.io.compression |
Provides classes and interfaces for supporting data compression.
|
Modifier and Type | Method and Description |
---|---|
abstract SplitInputStream |
AbstractAzureClient.newInputStream(AzureFilePath path,
long start,
long length,
int buffer) |
SplitInputStream |
AzureFileSplit.openSplit(int buffer) |
Modifier and Type | Class and Description |
---|---|
class |
SplitInputStreamImpl
A wrapper for input streams providing windowing behavior.
|
Modifier and Type | Method and Description |
---|---|
SplitInputStream |
SplittableCompressedFileSplit.openSplit(int buffer) |
SplitInputStream |
FileSplit.openSplit(int buffer) |
SplitInputStream |
DataSplit.openSplit(int buffer)
Opens the split for reading using the specified
size for the read buffer.
|
Constructor and Description |
---|
SplitReader(SplitInputStream in,
CharsetEncoding charset)
Creates a new reader on the specified stream, using the given
encoding properties.
|
SplitReader(SplitInputStream in,
CharsetEncoding charset,
int buffer)
Creates a new reader on the specified stream, using the given
encoding properties.
|
SplitReader(SplitInputStream in,
CharsetEncoding charset,
int buffer,
String syncMarker,
boolean doInitialSync)
Creates a new reader on the specified stream, using the given
encoding properties and synchronization marker.
|
SplitReader(SplitInputStream in,
CharsetEncoding charset,
String syncMarker,
boolean doInitialSync)
Creates a new reader on the specified stream, using the given
encoding properties and synchronization marker.
|
Modifier and Type | Method and Description |
---|---|
SplitInputStream |
UncompressedData.decompressSplitStream(DataSplit split,
InputStream in,
int bufferSize) |
SplitInputStream |
SnappyCompression.decompressSplitStream(DataSplit split,
InputStream in,
int bufferSize) |
SplitInputStream |
GZipCompression.decompressSplitStream(DataSplit split,
InputStream in,
int bufferSize) |
SplitInputStream |
CompressionFormat.decompressSplitStream(DataSplit split,
InputStream in,
int bufferSize)
Wraps the specified stream for a split in a decompressor
for the format.
|
SplitInputStream |
BZipCompression.decompressSplitStream(DataSplit split,
InputStream in,
int bufferSize) |
Copyright © 2021 Actian Corporation. All rights reserved.