http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/61ba656f/content/documentation/sdks/javadoc/0.1.0-incubating/index-all.html ---------------------------------------------------------------------- diff --git a/content/documentation/sdks/javadoc/0.1.0-incubating/index-all.html b/content/documentation/sdks/javadoc/0.1.0-incubating/index-all.html new file mode 100644 index 0000000..39efbac --- /dev/null +++ b/content/documentation/sdks/javadoc/0.1.0-incubating/index-all.html @@ -0,0 +1,18004 @@ + + + + + + +Index (Apache Beam SDK for Java 0.1.0-incubating API) + + + + + + + + +
+ + +
Skip navigation links
+ + + + +
+ + +
A B C D E F G H I J K L M N O P R S T U V W X Y Z  + + +

A

+
+
access(StateTag<? super K, StateT>) - Method in interface org.apache.beam.sdk.util.state.StateAccessor
+
+
Access the storage for the given address in the current window.
+
+
accessInEachMergingWindow(StateTag<? super K, StateT>) - Method in interface org.apache.beam.sdk.util.state.MergingStateAccessor
+
+
Analogous to StateAccessor.access(org.apache.beam.sdk.util.state.StateTag<? super K, StateT>), but returned as a map from each window which is + about to be merged to the corresponding state.
+
+
AccumulatingCombineFn() - Constructor for class org.apache.beam.sdk.transforms.Combine.AccumulatingCombineFn
+
 
+
accumulatingFiredPanes() - Static method in class org.apache.beam.sdk.transforms.windowing.Window
+
+
Returns a new Window PTransform that uses the registered WindowFn and + Triggering behavior, and that accumulates elements in a pane after they are triggered.
+
+
accumulatingFiredPanes() - Method in class org.apache.beam.sdk.transforms.windowing.Window.Bound
+
+
Returns a new Window PTransform that uses the registered WindowFn and + Triggering behavior, and that accumulates elements in a pane after they are triggered.
+
+
accumulatingFiredPanes() - Method in class org.apache.beam.sdk.transforms.windowing.Window.Unbound
+
+
Returns a new Window PTransform that uses the registered WindowFn and + Triggering behavior, and that accumulates elements in a pane after they are triggered.
+
+
AccumulatorCombiningState<InputT,AccumT,OutputT> - Interface in org.apache.beam.sdk.util.state
+
+
State for a single value that is managed by a Combine.CombineFn.
+
+
ackDeadlineSeconds(PubsubClient.SubscriptionPath) - Method in class org.apache.beam.sdk.util.PubsubClient
+
+
Return the ack deadline, in seconds, for subscription.
+
+
ackDeadlineSeconds(PubsubClient.SubscriptionPath) - Method in class org.apache.beam.sdk.util.PubsubGrpcClient
+
 
+
ackDeadlineSeconds(PubsubClient.SubscriptionPath) - Method in class org.apache.beam.sdk.util.PubsubJsonClient
+
 
+
ackDeadlineSeconds(PubsubClient.SubscriptionPath) - Method in class org.apache.beam.sdk.util.PubsubTestClient
+
 
+
ackId - Variable in class org.apache.beam.sdk.util.PubsubClient.IncomingMessage
+
+
Id to pass back to Pubsub to acknowledge receipt of this message.
+
+
acknowledge(PubsubClient.SubscriptionPath, List<String>) - Method in class org.apache.beam.sdk.util.PubsubClient
+
+
Acknowldege messages from subscription with ackIds.
+
+
acknowledge(PubsubClient.SubscriptionPath, List<String>) - Method in class org.apache.beam.sdk.util.PubsubGrpcClient
+
 
+
acknowledge(PubsubClient.SubscriptionPath, List<String>) - Method in class org.apache.beam.sdk.util.PubsubJsonClient
+
 
+
acknowledge(PubsubClient.SubscriptionPath, List<String>) - Method in class org.apache.beam.sdk.util.PubsubTestClient
+
 
