Index

A B C D E F G H I J K L M N O P Q R S T U V W X Y Z + + +

A

absolute(String, String...) - Static method in class org.apache.beam.sdk.transforms.display.DisplayData.Path: +
Construct a path from an absolute component path hierarchy.
+
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.
+
AccumulatorCheckpointingSparkListener() - Constructor for class org.apache.beam.runners.spark.aggregators.AggregatorsAccumulator.AccumulatorCheckpointingSparkListener
AccumulatorCheckpointingSparkListener() - Constructor for class org.apache.beam.runners.spark.metrics.MetricsAccumulator.AccumulatorCheckpointingSparkListener
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
add(int, GlobalWatermarkHolder.SparkWatermarks) - Static method in class org.apache.beam.runners.spark.util.GlobalWatermarkHolder
add(KV<byte[], byte[]>) - Method in class org.apache.beam.sdk.extensions.sorter.BufferedExternalSorter
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.ItemSpec<?>) - 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(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
addAll(Map<Integer, Queue<GlobalWatermarkHolder.SparkWatermarks>>) - Static method in class org.apache.beam.runners.spark.util.GlobalWatermarkHolder
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.
+
addComposite(TransformHierarchy.Node) - Method in class org.apache.beam.sdk.runners.TransformHierarchy.Node: +
Adds a composite operation to the transform node.
+
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
addElements(T, T...) - Method in class org.apache.beam.sdk.testing.TestStream.Builder: +
Adds the specified elements to the source with timestamp equal to the current watermark.
+
addElements(TimestampedValue<T>, TimestampedValue<T>...) - Method in class org.apache.beam.sdk.testing.TestStream.Builder: +
Adds the specified elements to the source with the provided timestamps.
+
addIfAbsent(T) - Method in interface org.apache.beam.sdk.util.state.SetState: +
Add a value to the buffer if it is not already present.
+
addIfNotDefault(DisplayData.ItemSpec<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.ItemSpec<?>) - 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(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
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
addMessage(Message) - Method in class org.apache.beam.sdk.io.jms.JmsCheckpointMark
addNameFilter(MetricNameFilter) - Method in class org.apache.beam.sdk.metrics.MetricsFilter.Builder: +
Add a MetricNameFilter.
+
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.
+
addOutput(DirectRunner.UncommittedBundle<?>, DirectRunner.UncommittedBundle<?>...) - Method in class org.apache.beam.runners.direct.StepTransformResult.Builder
addOutput(Collection<DirectRunner.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.
+
addProperties(Configuration, Properties) - Static method in class org.apache.beam.runners.apex.ApexYarnLauncher: +
Transfer the properties to the configuration object.
+
addStep(String) - Method in class org.apache.beam.sdk.metrics.MetricsFilter.Builder: +
Add a step filter.
+
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(WindowedValue<InputT>...) - Method in class org.apache.beam.runners.direct.StepTransformResult.Builder
addUnprocessedElements(Iterable<? extends WindowedValue<InputT>>) - 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(AggInputT) - Method in class org.apache.beam.sdk.transforms.DelegatingAggregator
advance() - Method in class org.apache.beam.runners.spark.io.MicrobatchSource.Reader
advance(JavaSparkContext) - Static method in class org.apache.beam.runners.spark.util.GlobalWatermarkHolder: +
Advances the watermarks to the next-in-line watermarks.
+
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 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.
+
advanceNextBatchWatermarkToInfinity() - Method in class org.apache.beam.runners.spark.io.CreateStream: +
Advances the watermark in the next batch to the end-of-time.
+
advanceProcessingTime(Duration) - Method in class org.apache.beam.sdk.testing.TestStream.Builder: +
Advance the processing time by the specified amount.
+
advanceWatermarkForNextBatch(Instant) - Method in class org.apache.beam.runners.spark.io.CreateStream: +
Advances the watermark in the next batch.
+
advanceWatermarkTo(Instant) - Method in class org.apache.beam.sdk.testing.TestStream.Builder: +
Advance the watermark of this source to the specified instant.
+
advanceWatermarkToInfinity() - Method in class org.apache.beam.sdk.testing.TestStream.Builder: +
Advance the watermark to infinity, completing this TestStream.
+
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.
+
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(DirectRunner.CommittedBundle<T>, TransformResult<T>, Iterable<? extends DirectRunner.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 TransformResult 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.
+
AfterProcessingTime(List<TimestampTransform>) - Constructor for class org.apache.beam.sdk.transforms.windowing.AfterProcessingTime
AfterSynchronizedProcessingTime - Class in org.apache.beam.sdk.transforms.windowing: +
FOR INTERNAL USE ONLY.
+
AfterWatermark - Class in org.apache.beam.sdk.transforms.windowing: +
AfterWatermark triggers fire based on progress of the system watermark.
+
AfterWatermark.AfterWatermarkEarlyAndLate - Class in org.apache.beam.sdk.transforms.windowing
AfterWatermark.FromEndOfWindow - Class in org.apache.beam.sdk.transforms.windowing: +
A watermark trigger targeted relative to the end of the window.
+
AfterWatermarkEarlyAndLate(Trigger.OnceTrigger, Trigger.OnceTrigger) - Constructor for class org.apache.beam.sdk.transforms.windowing.AfterWatermark.AfterWatermarkEarlyAndLate
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.
+
AggregatorContainer - Class in org.apache.beam.runners.direct: +
AccumT container for the current values associated with Aggregators.
+
AggregatorContainer.AggregatorKey - Class in org.apache.beam.runners.direct: +
Aggregators are identified by a step name and an aggregator name.
+
AggregatorContainer.Mutator - Class in org.apache.beam.runners.direct: +
AccumT class for mutations to the aggregator values.
+
AggregatorKey() - Constructor for class org.apache.beam.runners.direct.AggregatorContainer.AggregatorKey
AggregatorMetric - Class in org.apache.beam.runners.spark.metrics: +
An adapter between the NamedAggregators and Codahale's Metric interface.
+
AggregatorMetricSource - Class in org.apache.beam.runners.spark.metrics: +
A Spark Source that is tailored to expose an AggregatorMetric, + wrapping an underlying NamedAggregators instance.
+
AggregatorMetricSource(String, NamedAggregators) - Constructor for class org.apache.beam.runners.spark.metrics.AggregatorMetricSource
aggregatorName() - Method in class org.apache.beam.runners.direct.AggregatorContainer.AggregatorKey
AggregatorRetrievalException - Exception in org.apache.beam.sdk: +
Signals that an exception has occurred while retrieving Aggregators.
+
AggregatorRetrievalException(String, Throwable) - Constructor for exception org.apache.beam.sdk.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.
+
aggregators - Variable in class org.apache.beam.sdk.transforms.DoFn
AggregatorsAccumulator - Class in org.apache.beam.runners.spark.aggregators: +
For resilience, Accumulators are required to be wrapped in a Singleton.
+
AggregatorsAccumulator() - Constructor for class org.apache.beam.runners.spark.aggregators.AggregatorsAccumulator
AggregatorsAccumulator.AccumulatorCheckpointingSparkListener - Class in org.apache.beam.runners.spark.aggregators: +
Spark Listener which checkpoints NamedAggregators values for fault-tolerance.
+
AggregatorValues<T> - Class in org.apache.beam.sdk: +
A collection of values associated with an Aggregator.
+
AggregatorValues() - Constructor for class org.apache.beam.sdk.AggregatorValues
alignedTo(Duration, Instant) - Method in class org.apache.beam.sdk.transforms.windowing.AfterProcessingTime: +
Aligns timestamps to the smallest multiple of period since the offset greater + than the timestamp.
+
alignedTo(Duration) - Method in class org.apache.beam.sdk.transforms.windowing.AfterProcessingTime: +
Aligns the time to be the smallest multiple of period greater than the epoch + boundary (aka new Instant(0)).
+
alignTo(Duration, Instant) - Static method in class org.apache.beam.sdk.transforms.windowing.TimestampTransform: +
Returns a transform that aligns a timestamp to the next boundary of period, starting + from offset.
+
alignTo(Duration) - Static method in class org.apache.beam.sdk.transforms.windowing.TimestampTransform: +
Returns a transform that aligns a timestamp to the next boundary of period, starting + from the start of the epoch.
+
AlignTo() - Constructor for class org.apache.beam.sdk.transforms.windowing.TimestampTransform.AlignTo
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.
+
allMatches(String) - Static method in class org.apache.beam.sdk.transforms.Regex: +
Returns a Regex.AllMatches PTransform that checks if the entire line matches + the Regex.
+
allMatches(Pattern) - Static method in class org.apache.beam.sdk.transforms.Regex: +
Returns a Regex.AllMatches PTransform that checks if the entire line matches + the Regex.
+
AllMatches(Pattern) - Constructor for class org.apache.beam.sdk.transforms.Regex.AllMatches
ALLOWED_ENCODINGS - Static variable in class org.apache.beam.sdk.util.PropertyNames
allowsDynamicSplitting() - Method in class org.apache.beam.sdk.io.CompressedSource.CompressedReader
allowsDynamicSplitting() - Method in class org.apache.beam.sdk.io.OffsetBasedSource.OffsetBasedReader: +
Whether this reader 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.
+
ANNOTATION_FORMATTER - Static variable in class org.apache.beam.sdk.util.common.ReflectHelpers: +
A Function that returns a concise string for a Annotation.
+
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.
+
ApexPipelineOptions - Interface in org.apache.beam.runners.apex: +
Options that configure the Apex pipeline.
+
ApexRunner - Class in org.apache.beam.runners.apex: +
A PipelineRunner that translates the + pipeline to an Apex DAG and executes it on an Apex cluster.
+
ApexRunner(ApexPipelineOptions) - Constructor for class org.apache.beam.runners.apex.ApexRunner
ApexRunner.CreateApexPCollectionView<ElemT,ViewT> - Class in org.apache.beam.runners.apex: +
Creates a primitive PCollectionView.
+
ApexRunnerRegistrar - Class in org.apache.beam.runners.apex: +
Contains the PipelineRunnerRegistrar and PipelineOptionsRegistrar for the + ApexRunner.
+
ApexRunnerRegistrar.Options - Class in org.apache.beam.runners.apex: +
Registers the ApexPipelineOptions.
+
ApexRunnerRegistrar.Runner - Class in org.apache.beam.runners.apex: +
Registers the ApexRunner.
+
ApexRunnerResult - Class in org.apache.beam.runners.apex: +
Result of executing a Pipeline with Apex in embedded mode.
+
ApexRunnerResult(DAG, Launcher.AppHandle) - Constructor for class org.apache.beam.runners.apex.ApexRunnerResult
ApexYarnLauncher - Class in org.apache.beam.runners.apex: +
Proxy to launch the YARN application through the hadoop script to run in the + pre-configured environment (class path, configuration, native libraries etc.).
+
ApexYarnLauncher() - Constructor for class org.apache.beam.runners.apex.ApexYarnLauncher
ApexYarnLauncher.LaunchParams - Class in org.apache.beam.runners.apex: +
Launch parameters that will be serialized and passed to the child process.
+
ApexYarnLauncher.ProcessWatcher - Class in org.apache.beam.runners.apex: +
Starts a command and waits for it to complete.
+
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
AppEngineEnvironment - Class in org.apache.beam.sdk.util: +
Stores whether we are running within AppEngine or not.
+
AppEngineEnvironment() - Constructor for class org.apache.beam.sdk.util.AppEngineEnvironment
applicableTo(PCollection<?>) - Static method in class org.apache.beam.sdk.transforms.GroupByKey
ApplicationNameOptions - Interface in