Package | Description |
---|---|
org.apache.flink.api.avro | |
org.apache.flink.api.common.io | |
org.apache.flink.cep.operator | |
org.apache.flink.core.fs | |
org.apache.flink.core.fs.local | |
org.apache.flink.migration.state | |
org.apache.flink.runtime.fs.hdfs | |
org.apache.flink.runtime.fs.maprfs | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.memory | |
org.apache.flink.streaming.api.functions.source | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
Constructor and Description |
---|
FSDataInputStreamWrapper(FSDataInputStream stream,
long len) |
Modifier and Type | Class and Description |
---|---|
class |
InputStreamFSInputWrapper
This class wraps an
InputStream and exposes it as FSDataInputStream . |
Modifier and Type | Field and Description |
---|---|
protected FSDataInputStream |
FileInputFormat.stream
The input stream reading from the input file.
|
Modifier and Type | Method and Description |
---|---|
protected FSDataInputStream |
FileInputFormat.decorateInputStream(FSDataInputStream inputStream,
FileInputSplit fileSplit)
This method allows to wrap/decorate the raw
FSDataInputStream for a certain file split, e.g., for decoding. |
FSDataInputStream |
FileInputFormat.InputSplitOpenThread.waitForCompletion() |
Modifier and Type | Method and Description |
---|---|
protected FSDataInputStream |
FileInputFormat.decorateInputStream(FSDataInputStream inputStream,
FileInputSplit fileSplit)
This method allows to wrap/decorate the raw
FSDataInputStream for a certain file split, e.g., for decoding. |
Constructor and Description |
---|
BlockBasedInput(FSDataInputStream in,
int blockSize) |
BlockBasedInput(FSDataInputStream in,
int startPos,
long length) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractKeyedCEPPatternOperator.restoreState(FSDataInputStream in) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractMultiFSDataInputStream
Abstract base class for wrappers over multiple
FSDataInputStream , which gives a contiguous view on all inner
streams and makes them look like a single stream, in which we can read, seek, etc. |
class |
ClosingFSDataInputStream
This class is a
WrappingProxy for FSDataInputStream that is used to
implement a safety net against unclosed streams. |
class |
FSDataInputStreamWrapper
Simple forwarding wrapper around
FSDataInputStream |
Modifier and Type | Field and Description |
---|---|
protected FSDataInputStream |
AbstractMultiFSDataInputStream.delegate
Inner stream for the currently accessed segment of the virtual global stream
|
protected FSDataInputStream |
FSDataInputStreamWrapper.inputStream |
Modifier and Type | Method and Description |
---|---|
protected abstract FSDataInputStream |
AbstractMultiFSDataInputStream.getSeekedStreamForOffset(long globalStreamOffset)
Delivers a the right stream for the given global stream offset.
|
FSDataInputStream |
FSDataInputStreamWrapper.getWrappedDelegate() |
FSDataInputStream |
SafetyNetWrapperFileSystem.open(Path f) |
abstract FSDataInputStream |
FileSystem.open(Path f)
Opens an FSDataInputStream at the indicated Path.
|
FSDataInputStream |
SafetyNetWrapperFileSystem.open(Path f,
int bufferSize) |
abstract FSDataInputStream |
FileSystem.open(Path f,
int bufferSize)
Opens an FSDataInputStream at the indicated Path.
|
Modifier and Type | Method and Description |
---|---|
static ClosingFSDataInputStream |
ClosingFSDataInputStream.wrapSafe(FSDataInputStream delegate,
SafetyNetCloseableRegistry registry) |
static ClosingFSDataInputStream |
ClosingFSDataInputStream.wrapSafe(FSDataInputStream delegate,
SafetyNetCloseableRegistry registry,
String debugInfo) |
Constructor and Description |
---|
FSDataInputStreamWrapper(FSDataInputStream inputStream) |
Modifier and Type | Class and Description |
---|---|
class |
LocalDataInputStream
The
LocalDataInputStream class is a wrapper class for a data
input stream to the local file system. |
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
LocalFileSystem.open(Path f) |
FSDataInputStream |
LocalFileSystem.open(Path f,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
MigrationStreamStateHandle.openInputStream()
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
HadoopDataInputStream
Concrete implementation of the
FSDataInputStream for the Hadoop's input streams. |
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
MapRFileSystem.open(Path f) |
FSDataInputStream |
MapRFileSystem.open(Path f,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
StreamStateHandle.openInputStream()
Returns an
FSDataInputStream that can be used to read back the data that
was previously written to the stream. |
FSDataInputStream |
RetrievableStreamStateHandle.openInputStream() |
FSDataInputStream |
PlaceholderStreamStateHandle.openInputStream() |
FSDataInputStream |
OperatorStateHandle.openInputStream() |
FSDataInputStream |
MultiStreamStateHandle.openInputStream() |
FSDataInputStream |
KeyGroupsStateHandle.openInputStream() |
Constructor and Description |
---|
BoundedInputStream(FSDataInputStream delegate,
long endOffsetExclusive) |
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
FileStateHandle.openInputStream() |
Modifier and Type | Method and Description |
---|---|
FSDataInputStream |
ByteStreamStateHandle.openInputStream() |
Modifier and Type | Method and Description |
---|---|
void |
ContinuousFileReaderOperator.restoreState(FSDataInputStream in) |
Modifier and Type | Method and Description |
---|---|
void |
CheckpointedRestoringOperator.restoreState(FSDataInputStream in)
Deprecated.
Restores the operator state, if this operator's execution is recovering from a checkpoint.
|
void |
AbstractUdfStreamOperator.restoreState(FSDataInputStream in) |
Modifier and Type | Method and Description |
---|---|
void |
WindowOperator.restoreState(FSDataInputStream in) |
void |
AbstractAlignedProcessingTimeWindowOperator.restoreState(FSDataInputStream in)
Deprecated.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.