Index (ordered 2.74.0 API)

A B C D E F G H I L M N O P S T U V
All Classes All Packages

A

add(long, Instant, boolean) - Method in class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator
addInput(SequenceRangeAccumulator, TimestampedValue<KV<EventKeyT, KV<Long, EventT>>>) - Method in class org.apache.beam.sdk.extensions.ordered.combiner.DefaultSequenceCombiner

B

before_initial_sequence - org.apache.beam.sdk.extensions.ordered.UnprocessedEvent.Reason
buffered - org.apache.beam.sdk.extensions.ordered.UnprocessedEvent.Reason
build() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder
Builder() - Constructor for class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder

C

compareTo(ContiguousSequenceRange) - Method in class org.apache.beam.sdk.extensions.ordered.ContiguousSequenceRange
ContiguousSequenceRange - Class in org.apache.beam.sdk.extensions.ordered: A range of contiguous event sequences and the latest timestamp of the events in the range.
ContiguousSequenceRange() - Constructor for class org.apache.beam.sdk.extensions.ordered.ContiguousSequenceRange
create(EventT, Exception) - Static method in class org.apache.beam.sdk.extensions.ordered.UnprocessedEvent: Create new unprocessed event which failed due to an exception thrown.
create(EventT, UnprocessedEvent.Reason) - Static method in class org.apache.beam.sdk.extensions.ordered.UnprocessedEvent: Create new unprocessed event.
create(Long, long, Long, Long, long, long, long, boolean, ContiguousSequenceRange) - Static method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus
create(OrderedProcessingHandler<EventTypeT, EventKeyTypeT, StateTypeT, ResultTypeT>) - Static method in class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessor: Create the transform.
createAccumulator() - Method in class org.apache.beam.sdk.extensions.ordered.combiner.DefaultSequenceCombiner
createStateOnInitialEvent(EventT) - Method in interface org.apache.beam.sdk.extensions.ordered.EventExaminer: If the event was the first event for a given key, create the state to hold the required data needed for processing.

D

decode(InputStream) - Method in class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator.SequenceRangeAccumulatorCoder
DEFAULT_MAX_ELEMENTS_TO_OUTPUT - Static variable in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler
DefaultSequenceCombiner<EventKeyT,EventT,StateT extends MutableState<EventT,?>> - Class in org.apache.beam.sdk.extensions.ordered.combiner: Default global sequence combiner.
DefaultSequenceCombiner(EventExaminer<EventT, StateT>) - Constructor for class org.apache.beam.sdk.extensions.ordered.combiner.DefaultSequenceCombiner
duplicate - org.apache.beam.sdk.extensions.ordered.UnprocessedEvent.Reason

E

EMPTY - Static variable in class org.apache.beam.sdk.extensions.ordered.ContiguousSequenceRange
encode(SequenceRangeAccumulator, OutputStream) - Method in class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator.SequenceRangeAccumulatorCoder
equals(Object) - Method in class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator
equals(Object) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus
EventExaminer<EventT,StateT extends MutableState<EventT,?>> - Interface in org.apache.beam.sdk.extensions.ordered: Classes extending this interface will be called by OrderedEventProcessor to examine every incoming event.
exception_thrown - org.apache.beam.sdk.extensions.ordered.UnprocessedEvent.Reason
expand() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessorResult
expand(PCollection<KV<EventKeyT, KV<Long, EventT>>>) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessor
extractOutput(SequenceRangeAccumulator) - Method in class org.apache.beam.sdk.extensions.ordered.combiner.DefaultSequenceCombiner

F

finishSpecifyingOutput(String, PInput, PTransform<?, ?>) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessorResult

G