+
ActiveWindowSet<W extends BoundedWindow> - Interface in org.apache.beam.sdk.util
+
+
Track which windows are active, and the state address window(s) under which their + state is stored.
+
+
ActiveWindowSet.MergeCallback<W extends BoundedWindow> - Interface in org.apache.beam.sdk.util
+
+ +
+
add(Iterable<WindowedValue<ElemT>>) - Method in interface org.apache.beam.runners.direct.InProcessPipelineRunner.PCollectionViewWriter
+
 
+
add(WindowedValue<T>) - Method in interface org.apache.beam.runners.direct.InProcessPipelineRunner.UncommittedBundle
+
+
Outputs an element to this bundle.
+
+
add(Long) - Method in class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique
+
+
Adds a value to the heap, returning whether the value is (large enough + to be) in the heap.
+
+
add(DisplayData.Item<?>) - Method in interface org.apache.beam.sdk.transforms.display.DisplayData.Builder
+
+
Register the given display item.
+
+
add(long, long) - Method in class org.apache.beam.sdk.util.BucketingFunction
+
+
Add one sample of value (to bucket) at timeMsSinceEpoch.
+
+
add(Counter<?>) - Method in class org.apache.beam.sdk.util.common.CounterSet
+
 
+
add(long, long) - Method in class org.apache.beam.sdk.util.MovingFunction
+
+
Add value at nowMsSinceEpoch.
+
+
add(InputT) - Method in interface org.apache.beam.sdk.util.state.CombiningState
+
+
Add a value to the buffer.
+
+
addAccum(AccumT) - Method in interface org.apache.beam.sdk.util.state.AccumulatorCombiningState
+
+
Add an accumulator to this combining value.
+
+
addAccumulator(NamedAggregators, NamedAggregators) - Method in class org.apache.beam.runners.spark.aggregators.AggAccumParam
+
 
+
addActiveForTesting(W) - Method in interface org.apache.beam.sdk.util.ActiveWindowSet
+
+
If window is not already known to be ACTIVE then add it as ACTIVE.
+
+
addActiveForTesting(W) - Method in class org.apache.beam.sdk.util.MergingActiveWindowSet
+
 
+
addActiveForTesting(W, Iterable<W>) - Method in class org.apache.beam.sdk.util.MergingActiveWindowSet
+
 
+
addActiveForTesting(W) - Method in class org.apache.beam.sdk.util.NonMergingActiveWindowSet
+
 
+
addBoolean(Map<String, Object>, String, boolean) - Static method in class org.apache.beam.sdk.util.Structs
+
 
+
addChannel(WritableByteChannel) - Method in class org.apache.beam.sdk.util.ShardingWritableByteChannel
+
+
Adds another shard output channel.
+
+
addCollectionToSingletonOutput(String, PValue, PValue) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Adds an output with the given name to the previously added + CollectionToSingleton Dataflow step, consuming the specified + input PValue and producing the specified output + PValue.
+
+
addComposite(TransformTreeNode) - Method in class org.apache.beam.sdk.runners.TransformTreeNode
+
+
Adds a composite operation to the transform node.
+
+
addCounter(Counter<?>) - Method in class org.apache.beam.sdk.util.common.CounterSet
+
+
Adds a counter.
+
+
addCounter(Counter<T>) - Method in class org.apache.beam.sdk.util.common.CounterSet.AddCounterMutator
+
+
Adds the given Counter into the enclosing CounterSet.
+
+
AddCounterMutator() - Constructor for class org.apache.beam.sdk.util.common.CounterSet.AddCounterMutator
+
 
+
addDictionary(Map<String, Object>, String, Map<String, Object>) - Static method in class org.apache.beam.sdk.util.Structs
+
 
+
addDouble(Map<String, Object>, String, Double) - Static method in class org.apache.beam.sdk.util.Structs
+
 
+
addEncodingInput(Coder<?>) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Sets the encoding for the current Dataflow step.
+
+
addIfNotDefault(DisplayData.Item<T>, T) - Method in interface org.apache.beam.sdk.transforms.display.DisplayData.Builder
+
+
Register the given display item if the value is different than the specified default.
+
+
addIfNotNull(DisplayData.Item<?>) - Method in interface org.apache.beam.sdk.transforms.display.DisplayData.Builder
+
+
Register the given display item if the value is not null.
+
+
addInPlace(NamedAggregators, NamedAggregators) - Method in class org.apache.beam.runners.spark.aggregators.AggAccumParam
+
 
