KeyT
- ResultT
- public class OrderedEventProcessorResult<KeyT,ResultT,EventT> extends java.lang.Object implements POutput
In case of global sequence processing, the result also contains PCollectionView of the latest contiguous sequence range
Modifier and Type | Method and Description |
---|---|
java.util.Map<TupleTag<?>,PValue> |
expand()
|
void |
finishSpecifyingOutput(java.lang.String transformName,
PInput input,
PTransform<?,?> transform)
As part of applying the producing
PTransform , finalizes this output to make it ready
for being used as an input and for running. |
Pipeline |
getPipeline()
|
PCollectionView<ContiguousSequenceRange> |
latestContiguousRange() |
PCollection<KV<KeyT,ResultT>> |
output() |
PCollection<KV<KeyT,OrderedProcessingStatus>> |
processingStatuses() |
PCollection<KV<KeyT,KV<java.lang.Long,UnprocessedEvent<EventT>>>> |
unprocessedEvents() |
public Pipeline getPipeline()
POutput
getPipeline
in interface POutput
public java.util.Map<TupleTag<?>,PValue> expand()
POutput
POutput
into a list of its component output PValues
.
PValue
expands to itself.
PValues
(such as PCollectionTuple
or PCollectionList
) expands to its component PValue PValues
.
Not intended to be invoked directly by user code.
public void finishSpecifyingOutput(java.lang.String transformName, PInput input, PTransform<?,?> transform)
POutput
PTransform
, finalizes this output to make it ready
for being used as an input and for running.
This includes ensuring that all PCollections
have Coders
specified or defaulted.
Automatically invoked whenever this POutput
is output, after POutput.finishSpecifyingOutput(String, PInput, PTransform)
has been called on each component
PValue
returned by POutput.expand()
.
finishSpecifyingOutput
in interface POutput
public PCollection<KV<KeyT,OrderedProcessingStatus>> processingStatuses()
public PCollection<KV<KeyT,ResultT>> output()
public PCollection<KV<KeyT,KV<java.lang.Long,UnprocessedEvent<EventT>>>> unprocessedEvents()
@Nullable public PCollectionView<ContiguousSequenceRange> latestContiguousRange()