getAccumulatorCoder(CoderRegistry, Coder<TimestampedValue<KV<EventKeyT, KV<Long, EventT>>>>) - Method in class org.apache.beam.sdk.extensions.ordered.combiner.DefaultSequenceCombiner
getContiguousSequenceRangeReevaluationFrequency() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler.OrderedProcessingGlobalSequenceHandler: How frequently the combiner should reevaluate the maximum range? This parameter only affects the behaviour of streaming pipelines.
getDuplicateCount() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus: Returns number of duplicate events which were output in OrderedEventProcessorResult.unprocessedEvents() PCollection.
getEarliestBufferedSequence() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus: Returns earliest buffered sequence.
getEnd() - Method in class org.apache.beam.sdk.extensions.ordered.ContiguousSequenceRange: Returns exclusive end sequence.
getEvent() - Method in class org.apache.beam.sdk.extensions.ordered.UnprocessedEvent
getEventCoder(Pipeline, Coder<KV<KeyT, KV<Long, EventT>>>) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Provide the event coder.
getEventExaminer() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Returns the event examiner instance which will be used by the transform.
getExplanation() - Method in class org.apache.beam.sdk.extensions.ordered.UnprocessedEvent
getGlobalSequenceCombiner() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler.OrderedProcessingGlobalSequenceHandler: Provide the global sequence combiner.
getKeyCoder(Pipeline, Coder<KV<KeyT, KV<Long, EventT>>>) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Provide the key coder.
getLastContiguousSequenceRange() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus
getLastProcessedSequence() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus: Returns last sequence processed.
getLatestBufferedSequence() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus: Returns latest buffered sequence.
getMaxElementCountToTriggerContinuousSequenceRangeReevaluation() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler.OrderedProcessingGlobalSequenceHandler: Number of new elements to trigger the re-evaluation.
getMaxOutputElementsPerBundle() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Returns the maximum number of elements which will be output per each bundle.
getNumberOfBufferedEvents() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus: Returns number of events received out of sequence and buffered.
getNumberOfReceivedEvents() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus: Returns total number of events received for the given key and window.
getPipeline() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessorResult
getReason() - Method in class org.apache.beam.sdk.extensions.ordered.UnprocessedEvent
getResultCoder(Pipeline) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Provide the result coder.
getResultCount() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus: Returns number of output results produced.
getStart() - Method in class org.apache.beam.sdk.extensions.ordered.ContiguousSequenceRange: Returns inclusive starting sequence.
getStateCoder(Pipeline) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Provide the state coder.
getStatusDate() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus: Returns timestamp of when the status was produced.
getStatusUpdateFrequency() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Determines the frequency of emission of the OrderedProcessingStatus elements.
getTimestamp() - Method in class org.apache.beam.sdk.extensions.ordered.ContiguousSequenceRange: Returns latest timestamp of all events in the range.
GLOBAL_SEQUENCE_TRACKER - Static variable in class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessor

H

hashCode() - Method in class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator
hashCode() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus

I

isInitialEvent(long, EventT) - Method in interface org.apache.beam.sdk.extensions.ordered.EventExaminer: Is this event the first expected event for the given key and window if the per key sequence is used? In case of global sequence it determines the first global sequence event.
isLastEvent(long, EventT) - Method in interface org.apache.beam.sdk.extensions.ordered.EventExaminer: Is this event the last expected event for a given key and window?
isLastEventReceived() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus: Returns indicator that the last event for the given key and window has been received.
isProduceStatusUpdateOnEveryEvent() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Indicates if the status update needs to be sent after each event's processing.

L

largestContinuousRange() - Method in class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator
largestRange(Iterable<ContiguousSequenceRange>) - Static method in class org.apache.beam.sdk.extensions.ordered.ContiguousSequenceRange
latestContiguousRange() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessorResult: Returns a view to a calculated side input with the last contiguous range.

M

merge(SequenceRangeAccumulator) - Method in class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator
mergeAccumulators(Iterable<SequenceRangeAccumulator>) - Method in class org.apache.beam.sdk.extensions.ordered.combiner.DefaultSequenceCombiner
MutableState<EventT,ResultT> - Interface in org.apache.beam.sdk.extensions.ordered: Mutable state mutates when events apply to it.
mutate(EventT) - Method in interface org.apache.beam.sdk.extensions.ordered.MutableState: The interface assumes that events will mutate the state without the possibility of throwing an error.

N

numberOfRanges() - Method in class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator

O