+
addInput(String, Boolean) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Adds an input with the given name and value to the current + Dataflow step.
+
+
addInput(String, String) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Adds an input with the given name and value to the current + Dataflow step.
+
+
addInput(String, Long) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Adds an input with the given name and value to the current + Dataflow step.
+
+
addInput(String, PInput) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Adds an input with the given name to the previously added Dataflow + step, coming from the specified input PValue.
+
+
addInput(String, Map<String, Object>) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Adds an input that is a dictionary of strings to objects.
+
+
addInput(String, List<? extends Map<String, Object>>) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Adds an input that is a list of objects.
+
+
addInput(TransformTreeNode, PInput) - Method in class org.apache.beam.sdk.runners.TransformHierarchy
+
+
Adds an input to the given node.
+
+
addInput(ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique, T) - Method in class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn
+
 
+
addInput(InputT) - Method in interface org.apache.beam.sdk.transforms.Combine.AccumulatingCombineFn.Accumulator
+
+
Adds the given input value to this accumulator, modifying + this accumulator.
+
+
addInput(AccumT, InputT) - Method in class org.apache.beam.sdk.transforms.Combine.AccumulatingCombineFn
+
 
+
addInput(double[], Double) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineDoubleFn
+
 
+
addInput(Combine.Holder<V>, V) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineFn
+
 
+
addInput(int[], Integer) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineIntegerFn
+
 
+
addInput(long[], Long) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineLongFn
+
 
+
addInput(AccumT, InputT) - Method in class org.apache.beam.sdk.transforms.Combine.CombineFn
+
+
Adds the given input value to the given accumulator, returning the + new accumulator value.
+
+
addInput(List<V>, V) - Method in class org.apache.beam.sdk.transforms.Combine.IterableCombineFn
+
 
+
addInput(K, AccumT, InputT) - Method in class org.apache.beam.sdk.transforms.Combine.KeyedCombineFn
+
+
Adds the given input value to the given accumulator, returning the new accumulator value.
+
+
addInput(Object[], DataT) - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFn
+
 
+
addInput(Object[], DataT, CombineWithContext.Context) - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFnWithContext
+
 
+
addInput(K, Object[], DataT) - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedKeyedCombineFn
+
 
+
addInput(K, Object[], DataT, CombineWithContext.Context) - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedKeyedCombineFnWithContext
+
 
+
addInput(AccumT, InputT, CombineWithContext.Context) - Method in class org.apache.beam.sdk.transforms.CombineWithContext.CombineFnWithContext
+
+
Adds the given input value to the given accumulator, returning the + new accumulator value.
+
+
addInput(K, AccumT, InputT, CombineWithContext.Context) - Method in class org.apache.beam.sdk.transforms.CombineWithContext.KeyedCombineFnWithContext
+
+
Adds the given input value to the given accumulator, returning the new accumulator value.
+
+
addInput(Top.BoundedHeap<KV<Integer, T>, SerializableComparator<KV<Integer, T>>>, T) - Method in class org.apache.beam.sdk.transforms.Sample.FixedSizedSampleFn
+
 
