Class and Description |
---|
RecordEmitter
Emit a record to the downstream.
|
RecordsBySplits
An implementation of RecordsWithSplitIds to host all the records by splits.
|
RecordsWithSplitIds
An interface for the elements passed from the fetchers to the source reader.
|
SourceReaderBase
An abstract implementation of
SourceReader which provides some synchronization between
the mail box main thread and the SourceReader internal threads. |
SourceReaderOptions
The options that can be set for the
SourceReaderBase . |
Class and Description |
---|
RecordsWithSplitIds
An interface for the elements passed from the fetchers to the source reader.
|
Class and Description |
---|
RecordsWithSplitIds
An interface for the elements passed from the fetchers to the source reader.
|
Class and Description |
---|
RecordsWithSplitIds
An interface for the elements passed from the fetchers to the source reader.
|
SingleThreadMultiplexSourceReaderBase
A base for
SourceReader s that read splits with one thread using one SplitReader . |
SourceReaderBase
An abstract implementation of
SourceReader which provides some synchronization between
the mail box main thread and the SourceReader internal threads. |
Class and Description |
---|
RecordEmitter
Emit a record to the downstream.
|
RecordsWithSplitIds
An interface for the elements passed from the fetchers to the source reader.
|
SingleThreadMultiplexSourceReaderBase
A base for
SourceReader s that read splits with one thread using one SplitReader . |
SourceReaderBase
An abstract implementation of
SourceReader which provides some synchronization between
the mail box main thread and the SourceReader internal threads. |
Class and Description |
---|
RecordsWithSplitIds
An interface for the elements passed from the fetchers to the source reader.
|
Class and Description |
---|
RecordEmitter
Emit a record to the downstream.
|
Class and Description |
---|
RecordsWithSplitIds
An interface for the elements passed from the fetchers to the source reader.
|
Class and Description |
---|
RecordsBySplits.Builder
A utility builder to collect records in individual calls, rather than put a finished
collection in the
RecordsBySplits(Map, Set) constructor. |
Class and Description |
---|
RecordsWithSplitIds
An interface for the elements passed from the fetchers to the source reader.
|
SourceReaderBase
An abstract implementation of
SourceReader which provides some synchronization between
the mail box main thread and the SourceReader internal threads. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.