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() - 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.
ACCUMULATOR_NAME - Static variable in class org.apache.beam.runners.flink.metrics.FlinkMetricContainer
AccumulatorCheckpointingSparkListener() - Constructor for class org.apache.beam.runners.spark.aggregators.AggregatorsAccumulator.AccumulatorCheckpointingSparkListener
AccumulatorCheckpointingSparkListener() - Constructor for class org.apache.beam.runners.spark.metrics.MetricsAccumulator.AccumulatorCheckpointingSparkListener
add(MetricsContainerStepMap) - Method in class org.apache.beam.runners.flink.metrics.MetricsAccumulator
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(InputT) - Method in interface org.apache.beam.sdk.state.GroupingState: Add a value to the buffer.
add(Iterable<TimestampedValue<T>>) - Static method in class org.apache.beam.sdk.testing.TestStream.ElementEvent: For internal use only: no backwards compatibility guarantees.
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.
addAccum(AccumT) - Method in interface org.apache.beam.sdk.state.CombiningState: Add an accumulator to this state cell.
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.runners.dataflow.util.Structs
addDictionary(Map<String, Object>, String, Map<String, Object>) - Static method in class org.apache.beam.runners.dataflow.util.Structs
addDouble(Map<String, Object>, String, Double) - Static method in class org.apache.beam.runners.dataflow.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.state.SetState: Ensures a value is a member of the set, returning true if it was added and false otherwise.
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(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(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(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.runners.dataflow.util.Structs
addList(Map<String, Object>, String, T[]) - Static method in class org.apache.beam.runners.dataflow.util.Structs
addLong(Map<String, Object>, String, long) - Static method in class org.apache.beam.runners.dataflow.util.Structs
addLongs(Map<String, Object>, String, long...) - Static method in class org.apache.beam.runners.dataflow.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.runners.dataflow.util.Structs
addObject(Map<String, Object>, String, Map<String, Object>) - Static method in class org.apache.beam.runners.dataflow.util.Structs
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.runners.dataflow.util.Structs
addStringList(Map<String, Object>, String, List<String>) - Static method in class org.apache.beam.runners.dataflow.util.Structs
addTraceFor(AbstractGoogleClient, String) - Method in class org.apache.beam.sdk.extensions.gcp.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.extensions.gcp.options.GoogleApiDebugOptions.GoogleApiTracer: Creates a GoogleApiDebugOptions.GoogleApiTracer that sets the trace traceDestination on all calls that match for the given request type.
advance() - Method in class org.apache.beam.runners.spark.io.MicrobatchSource.Reader
advance() - 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.
advanceBy(Duration) - Static method in class org.apache.beam.sdk.testing.TestStream.ProcessingTimeEvent: For internal use only: no backwards compatibility guarantees.
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.
advanceTo(Instant) - Static method in class org.apache.beam.sdk.testing.TestStream.WatermarkEvent: For internal use only: no backwards compatibility guarantees.
advanceWatermark() - Method in class org.apache.beam.runners.spark.stateful.SparkTimerInternals: Advances the watermark.
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: A composite Trigger that fires when all of its sub-triggers are ready.
AfterEach - Class in org.apache.beam.sdk.transforms.windowing: A composite Trigger that executes its sub-triggers in order.
AfterFirst - Class in org.apache.beam.sdk.transforms.windowing: 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: A Trigger that fires at some point after a specified number of input elements have arrived.
AfterProcessingTime - Class in org.apache.beam.sdk.transforms.windowing: A Trigger trigger that fires at a specified point in processing time, relative to when input first arrives.
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.
AggAccumParam - Class in org.apache.beam.runners.spark.aggregators: Aggregator accumulator param.
AggAccumParam() - Constructor for class org.apache.beam.runners.spark.aggregators.AggAccumParam
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
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.
align(Duration) - Method in interface org.apache.beam.sdk.state.Timer: Aligns the target timestamp used by Timer.setRelative() to the next boundary of period.
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: For internal use only; no backwards-compatibility guarantees.
alignTo(Duration) - Static method in class org.apache.beam.sdk.transforms.windowing.TimestampTransform: For internal use only; no backwards-compatibility guarantees.
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.
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
allowsDynamicSplitting() - Method in class org.apache.beam.sdk.io.CompressedSource.CompressedReader
allowsDynamicSplitting() - Method in class org.apache.beam.sdk.io.FileBasedSource.FileBasedReader
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
alwaysRetry() - Static method in class org.apache.beam.sdk.io.gcp.bigquery.InsertRetryPolicy: Always retry all failures.
AmqpIO - Class in org.apache.beam.sdk.io.amqp: AmqpIO supports AMQP 1.0 protocol using the Apache QPid Proton-J library.
AmqpIO.Read - Class in org.apache.beam.sdk.io.amqp: A PTransform to read/receive messages using AMQP 1.0 protocol.
AmqpIO.Write - Class in org.apache.beam.sdk.io.amqp: A PTransform to send messages using AMQP 1.0 protocol.
AmqpMessageCoder - Class in org.apache.beam.sdk.io.amqp: A coder for AMQP message.
AmqpMessageCoder() - Constructor for class org.apache.beam.sdk.io.amqp.AmqpMessageCoder
AmqpMessageCoderProviderRegistrar - Class in org.apache.beam.sdk.io.amqp: A CoderProviderRegistrar for standard types used with AmqpIO.
AmqpMessageCoderProviderRegistrar() - Constructor for class org.apache.beam.sdk.io.amqp.AmqpMessageCoderProviderRegistrar
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(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.
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.
applicableTo(PCollection<?>) - Static method in class org.apache.beam.sdk.transforms.GroupByKey
ApplicationNameOptions - Interface in org.apache.beam.sdk.options: Options that allow setting the application name.
apply(InputT) - Method in interface org.apache.beam.sdk.coders.DelegateCoder.CodingFunction
apply(PTransform<? super PBegin, OutputT>) - Method in class org.apache.beam.sdk.Pipeline: Like Pipeline.apply(String, PTransform) but the transform node in the Pipeline graph will be named according to PTransform.getName().
apply(String, PTransform<? super PBegin, OutputT>) - Method in class org.apache.beam.sdk.Pipeline: Adds a root PTransform, such as Read or Create, to this Pipeline.
apply(T) - Method in class org.apache.beam.sdk.testing.PAssert.PCollectionContentsAssert.MatcherCheckerFn
apply(Statement, Description) - Method in class org.apache.beam.sdk.testing.TestPipeline
apply(double, double) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineDoubleFn: Applies the binary operation to the two operands, returning the result.
apply(V, V) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineFn: Applies the binary operation to the two operands, returning the result.
apply(int, int) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineIntegerFn: Applies the binary operation to the two operands, returning the result.
apply(long, long) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineLongFn: Applies the binary operation to the two operands, returning the result.
apply(Iterable<? extends InputT>) - Method in class org.apache.beam.sdk.transforms.Combine.CombineFn: Applies this CombineFn to a collection of input values to produce a combined output value.
apply(Iterable<? extends InputT>, CombineWithContext.Context) - Method in class org.apache.beam.sdk.transforms.CombineWithContext.CombineFnWithContext: Applies this CombineFnWithContext to a collection of input values to produce a combined output value.
apply(PTransform<KeyedPCollectionTuple<K>, OutputT>) - Method in class org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple: Like KeyedPCollectionTuple.apply(String, PTransform) but defaulting to the name provided by the PTransform.
apply(String, PTransform<KeyedPCollectionTuple<K>, OutputT>) - Method in class org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple: Applies the given PTransform to this input KeyedPCollectionTuple and returns its OutputT.
apply(InputT) - Method in interface org.apache.beam.sdk.transforms.SerializableFunction: Returns the result of invoking this function on the given input.
apply(InputT) - Method in class org.apache.beam.sdk.transforms.SimpleFunction
apply(PrimitiveViewT) - Method in class org.apache.beam.sdk.transforms.ViewFn: A function to adapt a primitive view type to a desired view type.
apply(PTransform<? super PBegin, OutputT>) - Method in class org.apache.beam.sdk.values.PBegin: Like PBegin.apply(String, PTransform) but defaulting to the name of the PTransform.
apply(String, PTransform<? super PBegin, OutputT>) - Method in class org.apache.beam.sdk.values.PBegin: Applies the given PTransform to this PBegin, using name to identify this specific application of the transform.
apply(PTransform<? super PCollection<T>, OutputT>) - Method in class org.apache.beam.sdk.values.PCollection: Like PCollection.apply(String, PTransform) but defaulting to the name of the PTransform.
apply(String, PTransform<? super PCollection<T>, OutputT>) - Method in class org.apache.beam.sdk.values.PCollection: Applies the given PTransform to this input PCollection, using name to identify this specific application of the transform.
apply(PTransform<PCollectionList<T>, OutputT>) - Method in class org.apache.beam.sdk.values.PCollectionList: Like PCollectionList.apply(String, PTransform) but defaulting to the name of the PTransform.
apply(String, PTransform<PCollectionList<T>, OutputT>) - Method in class org.apache.beam.sdk.values.PCollectionList: Applies the given PTransform to this input PCollectionList, using name to identify this specific application of the transform.
apply(PTransform<PCollectionTuple, OutputT>) - Method in class org.apache.beam.sdk.values.PCollectionTuple: Like PCollectionTuple.apply(String, PTransform) but defaulting to the name of the PTransform.
apply(String, PTransform<PCollectionTuple, OutputT>) - Method in class org.apache.beam.sdk.values.PCollectionTuple: Applies the given PTransform to this input PCollectionTuple, using name to identify this specific application of the transform.
apply(Iterable<WindowedValue<T>>) - Method in class org.apache.beam.sdk.values.PCollectionViews.IterableViewFn: Deprecated.
apply(Iterable<WindowedValue<T>>) - Method in class org.apache.beam.sdk.values.PCollectionViews.ListViewFn: Deprecated.
apply(Iterable<WindowedValue<KV<K, V>>>) - Method in class org.apache.beam.sdk.values.PCollectionViews.MapViewFn: Deprecated.

Input iterable must actually be Iterable<WindowedValue<KV<K, V>>>.
apply(Iterable<WindowedValue<KV<K, V>>>) - Method in class org.apache.beam.sdk.values.PCollectionViews.MultimapViewFn: Deprecated.
apply(Iterable<WindowedValue<T>>) - Method in class org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn: Deprecated.
applyTransform(InputT, PTransform<? super InputT, OutputT>) - Static method in class org.apache.beam.sdk.Pipeline: For internal use only; no backwards-compatibility guarantees.
applyTransform(String, InputT, PTransform<? super InputT, OutputT>) - Static method in class org.apache.beam.sdk.Pipeline: For internal use only; no backwards-compatibility guarantees.
ApproximateQuantiles - Class in org.apache.beam.sdk.transforms: PTransforms for getting an idea of a PCollection's data distribution using approximate N-tiles (e.g.
ApproximateQuantiles.ApproximateQuantilesCombineFn<T,ComparatorT extends java.util.Comparator<T> & java.io.Serializable> - Class in org.apache.beam.sdk.transforms: The ApproximateQuantilesCombineFn combiner gives an idea of the distribution of a collection of values using approximate N-tiles.
ApproximateUnique - Class in org.apache.beam.sdk.transforms: PTransforms for estimating the number of distinct elements in a PCollection, or the number of distinct values associated with each key in a PCollection of KVs.
ApproximateUnique() - Constructor for class org.apache.beam.sdk.transforms.ApproximateUnique
ApproximateUnique.ApproximateUniqueCombineFn<T> - Class in org.apache.beam.sdk.transforms: CombineFn that computes an estimate of the number of distinct values that were combined.
ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique - Class in org.apache.beam.sdk.transforms: A heap utility class to efficiently track the largest added elements.
ApproximateUniqueCombineFn(long, Coder<T>) - Constructor for class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn
array() - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData: Returns the backing array.
as(Class<T>) - Method in interface org.apache.beam.sdk.options.PipelineOptions: Transforms this object into an object of type <T> saving each property that has been manipulated.
as(Class<T>) - Static method in class org.apache.beam.sdk.options.PipelineOptionsFactory: Creates and returns an object that implements <T>.
as(Class<T>) - Method in class org.apache.beam.sdk.options.PipelineOptionsFactory.Builder: Creates and returns an object that implements <T> using the values configured on this builder during construction.
asCloudObject(Coder<?>) - Static method in class org.apache.beam.runners.dataflow.util.CloudObjects: Convert the provided Coder into a CloudObject.
asInputStream(int, int) - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData: Returns an InputStream wrapper which supplies the portion of this backing byte buffer starting at offset and up to length bytes.
asIterable() - Static method in class org.apache.beam.sdk.transforms.View: Returns a View.AsIterable transform that takes a PCollection as input and produces a PCollectionView mapping each window to an Iterable of the values in that window.
AsJsons<InputT> - Class in org.apache.beam.sdk.extensions.jackson: PTransform for serializing objects to JSON Strings.
asList() - Static method in class org.apache.beam.sdk.transforms.View: Returns a View.AsList transform that takes a PCollection and returns a PCollectionView mapping each window to a List containing all of the elements in the window.
asMap() - Method in class org.apache.beam.sdk.transforms.display.DisplayData
asMap() - Static method in class org.apache.beam.sdk.transforms.View: Returns a View.AsMap transform that takes a PCollection<KV<K, V>> as input and produces a PCollectionView mapping each window to a Map<K, V>.
asMultimap() - Static method in class org.apache.beam.sdk.transforms.View: Returns a View.AsMultimap transform that takes a PCollection<KV<K, V>> as input and produces a PCollectionView mapping each window to its contents as a Map<K, Iterable<V>> for use as a side input.
asOutputStream() - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData: Returns an output stream which writes to the backing buffer from the current position.
asPath() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubSubscription: Returns the string representation of this subscription as a path used in the Cloud Pub/Sub API.
asPath() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubTopic: Returns the string representation of this topic as a path used in the Cloud Pub/Sub API.
ASSERTION_ERROR - Static variable in class org.apache.beam.runners.apex.ApexRunner: TODO: this isn't thread safe and may cause issues when tests run in parallel Holds any most resent assertion error that was raised while processing elements.
assertionError() - Method in class org.apache.beam.sdk.testing.SuccessOrFailure
assertSourcesEqualReferenceSource(BoundedSource<T>, List<? extends BoundedSource<T>>, PipelineOptions) - Static method in class org.apache.beam.sdk.testing.SourceTestUtils: Given a reference Source and a list of Sources, assert that the union of the records read from the list of sources is equal to the records read from the reference source.
assertSplitAtFractionBehavior(BoundedSource<T>, int, double, SourceTestUtils.ExpectedSplitOutcome, PipelineOptions) - Static method in class org.apache.beam.sdk.testing.SourceTestUtils: Asserts that the source's reader either fails to splitAtFraction(fraction) after reading numItemsToReadBeforeSplit items, or succeeds in a way that is consistent according to SourceTestUtils.assertSplitAtFractionSucceedsAndConsistent(org.apache.beam.sdk.io.BoundedSource<T>, int, double, org.apache.beam.sdk.options.PipelineOptions).
assertSplitAtFractionExhaustive(BoundedSource<T>, PipelineOptions) - Static method in class org.apache.beam.sdk.testing.SourceTestUtils: Asserts that for each possible start position, BoundedSource.BoundedReader#splitAtFraction at every interesting fraction (halfway between two fractions that differ by at least one item) can be called successfully and the results are consistent if a split succeeds.
assertSplitAtFractionFails(BoundedSource<T>, int, double, PipelineOptions) - Static method in class org.apache.beam.sdk.testing.SourceTestUtils: Asserts that the source's reader fails to splitAtFraction(fraction) after reading numItemsToReadBeforeSplit items.
assertSplitAtFractionSucceedsAndConsistent(BoundedSource<T>, int, double, PipelineOptions) - Static method in class org.apache.beam.sdk.testing.SourceTestUtils: Verifies some consistency properties of BoundedSource.BoundedReader#splitAtFraction on the given source.
assertUnstartedReaderReadsSameAsItsSource(BoundedSource.BoundedReader<T>, PipelineOptions) - Static method in class org.apache.beam.sdk.testing.SourceTestUtils: Assert that a Reader returns a Source that, when read from, produces the same records as the reader.
assign(BoundedWindow, Instant) - Method in enum org.apache.beam.sdk.transforms.windowing.TimestampCombiner: Shorthand for TimestampCombiner.merge(org.apache.beam.sdk.transforms.windowing.BoundedWindow, java.lang.Iterable<? extends org.joda.time.Instant>) with just one element, to place it into the context of a window.
AssignContext() - Constructor for class org.apache.beam.sdk.transforms.windowing.WindowFn.AssignContext
assignedWindows(WindowFn<T, W>, long) - Static method in class org.apache.beam.sdk.testing.WindowFnTestUtils
assignsToOneWindow() - Method in class org.apache.beam.sdk.transforms.windowing.GlobalWindows
assignsToOneWindow() - Method in class org.apache.beam.sdk.transforms.windowing.PartitioningWindowFn
assignsToOneWindow() - Method in class org.apache.beam.sdk.transforms.windowing.SlidingWindows
assignsToOneWindow() - Method in class org.apache.beam.sdk.transforms.windowing.WindowFn: Returns true if this WindowFn always assigns an element to exactly one window.
assignWindow(Instant) - Method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows.DaysWindows
assignWindow(Instant) - Method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows.MonthsWindows
assignWindow(Instant) - Method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows.YearsWindows
assignWindow(Instant) - Method in class org.apache.beam.sdk.transforms.windowing.FixedWindows
assignWindow(Instant) - Method in class org.apache.beam.sdk.transforms.windowing.PartitioningWindowFn: Returns the single window to which elements with this timestamp belong.
assignWindows(WindowFn<Object, GlobalWindow>.AssignContext) - Method in class org.apache.beam.sdk.transforms.windowing.GlobalWindows
assignWindows(WindowFn<Object, W>.AssignContext) - Method in class org.apache.beam.sdk.transforms.windowing.InvalidWindows
assignWindows(WindowFn<T, W>.AssignContext) - Method in class org.apache.beam.sdk.transforms.windowing.PartitioningWindowFn
assignWindows(WindowFn<Object, IntervalWindow>.AssignContext) - Method in class org.apache.beam.sdk.transforms.windowing.Sessions
assignWindows(WindowFn<Object, IntervalWindow>.AssignContext) - Method in class org.apache.beam.sdk.transforms.windowing.SlidingWindows
assignWindows(Instant) - Method in class org.apache.beam.sdk.transforms.windowing.SlidingWindows
assignWindows(WindowFn<T, W>.AssignContext) - Method in class org.apache.beam.sdk.transforms.windowing.WindowFn: Given a timestamp and element, returns the set of windows into which it should be placed.
asSingleton() - Static method in class org.apache.beam.sdk.transforms.View: Returns a View.AsSingleton transform that takes a PCollection with a single value per window as input and produces a PCollectionView that returns the value in the main input window when read as a side input.
asSingletonView() - Method in class org.apache.beam.sdk.transforms.Combine.Globally: Returns a PTransform that produces a PCollectionView whose elements are the result of combining elements per-window in the input PCollection.
asV1Beta1Path() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubSubscription: Deprecated.
the v1beta1 API for Cloud Pub/Sub is deprecated.
asV1Beta1Path() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubTopic: Deprecated.
the v1beta1 API for Cloud Pub/Sub is deprecated.
asV1Beta2Path() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubSubscription: Deprecated.
the v1beta2 API for Cloud Pub/Sub is deprecated.
asV1Beta2Path() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubTopic: Deprecated.
the v1beta2 API for Cloud Pub/Sub is deprecated.
atMinimumTimestamp(V) - Static method in class org.apache.beam.sdk.values.TimestampedValue: Returns a new TimestampedValue with the minimum timestamp.
AtomicCoder<T> - Class in org.apache.beam.sdk.coders: A Coder that has no component Coders or other configuration.
AtomicCoder() - Constructor for class org.apache.beam.sdk.coders.AtomicCoder
AtomicLongFactory() - Constructor for class org.apache.beam.sdk.options.PipelineOptions.AtomicLongFactory
attached() - Method in class org.apache.beam.sdk.io.gcp.spanner.MutationGroup
attempted() - Method in interface org.apache.beam.sdk.metrics.MetricResult: Return the value of this metric across all attempts of executing all parts of the pipeline.
AvailableParallelismFactory() - Constructor for class org.apache.beam.runners.direct.DirectOptions.AvailableParallelismFactory
AvroCoder<T> - Class in org.apache.beam.sdk.coders: A Coder using Avro binary format.
AvroCoder(Class<T>, Schema) - Constructor for class org.apache.beam.sdk.coders.AvroCoder
AvroIO - Class in org.apache.beam.sdk.io: PTransforms for reading and writing Avro files.
AvroIO.Read<T> - Class in org.apache.beam.sdk.io: Implementation of AvroIO.read(java.lang.Class<T>).
AvroIO.Write<T> - Class in org.apache.beam.sdk.io: Implementation of AvroIO.write(java.lang.Class<T>).
AvroReader(AvroSource<T>) - Constructor for class org.apache.beam.sdk.io.AvroSource.AvroReader: Reads Avro records of type T from the specified source.
AvroSource<T> - Class in org.apache.beam.sdk.io: Do not use in pipelines directly: most users should use AvroIO.Read.
AvroSource.AvroReader<T> - Class in org.apache.beam.sdk.io: A BlockBasedSource.BlockBasedReader for reading blocks from Avro files.
awaitTermination(Duration) - Method in class org.apache.beam.runners.spark.SparkPipelineResult
awaitTermination(Duration) - Method in class org.apache.beam.runners.spark.SparkRunnerDebugger.DebugSparkPipelineResult

B

BACKLOG_UNKNOWN - Static variable in class org.apache.beam.sdk.io.UnboundedSource.UnboundedReader: Constant representing an unknown amount of backlog.
backlogBytes() - Static method in class org.apache.beam.sdk.metrics.SourceMetrics: Gauge for source backlog in bytes.
backlogBytesOfSplit(String) - Static method in class org.apache.beam.sdk.metrics.SourceMetrics: Gauge for source split backlog in bytes.
backlogElements() - Static method in class org.apache.beam.sdk.metrics.SourceMetrics: Gauge for source backlog in elements.
backlogElementsOfSplit(String) - Static method in class org.apache.beam.sdk.metrics.SourceMetrics: Gauge for source split backlog in elements.
bag() - Static method in class org.apache.beam.sdk.state.StateSpecs: Create a StateSpec for a BagState, optimized for adding values frequently and occasionally retrieving all the values that have been added.
bag(Coder<T>) - Static method in class org.apache.beam.sdk.state.StateSpecs: Identical to StateSpecs.bag(), but with an element coder explicitly supplied.
BagState<T> - Interface in org.apache.beam.sdk.state: A ReadableState cell containing a bag of values.
BatchStatefulParDoOverrides - Class in org.apache.beam.runners.dataflow: PTransformOverrideFactories that expands to correctly implement stateful ParDo using window-unaware BatchViewOverrides.GroupByKeyAndSortValuesOnly to linearize processing per key.
BatchStatefulParDoOverrides() - Constructor for class org.apache.beam.runners.dataflow.BatchStatefulParDoOverrides
BatchStatefulParDoOverrides.BatchStatefulDoFn<K,V,OutputT> - Class in org.apache.beam.runners.dataflow: A key-preserving DoFn that explodes an iterable that has been grouped by key and window.
BeamSparkRunnerRegistrator - Class in org.apache.beam.runners.spark.coders: Custom KryoRegistrators for Beam's Spark runner needs.
BeamSparkRunnerRegistrator() - Constructor for class org.apache.beam.runners.spark.coders.BeamSparkRunnerRegistrator
begin() - Method in class org.apache.beam.sdk.Pipeline: Returns a PBegin owned by this Pipeline.
beginningOnDay(int) - Method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows.MonthsWindows
beginningOnDay(int, int) - Method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows.YearsWindows
BigDecimalCoder - Class in org.apache.beam.sdk.coders: A BigDecimalCoder encodes a BigDecimal as an integer scale encoded with VarIntCoder and a BigInteger encoded using BigIntegerCoder.
bigdecimals() - Static method in class org.apache.beam.sdk.values.TypeDescriptors: The TypeDescriptor for BigDecimal.
BigEndianIntegerCoder - Class in org.apache.beam.sdk.coders: A BigEndianIntegerCoder encodes Integers in 4 bytes, big-endian.
BigEndianLongCoder - Class in org.apache.beam.sdk.coders: A BigEndianLongCoder encodes Longs in 8 bytes, big-endian.
BigIntegerCoder - Class in org.apache.beam.sdk.coders: A BigIntegerCoder encodes a BigInteger as a byte array containing the big endian two's-complement representation, encoded via ByteArrayCoder.
bigintegers() - Static method in class org.apache.beam.sdk.values.TypeDescriptors: The TypeDescriptor for BigInteger.
BigQueryCoderProviderRegistrar - Class in org.apache.beam.sdk.io.gcp.bigquery: A CoderProviderRegistrar for standard types used with BigQueryIO.
BigQueryCoderProviderRegistrar() - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.BigQueryCoderProviderRegistrar
BigQueryHelpers - Class in org.apache.beam.sdk.io.gcp.bigquery: A set of helper functions and classes used by BigQueryIO.
BigQueryHelpers() - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.BigQueryHelpers
BigQueryIO - Class in org.apache.beam.sdk.io.gcp.bigquery: PTransforms for reading and writing BigQuery tables.
BigQueryIO.Read - Class in org.apache.beam.sdk.io.gcp.bigquery: Implementation of BigQueryIO.read().
BigQueryIO.Write<T> - Class in org.apache.beam.sdk.io.gcp.bigquery: Implementation of BigQueryIO.write().
BigQueryIO.Write.CreateDisposition - Enum in org.apache.beam.sdk.io.gcp.bigquery: An enumeration type for the BigQuery create disposition strings.
BigQueryIO.Write.WriteDisposition - Enum in org.apache.beam.sdk.io.gcp.bigquery: An enumeration type for the BigQuery write disposition strings.
BigQueryOptions - Interface in org.apache.beam.sdk.io.gcp.bigquery: Properties needed when using Google BigQuery with the Apache Beam SDK.
BigtableIO - Class in org.apache.beam.sdk.io.gcp.bigtable: Transforms for reading from and writing to Google Cloud Bigtable.
BigtableIO.Read - Class in org.apache.beam.sdk.io.gcp.bigtable: A PTransform that reads from Google Cloud Bigtable.
BigtableIO.Write - Class in org.apache.beam.sdk.io.gcp.bigtable: A PTransform that writes to Google Cloud Bigtable.
BinaryCombineDoubleFn() - Constructor for class org.apache.beam.sdk.transforms.Combine.BinaryCombineDoubleFn
BinaryCombineFn() - Constructor for class org.apache.beam.sdk.transforms.Combine.BinaryCombineFn
BinaryCombineIntegerFn() - Constructor for class org.apache.beam.sdk.transforms.Combine.BinaryCombineIntegerFn
BinaryCombineLongFn() - Constructor for class org.apache.beam.sdk.transforms.Combine.BinaryCombineLongFn
bind(String, StateBinder) - Method in interface org.apache.beam.sdk.state.StateSpec: For internal use only; no backwards-compatibility guarantees.
bindBag(String, StateSpec<BagState<T>>, Coder<T>) - Method in interface org.apache.beam.sdk.state.StateBinder
bindCombining(String, StateSpec<CombiningState<InputT, AccumT, OutputT>>, Coder<AccumT>, Combine.CombineFn<InputT, AccumT, OutputT>) - Method in interface org.apache.beam.sdk.state.StateBinder
bindCombiningWithContext(String, StateSpec<CombiningState<InputT, AccumT, OutputT>>, Coder<AccumT>, CombineWithContext.CombineFnWithContext<InputT, AccumT, OutputT>) - Method in interface org.apache.beam.sdk.state.StateBinder
bindMap(String, StateSpec<MapState<KeyT, ValueT>>, Coder<KeyT>, Coder<ValueT>) - Method in interface org.apache.beam.sdk.state.StateBinder
bindSet(String, StateSpec<SetState<T>>, Coder<T>) - Method in interface org.apache.beam.sdk.state.StateBinder
bindValue(String, StateSpec<ValueState<T>>, Coder<T>) - Method in interface org.apache.beam.sdk.state.StateBinder
bindWatermark(String, StateSpec<WatermarkHoldState>, TimestampCombiner) - Method in interface org.apache.beam.sdk.state.StateBinder: Bind to a watermark StateSpec.
BitSetCoder - Class in org.apache.beam.sdk.coders: Coder for BitSet.
Block() - Constructor for class org.apache.beam.sdk.io.BlockBasedSource.Block
BlockBasedReader(BlockBasedSource<T>) - Constructor for class org.apache.beam.sdk.io.BlockBasedSource.BlockBasedReader
BlockBasedSource<T> - Class in org.apache.beam.sdk.io: A BlockBasedSource is a FileBasedSource where a file consists of blocks of records.
BlockBasedSource(String, long) - Constructor for class org.apache.beam.sdk.io.BlockBasedSource: Creates a BlockBasedSource based on a file name or pattern.
BlockBasedSource(MatchResult.Metadata, long, long, long) - Constructor for class org.apache.beam.sdk.io.BlockBasedSource: Creates a BlockBasedSource for a single file.
BlockBasedSource.Block<T> - Class in org.apache.beam.sdk.io: A Block represents a block of records that can be read.
BlockBasedSource.BlockBasedReader<T> - Class in org.apache.beam.sdk.io: A Reader that reads records from a BlockBasedSource.
booleans() - Static method in class org.apache.beam.sdk.values.TypeDescriptors: The TypeDescriptor for Boolean.
Bounded(SparkContext, BoundedSource<T>, SparkRuntimeContext, String) - Constructor for class org.apache.beam.runners.spark.io.SourceRDD.Bounded
BoundedReader() - Constructor for class org.apache.beam.sdk.io.BoundedSource.BoundedReader
BoundedReadFromUnboundedSource<T> - Class in org.apache.beam.sdk.io: PTransform that reads a bounded amount of data from an UnboundedSource, specified as one or both of a maximum number of elements or a maximum period of time to read.
BoundedSource<T> - Class in org.apache.beam.sdk.io: A Source that reads a finite amount of input and, because of that, supports some additional operations.
BoundedSource() - Constructor for class org.apache.beam.sdk.io.BoundedSource
BoundedSource.BoundedReader<T> - Class in org.apache.beam.sdk.io: A Reader that reads a bounded amount of input and supports some additional operations, such as progress estimation and dynamic work rebalancing.
BoundedWindow - Class in org.apache.beam.sdk.transforms.windowing: A BoundedWindow represents window information assigned to data elements.
BoundedWindow() - Constructor for class org.apache.beam.sdk.transforms.windowing.BoundedWindow
broadcast(JavaSparkContext) - Method in class org.apache.beam.runners.spark.util.SideInputBroadcast
BufferedExternalSorter - Class in org.apache.beam.sdk.extensions.sorter: Sorter that will use in memory sorting until the values can't fit into memory and will then fall back to external sorting.
BufferedExternalSorter.Options - Class in org.apache.beam.sdk.extensions.sorter: Contains configuration for the sorter.
build() - Method in class org.apache.beam.sdk.extensions.gcp.storage.GcsCreateOptions.Builder
build() - Method in class org.apache.beam.sdk.io.fs.CreateOptions.StandardCreateOptions.Builder
build() - Method in class org.apache.beam.sdk.io.fs.MatchResult.Metadata.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.spanner.SpannerConfig.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.CreateTransaction.Builder
build() - Method in class org.apache.beam.sdk.metrics.MetricsFilter.Builder
builder() - Static method in class org.apache.beam.sdk.extensions.gcp.storage.GcsCreateOptions: Returns a GcsCreateOptions.Builder.
Builder() - Constructor for class org.apache.beam.sdk.extensions.gcp.storage.GcsCreateOptions.Builder
Builder() - Constructor for class org.apache.beam.sdk.io.fs.CreateOptions.Builder
builder() - Static method in class org.apache.beam.sdk.io.fs.CreateOptions.StandardCreateOptions: Returns a CreateOptions.StandardCreateOptions.Builder.
Builder() - Constructor for class org.apache.beam.sdk.io.fs.CreateOptions.StandardCreateOptions.Builder
builder() - Static method in class org.apache.beam.sdk.io.fs.MatchResult.Metadata
Builder() - Constructor for class org.apache.beam.sdk.io.fs.MatchResult.Metadata.Builder
Builder() - Constructor for class org.apache.beam.sdk.io.gcp.spanner.SpannerConfig.Builder
Builder() - Constructor for class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.CreateTransaction.Builder
builder() - Static method in class org.apache.beam.sdk.metrics.MetricsFilter
Builder() - Constructor for class org.apache.beam.sdk.metrics.MetricsFilter.Builder
buildOutputFilenames(Iterable<FileBasedSink.FileResult>) - Method in class org.apache.beam.sdk.io.FileBasedSink.WriteOperation
buildTemporaryFilename(ResourceId, String) - Static method in class org.apache.beam.sdk.io.FileBasedSink.WriteOperation: Constructs a temporary file resource given the temporary directory and a filename.
by(PredicateT) - Static method in class org.apache.beam.sdk.transforms.Filter: Returns a PTransform that takes an input PCollection<T> and returns a PCollection<T> with elements that satisfy the given predicate.
ByteArray - Class in org.apache.beam.runners.spark.util: Serializable byte array.
ByteArray(byte[]) - Constructor for class org.apache.beam.runners.spark.util.ByteArray
ByteArrayCoder - Class in org.apache.beam.sdk.coders: A Coder for byte[].
ByteCoder - Class in org.apache.beam.sdk.coders: A ByteCoder encodes Byte values in 1 byte using Java serialization.
ByteKey - Class in org.apache.beam.sdk.io.range: A class representing a key consisting of an array of bytes.
ByteKeyRange - Class in org.apache.beam.sdk.io.range: A class representing a range of ByteKeys.
ByteKeyRangeTracker - Class in org.apache.beam.sdk.io.range: A RangeTracker for ByteKeys in ByteKeyRanges.
bytes() - Static method in class org.apache.beam.sdk.values.TypeDescriptors: The TypeDescriptor for Byte.
bytesRead() - Static method in class org.apache.beam.sdk.metrics.SourceMetrics: Counter of bytes read by a source.
bytesReadBySplit(String) - Static method in class org.apache.beam.sdk.metrics.SourceMetrics: Counter of bytes read by a source split.
ByteStringCoder - Class in org.apache.beam.sdk.extensions.protobuf: A Coder for ByteString objects based on their encoded Protocol Buffer form.
bytesWritten() - Static method in class org.apache.beam.sdk.metrics.SinkMetrics: Counter of bytes written to a sink.

C

CalendarWindows - Class in org.apache.beam.sdk.transforms.windowing: A collection of WindowFns that windows values into calendar-based windows such as spans of days, months, or years.
CalendarWindows() - Constructor for class org.apache.beam.sdk.transforms.windowing.CalendarWindows
CalendarWindows.DaysWindows - Class in org.apache.beam.sdk.transforms.windowing: A WindowFn that windows elements into periods measured by days.
CalendarWindows.MonthsWindows - Class in org.apache.beam.sdk.transforms.windowing: A WindowFn that windows elements into periods measured by months.
CalendarWindows.YearsWindows - Class in org.apache.beam.sdk.transforms.windowing: A WindowFn that windows elements into periods measured by years.
cancel() - Method in class org.apache.beam.runners.apex.ApexRunnerResult
cancel() - Method in class org.apache.beam.runners.dataflow.DataflowPipelineJob
cancel() - Method in class org.apache.beam.runners.dataflow.util.DataflowTemplateJob
cancel() - Method in class org.apache.beam.runners.direct.DirectRunner.DirectPipelineResult
cancel() - Method in class org.apache.beam.runners.flink.FlinkDetachedRunnerResult
cancel() - Method in class org.apache.beam.runners.flink.FlinkRunnerResult
cancel() - Method in class org.apache.beam.runners.spark.SparkPipelineResult
cancel() - Method in interface org.apache.beam.sdk.PipelineResult: Cancels the pipeline execution.
CannotProvideCoderException - Exception in org.apache.beam.sdk.coders: The exception thrown when a CoderRegistry or CoderProvider cannot provide a Coder that has been requested.
CannotProvideCoderException(String) - Constructor for exception org.apache.beam.sdk.coders.CannotProvideCoderException
CannotProvideCoderException(String, CannotProvideCoderException.ReasonCode) - Constructor for exception org.apache.beam.sdk.coders.CannotProvideCoderException
CannotProvideCoderException(String, Throwable) - Constructor for exception org.apache.beam.sdk.coders.CannotProvideCoderException
CannotProvideCoderException(String, Throwable, CannotProvideCoderException.ReasonCode) - Constructor for exception org.apache.beam.sdk.coders.CannotProvideCoderException
CannotProvideCoderException(Throwable) - Constructor for exception org.apache.beam.sdk.coders.CannotProvideCoderException
CannotProvideCoderException(Throwable, CannotProvideCoderException.ReasonCode) - Constructor for exception org.apache.beam.sdk.coders.CannotProvideCoderException
CannotProvideCoderException.ReasonCode - Enum in org.apache.beam.sdk.coders: Indicates the reason that Coder inference failed.
CassandraIO - Class in org.apache.beam.sdk.io.cassandra: An IO to read from Apache Cassandra.
CassandraIO.Read<T> - Class in org.apache.beam.sdk.io.cassandra: A PTransform to read data from Apache Cassandra.
CassandraIO.Write<T> - Class in org.apache.beam.sdk.io.cassandra: A PTransform to write into Apache Cassandra.
CassandraService<T> - Interface in org.apache.beam.sdk.io.cassandra: An interface for real or fake implementations of Cassandra.
CassandraService.Writer<T> - Interface in org.apache.beam.sdk.io.cassandra: Writer for an entity.
CassandraServiceImpl<T> - Class in org.apache.beam.sdk.io.cassandra: An implementation of the CassandraService that actually use a Cassandra instance.
CassandraServiceImpl() - Constructor for class org.apache.beam.sdk.io.cassandra.CassandraServiceImpl
CassandraServiceImpl.TokenRange - Class in org.apache.beam.sdk.io.cassandra: Represent a token range in Cassandra instance, wrapping the partition count, size and token range.
CassandraServiceImpl.WriterImpl<T> - Class in org.apache.beam.sdk.io.cassandra: Writer storing an entity into Apache Cassandra database.
characters() - Static method in class org.apache.beam.sdk.values.TypeDescriptors: The TypeDescriptor for Character.
checkDone() - Method in class org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker
checkDone() - Method in interface org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker: Called by the runner after DoFn.ProcessElement returns.
checkpoint() - Method in class org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker
checkpoint() - Method in interface org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker: Signals that the current DoFn.ProcessElement call should terminate as soon as possible.
classesToTranslators() - Method in interface org.apache.beam.runners.dataflow.util.CoderCloudObjectTranslatorRegistrar: Gets a map from Coder to a CloudObjectTranslator that can translate that Coder.
classesToTranslators() - Method in class org.apache.beam.runners.dataflow.util.DefaultCoderCloudObjectTranslatorRegistrar
classNamesToTranslators() - Method in interface org.apache.beam.runners.dataflow.util.CoderCloudObjectTranslatorRegistrar: Gets a map from the name returned by CloudObject.getClassName() to a translator that can convert into the equivalent Coder.
classNamesToTranslators() - Method in class org.apache.beam.runners.dataflow.util.DefaultCoderCloudObjectTranslatorRegistrar
CLASSPATH_SCHEME - Static variable in class org.apache.beam.runners.apex.ApexRunner
cleanup() - Method in class org.apache.beam.sdk.io.FileBasedSink.Writer
clear() - Static method in class org.apache.beam.runners.spark.aggregators.AggregatorsAccumulator
clear() - Static method in class org.apache.beam.runners.spark.metrics.MetricsAccumulator
clear() - Static method in class org.apache.beam.runners.spark.util.GlobalWatermarkHolder
clear() - Method in interface org.apache.beam.sdk.state.State: Clear out the state location.
clearCache() - Static method in class org.apache.beam.runners.spark.io.MicrobatchSource
clearOutputElements() - Method in class org.apache.beam.sdk.transforms.DoFnTester: Clears the record of the elements output so far to the main output.
clearOutputElements(TupleTag<T>) - Method in class org.apache.beam.sdk.transforms.DoFnTester: Clears the record of the elements output so far to the output with the given tag.
clone() - Method in class org.apache.beam.runners.dataflow.util.CloudObject
clone() - Method in class org.apache.beam.runners.flink.metrics.MetricsAccumulator
close() - Method in class org.apache.beam.runners.spark.io.MicrobatchSource.Reader
close() - Method in class org.apache.beam.sdk.io.cassandra.CassandraServiceImpl.WriterImpl
close() - Method in class org.apache.beam.sdk.io.FileBasedSink.Writer: Closes the channel and returns the bundle result.
close() - Method in class org.apache.beam.sdk.io.FileBasedSource.FileBasedReader: Closes any ReadableByteChannel created for the current reader.
close() - Method in class org.apache.beam.sdk.io.kafka.serialization.InstantDeserializer
close() - Method in class org.apache.beam.sdk.io.kafka.serialization.InstantSerializer
close() - Method in class org.apache.beam.sdk.io.Source.Reader: Closes the reader.
close() - Method in class org.apache.beam.sdk.transforms.DoFnTester
CloudDebuggerOptions - Interface in org.apache.beam.runners.dataflow.options: Options for controlling Cloud Debugger.
CloudObject - Class in org.apache.beam.runners.dataflow.util: A representation of an arbitrary Java object to be instantiated by Dataflow workers.
cloudObjectClassName() - Method in interface org.apache.beam.runners.dataflow.util.CloudObjectTranslator: Gets the class name that will represent the CloudObject created by this CloudObjectTranslator.
CloudObjects - Class in org.apache.beam.runners.dataflow.util: Utilities for converting an object to a CloudObject.
CloudObjectTranslator<T> - Interface in org.apache.beam.runners.dataflow.util: A translator that takes an object and creates a CloudObject which can be converted back to the original object.
CloudResourceManagerOptions - Interface in org.apache.beam.sdk.extensions.gcp.options: Properties needed when using Google CloudResourceManager with the Apache Beam SDK.
CO_GBK_RESULT_SCHEMA - Static variable in class org.apache.beam.runners.dataflow.util.PropertyNames
Coder<T> - Class in org.apache.beam.sdk.coders: A Coder<T> defines how to encode and decode values of type T into byte streams.
Coder() - Constructor for class org.apache.beam.sdk.coders.Coder
Coder.Context - Class in org.apache.beam.sdk.coders: Deprecated.
Coder.NonDeterministicException - Exception in org.apache.beam.sdk.coders: Exception thrown by Coder.verifyDeterministic() if the encoding is not deterministic, including details of why the encoding is not deterministic.
CoderCloudObjectTranslatorRegistrar - Interface in org.apache.beam.runners.dataflow.util: Coder authors have the ability to automatically have their Coder registered with the Dataflow Runner by creating a ServiceLoader entry and a concrete implementation of this interface.
coderConsistentWithEquals(Coder<T>, T, T) - Static method in class org.apache.beam.sdk.testing.CoderProperties: Verifies that for the given Coder<T> and values of type T, the values are equal if and only if the encoded bytes are equal.
coderConsistentWithEqualsInContext(Coder<T>, Coder.Context, T, T) - Static method in class org.apache.beam.sdk.testing.CoderProperties: Verifies that for the given Coder<T>, Coder.Context, and values of type T, the values are equal if and only if the encoded bytes are equal, in any Coder.Context.
coderDecodeEncodeContentsEqual(Coder<CollectionT>, CollectionT) - Static method in class org.apache.beam.sdk.testing.CoderProperties: Verifies that for the given Coder<Collection<T>>, and value of type Collection<T>, encoding followed by decoding yields an equal value of type Collection<T>, in any Coder.Context.
coderDecodeEncodeContentsEqualInContext(Coder<CollectionT>, Coder.Context, CollectionT) - Static method in class org.apache.beam.sdk.testing.CoderProperties: Verifies that for the given Coder<Collection<T>>, and value of type Collection<T>, encoding followed by decoding yields an equal value of type Collection<T>, in the given Coder.Context.
coderDecodeEncodeContentsInSameOrder(Coder<IterableT>, IterableT) - Static method in class org.apache.beam.sdk.testing.CoderProperties: Verifies that for the given Coder<Collection<T>>, and value of type Collection<T>, encoding followed by decoding yields an equal value of type Collection<T>, in any Coder.Context.
coderDecodeEncodeContentsInSameOrderInContext(Coder<IterableT>, Coder.Context, IterableT) - Static method in class org.apache.beam.sdk.testing.CoderProperties: Verifies that for the given Coder<Iterable<T>>, and value of type Iterable<T>, encoding followed by decoding yields an equal value of type Collection<T>, in the given Coder.Context.
coderDecodeEncodeEqual(Coder<T>, T) - Static method in class org.apache.beam.sdk.testing.CoderProperties: Verifies that for the given Coder<T>, and value of type T, encoding followed by decoding yields an equal value of type T, in any Coder.Context.
coderDecodeEncodeEqualInContext(Coder<T>, Coder.Context, T) - Static method in class org.apache.beam.sdk.testing.CoderProperties: Verifies that for the given Coder<T>, Coder.Context, and value of type T, encoding followed by decoding yields an equal value of type T.
coderDecodesBase64(Coder<T>, String, T) - Static method in class org.apache.beam.sdk.testing.CoderProperties
coderDecodesBase64(Coder<T>, List<String>, List<T>) - Static method in class org.apache.beam.sdk.testing.CoderProperties
coderDecodesBase64ContentsEqual(Coder<IterableT>, String, IterableT) - Static method in class org.apache.beam.sdk.testing.CoderProperties
coderDecodesBase64ContentsEqual(Coder<IterableT>, List<String>, List<IterableT>) - Static method in class org.apache.beam.sdk.testing.CoderProperties
coderDeterministic(Coder<T>, T, T) - Static method in class org.apache.beam.sdk.testing.CoderProperties: Verifies that for the given Coder<T>, and values of type T, if the values are equal then the encoded bytes are equal, in any Coder.Context.
coderDeterministicInContext(Coder<T>, Coder.Context, T, T) - Static method in class org.apache.beam.sdk.testing.CoderProperties: Verifies that for the given Coder<T>, Coder.Context, and values of type T, if the values are equal then the encoded bytes are equal.
coderEncodesBase64(Coder<T>, T, String) - Static method in class org.apache.beam.sdk.testing.CoderProperties
coderEncodesBase64(Coder<T>, List<T>, List<String>) - Static method in class org.apache.beam.sdk.testing.CoderProperties
CoderException - Exception in org.apache.beam.sdk.coders: An Exception thrown if there is a problem encoding or decoding a value.
CoderException(String) - Constructor for exception org.apache.beam.sdk.coders.CoderException
CoderException(String, Throwable) - Constructor for exception org.apache.beam.sdk.coders.CoderException
CoderException(Throwable) - Constructor for exception org.apache.beam.sdk.coders.CoderException
coderFor(TypeDescriptor<T>, List<? extends Coder<?>>) - Method in class org.apache.beam.sdk.coders.CoderProvider: Returns a Coder<T> to use for values of a particular type, given the Coders for each of the type's generic parameter types.
coderFromCloudObject(CloudObject) - Static method in class org.apache.beam.runners.dataflow.util.CloudObjects
CoderHelpers - Class in org.apache.beam.runners.spark.coders: Serialization utility class.
CoderProperties - Class in org.apache.beam.sdk.testing: Properties for use in Coder tests.
CoderProperties() - Constructor for class org.apache.beam.sdk.testing.CoderProperties
CoderProperties.TestElementByteSizeObserver - Class in org.apache.beam.sdk.testing: An ElementByteSizeObserver that records the observed element sizes for testing purposes.
CoderProvider - Class in org.apache.beam.sdk.coders: A CoderProvider provides Coders.
CoderProvider() - Constructor for class org.apache.beam.sdk.coders.CoderProvider
CoderProviderRegistrar - Interface in org.apache.beam.sdk.coders: Coder creators have the ability to automatically have their coders registered with this SDK by creating a ServiceLoader entry and a concrete implementation of this interface.
CoderProviders - Class in org.apache.beam.sdk.coders: Static utility methods for creating and working with CoderProviders.
CoderRegistry - Class in org.apache.beam.sdk.coders: A CoderRegistry allows creating a Coder for a given Java class or type descriptor.
coderSerializable(Coder<T>) - Static method in class org.apache.beam.sdk.testing.CoderProperties: Verifies that the given Coder<T> can be correctly serialized and deserialized.
CoGbkResult - Class in org.apache.beam.sdk.transforms.join: A row result of a CoGroupByKey.
CoGbkResult(CoGbkResultSchema, Iterable<RawUnionValue>) - Constructor for class org.apache.beam.sdk.transforms.join.CoGbkResult: A row in the PCollection resulting from a CoGroupByKey transform.
CoGbkResult(CoGbkResultSchema, Iterable<RawUnionValue>, int) - Constructor for class org.apache.beam.sdk.transforms.join.CoGbkResult
CoGbkResult.CoGbkResultCoder - Class in org.apache.beam.sdk.transforms.join: A Coder for CoGbkResults.
CoGbkResultSchema - Class in org.apache.beam.sdk.transforms.join: A schema for the results of a CoGroupByKey.
CoGbkResultSchema(TupleTagList) - Constructor for class org.apache.beam.sdk.transforms.join.CoGbkResultSchema: Builds a schema from a tuple of TupleTag<?>s.
CoGroupByKey<K> - Class in org.apache.beam.sdk.transforms.join: A PTransform that performs a CoGroupByKey on a tuple of tables.
CollectionCoder<T> - Class in org.apache.beam.sdk.coders: A CollectionCoder encodes Collections in the format of IterableLikeCoder.
CollectionCoder(Coder<T>) - Constructor for class org.apache.beam.sdk.coders.CollectionCoder
Combine - Class in org.apache.beam.sdk.transforms: PTransforms for combining PCollection elements globally and per-key.
combine(Iterable<? extends Instant>) - Method in enum org.apache.beam.sdk.transforms.windowing.TimestampCombiner: Combines the given times, which must be from the same window and must have been passed through TimestampCombiner.merge(org.apache.beam.sdk.transforms.windowing.BoundedWindow, java.lang.Iterable<? extends org.joda.time.Instant>).
combine(Instant...) - Method in enum org.apache.beam.sdk.transforms.windowing.TimestampCombiner: Varargs variant of TimestampCombiner.combine(java.lang.Iterable<? extends org.joda.time.Instant>).
Combine.AccumulatingCombineFn<InputT,AccumT extends Combine.AccumulatingCombineFn.Accumulator<InputT,AccumT,OutputT>,OutputT> - Class in org.apache.beam.sdk.transforms: A CombineFn that uses a subclass of Combine.AccumulatingCombineFn.Accumulator as its accumulator type.
Combine.AccumulatingCombineFn.Accumulator<InputT,AccumT,OutputT> - Interface in org.apache.beam.sdk.transforms: The type of mutable accumulator values used by this AccumulatingCombineFn.
Combine.BinaryCombineDoubleFn - Class in org.apache.beam.sdk.transforms: An abstract subclass of Combine.CombineFn for implementing combiners that are more easily and efficiently expressed as binary operations on doubles.
Combine.BinaryCombineFn<V> - Class in org.apache.beam.sdk.transforms: An abstract subclass of Combine.CombineFn for implementing combiners that are more easily expressed as binary operations.
Combine.BinaryCombineIntegerFn - Class in org.apache.beam.sdk.transforms: An abstract subclass of Combine.CombineFn for implementing combiners that are more easily and efficiently expressed as binary operations on ints
Combine.BinaryCombineLongFn - Class in org.apache.beam.sdk.transforms: An abstract subclass of Combine.CombineFn for implementing combiners that are more easily and efficiently expressed as binary operations on longs.
Combine.CombineFn<InputT,AccumT,OutputT> - Class in org.apache.beam.sdk.transforms: A CombineFn<InputT, AccumT, OutputT> specifies how to combine a collection of input values of type InputT into a single output value of type OutputT.
Combine.Globally<InputT,OutputT> - Class in org.apache.beam.sdk.transforms: Combine.Globally<InputT, OutputT> takes a PCollection<InputT> and returns a PCollection<OutputT> whose elements are the result of combining all the elements in each window of the input PCollection, using a specified CombineFn<InputT, AccumT, OutputT>.
Combine.GloballyAsSingletonView<InputT,OutputT> - Class in org.apache.beam.sdk.transforms: Combine.GloballyAsSingletonView<InputT, OutputT> takes a PCollection<InputT> and returns a PCollectionView<OutputT> whose elements are the result of combining all the elements in each window of the input PCollection, using a specified CombineFn<InputT, AccumT, OutputT>.
Combine.GroupedValues<K,InputT,OutputT> - Class in org.apache.beam.sdk.transforms: GroupedValues<K, InputT, OutputT> takes a PCollection<KV<K, Iterable<InputT>>>, such as the result of GroupByKey, applies a specified CombineFn<InputT, AccumT, OutputT> to each of the input KV<K, Iterable<InputT>> elements to produce a combined output KV<K, OutputT> element, and returns a PCollection<KV<K, OutputT>> containing all the combined output elements.
Combine.Holder<V> - Class in org.apache.beam.sdk.transforms: Holds a single value value of type V which may or may not be present.
Combine.IterableCombineFn<V> - Class in org.apache.beam.sdk.transforms: Converts a SerializableFunction from Iterable<V>s to Vs into a simple Combine.CombineFn over Vs.
Combine.PerKey<K,InputT,OutputT> - Class in org.apache.beam.sdk.transforms: PerKey<K, InputT, OutputT> takes a PCollection<KV<K, InputT>>, groups it by key, applies a combining function to the InputT values associated with each key to produce a combined OutputT value, and returns a PCollection<KV<K, OutputT>> representing a map from each distinct key of the input PCollection to the corresponding combined value.
Combine.PerKeyWithHotKeyFanout<K,InputT,OutputT> - Class in org.apache.beam.sdk.transforms: Like Combine.PerKey, but sharding the combining of hot keys.
Combine.SimpleCombineFn<V> - Class in org.apache.beam.sdk.transforms: Deprecated.
CombineFn() - Constructor for class org.apache.beam.sdk.transforms.Combine.CombineFn
combineFn() - Static method in class org.apache.beam.sdk.transforms.Count: Returns a Combine.CombineFn that counts the number of its inputs.
combineFn() - Static method in class org.apache.beam.sdk.transforms.Latest: Returns a Combine.CombineFn that selects the latest element among its inputs.
combineFn(int) - Static method in class org.apache.beam.sdk.transforms.Sample: Returns a Combine.CombineFn that computes a fixed-sized sample of its inputs.
CombineFnBase - Class in org.apache.beam.sdk.transforms: For internal use only; no backwards-compatibility guarantees.
CombineFnBase() - Constructor for class org.apache.beam.sdk.transforms.CombineFnBase
CombineFnBase.GlobalCombineFn<InputT,AccumT,OutputT> - Interface in org.apache.beam.sdk.transforms: For internal use only; no backwards-compatibility guarantees.
CombineFns - Class in org.apache.beam.sdk.transforms: Static utility methods that create combine function instances.
CombineFns() - Constructor for class org.apache.beam.sdk.transforms.CombineFns
CombineFns.CoCombineResult - Class in org.apache.beam.sdk.transforms: A tuple of outputs produced by a composed combine functions.
CombineFns.ComposeCombineFnBuilder - Class in org.apache.beam.sdk.transforms: A builder class to construct a composed CombineFnBase.GlobalCombineFn.
CombineFns.ComposedCombineFn<DataT> - Class in org.apache.beam.sdk.transforms: A composed Combine.CombineFn that applies multiple CombineFns.
CombineFns.ComposedCombineFnWithContext<DataT> - Class in org.apache.beam.sdk.transforms: A composed CombineWithContext.CombineFnWithContext that applies multiple CombineFnWithContexts.
CombineFnWithContext() - Constructor for class org.apache.beam.sdk.transforms.CombineWithContext.CombineFnWithContext
CombineFunctionState(Combine.CombineFn<InputT, InterT, OutputT>, Coder<InputT>, SparkRuntimeContext) - Constructor for class org.apache.beam.runners.spark.aggregators.NamedAggregators.CombineFunctionState
CombineWithContext - Class in org.apache.beam.sdk.transforms: This class contains combine functions that have access to PipelineOptions and side inputs through CombineWithContext.Context.
CombineWithContext() - Constructor for class org.apache.beam.sdk.transforms.CombineWithContext
CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT> - Class in org.apache.beam.sdk.transforms: A combine function that has access to PipelineOptions and side inputs through CombineWithContext.Context.
CombineWithContext.Context - Class in org.apache.beam.sdk.transforms: Information accessible to all methods in CombineFnWithContext and KeyedCombineFnWithContext.
CombineWithContext.RequiresContextInternal - Interface in org.apache.beam.sdk.transforms: An internal interface for signaling that a GloballyCombineFn or a PerKeyCombineFn needs to access CombineWithContext.Context.
combining(Combine.CombineFn<InputT, AccumT, OutputT>) - Static method in class org.apache.beam.sdk.state.StateSpecs: Create a StateSpec for a CombiningState which uses a Combine.CombineFn to automatically merge multiple values of type InputT into a single resulting OutputT.
combining(CombineWithContext.CombineFnWithContext<InputT, AccumT, OutputT>) - Static method in class org.apache.beam.sdk.state.StateSpecs: For internal use only; no backwards compatibility guarantees
combining(Coder<AccumT>, Combine.CombineFn<InputT, AccumT, OutputT>) - Static method in class org.apache.beam.sdk.state.StateSpecs: Identical to #combining(CombineFn), but with an accumulator coder explicitly supplied.
combining(Coder<AccumT>, CombineWithContext.CombineFnWithContext<InputT, AccumT, OutputT>) - Static method in class org.apache.beam.sdk.state.StateSpecs: For internal use only; no backwards compatibility guarantees
combiningFromInputInternal(Coder<InputT>, Combine.CombineFn<InputT, AccumT, OutputT>) - Static method in class org.apache.beam.sdk.state.StateSpecs: For internal use only; no backwards-compatibility guarantees.
CombiningState<InputT,AccumT,OutputT> - Interface in org.apache.beam.sdk.state: A ReadableState cell defined by a Combine.CombineFn, accepting multiple input values, combining them as specified into accumulators, and producing a single output value.
committed() - Method in interface org.apache.beam.sdk.metrics.MetricResult: Return the value of this metric across all successfully completed parts of the pipeline.
commonPrefixLength(RandomAccessData, RandomAccessData) - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData.UnsignedLexicographicalComparator: Compute the length of the common prefix of the two provided sets of bytes.
compact(AccumT) - Method in class org.apache.beam.sdk.transforms.Combine.CombineFn: Returns an accumulator that represents the same logical value as the input accumulator, but may have a more compact representation.
compact(List<V>) - Method in class org.apache.beam.sdk.transforms.Combine.IterableCombineFn
compact(Object[]) - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFn
compact(Object[], CombineWithContext.Context) - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFnWithContext
compact(AccumT, CombineWithContext.Context) - Method in class org.apache.beam.sdk.transforms.CombineWithContext.CombineFnWithContext: Returns an accumulator that represents the same logical value as the input accumulator, but may have a more compact representation.
compare(JobMessage, JobMessage) - Method in class org.apache.beam.runners.dataflow.util.MonitoringUtil.TimeStampComparator
compare(RandomAccessData, RandomAccessData) - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData.UnsignedLexicographicalComparator
compare(RandomAccessData, RandomAccessData, int) - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData.UnsignedLexicographicalComparator: Compare the two sets of bytes starting at the given offset.
compare(T, T) - Method in class org.apache.beam.sdk.transforms.Top.Largest: Deprecated.
compare(T, T) - Method in class org.apache.beam.sdk.transforms.Top.Natural
compare(T, T) - Method in class org.apache.beam.sdk.transforms.Top.Reversed
compare(T, T) - Method in class org.apache.beam.sdk.transforms.Top.Smallest: Deprecated.
compare(KV<K, V>, KV<K, V>) - Method in class org.apache.beam.sdk.values.KV.OrderByKey
compare(KV<K, V>, KV<K, V>) - Method in class org.apache.beam.sdk.values.KV.OrderByValue
compareTo(ByteArray) - Method in class org.apache.beam.runners.spark.util.ByteArray
compareTo(ByteKey) - Method in class org.apache.beam.sdk.io.range.ByteKey: ByteKey implements Comparable<ByteKey> by comparing the arrays in lexicographic order.
compareTo(IntervalWindow) - Method in class org.apache.beam.sdk.transforms.windowing.IntervalWindow
COMPONENT_ENCODINGS - Static variable in class org.apache.beam.runners.dataflow.util.PropertyNames
compose() - Static method in class org.apache.beam.sdk.transforms.CombineFns: Returns a CombineFns.ComposeCombineFnBuilder to construct a composed CombineFnBase.GlobalCombineFn.
ComposeCombineFnBuilder() - Constructor for class org.apache.beam.sdk.transforms.CombineFns.ComposeCombineFnBuilder
CompositeSource - Class in org.apache.beam.runners.spark.metrics: Composite source made up of several MetricRegistry instances.
CompositeSource(String, MetricRegistry...) - Constructor for class org.apache.beam.runners.spark.metrics.CompositeSource
CompressedReader(CompressedSource<T>, FileBasedSource.FileBasedReader<T>) - Constructor for class org.apache.beam.sdk.io.CompressedSource.CompressedReader: Create a CompressedReader from a CompressedSource and delegate reader.
CompressedSource<T> - Class in org.apache.beam.sdk.io: A Source that reads from compressed files.
CompressedSource.CompressedReader<T> - Class in org.apache.beam.sdk.io: Reader for a CompressedSource.
CompressedSource.CompressionMode - Enum in org.apache.beam.sdk.io: Default compression types supported by the CompressedSource.
CompressedSource.DecompressingChannelFactory - Interface in org.apache.beam.sdk.io: Factory interface for creating channels that decompress the content of an underlying channel.
compute(Partition, TaskContext) - Method in class org.apache.beam.runners.spark.io.SourceRDD.Bounded
compute(Partition, TaskContext) - Method in class org.apache.beam.runners.spark.io.SourceRDD.Unbounded
ConfigurationLocator() - Constructor for class org.apache.beam.sdk.io.hdfs.HadoopFileSystemOptions.ConfigurationLocator
configure(Map<String, ?>, boolean) - Method in class org.apache.beam.sdk.io.kafka.serialization.InstantDeserializer
configure(Map<String, ?>, boolean) - Method in class org.apache.beam.sdk.io.kafka.serialization.InstantSerializer
configure() - Static method in class org.apache.beam.sdk.transforms.windowing.Window: Returns a new builder for a Window transform for setting windowing parameters other than the windowing function.
ConnectionConfiguration() - Constructor for class org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.ConnectionConfiguration
ConnectionConfiguration() - Constructor for class org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.ConnectionConfiguration
ConnectionConfiguration() - Constructor for class org.apache.beam.sdk.io.mqtt.MqttIO.ConnectionConfiguration
consistentWithEquals() - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.BigDecimalCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.BigEndianIntegerCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.BigEndianLongCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.BigIntegerCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.BitSetCoder
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.ByteCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.Coder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.DoubleCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.DurationCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.InstantCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.KvCoder
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.LengthPrefixCoder: LengthPrefixCoder is consistent with equals if the nested Coder is.
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.NullableCoder: NullableCoder is consistent with equals if the nested Coder is.
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.StringUtf8Coder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.StructuredCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.VarIntCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.VarLongCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.VoidCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.extensions.protobuf.ByteStringCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
consistentWithEquals() - Method in class org.apache.beam.sdk.io.kafka.KafkaRecordCoder
consistentWithEquals() - Method in class org.apache.beam.sdk.transforms.windowing.GlobalWindow.Coder
consistentWithEquals() - Method in class org.apache.beam.sdk.transforms.windowing.IntervalWindow.IntervalWindowCoder
ConsoleIO - Class in org.apache.beam.runners.spark.io: Print to console.
ConsoleIO.Write - Class in org.apache.beam.runners.spark.io: Write on the console.
ConsoleIO.Write.Unbound<T> - Class in org.apache.beam.runners.spark.io: PTransform writing PCollection on the console.
constructUsingStandardParameters(ValueProvider<ResourceId>, String, String, boolean) - Static method in class org.apache.beam.sdk.io.DefaultFilenamePolicy: A helper function to construct a DefaultFilenamePolicy using the standard filename parameters, namely a provided ResourceId for the output prefix, and possibly-null shard name template and suffix.
contains(PCollectionView<T>) - Method in class org.apache.beam.runners.spark.util.SparkSideInputReader
contains(T) - Method in interface org.apache.beam.sdk.state.SetState: Returns true if this set contains the specified element.
contains(IntervalWindow) - Method in class org.apache.beam.sdk.transforms.windowing.IntervalWindow: Returns whether this window contains the given window.
containsInAnyOrder(T...) - Method in interface org.apache.beam.sdk.testing.PAssert.IterableAssert: Asserts that the iterable in question contains the provided elements.
containsInAnyOrder(Iterable<T>) - Method in interface org.apache.beam.sdk.testing.PAssert.IterableAssert: Asserts that the iterable in question contains the provided elements.
containsInAnyOrder(T...) - Method in class org.apache.beam.sdk.testing.PAssert.PCollectionContentsAssert: Checks that the Iterable contains the expected elements, in any order.
containsInAnyOrder(Iterable<T>) - Method in class org.apache.beam.sdk.testing.PAssert.PCollectionContentsAssert: Checks that the Iterable contains the expected elements, in any order.
containsKey(ByteKey) - Method in class org.apache.beam.sdk.io.range.ByteKeyRange: Returns true if the specified ByteKey is contained within this range.
Context(boolean) - Constructor for class org.apache.beam.sdk.coders.Coder.Context: Deprecated.
Context(int, int) - Constructor for class org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy.Context
Context(TableDataInsertAllResponse.InsertErrors) - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.InsertRetryPolicy.Context
Context() - Constructor for class org.apache.beam.sdk.transforms.CombineWithContext.Context
convertToArgs(PipelineOptions) - Static method in class org.apache.beam.sdk.testing.TestPipeline
convertToBagSpecInternal(StateSpec<CombiningState<InputT, AccumT, OutputT>>) - Static method in class org.apache.beam.sdk.state.StateSpecs: For internal use only; no backwards-compatibility guarantees.
convertToFileResourceIfPossible(String) - Static method in class org.apache.beam.sdk.io.FileBasedSink: This is a helper function for turning a user-provided output filename prefix and converting it into a ResourceId for writing output files.
copy() - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData: Returns a copy of this RandomAccessData.
copy(List<ResourceIdT>, List<ResourceIdT>) - Method in class org.apache.beam.sdk.io.FileSystem: Copies a List of file-like resources from one location to another.
copy(List<ResourceId>, List<ResourceId>, MoveOptions...) - Static method in class org.apache.beam.sdk.io.FileSystems: Copies a List of file-like resources from one location to another.
copyFrom(ByteBuffer) - Static method in class org.apache.beam.sdk.io.range.ByteKey: Creates a new ByteKey backed by a copy of the data remaining in the specified ByteBuffer.
copyFrom(byte[]) - Static method in class org.apache.beam.sdk.io.range.ByteKey: Creates a new ByteKey backed by a copy of the specified byte[].
count() - Method in class org.apache.beam.sdk.metrics.DistributionResult
Count - Class in org.apache.beam.sdk.transforms: PTransforms to count the elements in a PCollection.
countAsserts(Pipeline) - Static method in class org.apache.beam.sdk.testing.PAssert
Counter - Interface in org.apache.beam.sdk.metrics: A metric that reports a single long value and can be incremented or decremented.
counter(String, String) - Static method in class org.apache.beam.sdk.metrics.Metrics: Create a metric that can be incremented and decremented, and is aggregated by taking the sum.
counter(Class<?>, String) - Static method in class org.apache.beam.sdk.metrics.Metrics: Create a metric that can be incremented and decremented, and is aggregated by taking the sum.
CounterMark(long, Instant) - Constructor for class org.apache.beam.sdk.io.CountingSource.CounterMark: Creates a checkpoint mark reflecting the last emitted value.
counters() - Method in interface org.apache.beam.sdk.metrics.MetricQueryResults: Return the metric results for the counters that matched the filter.
CountingSource - Class in org.apache.beam.sdk.io: Most users should use GenerateSequence instead.
CountingSource.CounterMark - Class in org.apache.beam.sdk.io: The checkpoint for an unbounded CountingSource is simply the last value produced.
CrashingRunner - Class in org.apache.beam.sdk.testing: A PipelineRunner that applies no overrides and throws an exception on calls to Pipeline.run().
CrashingRunner() - Constructor for class org.apache.beam.sdk.testing.CrashingRunner
create(DataflowPipelineOptions) - Static method in class org.apache.beam.runners.dataflow.DataflowClient
create(PCollectionView<?>, Coder<T>) - Static method in class org.apache.beam.runners.dataflow.DataflowRunner.StreamingPCollectionViewWriterFn: Deprecated.
create(PipelineOptions) - Method in class org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions.DataflowClientFactory
create(PipelineOptions) - Method in class org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions.StagerFactory
create(PipelineOptions) - Method in class org.apache.beam.runners.dataflow.options.DataflowPipelineOptions.StagingLocationFactory
create(PipelineOptions) - Method in class org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions.WorkerHarnessContainerImageFactory
create(PipelineOptions) - Method in class org.apache.beam.runners.direct.DirectOptions.AvailableParallelismFactory
create(PipelineOptions) - Method in class org.apache.beam.runners.flink.DefaultParallelismFactory
create(boolean) - Static method in class org.apache.beam.runners.flink.TestFlinkRunner
create(PipelineOptions) - Method in class org.apache.beam.runners.spark.SparkContextOptions.EmptyListenersList
create(PipelineOptions) - Method in class org.apache.beam.runners.spark.SparkPipelineOptions.TmpCheckpointDirFactory
create() - Static method in class org.apache.beam.runners.spark.SparkRunner: Creates and returns a new SparkRunner with default options.
create(SparkPipelineOptions) - Static method in class org.apache.beam.runners.spark.SparkRunner: Creates and returns a new SparkRunner with specified options.
create(PipelineOptions) - Method in class org.apache.beam.runners.spark.TestSparkPipelineOptions.DefaultStopPipelineWatermarkFactory
create(byte[], Coder<T>) - Static method in class org.apache.beam.runners.spark.util.SideInputBroadcast
create(PipelineOptions) - Method in class org.apache.beam.sdk.extensions.gcp.options.GcpOptions.DefaultProjectFactory
create(PipelineOptions) - Method in class org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpTempLocationFactory
create(PipelineOptions) - Method in class org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpUserCredentialsFactory
create(PipelineOptions) - Method in class org.apache.beam.sdk.extensions.gcp.options.GcsOptions.ExecutorServiceFactory
create(PipelineOptions) - Method in class org.apache.beam.sdk.extensions.gcp.options.GcsOptions.PathValidatorFactory
create(BufferedExternalSorter.Options) - Static method in class org.apache.beam.sdk.extensions.sorter.BufferedExternalSorter
create(BufferedExternalSorter.Options) - Static method in class org.apache.beam.sdk.extensions.sorter.SortValues: Returns a SortValues<PrimaryKeyT, SecondaryKeyT, ValueT> PTransform.
create(String[], String, String) - Static method in class org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.ConnectionConfiguration: Creates a new Elasticsearch connection configuration.
create(WritableByteChannel) - Method in interface org.apache.beam.sdk.io.FileBasedSink.WritableByteChannelFactory
create(ResourceIdT, CreateOptions) - Method in class org.apache.beam.sdk.io.FileSystem: Returns a write channel for the given ResourceIdT.
create(ResourceId, String) - Static method in class org.apache.beam.sdk.io.FileSystems: Returns a write channel for the given ResourceId.
create(ResourceId, CreateOptions) - Static method in class org.apache.beam.sdk.io.FileSystems: Returns a write channel for the given ResourceId with CreateOptions.
create(MatchResult.Status, List<MatchResult.Metadata>) - Static method in class org.apache.beam.sdk.io.fs.MatchResult: Returns a MatchResult given the MatchResult.Status and MatchResult.Metadata.
create(MatchResult.Status, IOException) - Static method in class org.apache.beam.sdk.io.fs.MatchResult: Returns a MatchResult given the MatchResult.Status and IOException.
create(Mutation, Mutation...) - Static method in class org.apache.beam.sdk.io.gcp.spanner.MutationGroup: Creates a new group.
create(Mutation, Iterable<Mutation>) - Static method in class org.apache.beam.sdk.io.gcp.spanner.MutationGroup
create() - Static method in class org.apache.beam.sdk.io.gcp.spanner.SpannerConfig
create(Timestamp) - Static method in class org.apache.beam.sdk.io.gcp.spanner.Transaction
create(PipelineOptions) - Method in class org.apache.beam.sdk.io.hdfs.HadoopFileSystemOptions.ConfigurationLocator
create(DataSource) - Static method in class org.apache.beam.sdk.io.jdbc.JdbcIO.DataSourceConfiguration
create(String, String) - Static method in class org.apache.beam.sdk.io.jdbc.JdbcIO.DataSourceConfiguration
create(String, String) - Static method in class org.apache.beam.sdk.io.mqtt.MqttIO.ConnectionConfiguration: Describe a connection configuration to the MQTT broker.
create(String, String, String) - Static method in class org.apache.beam.sdk.io.mqtt.MqttIO.ConnectionConfiguration: Describe a connection configuration to the MQTT broker.
create(long, long, long, long) - Static method in class org.apache.beam.sdk.metrics.DistributionResult
create(long, Instant) - Static method in class org.apache.beam.sdk.metrics.GaugeResult
create(PipelineOptions) - Method in interface org.apache.beam.sdk.options.DefaultValueFactory: Creates a default value for a getter marked with Default.InstanceFactory.
create(PipelineOptions) - Method in class org.apache.beam.sdk.options.PipelineOptions.AtomicLongFactory
create(PipelineOptions) - Method in class org.apache.beam.sdk.options.PipelineOptions.DirectRunner
create(PipelineOptions) - Method in class org.apache.beam.sdk.options.PipelineOptions.JobNameFactory
create() - Method in class org.apache.beam.sdk.options.PipelineOptionsFactory.Builder: Creates and returns an object that implements PipelineOptions using the values configured on this builder during construction.
create() - Static method in class org.apache.beam.sdk.options.PipelineOptionsFactory: Creates and returns an object that implements PipelineOptions.
create() - Static method in class org.apache.beam.sdk.Pipeline: Constructs a pipeline from default PipelineOptions.
create(PipelineOptions) - Static method in class org.apache.beam.sdk.Pipeline: Constructs a pipeline from the provided PipelineOptions.
create() - Static method in class org.apache.beam.sdk.testing.TestPipeline: Creates and returns a new test pipeline.
create(PipelineOptions) - Method in class org.apache.beam.sdk.testing.TestPipelineOptions.AlwaysPassMatcherFactory
create(Coder<T>) - Static method in class org.apache.beam.sdk.testing.TestStream: Create a new TestStream.Builder with no elements and watermark equal to BoundedWindow.TIMESTAMP_MIN_VALUE.
create(int, ComparatorT) - Static method in class org.apache.beam.sdk.transforms.ApproximateQuantiles.ApproximateQuantilesCombineFn: Returns an approximate quantiles combiner with the given compareFn and desired number of quantiles.
create(int) - Static method in class org.apache.beam.sdk.transforms.ApproximateQuantiles.ApproximateQuantilesCombineFn: Like ApproximateQuantiles.ApproximateQuantilesCombineFn.create(int, Comparator), but sorts values using their natural ordering.
create(int, ComparatorT, long, double) - Static method in class org.apache.beam.sdk.transforms.ApproximateQuantiles.ApproximateQuantilesCombineFn: Creates an approximate quantiles combiner with the given compareFn and desired number of quantiles.
Create<T> - Class in org.apache.beam.sdk.transforms: Create<T> takes a collection of elements of type T known when the pipeline is constructed and returns a PCollection<T> containing the elements.
Create() - Constructor for class org.apache.beam.sdk.transforms.Create
create() - Static method in class org.apache.beam.sdk.transforms.Distinct: Returns a Distinct<T> PTransform.
create() - Static method in class org.apache.beam.sdk.transforms.GroupByKey: Returns a GroupByKey<K, V> PTransform.
create() - Static method in class org.apache.beam.sdk.transforms.join.CoGroupByKey: Returns a CoGroupByKey<K> PTransform.
create() - Static method in class org.apache.beam.sdk.transforms.Keys: Returns a Keys<K> PTransform.
create() - Static method in class org.apache.beam.sdk.transforms.KvSwap: Returns a KvSwap<K, V> PTransform.
create() - Static method in class org.apache.beam.sdk.transforms.Values: Returns a Values<V> PTransform.
Create.TimestampedValues<T> - Class in org.apache.beam.sdk.transforms: A PTransform that creates a PCollection whose elements have associated timestamps.
Create.Values<T> - Class in org.apache.beam.sdk.transforms: A PTransform that creates a PCollection from a set of in-memory objects.
createAccumulator() - Method in class org.apache.beam.sdk.transforms.ApproximateQuantiles.ApproximateQuantilesCombineFn
createAccumulator() - Method in class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn
createAccumulator() - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineDoubleFn
createAccumulator() - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineFn
createAccumulator() - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineIntegerFn
createAccumulator() - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineLongFn
createAccumulator() - Method in class org.apache.beam.sdk.transforms.Combine.CombineFn: Returns a new, mutable accumulator value, representing the accumulation of zero input values.
createAccumulator() - Method in class org.apache.beam.sdk.transforms.Combine.IterableCombineFn
createAccumulator() - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFn
createAccumulator(CombineWithContext.Context) - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFnWithContext
createAccumulator(CombineWithContext.Context) - Method in class org.apache.beam.sdk.transforms.CombineWithContext.CombineFnWithContext: Returns a new, mutable accumulator value, representing the accumulation of zero input values.
createAccumulator() - Method in class org.apache.beam.sdk.transforms.Sample.FixedSizedSampleFn
createAccumulator() - Method in class org.apache.beam.sdk.transforms.Top.TopCombineFn
createContextual(DeserializationContext, BeanProperty) - Method in class org.apache.beam.sdk.options.ValueProvider.Deserializer
CreateDataflowView<ElemT,ViewT> - Class in org.apache.beam.runners.dataflow: A DataflowRunner marker class for creating a PCollectionView.
createDecompressingChannel(ReadableByteChannel) - Method in enum org.apache.beam.sdk.io.CompressedSource.CompressionMode
createDecompressingChannel(ReadableByteChannel) - Method in interface org.apache.beam.sdk.io.CompressedSource.DecompressingChannelFactory: Given a channel, create a channel that decompresses the content read from the channel.
createDefault() - Static method in class org.apache.beam.sdk.coders.CoderRegistry: Creates a CoderRegistry containing registrations for all standard coders part of the core Java Apache Beam SDK and also any registrations provided by coder registrars.
createForSubrangeOfFile(String, long, long) - Method in class org.apache.beam.sdk.io.AvroSource: Deprecated.
createForSubrangeOfFile(MatchResult.Metadata, long, long) - Method in class org.apache.beam.sdk.io.AvroSource
createForSubrangeOfFile(MatchResult.Metadata, long, long) - Method in class org.apache.beam.sdk.io.BlockBasedSource: Creates a BlockBasedSource for the specified range in a single file.
createForSubrangeOfFile(MatchResult.Metadata, long, long) - Method in class org.apache.beam.sdk.io.CompressedSource: Creates a CompressedSource for a subrange of a file.
createForSubrangeOfFile(MatchResult.Metadata, long, long) - Method in class org.apache.beam.sdk.io.FileBasedSource: Creates and returns a new FileBasedSource of the same type as the current FileBasedSource backed by a given file and an offset range.
createForSubrangeOfFile(MatchResult.Metadata, long, long) - Method in class org.apache.beam.sdk.io.xml.XmlSource
createInputFormatInstance() - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.HadoopInputFormatBoundedSource: Creates instance of InputFormat class.
createJar(File, File) - Static method in class org.apache.beam.runners.apex.ApexYarnLauncher: Create a jar file from the given directory.
createJob(Job) - Method in class org.apache.beam.runners.dataflow.DataflowClient: Creates the Dataflow Job.
CreateOptions - Class in org.apache.beam.sdk.io.fs: An abstract class that contains common configuration options for creating resources.
CreateOptions() - Constructor for class org.apache.beam.sdk.io.fs.CreateOptions
CreateOptions.Builder<BuilderT extends CreateOptions.Builder<BuilderT>> - Class in org.apache.beam.sdk.io.fs: An abstract builder for CreateOptions.
CreateOptions.StandardCreateOptions - Class in org.apache.beam.sdk.io.fs: A standard configuration options with builder.
CreateOptions.StandardCreateOptions.Builder - Class in org.apache.beam.sdk.io.fs: Builder for CreateOptions.StandardCreateOptions.
createPane(boolean, boolean, PaneInfo.Timing) - Static method in class org.apache.beam.sdk.transforms.windowing.PaneInfo
createPane(boolean, boolean, PaneInfo.Timing, long, long) - Static method in class org.apache.beam.sdk.transforms.windowing.PaneInfo: Factory method to create a PaneInfo with the specified parameters.
createPrimitiveOutputInternal(Pipeline, WindowingStrategy<?, ?>, PCollection.IsBounded) - Static method in class org.apache.beam.sdk.values.PCollection: For internal use only; no backwards-compatibility guarantees.
createProcessContext(ValueInSingleWindow<InputT>) - Method in class org.apache.beam.sdk.transforms.DoFnTester
createReader(PipelineOptions) - Method in class org.apache.beam.sdk.io.BoundedSource: Returns a new BoundedSource.BoundedReader that reads from this source.
createReader(CassandraIO.CassandraSource<T>) - Method in interface org.apache.beam.sdk.io.cassandra.CassandraService: Returns a BoundedSource.BoundedReader that will read from Cassandra using the spec from CassandraIO.CassandraSource.
createReader(CassandraIO.CassandraSource<T>) - Method in class org.apache.beam.sdk.io.cassandra.CassandraServiceImpl
createReader(PipelineOptions) - Method in class org.apache.beam.sdk.io.FileBasedSource
createReader(PipelineOptions) - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.HadoopInputFormatBoundedSource
createReader(PipelineOptions, JmsCheckpointMark) - Method in class org.apache.beam.sdk.io.jms.JmsIO.UnboundedJmsSource
createReader(PipelineOptions) - Method in class org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.Read.BoundedGridFSSource
createReader(PipelineOptions, CheckpointMarkT) - Method in class org.apache.beam.sdk.io.UnboundedSource: Create a new UnboundedSource.UnboundedReader to read from this source, resuming from the given checkpoint if present.
createSingleFileReader(PipelineOptions) - Method in class org.apache.beam.sdk.io.AvroSource
createSingleFileReader(PipelineOptions) - Method in class org.apache.beam.sdk.io.BlockBasedSource: Creates a BlockBasedReader.
createSingleFileReader(PipelineOptions) - Method in class org.apache.beam.sdk.io.CompressedSource: Creates a FileBasedReader to read a single file.
createSingleFileReader(PipelineOptions) - Method in class org.apache.beam.sdk.io.FileBasedSource: Creates and returns an instance of a FileBasedReader implementation for the current source assuming the source represents a single file.
createSingleFileReader(PipelineOptions) - Method in class org.apache.beam.sdk.io.xml.XmlSource
createSourceForSubrange(long, long) - Method in class org.apache.beam.sdk.io.FileBasedSource
createSourceForSubrange(long, long) - Method in class org.apache.beam.sdk.io.OffsetBasedSource: Returns an OffsetBasedSource for a subrange of the current source.
CreateStream<T> - Class in org.apache.beam.runners.spark.io: Create an input stream from Queue.
createStructuralValues(Coder<T>, List<T>) - Static method in class org.apache.beam.sdk.testing.SourceTestUtils: Testing utilities below depend on standard assertions and matchers to compare elements read by sources.
CreateTables<DestinationT> - Class in org.apache.beam.sdk.io.gcp.bigquery: Creates any tables needed before performing streaming writes to the tables.
CreateTables(BigQueryIO.Write.CreateDisposition, DynamicDestinations<?, DestinationT>) - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.CreateTables
createTransaction() - Static method in class org.apache.beam.sdk.io.gcp.spanner.SpannerIO: Returns a transform that creates a batch transaction.
CreateTransaction() - Constructor for class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.CreateTransaction
createWriteOperation() - Method in class org.apache.beam.sdk.io.FileBasedSink: Return a subclass of FileBasedSink.WriteOperation that will manage the write to the sink.
createWriter(CassandraIO.Write<T>) - Method in interface org.apache.beam.sdk.io.cassandra.CassandraService: Create a CassandraService.Writer that writes entities into the Cassandra instance.
createWriter(CassandraIO.Write<T>) - Method in class org.apache.beam.sdk.io.cassandra.CassandraServiceImpl
createWriter() - Method in class org.apache.beam.sdk.io.FileBasedSink.WriteOperation: Clients must implement to return a subclass of FileBasedSink.Writer.
CredentialFactory - Interface in org.apache.beam.sdk.extensions.gcp.auth: Construct an oauth credential to be used by the SDK and the SDK workers.
CsvSink - Class in org.apache.beam.runners.spark.metrics.sink: A Spark Sink that is tailored to report AggregatorMetric metrics to a CSV file.
CsvSink(Properties, MetricRegistry, SecurityManager) - Constructor for class org.apache.beam.runners.spark.metrics.sink.CsvSink
ctxt - Variable in class org.apache.beam.runners.spark.SparkRunner.Evaluator
current() - Method in class org.apache.beam.runners.spark.aggregators.NamedAggregators.CombineFunctionState
current() - Method in interface org.apache.beam.runners.spark.aggregators.NamedAggregators.State
currentEventTime() - Method in interface org.apache.beam.sdk.state.Timers: Returns the current event time.
currentInputWatermarkTime() - Method in class org.apache.beam.runners.spark.stateful.SparkTimerInternals
currentOutputWatermarkTime() - Method in class org.apache.beam.runners.spark.stateful.SparkTimerInternals
currentProcessingTime() - Method in class org.apache.beam.runners.spark.stateful.SparkTimerInternals
currentProcessingTime() - Method in interface org.apache.beam.sdk.state.Timers: Returns the current processing time.
currentRestriction() - Method in class org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker
currentRestriction() - Method in interface org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker: Returns a restriction accurately describing the full range of work the current DoFn.ProcessElement call will do, including already completed work.
currentSynchronizedProcessingTime() - Method in class org.apache.beam.runners.spark.stateful.SparkTimerInternals
currentSynchronizedProcessingTime() - Method in interface org.apache.beam.sdk.state.Timers: Returns the current synchronized processing time or null if unknown.
CUSTOM_SOURCE_FORMAT - Static variable in class org.apache.beam.runners.dataflow.util.PropertyNames
CustomCoder<T> - Class in org.apache.beam.sdk.coders: An abstract base class that implements all methods of Coder except Coder.encode(T, java.io.OutputStream) and Coder.decode(java.io.InputStream).
CustomCoder() - Constructor for class org.apache.beam.sdk.coders.CustomCoder

D

DataflowClient - Class in org.apache.beam.runners.dataflow: Wrapper around the generated Dataflow client to provide common functionality.
DataflowClientFactory() - Constructor for class org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions.DataflowClientFactory
DataflowJobAlreadyExistsException - Exception in org.apache.beam.runners.dataflow: An exception that is thrown if the unique job name constraint of the Dataflow service is broken because an existing job with the same job name is currently active.
DataflowJobAlreadyExistsException(DataflowPipelineJob, String) - Constructor for exception org.apache.beam.runners.dataflow.DataflowJobAlreadyExistsException: Create a new DataflowJobAlreadyExistsException with the specified DataflowPipelineJob and message.
DataflowJobAlreadyUpdatedException - Exception in org.apache.beam.runners.dataflow: An exception that is thrown if the existing job has already been updated within the Dataflow service and is no longer able to be updated.
DataflowJobAlreadyUpdatedException(DataflowPipelineJob, String) - Constructor for exception org.apache.beam.runners.dataflow.DataflowJobAlreadyUpdatedException: Create a new DataflowJobAlreadyUpdatedException with the specified DataflowPipelineJob and message.
DataflowJobException - Exception in org.apache.beam.runners.dataflow: A RuntimeException that contains information about a DataflowPipelineJob.
DataflowPipelineDebugOptions - Interface in org.apache.beam.runners.dataflow.options: Internal.
DataflowPipelineDebugOptions.DataflowClientFactory - Class in org.apache.beam.runners.dataflow.options: Returns the default Dataflow client built from the passed in PipelineOptions.
DataflowPipelineDebugOptions.StagerFactory - Class in org.apache.beam.runners.dataflow.options: Creates a Stager object using the class specified in DataflowPipelineDebugOptions.getStagerClass().
DataflowPipelineJob - Class in org.apache.beam.runners.dataflow: A DataflowPipelineJob represents a job submitted to Dataflow using DataflowRunner.
DataflowPipelineJob(DataflowClient, String, DataflowPipelineOptions, Map<AppliedPTransform<?, ?, ?>, String>) - Constructor for class org.apache.beam.runners.dataflow.DataflowPipelineJob: Constructs the job.
DataflowPipelineOptions - Interface in org.apache.beam.runners.dataflow.options: Options that can be used to configure the DataflowRunner.
DataflowPipelineOptions.StagingLocationFactory - Class in org.apache.beam.runners.dataflow.options: Returns a default staging location under GcpOptions.getGcpTempLocation().
DataflowPipelineRegistrar - Class in org.apache.beam.runners.dataflow: Contains the PipelineOptionsRegistrar and PipelineRunnerRegistrar for the DataflowRunner.
DataflowPipelineRegistrar.Options - Class in org.apache.beam.runners.dataflow: Register the DataflowPipelineOptions.
DataflowPipelineRegistrar.Runner - Class in org.apache.beam.runners.dataflow: Register the DataflowRunner.
DataflowPipelineTranslator - Class in org.apache.beam.runners.dataflow: DataflowPipelineTranslator knows how to translate Pipeline objects into Cloud Dataflow Service API Jobs.
DataflowPipelineTranslator.JobSpecification - Class in org.apache.beam.runners.dataflow: The result of a job translation.
DataflowPipelineWorkerPoolOptions - Interface in org.apache.beam.runners.dataflow.options: Options that are used to configure the Dataflow pipeline worker pool.
DataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType - Enum in org.apache.beam.runners.dataflow.options: Type of autoscaling algorithm to use.
DataflowPipelineWorkerPoolOptions.WorkerHarnessContainerImageFactory - Class in org.apache.beam.runners.dataflow.options: Returns the default Docker container image that executes Dataflow worker harness, residing in Google Container Registry.
DataflowProfilingAgentConfiguration() - Constructor for class org.apache.beam.runners.dataflow.options.DataflowProfilingOptions.DataflowProfilingAgentConfiguration
DataflowProfilingOptions - Interface in org.apache.beam.runners.dataflow.options: Options for controlling profiling of pipeline execution.
DataflowProfilingOptions.DataflowProfilingAgentConfiguration - Class in org.apache.beam.runners.dataflow.options: Configuration the for profiling agent.
DataflowRunner - Class in org.apache.beam.runners.dataflow: A PipelineRunner that executes the operations in the pipeline by first translating them to the Dataflow representation using the DataflowPipelineTranslator and then submitting them to a Dataflow service for execution.
DataflowRunner(DataflowPipelineOptions) - Constructor for class org.apache.beam.runners.dataflow.DataflowRunner
DataflowRunner.StreamingPCollectionViewWriterFn<T> - Class in org.apache.beam.runners.dataflow: Deprecated.
DataflowRunnerHooks - Class in org.apache.beam.runners.dataflow: An instance of this class can be passed to the DataflowRunner to add user defined hooks to be invoked at various times during pipeline execution.
DataflowRunnerHooks() - Constructor for class org.apache.beam.runners.dataflow.DataflowRunnerHooks
DataflowRunnerInfo - Class in org.apache.beam.runners.dataflow: Populates versioning and other information for DataflowRunner.
DataflowServiceException - Exception in org.apache.beam.runners.dataflow: Signals there was an error retrieving information about a job from the Cloud Dataflow Service.
DataflowTemplateJob - Class in org.apache.beam.runners.dataflow.util: A DataflowPipelineJob that is returned when --templateRunner is set.
DataflowTemplateJob() - Constructor for class org.apache.beam.runners.dataflow.util.DataflowTemplateJob
DataflowTransport - Class in org.apache.beam.runners.dataflow.util: Helpers for cloud communication.
DataflowTransport() - Constructor for class org.apache.beam.runners.dataflow.util.DataflowTransport
DataflowWorkerHarnessOptions - Interface in org.apache.beam.runners.dataflow.options: Options that are used exclusively within the Dataflow worker harness.
DataflowWorkerLoggingOptions - Interface in org.apache.beam.runners.dataflow.options: Options that are used to control logging configuration on the Dataflow worker.
DataflowWorkerLoggingOptions.Level - Enum in org.apache.beam.runners.dataflow.options: The set of log levels that can be used on the Dataflow worker.
DataflowWorkerLoggingOptions.WorkerLogLevelOverrides - Class in org.apache.beam.runners.dataflow.options: Defines a log level override for a specific class, package, or name.
DataSourceConfiguration() - Constructor for class org.apache.beam.sdk.io.jdbc.JdbcIO.DataSourceConfiguration
DatastoreIO - Class in org.apache.beam.sdk.io.gcp.datastore: DatastoreIO provides an API for reading from and writing to Google Cloud Datastore over different versions of the Cloud Datastore Client libraries.
DatastoreV1 - Class in org.apache.beam.sdk.io.gcp.datastore: DatastoreV1 provides an API to Read, Write and Delete PCollections of Google Cloud Datastore version v1 Entity objects.
DatastoreV1.DeleteEntity - Class in org.apache.beam.sdk.io.gcp.datastore: A PTransform that deletes Entities from Cloud Datastore.
DatastoreV1.DeleteKey - Class in org.apache.beam.sdk.io.gcp.datastore: A PTransform that deletes Entities associated with the given Keys from Cloud Datastore.
DatastoreV1.Read - Class in org.apache.beam.sdk.io.gcp.datastore: A PTransform that reads the result rows of a Cloud Datastore query as Entity objects.
DatastoreV1.Write - Class in org.apache.beam.sdk.io.gcp.datastore: A PTransform that writes Entity objects to Cloud Datastore.
days(int) - Static method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows: Returns a WindowFn that windows elements into periods measured by days.
dec() - Method in interface org.apache.beam.sdk.metrics.Counter
dec(long) - Method in interface org.apache.beam.sdk.metrics.Counter
decode(InputStream) - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.AvroCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.BigDecimalCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.BigDecimalCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.BigEndianIntegerCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.BigEndianLongCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.BigIntegerCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.BigIntegerCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.BitSetCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.BitSetCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.ByteArrayCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.ByteArrayCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.ByteCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.Coder: Decodes a value of type T from the given input stream in the given context.
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.Coder: Deprecated.
decode(InputStream) - Method in class org.apache.beam.sdk.coders.DelegateCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.DelegateCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.DoubleCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.DurationCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.InstantCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.IterableLikeCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.KvCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.KvCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.LengthPrefixCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.MapCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.MapCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.NullableCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.NullableCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.SerializableCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.StringDelegateCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.StringDelegateCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.StringUtf8Coder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.StringUtf8Coder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.TextualIntegerCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.TextualIntegerCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.VarIntCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.VarLongCoder
decode(InputStream) - Method in class org.apache.beam.sdk.coders.VoidCoder
decode(InputStream) - Method in class org.apache.beam.sdk.extensions.protobuf.ByteStringCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.extensions.protobuf.ByteStringCoder
decode(InputStream) - Method in class org.apache.beam.sdk.extensions.protobuf.ProtoCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.extensions.protobuf.ProtoCoder
decode(InputStream) - Method in class org.apache.beam.sdk.io.amqp.AmqpMessageCoder
decode(InputStream) - Method in class org.apache.beam.sdk.io.FileBasedSink.FileResultCoder
decode(InputStream) - Method in class org.apache.beam.sdk.io.gcp.bigquery.TableDestinationCoder
decode(InputStream) - Method in class org.apache.beam.sdk.io.gcp.bigquery.TableRowJsonCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.io.gcp.bigquery.TableRowJsonCoder
decode(InputStream) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessagePayloadOnlyCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessagePayloadOnlyCoder
decode(InputStream) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessageWithAttributesCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessageWithAttributesCoder
decode(InputStream) - Method in class org.apache.beam.sdk.io.hadoop.WritableCoder
decode(InputStream) - Method in class org.apache.beam.sdk.io.kafka.KafkaRecordCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.io.kafka.KafkaRecordCoder
decode(InputStream) - Method in class org.apache.beam.sdk.io.xml.JAXBCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.io.xml.JAXBCoder
decode(InputStream) - Method in class org.apache.beam.sdk.transforms.join.CoGbkResult.CoGbkResultCoder
decode(InputStream) - Method in class org.apache.beam.sdk.transforms.join.UnionCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.transforms.join.UnionCoder
decode(InputStream) - Method in class org.apache.beam.sdk.transforms.windowing.GlobalWindow.Coder
decode(InputStream) - Method in class org.apache.beam.sdk.transforms.windowing.IntervalWindow.IntervalWindowCoder
decode(InputStream) - Method in class org.apache.beam.sdk.transforms.windowing.PaneInfo.PaneInfoCoder
decode(InputStream) - Method in class org.apache.beam.sdk.values.TimestampedValue.TimestampedValueCoder
decode(InputStream) - Method in class org.apache.beam.sdk.values.ValueInSingleWindow.Coder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.values.ValueInSingleWindow.Coder
decode(InputStream) - Method in class org.apache.beam.sdk.values.ValueWithRecordId.ValueWithRecordIdCoder
decode(InputStream, Coder.Context) - Method in class org.apache.beam.sdk.values.ValueWithRecordId.ValueWithRecordIdCoder
decodePane(byte) - Static method in class org.apache.beam.sdk.transforms.windowing.PaneInfo
decodeToIterable(List<T>) - Method in class org.apache.beam.sdk.coders.CollectionCoder: Builds an instance of IterableT, this coder's associated Iterable-like subtype, from a list of decoded elements.
decodeToIterable(List<T>) - Method in class org.apache.beam.sdk.coders.IterableCoder
decodeToIterable(List<T>) - Method in class org.apache.beam.sdk.coders.IterableLikeCoder: Builds an instance of IterableT, this coder's associated Iterable-like subtype, from a list of decoded elements.
decodeToIterable(List<T>) - Method in class org.apache.beam.sdk.coders.ListCoder
decodeToIterable(List<T>) - Method in class org.apache.beam.sdk.coders.SetCoder: Builds an instance of IterableT, this coder's associated Iterable-like subtype, from a list of decoded elements.
Default - Annotation Type in org.apache.beam.sdk.options: Default represents a set of annotations that can be used to annotate getter properties on PipelineOptions with information representing the default value to be returned if no value is specified.
Default.Boolean - Annotation Type in org.apache.beam.sdk.options: This represents that the default of the option is the specified boolean primitive value.
Default.Byte - Annotation Type in org.apache.beam.sdk.options: This represents that the default of the option is the specified byte primitive value.
Default.Character - Annotation Type in org.apache.beam.sdk.options: This represents that the default of the option is the specified char primitive value.
Default.Class - Annotation Type in org.apache.beam.sdk.options: This represents that the default of the option is the specified Class value.
Default.Double - Annotation Type in org.apache.beam.sdk.options: This represents that the default of the option is the specified double primitive value.
Default.Enum - Annotation Type in org.apache.beam.sdk.options: This represents that the default of the option is the specified enum.
Default.Float - Annotation Type in org.apache.beam.sdk.options: This represents that the default of the option is the specified float primitive value.
Default.InstanceFactory - Annotation Type in org.apache.beam.sdk.options: Value must be of type DefaultValueFactory and have a default constructor.
Default.Integer - Annotation Type in org.apache.beam.sdk.options: This represents that the default of the option is the specified int primitive value.
Default.Long - Annotation Type in org.apache.beam.sdk.options: This represents that the default of the option is the specified long primitive value.
Default.Short - Annotation Type in org.apache.beam.sdk.options: This represents that the default of the option is the specified short primitive value.
Default.String - Annotation Type in org.apache.beam.sdk.options: This represents that the default of the option is the specified String value.
DEFAULT_BYTE_ARRAY_CODER - Static variable in class org.apache.beam.sdk.io.TFRecordIO: The default coder, which returns each record of the input file as a byte array.
DEFAULT_MAX_NUM_ELEMENTS - Static variable in class org.apache.beam.sdk.transforms.ApproximateQuantiles.ApproximateQuantilesCombineFn: The cost (in time and space) to compute quantiles to a given accuracy is a function of the total number of elements in the data set.
DEFAULT_SCHEME - Static variable in class org.apache.beam.sdk.io.FileSystems
DEFAULT_UNWINDOWED_SHARD_TEMPLATE - Static variable in class org.apache.beam.sdk.io.DefaultFilenamePolicy: The default sharding name template used in DefaultFilenamePolicy.constructUsingStandardParameters(org.apache.beam.sdk.options.ValueProvider<org.apache.beam.sdk.io.fs.ResourceId>, java.lang.String, java.lang.String, boolean).
DefaultCoder - Annotation Type in org.apache.beam.sdk.coders: The DefaultCoder annotation specifies a Coder class to handle encoding and decoding instances of the annotated class.
DefaultCoder.DefaultCoderProviderRegistrar - Class in org.apache.beam.sdk.coders: A CoderProviderRegistrar that registers a CoderProvider which can use the @DefaultCoder annotation to provide coder providers that creates Coders.
DefaultCoderCloudObjectTranslatorRegistrar - Class in org.apache.beam.runners.dataflow.util: The CoderCloudObjectTranslatorRegistrar containing the default collection of Coder Cloud Object Translators.
DefaultCoderCloudObjectTranslatorRegistrar() - Constructor for class org.apache.beam.runners.dataflow.util.DefaultCoderCloudObjectTranslatorRegistrar
DefaultCoderProviderRegistrar() - Constructor for class org.apache.beam.sdk.coders.DefaultCoder.DefaultCoderProviderRegistrar
DefaultConcludeTransform() - Constructor for class org.apache.beam.sdk.testing.PAssert.DefaultConcludeTransform
DefaultFilenamePolicy - Class in org.apache.beam.sdk.io: A default FileBasedSink.FilenamePolicy for windowed and unwindowed files.
DefaultParallelismFactory - Class in org.apache.beam.runners.flink: DefaultValueFactory for getting a default value for the parallelism option on FlinkPipelineOptions.
DefaultParallelismFactory() - Constructor for class org.apache.beam.runners.flink.DefaultParallelismFactory
DefaultPipelineOptionsRegistrar - Class in org.apache.beam.sdk.options: A PipelineOptionsRegistrar containing the PipelineOptions subclasses available by default.
DefaultPipelineOptionsRegistrar() - Constructor for class org.apache.beam.sdk.options.DefaultPipelineOptionsRegistrar
DefaultProjectFactory() - Constructor for class org.apache.beam.sdk.extensions.gcp.options.GcpOptions.DefaultProjectFactory
Defaults() - Constructor for class org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults
DefaultStopPipelineWatermarkFactory() - Constructor for class org.apache.beam.runners.spark.TestSparkPipelineOptions.DefaultStopPipelineWatermarkFactory
DefaultTrigger - Class in org.apache.beam.sdk.transforms.windowing: A trigger that is equivalent to Repeatedly.forever(AfterWatermark.pastEndOfWindow()).
defaultValue() - Method in class org.apache.beam.sdk.transforms.Combine.CombineFn: Returns the default value when there are no values added to the accumulator.
defaultValue() - Method in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn: Returns the default value when there are no values added to the accumulator.
defaultValue() - Method in class org.apache.beam.sdk.transforms.CombineWithContext.CombineFnWithContext
defaultValue() - Method in class org.apache.beam.sdk.transforms.View.AsSingleton: Returns the default value of this transform, or null if there isn't one.
DefaultValueFactory<T> - Interface in org.apache.beam.sdk.options: An interface used with the Default.InstanceFactory annotation to specify the class that will be an instance factory to produce default values for a given getter on PipelineOptions.
delay(Duration) - Static method in class org.apache.beam.sdk.transforms.windowing.TimestampTransform: For internal use only; no backwards-compatibility guarantees.
Delay() - Constructor for class org.apache.beam.sdk.transforms.windowing.TimestampTransform.Delay
delegate() - Method in class org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory.ParDoSingle
delegate(HasDisplayData) - Method in interface org.apache.beam.sdk.transforms.display.DisplayData.Builder: Register display data from the specified component on behalf of the current component.
DelegateCoder<T,IntermediateT> - Class in org.apache.beam.sdk.coders: A DelegateCoder<T, IntermediateT> wraps a Coder for IntermediateT and encodes/decodes values of type T by converting to/from IntermediateT and then encoding/decoding using the underlying Coder<IntermediateT>.
DelegateCoder(Coder<IntermediateT>, DelegateCoder.CodingFunction<T, IntermediateT>, DelegateCoder.CodingFunction<IntermediateT, T>, TypeDescriptor<T>) - Constructor for class org.apache.beam.sdk.coders.DelegateCoder
DelegateCoder.CodingFunction<InputT,OutputT> - Interface in org.apache.beam.sdk.coders: A CodingFunction<InputT, OutputT> is a serializable function from InputT to OutputT that may throw any Exception.
delete(Collection<ResourceIdT>) - Method in class org.apache.beam.sdk.io.FileSystem: Deletes a collection of resources.
delete(Collection<ResourceId>, MoveOptions...) - Static method in class org.apache.beam.sdk.io.FileSystems: Deletes a collection of resources.
deleteEntity() - Method in class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1: Returns an empty DatastoreV1.DeleteEntity builder.
deleteKey() - Method in class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1: Returns an empty DatastoreV1.DeleteKey builder.
deleteTimer(StateNamespace, String, TimeDomain) - Method in class org.apache.beam.runners.spark.stateful.SparkTimerInternals
deleteTimer(TimerInternals.TimerData) - Method in class org.apache.beam.runners.spark.stateful.SparkTimerInternals
deleteTimer(StateNamespace, String) - Method in class org.apache.beam.runners.spark.stateful.SparkTimerInternals
deleteTimer(Instant, TimeDomain) - Method in interface org.apache.beam.sdk.state.Timers: Removes the timer set in this context for the timestmap and timeDomain.
dependsOnlyOnEarliestTimestamp() - Method in enum org.apache.beam.sdk.transforms.windowing.TimestampCombiner: Returns true if the result of combination of many output timestamps actually depends only on the earliest.
dependsOnlyOnWindow() - Method in enum org.apache.beam.sdk.transforms.windowing.TimestampCombiner: Returns true if the result does not depend on what outputs were combined but only the window they are in.
describeMismatchSafely(PipelineResult, Description) - Method in class org.apache.beam.sdk.testing.FileChecksumMatcher
describeTo(Description) - Method in class org.apache.beam.sdk.testing.FileChecksumMatcher
describeTo(Description) - Method in class org.apache.beam.sdk.testing.RegexMatcher
describeTo(Description) - Method in class org.apache.beam.sdk.testing.TestPipelineOptions.AlwaysPassMatcher
Description - Annotation Type in org.apache.beam.sdk.options: Descriptions are used to generate human readable output when the --help command is specified.
deserialize(String, byte[]) - Method in class org.apache.beam.sdk.io.kafka.serialization.InstantDeserializer
deserialize(JsonParser, DeserializationContext) - Method in class org.apache.beam.sdk.options.ValueProvider.Deserializer
deserializeTimers(Collection<byte[]>, TimerInternals.TimerDataCoder) - Static method in class org.apache.beam.runners.spark.stateful.SparkTimerInternals
detectClassPathResourcesToStage(ClassLoader) - Static method in class org.apache.beam.runners.dataflow.DataflowRunner: Attempts to detect all the resources the class loader has access to.
detectClassPathResourcesToStage(ClassLoader) - Static method in class org.apache.beam.runners.flink.FlinkRunner: Attempts to detect all the resources the class loader has access to.
DirectOptions - Interface in org.apache.beam.runners.direct: Options that can be used to configure the DirectRunner.
DirectOptions.AvailableParallelismFactory - Class in org.apache.beam.runners.direct: A DefaultValueFactory that returns the result of Runtime.availableProcessors() from the DirectOptions.AvailableParallelismFactory.create(PipelineOptions) method.
DIRECTORY_CONTAINER - Static variable in class org.apache.beam.sdk.io.ShardNameTemplate: Shard is a file within a directory.
DirectRegistrar - Class in org.apache.beam.runners.direct: Contains the PipelineRunnerRegistrar and PipelineOptionsRegistrar for the DirectRunner.
DirectRegistrar.Options - Class in org.apache.beam.runners.direct: Registers the DirectOptions.
DirectRegistrar.Runner - Class in org.apache.beam.runners.direct: Registers the DirectRunner.
DirectRunner - Class in org.apache.beam.runners.direct: A PipelineRunner that executes a Pipeline within the process that constructed the Pipeline.
DirectRunner() - Constructor for class org.apache.beam.sdk.options.PipelineOptions.DirectRunner
DirectRunner.DirectPipelineResult - Class in org.apache.beam.runners.direct: The result of running a Pipeline with the DirectRunner.
DirectTestOptions - Interface in org.apache.beam.runners.direct: Internal-only options for tweaking the behavior of the DirectRunner in ways that users should never do.
DISALLOW_COMBINER_LIFTING - Static variable in class org.apache.beam.runners.dataflow.util.PropertyNames
discardingFiredPanes() - 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 discards elements in a pane after they are triggered.
dispatchBag(Coder<?>) - Method in interface org.apache.beam.sdk.state.StateSpec.Cases
dispatchBag(Coder<?>) - Method in class org.apache.beam.sdk.state.StateSpec.Cases.WithDefault
dispatchCombining(Combine.CombineFn<?, ?, ?>, Coder<?>) - Method in interface org.apache.beam.sdk.state.StateSpec.Cases
dispatchCombining(Combine.CombineFn<?, ?, ?>, Coder<?>) - Method in class org.apache.beam.sdk.state.StateSpec.Cases.WithDefault
dispatchDefault() - Method in class org.apache.beam.sdk.state.StateSpec.Cases.WithDefault
dispatchMap(Coder<?>, Coder<?>) - Method in interface org.apache.beam.sdk.state.StateSpec.Cases
dispatchMap(Coder<?>, Coder<?>) - Method in class org.apache.beam.sdk.state.StateSpec.Cases.WithDefault
dispatchSet(Coder<?>) - Method in interface org.apache.beam.sdk.state.StateSpec.Cases
dispatchSet(Coder<?>) - Method in class org.apache.beam.sdk.state.StateSpec.Cases.WithDefault
dispatchValue(Coder<?>) - Method in interface org.apache.beam.sdk.state.StateSpec.Cases
dispatchValue(Coder<?>) - Method in class org.apache.beam.sdk.state.StateSpec.Cases.WithDefault
DISPLAY_DATA - Static variable in class org.apache.beam.runners.dataflow.util.PropertyNames
DisplayData - Class in org.apache.beam.sdk.transforms.display: Static display data associated with a pipeline component.
DisplayData.Builder - Interface in org.apache.beam.sdk.transforms.display: Utility to build up display data from a component and its included subcomponents.
DisplayData.Identifier - Class in org.apache.beam.sdk.transforms.display: Unique identifier for a display data item within a component.
DisplayData.Item - Class in org.apache.beam.sdk.transforms.display: Items are the unit of display data.
DisplayData.ItemSpec<T> - Class in org.apache.beam.sdk.transforms.display: Specifies an DisplayData.Item to register as display data.
DisplayData.Path - Class in org.apache.beam.sdk.transforms.display: Structured path of registered display data within a component hierarchy.
DisplayData.Type - Enum in org.apache.beam.sdk.transforms.display: Display data type.
distance(long, long) - Static method in class org.apache.beam.sdk.io.cassandra.CassandraServiceImpl: Measure distance between two tokens.
Distinct<T> - Class in org.apache.beam.sdk.transforms: Distinct<T> takes a PCollection<T> and returns a PCollection<T> that has all distinct elements of the input.
Distinct() - Constructor for class org.apache.beam.sdk.transforms.Distinct
Distinct.WithRepresentativeValues<T,IdT> - Class in org.apache.beam.sdk.transforms: A Distinct PTransform that uses a SerializableFunction to obtain a representative value for each input element.
Distribution - Interface in org.apache.beam.sdk.metrics: A metric that reports information about the distribution of reported values.
distribution(String, String) - Static method in class org.apache.beam.sdk.metrics.Metrics: Create a metric that records various statistics about the distribution of reported values.
distribution(Class<?>, String) - Static method in class org.apache.beam.sdk.metrics.Metrics: Create a metric that records various statistics about the distribution of reported values.
DistributionResult - Class in org.apache.beam.sdk.metrics: The result of a Distribution metric.
DistributionResult() - Constructor for class org.apache.beam.sdk.metrics.DistributionResult
distributions() - Method in interface org.apache.beam.sdk.metrics.MetricQueryResults: Return the metric results for the distributions that matched the filter.
doChecks(PAssert.PAssertionSite, ActualT, SerializableFunction<ActualT, Void>) - Static method in class org.apache.beam.sdk.testing.PAssert
DoFn<InputT,OutputT> - Class in org.apache.beam.sdk.transforms: The argument to ParDo providing the code to use to process elements of the input PCollection.
DoFn() - Constructor for class org.apache.beam.sdk.transforms.DoFn
DoFn.BoundedPerElement - Annotation Type in org.apache.beam.sdk.transforms: Annotation on a splittable DoFn specifying that the DoFn performs a bounded amount of work per input element, so applying it to a bounded PCollection will produce also a bounded PCollection.
DoFn.FinishBundle - Annotation Type in org.apache.beam.sdk.transforms: Annotation for the method to use to finish processing a batch of elements.
DoFn.FinishBundleContext - Class in org.apache.beam.sdk.transforms: Information accessible while within the DoFn.FinishBundle method.
DoFn.GetInitialRestriction - Annotation Type in org.apache.beam.sdk.transforms: Annotation for the method that maps an element to an initial restriction for a splittable DoFn.
DoFn.GetRestrictionCoder - Annotation Type in org.apache.beam.sdk.transforms: Annotation for the method that returns the coder to use for the restriction of a splittable DoFn.
DoFn.NewTracker - Annotation Type in org.apache.beam.sdk.transforms: Annotation for the method that creates a new RestrictionTracker for the restriction of a splittable DoFn.
DoFn.OnTimer - Annotation Type in org.apache.beam.sdk.transforms: Annotation for registering a callback for a timer.
DoFn.OnTimerContext - Class in org.apache.beam.sdk.transforms: Information accessible when running a DoFn.OnTimer method.
DoFn.OutputReceiver<T> - Interface in org.apache.beam.sdk.transforms: Receives values of the given type.
DoFn.ProcessContext - Class in org.apache.beam.sdk.transforms: Information accessible when running a DoFn.ProcessElement method.
DoFn.ProcessContinuation - Class in org.apache.beam.sdk.transforms: Temporary, do not use.
DoFn.ProcessElement - Annotation Type in org.apache.beam.sdk.transforms: Annotation for the method to use for processing elements.
DoFn.Setup - Annotation Type in org.apache.beam.sdk.transforms: Annotation for the method to use to prepare an instance for processing bundles of elements.
DoFn.SplitRestriction - Annotation Type in org.apache.beam.sdk.transforms: Annotation for the method that splits restriction of a splittable DoFn into multiple parts to be processed in parallel.
DoFn.StartBundle - Annotation Type in org.apache.beam.sdk.transforms: Annotation for the method to use to prepare an instance for processing a batch of elements.
DoFn.StartBundleContext - Class in org.apache.beam.sdk.transforms: Information accessible while within the DoFn.StartBundle method.
DoFn.StateId - Annotation Type in org.apache.beam.sdk.transforms: Annotation for declaring and dereferencing state cells.
DoFn.Teardown - Annotation Type in org.apache.beam.sdk.transforms: Annotation for the method to use to clean up this instance after processing bundles of elements.
DoFn.TimerId - Annotation Type in org.apache.beam.sdk.transforms: Annotation for declaring and dereferencing timers.
DoFn.UnboundedPerElement - Annotation Type in org.apache.beam.sdk.transforms: Annotation on a splittable DoFn specifying that the DoFn performs an unbounded amount of work per input element, so applying it to a bounded PCollection will produce an unbounded PCollection.
DoFn.WindowedContext - Class in org.apache.beam.sdk.transforms: Information accessible to all methods in this DoFn where the context is in some window.
DoFnInfo<InputT,OutputT> - Class in org.apache.beam.runners.dataflow.util: Wrapper class holding the necessary information to serialize a DoFn.
DoFnRunnerWithMetricsUpdate<InputT,OutputT> - Class in org.apache.beam.runners.flink.metrics: DoFnRunner decorator which registers MetricsContainerImpl.
DoFnRunnerWithMetricsUpdate(String, DoFnRunner<InputT, OutputT>, RuntimeContext) - Constructor for class org.apache.beam.runners.flink.metrics.DoFnRunnerWithMetricsUpdate
DoFnTester<InputT,OutputT> - Class in org.apache.beam.sdk.transforms: A harness for unit-testing a DoFn.
DoFnTester.CloningBehavior - Enum in org.apache.beam.sdk.transforms: When a DoFnTester should clone the DoFn under test and how it should manage the lifecycle of the DoFn.
DoubleCoder - Class in org.apache.beam.sdk.coders: A DoubleCoder encodes Double values in 8 bytes using Java serialization.
doubles() - Static method in class org.apache.beam.sdk.values.TypeDescriptors: The TypeDescriptor for Double.
doublesGlobally() - Static method in class org.apache.beam.sdk.transforms.Max: Returns a PTransform that takes an input PCollection<Double> and returns a PCollection<Double> whose contents is the maximum of the input PCollection's elements, or Double.NEGATIVE_INFINITY if there are no elements.
doublesGlobally() - Static method in class org.apache.beam.sdk.transforms.Min: Returns a PTransform that takes an input PCollection<Double> and returns a PCollection<Double> whose contents is the minimum of the input PCollection's elements, or Double.POSITIVE_INFINITY if there are no elements.
doublesGlobally() - Static method in class org.apache.beam.sdk.transforms.Sum: Returns a PTransform that takes an input PCollection<Double> and returns a PCollection<Double> whose contents is the sum of the input PCollection's elements, or 0 if there are no elements.
doublesPerKey() - Static method in class org.apache.beam.sdk.transforms.Max: Returns a PTransform that takes an input PCollection<KV<K, Double>> and returns a PCollection<KV<K, Double>> that contains an output element mapping each distinct key in the input PCollection to the maximum of the values associated with that key in the input PCollection.
doublesPerKey() - Static method in class org.apache.beam.sdk.transforms.Min: Returns a PTransform that takes an input PCollection<KV<K, Double>> and returns a PCollection<KV<K, Double>> that contains an output element mapping each distinct key in the input PCollection to the minimum of the values associated with that key in the input PCollection.
doublesPerKey() - Static method in class org.apache.beam.sdk.transforms.Sum: Returns a PTransform that takes an input PCollection<KV<K, Double>> and returns a PCollection<KV<K, Double>> that contains an output element mapping each distinct key in the input PCollection to the sum of the values associated with that key in the input PCollection.
DurationCoder - Class in org.apache.beam.sdk.coders: A Coder that encodes a joda Duration as a Long using the format of VarLongCoder.
DynamicDestinations<T,DestinationT> - Class in org.apache.beam.sdk.io.gcp.bigquery: This class provides the most general way of specifying dynamic BigQuery table destinations.
DynamicDestinations() - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.DynamicDestinations

E

ElasticsearchIO - Class in org.apache.beam.sdk.io.elasticsearch: Transforms for reading and writing data from/to Elasticsearch.
ElasticsearchIO.ConnectionConfiguration - Class in org.apache.beam.sdk.io.elasticsearch: A POJO describing a connection configuration to Elasticsearch.
ElasticsearchIO.Read - Class in org.apache.beam.sdk.io.elasticsearch: A PTransform reading data from Elasticsearch.
ElasticsearchIO.Write - Class in org.apache.beam.sdk.io.elasticsearch: A PTransform writing data to Elasticsearch.
element() - Method in class org.apache.beam.sdk.transforms.DoFn.ProcessContext: Returns the input element to be processed.
element() - Method in class org.apache.beam.sdk.transforms.windowing.WindowFn.AssignContext: Returns the current element.
elementCountAtLeast(int) - Static method in class org.apache.beam.sdk.transforms.windowing.AfterPane: Creates a trigger that fires when the pane contains at least countElems elements.
ElementEvent() - Constructor for class org.apache.beam.sdk.testing.TestStream.ElementEvent
elements() - Static method in class org.apache.beam.sdk.transforms.ToString: Transforms each element of the input PCollection to a String using the Object.toString() method.
elementsRead() - Static method in class org.apache.beam.sdk.metrics.SourceMetrics: Counter of elements read by a source.
elementsReadBySplit(String) - Static method in class org.apache.beam.sdk.metrics.SourceMetrics: Counter of elements read by a source split.
elementsWritten() - Static method in class org.apache.beam.sdk.metrics.SinkMetrics: Counter of elements written to a sink.
EMPTY - Static variable in class org.apache.beam.sdk.io.range.ByteKey: An empty key.
empty() - Static method in class org.apache.beam.sdk.metrics.GaugeResult
empty() - Method in interface org.apache.beam.sdk.testing.PAssert.IterableAssert: Asserts that the iterable in question is empty.
empty() - Method in class org.apache.beam.sdk.testing.PAssert.PCollectionContentsAssert
empty(Coder<T>) - Static method in class org.apache.beam.sdk.transforms.Create: Returns a new Create.Values transform that produces an empty PCollection.
empty(TypeDescriptor<T>) - Static method in class org.apache.beam.sdk.transforms.Create: Returns a new Create.Values transform that produces an empty PCollection.
empty() - Static method in class org.apache.beam.sdk.transforms.join.CoGbkResult: Returns an empty CoGbkResult.
empty(Pipeline) - Static method in class org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple: Returns an empty KeyedPCollectionTuple<K> on the given pipeline.
empty(Pipeline) - Static method in class org.apache.beam.sdk.values.PCollectionList: Returns an empty PCollectionList that is part of the given Pipeline.
empty(Pipeline) - Static method in class org.apache.beam.sdk.values.PCollectionTuple: Returns an empty PCollectionTuple that is part of the given Pipeline.
empty() - Static method in class org.apache.beam.sdk.values.TupleTagList: Returns an empty TupleTagList.
emptyBatch() - Method in class org.apache.beam.runners.spark.io.CreateStream: Adds an empty batch.
EmptyCheckpointMark - Class in org.apache.beam.runners.spark.io: Passing null values to Spark's Java API may cause problems because of Guava preconditions.
EmptyListenersList() - Constructor for class org.apache.beam.runners.spark.SparkContextOptions.EmptyListenersList
enableAbandonedNodeEnforcement(boolean) - Method in class org.apache.beam.sdk.testing.TestPipeline: Enables the abandoned node detection.
enableAutoRunIfMissing(boolean) - Method in class org.apache.beam.sdk.testing.TestPipeline: If enabled, a pipeline.run() statement will be added automatically in case it is missing in the test.
encode(RandomAccessData, OutputStream) - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder
encode(RandomAccessData, OutputStream, Coder.Context) - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder
encode(T, OutputStream) - Method in class org.apache.beam.sdk.coders.AvroCoder
encode(BigDecimal, OutputStream) - Method in class org.apache.beam.sdk.coders.BigDecimalCoder
encode(BigDecimal, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.BigDecimalCoder
encode(Integer, OutputStream) - Method in class org.apache.beam.sdk.coders.BigEndianIntegerCoder
encode(Long, OutputStream) - Method in class org.apache.beam.sdk.coders.BigEndianLongCoder
encode(BigInteger, OutputStream) - Method in class org.apache.beam.sdk.coders.BigIntegerCoder
encode(BigInteger, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.BigIntegerCoder
encode(BitSet, OutputStream) - Method in class org.apache.beam.sdk.coders.BitSetCoder
encode(BitSet, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.BitSetCoder
encode(byte[], OutputStream) - Method in class org.apache.beam.sdk.coders.ByteArrayCoder
encode(byte[], OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.ByteArrayCoder
encode(Byte, OutputStream) - Method in class org.apache.beam.sdk.coders.ByteCoder
encode(T, OutputStream) - Method in class org.apache.beam.sdk.coders.Coder: Encodes the given value of type T onto the given output stream.
encode(T, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.Coder: Deprecated.
encode(T, OutputStream) - Method in class org.apache.beam.sdk.coders.DelegateCoder
encode(T, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.DelegateCoder
encode(Double, OutputStream) - Method in class org.apache.beam.sdk.coders.DoubleCoder
encode(ReadableDuration, OutputStream) - Method in class org.apache.beam.sdk.coders.DurationCoder
encode(Instant, OutputStream) - Method in class org.apache.beam.sdk.coders.InstantCoder
encode(IterableT, OutputStream) - Method in class org.apache.beam.sdk.coders.IterableLikeCoder
encode(KV<K, V>, OutputStream) - Method in class org.apache.beam.sdk.coders.KvCoder
encode(KV<K, V>, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.KvCoder
encode(T, OutputStream) - Method in class org.apache.beam.sdk.coders.LengthPrefixCoder
encode(Map<K, V>, OutputStream) - Method in class org.apache.beam.sdk.coders.MapCoder
encode(Map<K, V>, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.MapCoder
encode(T, OutputStream) - Method in class org.apache.beam.sdk.coders.NullableCoder
encode(T, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.NullableCoder
encode(T, OutputStream) - Method in class org.apache.beam.sdk.coders.SerializableCoder
encode(T, OutputStream) - Method in class org.apache.beam.sdk.coders.StringDelegateCoder
encode(T, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.StringDelegateCoder
encode(String, OutputStream) - Method in class org.apache.beam.sdk.coders.StringUtf8Coder
encode(String, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.StringUtf8Coder
encode(Integer, OutputStream) - Method in class org.apache.beam.sdk.coders.TextualIntegerCoder
encode(Integer, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.TextualIntegerCoder
encode(Integer, OutputStream) - Method in class org.apache.beam.sdk.coders.VarIntCoder
encode(Long, OutputStream) - Method in class org.apache.beam.sdk.coders.VarLongCoder
encode(Void, OutputStream) - Method in class org.apache.beam.sdk.coders.VoidCoder
encode(ByteString, OutputStream) - Method in class org.apache.beam.sdk.extensions.protobuf.ByteStringCoder
encode(ByteString, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.extensions.protobuf.ByteStringCoder
encode(T, OutputStream) - Method in class org.apache.beam.sdk.extensions.protobuf.ProtoCoder
encode(T, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.extensions.protobuf.ProtoCoder
encode(Message, OutputStream) - Method in class org.apache.beam.sdk.io.amqp.AmqpMessageCoder
encode(FileBasedSink.FileResult, OutputStream) - Method in class org.apache.beam.sdk.io.FileBasedSink.FileResultCoder
encode(TableDestination, OutputStream) - Method in class org.apache.beam.sdk.io.gcp.bigquery.TableDestinationCoder
encode(TableRow, OutputStream) - Method in class org.apache.beam.sdk.io.gcp.bigquery.TableRowJsonCoder
encode(TableRow, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.io.gcp.bigquery.TableRowJsonCoder
encode(PubsubMessage, OutputStream) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessagePayloadOnlyCoder
encode(PubsubMessage, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessagePayloadOnlyCoder
encode(PubsubMessage, OutputStream) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessageWithAttributesCoder
encode(PubsubMessage, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessageWithAttributesCoder
encode(T, OutputStream) - Method in class org.apache.beam.sdk.io.hadoop.WritableCoder
encode(KafkaRecord<K, V>, OutputStream) - Method in class org.apache.beam.sdk.io.kafka.KafkaRecordCoder
encode(KafkaRecord<K, V>, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.io.kafka.KafkaRecordCoder
encode(T, OutputStream) - Method in class org.apache.beam.sdk.io.xml.JAXBCoder
encode(T, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.io.xml.JAXBCoder
encode(CoGbkResult, OutputStream) - Method in class org.apache.beam.sdk.transforms.join.CoGbkResult.CoGbkResultCoder
encode(RawUnionValue, OutputStream) - Method in class org.apache.beam.sdk.transforms.join.UnionCoder
encode(RawUnionValue, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.transforms.join.UnionCoder
encode(GlobalWindow, OutputStream) - Method in class org.apache.beam.sdk.transforms.windowing.GlobalWindow.Coder
encode(IntervalWindow, OutputStream) - Method in class org.apache.beam.sdk.transforms.windowing.IntervalWindow.IntervalWindowCoder
encode(PaneInfo, OutputStream) - Method in class org.apache.beam.sdk.transforms.windowing.PaneInfo.PaneInfoCoder
encode(TimestampedValue<T>, OutputStream) - Method in class org.apache.beam.sdk.values.TimestampedValue.TimestampedValueCoder
encode(ValueInSingleWindow<T>, OutputStream) - Method in class org.apache.beam.sdk.values.ValueInSingleWindow.Coder
encode(ValueInSingleWindow<T>, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.values.ValueInSingleWindow.Coder
encode(ValueWithRecordId<ValueT>, OutputStream) - Method in class org.apache.beam.sdk.values.ValueWithRecordId.ValueWithRecordIdCoder
encode(ValueWithRecordId<ValueT>, OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.values.ValueWithRecordId.ValueWithRecordIdCoder
encodeAndOwn(byte[], OutputStream, Coder.Context) - Method in class org.apache.beam.sdk.coders.ByteArrayCoder: Encodes the provided value with the identical encoding to ByteArrayCoder.encode(byte[], java.io.OutputStream), but with optimizations that take ownership of the value.
ENCODING - Static variable in class org.apache.beam.runners.dataflow.util.PropertyNames
end() - Method in class org.apache.beam.sdk.transforms.windowing.IntervalWindow: Returns the end of this window, exclusive.
enterCompositeTransform(TransformHierarchy.Node) - Method in class org.apache.beam.runners.spark.SparkNativePipelineVisitor
enterCompositeTransform(TransformHierarchy.Node) - Method in class org.apache.beam.runners.spark.SparkRunner.Evaluator
enterCompositeTransform(TransformHierarchy.Node) - Method in class org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults
enterCompositeTransform(TransformHierarchy.Node) - Method in interface org.apache.beam.sdk.Pipeline.PipelineVisitor: Called for each composite transform after all topological predecessors have been visited but before any of its component transforms.
enterPipeline(Pipeline) - Method in class org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults
enterPipeline(Pipeline) - Method in interface org.apache.beam.sdk.Pipeline.PipelineVisitor: Called before visiting anything values or transforms, as many uses of a visitor require access to the Pipeline object itself.
entries() - Method in interface org.apache.beam.sdk.state.MapState: Returns an Iterable over the key-value pairs contained in this map.
ENVIRONMENT_VERSION_JOB_TYPE_KEY - Static variable in class org.apache.beam.runners.dataflow.util.PropertyNames
ENVIRONMENT_VERSION_MAJOR_KEY - Static variable in class org.apache.beam.runners.dataflow.util.PropertyNames
equal(T) - Static method in class org.apache.beam.sdk.transforms.Filter: Returns a PTransform that takes an input PCollection<T> and returns a PCollection<T> with elements that equals to a given value.
equals(Object) - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData
equals(Object) - Method in class org.apache.beam.runners.spark.io.EmptyCheckpointMark
equals(Object) - Method in class org.apache.beam.runners.spark.io.MicrobatchSource
equals(Object) - Method in class org.apache.beam.runners.spark.util.ByteArray
equals(Object) - Method in class org.apache.beam.sdk.coders.AtomicCoder: .
equals(Object) - Method in class org.apache.beam.sdk.coders.AvroCoder
equals(Object) - Method in class org.apache.beam.sdk.coders.Coder.Context: Deprecated.
equals(Object) - Method in class org.apache.beam.sdk.coders.DelegateCoder
equals(Object) - Method in class org.apache.beam.sdk.coders.SerializableCoder
equals(Object) - Method in class org.apache.beam.sdk.coders.StringDelegateCoder
equals(Object) - Method in class org.apache.beam.sdk.coders.StructuralByteArray
equals(Object) - Method in class org.apache.beam.sdk.coders.StructuredCoder
equals(Object) - Method in class org.apache.beam.sdk.extensions.gcp.storage.GcsResourceId
equals(Object) - Method in class org.apache.beam.sdk.extensions.protobuf.ProtoCoder
equals(Object) - Method in class org.apache.beam.sdk.io.gcp.bigquery.TableDestination
equals(Object) - Method in class org.apache.beam.sdk.io.hadoop.WritableCoder
equals(Object) - Method in class org.apache.beam.sdk.io.jms.JmsRecord
equals(Object) - Method in class org.apache.beam.sdk.io.kafka.KafkaRecord
equals(Object) - Method in class org.apache.beam.sdk.io.kinesis.KinesisRecord
equals(Object) - Method in class org.apache.beam.sdk.io.range.ByteKey
equals(Object) - Method in class org.apache.beam.sdk.io.range.ByteKeyRange
equals(Object) - Method in class org.apache.beam.sdk.io.xml.JAXBCoder
equals(Object) - Method in class org.apache.beam.sdk.testing.PAssert.PCollectionContentsAssert: Deprecated.
Object.equals(Object) is not supported on PAssert objects. If you meant to test object equality, use a variant of PAssert.PCollectionContentsAssert.containsInAnyOrder(T...) instead.
equals(Object) - Method in class org.apache.beam.sdk.testing.TestStream
equals(Object) - Method in class org.apache.beam.sdk.transforms.display.DisplayData
equals(Object) - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Path
equals(Object) - Method in class org.apache.beam.sdk.transforms.join.CoGbkResult.CoGbkResultCoder
equals(Object) - Method in class org.apache.beam.sdk.transforms.join.CoGbkResultSchema
equals(Object) - Method in class org.apache.beam.sdk.transforms.join.RawUnionValue
equals(Object) - Method in class org.apache.beam.sdk.transforms.splittabledofn.OffsetRange
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.AfterPane
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.AfterProcessingTime
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.AfterSynchronizedProcessingTime
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.AfterWatermark.FromEndOfWindow
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.FixedWindows
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.GlobalWindow
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.GlobalWindows
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.IntervalWindow
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.PaneInfo
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.Sessions
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.SlidingWindows
equals(Object) - Method in class org.apache.beam.sdk.transforms.windowing.Trigger
equals(Object) - Method in class org.apache.beam.sdk.values.KV
equals(Object) - Method in class org.apache.beam.sdk.values.PCollectionList
equals(Object) - Method in class org.apache.beam.sdk.values.PCollectionTuple
equals(Object) - Method in class org.apache.beam.sdk.values.PCollectionViews.ListViewFn: Deprecated.
equals(Object) - Method in class org.apache.beam.sdk.values.PCollectionViews.SimplePCollectionView
equals(Object) - Method in class org.apache.beam.sdk.values.TimestampedValue
equals(Object) - Method in class org.apache.beam.sdk.values.TupleTag
equals(Object) - Method in class org.apache.beam.sdk.values.TypeDescriptor: Two type descriptor are equal if and only if they represent the same type.
equals(Object) - Method in class org.apache.beam.sdk.values.TypeParameter
equals(Object) - Method in class org.apache.beam.sdk.values.ValueWithRecordId
equals(Object) - Method in class org.apache.beam.sdk.values.WindowingStrategy
estimateFractionForKey(ByteKey) - Method in class org.apache.beam.sdk.io.range.ByteKeyRange: Returns the fraction of this range [startKey, endKey) that is in the interval [startKey, key).
Evaluator(SparkPipelineTranslator, EvaluationContext) - Constructor for class org.apache.beam.runners.spark.SparkRunner.Evaluator
ever() - Static method in class org.apache.beam.sdk.transforms.windowing.Never: Returns a trigger which never fires.
every(Duration) - Method in class org.apache.beam.sdk.transforms.windowing.SlidingWindows: Returns a new SlidingWindows with the original size, that assigns timestamps into half-open intervals of the form [N * period, N * period + size), where 0 is the epoch.
ExecutorServiceFactory() - Constructor for class org.apache.beam.sdk.extensions.gcp.options.GcsOptions.ExecutorServiceFactory
expand(PCollection<ElemT>) - Method in class org.apache.beam.runners.apex.ApexRunner.CreateApexPCollectionView
expand(PCollection<ElemT>) - Method in class org.apache.beam.runners.dataflow.CreateDataflowView
expand(PCollection<? extends InputT>) - Method in class org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory.ParDoSingle
expand(PCollection<T>) - Method in class org.apache.beam.runners.spark.io.ConsoleIO.Write.Unbound
expand(PBegin) - Method in class org.apache.beam.runners.spark.io.CreateStream
expand(PInput) - Method in class org.apache.beam.runners.spark.util.SinglePrimitiveOutputPTransform
expand(PCollection<InputT>) - Method in class org.apache.beam.sdk.extensions.jackson.AsJsons
expand(PCollection<String>) - Method in class org.apache.beam.sdk.extensions.jackson.ParseJsons
expand(PCollection<KV<PrimaryKeyT, Iterable<KV<SecondaryKeyT, ValueT>>>>) - Method in class org.apache.beam.sdk.extensions.sorter.SortValues
expand(PBegin) - Method in class org.apache.beam.sdk.io.amqp.AmqpIO.Read
expand(PCollection<Message>) - Method in class org.apache.beam.sdk.io.amqp.AmqpIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.AvroIO.Read
expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.AvroIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.BoundedReadFromUnboundedSource
expand(PBegin) - Method in class org.apache.beam.sdk.io.cassandra.CassandraIO.Read
expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.cassandra.CassandraIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.Read
expand(PCollection<String>) - Method in class org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Read
expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write
expand(PCollection<KV<DestinationT, TableRow>>) - Method in class org.apache.beam.sdk.io.gcp.bigquery.CreateTables
expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.gcp.bigquery.PrepareWrite
expand(PCollection<KV<DestinationT, TableRow>>) - Method in class org.apache.beam.sdk.io.gcp.bigquery.StreamingInserts
expand(PCollection<KV<TableDestination, TableRow>>) - Method in class org.apache.beam.sdk.io.gcp.bigquery.StreamingWriteTables
expand() - Method in class org.apache.beam.sdk.io.gcp.bigquery.WriteResult
expand(PBegin) - Method in class org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Read
expand(PCollection<KV<ByteString, Iterable<Mutation>>>) - Method in class org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Read
expand(PBegin) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Read
expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Write
expand(PCollection<PubsubMessage>) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSink
expand(PBegin) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSource
expand(PBegin) - Method in class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.CreateTransaction
expand(PBegin) - Method in class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.Read
expand(PCollection<Mutation>) - Method in class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.Write
expand(PCollection<MutationGroup>) - Method in class org.apache.beam.sdk.io.gcp.spanner.SpannerIO.WriteGrouped
expand(PBegin) - Method in class org.apache.beam.sdk.io.GenerateSequence
expand(PBegin) - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.Read
expand(PBegin) - Method in class org.apache.beam.sdk.io.hbase.HBaseIO.Read
expand(PCollection<Mutation>) - Method in class org.apache.beam.sdk.io.hbase.HBaseIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.hcatalog.HCatalogIO.Read
expand(PCollection<HCatRecord>) - Method in class org.apache.beam.sdk.io.hcatalog.HCatalogIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.jdbc.JdbcIO.Read
expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.jdbc.JdbcIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Read
expand(PCollection<String>) - Method in class org.apache.beam.sdk.io.jms.JmsIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.kafka.KafkaIO.Read
expand(PBegin) - Method in class org.apache.beam.sdk.io.kafka.KafkaIO.TypedWithoutMetadata
expand(PCollection<KV<K, V>>) - Method in class org.apache.beam.sdk.io.kafka.KafkaIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.kinesis.KinesisIO.Read
expand(PBegin) - Method in class org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.Read
expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.mongodb.MongoDbIO.Read
expand(PCollection<Document>) - Method in class org.apache.beam.sdk.io.mongodb.MongoDbIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.mqtt.MqttIO.Read
expand(PCollection<byte[]>) - Method in class org.apache.beam.sdk.io.mqtt.MqttIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.Read.Bounded
expand(PBegin) - Method in class org.apache.beam.sdk.io.Read.Unbounded
expand(PBegin) - Method in class org.apache.beam.sdk.io.TextIO.Read
expand(PCollection<String>) - Method in class org.apache.beam.sdk.io.TextIO.Write
expand(PBegin) - Method in class org.apache.beam.sdk.io.TFRecordIO.Read
expand(PCollection<byte[]>) - Method in class org.apache.beam.sdk.io.TFRecordIO.Write
expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.WriteFiles
expand(PBegin) - Method in class org.apache.beam.sdk.io.xml.XmlIO.Read
expand(PCollection<T>) - Method in class org.apache.beam.sdk.io.xml.XmlIO.Write
expand(PCollection<SuccessOrFailure>) - Method in class org.apache.beam.sdk.testing.PAssert.DefaultConcludeTransform
expand(PCollection<T>) - Method in class org.apache.beam.sdk.testing.PAssert.GroupThenAssert
expand(PCollection<Iterable<T>>) - Method in class org.apache.beam.sdk.testing.PAssert.GroupThenAssertForSingleton
expand(PBegin) - Method in class org.apache.beam.sdk.testing.PAssert.OneSideInputAssert
expand(PBegin) - Method in class org.apache.beam.sdk.testing.TestStream
expand(PCollection<InputT>) - Method in class org.apache.beam.sdk.transforms.Combine.Globally
expand(PCollection<InputT>) - Method in class org.apache.beam.sdk.transforms.Combine.GloballyAsSingletonView
expand(PCollection<? extends KV<K, ? extends Iterable<InputT>>>) - Method in class org.apache.beam.sdk.transforms.Combine.GroupedValues
expand(PCollection<KV<K, InputT>>) - Method in class org.apache.beam.sdk.transforms.Combine.PerKey
expand(PCollection<KV<K, InputT>>) - Method in class org.apache.beam.sdk.transforms.Combine.PerKeyWithHotKeyFanout
expand(PBegin) - Method in class org.apache.beam.sdk.transforms.Create.TimestampedValues
expand(PBegin) - Method in class org.apache.beam.sdk.transforms.Create.Values
expand(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.Distinct
expand(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.Distinct.WithRepresentativeValues
expand(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.Filter
expand(PCollection<? extends InputT>) - Method in class org.apache.beam.sdk.transforms.FlatMapElements
expand(PCollection<? extends Iterable<T>>) - Method in class org.apache.beam.sdk.transforms.Flatten.Iterables
expand(PCollectionList<T>) - Method in class org.apache.beam.sdk.transforms.Flatten.PCollections
expand(PCollection<KV<K, V>>) - Method in class org.apache.beam.sdk.transforms.GroupByKey
expand(PCollection<KV<K, InputT>>) - Method in class org.apache.beam.sdk.transforms.GroupIntoBatches
expand(KeyedPCollectionTuple<K>) - Method in class org.apache.beam.sdk.transforms.join.CoGroupByKey
expand() - Method in class org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple: Expands the component PCollections, stripping off any tag-specific information.
expand(PCollection<? extends KV<K, ?>>) - Method in class org.apache.beam.sdk.transforms.Keys
expand(PCollection<KV<K, V>>) - Method in class org.apache.beam.sdk.transforms.KvSwap
expand(PCollection<? extends InputT>) - Method in class org.apache.beam.sdk.transforms.MapElements
expand(PCollection<? extends InputT>) - Method in class org.apache.beam.sdk.transforms.ParDo.MultiOutput
expand(PCollection<? extends InputT>) - Method in class org.apache.beam.sdk.transforms.ParDo.SingleOutput
expand(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.Partition
expand(InputT) - Method in class org.apache.beam.sdk.transforms.PTransform: Override this method to specify how this PTransform should be expanded on the given InputT.
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.AllMatches
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.Find
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.FindAll
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.FindKV
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.FindName
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.FindNameKV
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.Matches
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.MatchesKV
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.MatchesName
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.MatchesNameKV
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.ReplaceAll
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.ReplaceFirst
expand(PCollection<String>) - Method in class org.apache.beam.sdk.transforms.Regex.Split
expand(PCollection<KV<K, V>>) - Method in class org.apache.beam.sdk.transforms.Reshuffle: Deprecated.
expand(PCollection<? extends KV<?, V>>) - Method in class org.apache.beam.sdk.transforms.Values
expand(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.View.AsIterable
expand(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.View.AsList
expand(PCollection<KV<K, V>>) - Method in class org.apache.beam.sdk.transforms.View.AsMap
expand(PCollection<KV<K, V>>) - Method in class org.apache.beam.sdk.transforms.View.AsMultimap
expand(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.View.AsSingleton
expand(PCollection<ElemT>) - Method in class org.apache.beam.sdk.transforms.View.CreatePCollectionView
expand(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.windowing.Window.Assign
expand(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.windowing.Window
expand(PCollection<V>) - Method in class org.apache.beam.sdk.transforms.WithKeys
expand(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.WithTimestamps
expand() - Method in class org.apache.beam.sdk.values.PBegin
expand() - Method in class org.apache.beam.sdk.values.PCollection
expand() - Method in class org.apache.beam.sdk.values.PCollectionList
expand() - Method in class org.apache.beam.sdk.values.PCollectionTuple
expand() - Method in class org.apache.beam.sdk.values.PCollectionViews.SimplePCollectionView
expand() - Method in class org.apache.beam.sdk.values.PDone: A PDone contains no PValues.
expand() - Method in interface org.apache.beam.sdk.values.PInput: Expands this PInput into a list of its component output PValues.
expand() - Method in interface org.apache.beam.sdk.values.POutput: Expands this POutput into a list of its component output PValues.
expand() - Method in interface org.apache.beam.sdk.values.PValue: Deprecated.
Experimental - Annotation Type in org.apache.beam.sdk.annotations: Signifies that a public API (public class, method or field) is subject to incompatible changes, or even removal, in a future release.
Experimental.Kind - Enum in org.apache.beam.sdk.annotations: An enumeration of various kinds of experimental APIs.
extend(String) - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Path: Extend the path by appending a sub-component path.
extractOrderedList() - Method in class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique: Returns the values in the heap, ordered largest to smallest.
extractOutput(ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique) - Method in class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn
extractOutput() - Method in interface org.apache.beam.sdk.transforms.Combine.AccumulatingCombineFn.Accumulator: Returns the output value that is the result of combining all the input values represented by this accumulator.
extractOutput(AccumT) - Method in class org.apache.beam.sdk.transforms.Combine.AccumulatingCombineFn
extractOutput(double[]) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineDoubleFn
extractOutput(Combine.Holder<V>) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineFn
extractOutput(int[]) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineIntegerFn
extractOutput(long[]) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineLongFn
extractOutput(AccumT) - Method in class org.apache.beam.sdk.transforms.Combine.CombineFn: Returns the output value that is the result of combining all the input values represented by the given accumulator.
extractOutput(List<V>) - Method in class org.apache.beam.sdk.transforms.Combine.IterableCombineFn
extractOutput(Object[]) - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFn
extractOutput(Object[], CombineWithContext.Context) - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFnWithContext
extractOutput(AccumT, CombineWithContext.Context) - Method in class org.apache.beam.sdk.transforms.CombineWithContext.CombineFnWithContext: Returns the output value that is the result of combining all the input values represented by the given accumulator.
extractOutput(Top.BoundedHeap<KV<Integer, T>, SerializableComparator<KV<Integer, T>>>) - Method in class org.apache.beam.sdk.transforms.Sample.FixedSizedSampleFn

F

failure(PAssert.PAssertionSite, String) - Static method in class org.apache.beam.sdk.testing.SuccessOrFailure
failure(PAssert.PAssertionSite) - Static method in class org.apache.beam.sdk.testing.SuccessOrFailure
FAILURE_COUNTER - Static variable in class org.apache.beam.sdk.testing.PAssert
fewKeys() - Method in class org.apache.beam.sdk.transforms.GroupByKey: Returns whether it groups just few keys.
FileBasedReader(FileBasedSource<T>) - Constructor for class org.apache.beam.sdk.io.FileBasedSource.FileBasedReader: Subclasses should not perform IO operations at the constructor.
FileBasedSink<T> - Class in org.apache.beam.sdk.io: Abstract class for file-based output.
FileBasedSink(ValueProvider<ResourceId>, FileBasedSink.FilenamePolicy) - Constructor for class org.apache.beam.sdk.io.FileBasedSink: Construct a FileBasedSink with the given filename policy, producing uncompressed files.
FileBasedSink(ValueProvider<ResourceId>, FileBasedSink.FilenamePolicy, FileBasedSink.WritableByteChannelFactory) - Constructor for class org.apache.beam.sdk.io.FileBasedSink: Construct a FileBasedSink with the given filename policy and output channel type.
FileBasedSink.CompressionType - Enum in org.apache.beam.sdk.io: Directly supported file output compression types.
FileBasedSink.FilenamePolicy - Class in org.apache.beam.sdk.io: A naming policy for output files.
FileBasedSink.FilenamePolicy.Context - Class in org.apache.beam.sdk.io: Context used for generating a name based on shard number, and num shards.
FileBasedSink.FilenamePolicy.WindowedContext - Class in org.apache.beam.sdk.io: Context used for generating a name based on window, pane, shard number, and num shards.
FileBasedSink.FileResult - Class in org.apache.beam.sdk.io: Result of a single bundle write.
FileBasedSink.FileResultCoder - Class in org.apache.beam.sdk.io: A coder for FileBasedSink.FileResult objects.
FileBasedSink.WritableByteChannelFactory - Interface in org.apache.beam.sdk.io: Implementations create instances of WritableByteChannel used by FileBasedSink and related classes to allow decorating, or otherwise transforming, the raw data that would normally be written directly to the WritableByteChannel passed into FileBasedSink.WritableByteChannelFactory.create(WritableByteChannel).
FileBasedSink.WriteOperation<T> - Class in org.apache.beam.sdk.io: Abstract operation that manages the process of writing to FileBasedSink.
FileBasedSink.Writer<T> - Class in org.apache.beam.sdk.io: Abstract writer that writes a bundle to a FileBasedSink.
FileBasedSource<T> - Class in org.apache.beam.sdk.io: A common base class for all file-based Sources.
FileBasedSource(ValueProvider<String>, long) - Constructor for class org.apache.beam.sdk.io.FileBasedSource: Create a FileBaseSource based on a file or a file pattern specification.
FileBasedSource(MatchResult.Metadata, long, long, long) - Constructor for class org.apache.beam.sdk.io.FileBasedSource: Create a FileBasedSource based on a single file.
FileBasedSource.FileBasedReader<T> - Class in org.apache.beam.sdk.io: A reader that implements code common to readers of FileBasedSources.
FileBasedSource.Mode - Enum in org.apache.beam.sdk.io: A given FileBasedSource represents a file resource of one of these types.
FileChecksumMatcher - Class in org.apache.beam.sdk.testing: Matcher to verify file checksum in E2E test.
FileChecksumMatcher(String, String) - Constructor for class org.apache.beam.sdk.testing.FileChecksumMatcher: Constructor that uses default shard template.
FileChecksumMatcher(String, String, Pattern) - Constructor for class org.apache.beam.sdk.testing.FileChecksumMatcher: Constructor using a custom shard template.
FileChecksumMatcher(String, ShardedFile) - Constructor for class org.apache.beam.sdk.testing.FileChecksumMatcher: Constructor using an entirely custom ShardedFile implementation.
FilenamePolicy() - Constructor for class org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy
FileResult(ResourceId, int, BoundedWindow, PaneInfo) - Constructor for class org.apache.beam.sdk.io.FileBasedSink.FileResult
FileResultCoder(Coder<BoundedWindow>) - Constructor for class org.apache.beam.sdk.io.FileBasedSink.FileResultCoder
FileSystem<ResourceIdT extends ResourceId> - Class in org.apache.beam.sdk.io: File system interface in Beam.
FileSystem() - Constructor for class org.apache.beam.sdk.io.FileSystem
FileSystemRegistrar - Interface in org.apache.beam.sdk.io: A registrar that creates FileSystem instances from PipelineOptions.
FileSystems - Class in org.apache.beam.sdk.io: Clients facing FileSystem utility.
FileSystems() - Constructor for class org.apache.beam.sdk.io.FileSystems
Filter<T> - Class in org.apache.beam.sdk.transforms: PTransforms for filtering from a PCollection the elements satisfying a predicate, or satisfying an inequality with a given value based on the elements' natural ordering.
finalize(Iterable<FileBasedSink.FileResult>) - Method in class org.apache.beam.sdk.io.FileBasedSink.WriteOperation: Finalizes writing by copying temporary output files to their final location and optionally removing temporary files.
finalizeCheckpoint() - Method in class org.apache.beam.runners.spark.io.EmptyCheckpointMark
finalizeCheckpoint() - Method in class org.apache.beam.sdk.io.CountingSource.CounterMark
finalizeCheckpoint() - Method in class org.apache.beam.sdk.io.jms.JmsCheckpointMark: Acknowledge all outstanding message.
finalizeCheckpoint() - Method in class org.apache.beam.sdk.io.kafka.KafkaCheckpointMark
finalizeCheckpoint() - Method in interface org.apache.beam.sdk.io.UnboundedSource.CheckpointMark: Called by the system to signal that this checkpoint mark has been committed along with all the records which have been read from the UnboundedSource.UnboundedReader since the previous checkpoint was taken.
find(String) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.Find PTransform that checks if a portion of the line matches the Regex.
find(Pattern) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.Find PTransform that checks if a portion of the line matches the Regex.
find(String, int) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.Find PTransform that checks if a portion of the line matches the Regex.
find(Pattern, int) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.Find PTransform that checks if a portion of the line matches the Regex.
find(String, String) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.FindName PTransform that checks if a portion of the line matches the Regex.
find(Pattern, String) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.FindName PTransform that checks if a portion of the line matches the Regex.
Find(Pattern, int) - Constructor for class org.apache.beam.sdk.transforms.Regex.Find
findAll(String) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.FindAll PTransform that checks if a portion of the line matches the Regex.
findAll(Pattern) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.FindAll PTransform that checks if a portion of the line matches the Regex.
FindAll(Pattern) - Constructor for class org.apache.beam.sdk.transforms.Regex.FindAll
findKV(String, int, int) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.FindKV PTransform that checks if a portion of the line matches the Regex.
findKV(Pattern, int, int) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.FindKV PTransform that checks if a portion of the line matches the Regex.
findKV(String, String, String) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.FindNameKV PTransform that checks if a portion of the line matches the Regex.
findKV(Pattern, String, String) - Static method in class org.apache.beam.sdk.transforms.Regex: Returns a Regex.FindNameKV PTransform that checks if a portion of the line matches the Regex.
FindKV(Pattern, int, int) - Constructor for class org.apache.beam.sdk.transforms.Regex.FindKV
FindName(Pattern, String) - Constructor for class org.apache.beam.sdk.transforms.Regex.FindName
FindNameKV(Pattern, String, String) - Constructor for class org.apache.beam.sdk.transforms.Regex.FindNameKV
finishBundle() - Method in class org.apache.beam.runners.flink.metrics.DoFnRunnerWithMetricsUpdate
finishBundle() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Write.PubsubBoundedWriter
finishBundle() - Method in class org.apache.beam.sdk.transforms.DoFnTester: Calls the DoFn.FinishBundle method of the DoFn under test.
FinishBundleContext() - Constructor for class org.apache.beam.sdk.transforms.DoFn.FinishBundleContext
finishSpecifying() - Method in interface org.apache.beam.sdk.state.StateSpec: For internal use only; no backwards-compatibility guarantees.
finishSpecifying(PInput, PTransform<?, ?>) - Method in class org.apache.beam.sdk.values.PCollection: After building, finalizes this PValue to make it ready for running.
finishSpecifying(PInput, PTransform<?, ?>) - Method in interface org.apache.beam.sdk.values.PValue: After building, finalizes this PValue to make it ready for being used as an input to a PTransform.
finishSpecifying(PInput, PTransform<?, ?>) - Method in class org.apache.beam.sdk.values.PValueBase
finishSpecifyingOutput(String, PInput, PTransform<?, ?>) - Method in class org.apache.beam.sdk.io.gcp.bigquery.WriteResult
finishSpecifyingOutput(String, PInput, PTransform<?, ?>) - Method in class org.apache.beam.sdk.values.PCollection
finishSpecifyingOutput(String, PInput, PTransform<?, ?>) - Method in class org.apache.beam.sdk.values.PCollectionList
finishSpecifyingOutput(String, PInput, PTransform<?, ?>) - Method in class org.apache.beam.sdk.values.PCollectionTuple
finishSpecifyingOutput(String, PInput, PTransform<?, ?>) - Method in class org.apache.beam.sdk.values.PDone: Does nothing; there is nothing to finish specifying.
finishSpecifyingOutput(String, PInput, PTransform<?, ?>) - Method in interface org.apache.beam.sdk.values.POutput: As part of applying the producing PTransform, finalizes this output to make it ready for being used as an input and for running.
finishSpecifyingOutput(String, PInput, PTransform<?, ?>) - Method in class org.apache.beam.sdk.values.PValueBase
finishWrite() - Method in class org.apache.beam.sdk.io.FileBasedSink.Writer: Called after all calls to FileBasedSink.Writer.writeHeader(), FileBasedSink.Writer.write(T) and FileBasedSink.Writer.writeFooter().
fixDefaults() - Method in class org.apache.beam.sdk.values.WindowingStrategy: Fixes all the defaults so that equals can be used to check that two strategies are the same, regardless of the state of "defaulted-ness".
fixedSizeGlobally(int) - Static method in class org.apache.beam.sdk.transforms.Sample: Returns a PTransform that takes a PCollection<T>, selects sampleSize elements, uniformly at random, and returns a PCollection<Iterable<T>> containing the selected elements.
fixedSizePerKey(int) - Static method in class org.apache.beam.sdk.transforms.Sample: Returns a PTransform that takes an input PCollection<KV<K, V>> and returns a PCollection<KV<K, Iterable<V>>> that contains an output element mapping each distinct key in the input PCollection to a sample of sampleSize values associated with that key in the input PCollection, taken uniformly at random.
FixedWindows - Class in org.apache.beam.sdk.transforms.windowing: A WindowFn that windows values into fixed-size timestamp-based windows.
FlatMapElements<InputT,OutputT> - Class in org.apache.beam.sdk.transforms: PTransforms for mapping a simple function that returns iterables over the elements of a PCollection and merging the results.
Flatten - Class in org.apache.beam.sdk.transforms: Flatten<T> takes multiple PCollection<T>s bundled into a PCollectionList<T> and returns a single PCollection<T> containing all the elements in all the input PCollections.
Flatten() - Constructor for class org.apache.beam.sdk.transforms.Flatten
Flatten.Iterables<T> - Class in org.apache.beam.sdk.transforms: FlattenIterables<T> takes a PCollection<Iterable<T>> and returns a PCollection<T> that contains all the elements from each iterable.
Flatten.PCollections<T> - Class in org.apache.beam.sdk.transforms: A PTransform that flattens a PCollectionList into a PCollection containing all the elements of all the PCollections in its input.
FlattenWithHeterogeneousCoders - Interface in org.apache.beam.sdk.testing: Category tag for tests that use a Flatten where the input PCollectionList contains PCollections heterogeneous coders.
FlinkDetachedRunnerResult - Class in org.apache.beam.runners.flink: Result of a detached execution of a Pipeline with Flink.
FlinkMetricContainer - Class in org.apache.beam.runners.flink.metrics: Helper class for holding a MetricsContainerImpl and forwarding Beam metrics to Flink accumulators and metrics.
FlinkMetricContainer(RuntimeContext) - Constructor for class org.apache.beam.runners.flink.metrics.FlinkMetricContainer
FlinkMetricContainer.FlinkDistributionGauge - Class in org.apache.beam.runners.flink.metrics: Flink Gauge for DistributionResult.
FlinkMetricContainer.FlinkGauge - Class in org.apache.beam.runners.flink.metrics: Flink Gauge for GaugeResult.
FlinkPipelineOptions - Interface in org.apache.beam.runners.flink: Options which can be used to configure a Flink PipelineRunner.
FlinkRunner - Class in org.apache.beam.runners.flink: A PipelineRunner that executes the operations in the pipeline by first translating them to a Flink Plan and then executing them either locally or on a Flink cluster, depending on the configuration.
FlinkRunnerRegistrar - Class in org.apache.beam.runners.flink: AutoService registrar - will register FlinkRunner and FlinkOptions as possible pipeline runner services.
FlinkRunnerRegistrar.Options - Class in org.apache.beam.runners.flink: Pipeline options registrar.
FlinkRunnerRegistrar.Runner - Class in org.apache.beam.runners.flink: Pipeline runner registrar.
FlinkRunnerResult - Class in org.apache.beam.runners.flink: Result of executing a Pipeline with Flink.
FlinkTransformOverrides - Class in org.apache.beam.runners.flink: PTransform overrides for Flink runner.
FlinkTransformOverrides() - Constructor for class org.apache.beam.runners.flink.FlinkTransformOverrides
floats() - Static method in class org.apache.beam.sdk.values.TypeDescriptors: The TypeDescriptor for Float.
forBoolean(Boolean) - Static method in class org.apache.beam.runners.dataflow.util.CloudObject: Constructs a CloudObject representing the given value.
forClass(Class<?>) - Static method in class org.apache.beam.runners.dataflow.util.CloudObject: Constructs a CloudObject to be used for serializing an instance of the supplied class for transport via the Dataflow API.
forClassName(String) - Static method in class org.apache.beam.runners.dataflow.util.CloudObject: Constructs a CloudObject to be used for serializing data to be deserialized using the supplied class name the supplied class name for transport via the Dataflow API.
forCoder(TypeDescriptor<?>, Coder<?>) - Static method in class org.apache.beam.sdk.coders.CoderProviders: Creates a CoderProvider that always returns the given coder for the specified type.
forever(Trigger) - Static method in class org.apache.beam.sdk.transforms.windowing.Repeatedly: Create a composite trigger that repeatedly executes the trigger repeated, firing each time it fires and ignoring any indications to finish.
forFloat(Float) - Static method in class org.apache.beam.runners.dataflow.util.CloudObject: Constructs a CloudObject representing the given value.
forFloat(Double) - Static method in class org.apache.beam.runners.dataflow.util.CloudObject: Constructs a CloudObject representing the given value.
forFn(DoFn<InputT, OutputT>, WindowingStrategy<?, ?>, Iterable<PCollectionView<?>>, Coder<InputT>, long, Map<Long, TupleTag<?>>) - Static method in class org.apache.beam.runners.dataflow.util.DoFnInfo: Creates a DoFnInfo for the given DoFn.
forInteger(Long) - Static method in class org.apache.beam.runners.dataflow.util.CloudObject: Constructs a CloudObject representing the given value.
forInteger(Integer) - Static method in class org.apache.beam.runners.dataflow.util.CloudObject: Constructs a CloudObject representing the given value.
forKnownType(Object) - Static method in class org.apache.beam.runners.dataflow.util.CloudObject: Constructs a CloudObject representing the given value of a well-known cloud object type.
FORMAT - Static variable in class org.apache.beam.runners.dataflow.util.PropertyNames
formatTimestamp(Instant) - Static method in class org.apache.beam.sdk.transforms.windowing.BoundedWindow: Formats a Instant timestamp with additional Beam-specific metadata, such as indicating whether the timestamp is the end of the global window or one of the distinguished values BoundedWindow.TIMESTAMP_MIN_VALUE or BoundedWindow.TIMESTAMP_MIN_VALUE.
forRegistry(MetricRegistry) - Static method in class org.apache.beam.runners.spark.metrics.WithMetricsSupport
forStreamFromSources(List<Integer>, Map<Integer, GlobalWatermarkHolder.SparkWatermarks>) - Static method in class org.apache.beam.runners.spark.stateful.SparkTimerInternals: Build the TimerInternals according to the feeding streams.
forString(String) - Static method in class org.apache.beam.runners.dataflow.util.CloudObject: Constructs a CloudObject representing the given value.
from(Map<String, String>) - Static method in class org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.WorkerLogLevelOverrides: Expects a map keyed by logger Names with values representing Levels.
from(String) - Method in class org.apache.beam.sdk.io.AvroIO.Read: Reads from the given filename or filepattern.
from(String) - Static method in class org.apache.beam.sdk.io.AvroSource: Creates an AvroSource that reads from the given file name or pattern ("glob").
from(FileBasedSource<T>) - Static method in class org.apache.beam.sdk.io.CompressedSource: Creates a CompressedSource from an underlying FileBasedSource.
from(String) - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Read: Reads a BigQuery table specified as "[project_id]:[dataset_id].[table_id]" or "[dataset_id].[table_id]" for tables within the current project.
from(ValueProvider<String>) - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Read: Same as from(String), but with a ValueProvider.
from(TableReference) - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Read: Read from table specified by a TableReference.
from(long) - Static method in class org.apache.beam.sdk.io.GenerateSequence: Specifies the minimum number to generate (inclusive).
from(String, InitialPositionInStream) - Method in class org.apache.beam.sdk.io.kinesis.KinesisIO.Read: Specify reading from streamName at some initial position.
from(String, Instant) - Method in class org.apache.beam.sdk.io.kinesis.KinesisIO.Read: Specify reading from streamName beginning at given Instant.
from(BoundedSource<T>) - Method in class org.apache.beam.sdk.io.Read.Builder: Returns a new Read.Bounded PTransform reading from the given BoundedSource.
from(UnboundedSource<T, ?>) - Method in class org.apache.beam.sdk.io.Read.Builder: Returns a new Read.Unbounded PTransform reading from the given UnboundedSource.
from(BoundedSource<T>) - Static method in class org.apache.beam.sdk.io.Read: Returns a new Read.Bounded PTransform reading from the given BoundedSource.
from(UnboundedSource<T, ?>) - Static method in class org.apache.beam.sdk.io.Read: Returns a new Read.Unbounded PTransform reading from the given UnboundedSource.
from(String) - Method in class org.apache.beam.sdk.io.TextIO.Read: Reads text files that reads from the file(s) with the given filename or filename pattern.
from(ValueProvider<String>) - Method in class org.apache.beam.sdk.io.TextIO.Read: Same as from(filepattern), but accepting a ValueProvider.
from(String) - Method in class org.apache.beam.sdk.io.TFRecordIO.Read: Returns a transform for reading TFRecord files that reads from the file(s) with the given filename or filename pattern.
from(ValueProvider<String>) - Method in class org.apache.beam.sdk.io.TFRecordIO.Read: Same as from(filepattern), but accepting a ValueProvider.
from(String) - Method in class org.apache.beam.sdk.io.xml.XmlIO.Read: Reads a single XML file or a set of XML files defined by a Java "glob" file pattern.
from(HasDisplayData) - Static method in class org.apache.beam.sdk.transforms.display.DisplayData: Collect the DisplayData from a component.
fromArgs(String...) - Method in class org.apache.beam.sdk.options.PipelineOptionsFactory.Builder: Sets the command line arguments to parse when constructing the PipelineOptions.
fromArgs(String...) - Static method in class org.apache.beam.sdk.options.PipelineOptionsFactory: Sets the command line arguments to parse when constructing the PipelineOptions.
fromByteArray(byte[], Coder<T>) - Static method in class org.apache.beam.runners.spark.coders.CoderHelpers: Utility method for deserializing a byte array using the specified coder.
fromByteArrays(Collection<byte[]>, Coder<T>) - Static method in class org.apache.beam.runners.spark.coders.CoderHelpers: Utility method for deserializing a Iterable of byte arrays using the specified coder.
fromByteFunction(Coder<T>) - Static method in class org.apache.beam.runners.spark.coders.CoderHelpers: A function wrapper for converting a byte array to an object.
fromByteFunction(Coder<K>, Coder<V>) - Static method in class org.apache.beam.runners.spark.coders.CoderHelpers: A function wrapper for converting a byte array pair to a key-value pair.
fromByteFunctionIterable(Coder<K>, Coder<V>) - Static method in class org.apache.beam.runners.spark.coders.CoderHelpers: A function wrapper for converting a byte array pair to a key-value pair, where values are Iterable.
fromCloudDuration(String) - Static method in class org.apache.beam.runners.dataflow.util.TimeUtil: Converts a Dataflow API duration string into a Duration.
fromCloudObject(CloudObject) - Method in interface org.apache.beam.runners.dataflow.util.CloudObjectTranslator: Converts back into the original object from a provided CloudObject.
fromCloudTime(String) - Static method in class org.apache.beam.runners.dataflow.util.TimeUtil: Converts a time value received via the Dataflow API into the corresponding Instant.
fromFile(File, boolean) - Static method in class org.apache.beam.sdk.io.LocalResources
fromOptions(PipelineOptions) - Static method in class org.apache.beam.runners.apex.ApexRunner
fromOptions(PipelineOptions) - Static method in class org.apache.beam.runners.apex.TestApexRunner
fromOptions(DataflowPipelineOptions) - Static method in class org.apache.beam.runners.dataflow.DataflowPipelineTranslator: Constructs a translator from the provided options.
fromOptions(PipelineOptions) - Static method in class org.apache.beam.runners.dataflow.DataflowRunner: Construct a runner from the provided options.
fromOptions(PipelineOptions) - Static method in class org.apache.beam.runners.dataflow.TestDataflowRunner: Constructs a runner from the provided options.
fromOptions(PipelineOptions) - Static method in class org.apache.beam.runners.dataflow.util.GcsStager
fromOptions(PipelineOptions) - Static method in class org.apache.beam.runners.direct.DirectRunner: Construct a DirectRunner from the provided options.
fromOptions(PipelineOptions) - Static method in class org.apache.beam.runners.flink.FlinkRunner: Construct a runner from the provided options.
fromOptions(PipelineOptions) - Static method in class org.apache.beam.runners.flink.TestFlinkRunner
fromOptions(PipelineOptions) - Static method in class org.apache.beam.runners.spark.SparkRunner: Creates and returns a new SparkRunner with specified options.
fromOptions(PipelineOptions) - Static method in class org.apache.beam.runners.spark.SparkRunnerDebugger
fromOptions(PipelineOptions) - Static method in class org.apache.beam.runners.spark.TestSparkRunner
fromOptions(PipelineOptions) - Static method in class org.apache.beam.sdk.extensions.gcp.auth.GcpCredentialFactory
fromOptions(PipelineOptions) - Static method in class org.apache.beam.sdk.extensions.gcp.auth.NoopCredentialFactory
fromOptions(PipelineOptions) - Method in class org.apache.beam.sdk.extensions.gcp.storage.GcsFileSystemRegistrar
fromOptions(PipelineOptions) - Static method in class org.apache.beam.sdk.extensions.gcp.storage.GcsPathValidator
fromOptions(PipelineOptions) - Static method in class org.apache.beam.sdk.extensions.gcp.storage.NoopPathValidator
fromOptions(PipelineOptions) - Method in interface org.apache.beam.sdk.io.FileSystemRegistrar: Create zero or more filesystems from the given PipelineOptions.
fromOptions(PipelineOptions) - Method in class org.apache.beam.sdk.io.hdfs.HadoopFileSystemRegistrar
fromOptions(PipelineOptions) - Method in class org.apache.beam.sdk.io.LocalFileSystemRegistrar
fromOptions(PipelineOptions) - Static method in class org.apache.beam.sdk.PipelineRunner: Constructs a runner from the provided PipelineOptions.
fromOptions(PipelineOptions) - Static method in class org.apache.beam.sdk.testing.CrashingRunner
fromOptions(PipelineOptions) - Static method in class org.apache.beam.sdk.testing.TestPipeline
fromPath(String) - Static method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubSubscription: Creates a class representing a Pub/Sub subscription from the specified subscription path.
fromPath(String) - Static method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubTopic: Creates a class representing a Cloud Pub/Sub topic from the specified topic path.
fromPath(Path, boolean) - Static method in class org.apache.beam.sdk.io.LocalResources
fromQuery(String) - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Read: Reads results received after executing the given query.
fromQuery(ValueProvider<String>) - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Read: Same as fromQuery(String), but with a ValueProvider.
fromRawEvents(Coder<T>, List<TestStream.Event<T>>) - Static method in class org.apache.beam.sdk.testing.TestStream: For internal use only.
fromSerializableFunctionWithOutputType(SerializableFunction<InputT, OutputT>, TypeDescriptor<OutputT>) - Static method in class org.apache.beam.sdk.transforms.SimpleFunction
fromSpec(Map<String, Object>) - Static method in class org.apache.beam.runners.dataflow.util.CloudObject: Constructs a CloudObject by copying the supplied serialized object spec, which must represent an SDK object serialized for transport via the Dataflow API.
fromStaticMethods(Class<?>, Class<?>) - Static method in class org.apache.beam.sdk.coders.CoderProviders: Creates a CoderProvider from a class's static <T> Coder<T> of(TypeDescriptor<T>, List<Coder<?>>) method.
fromString(String, boolean) - Static method in class org.apache.beam.sdk.io.LocalResources
fromString(ValueProvider<String>, boolean) - Static method in class org.apache.beam.sdk.io.LocalResources
fromSubscription(String) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Read: Reads from the given subscription.
fromSubscription(ValueProvider<String>) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Read: Like subscription() but with a ValueProvider.
fromTopic(String) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Read: Creates and returns a transform for reading from a Cloud Pub/Sub topic.
fromTopic(ValueProvider<String>) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Read: Like topic() but with a ValueProvider.
fullOuterJoin(PCollection<KV<K, V1>>, PCollection<KV<K, V2>>, V1, V2) - Static method in class org.apache.beam.sdk.extensions.joinlibrary.Join: Full Outer Join of two collections of KV elements.

G

Gauge - Interface in org.apache.beam.sdk.metrics

A metric that reports the latest value out of reported values.

gauge(String, String) - Static method in class org.apache.beam.sdk.metrics.Metrics

Create a metric that can have its new value set, and is aggregated by taking the last reported value.

gauge(Class<?>, String) - Static method in class org.apache.beam.sdk.metrics.Metrics

Create a metric that can have its new value set, and is aggregated by taking the last reported value.

GaugeResult - Class in org.apache.beam.sdk.metrics

The result of a Gauge metric.

GaugeResult() - Constructor for class org.apache.beam.sdk.metrics.GaugeResult

GaugeResult.EmptyGaugeResult - Class in org.apache.beam.sdk.metrics

Empty GaugeResult, representing no values reported.

gauges() - Method in interface org.apache.beam.sdk.metrics.MetricQueryResults

Return the metric results for the gauges that matched the filter.

GcpCredentialFactory - Class in org.apache.beam.sdk.extensions.gcp.auth

Construct an oauth credential to be used by the SDK and the SDK workers.

GcpCredentialFactory() - Constructor for class org.apache.beam.sdk.extensions.gcp.auth.GcpCredentialFactory

GcpIoPipelineOptionsRegistrar - Class in org.apache.beam.sdk.io.gcp.common

A registrar containing the default GCP options.

GcpIoPipelineOptionsRegistrar() - Constructor for class org.apache.beam.sdk.io.gcp.common.GcpIoPipelineOptionsRegistrar

GcpOptions - Interface in org.apache.beam.sdk.extensions.gcp.options

Options used to configure Google Cloud Platform specific options such as the project and credentials.

GcpOptions.DefaultProjectFactory - Class in org.apache.beam.sdk.extensions.gcp.options

Attempts to infer the default project based upon the environment this application is executing within.

GcpOptions.GcpTempLocationFactory - Class in org.apache.beam.sdk.extensions.gcp.options

Returns PipelineOptions.getTempLocation() as the default GCP temp location.

GcpOptions.GcpUserCredentialsFactory - Class in org.apache.beam.sdk.extensions.gcp.options

Attempts to load the GCP credentials.

GcpPipelineOptionsRegistrar - Class in org.apache.beam.sdk.extensions.gcp.options

A registrar containing the default GCP options.

GcpPipelineOptionsRegistrar() - Constructor for class org.apache.beam.sdk.extensions.gcp.options.GcpPipelineOptionsRegistrar

GcpTempLocationFactory() - Constructor for class org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpTempLocationFactory

GcpUserCredentialsFactory() - Constructor for class org.apache.beam.sdk.extensions.gcp.options.GcpOptions.GcpUserCredentialsFactory

GcsCreateOptions - Class in org.apache.beam.sdk.extensions.gcp.storage

An abstract class that contains common configuration options for creating resources.

GcsCreateOptions() - Constructor for class org.apache.beam.sdk.extensions.gcp.storage.GcsCreateOptions

GcsCreateOptions.Builder - Class in org.apache.beam.sdk.extensions.gcp.storage

A builder for GcsCreateOptions.

GcsFileSystemRegistrar - Class in org.apache.beam.sdk.extensions.gcp.storage

AutoService registrar for the GcsFileSystem.

GcsFileSystemRegistrar() - Constructor for class org.apache.beam.sdk.extensions.gcp.storage.GcsFileSystemRegistrar

GcsOptions - Interface in org.apache.beam.sdk.extensions.gcp.options

Options used to configure Google Cloud Storage.

GcsOptions.ExecutorServiceFactory - Class in org.apache.beam.sdk.extensions.gcp.options

Returns the default ExecutorService to use within the Apache Beam SDK.

GcsOptions.PathValidatorFactory - Class in org.apache.beam.sdk.extensions.gcp.options

Creates a PathValidator object using the class specified in GcsOptions.getPathValidatorClass().

GcsPathValidator - Class in org.apache.beam.sdk.extensions.gcp.storage

GCP implementation of PathValidator.

GcsResourceId - Class in org.apache.beam.sdk.extensions.gcp.storage

ResourceId implementation for Google Cloud Storage.

GcsStager - Class in org.apache.beam.runners.dataflow.util

Utility class for staging files to GCS.

gcsUploadBufferSizeBytes() - Method in class org.apache.beam.sdk.extensions.gcp.storage.GcsCreateOptions

The buffer size (in bytes) to use when uploading files to GCS.

GenerateSequence - Class in org.apache.beam.sdk.io

A PTransform that produces longs starting from the given value, and either up to the given limit or until Long.MAX_VALUE / until the given time elapses.

GenerateSequence() - Constructor for class org.apache.beam.sdk.io.GenerateSequence

get() - Static method in class org.apache.beam.runners.spark.io.EmptyCheckpointMark

get(Long) - Static method in class org.apache.beam.runners.spark.util.GlobalWatermarkHolder

Returns the Broadcast containing the GlobalWatermarkHolder.SparkWatermarks mapped to their sources.

get(PCollectionView<T>, BoundedWindow) - Method in class org.apache.beam.runners.spark.util.SparkSideInputReader

get() - Method in class org.apache.beam.sdk.io.hadoop.SerializableConfiguration

get() - Method in interface org.apache.beam.sdk.options.ValueProvider

Return the value wrapped by this ValueProvider.

get() - Method in class org.apache.beam.sdk.options.ValueProvider.NestedValueProvider

get() - Method in class org.apache.beam.sdk.options.ValueProvider.RuntimeValueProvider

get() - Method in class org.apache.beam.sdk.options.ValueProvider.StaticValueProvider

get(K) - Method in interface org.apache.beam.sdk.state.MapState

A deferred lookup.

get(TupleTag<V>) - Method in class org.apache.beam.sdk.transforms.CombineFns.CoCombineResult

Returns the value represented by the given TupleTag.

get(int) - Method in class org.apache.beam.sdk.values.PCollectionList

Returns the PCollection at the given index (origin zero).

get(TupleTag<T>) - Method in class org.apache.beam.sdk.values.PCollectionTuple

Returns the PCollection associated with the given TupleTag in this PCollectionTuple.

get(int) - Method in class org.apache.beam.sdk.values.TupleTagList

Returns the TupleTag at the given index (origin zero).

getAccum() - Method in interface org.apache.beam.sdk.state.CombiningState

Read the merged accumulator for this state cell.

getAccumulatorCoder(CoderRegistry, Coder<T>) - Method in class org.apache.beam.sdk.transforms.ApproximateQuantiles.ApproximateQuantilesCombineFn

getAccumulatorCoder(CoderRegistry, Coder<T>) - Method in class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn

getAccumulatorCoder(CoderRegistry, Coder<Double>) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineDoubleFn

getAccumulatorCoder(CoderRegistry, Coder<V>) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineFn

getAccumulatorCoder(CoderRegistry, Coder<Integer>) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineIntegerFn

getAccumulatorCoder(CoderRegistry, Coder<Long>) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineLongFn

getAccumulatorCoder(CoderRegistry, Coder<InputT>) - Method in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn

Returns the Coder to use for accumulator AccumT values, or null if it is not able to be inferred.

getAccumulatorCoder(CoderRegistry, Coder<DataT>) - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFn

getAccumulatorCoder(CoderRegistry, Coder<DataT>) - Method in class org.apache.beam.sdk.transforms.CombineFns.ComposedCombineFnWithContext

getAccumulatorCoder(CoderRegistry, Coder<T>) - Method in class org.apache.beam.sdk.transforms.Sample.FixedSizedSampleFn

getAccumulatorCoder(CoderRegistry, Coder<T>) - Method in class org.apache.beam.sdk.transforms.Top.TopCombineFn

getAdaptedSource() - Method in class org.apache.beam.sdk.io.BoundedReadFromUnboundedSource

Returns an adapted BoundedSource wrapping the underlying UnboundedSource, with the specified bounds on number of records and read time.

getAdditionalInputs() - Method in class org.apache.beam.sdk.transforms.Combine.Globally

Returns the side inputs of this Combine, tagged with the tag of the PCollectionView.

getAdditionalInputs() - Method in class org.apache.beam.sdk.transforms.Combine.PerKey

Returns the side inputs of this Combine, tagged with the tag of the PCollectionView.

getAdditionalInputs() - Method in class org.apache.beam.sdk.transforms.ParDo.MultiOutput

Returns the side inputs of this ParDo, tagged with the tag of the PCollectionView.

getAdditionalInputs() - Method in class org.apache.beam.sdk.transforms.ParDo.SingleOutput

Returns the side inputs of this ParDo, tagged with the tag of the PCollectionView.

getAdditionalInputs() - Method in class org.apache.beam.sdk.transforms.PTransform

Returns all PValues that are consumed as inputs to this PTransform that are independent of the expansion of the InputT within PTransform.expand(PInput).

getAdditionalOutputTags() - Method in class org.apache.beam.sdk.transforms.ParDo.MultiOutput

getAlgorithm() - Method in enum org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType

Returns the string representation of this type.

getAll(TupleTag<V>) - Method in class org.apache.beam.sdk.transforms.join.CoGbkResult

Returns the values from the table represented by the given TupleTag<V> as an Iterable<V> (which may be empty if there are no results).

getAll() - Method in class org.apache.beam.sdk.values.PCollectionList

Returns an immutable List of all the PCollections in this PCollectionList.

getAll() - Method in class org.apache.beam.sdk.values.PCollectionTuple

Returns an immutable Map from TupleTag to corresponding PCollection, for all the members of this PCollectionTuple.

getAll() - Method in class org.apache.beam.sdk.values.TupleTagList

Returns an immutable List of all the TupleTags in this TupleTagList.

getAllowedLateness() - Method in class org.apache.beam.sdk.values.WindowingStrategy

getAllowedTimestampSkew() - Method in class org.apache.beam.sdk.transforms.DoFn

Deprecated.
This method permits a DoFn to emit elements behind the watermark. These elements are considered late, and if behind the allowed lateness of a downstream PCollection may be silently dropped. See https://issues.apache.org/jira/browse/BEAM-644 for details on a replacement.

getAllowedTimestampSkew() - Method in class org.apache.beam.sdk.transforms.WithTimestamps

Deprecated.
This method permits a to elements to be emitted behind the watermark. These elements are considered late, and if behind the allowed lateness of a downstream PCollection may be silently dropped. See https://issues.apache.org/jira/browse/BEAM-644 for details on a replacement.

getApexDAG() - Method in class org.apache.beam.runners.apex.ApexRunnerResult

Return the DAG executed by the pipeline.

getApexLauncher() - Method in class org.apache.beam.runners.apex.ApexYarnLauncher.LaunchParams

getApiRootUrl() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions

The root URL for the Dataflow API.

getApplicationName() - Method in interface org.apache.beam.runners.apex.ApexPipelineOptions

getAppliedFn(CoderRegistry, Coder<? extends KV<K, ? extends Iterable<InputT>>>, WindowingStrategy<?, ?>) - Method in class org.apache.beam.sdk.transforms.Combine.GroupedValues

Returns the Combine.CombineFn bound to its coders.

getAppName() - Method in interface org.apache.beam.sdk.options.ApplicationNameOptions

Name of application, for display purposes.

getApproximateArrivalTimestamp() - Method in class org.apache.beam.sdk.io.kinesis.KinesisRecord

getArgumentTypes(Method) - Method in class org.apache.beam.sdk.values.TypeDescriptor

Returns a list of argument types for the given method, which must be a part of the class.

getAttribute(String) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessage

Returns the given attribute value.

getAttributeMap() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessage

Returns the full map of attributes.

getAutoscalingAlgorithm() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions

[Experimental] The autoscaling algorithm to use for the workerpool.

getBaseOutputDirectoryProvider() - Method in class org.apache.beam.sdk.io.FileBasedSink

Returns the base directory inside which files will be written according to the configured FileBasedSink.FilenamePolicy.

getBatches() - Method in class org.apache.beam.runners.spark.io.CreateStream

Get the underlying queue representing the mock stream of micro-batches.

getBatchIntervalMillis() - Method in interface org.apache.beam.runners.spark.SparkPipelineOptions

getBigtableOptions() - Method in class org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Read

Returns the Google Cloud Bigtable instance being read from, and other parameters.

getBigtableOptions() - Method in class org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Write

Returns the Google Cloud Bigtable instance being written to, and other parameters.

getBoolean(Map<String, Object>, String) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getBoolean(Map<String, Object>, String, Boolean) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getBytes(Map<String, Object>, String) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getBytes(Map<String, Object>, String, byte[]) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getBytes() - Method in class org.apache.beam.sdk.io.range.ByteKey

Returns a newly-allocated byte[] representing this ByteKey.

getBytesPerOffset() - Method in class org.apache.beam.sdk.io.OffsetBasedSource

Returns approximately how many bytes of data correspond to a single offset in this source.

getCause() - Method in class org.apache.beam.sdk.transforms.windowing.InvalidWindows

Returns the reason that this WindowFn is invalid.

getChannelFactory() - Method in class org.apache.beam.sdk.io.CompressedSource

getCheckpointDir() - Method in interface org.apache.beam.runners.spark.SparkPipelineOptions

getCheckpointDurationMillis() - Method in interface org.apache.beam.runners.spark.SparkPipelineOptions

getCheckpointingInterval() - Method in interface org.apache.beam.runners.flink.FlinkPipelineOptions

getCheckpointingMode() - Method in interface org.apache.beam.runners.flink.FlinkPipelineOptions

getCheckpointMark() - Method in class org.apache.beam.runners.spark.io.MicrobatchSource.Reader

getCheckpointMark() - Method in class org.apache.beam.sdk.io.UnboundedSource.UnboundedReader

Returns a UnboundedSource.CheckpointMark representing the progress of this UnboundedReader.

getCheckpointMarkCoder() - Method in class org.apache.beam.runners.spark.io.MicrobatchSource

getCheckpointMarkCoder() - Method in class org.apache.beam.sdk.io.jms.JmsIO.UnboundedJmsSource

getCheckpointMarkCoder() - Method in class org.apache.beam.sdk.io.UnboundedSource

Returns a Coder for encoding and decoding the checkpoints for this source.

getCheckpointTimeoutMillis() - Method in interface org.apache.beam.runners.flink.FlinkPipelineOptions

getClasses() - Method in class org.apache.beam.sdk.values.TypeDescriptor

Returns a set of TypeDescriptors, one for each superclass (including this class).

getClassName() - Method in class org.apache.beam.runners.dataflow.util.CloudObject

Gets the name of the Java class that this CloudObject represents.

getCloningBehavior() - Method in class org.apache.beam.sdk.transforms.DoFnTester

Indicates whether this DoFnTester will clone the DoFn under test.

getClosingBehavior() - Method in class org.apache.beam.sdk.values.WindowingStrategy

getCmd() - Method in class org.apache.beam.runners.apex.ApexYarnLauncher.LaunchParams

getCoder(Class<T>) - Method in class org.apache.beam.sdk.coders.CoderRegistry

Returns the Coder to use for values of the given class.

getCoder(TypeDescriptor<T>) - Method in class org.apache.beam.sdk.coders.CoderRegistry

Returns the Coder to use for values of the given type.

getCoder(TypeDescriptor<OutputT>, TypeDescriptor<InputT>, Coder<InputT>) - Method in class org.apache.beam.sdk.coders.CoderRegistry

Deprecated.

getCoder(Class<? extends T>, Class<T>, Map<Type, ? extends Coder<?>>, TypeVariable<?>) - Method in class org.apache.beam.sdk.coders.CoderRegistry

Deprecated.

getCoder() - Method in class org.apache.beam.sdk.coders.DelegateCoder

Returns the coder used to encode/decode the intermediate values produced/consumed by the coding functions of this DelegateCoder.

getCoder() - Static method in class org.apache.beam.sdk.transforms.windowing.IntervalWindow

Returns a Coder suitable for IntervalWindow.

getCoder() - Method in class org.apache.beam.sdk.values.PCollection

Returns the Coder used by this PCollection to encode and decode the values stored in it.

getCoderArguments() - Method in class org.apache.beam.sdk.coders.AtomicCoder

If this is a Coder for a parameterized type, returns the list of Coders being used for each of the parameters in the same order they appear within the parameterized type's type signature.

getCoderArguments() - Method in class org.apache.beam.sdk.coders.Coder

If this is a Coder for a parameterized type, returns the list of Coders being used for each of the parameters in the same order they appear within the parameterized type's type signature.

getCoderArguments() - Method in class org.apache.beam.sdk.coders.CustomCoder

If this is a Coder for a parameterized type, returns the list of Coders being used for each of the parameters in the same order they appear within the parameterized type's type signature.

getCoderArguments() - Method in class org.apache.beam.sdk.coders.IterableLikeCoder

getCoderArguments() - Method in class org.apache.beam.sdk.coders.KvCoder

getCoderArguments() - Method in class org.apache.beam.sdk.coders.LengthPrefixCoder

getCoderArguments() - Method in class org.apache.beam.sdk.coders.MapCoder

If this is a Coder for a parameterized type, returns the list of Coders being used for each of the parameters in the same order they appear within the parameterized type's type signature.

getCoderArguments() - Method in class org.apache.beam.sdk.coders.NullableCoder

getCoderArguments() - Method in class org.apache.beam.sdk.coders.VarLongCoder

getCoderArguments() - Method in class org.apache.beam.sdk.io.FileBasedSink.FileResultCoder

getCoderArguments() - Method in class org.apache.beam.sdk.io.hadoop.WritableCoder

getCoderArguments() - Method in class org.apache.beam.sdk.io.kafka.KafkaRecordCoder

getCoderArguments() - Method in class org.apache.beam.sdk.transforms.join.CoGbkResult.CoGbkResultCoder

getCoderArguments() - Method in class org.apache.beam.sdk.transforms.join.UnionCoder

getCoderArguments() - Method in class org.apache.beam.sdk.transforms.windowing.GlobalWindow.Coder

getCoderArguments() - Method in class org.apache.beam.sdk.transforms.windowing.IntervalWindow.IntervalWindowCoder

getCoderArguments() - Method in class org.apache.beam.sdk.values.TimestampedValue.TimestampedValueCoder

getCoderArguments() - Method in class org.apache.beam.sdk.values.ValueInSingleWindow.Coder

getCoderArguments() - Method in class org.apache.beam.sdk.values.ValueWithRecordId.ValueWithRecordIdCoder

getCoderInternal() - Method in interface org.apache.beam.sdk.values.PCollectionView

Deprecated.
this method will be removed entirely. The PCollection underlying a side input, including its Coder, is part of the side input's specification with a ParDo transform, which will obtain that information via a package-private channel.

getCoderInternal() - Method in class org.apache.beam.sdk.values.PCollectionViews.SimplePCollectionView

getCoderProvider() - Static method in class org.apache.beam.sdk.coders.AvroCoder

Returns a CoderProvider which uses the AvroCoder if possible for all types.

getCoderProvider() - Static method in class org.apache.beam.sdk.coders.SerializableCoder

Returns a CoderProvider which uses the SerializableCoder if possible for all types.

getCoderProvider() - Static method in class org.apache.beam.sdk.extensions.protobuf.ProtoCoder

Returns a CoderProvider which uses the ProtoCoder for proto messages.

getCoderProvider() - Static method in class org.apache.beam.sdk.io.hadoop.WritableCoder

Returns a CoderProvider which uses the WritableCoder for Hadoop writable types.

getCoderProviders() - Method in interface org.apache.beam.sdk.coders.CoderProviderRegistrar

Returns a list of coder providers which will be registered by default within each coder registry instance.

getCoderProviders() - Method in class org.apache.beam.sdk.coders.DefaultCoder.DefaultCoderProviderRegistrar

getCoderProviders() - Method in class org.apache.beam.sdk.coders.SerializableCoder.SerializableCoderProviderRegistrar

getCoderProviders() - Method in class org.apache.beam.sdk.extensions.protobuf.ProtobufCoderProviderRegistrar

getCoderProviders() - Method in class org.apache.beam.sdk.io.amqp.AmqpMessageCoderProviderRegistrar

getCoderProviders() - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryCoderProviderRegistrar

getCoderProviders() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubCoderProviderRegistrar

getCoderProviders() - Method in class org.apache.beam.sdk.io.hadoop.WritableCoder.WritableCoderProviderRegistrar

getCoderProviders() - Method in class org.apache.beam.sdk.io.hbase.HBaseCoderProviderRegistrar

getCoderRegistry() - Method in class org.apache.beam.sdk.Pipeline

Returns the CoderRegistry that this Pipeline uses.

getCoGbkResultSchema() - Method in class org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple

Returns the CoGbkResultSchema associated with this KeyedPCollectionTuple.

getCollection() - Method in class org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple.TaggedKeyedPCollection

Returns the underlying PCollection of this TaggedKeyedPCollection.

getCombineFn() - Method in class org.apache.beam.runners.spark.aggregators.NamedAggregators.CombineFunctionState

getCombineFn() - Method in interface org.apache.beam.runners.spark.aggregators.NamedAggregators.State

getCombineFn() - Method in class org.apache.beam.sdk.transforms.Combine.GloballyAsSingletonView

getComponents() - Method in class org.apache.beam.sdk.coders.AtomicCoder

Returns the list of Coders that are components of this Coder.

getComponents() - Method in class org.apache.beam.sdk.coders.StructuredCoder

Returns the list of Coders that are components of this Coder.

getComponents() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Path

Hierarchy list of component paths making up the full path, starting with the top-level child component path.

getComponents() - Method in class org.apache.beam.sdk.transforms.join.UnionCoder

getComponents() - Method in class org.apache.beam.sdk.values.TimestampedValue.TimestampedValueCoder

getComponents() - Method in class org.apache.beam.sdk.values.ValueInSingleWindow.Coder

getComponentType() - Method in class org.apache.beam.sdk.values.TypeDescriptor

Returns the component type if this type is an array type, otherwise returns null.

getConfigFile() - Method in interface org.apache.beam.runners.apex.ApexPipelineOptions

getConfiguration() - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.HadoopInputFormatBoundedSource

getConfiguration() - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.Read

getConfiguration() - Method in class org.apache.beam.sdk.io.hbase.HBaseIO.Read

getConfiguration() - Method in class org.apache.beam.sdk.io.hbase.HBaseIO.Write

getContainerVersion() - Method in class org.apache.beam.runners.dataflow.DataflowRunnerInfo

Provides the container version that will be used for constructing harness image paths.

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.AfterAll

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.AfterEach

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.AfterFirst

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.AfterPane

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.AfterProcessingTime

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.AfterSynchronizedProcessingTime

getContinuationTrigger() - Method in class org.apache.beam.sdk.transforms.windowing.AfterWatermark.AfterWatermarkEarlyAndLate

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.AfterWatermark.AfterWatermarkEarlyAndLate

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.AfterWatermark.FromEndOfWindow

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.DefaultTrigger

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.Never.NeverTrigger

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.OrFinallyTrigger

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.Repeatedly

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.ReshuffleTrigger

Deprecated.

getContinuationTrigger() - Method in class org.apache.beam.sdk.transforms.windowing.Trigger

Return a trigger to use after a GroupByKey to preserve the intention of this trigger.

getContinuationTrigger(List<Trigger>) - Method in class org.apache.beam.sdk.transforms.windowing.Trigger

Subclasses should override this to return the Trigger.getContinuationTrigger() of this Trigger.

getContinuationTrigger() - Method in class org.apache.beam.sdk.transforms.windowing.Trigger.OnceTrigger

getCount() - Method in class org.apache.beam.sdk.testing.CoderProperties.TestElementByteSizeObserver

getCounter(MetricName) - Method in interface org.apache.beam.sdk.metrics.MetricsContainer

Return the Counter that should be used for implementing the given metricName in this container.

getCounters(MetricFilter) - Method in class org.apache.beam.runners.spark.metrics.WithMetricsSupport

getCredential() - Method in interface org.apache.beam.sdk.extensions.gcp.auth.CredentialFactory

getCredential() - Method in class org.apache.beam.sdk.extensions.gcp.auth.GcpCredentialFactory

Returns a default GCP Credentials or null when it fails.

getCredential() - Method in class org.apache.beam.sdk.extensions.gcp.auth.NoopCredentialFactory

getCredentialFactoryClass() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

The class of the credential factory that should be created and used to create credentials.

getCurrent() - Method in class org.apache.beam.runners.spark.io.MicrobatchSource.Reader

getCurrent() - Method in class org.apache.beam.sdk.io.BlockBasedSource.BlockBasedReader

getCurrent() - Method in class org.apache.beam.sdk.io.CompressedSource.CompressedReader

Gets the current record from the delegate reader.

getCurrent() - Method in class org.apache.beam.sdk.io.Source.Reader

Returns the value of the data item that was read by the last Source.Reader.start() or Source.Reader.advance() call.

getCurrentBlock() - Method in class org.apache.beam.sdk.io.AvroSource.AvroReader

getCurrentBlock() - Method in class org.apache.beam.sdk.io.BlockBasedSource.BlockBasedReader

Returns the current block (the block that was read by the last successful call to BlockBasedSource.BlockBasedReader.readNextBlock()).

getCurrentBlockOffset() - Method in class org.apache.beam.sdk.io.AvroSource.AvroReader

getCurrentBlockOffset() - Method in class org.apache.beam.sdk.io.BlockBasedSource.BlockBasedReader

Returns the largest offset such that starting to read from that offset includes the current block.

getCurrentBlockSize() - Method in class org.apache.beam.sdk.io.AvroSource.AvroReader

getCurrentBlockSize() - Method in class org.apache.beam.sdk.io.BlockBasedSource.BlockBasedReader

Returns the size of the current block in bytes as it is represented in the underlying file, if possible.

getCurrentContainer() - Static method in class org.apache.beam.sdk.metrics.MetricsEnvironment

Return the MetricsContainer for the current thread.

getCurrentDirectory() - Method in class org.apache.beam.sdk.extensions.gcp.storage.GcsResourceId

getCurrentDirectory() - Method in interface org.apache.beam.sdk.io.fs.ResourceId

Returns the ResourceId that represents the current directory of this ResourceId.

getCurrentOffset() - Method in class org.apache.beam.sdk.io.BlockBasedSource.BlockBasedReader

getCurrentOffset() - Method in class org.apache.beam.sdk.io.CompressedSource.CompressedReader

getCurrentOffset() - Method in class org.apache.beam.sdk.io.OffsetBasedSource.OffsetBasedReader

Returns the starting offset of the current record, which has been read by the last successful Source.Reader.start() or Source.Reader.advance() call.

getCurrentRecord() - Method in class org.apache.beam.sdk.io.BlockBasedSource.Block

Returns the current record.

getCurrentRecordId() - Method in class org.apache.beam.sdk.io.UnboundedSource.UnboundedReader

Returns a unique identifier for the current record.

getCurrentSource() - Method in class org.apache.beam.runners.spark.io.MicrobatchSource.Reader

getCurrentSource() - Method in class org.apache.beam.sdk.io.AvroSource.AvroReader

getCurrentSource() - Method in class org.apache.beam.sdk.io.BoundedSource.BoundedReader

Returns a Source describing the same input that this Reader currently reads (including items already read).

getCurrentSource() - Method in class org.apache.beam.sdk.io.FileBasedSource.FileBasedReader

getCurrentSource() - Method in class org.apache.beam.sdk.io.OffsetBasedSource.OffsetBasedReader

getCurrentSource() - Method in class org.apache.beam.sdk.io.Source.Reader

Returns a Source describing the same input that this Reader currently reads (including items already read).

getCurrentSource() - Method in class org.apache.beam.sdk.io.UnboundedSource.UnboundedReader

Returns the UnboundedSource that created this reader.

getCurrentTimestamp() - Method in class org.apache.beam.runners.spark.io.MicrobatchSource.Reader

getCurrentTimestamp() - Method in class org.apache.beam.sdk.io.BoundedSource.BoundedReader

By default, returns the minimum possible timestamp.

getCurrentTimestamp() - Method in class org.apache.beam.sdk.io.CompressedSource.CompressedReader

getCurrentTimestamp() - Method in class org.apache.beam.sdk.io.Source.Reader

Returns the timestamp associated with the current data item.

getData() - Method in class org.apache.beam.sdk.io.kinesis.KinesisRecord

getDataAsBytes() - Method in class org.apache.beam.sdk.io.kinesis.KinesisRecord

getDataCoder() - Method in class org.apache.beam.runners.dataflow.DataflowRunner.StreamingPCollectionViewWriterFn

Deprecated.

getDataflowClient() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions

An instance of the Dataflow client.

getDataflowEndpoint() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions

Dataflow endpoint to use.

getDataflowJobFile() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions

The path to write the translated Dataflow job specification out to at job submission time.

getDataflowRunnerInfo() - Static method in class org.apache.beam.runners.dataflow.DataflowRunnerInfo

Returns an instance of DataflowRunnerInfo.

getDayOfMonth() - Method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows.MonthsWindows

getDayOfMonth() - Method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows.YearsWindows

getDebuggee() - Method in interface org.apache.beam.runners.dataflow.options.CloudDebuggerOptions

The Cloud Debugger debuggee to associate with.

getDefaultCoder(TypeDescriptor<?>, CoderRegistry) - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.Read

Returns the default coder for a given type descriptor.

getDefaultOutputCoder() - Method in class org.apache.beam.runners.spark.io.CreateStream

getDefaultOutputCoder() - Method in class org.apache.beam.runners.spark.io.MicrobatchSource

getDefaultOutputCoder(PCollection<KV<PrimaryKeyT, Iterable<KV<SecondaryKeyT, ValueT>>>>) - Method in class org.apache.beam.sdk.extensions.sorter.SortValues

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.AvroIO.Read

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.AvroIO.Write

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.AvroSource

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.BoundedReadFromUnboundedSource

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.CompressedSource

Returns the delegate source's default output coder.

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Read

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.Write

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.gcp.bigquery.StreamingInserts

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Read

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Write

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.HadoopInputFormatBoundedSource

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.jms.JmsIO.UnboundedJmsSource

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.Read.BoundedGridFSSource

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.Read.Bounded

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.Read.Unbounded

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.Source

Returns the default Coder to use for the data read from this source.

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.TextIO.Read

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.TextIO.Write

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.TFRecordIO.Read

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.TFRecordIO.Write

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.io.xml.XmlSource

getDefaultOutputCoder(CoderRegistry, Coder<Double>) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineDoubleFn

getDefaultOutputCoder(CoderRegistry, Coder<V>) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineFn

getDefaultOutputCoder(CoderRegistry, Coder<Integer>) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineIntegerFn

getDefaultOutputCoder(CoderRegistry, Coder<Long>) - Method in class org.apache.beam.sdk.transforms.Combine.BinaryCombineLongFn

getDefaultOutputCoder(PCollection<? extends KV<K, ? extends Iterable<InputT>>>) - Method in class org.apache.beam.sdk.transforms.Combine.GroupedValues

getDefaultOutputCoder(CoderRegistry, Coder<InputT>) - Method in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn

Returns the Coder to use by default for output OutputT values, or null if it is not able to be inferred.

getDefaultOutputCoder(PBegin) - Method in class org.apache.beam.sdk.transforms.Create.TimestampedValues

getDefaultOutputCoder(PBegin) - Method in class org.apache.beam.sdk.transforms.Create.Values

getDefaultOutputCoder(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.Filter

getDefaultOutputCoder(PCollectionList<T>) - Method in class org.apache.beam.sdk.transforms.Flatten.PCollections

getDefaultOutputCoder(PCollection<KV<K, V>>) - Method in class org.apache.beam.sdk.transforms.GroupByKey

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.transforms.ParDo.MultiOutput

getDefaultOutputCoder(PCollection<? extends InputT>, PCollection<T>) - Method in class org.apache.beam.sdk.transforms.ParDo.MultiOutput

getDefaultOutputCoder(PCollection<? extends InputT>) - Method in class org.apache.beam.sdk.transforms.ParDo.SingleOutput

getDefaultOutputCoder() - Method in class org.apache.beam.sdk.transforms.PTransform

Returns the default Coder to use for the output of this single-output PTransform.

getDefaultOutputCoder(InputT) - Method in class org.apache.beam.sdk.transforms.PTransform

Returns the default Coder to use for the output of this single-output PTransform when applied to the given input.

getDefaultOutputCoder(InputT, PCollection<T>) - Method in class org.apache.beam.sdk.transforms.PTransform

Returns the default Coder to use for the given output of this single-output PTransform when applied to the given input.

getDefaultOutputCoder(CoderRegistry, Coder<T>) - Method in class org.apache.beam.sdk.transforms.Sample.FixedSizedSampleFn

getDefaultOutputCoder(PCollection<T>) - Method in class org.apache.beam.sdk.transforms.windowing.Window

getDefaultOverrides(boolean) - Static method in class org.apache.beam.runners.flink.FlinkTransformOverrides

getDefaultValue() - Method in class org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn

Deprecated.

Returns the default value that was specified.

getDefaultWindowMappingFn() - Method in class org.apache.beam.sdk.transforms.windowing.GlobalWindows

getDefaultWindowMappingFn() - Method in class org.apache.beam.sdk.transforms.windowing.InvalidWindows

getDefaultWindowMappingFn() - Method in class org.apache.beam.sdk.transforms.windowing.PartitioningWindowFn

getDefaultWindowMappingFn() - Method in class org.apache.beam.sdk.transforms.windowing.Sessions

getDefaultWindowMappingFn() - Method in class org.apache.beam.sdk.transforms.windowing.SlidingWindows

Return a WindowMappingFn that returns the earliest window that contains the end of the main-input window.

getDefaultWindowMappingFn() - Method in class org.apache.beam.sdk.transforms.windowing.WindowFn

Returns the default WindowMappingFn to use to map main input windows to side input windows.

getDefaultWorkerLogLevel() - Method in interface org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions

This option controls the default log level of all loggers without a log level override.

getDelay() - Method in class org.apache.beam.sdk.transforms.windowing.TimestampTransform.Delay

getDestination(ValueInSingleWindow<T>) - Method in class org.apache.beam.sdk.io.gcp.bigquery.DynamicDestinations

Returns an object that represents at a high level which table is being written to.

getDestinationCoder() - Method in class org.apache.beam.sdk.io.gcp.bigquery.DynamicDestinations

Returns the coder for DestinationT.

getDestinationFile(FileBasedSink.FilenamePolicy, ResourceId, int, String) - Method in class org.apache.beam.sdk.io.FileBasedSink.FileResult

getDictionary(Map<String, Object>, String) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getDictionary(Map<String, Object>, String, Map<String, Object>) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getDiskSizeGb() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions

Remote worker disk size, in gigabytes, or 0 to use the default size.

getDistribution(MetricName) - Method in interface org.apache.beam.sdk.metrics.MetricsContainer

Return the Distribution that should be used for implementing the given metricName in this container.

getDoFn() - Method in class org.apache.beam.runners.dataflow.util.DoFnInfo

Returns the embedded function.

getDumpHeapOnOOM() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions

If true, save a heap dump before killing a thread or process which is GC thrashing or out of memory.

getEarlyTrigger() - Method in class org.apache.beam.sdk.transforms.windowing.AfterWatermark.AfterWatermarkEarlyAndLate

getElemCoder() - Method in class org.apache.beam.sdk.coders.IterableLikeCoder

getElementCoders() - Method in class org.apache.beam.sdk.transforms.join.UnionCoder

getElementCount() - Method in class org.apache.beam.sdk.transforms.windowing.AfterPane

The number of elements after which this trigger may fire.

getElements() - Method in class org.apache.beam.sdk.testing.TestStream.ElementEvent

getElements() - Method in class org.apache.beam.sdk.transforms.Create.Values

getEnableCloudDebugger() - Method in interface org.apache.beam.runners.dataflow.options.CloudDebuggerOptions

Whether to enable the Cloud Debugger snapshot agent for the current job.

getEnableMetrics() - Method in interface org.apache.beam.runners.flink.FlinkPipelineOptions

getEnableSparkMetricSinks() - Method in interface org.apache.beam.runners.spark.SparkPipelineOptions

getEncodedElementByteSize(RandomAccessData) - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder

getEncodedElementByteSize(BigDecimal) - Method in class org.apache.beam.sdk.coders.BigDecimalCoder

Returns the size in bytes of the encoded value using this coder.

getEncodedElementByteSize(Integer) - Method in class org.apache.beam.sdk.coders.BigEndianIntegerCoder

Returns the size in bytes of the encoded value using this coder.

getEncodedElementByteSize(Long) - Method in class org.apache.beam.sdk.coders.BigEndianLongCoder

Returns the size in bytes of the encoded value using this coder.

getEncodedElementByteSize(BigInteger) - Method in class org.apache.beam.sdk.coders.BigIntegerCoder

Returns the size in bytes of the encoded value using this coder.

getEncodedElementByteSize(byte[]) - Method in class org.apache.beam.sdk.coders.ByteArrayCoder

getEncodedElementByteSize(Byte) - Method in class org.apache.beam.sdk.coders.ByteCoder

Returns the size in bytes of the encoded value using this coder.

getEncodedElementByteSize(T) - Method in class org.apache.beam.sdk.coders.Coder

Returns the size in bytes of the encoded value using this coder.

getEncodedElementByteSize(Double) - Method in class org.apache.beam.sdk.coders.DoubleCoder

Returns the size in bytes of the encoded value using this coder.

getEncodedElementByteSize(Instant) - Method in class org.apache.beam.sdk.coders.InstantCoder

getEncodedElementByteSize(T) - Method in class org.apache.beam.sdk.coders.LengthPrefixCoder

Overridden to short-circuit the default StructuredCoder behavior of encoding and counting the bytes.

getEncodedElementByteSize(T) - Method in class org.apache.beam.sdk.coders.NullableCoder

Overridden to short-circuit the default StructuredCoder behavior of encoding and counting the bytes.

getEncodedElementByteSize(String) - Method in class org.apache.beam.sdk.coders.StringUtf8Coder

Returns the size in bytes of the encoded value using this coder.

getEncodedElementByteSize(Integer) - Method in class org.apache.beam.sdk.coders.TextualIntegerCoder

getEncodedElementByteSize(Integer) - Method in class org.apache.beam.sdk.coders.VarIntCoder

getEncodedElementByteSize(Long) - Method in class org.apache.beam.sdk.coders.VarLongCoder

getEncodedElementByteSize(Void) - Method in class org.apache.beam.sdk.coders.VoidCoder

getEncodedElementByteSize(ByteString) - Method in class org.apache.beam.sdk.extensions.protobuf.ByteStringCoder

getEncodedElementByteSize(TableRow) - Method in class org.apache.beam.sdk.io.gcp.bigquery.TableRowJsonCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.AvroCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.BigEndianIntegerCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.BigEndianLongCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.ByteArrayCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.ByteCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.Coder

Returns the TypeDescriptor for the type encoded.

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.CollectionCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.DelegateCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.DoubleCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.DurationCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.InstantCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.IterableCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.KvCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.ListCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.MapCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.NullableCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.SerializableCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.SetCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.StringDelegateCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.StringUtf8Coder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.StructuredCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.TextualIntegerCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.VarIntCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.VarLongCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.coders.VoidCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.extensions.protobuf.ByteStringCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.io.gcp.bigquery.TableRowJsonCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.io.xml.JAXBCoder

getEncodedTypeDescriptor() - Method in class org.apache.beam.sdk.values.TimestampedValue.TimestampedValueCoder

getEndKey() - Method in class org.apache.beam.sdk.io.range.ByteKeyRange

Returns the ByteKey representing the upper bound of this ByteKeyRange.

getEndOffset() - Method in class org.apache.beam.sdk.io.OffsetBasedSource

Returns the specified ending offset of the source.

getEnv() - Method in class org.apache.beam.runners.apex.ApexYarnLauncher.LaunchParams

getEstimatedSizeBytes(PipelineOptions) - Method in class org.apache.beam.sdk.io.BoundedSource

An estimate of the total size (in bytes) of the data that would be read from this source.

getEstimatedSizeBytes(CassandraIO.Read<T>) - Method in interface org.apache.beam.sdk.io.cassandra.CassandraService

Returns an estimation of the size that could be read.

getEstimatedSizeBytes(CassandraIO.Read<T>) - Method in class org.apache.beam.sdk.io.cassandra.CassandraServiceImpl

getEstimatedSizeBytes(List<CassandraServiceImpl.TokenRange>) - Static method in class org.apache.beam.sdk.io.cassandra.CassandraServiceImpl

Actually estimate the size of the data to read on the cluster, based on the given token ranges to address.

getEstimatedSizeBytes(PipelineOptions) - Method in class org.apache.beam.sdk.io.FileBasedSource

getEstimatedSizeBytes(PipelineOptions) - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.HadoopInputFormatBoundedSource

getEstimatedSizeBytes(PipelineOptions) - Method in class org.apache.beam.sdk.io.mongodb.MongoDbGridFSIO.Read.BoundedGridFSSource

getEstimatedSizeBytes(PipelineOptions) - Method in class org.apache.beam.sdk.io.OffsetBasedSource

getEvents() - Method in class org.apache.beam.sdk.testing.TestStream

Returns the sequence of Events in this TestStream.

getExecutionRetryDelay() - Method in interface org.apache.beam.runners.flink.FlinkPipelineOptions

getExecutorService() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions

The ExecutorService instance to use to create threads, can be overridden to specify an ExecutorService that is compatible with the users environment.

getExpectedAssertions() - Method in interface org.apache.beam.runners.spark.TestSparkPipelineOptions

getExperiments() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions

The list of backend experiments to enable.

getExtendedSequenceNumber() - Method in class org.apache.beam.sdk.io.kinesis.KinesisRecord

getExtension() - Method in class org.apache.beam.sdk.io.FileBasedSink

Returns the extension that will be written to the produced files.

getExtensionHosts() - Method in class org.apache.beam.sdk.extensions.protobuf.ProtoCoder

getExtensionRegistry() - Method in class org.apache.beam.sdk.extensions.protobuf.ProtoCoder

Returns the ExtensionRegistry listing all known Protocol Buffers extension messages to T registered with this ProtoCoder.

getFailedInserts() - Method in class org.apache.beam.sdk.io.gcp.bigquery.WriteResult

getFanout() - Method in class org.apache.beam.sdk.transforms.Combine.GloballyAsSingletonView

getFilename() - Method in class org.apache.beam.sdk.extensions.gcp.storage.GcsResourceId

getFilename() - Method in interface org.apache.beam.sdk.io.fs.ResourceId

Returns the name of the file or directory denoted by this ResourceId.

getFilenamePolicy() - Method in class org.apache.beam.sdk.io.FileBasedSink

Returns the policy by which files will be named inside of the base output directory.

getFilenameSuffix() - Method in enum org.apache.beam.sdk.io.FileBasedSink.CompressionType

getFilenameSuffix() - Method in interface org.apache.beam.sdk.io.FileBasedSink.WritableByteChannelFactory

getFileOrPatternSpec() - Method in class org.apache.beam.sdk.io.FileBasedSource

getFileOrPatternSpecProvider() - Method in class org.apache.beam.sdk.io.FileBasedSource

getFilesToStage() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions

List of local files to make available to workers.

getFilesToStage() - Method in interface org.apache.beam.runners.flink.FlinkPipelineOptions

List of local files to make available to workers.

getFlinkMaster() - Method in interface org.apache.beam.runners.flink.FlinkPipelineOptions

The url of the Flink JobManager on which to execute pipelines.

getFn() - Method in class org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory.ParDoSingle

getFn() - Method in class org.apache.beam.sdk.transforms.Combine.Globally

Returns the CombineFnBase.GlobalCombineFn used by this Combine operation.

getFn() - Method in class org.apache.beam.sdk.transforms.Combine.GroupedValues

Returns the CombineFnBase.GlobalCombineFn used by this Combine operation.

getFn() - Method in class org.apache.beam.sdk.transforms.Combine.PerKey

Returns the CombineFnBase.GlobalCombineFn used by this Combine operation.

getFn() - Method in class org.apache.beam.sdk.transforms.ParDo.MultiOutput

getFn() - Method in class org.apache.beam.sdk.transforms.ParDo.SingleOutput

getFnApiEnvironmentMajorVersion() - Method in class org.apache.beam.runners.dataflow.DataflowRunnerInfo

Provides the FnAPI environment's major version number.

getFractionConsumed() - Method in class org.apache.beam.sdk.io.BlockBasedSource.BlockBasedReader

getFractionConsumed() - Method in class org.apache.beam.sdk.io.BoundedSource.BoundedReader

Returns a value in [0, 1] representing approximately what fraction of the current source this reader has read so far, or null if such an estimate is not available.

getFractionConsumed() - Method in class org.apache.beam.sdk.io.OffsetBasedSource.OffsetBasedReader

getFractionConsumed() - Method in class org.apache.beam.sdk.io.range.ByteKeyRangeTracker

getFractionConsumed() - Method in class org.apache.beam.sdk.io.range.OffsetRangeTracker

getFractionConsumed() - Method in interface org.apache.beam.sdk.io.range.RangeTracker

Returns the approximate fraction of positions in the source that have been consumed by successful RangeTracker.tryReturnRecordAt(boolean, PositionT) calls, or 0.0 if no such calls have happened.

getFractionOfBlockConsumed() - Method in class org.apache.beam.sdk.io.BlockBasedSource.Block

Returns the fraction of the block already consumed, if possible, as a value in [0, 1].

getFrom() - Method in class org.apache.beam.sdk.transforms.splittabledofn.OffsetRange

getGapDuration() - Method in class org.apache.beam.sdk.transforms.windowing.Sessions

getGauge(MetricName) - Method in interface org.apache.beam.sdk.metrics.MetricsContainer

Return the Gauge that should be used for implementing the given metricName in this container.

getGauges(MetricFilter) - Method in class org.apache.beam.runners.spark.metrics.WithMetricsSupport

getGcloudCancelCommand(DataflowPipelineOptions, String) - Static method in class org.apache.beam.runners.dataflow.util.MonitoringUtil

getGcpCredential() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

The credential instance that should be used to authenticate against GCP services.

getGcpTempLocation() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

A GCS path for storing temporary files in GCP.

getGcsEndpoint() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions

GCS endpoint to use.

getGcsUploadBufferSizeBytes() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions

The buffer size (in bytes) to use when uploading files to GCS.

getGcsUtil() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions

The GcsUtil instance that should be used to communicate with Google Cloud Storage.

getGoogleApiTrace() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GoogleApiDebugOptions

This option enables tracing of API calls to Google services used within the Apache Beam SDK.

getHdfsConfiguration() - Method in interface org.apache.beam.sdk.io.hdfs.HadoopFileSystemOptions

getHighWatermark() - Method in class org.apache.beam.runners.spark.util.GlobalWatermarkHolder.SparkWatermarks

getHistograms(MetricFilter) - Method in class org.apache.beam.runners.spark.metrics.WithMetricsSupport

getId() - Method in class org.apache.beam.runners.spark.io.MicrobatchSource

getId() - Method in class org.apache.beam.sdk.values.TupleTag

Returns the id of this TupleTag.

getId() - Method in class org.apache.beam.sdk.values.ValueWithRecordId

getIdAttribute() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSink

Get the id attribute.

getIdAttribute() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSource

Get the id attribute.

getIncompatibleGlobalWindowErrorMessage() - Method in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn

Returns the error message for not supported default values in Combine.globally().

getIncompatibleGlobalWindowErrorMessage() - Method in class org.apache.beam.sdk.transforms.Top.TopCombineFn

getIndex(TupleTag<?>) - Method in class org.apache.beam.sdk.transforms.join.CoGbkResultSchema

Returns the index for the given tuple tag, if the tag is present in this schema, -1 if it isn't.

getIndex() - Method in class org.apache.beam.sdk.transforms.windowing.PaneInfo

The zero-based index of this trigger firing that produced this pane.

getInputCoder() - Method in class org.apache.beam.runners.dataflow.util.DoFnInfo

getinputFormatClass() - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.Read

getinputFormatKeyClass() - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.Read

getinputFormatValueClass() - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.Read

getInputTypeDescriptor() - Method in class org.apache.beam.sdk.transforms.DoFn

Returns a TypeDescriptor capturing what is known statically about the input type of this DoFn instance's most-derived class.

getInputTypeDescriptor() - Method in class org.apache.beam.sdk.transforms.SimpleFunction

Returns a TypeDescriptor capturing what is known statically about the input type of this SimpleFunction instance's most-derived class.

getInputValueCoder(Coder<KV<K, V>>) - Static method in class org.apache.beam.sdk.transforms.GroupByKey

Returns the Coder of the values of the input to this transform.

getInsertDefault() - Method in class org.apache.beam.sdk.transforms.Combine.GloballyAsSingletonView

getInstance() - Static method in class org.apache.beam.runners.spark.aggregators.AggregatorsAccumulator

getInstance() - Static method in class org.apache.beam.runners.spark.metrics.MetricsAccumulator

getInt(Map<String, Object>, String) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getInt(Map<String, Object>, String, Integer) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getInterfaces() - Method in class org.apache.beam.sdk.values.TypeDescriptor

Returns a set of TypeDescriptors, one for each interface implemented by this class.

getJAXBClass() - Method in class org.apache.beam.sdk.io.xml.JAXBCoder

getJmsCorrelationID() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getJmsDeliveryMode() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getJmsDestination() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getJmsExpiration() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getJmsMessageID() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getJmsPriority() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getJmsRedelivered() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getJmsReplyTo() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getJmsTimestamp() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getJmsType() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getJob(String) - Method in class org.apache.beam.runners.dataflow.DataflowClient

Gets the Dataflow Job with the given jobId.

getJob() - Method in exception org.apache.beam.runners.dataflow.DataflowJobException

Returns the failed job.

getJob() - Method in class org.apache.beam.runners.dataflow.DataflowPipelineTranslator.JobSpecification

getJobId() - Method in class org.apache.beam.runners.dataflow.DataflowPipelineJob

Get the id of this job.

getJobId() - Method in interface org.apache.beam.runners.dataflow.options.DataflowWorkerHarnessOptions

The identity of the Dataflow job.

getJobId() - Method in class org.apache.beam.runners.dataflow.util.DataflowTemplateJob

getJobMessages(String, long) - Method in class org.apache.beam.runners.dataflow.util.MonitoringUtil

Return job messages sorted in ascending order by timestamp.

getJobMetrics(String) - Method in class org.apache.beam.runners.dataflow.DataflowClient

Gets the JobMetrics with the given jobId.

getJobMonitoringPageURL(String, String) - Static method in class org.apache.beam.runners.dataflow.util.MonitoringUtil

getJobName() - Method in interface org.apache.beam.sdk.options.PipelineOptions

getKey() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Identifier

getKey() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Item

The key for the display item.

getKey() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.ItemSpec

The key for the display item.

getKey() - Method in class org.apache.beam.sdk.values.KV

Returns the key of this KV.

getKeyCoder() - Method in class org.apache.beam.sdk.coders.KvCoder

getKeyCoder() - Method in class org.apache.beam.sdk.coders.MapCoder

getKeyCoder(Coder<KV<K, V>>) - Static method in class org.apache.beam.sdk.transforms.GroupByKey

Returns the Coder of the keys of the input to this transform, which is also used as the Coder of the keys of the output of this transform.

getKeyCoder() - Method in class org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple

Returns the key Coder for all PCollections in this KeyedPCollectionTuple.

getKeyedCollections() - Method in class org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple

Returns a list of TaggedKeyedPCollections for the PCollections contained in this KeyedPCollectionTuple.

getKeyRange() - Method in class org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Read

Returns the range of keys that will be read from the table.

getKeyRange() - Method in class org.apache.beam.sdk.io.hbase.HBaseIO.Read

Returns the range of keys that will be read from the table.

getKeyTranslationFunction() - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.Read

getKeyTypeDescriptor() - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.Read

getKindString() - Method in class org.apache.beam.sdk.io.BoundedReadFromUnboundedSource

getKindString() - Method in class org.apache.beam.sdk.io.Read.Bounded

getKindString() - Method in class org.apache.beam.sdk.io.Read.Unbounded

getKindString() - Method in class org.apache.beam.sdk.transforms.Combine.Globally

getKindString() - Method in class org.apache.beam.sdk.transforms.Combine.PerKey

getKindString() - Method in class org.apache.beam.sdk.transforms.Combine.PerKeyWithHotKeyFanout

getKindString() - Method in class org.apache.beam.sdk.transforms.ParDo.MultiOutput

getKindString() - Method in class org.apache.beam.sdk.transforms.ParDo.SingleOutput

getKindString() - Method in class org.apache.beam.sdk.transforms.PTransform

Returns the name to use by default for this PTransform (not including the names of any enclosing PTransforms).

getKindString() - Method in class org.apache.beam.sdk.transforms.windowing.Window

getKindString() - Method in class org.apache.beam.sdk.values.PValueBase

Returns a String capturing the kind of this PValueBase.

getKV() - Method in class org.apache.beam.sdk.io.kafka.KafkaRecord

getLabel() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Item

Retrieve the optional label for an item.

getLabel() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.ItemSpec

The optional label for an item.

getLastEmitted() - Method in class org.apache.beam.sdk.io.CountingSource.CounterMark

Returns the last value emitted by the reader.

getLateTrigger() - Method in class org.apache.beam.sdk.transforms.windowing.AfterWatermark.AfterWatermarkEarlyAndLate

getLegacyEnvironmentMajorVersion() - Method in class org.apache.beam.runners.dataflow.DataflowRunnerInfo

Provides the legacy environment's major version number.

getLinkUrl() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Item

Retrieve the optional link URL for an item.

getLinkUrl() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.ItemSpec

The optional link URL for an item.

getListeners() - Method in interface org.apache.beam.runners.spark.SparkContextOptions

getListOfMaps(Map<String, Object>, String, List<Map<String, Object>>) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getLiteralGqlQuery() - Method in class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Read

getLocalhost() - Method in class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Read

getLocalValue() - Method in class org.apache.beam.runners.flink.metrics.MetricsAccumulator

getLong(Map<String, Object>, String) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getLong(Map<String, Object>, String, Long) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getLowWatermark() - Method in class org.apache.beam.runners.spark.util.GlobalWatermarkHolder.SparkWatermarks

getMainOutput() - Method in class org.apache.beam.runners.dataflow.util.DoFnInfo

getMainOutputTag() - Method in class org.apache.beam.sdk.transforms.DoFnTester

getMainOutputTag() - Method in class org.apache.beam.sdk.transforms.ParDo.MultiOutput

getMainTrigger() - Method in class org.apache.beam.sdk.transforms.windowing.OrFinallyTrigger

The main trigger, which will continue firing until the "until" trigger fires.

getMaterialization() - Method in class org.apache.beam.sdk.transforms.ViewFn

Gets the materialization of this ViewFn.

getMaterialization() - Method in class org.apache.beam.sdk.values.PCollectionViews.IterableViewFn

Deprecated.

getMaterialization() - Method in class org.apache.beam.sdk.values.PCollectionViews.ListViewFn

Deprecated.

getMaterialization() - Method in class org.apache.beam.sdk.values.PCollectionViews.MapViewFn

Deprecated.

getMaterialization() - Method in class org.apache.beam.sdk.values.PCollectionViews.MultimapViewFn

Deprecated.

getMaterialization() - Method in class org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn

Deprecated.

getMaxConditionCost() - Method in interface org.apache.beam.runners.dataflow.options.CloudDebuggerOptions

The maximum cost (as a ratio of CPU time) allowed for evaluating conditional snapshots.

getMaxEndOffset(PipelineOptions) - Method in class org.apache.beam.sdk.io.FileBasedSource

getMaxEndOffset(PipelineOptions) - Method in class org.apache.beam.sdk.io.OffsetBasedSource

Returns the actual ending offset of the current source.

getMaxNumWorkers() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions

The maximum number of workers to use for the workerpool.

getMaxRecordsPerBatch() - Method in interface org.apache.beam.runners.spark.SparkPipelineOptions

getMean() - Method in class org.apache.beam.sdk.testing.CoderProperties.TestElementByteSizeObserver

getMemoryMB() - Method in class org.apache.beam.sdk.extensions.sorter.BufferedExternalSorter.Options

Returns the configured size of the memory buffer.

getMessage() - Method in exception org.apache.beam.sdk.coders.Coder.NonDeterministicException

getMessage() - Method in exception org.apache.beam.sdk.transforms.windowing.IncompatibleWindowException

getMessages() - Method in class org.apache.beam.sdk.io.jms.JmsCheckpointMark

getMessageType() - Method in class org.apache.beam.sdk.extensions.protobuf.ProtoCoder

Returns the Protocol Buffers Message type this ProtoCoder supports.

getMeters(MetricFilter) - Method in class org.apache.beam.runners.spark.metrics.WithMetricsSupport

getMimeType() - Method in enum org.apache.beam.sdk.io.FileBasedSink.CompressionType

getMimeType() - Method in interface org.apache.beam.sdk.io.FileBasedSink.WritableByteChannelFactory

Returns the MIME type that should be used for the files that will hold the output data.

getMinBundleSize() - Method in class org.apache.beam.sdk.io.OffsetBasedSource

Returns the minimum bundle size that should be used when splitting the source into sub-sources.

getMinReadTimeMillis() - Method in interface org.apache.beam.runners.spark.SparkPipelineOptions

getMode() - Method in class org.apache.beam.sdk.io.FileBasedSource

getMode() - Method in class org.apache.beam.sdk.values.WindowingStrategy

getMonthOfYear() - Method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows.YearsWindows

getMutableOutput(TupleTag<T>) - Method in class org.apache.beam.sdk.transforms.DoFnTester

getName() - Method in interface org.apache.beam.sdk.metrics.Metric

The MetricName given to this metric.

getName() - Method in class org.apache.beam.sdk.metrics.MetricNameFilter

If set, the metric must have this name to match this MetricNameFilter.

getName() - Method in class org.apache.beam.sdk.transforms.PTransform

Returns the transform name.

getName() - Method in class org.apache.beam.sdk.values.PCollection

Returns the name of this PCollection.

getName() - Method in interface org.apache.beam.sdk.values.PValue

Returns the name of this PValue.

getName() - Method in class org.apache.beam.sdk.values.PValueBase

Returns the name of this PValueBase.

getNameOverride() - Method in class org.apache.beam.sdk.transforms.Combine.IterableCombineFn

getNameOverride() - Method in class org.apache.beam.sdk.transforms.Top.TopCombineFn

getNamespace() - Method in class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Read

getNamespace() - Method in class org.apache.beam.sdk.metrics.MetricNameFilter

The inNamespace that a metric must be in to match this MetricNameFilter.

getNamespace() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Identifier

getNamespace() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Item

The namespace for the display item.

getNamespace() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.ItemSpec

The namespace for the display item.

getNeedsAttributes() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSource

getNetwork() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions

GCE network for launching workers.

getNextOffset() - Method in class org.apache.beam.sdk.io.kafka.KafkaCheckpointMark.PartitionMark

getNonSpeculativeIndex() - Method in class org.apache.beam.sdk.transforms.windowing.PaneInfo

The zero-based index of this trigger firing among non-speculative panes.

getNum() - Method in class org.apache.beam.runners.spark.io.ConsoleIO.Write.Unbound

getNumber() - Method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows.DaysWindows

getNumber() - Method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows.MonthsWindows

getNumber() - Method in class org.apache.beam.sdk.transforms.windowing.CalendarWindows.YearsWindows

getNumberOfExecutionRetries() - Method in interface org.apache.beam.runners.flink.FlinkPipelineOptions

getNumberOfWorkerHarnessThreads() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions

Number of threads to use on the Dataflow worker harness.

getNumQuerySplits() - Method in class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Read

getNumShards() - Method in class org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy.Context

getNumShards() - Method in class org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy.WindowedContext

getNumShards() - Method in class org.apache.beam.sdk.io.WriteFiles

getNumWorkers() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions

Number of workers to use when executing the Dataflow job.

getObject(Map<String, Object>, String) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getObject(Map<String, Object>, String, Map<String, Object>) - Static method in class org.apache.beam.runners.dataflow.util.Structs

getObjectReuse() - Method in interface org.apache.beam.runners.flink.FlinkPipelineOptions

getOffset() - Method in class org.apache.beam.sdk.io.kafka.KafkaRecord

getOffset() - Method in class org.apache.beam.sdk.transforms.windowing.FixedWindows

getOffset() - Method in class org.apache.beam.sdk.transforms.windowing.SlidingWindows

getOffset() - Method in class org.apache.beam.sdk.transforms.windowing.TimestampTransform.AlignTo

getOldestPendingTimestamp() - Method in class org.apache.beam.sdk.io.jms.JmsCheckpointMark

getOnCreateMatcher() - Method in interface org.apache.beam.sdk.testing.TestPipelineOptions

getOnly(TupleTag<V>) - Method in class org.apache.beam.sdk.transforms.join.CoGbkResult

If there is a singleton value for the given tag, returns it.

getOnly(TupleTag<V>, V) - Method in class org.apache.beam.sdk.transforms.join.CoGbkResult

If there is a singleton value for the given tag, returns it.

getOnSuccessMatcher() - Method in interface org.apache.beam.sdk.testing.TestPipelineOptions

getOnTimeBehavior() - Method in class org.apache.beam.sdk.values.WindowingStrategy

getOptions() - Method in class org.apache.beam.sdk.testing.TestPipeline

getOptionsId() - Method in interface org.apache.beam.sdk.options.PipelineOptions

Provides a unique ID for this PipelineOptions object, assigned at graph construction time.

getOrCreateReader(PipelineOptions, CheckpointMarkT) - Method in class org.apache.beam.runners.spark.io.MicrobatchSource

getOriginalWindowFn() - Method in class org.apache.beam.sdk.transforms.windowing.InvalidWindows

Returns the original windowFn that this InvalidWindows replaced.

getOutName(int) - Method in class org.apache.beam.sdk.values.TupleTag

If this TupleTag is tagging output outputIndex of a PTransform, returns the name that should be used by default for the output.

getOutputCoder(SerializableFunction<InputT, OutputT>, Coder<InputT>) - Method in class org.apache.beam.sdk.coders.CoderRegistry

Deprecated.

getOutputKvCoder(Coder<KV<K, V>>) - Static method in class org.apache.beam.sdk.transforms.GroupByKey

Returns the Coder of the output of this transform.

getOutputMap() - Method in class org.apache.beam.runners.dataflow.util.DoFnInfo

getOutputStrategyInternal(WindowingStrategy<?, ?>) - Method in class org.apache.beam.sdk.transforms.windowing.Window

Get the output strategy of this Window PTransform.

getOutputTime(Instant, GlobalWindow) - Method in class org.apache.beam.sdk.transforms.windowing.GlobalWindows

getOutputTime(Instant, W) - Method in class org.apache.beam.sdk.transforms.windowing.InvalidWindows

getOutputTime(Instant, W) - Method in class org.apache.beam.sdk.transforms.windowing.PartitioningWindowFn

getOutputTime(Instant, IntervalWindow) - Method in class org.apache.beam.sdk.transforms.windowing.SlidingWindows

Ensures that later sliding windows have an output time that is past the end of earlier windows.

getOutputTime(Instant, W) - Method in class org.apache.beam.sdk.transforms.windowing.WindowFn

Returns the output timestamp to use for data depending on the given inputTimestamp in the specified window.

getOutputType() - Method in class org.apache.beam.sdk.transforms.Combine.CombineFn

Returns a TypeDescriptor capturing what is known statically about the output type of this CombineFn instance's most-derived class.

getOutputTypeDescriptor() - Method in class org.apache.beam.runners.dataflow.BatchStatefulParDoOverrides.BatchStatefulDoFn

getOutputTypeDescriptor() - Method in class org.apache.beam.sdk.transforms.DoFn

Returns a TypeDescriptor capturing what is known statically about the output type of this DoFn instance's most-derived class.

getOutputTypeDescriptor() - Method in class org.apache.beam.sdk.transforms.SimpleFunction

Returns a TypeDescriptor capturing what is known statically about the output type of this SimpleFunction instance's most-derived class.

getOverrideWindmillBinary() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineDebugOptions

Custom windmill_main binary to use with the streaming runner.

getPane() - Method in class org.apache.beam.sdk.values.ValueInSingleWindow

Returns the pane of this ValueInSingleWindow in its window.

getPaneInfo() - Method in class org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy.WindowedContext

getPaneInfo() - Method in class org.apache.beam.sdk.io.FileBasedSink.FileResult

getParallelism() - Method in interface org.apache.beam.runners.flink.FlinkPipelineOptions

getPartition() - Method in class org.apache.beam.sdk.io.kafka.KafkaCheckpointMark.PartitionMark

getPartition() - Method in class org.apache.beam.sdk.io.kafka.KafkaRecord

getPartitionKey() - Method in class org.apache.beam.sdk.io.kinesis.KinesisRecord

getPartitions() - Method in class org.apache.beam.runners.spark.io.SourceRDD.Bounded

getPartitions() - Method in class org.apache.beam.runners.spark.io.SourceRDD.Unbounded

getPartitions() - Method in class org.apache.beam.sdk.io.kafka.KafkaCheckpointMark

getPath() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Identifier

getPath() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Item

The path for the display item within a component hierarchy.

getPathValidator() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions

The path validator instance that should be used to validate paths.

getPathValidatorClass() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcsOptions

The class of the validator that should be created and used to validate paths.

getPayload() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessage

Returns the main PubSub message.

getPayload() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getPCollection() - Method in interface org.apache.beam.sdk.values.PCollectionView

For internal use only.

getPCollection() - Method in class org.apache.beam.sdk.values.PCollectionViews.SimplePCollectionView

getPeriod() - Method in class org.apache.beam.sdk.transforms.windowing.SlidingWindows

getPeriod() - Method in class org.apache.beam.sdk.transforms.windowing.TimestampTransform.AlignTo

getPipeline() - Method in class org.apache.beam.sdk.io.gcp.bigquery.WriteResult

getPipeline() - Method in class org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults

getPipeline() - Method in class org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple

getPipeline() - Method in class org.apache.beam.sdk.values.PBegin

getPipeline() - Method in class org.apache.beam.sdk.values.PCollectionList

getPipeline() - Method in class org.apache.beam.sdk.values.PCollectionTuple

getPipeline() - Method in class org.apache.beam.sdk.values.PDone

getPipeline() - Method in interface org.apache.beam.sdk.values.PInput

Returns the owning Pipeline of this PInput.

getPipeline() - Method in interface org.apache.beam.sdk.values.POutput

Returns the owning Pipeline of this POutput.

getPipeline() - Method in class org.apache.beam.sdk.values.PValueBase

getPipelineOptions() - Method in class org.apache.beam.runners.apex.ApexRunnerRegistrar.Options

getPipelineOptions() - Method in class org.apache.beam.runners.dataflow.DataflowPipelineRegistrar.Options

getPipelineOptions() - Method in class org.apache.beam.runners.direct.DirectRegistrar.Options

getPipelineOptions() - Method in class org.apache.beam.runners.direct.DirectRunner

Returns the PipelineOptions used to create this DirectRunner.

getPipelineOptions() - Method in class org.apache.beam.runners.flink.FlinkRunner

For testing.

getPipelineOptions() - Method in class org.apache.beam.runners.flink.FlinkRunnerRegistrar.Options

getPipelineOptions() - Method in class org.apache.beam.runners.flink.TestFlinkRunner

getPipelineOptions() - Method in class org.apache.beam.runners.spark.SparkRunnerRegistrar.Options

getPipelineOptions() - Method in class org.apache.beam.sdk.extensions.gcp.options.GcpPipelineOptionsRegistrar

getPipelineOptions() - Method in class org.apache.beam.sdk.io.gcp.common.GcpIoPipelineOptionsRegistrar

getPipelineOptions() - Method in class org.apache.beam.sdk.io.hdfs.HadoopFileSystemOptionsRegistrar

getPipelineOptions() - Method in class org.apache.beam.sdk.options.DefaultPipelineOptionsRegistrar

getPipelineOptions() - Method in interface org.apache.beam.sdk.options.PipelineOptionsRegistrar

getPipelineOptions() - Method in interface org.apache.beam.sdk.state.StateContext

Returns the PipelineOptions specified with the PipelineRunner.

getPipelineOptions() - Method in class org.apache.beam.sdk.transforms.CombineWithContext.Context

Returns the PipelineOptions specified with the PipelineRunner invoking this KeyedCombineFn.

getPipelineOptions() - Method in class org.apache.beam.sdk.transforms.DoFn.FinishBundleContext

Returns the PipelineOptions specified with the PipelineRunner invoking this DoFn.

getPipelineOptions() - Method in class org.apache.beam.sdk.transforms.DoFn.StartBundleContext

Returns the PipelineOptions specified with the PipelineRunner invoking this DoFn.

getPipelineOptions() - Method in class org.apache.beam.sdk.transforms.DoFn.WindowedContext

Returns the PipelineOptions specified with the PipelineRunner invoking this DoFn.

getPipelineOptions() - Method in class org.apache.beam.sdk.transforms.DoFnTester

getPipelineRunners() - Method in class org.apache.beam.runners.apex.ApexRunnerRegistrar.Runner

getPipelineRunners() - Method in class org.apache.beam.runners.dataflow.DataflowPipelineRegistrar.Runner

getPipelineRunners() - Method in class org.apache.beam.runners.direct.DirectRegistrar.Runner

getPipelineRunners() - Method in class org.apache.beam.runners.flink.FlinkRunnerRegistrar.Runner

getPipelineRunners() - Method in class org.apache.beam.runners.spark.SparkRunnerRegistrar.Runner

getPositionForFractionConsumed(double) - Method in class org.apache.beam.sdk.io.range.OffsetRangeTracker

Returns a position P such that the range [start, P) represents approximately the given fraction of the range [start, end).

getProcessingTimeAdvance() - Method in class org.apache.beam.sdk.testing.TestStream.ProcessingTimeEvent

getProfilingAgentConfiguration() - Method in interface org.apache.beam.runners.dataflow.options.DataflowProfilingOptions

getProject() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineOptions

getProject() - Method in interface org.apache.beam.sdk.extensions.gcp.options.GcpOptions

Project id to use when launching jobs.

getProject() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubUnboundedSource

Get the project path.

getProjectId() - Method in class org.apache.beam.runners.dataflow.DataflowPipelineJob

Get the project this job exists in.

getProjectId() - Method in class org.apache.beam.runners.dataflow.util.DataflowTemplateJob

getProjectId() - Method in class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Read

getProperties() - Method in class org.apache.beam.sdk.io.jms.JmsRecord

getProvidedSparkContext() - Method in interface org.apache.beam.runners.spark.SparkContextOptions

getPubsubRootUrl() - Method in interface org.apache.beam.sdk.io.gcp.pubsub.PubsubOptions

Root URL for use with the Google Cloud Pub/Sub API.

getQuery() - Method in class org.apache.beam.sdk.io.gcp.datastore.DatastoreV1.Read

getRange() - Method in class org.apache.beam.sdk.io.range.ByteKeyRangeTracker

Returns the current range.

getRawType() - Method in class org.apache.beam.sdk.values.TypeDescriptor

Returns the Class underlying the Type represented by this TypeDescriptor.

getReadDurationMillis() - Method in class org.apache.beam.runners.spark.io.SparkUnboundedSource.Metadata

getReadTime() - Method in class org.apache.beam.sdk.io.kinesis.KinesisRecord

getReadTimePercentage() - Method in interface org.apache.beam.runners.spark.SparkPipelineOptions

getReason() - Method in exception org.apache.beam.sdk.coders.CannotProvideCoderException

getReasons() - Method in exception org.apache.beam.sdk.coders.Coder.NonDeterministicException

getRecordType() - Method in class org.apache.beam.sdk.coders.SerializableCoder

getRegion() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineOptions

The Google Compute Engine region for creating Dataflow jobs.

getRegisteredOptions() - Static method in class org.apache.beam.sdk.options.PipelineOptionsFactory

getRepeatedTrigger() - Method in class org.apache.beam.sdk.transforms.windowing.Repeatedly

getReplacedByJob() - Method in class org.apache.beam.runners.dataflow.DataflowPipelineJob

Returns a new DataflowPipelineJob for the job that replaced this one, if applicable.

getReplacedByJob() - Method in class org.apache.beam.runners.dataflow.util.DataflowTemplateJob

getReplacementTransform(AppliedPTransform<PCollection<? extends InputT>, PCollection<OutputT>, ParDo.SingleOutput<InputT, OutputT>>) - Method in class org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory

getRetainExternalizedCheckpointsOnCancellation() - Method in interface org.apache.beam.runners.flink.FlinkPipelineOptions

getRingFraction(List<CassandraServiceImpl.TokenRange>) - Static method in class org.apache.beam.sdk.io.cassandra.CassandraServiceImpl

Compute the percentage of token addressed compared with the whole tokens in the cluster.

getRootCause() - Method in exception org.apache.beam.sdk.coders.CannotProvideCoderException

Returns the inner-most CannotProvideCoderException when they are deeply nested.

getRunMillis() - Method in interface org.apache.beam.runners.apex.ApexPipelineOptions

getRunner() - Method in interface org.apache.beam.sdk.options.PipelineOptions

The pipeline runner that will be used to execute the pipeline.

getSaveProfilesToGcs() - Method in interface org.apache.beam.runners.dataflow.options.DataflowProfilingOptions

getSchema() - Method in class org.apache.beam.sdk.coders.AvroCoder

Returns the schema used by this coder.

getSchema() - Method in class org.apache.beam.sdk.io.AvroSource

getSchema(DestinationT) - Method in class org.apache.beam.sdk.io.gcp.bigquery.DynamicDestinations

Returns the table schema for the destination.

getSchema() - Method in class org.apache.beam.sdk.transforms.join.CoGbkResult.CoGbkResultCoder

getSchema() - Method in class org.apache.beam.sdk.transforms.join.CoGbkResult

Returns the schema used by this CoGbkResult.

getScheme() - Method in class org.apache.beam.sdk.extensions.gcp.storage.GcsResourceId

getScheme() - Method in class org.apache.beam.sdk.io.FileSystem

Get the URI scheme which defines the namespace of the FileSystem.

getScheme() - Method in interface org.apache.beam.sdk.io.fs.ResourceId

Get the scheme which defines the namespace of the ResourceId.

getSequenceNumber() - Method in class org.apache.beam.sdk.io.kinesis.KinesisRecord

getServiceAccount() - Method in interface org.apache.beam.runners.dataflow.options.DataflowPipelineOptions

Run the job as a specific service account, instead of the default GCE robot.

getShard() - Method in class org.apache.beam.sdk.io.FileBasedSink.FileResult

getShardId() - Method in class org.apache.beam.sdk.io.kinesis.KinesisRecord

getSharding() - Method in class org.apache.beam.sdk.io.WriteFiles

Gets the PTransform that will be used to determine sharding.

getShardNumber() - Method in class org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy.Context

getShardNumber() - Method in class org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy.WindowedContext

getShortValue() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.Item

Return the optional short value for an item, or null if none is provided.

getShortValue() - Method in class org.apache.beam.sdk.transforms.display.DisplayData.ItemSpec

The optional short value for an item, or null if none is provided.

getSideInputs() - Method in class org.apache.beam.runners.dataflow.PrimitiveParDoSingleFactory.ParDoSingle

getSideInputs() - Method in class org.apache.beam.sdk.io.gcp.bigquery.DynamicDestinations

Specifies that this object needs access to one or more side inputs.

getSideInputs() - Method in class org.apache.beam.sdk.transforms.Combine.Globally

Returns the side inputs used by this Combine operation.

getSideInputs() - Method in class org.apache.beam.sdk.transforms.Combine.GroupedValues

getSideInputs() - Method in class org.apache.beam.sdk.transforms.Combine.PerKey

Returns the side inputs used by this Combine operation.

getSideInputs() - Method in class org.apache.beam.sdk.transforms.ParDo.MultiOutput

getSideInputs() - Method in class org.apache.beam.sdk.transforms.ParDo.SingleOutput

getSideInputViews() - Method in class org.apache.beam.runners.dataflow.util.DoFnInfo

getSideInputWindow(BoundedWindow) - Method in class org.apache.beam.sdk.transforms.windowing.WindowMappingFn

Returns the window of the side input corresponding to the given window of the main input.

getSingleFileMetadata() - Method in class org.apache.beam.sdk.io.FileBasedSource

Returns the information about the single file that this source is reading from.

getSink() - Method in class org.apache.beam.sdk.io.FileBasedSink.WriteOperation

Returns the FileBasedSink for this write operation.

getSink() - Method in class org.apache.beam.sdk.io.WriteFiles

Returns the FileBasedSink associated with this PTransform.

getSize() - Method in class org.apache.beam.sdk.transforms.windowing.FixedWindows

getSize() - Method in class org.apache.beam.sdk.transforms.windowing.SlidingWindows

getSource() - Method in class org.apache.beam.sdk.io.Read.Bounded

Returns the BoundedSource used to create this Read PTransform.

getSource() - Method in class org.apache.beam.sdk.io.Read.Unbounded

Returns the UnboundedSource used to create this Read PTransform.

getSource() - Method in class org.apache.beam.sdk.io.TextIO.Read

getSource() - Method in class org.apache.beam.sdk.io.TFRecordIO.Read

getSparkMaster() - Method in interface org.apache.beam.runners.spark.SparkPipelineOptions

getSplit() - Method in class org.apache.beam.sdk.io.hadoop.inputformat.HadoopInputFormatIO.SerializableSplit

getSplitBacklogBytes() - Method in class org.apache.beam.sdk.io.UnboundedSource.UnboundedReader

Returns the size of the backlog of unread data in the underlying data source represented by this split of this source.

getSplitPointsConsumed() - Method in class org.apache.beam.sdk.io.BoundedSource.BoundedReader

Returns the total amount of parallelism in the consumed (returned and processed) range of this reader's current BoundedSource (as would be returned by BoundedSource.BoundedReader.getCurrentSource()).

getSplitPointsConsumed() - Method in class org.apache.beam.sdk.io.CompressedSource.CompressedReader

getSplitPointsConsumed() - Method in class org.apache.beam.sdk.io.OffsetBasedSource.OffsetBasedReader