+
addInput(K, AccumT, InputT, DoFn<?, ?>.ProcessContext) - Method in interface org.apache.beam.sdk.util.PerKeyCombineFnRunner
+
+
Forwards the call to a CombineFnBase.PerKeyCombineFn to add the input in a DoFn.
+
+
addInput(K, AccumT, InputT, PipelineOptions, SideInputReader, Collection<? extends BoundedWindow>) - Method in interface org.apache.beam.sdk.util.PerKeyCombineFnRunner
+
+
Forwards the call to a CombineFnBase.PerKeyCombineFn to add the input.
+
+
addInputProducer(PValue, TransformTreeNode) - Method in class org.apache.beam.sdk.runners.TransformTreeNode
+
+
Adds an input to the transform node.
+
+
addInputs(K, Iterable<InputT>, DoFn<?, ?>.ProcessContext) - Method in interface org.apache.beam.sdk.util.PerKeyCombineFnRunner
+
+
Forwards the call to a CombineFnBase.PerKeyCombineFn to add all inputs in a DoFn.
+
+
addInputsRandomly(PerKeyCombineFnRunner<? super K, ? super InputT, AccumT, ?>, K, Iterable<InputT>, Random, DoFn<?, ?>.ProcessContext) - Static method in class org.apache.beam.sdk.runners.DirectPipelineRunner.TestCombineDoFn
+
+
Create a random list of accumulators from the given list of values.
+
+
addList(Map<String, Object>, String, List<? extends Map<String, Object>>) - Static method in class org.apache.beam.sdk.util.Structs
+
 
+
addList(Map<String, Object>, String, T[]) - Static method in class org.apache.beam.sdk.util.Structs
+
 
+
addLong(Map<String, Object>, String, long) - Static method in class org.apache.beam.sdk.util.Structs
+
 
+
addLongs(Map<String, Object>, String, long...) - Static method in class org.apache.beam.sdk.util.Structs
+
 
+
addNewCounter(Counter<?>) - Method in class org.apache.beam.sdk.util.common.CounterSet
+
+
Adds a new counter, throwing an exception if a counter of the + same name already exists.
+
+
addNull(Map<String, Object>, String) - Static method in class org.apache.beam.sdk.util.Structs
+
 
+
addObject(Map<String, Object>, String, Map<String, Object>) - Static method in class org.apache.beam.sdk.util.Structs
+
 
+
addObserver(Observer) - Method in class org.apache.beam.sdk.util.common.ElementByteSizeObservableIterable
+
+
Sets the observer, which will observe the iterator returned in + the next call to iterator() method.
+
+
addOrReuseCounter(Counter<T>) - Method in class org.apache.beam.sdk.util.common.CounterSet
+
+
Adds the given Counter to this CounterSet.
+
+
addOutput(String, PValue) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Adds an output with the given name to the previously added + Dataflow step, producing the specified output PValue, + including its Coder if a TypedPValue.
+
+
addOutput(InProcessPipelineRunner.UncommittedBundle<?>, InProcessPipelineRunner.UncommittedBundle<?>...) - Method in class org.apache.beam.runners.direct.StepTransformResult.Builder
+
 
+
addOutput(Collection<InProcessPipelineRunner.UncommittedBundle<?>>) - Method in class org.apache.beam.runners.direct.StepTransformResult.Builder
+
 
+
addOverrideForClass(Class<?>, DataflowWorkerLoggingOptions.Level) - Method in class org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.WorkerLogLevelOverrides
+
+
Overrides the default log level for the passed in class.
+
+
addOverrideForName(String, DataflowWorkerLoggingOptions.Level) - Method in class org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.WorkerLogLevelOverrides
+
+
Overrides the default log level for the passed in name.
+
+
addOverrideForPackage(Package, DataflowWorkerLoggingOptions.Level) - Method in class org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.WorkerLogLevelOverrides
+
+
Overrides the default log level for the passed in package.
+
+
addStep(PTransform<?, ?>, String) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Adds a step to the Dataflow workflow for the given transform, with + the given Dataflow step type.
+
+
addStep(PTransform<?, ? extends PValue>, Step) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Adds a pre-defined step to the Dataflow workflow.
+
+
addString(Map<String, Object>, String, String) - Static method in class org.apache.beam.sdk.util.Structs
+
 
+
addStringList(Map<String, Object>, String, List<String>) - Static method in class org.apache.beam.sdk.util.Structs
+
 