of() - Static method in class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator.SequenceRangeAccumulatorCoder
of(long, long, Instant) - Static method in class org.apache.beam.sdk.extensions.ordered.ContiguousSequenceRange
OrderedEventProcessor<EventT,EventKeyT,ResultT,StateT extends MutableState<EventT,ResultT>> - Class in org.apache.beam.sdk.extensions.ordered: Transform for processing ordered events.
OrderedEventProcessor() - Constructor for class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessor
OrderedEventProcessorResult<KeyT,ResultT,EventT> - Class in org.apache.beam.sdk.extensions.ordered: The result of the ordered processing.
OrderedProcessingGlobalSequenceHandler(Class<EventT>, Class<KeyT>, Class<StateT>, Class<ResultT>) - Constructor for class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler.OrderedProcessingGlobalSequenceHandler
OrderedProcessingHandler<EventT,KeyT,StateT extends MutableState<EventT,?>,ResultT> - Class in org.apache.beam.sdk.extensions.ordered: Parent class for Ordered Processing configuration handlers.
OrderedProcessingHandler(Class<EventT>, Class<KeyT>, Class<StateT>, Class<ResultT>) - Constructor for class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Provide concrete classes which will be used by the ordered processing transform.
OrderedProcessingHandler.OrderedProcessingGlobalSequenceHandler<EventT,KeyT,StateT extends MutableState<EventT,?>,ResultT> - Class in org.apache.beam.sdk.extensions.ordered: Parent class for Ordered Processing configuration handlers to handle processing of the events where global sequence is used.
OrderedProcessingStatus - Class in org.apache.beam.sdk.extensions.ordered: Indicates the status of ordered processing for a particular key.
OrderedProcessingStatus() - Constructor for class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus
OrderedProcessingStatus.Builder - Class in org.apache.beam.sdk.extensions.ordered
org.apache.beam.sdk.extensions.ordered - package org.apache.beam.sdk.extensions.ordered: Provides a transform for ordered processing.
org.apache.beam.sdk.extensions.ordered.combiner - package org.apache.beam.sdk.extensions.ordered.combiner: Default implementation of the global sequence combiner used by OrderedEventProcessor when processing events using global sequences.
output() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessorResult: Returns processed states keyed by the original key.

P

processingStatuses() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessorResult: Returns processing status for a particular key.
produceResult() - Method in interface org.apache.beam.sdk.extensions.ordered.MutableState: This method is called after each state mutation.

S

sequence_id_outside_valid_range - org.apache.beam.sdk.extensions.ordered.UnprocessedEvent.Reason
SequenceRangeAccumulator - Class in org.apache.beam.sdk.extensions.ordered.combiner: Default accumulator used to combine sequence ranges.
SequenceRangeAccumulator() - Constructor for class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator
SequenceRangeAccumulator.SequenceRangeAccumulatorCoder - Class in org.apache.beam.sdk.extensions.ordered.combiner
setDuplicateCount(long) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder
setEarliestBufferedSequence(Long) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder
setLastContiguousSequenceRange(ContiguousSequenceRange) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder
setLastEventReceived(boolean) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder
setLastProcessedSequence(Long) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder
setLatestBufferedSequence(Long) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder
setMaxOutputElementsPerBundle(int) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Overrides the default value.
setNumberOfBufferedEvents(long) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder
setNumberOfReceivedEvents(long) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder
setProduceStatusUpdateOnEveryEvent(boolean) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Sets the indicator of whether the status notification needs to be produced on every event.
setResultCount(long) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder
setStatusDate(Instant) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingStatus.Builder
setStatusUpdateFrequency(Duration) - Method in class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler: Changes the default status update frequency.

T

toString() - Method in class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator

U

UnprocessedEvent<EventT> - Class in org.apache.beam.sdk.extensions.ordered: Combines the source event which failed to process with the failure reason.
UnprocessedEvent() - Constructor for class org.apache.beam.sdk.extensions.ordered.UnprocessedEvent
UnprocessedEvent.Reason - Enum in org.apache.beam.sdk.extensions.ordered
unprocessedEvents() - Method in class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessorResult: Returns events which failed to process, including the reasons for failure.

V

valueOf(String) - Static method in enum org.apache.beam.sdk.extensions.ordered.UnprocessedEvent.Reason: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.beam.sdk.extensions.ordered.UnprocessedEvent.Reason: Returns an array containing the constants of this enum type, in the order they are declared.

A B C D E F G H I L M N O P S T U V
All Classes All Packages