Modifier and Type | Method and Description |
---|---|
void |
PulsarRecordEmitter.emitRecord(PulsarMessage<T> element,
SourceOutput<T> output,
PulsarPartitionSplitState splitState) |
Modifier and Type | Method and Description |
---|---|
protected void |
PulsarOrderedSourceReader.onSplitFinished(Map<String,PulsarPartitionSplitState> finishedSplitIds) |
protected void |
PulsarUnorderedSourceReader.onSplitFinished(Map<String,PulsarPartitionSplitState> finishedSplitIds) |
Modifier and Type | Method and Description |
---|---|
Optional<PulsarPartitionSplitState> |
PulsarUnorderedPartitionSplitReader.snapshotState() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.