+
addTraceFor(AbstractGoogleClient, String) - Method in class org.apache.beam.sdk.options.GoogleApiDebugOptions.GoogleApiTracer
+
+
Creates a GoogleApiDebugOptions.GoogleApiTracer that sets the trace destination on all + calls that match the given client type.
+
+
addTraceFor(AbstractGoogleClientRequest<?>, String) - Method in class org.apache.beam.sdk.options.GoogleApiDebugOptions.GoogleApiTracer
+
+
Creates a GoogleApiDebugOptions.GoogleApiTracer that sets the trace traceDestination on all + calls that match for the given request type.
+
+
addUnprocessedElements(Iterable<? extends WindowedValue<?>>) - Method in class org.apache.beam.runners.direct.StepTransformResult.Builder
+
 
+
addValue(InputT) - Method in interface org.apache.beam.sdk.transforms.Aggregator
+
+
Adds a new value into the Aggregator.
+
+
addValue(T) - Method in class org.apache.beam.sdk.util.common.Counter
+
+
Adds a new value to the aggregation stream.
+
+
addValue(InputT) - Method in class org.apache.beam.sdk.util.CounterAggregator
+
 
+
addValueInternal(PValue) - Method in class org.apache.beam.sdk.Pipeline
+
+
Adds the given PValue to this Pipeline.
+
+
addValueOnlyOutput(String, PValue) - Method in interface org.apache.beam.runners.dataflow.DataflowPipelineTranslator.TranslationContext
+
+
Adds an output with the given name to the previously added + Dataflow step, producing the specified output PValue, + including its Coder if a TypedPValue.
+
+
advance() - Method in class org.apache.beam.sdk.io.DatastoreIO.DatastoreReader
+
 
+
advance() - Method in class org.apache.beam.sdk.io.OffsetBasedSource.OffsetBasedReader
+
 
+
advance() - Method in class org.apache.beam.sdk.io.Source.Reader
+
+
Advances the reader to the next valid record.
+
+
advance() - Method in class org.apache.beam.sdk.io.UnboundedSource.UnboundedReader
+
+
Advances the reader to the next valid record.
+
+
advance() - Method in interface org.apache.beam.sdk.util.BigQueryServices.BigQueryJsonReader
+
+
Advances the reader to the next valid record.
+
+
advance() - Method in class org.apache.beam.sdk.util.BigQueryTableRowIterator
+
 
+
advance() - Method in class org.apache.beam.sdk.util.common.ElementByteSizeObserver
+
+
Advances the observer to the next element.
+
+
advance() - Method in class org.apache.beam.sdk.util.PubsubTestClient
+
+
For subscription mode only: + Track progression of time according to the Clock passed .
+
+
advanceImpl() - Method in class org.apache.beam.sdk.io.FileBasedSource.FileBasedReader
+
 
+
advanceImpl() - Method in class org.apache.beam.sdk.io.OffsetBasedSource.OffsetBasedReader
+
+
Advances to the next record and returns true, or returns false if there is no next + record.
+
+
advanceInputWatermark(ReduceFnRunner<?, ?, ?, ?>, Instant) - Method in class org.apache.beam.sdk.util.BatchTimerInternals
+
 
+
advanceProcessingTime(ReduceFnRunner<?, ?, ?, ?>, Instant) - Method in class org.apache.beam.sdk.util.BatchTimerInternals
+
 
+
AfterAll - Class in org.apache.beam.sdk.transforms.windowing
+
+
Create a Trigger that fires and finishes once after all of its sub-triggers have fired.
+
+
AfterDelayFromFirstElement - Class in org.apache.beam.sdk.transforms.windowing
+
+
A base class for triggers that happen after a processing time delay from the arrival + of the first element in a pane.
+
+
AfterDelayFromFirstElement(TimeDomain, List<SerializableFunction<Instant, Instant>>) - Constructor for class org.apache.beam.sdk.transforms.windowing.AfterDelayFromFirstElement
+
 
