| Interface | Description |
|---|---|
| ParallelSourceFunction<OUT> | Deprecated
This interface is based on the
SourceFunction API, which is due to be
removed. |
| SourceFunction<T> | Deprecated
This interface will be removed in future versions.
|
| SourceFunction.SourceContext<T> |
Interface that source functions use to emit elements, and possibly watermarks.
|
| TimestampedInputSplit |
An extended
InputSplit that also includes information about:
The modification time of the file this split belongs to. |
| Class | Description |
|---|---|
| ContinuousFileMonitoringFunction<OUT> | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| ContinuousFileReaderOperator<OUT,T extends TimestampedInputSplit> |
The operator that reads the
splits received from the preceding
ContinuousFileMonitoringFunction. |
| ContinuousFileReaderOperatorFactory<OUT,T extends TimestampedInputSplit> |
ContinuousFileReaderOperator factory. |
| FileMonitoringFunction | Deprecated
Internal class deprecated in favour of
ContinuousFileMonitoringFunction. |
| FileReadFunction | Deprecated
Internal class deprecated in favour of
ContinuousFileMonitoringFunction. |
| FromElementsFunction<T> | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| FromIteratorFunction<T> | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| FromSplittableIteratorFunction<T> | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| InputFormatSourceFunction<OUT> | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| MessageAcknowledgingSourceBase<Type,UId> | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| MultipleIdsMessageAcknowledgingSourceBase<Type,UId,SessionId> | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| RichParallelSourceFunction<OUT> | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| RichSourceFunction<OUT> | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| SocketTextStreamFunction | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| StatefulSequenceSource | Deprecated
This class is based on the
SourceFunction API, which is due to be
removed. |
| TimestampedFileInputSplit |
A
FileInputSplit with TimestampedInputSplit. |
| Enum | Description |
|---|---|
| FileMonitoringFunction.WatchType |
The watch type of the
FileMonitoringFunction. |
| FileProcessingMode |
The mode in which the
ContinuousFileMonitoringFunction operates. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.