This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 76ee66f [FLINK-24041][connectors] First draft of API, uses FLIP-143:
Unified Sink API, Increase robustness for flush, Add license header, Update
JavaDoc comments, added unit and integration tests for the generic sink
implementation. Corrected an inconsistency that led to prepareCommit() not
fully flushing the entire contents of the buffer at checkpoint time, removed
catching of RuntimeExceptions in concrete implementations, added
@PublicEvolving to classes, rearranged cosmetics [...]
add e4b0008 [FLINK-22357][core] Upgrades API stability of unified source
API to @Public (= stable).
add d666d2a [hotfix][core] Improve/fix JavaDocs in SplitEnumeratorContext
class.
add c28dd94 [FLINK-22358][connector base] Add stability annotations to
connector base and iterator sources.
add 713f066 [hotfix][connectors] Deduplicate config default in
FutureCompletingBlockingQueue.
No new revisions were added by this update.
Summary of changes:
.../base/source/reader/RecordEmitter.java | 2 ++
.../base/source/reader/RecordsBySplits.java | 2 ++
.../base/source/reader/RecordsWithSplitIds.java | 3 +++
.../SingleThreadMultiplexSourceReaderBase.java | 2 ++
.../base/source/reader/SourceReaderBase.java | 2 ++
.../base/source/reader/SourceReaderOptions.java | 2 ++
.../base/source/reader/fetcher/AddSplitsTask.java | 2 ++
.../base/source/reader/fetcher/FetchTask.java | 2 ++
.../reader/fetcher/SingleThreadFetcherManager.java | 2 ++
.../base/source/reader/fetcher/SplitFetcher.java | 2 ++
.../source/reader/fetcher/SplitFetcherManager.java | 2 ++
.../source/reader/fetcher/SplitFetcherTask.java | 3 +++
.../source/reader/splitreader/SplitReader.java | 2 ++
.../source/reader/splitreader/SplitsAddition.java | 3 +++
.../source/reader/splitreader/SplitsChange.java | 3 +++
.../FutureCompletingBlockingQueue.java | 8 +++---
.../connector/base/source/utils/SerdeUtils.java | 2 ++
.../flink/api/connector/source/Boundedness.java | 4 +--
.../flink/api/connector/source/ReaderInfo.java | 4 +--
.../flink/api/connector/source/ReaderOutput.java | 4 +--
.../apache/flink/api/connector/source/Source.java | 4 +--
.../flink/api/connector/source/SourceEvent.java | 4 +--
.../flink/api/connector/source/SourceOutput.java | 4 +--
.../flink/api/connector/source/SourceReader.java | 4 +--
.../api/connector/source/SourceReaderContext.java | 4 +--
.../flink/api/connector/source/SourceSplit.java | 4 +--
.../api/connector/source/SplitEnumerator.java | 4 +--
.../connector/source/SplitEnumeratorContext.java | 29 ++++++++++++++--------
.../api/connector/source/SplitsAssignment.java | 4 +--
.../connector/source/lib/NumberSequenceSource.java | 2 ++
.../source/lib/util/IteratorSourceEnumerator.java | 2 ++
.../source/lib/util/IteratorSourceReader.java | 2 ++
.../source/lib/util/IteratorSourceSplit.java | 2 ++
33 files changed, 88 insertions(+), 37 deletions(-)