+
AfterEach - Class in org.apache.beam.sdk.transforms.windowing
+
+
A composite Trigger that executes its sub-triggers in order.
+
+
afterElement(WindowedValue<T>) - Method in interface org.apache.beam.runners.direct.ModelEnforcement
+
+
Called after a call to TransformEvaluator.processElement(WindowedValue) on the + provided WindowedValue.
+
+
afterFinish(InProcessPipelineRunner.CommittedBundle<T>, InProcessTransformResult, Iterable<? extends InProcessPipelineRunner.CommittedBundle<?>>) - Method in interface org.apache.beam.runners.direct.ModelEnforcement
+
+
Called after a bundle has been completed and TransformEvaluator.finishBundle() has been + called, producing the provided InProcessTransformResult and + output bundles.
+
+
AfterFirst - Class in org.apache.beam.sdk.transforms.windowing
+
+
Create a composite Trigger that fires once after at least one of its sub-triggers have + fired.
+
+
AfterPane - Class in org.apache.beam.sdk.transforms.windowing
+
+
Triggers that fire based on properties of the elements in the current pane.
+
+
AfterProcessingTime - Class in org.apache.beam.sdk.transforms.windowing
+
+
AfterProcessingTime triggers fire based on the current processing time.
+
+
AfterWatermark - Class in org.apache.beam.sdk.transforms.windowing
+
+
AfterWatermark triggers fire based on progress of the system watermark.
+
+
AfterWatermark.AfterWatermarkEarly - Interface in org.apache.beam.sdk.transforms.windowing
+
+
Interface for building an AfterWatermarkTrigger with early firings already filled in.
+
+
AfterWatermark.AfterWatermarkLate - Interface in org.apache.beam.sdk.transforms.windowing
+
+
Interface for building an AfterWatermarkTrigger with late firings already filled in.
+
+
AfterWatermark.FromEndOfWindow - Class in org.apache.beam.sdk.transforms.windowing
+
+
A watermark trigger targeted relative to the end of the window.
+
+
AggAccumParam - Class in org.apache.beam.runners.spark.aggregators
+
+
Aggregator accumulator param.
+
+
AggAccumParam() - Constructor for class org.apache.beam.runners.spark.aggregators.AggAccumParam
+
 
+
Aggregator<InputT,OutputT> - Interface in org.apache.beam.sdk.transforms
+
+
An Aggregator<InputT> enables monitoring of values of type InputT, + to be combined across all bundles.
+
+
AggregatorPipelineExtractor - Class in org.apache.beam.sdk.runners
+
+
Retrieves Aggregators at each ParDo and returns a Map of + Aggregator to the PTransforms in which it is present.
+
+
AggregatorPipelineExtractor(Pipeline) - Constructor for class org.apache.beam.sdk.runners.AggregatorPipelineExtractor
+
+
Creates an AggregatorPipelineExtractor for the given Pipeline.
+
+
AggregatorRetrievalException - Exception in org.apache.beam.sdk.runners
+
+
Signals that an exception has occurred while retrieving Aggregators.
+
+
AggregatorRetrievalException(String, Throwable) - Constructor for exception org.apache.beam.sdk.runners.AggregatorRetrievalException
+
+
Constructs a new AggregatorRetrievalException with the specified detail message and + cause.
+
+
AggregatorRetriever - Class in org.apache.beam.sdk.transforms
+
+
An internal class for extracting Aggregators from DoFns.
+
+
AggregatorValues<T> - Class in org.apache.beam.sdk.runners
+
+
A collection of values associated with an Aggregator.
+
+
AggregatorValues() - Constructor for class org.apache.beam.sdk.runners.AggregatorValues
+
 
+
alignedTo(Duration, Instant) - Method in class org.apache.beam.sdk.transforms.windowing.AfterDelayFromFirstElement
+
+
Aligns timestamps to the smallest multiple of size since the offset greater + than the timestamp.
+
+
alignedTo(Duration) - Method in class org.apache.beam.sdk.transforms.windowing.AfterDelayFromFirstElement
+
+
Aligns the time to be the smallest multiple of size greater than the timestamp + since the epoch.
+
+
ALL_CONTEXTS - Static variable in class org.apache.beam.sdk.testing.CoderProperties
+
+
All the contexts, for use in test cases.
+
+
ALL_KEYS - Static variable in class org.apache.beam.sdk.io.range.ByteKeyRange
+
+
The range of all keys, with empty start and end keys.
+
+
ALL_SHARDS - Static variable in class org.apache.beam.sdk.util.ShardingWritableByteChannel
+
+
Special shard number that causes a write to all shards.
+
+
ALLOWED_ENCODINGS - Static variable in class org.apache.beam.sdk.util.PropertyNames
+
 
