KeyT - ResultT - public class OrderedEventProcessorResult<KeyT,ResultT,EventT> extends java.lang.Object implements POutput
| 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()
|
PCollection<KV<KeyT,ResultT>> |
output() |
PCollection<KV<KeyT,OrderedProcessingStatus>> |
processingStatuses() |
PCollection<KV<KeyT,KV<java.lang.Long,UnprocessedEvent<EventT>>>> |
unprocessedEvents() |
public Pipeline getPipeline()
POutputgetPipeline in interface POutputpublic java.util.Map<TupleTag<?>,PValue> expand()
POutputPOutput 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)
POutputPTransform, 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 POutputpublic PCollection<KV<KeyT,OrderedProcessingStatus>> processingStatuses()
public PCollection<KV<KeyT,ResultT>> output()
public PCollection<KV<KeyT,KV<java.lang.Long,UnprocessedEvent<EventT>>>> unprocessedEvents()