+
allowsDynamicSplitting() - Method in class org.apache.beam.sdk.io.OffsetBasedSource
+
+
Whether this source should allow dynamic splitting of the offset ranges.
+
+
AlwaysPassMatcher() - Constructor for class org.apache.beam.sdk.testing.TestPipelineOptions.AlwaysPassMatcher
+
 
+
AlwaysPassMatcherFactory() - Constructor for class org.apache.beam.sdk.testing.TestPipelineOptions.AlwaysPassMatcherFactory
+
 
+
and(TupleTag<V>, List<V>) - Method in class org.apache.beam.sdk.transforms.join.CoGbkResult
+
+
Returns a new CoGbkResult based on this, with the given tag and given data + added to it.
+
+
and(TupleTag<V>, PCollection<KV<K, V>>) - Method in class org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple
+
+
Returns a new KeyedPCollectionTuple<K> that is the same as this, + appended with the given PCollection.
+
+
and(TupleTag<V>, V) - Method in class org.apache.beam.sdk.util.PTuple
+
+
Returns a new PTuple that has all the values and + tags of this PTuple plus the given value and tag.
+
+
and(PCollection.IsBounded) - Method in enum org.apache.beam.sdk.values.PCollection.IsBounded
+
+
Returns the composed IsBounded property.
+
+
and(PCollection<T>) - Method in class org.apache.beam.sdk.values.PCollectionList
+
+
Returns a new PCollectionList that has all the PCollections of + this PCollectionList plus the given PCollection appended to the end.
+
+
and(Iterable<PCollection<T>>) - Method in class org.apache.beam.sdk.values.PCollectionList
+
+
Returns a new PCollectionList that has all the PCollections of + this PCollectionList plus the given PCollections appended to the + end, in order.
+
+
and(TupleTag<T>, PCollection<T>) - Method in class org.apache.beam.sdk.values.PCollectionTuple
+
+
Returns a new PCollectionTuple that has each PCollection and + TupleTag of this PCollectionTuple plus the given PCollection + associated with the given TupleTag.
+
+
and(TupleTag<?>) - Method in class org.apache.beam.sdk.values.TupleTagList
+
+
Returns a new TupleTagList that has all the TupleTags of + this TupleTagList plus the given TupleTag appended to the end.
+
+
and(List<TupleTag<?>>) - Method in class org.apache.beam.sdk.values.TupleTagList
+
+
Returns a new TupleTagList that has all the TupleTags of + this TupleTagList plus the given TupleTags appended to the end, + in order.
+
+
any(long) - Static method in class org.apache.beam.sdk.transforms.Sample
+
+
Sample#any(long) takes a PCollection<T> and a limit, and + produces a new PCollection<T> containing up to limit + elements of the input PCollection.
+
+
ApiSurface - Class in org.apache.beam.sdk.util
+
+
Represents the API surface of a package prefix.
+
+
APPEND_TRAILING_NEWLINES - Static variable in class org.apache.beam.sdk.util.PropertyNames
+
 
+
appendTo(Appendable) - Method in interface org.apache.beam.sdk.util.state.StateNamespace
+
+
Append the string representation of this key to the Appendable.
+
+
appendTo(Appendable) - Method in class org.apache.beam.sdk.util.state.StateNamespaceForTest
+
 
+
appendTo(Appendable) - Method in class org.apache.beam.sdk.util.state.StateNamespaces.GlobalNamespace
+
 
+
appendTo(Appendable) - Method in class org.apache.beam.sdk.util.state.StateNamespaces.WindowAndTriggerNamespace
+
 
+
appendTo(Appendable) - Method in class org.apache.beam.sdk.util.state.StateNamespaces.WindowNamespace
+
 
+