Index (Apache Beam 2.39.0)

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

abort() - Method in interface org.apache.beam.runners.fnexecution.state.StateDelegator.Registration

De-registers the handler for all future requests for state for the registered process bundle instruction id.

abort(Executor) - Method in class org.apache.beam.sdk.extensions.sql.impl.CalciteConnectionWrapper

absolute(String, String...) - Static method in class org.apache.beam.sdk.transforms.display.DisplayData.Path

Construct a path from an absolute component path hierarchy.

AbstractBeamCalcRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel

BeamRelNode to replace Project and Filter node.

AbstractBeamCalcRel(RelOptCluster, RelTraitSet, RelNode, RexProgram) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.AbstractBeamCalcRel

AbstractGetterTypeSupplier() - Constructor for class org.apache.beam.sdk.schemas.AutoValueSchema.AbstractGetterTypeSupplier

AbstractTranslationContext - Class in org.apache.beam.runners.spark.structuredstreaming.translation

Base class that gives a context for PTransform translation: keeping track of the datasets, the SparkSession, the current transform being translated.

AbstractTranslationContext(SparkStructuredStreamingPipelineOptions) - Constructor for class org.apache.beam.runners.spark.structuredstreaming.translation.AbstractTranslationContext

accept(ByteString, Boolean) - Method in class org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver

Deprecated.

accept(BeamFnApi.Elements) - Method in class org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver2

accept(T) - Method in class org.apache.beam.sdk.fn.data.BeamFnDataOutboundObserver

Deprecated.

accept(ByteString) - Method in class org.apache.beam.sdk.fn.data.DecodingFnDataReceiver

accept(T) - Method in interface org.apache.beam.sdk.fn.data.FnDataReceiver

accept(T1, T2) - Method in interface org.apache.beam.sdk.function.ThrowingBiConsumer

accept(T) - Method in interface org.apache.beam.sdk.function.ThrowingConsumer

accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.ArrayQualifierContext

accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.ArrayQualifierListContext

accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.DotExpressionContext

accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.FieldSpecifierContext

accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.MapQualifierContext

accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.MapQualifierListContext

accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.QualifiedComponentContext

accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.QualifyComponentContext

accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.SimpleIdentifierContext

accept(ParseTreeVisitor<? extends T>) - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.WildcardContext

accept(SchemaZipFold.Context, Schema.FieldType, Schema.FieldType) - Method in class org.apache.beam.sdk.schemas.utils.SchemaZipFold

Accepts two components, context.parent() is always ROW, MAP, ARRAY or absent.

accept(SchemaZipFold.Context, Optional<Schema.Field>, Optional<Schema.Field>) - Method in class org.apache.beam.sdk.schemas.utils.SchemaZipFold

Accepts two fields, context.parent() is always ROW.

accessPattern() - Method in class org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.SideInputSpec

accumulate(T, T) - Method in class org.apache.beam.sdk.schemas.utils.SchemaZipFold

Accumulate two results together.

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

ackDeadlineSeconds(PubsubClient.SubscriptionPath) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubClient

Return the ack deadline, in seconds, for subscription.

ackDeadlineSeconds(PubsubClient.SubscriptionPath) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubGrpcClient

ackDeadlineSeconds(PubsubClient.SubscriptionPath) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubJsonClient

ackDeadlineSeconds(PubsubClient.SubscriptionPath) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubTestClient

acknowledge(PubsubClient.SubscriptionPath, List<String>) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubClient

Acknowldege messages from subscription with ackIds.

acknowledge(PubsubClient.SubscriptionPath, List<String>) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubGrpcClient

acknowledge(PubsubClient.SubscriptionPath, List<String>) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubJsonClient

acknowledge(PubsubClient.SubscriptionPath, List<String>) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubTestClient

acquireTaskAttemptIdLock(Configuration, int) - Method in interface org.apache.beam.sdk.io.hadoop.format.ExternalSynchronization

Creates unique TaskAttemptID for given taskId.

acquireTaskAttemptIdLock(Configuration, int) - Method in class org.apache.beam.sdk.io.hadoop.format.HDFSSynchronization

acquireTaskIdLock(Configuration) - Method in interface org.apache.beam.sdk.io.hadoop.format.ExternalSynchronization

Creates TaskID with unique id among given job.

acquireTaskIdLock(Configuration) - Method in class org.apache.beam.sdk.io.hadoop.format.HDFSSynchronization

ActionFactory - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.action

Factory class for creating instances that will handle each type of record within a change stream query.

ActionFactory() - Constructor for class org.apache.beam.sdk.io.gcp.spanner.changestreams.action.ActionFactory

ACTIVE_PARTITION_READ_COUNT - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.ChangeStreamMetrics

Counter for the active partition reads during the execution of the Connector.

actuateProjectionPushdown(Map<TupleTag<?>, FieldAccessDescriptor>) - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.TypedRead

actuateProjectionPushdown(Map<TupleTag<?>, FieldAccessDescriptor>) - Method in interface org.apache.beam.sdk.schemas.ProjectionProducer

Actuate a projection pushdown.

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

add(NamedAggregators) - Method in class org.apache.beam.runners.spark.aggregators.NamedAggregatorsAccumulator

add(MetricsContainerStepMap) - Method in class org.apache.beam.runners.spark.metrics.MetricsContainerStepMapAccumulator

add(NamedAggregators) - Method in class org.apache.beam.runners.spark.structuredstreaming.aggregators.NamedAggregatorsAccumulator

add(MetricsContainerStepMap) - Method in class org.apache.beam.runners.spark.structuredstreaming.metrics.MetricsContainerStepMapAccumulator

add(String, Broadcast<?>, Coder<?>) - Method in class org.apache.beam.runners.spark.structuredstreaming.translation.helpers.SideInputBroadcast

add(int, GlobalWatermarkHolder.SparkWatermarks) - Static method in class org.apache.beam.runners.spark.util.GlobalWatermarkHolder

add(T) - Method in class org.apache.beam.runners.twister2.translators.functions.Twister2SinkFunction

add(T, long, Coder<T>) - Method in class org.apache.beam.sdk.extensions.sketching.SketchFrequencies.Sketch

add(T, Coder<T>) - Method in class org.apache.beam.sdk.extensions.sketching.SketchFrequencies.Sketch

add(KV<byte[], byte[]>) - Method in class org.apache.beam.sdk.extensions.sorter.BufferedExternalSorter

add(Class<?>, String) - Method in class org.apache.beam.sdk.extensions.sql.impl.UdfImplReflectiveFunctionBase.ParameterListBuilder

add(Type, String, boolean) - Method in class org.apache.beam.sdk.extensions.sql.impl.UdfImplReflectiveFunctionBase.ParameterListBuilder

add(List<ValueInSingleWindow<T>>, TableDataInsertAllResponse.InsertErrors, TableReference, FailsafeValueInSingleWindow<TableRow, TableRow>) - Method in interface org.apache.beam.sdk.io.gcp.bigquery.ErrorContainer

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

Deprecated.

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

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

Add an accumulator to this state cell.

addAll(Map<Integer, Queue<GlobalWatermarkHolder.SparkWatermarks>>) - Static method in class org.apache.beam.runners.spark.util.GlobalWatermarkHolder

addArray(Collection<T>) - Method in class org.apache.beam.sdk.values.Row.Builder

addArray(Object...) - Method in class org.apache.beam.sdk.values.Row.Builder

addArrayField(String, Schema.FieldType) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addAttempted(T, BiFunction<T, T, T>) - Method in class org.apache.beam.sdk.metrics.MetricResult

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

addBooleanField(String) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addByteArrayField(String) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addByteField(String) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addCollectionToSingletonOutput(PCollection<?>, String, PCollectionView<?>) - Method in interface org.apache.beam.runners.dataflow.TransformTranslator.StepTranslationContext

Adds an output to this CollectionToSingleton Dataflow step, consuming the specified input PValue and producing the specified output PValue.

addCommitted(T, BiFunction<T, T, T>) - Method in class org.apache.beam.sdk.metrics.MetricResult

addDataSet(String, DataSet<T>) - Method in class org.apache.beam.runners.flink.FlinkBatchPortablePipelineTranslator.BatchTranslationContext

addDataStream(String, DataStream<T>) - Method in class org.apache.beam.runners.flink.FlinkStreamingPortablePipelineTranslator.StreamingTranslationContext

addDateTimeField(String) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addDecimalField(String) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

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

addDoubleField(String) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

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.

addEncodingInput(Coder<?>) - Method in interface org.apache.beam.runners.dataflow.TransformTranslator.StepTranslationContext

Sets the encoding for this Dataflow step.

addErrorForCode(int, String) - Method in class org.apache.beam.sdk.extensions.gcp.util.CustomHttpErrors.Builder

Adds a matcher to log the provided string if the error matches a particular status code.

addErrorForCodeAndUrlContains(int, String, String) - Method in class org.apache.beam.sdk.extensions.gcp.util.CustomHttpErrors.Builder

Adds a matcher to log the provided string if the error matches a particular status code and the url contains a certain string.

addExperiment(ExperimentalOptions, String) - Static method in interface org.apache.beam.sdk.options.ExperimentalOptions

Adds experiment to options if not already present.

addField(Schema.Field) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addField(String, Schema.FieldType) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addFields(List<Schema.Field>) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addFields(Schema.Field...) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

AddFields - Class in org.apache.beam.sdk.schemas.transforms

A transform to add new nullable fields to a PCollection's schema.

AddFields() - Constructor for class org.apache.beam.sdk.schemas.transforms.AddFields

AddFields.Inner<T> - Class in org.apache.beam.sdk.schemas.transforms

Inner PTransform for AddFields.

addFloatField(String) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

AddHarnessIdInterceptor - Class in org.apache.beam.sdk.fn.channel

A ClientInterceptor that attaches a provided SDK Harness ID to outgoing messages.

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

addIfNotNull(DisplayData.ItemSpec<?>) - Method in interface org.apache.beam.sdk.transforms.display.DisplayData.Builder

addInput(String, Boolean) - Method in interface org.apache.beam.runners.dataflow.TransformTranslator.StepTranslationContext

Adds an input with the given name and value to this Dataflow step.

addInput(String, String) - Method in interface org.apache.beam.runners.dataflow.TransformTranslator.StepTranslationContext

Adds an input with the given name and value to this Dataflow step.

addInput(String, Long) - Method in interface org.apache.beam.runners.dataflow.TransformTranslator.StepTranslationContext

Adds an input with the given name and value to this Dataflow step.

addInput(String, PInput) - Method in interface org.apache.beam.runners.dataflow.TransformTranslator.StepTranslationContext

Adds an input with the given name to this Dataflow step, coming from the specified input PValue.

addInput(String, Map<String, Object>) - Method in interface org.apache.beam.runners.dataflow.TransformTranslator.StepTranslationContext

Adds an input that is a dictionary of strings to objects.

addInput(String, List<? extends Map<String, Object>>) - Method in interface org.apache.beam.runners.dataflow.TransformTranslator.StepTranslationContext

Adds an input that is a list of objects.

addInput(HyperLogLogPlus, InputT) - Method in class org.apache.beam.sdk.extensions.sketching.ApproximateDistinct.ApproximateDistinctFn

addInput(SketchFrequencies.Sketch<InputT>, InputT) - Method in class org.apache.beam.sdk.extensions.sketching.SketchFrequencies.CountMinSketchFn

addInput(MergingDigest, Double) - Method in class org.apache.beam.sdk.extensions.sketching.TDigestQuantiles.TDigestQuantilesFn

addInput(AccumT, InputT) - Method in class org.apache.beam.sdk.extensions.sql.impl.LazyAggregateCombineFn

addInput(long[], Boolean) - Method in class org.apache.beam.sdk.extensions.sql.impl.transform.agg.CountIf.CountIfFn

addInput(CovarianceAccumulator, Row) - Method in class org.apache.beam.sdk.extensions.sql.impl.transform.agg.CovarianceFn

addInput(VarianceAccumulator, T) - Method in class org.apache.beam.sdk.extensions.sql.impl.transform.agg.VarianceFn

addInput(BeamBuiltinAggregations.BitXOr.Accum, T) - Method in class org.apache.beam.sdk.extensions.sql.impl.transform.BeamBuiltinAggregations.BitXOr

addInput(AccumT, InputT, Long, Long, Long) - Method in class org.apache.beam.sdk.extensions.sql.impl.transform.BeamBuiltinAnalyticFunctions.PositionAwareCombineFn

addInput(AccumT, InputT) - Method in class org.apache.beam.sdk.extensions.sql.impl.transform.BeamBuiltinAnalyticFunctions.PositionAwareCombineFn

addInput(List<T>, T) - Method in class org.apache.beam.sdk.extensions.sql.impl.udaf.ArrayAgg.ArrayAggArray

addInput(String, byte[]) - Method in class org.apache.beam.sdk.extensions.sql.impl.udaf.StringAgg.StringAggByte

addInput(String, String) - Method in class org.apache.beam.sdk.extensions.sql.impl.udaf.StringAgg.StringAggString

addInput(Long, Long) - Method in class org.apache.beam.sdk.extensions.sql.provider.UdfTestProvider.Sum

addInput(AccumT, InputT) - Method in class org.apache.beam.sdk.extensions.sql.TypedCombineFnDelegate

addInput(AccumT, InputT) - Method in interface org.apache.beam.sdk.extensions.sql.udf.AggregateFn

Adds the given input value to the given accumulator, returning the new accumulator value.

addInput(List<String>, String) - Method in class org.apache.beam.sdk.io.snowflake.SnowflakeIO.Concatenate

addInput(ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique, T) - Method in class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn

Deprecated.

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

addInt16Field(String) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addInt32Field(String) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addInt64Field(String) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addIterable(Iterable<T>) - Method in class org.apache.beam.sdk.values.Row.Builder

addIterableField(String, Schema.FieldType) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addLengthPrefixedCoder(String, RunnerApi.Components.Builder, boolean) - Static method in class org.apache.beam.runners.fnexecution.wire.LengthPrefixUnknownCoders

Recursively traverses the coder tree and wraps the first unknown coder in every branch with a LengthPrefixCoder unless an ancestor coder is itself a LengthPrefixCoder.

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

addLogicalTypeField(String, Schema.LogicalType<InputT, BaseT>) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

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

addMapField(String, Schema.FieldType, Schema.FieldType) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addMessageListener(Consumer<JobApi.JobMessage>) - Method in class org.apache.beam.runners.jobsubmission.JobInvocation

Listen for job messages with a Consumer.

addMethodParameters(Method) - Method in class org.apache.beam.sdk.extensions.sql.impl.UdfImplReflectiveFunctionBase.ParameterListBuilder

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

addNullableField(String, Schema.FieldType) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

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

addOptions(Schema.Options) - Method in class org.apache.beam.sdk.schemas.Schema.Options.Builder

addOutput(String, PCollection<?>) - Method in interface org.apache.beam.runners.dataflow.TransformTranslator.StepTranslationContext

Adds a primitive output to this Dataflow step with the given name as the local output name, producing the specified output PValue, including its Coder if a TypedPValue.

addOutputColumnList(List<ResolvedNodes.ResolvedOutputColumn>) - Method in class org.apache.beam.sdk.extensions.sql.zetasql.QueryTrait

addOverrideForClass(Class<?>, DataflowWorkerLoggingOptions.Level) - Method in class org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.WorkerLogLevelOverrides

Deprecated.

Overrides the default log level for the passed in class.

addOverrideForClass(Class<?>, SdkHarnessOptions.LogLevel) - Method in class org.apache.beam.sdk.options.SdkHarnessOptions.SdkHarnessLogLevelOverrides

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

Deprecated.

Overrides the default log level for the passed in name.

addOverrideForName(String, SdkHarnessOptions.LogLevel) - Method in class org.apache.beam.sdk.options.SdkHarnessOptions.SdkHarnessLogLevelOverrides

Overrides the default log logLevel for the passed in name.

addOverrideForPackage(Package, DataflowWorkerLoggingOptions.Level) - Method in class org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions.WorkerLogLevelOverrides

Deprecated.

Overrides the default log level for the passed in package.

addOverrideForPackage(Package, SdkHarnessOptions.LogLevel) - Method in class org.apache.beam.sdk.options.SdkHarnessOptions.SdkHarnessLogLevelOverrides

Overrides the default log level for the passed in package.

addResolvedTable(TableResolution.SimpleTableWithPath) - Method in class org.apache.beam.sdk.extensions.sql.zetasql.QueryTrait

Store a table together with its full path for repeated resolutions.

addRowField(String, Schema) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

addRows(Object...) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestBoundedTable

Add rows to the builder.

addRows(String, Row...) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTableProvider

addRows(Duration, Object...) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestUnboundedTable

Add rows to the builder.

addRunnerWireCoder(PipelineNode.PCollectionNode, RunnerApi.Components.Builder, RunnerApi.ExecutableStagePayload.WireCoderSetting) - Static method in class org.apache.beam.runners.fnexecution.wire.WireCoders

Creates a runner-side wire coder for a port read/write for the given PCollection.

addSchema(String, TableProvider) - Method in class org.apache.beam.sdk.extensions.sql.impl.BeamSqlEnv.BeamSqlEnvBuilder

Add a top-level schema backed by the table provider.

addSdkWireCoder(PipelineNode.PCollectionNode, RunnerApi.Components.Builder, RunnerApi.ExecutableStagePayload.WireCoderSetting) - Static method in class org.apache.beam.runners.fnexecution.wire.WireCoders

Creates an SDK-side wire coder for a port read/write for the given PCollection.

addStateListener(Consumer<JobApi.JobStateEvent>) - Method in class org.apache.beam.runners.jobsubmission.JobInvocation

Listen for job state changes with a Consumer.

addStep(PTransform<?, ?>, String) - Method in interface org.apache.beam.runners.dataflow.TransformTranslator.TranslationContext

Adds a step to the Dataflow workflow for the given transform, with the given Dataflow step type.

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

addStringField(String) - Method in class org.apache.beam.sdk.schemas.Schema.Builder

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.

addUdaf(String, Combine.CombineFn) - Method in class org.apache.beam.sdk.extensions.sql.impl.BeamSqlEnv.BeamSqlEnvBuilder

addUdf(String, Class<?>, String) - Method in class org.apache.beam.sdk.extensions.sql.impl.BeamSqlEnv.BeamSqlEnvBuilder

addUdf(String, Class<? extends BeamSqlUdf>) - Method in class org.apache.beam.sdk.extensions.sql.impl.BeamSqlEnv.BeamSqlEnvBuilder

addUdf(String, SerializableFunction) - Method in class org.apache.beam.sdk.extensions.sql.impl.BeamSqlEnv.BeamSqlEnvBuilder

addUuids() - Static method in class org.apache.beam.sdk.io.gcp.pubsublite.PubsubLiteIO

Add Uuids to to-be-published messages that ensures that uniqueness is maintained.

AddUuidsTransform - Class in org.apache.beam.sdk.io.gcp.pubsublite.internal

A transform to add UUIDs to each message to be written to Pub/Sub Lite.

AddUuidsTransform() - Constructor for class org.apache.beam.sdk.io.gcp.pubsublite.internal.AddUuidsTransform

addValue(Object) - Method in class org.apache.beam.sdk.values.Row.Builder

addValues(List<Object>) - Method in class org.apache.beam.sdk.values.Row.Builder

addValues(Object...) - Method in class org.apache.beam.sdk.values.Row.Builder

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

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

See GlobalWatermarkHolder.advance(String).

advance() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubTestClient

For subscription mode only: Track progression of time according to the Clock passed .

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.

AdvancingPhaser - Class in org.apache.beam.sdk.fn.stream

A Phaser which never terminates.

AdvancingPhaser(int) - Constructor for class org.apache.beam.sdk.fn.stream.AdvancingPhaser

AfterAll - Class in org.apache.beam.sdk.transforms.windowing

A composite Trigger that fires when all of its sub-triggers are ready.

afterBundleCommit(Instant, DoFn.BundleFinalizer.Callback) - Method in interface org.apache.beam.sdk.transforms.DoFn.BundleFinalizer

The provided function will be called after the runner successfully commits the output of a successful bundle.

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.

afterIterations(int) - Static method in class org.apache.beam.sdk.transforms.Watch.Growth

Returns a Watch.Growth.TerminationCondition that holds after the given number of polling iterations have occurred per-input.

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.

afterTimeSinceNewOutput(ReadableDuration) - Static method in class org.apache.beam.sdk.transforms.Watch.Growth

Returns a Watch.Growth.TerminationCondition that holds after the given time has elapsed after the last time the Watch.Growth.PollResult for the current input contained a previously unseen output.

afterTimeSinceNewOutput(SerializableFunction<InputT, ReadableDuration>) - Static method in class org.apache.beam.sdk.transforms.Watch.Growth

Like Watch.Growth.afterTimeSinceNewOutput(ReadableDuration), but the duration is input-dependent.

afterTotalOf(ReadableDuration) - Static method in class org.apache.beam.sdk.transforms.Watch.Growth

Returns a Watch.Growth.TerminationCondition that holds after the given time has elapsed after the current input was seen.

afterTotalOf(SerializableFunction<InputT, ReadableDuration>) - Static method in class org.apache.beam.sdk.transforms.Watch.Growth

Like Watch.Growth.afterTotalOf(ReadableDuration), but the duration is input-dependent.

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.

aggregate(Combine.CombineFn<InputT, ?, OutputT>) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

Aggregate the grouped data using the specified Combine.CombineFn.

AggregateCombiner() - Constructor for class org.apache.beam.sdk.schemas.transforms.Group.AggregateCombiner

aggregateField(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.AggregateCombiner

Build up an aggregation function over the input elements.

aggregateField(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.AggregateCombiner

Build up an aggregation function over the input elements.

aggregateField(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

Build up an aggregation function over the input elements.

aggregateField(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

aggregateField(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

Build up an aggregation function over the input elements.

aggregateField(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

aggregateField(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

Build up an aggregation function over the input elements.

aggregateField(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

aggregateField(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

Build up an aggregation function over the input elements.

aggregateField(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

aggregateField(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

Build up an aggregation function over the input elements.

aggregateField(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

aggregateField(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

Build up an aggregation function over the input elements.

aggregateField(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

aggregateField(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

Build up an aggregation function over the input elements.

aggregateField(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

The same as

Group.Global.aggregateField(java.lang.String, org.apache.beam.sdk.transforms.Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, java.lang.String)

but using field id.

aggregateField(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

Build up an aggregation function over the input elements.

aggregateField(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

The same as

Group.Global.aggregateField(java.lang.String, org.apache.beam.sdk.transforms.Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, java.lang.String)

but using field id.

aggregateFieldBaseValue(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

aggregateFieldBaseValue(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

aggregateFieldBaseValue(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

aggregateFieldBaseValue(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

aggregateFieldBaseValue(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

aggregateFieldBaseValue(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

aggregateFieldBaseValue(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

aggregateFieldBaseValue(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

aggregateFieldBaseValue(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

aggregateFieldBaseValue(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

aggregateFieldBaseValue(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

aggregateFieldBaseValue(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

aggregateFieldBaseValue(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

aggregateFieldBaseValue(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

aggregateFieldBaseValue(String, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

aggregateFieldBaseValue(int, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

aggregateFields(List<String>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

Build up an aggregation function over the input elements.

aggregateFields(FieldAccessDescriptor, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

Build up an aggregation function over the input elements.

aggregateFields(List<String>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

Build up an aggregation function over the input elements.

aggregateFields(FieldAccessDescriptor, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

Build up an aggregation function over the input elements.

aggregateFields(List<String>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

Build up an aggregation function over the input elements.

aggregateFields(FieldAccessDescriptor, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

Build up an aggregation function over the input elements.

aggregateFields(List<String>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

Build up an aggregation function over the input elements.

aggregateFields(FieldAccessDescriptor, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

Build up an aggregation function over the input elements.

aggregateFields(List<String>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

Build up an aggregation function over the input elements.

aggregateFields(FieldAccessDescriptor, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

Build up an aggregation function over the input elements.

aggregateFields(List<String>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

Build up an aggregation function over the input elements.

aggregateFields(FieldAccessDescriptor, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

Build up an aggregation function over the input elements.

aggregateFields(List<String>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

Build up an aggregation function over the input elements.

aggregateFields(FieldAccessDescriptor, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

Build up an aggregation function over the input elements.

aggregateFields(List<String>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

Build up an aggregation function over the input elements.

aggregateFields(FieldAccessDescriptor, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

Build up an aggregation function over the input elements.

aggregateFieldsById(List<Integer>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.AggregateCombiner

Build up an aggregation function over the input elements by field id.

aggregateFieldsById(List<Integer>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

aggregateFieldsById(List<Integer>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.ByFields

aggregateFieldsById(List<Integer>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields

aggregateFieldsById(List<Integer>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

aggregateFieldsById(List<Integer>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsGlobally

aggregateFieldsById(List<Integer>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, String) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

The same as

Group.Global.aggregateFields(java.util.List<java.lang.String>, org.apache.beam.sdk.transforms.Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, java.lang.String)

but with field ids.

aggregateFieldsById(List<Integer>, Combine.CombineFn<CombineInputT, AccumT, CombineOutputT>, Schema.Field) - Method in class org.apache.beam.sdk.schemas.transforms.Group.Global

AggregateFn<InputT,AccumT,OutputT> - Interface in org.apache.beam.sdk.extensions.sql.udf

An aggregate function that can be executed as part of a SQL query.

AggregationCombineFnAdapter<T> - Class in org.apache.beam.sdk.extensions.sql.impl.transform.agg

Wrapper Combine.CombineFns for aggregation function calls.

AggregationCombineFnAdapter() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.transform.agg.AggregationCombineFnAdapter

AggregationQuery - Class in org.apache.beam.sdk.io.mongodb

Builds a MongoDB AggregateIterable object.

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

AggregatorMetric - Class in org.apache.beam.runners.spark.metrics

An adapter between the NamedAggregators and Codahale's Metric interface.

AggregatorMetric - Class in org.apache.beam.runners.spark.structuredstreaming.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

AggregatorMetricSource - Class in org.apache.beam.runners.spark.structuredstreaming.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.structuredstreaming.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 - Class in org.apache.beam.runners.spark.structuredstreaming.aggregators

For resilience, Accumulators are required to be wrapped in a Singleton.

AggregatorsAccumulator() - Constructor for class org.apache.beam.runners.spark.structuredstreaming.aggregators.AggregatorsAccumulator

AggregatorsAccumulator.AccumulatorCheckpointingSparkListener - Class in org.apache.beam.runners.spark.aggregators

Spark Listener which checkpoints NamedAggregators values for fault-tolerance.

algorithm(String) - Method in class org.apache.beam.sdk.io.aws2.s3.SSECustomerKey.Builder

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.

allLeavesDescriptor(Schema, SerializableFunction<List<String>, String>) - Static method in class org.apache.beam.sdk.schemas.utils.SelectHelpers

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

allMetrics() - Method in class org.apache.beam.sdk.metrics.MetricResults

allocateAddressAndCreate(List<BindableService>, Endpoints.ApiServiceDescriptor.Builder) - Method in class org.apache.beam.sdk.fn.server.InProcessServerFactory

allocateAddressAndCreate(List<BindableService>, Endpoints.ApiServiceDescriptor.Builder) - Method in class org.apache.beam.sdk.fn.server.ServerFactory

Creates an instance of this server using an ephemeral address.

allocateAddressAndCreate(List<BindableService>, Endpoints.ApiServiceDescriptor.Builder) - Method in class org.apache.beam.sdk.fn.server.ServerFactory.InetSocketAddressServerFactory

allocatePortAndCreateFor(ServiceT, ServerFactory) - Static method in class org.apache.beam.sdk.fn.server.GrpcFnServer

Create a GrpcFnServer for the provided FnService running on an arbitrary port.

allocatePortAndCreateFor(List<? extends FnService>, ServerFactory) - Static method in class org.apache.beam.sdk.fn.server.GrpcFnServer

Create GrpcFnServers for the provided FnServices running on an arbitrary port.

allOf(Iterable<SerializableMatcher<? super T>>) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.allOf(Iterable).

allOf(SerializableMatcher<T>...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.allOf(Matcher[]).

allOf(Watch.Growth.TerminationCondition<InputT, FirstStateT>, Watch.Growth.TerminationCondition<InputT, SecondStateT>) - Static method in class org.apache.beam.sdk.transforms.Watch.Growth

Returns a Watch.Growth.TerminationCondition that holds when both of the given two conditions hold.

ALLOWS_SHARDABLE_STATE - Static variable in class org.apache.beam.runners.dataflow.util.PropertyNames

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(String, PCollection<KV<K, V>>) - Method in class org.apache.beam.sdk.transforms.join.KeyedPCollectionTuple

A version of KeyedPCollectionTuple.and(String, PCollection) that takes in a string instead of a TupleTag.

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(String, PCollection<Row>) - Method in class org.apache.beam.sdk.values.PCollectionRowTuple

Returns a new PCollectionRowTuple that has each PCollection and tag of this PCollectionRowTuple plus the given PCollection associated with the given tag.

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(String, PCollection<T>) - Method in class org.apache.beam.sdk.values.PCollectionTuple

A version of PCollectionTuple.and(TupleTag, PCollection) that takes in a String instead of a 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.

annotateFromBytes(PCollectionView<Map<ByteString, VideoContext>>, List<Feature>) - Static method in class org.apache.beam.sdk.extensions.ml.VideoIntelligence

Annotates videos from ByteStrings of their contents.

annotateFromBytesWithContext(List<Feature>) - Static method in class org.apache.beam.sdk.extensions.ml.VideoIntelligence

Annotates videos from key-value pairs of ByteStrings and VideoContext.

annotateFromURI(List<Feature>, PCollectionView<Map<String, VideoContext>>) - Static method in class org.apache.beam.sdk.extensions.ml.VideoIntelligence

Annotates videos from GCS URIs.

annotateFromUriWithContext(List<Feature>) - Static method in class org.apache.beam.sdk.extensions.ml.VideoIntelligence

Annotates videos from key-value pairs of GCS URI and VideoContext.

annotateImagesFromBytes(PCollectionView<Map<ByteString, ImageContext>>, List<Feature>, long, int) - Static method in class org.apache.beam.sdk.extensions.ml.CloudVision

Creates a PTransform that annotates images from their contents encoded in ByteStrings.

annotateImagesFromBytes(PCollectionView<Map<ByteString, ImageContext>>, List<Feature>, long) - Static method in class org.apache.beam.sdk.extensions.ml.CloudVision

Creates a PTransform that annotates images from their contents encoded in ByteStrings.

AnnotateImagesFromBytes(PCollectionView<Map<ByteString, ImageContext>>, List<Feature>, long, int) - Constructor for class org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromBytes

annotateImagesFromBytesWithContext(List<Feature>, long, int) - Static method in class org.apache.beam.sdk.extensions.ml.CloudVision

Creates a PTransform that annotates images from KVs of their GCS addresses in Strings and ImageContext for each image.

annotateImagesFromBytesWithContext(List<Feature>, long) - Static method in class org.apache.beam.sdk.extensions.ml.CloudVision

Creates a PTransform that annotates images from KVs of their GCS addresses in Strings and ImageContext for each image.

AnnotateImagesFromBytesWithContext(List<Feature>, long, int) - Constructor for class org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromBytesWithContext

annotateImagesFromGcsUri(PCollectionView<Map<String, ImageContext>>, List<Feature>, long, int) - Static method in class org.apache.beam.sdk.extensions.ml.CloudVision

Creates a PTransform that annotates images from their GCS addresses.

annotateImagesFromGcsUri(PCollectionView<Map<String, ImageContext>>, List<Feature>, long) - Static method in class org.apache.beam.sdk.extensions.ml.CloudVision

Creates a PTransform that annotates images from their GCS addresses.

AnnotateImagesFromGcsUri(PCollectionView<Map<String, ImageContext>>, List<Feature>, long, int) - Constructor for class org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromGcsUri

annotateImagesFromGcsUriWithContext(List<Feature>, long, int) - Static method in class org.apache.beam.sdk.extensions.ml.CloudVision

Creates a PTransform that annotates images from KVs of their String-encoded contents and ImageContext for each image.

annotateImagesFromGcsUriWithContext(List<Feature>, long) - Static method in class org.apache.beam.sdk.extensions.ml.CloudVision

Creates a PTransform that annotates images from KVs of their String-encoded contents and ImageContext for each image.

AnnotateImagesFromGcsUriWithContext(List<Feature>, long, int) - Constructor for class org.apache.beam.sdk.extensions.ml.CloudVision.AnnotateImagesFromGcsUriWithContext

AnnotateText - Class in org.apache.beam.sdk.extensions.ml

A PTransform using the Cloud AI Natural language processing capability.

AnnotateText() - Constructor for class org.apache.beam.sdk.extensions.ml.AnnotateText

AnnotateText.Builder - Class in org.apache.beam.sdk.extensions.ml

AnnotateVideoFromBytes(PCollectionView<Map<ByteString, VideoContext>>, List<Feature>) - Constructor for class org.apache.beam.sdk.extensions.ml.VideoIntelligence.AnnotateVideoFromBytes

AnnotateVideoFromBytesWithContext(List<Feature>) - Constructor for class org.apache.beam.sdk.extensions.ml.VideoIntelligence.AnnotateVideoFromBytesWithContext

AnnotateVideoFromUri(PCollectionView<Map<String, VideoContext>>, List<Feature>) - Constructor for class org.apache.beam.sdk.extensions.ml.VideoIntelligence.AnnotateVideoFromUri

AnnotateVideoFromURIWithContext(List<Feature>) - Constructor for class org.apache.beam.sdk.extensions.ml.VideoIntelligence.AnnotateVideoFromURIWithContext

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.

anyCombineFn(int) - Static method in class org.apache.beam.sdk.transforms.Sample

Returns a Combine.CombineFn that computes a fixed-sized potentially non-uniform sample of its inputs.

anyOf(Iterable<SerializableMatcher<? super T>>) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.anyOf(Iterable).

anyOf(SerializableMatcher<T>...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.anyOf(Matcher[]).

anything() - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.anything().

anyValueCombineFn() - Static method in class org.apache.beam.sdk.transforms.Sample

Returns a Combine.CombineFn that computes a single and potentially non-uniform sample value of its inputs.

append(K, W, Iterator<V>) - Method in interface org.apache.beam.runners.fnexecution.state.StateRequestHandlers.BagUserStateHandler

Appends the values to the bag user state for the given key and window.

appendRows(long, ProtoRows) - Method in interface org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.StreamAppendClient

Append rows to a Storage API write stream at the given offset.

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(Tuple2<ByteArray, byte[]>) - Method in class org.apache.beam.runners.spark.coders.CoderHelpers.FromByteFunction

apply(KV<String, Long>) - Method in class org.apache.beam.runners.spark.structuredstreaming.examples.WordCount.FormatAsTextFn

apply(InputT) - Method in interface org.apache.beam.sdk.coders.DelegateCoder.CodingFunction

apply(Pipeline, String, RunnerApi.FunctionSpec, Map<String, PCollection<?>>) - Method in interface org.apache.beam.sdk.expansion.service.ExpansionService.TransformProvider

apply(Row) - Method in class org.apache.beam.sdk.extensions.sql.impl.transform.BeamSetOperatorsTransforms.BeamSqlRow2KvFn

apply(Iterable<? extends InputT>) - Method in class org.apache.beam.sdk.extensions.sql.TypedCombineFnDelegate

apply(T1, T2) - Method in interface org.apache.beam.sdk.function.ThrowingBiFunction

apply(T1) - Method in interface org.apache.beam.sdk.function.ThrowingFunction

apply(Schema) - Method in interface org.apache.beam.sdk.io.AvroSink.DatumWriterFactory

apply(Schema, Schema) - Method in interface org.apache.beam.sdk.io.AvroSource.DatumReaderFactory

apply(Statement, Description) - Method in class org.apache.beam.sdk.io.gcp.bigquery.TestBigQuery

apply(Row) - Method in class org.apache.beam.sdk.io.gcp.bigtable.BeamRowToBigtableMutation.ToBigtableRowFn

apply(HealthcareIOError<T>) - Method in class org.apache.beam.sdk.io.gcp.healthcare.HealthcareIOErrorToTableRow

apply(byte[]) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessages.DeserializeBytesIntoPubsubMessagePayloadOnly

apply(PubsubMessage) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessages.ParsePayloadAsPubsubMessageProto

apply(byte[]) - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubMessages.ParsePubsubMessageProtoAsPayload

apply(Statement, Description) - Method in class org.apache.beam.sdk.io.gcp.pubsub.TestPubsub

apply(Statement, Description) - Method in class org.apache.beam.sdk.io.gcp.pubsub.TestPubsubSignal

apply(Void) - Method in class org.apache.beam.sdk.io.jdbc.JdbcIO.DataSourceProviderFromDataSourceConfiguration

apply(SQLException) - Method in class org.apache.beam.sdk.io.jdbc.JdbcIO.DefaultRetryStrategy

apply(Void) - Method in class org.apache.beam.sdk.io.jdbc.JdbcIO.PoolableDataSourceProvider

apply(SQLException) - Method in interface org.apache.beam.sdk.io.jdbc.JdbcIO.RetryStrategy

apply(String, Session) - Method in class org.apache.beam.sdk.io.jms.TextMessageMapper

apply(MongoCollection<Document>) - Method in class org.apache.beam.sdk.io.mongodb.AggregationQuery

apply(MongoCollection<Document>) - Method in class org.apache.beam.sdk.io.mongodb.FindQuery

apply(Void) - Method in class org.apache.beam.sdk.io.neo4j.Neo4jIO.DriverProviderFromDriverConfiguration

apply(FileIO.ReadableFile, OffsetRange, Exception) - Method in class org.apache.beam.sdk.io.ReadAllViaFileBasedSource.ReadFileRangesFnExceptionHandler

apply(Void) - Method in class org.apache.beam.sdk.io.snowflake.SnowflakeIO.DataSourceProviderFromDataSourceConfiguration

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(Schema, Schema) - Method in class org.apache.beam.sdk.schemas.transforms.Cast.Narrowing

apply(Schema, Schema) - Method in interface org.apache.beam.sdk.schemas.transforms.Cast.Validator

apply(Schema, Schema) - Method in class org.apache.beam.sdk.schemas.transforms.Cast.Widening

apply(Schema, Schema) - Method in class org.apache.beam.sdk.schemas.utils.SchemaZipFold

apply(T) - Method in class org.apache.beam.sdk.testing.PAssert.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(InputT, Contextful.Fn.Context) - Method in interface org.apache.beam.sdk.transforms.Contextful.Fn

Invokes the function on the given input with the given context.

apply(InputT) - Method in class org.apache.beam.sdk.transforms.InferableFunction

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.ProcessFunction

Returns the result of invoking this function on the given input.

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(WithFailures.ExceptionElement<T>) - Method in class org.apache.beam.sdk.transforms.WithFailures.ExceptionAsMapHandler

apply(WithFailures.ExceptionElement<T>) - Method in class org.apache.beam.sdk.transforms.WithFailures.ThrowableHandler

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

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<? super PCollectionRowTuple, OutputT>) - Method in class org.apache.beam.sdk.values.PCollectionRowTuple

Like PCollectionRowTuple.apply(String, PTransform) but defaulting to the name of the PTransform.

apply(String, PTransform<? super PCollectionRowTuple, OutputT>) - Method in class org.apache.beam.sdk.values.PCollectionRowTuple

Applies the given PTransform to this input PCollectionRowTuple, using name to identify this specific application of the transform.

apply(PTransform<? super 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<? super 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(Materializations.MultimapView<Void, T>) - Method in class org.apache.beam.sdk.values.PCollectionViews.IterableViewFn

Deprecated.

apply(Materializations.IterableView<T>) - Method in class org.apache.beam.sdk.values.PCollectionViews.IterableViewFn2

apply(Materializations.MultimapView<Void, T>) - Method in class org.apache.beam.sdk.values.PCollectionViews.ListViewFn

Deprecated.

apply(Materializations.MultimapView<Long, PCollectionViews.ValueOrMetadata<T, OffsetRange>>) - Method in class org.apache.beam.sdk.values.PCollectionViews.ListViewFn2

apply(Materializations.MultimapView<Void, KV<K, V>>) - Method in class org.apache.beam.sdk.values.PCollectionViews.MapViewFn

Deprecated.

apply(Materializations.MultimapView<K, V>) - Method in class org.apache.beam.sdk.values.PCollectionViews.MapViewFn2

apply(Materializations.MultimapView<Void, KV<K, V>>) - Method in class org.apache.beam.sdk.values.PCollectionViews.MultimapViewFn

Deprecated.

apply(Materializations.MultimapView<K, V>) - Method in class org.apache.beam.sdk.values.PCollectionViews.MultimapViewFn2

apply(Materializations.MultimapView<Void, T>) - Method in class org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn

Deprecated.

apply(Materializations.IterableView<T>) - Method in class org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn2

applySdkEnvironmentOverrides(RunnerApi.Pipeline, DataflowPipelineDebugOptions) - Method in class org.apache.beam.runners.dataflow.DataflowRunner

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.

applyWindowing() - Method in class org.apache.beam.sdk.transforms.PeriodicImpulse

ApproximateCountDistinct - Class in org.apache.beam.sdk.extensions.zetasketch

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.

ApproximateCountDistinct() - Constructor for class org.apache.beam.sdk.extensions.zetasketch.ApproximateCountDistinct

ApproximateCountDistinct.Globally<T> - Class in org.apache.beam.sdk.extensions.zetasketch

PTransform for estimating the number of distinct elements in a PCollection.

ApproximateCountDistinct.Globally.Builder<T> - Class in org.apache.beam.sdk.extensions.zetasketch

ApproximateCountDistinct.PerKey<K,V> - Class in org.apache.beam.sdk.extensions.zetasketch

ApproximateCountDistinct.PerKey.Builder<K,V> - Class in org.apache.beam.sdk.extensions.zetasketch

ApproximateDistinct - Class in org.apache.beam.sdk.extensions.sketching

PTransforms for computing the approximate number of distinct elements in a stream.

ApproximateDistinct() - Constructor for class org.apache.beam.sdk.extensions.sketching.ApproximateDistinct

ApproximateDistinct.ApproximateDistinctFn<InputT> - Class in org.apache.beam.sdk.extensions.sketching

Implements the Combine.CombineFn of ApproximateDistinct transforms.

ApproximateDistinct.GloballyDistinct<InputT> - Class in org.apache.beam.sdk.extensions.sketching

Implementation of ApproximateDistinct.globally().

ApproximateDistinct.HyperLogLogPlusCoder - Class in org.apache.beam.sdk.extensions.sketching

Coder for HyperLogLogPlus class.

ApproximateDistinct.PerKeyDistinct<K,V> - Class in org.apache.beam.sdk.extensions.sketching

Implementation of ApproximateDistinct.perKey().

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

Deprecated.

Consider using ApproximateCountDistinct in the zetasketch extension module, which makes use of the HllCount implementation.

If ApproximateCountDistinct does not meet your needs then you can directly use HllCount. Direct usage will also give you access to save intermediate aggregation result into a sketch for later processing.

For example, to estimate the number of distinct elements in a PCollection<String>:


 PCollection<String> input = ...;
 PCollection<Long> countDistinct =
     input.apply(HllCount.Init.forStrings().globally()).apply(HllCount.Extract.globally());

For more details about using HllCount and the zetasketch extension module, see https://s.apache.org/hll-in-beam#bookmark=id.v6chsij1ixo7.

ApproximateUnique() - Constructor for class org.apache.beam.sdk.transforms.ApproximateUnique

Deprecated.

ApproximateUnique.ApproximateUniqueCombineFn<T> - Class in org.apache.beam.sdk.transforms

Deprecated.

CombineFn that computes an estimate of the number of distinct values that were combined.

ApproximateUnique.ApproximateUniqueCombineFn.LargestUnique - Class in org.apache.beam.sdk.transforms

Deprecated.

A heap utility class to efficiently track the largest added elements.

ApproximateUnique.Globally<T> - Class in org.apache.beam.sdk.transforms

Deprecated.

PTransform for estimating the number of distinct elements in a PCollection.

ApproximateUnique.PerKey<K,V> - Class in org.apache.beam.sdk.transforms

Deprecated.

PTransform for estimating the number of distinct values associated with each key in a PCollection of KVs.

ApproximateUniqueCombineFn(long, Coder<T>) - Constructor for class org.apache.beam.sdk.transforms.ApproximateUnique.ApproximateUniqueCombineFn

Deprecated.

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

Returns the backing array.

array(TableSchema.ColumnType) - Static method in class org.apache.beam.sdk.io.clickhouse.TableSchema.ColumnType

array(Schema.FieldType) - Static method in class org.apache.beam.sdk.schemas.Schema.FieldType

Create an array type for the given field type.

array(Schema.FieldType, boolean) - Static method in class org.apache.beam.sdk.schemas.Schema.FieldType

Deprecated.

Set the nullability on the elementType instead

ARRAY_AGG_FN - Static variable in class org.apache.beam.sdk.extensions.sql.zetasql.translation.SqlOperators

ArrayAgg - Class in org.apache.beam.sdk.extensions.sql.impl.udaf

ArrayAgg() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.udaf.ArrayAgg

ArrayAgg.ArrayAggArray<T> - Class in org.apache.beam.sdk.extensions.sql.impl.udaf

ArrayAggArray() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.udaf.ArrayAgg.ArrayAggArray

arrayContaining(T...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.arrayContaining(Object[]).

arrayContaining(Coder<T>, T...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.arrayContaining(Object[]).

arrayContaining(SerializableMatcher<? super T>...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.arrayContaining(Matcher[]).

arrayContaining(List<SerializableMatcher<? super T>>) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.arrayContaining(List).

arrayContainingInAnyOrder(T...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Object[]).

arrayContainingInAnyOrder(Coder<T>, T...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Object[]).

arrayContainingInAnyOrder(SerializableMatcher<? super T>...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Matcher[]).

arrayContainingInAnyOrder(Collection<SerializableMatcher<? super T>>) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.arrayContainingInAnyOrder(Collection).

arrayElementType() - Method in class org.apache.beam.sdk.io.clickhouse.TableSchema.ColumnType

arrayQualifier() - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser

arrayQualifier() - Method in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.ArrayQualifierListContext

ArrayQualifierContext(ParserRuleContext, int) - Constructor for class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.ArrayQualifierContext

ArrayQualifierListContext(FieldSpecifierNotationParser.QualifierListContext) - Constructor for class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.ArrayQualifierListContext

arrayWithSize(int) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.arrayWithSize(int).

arrayWithSize(SerializableMatcher<? super Integer>) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers

A SerializableMatcher with identical criteria to Matchers.arrayWithSize(Matcher).

ArrowConversion - Class in org.apache.beam.sdk.extensions.arrow

Utilities to create Iterables of Beam Row instances backed by Arrow record batches.

ArrowConversion.ArrowSchemaTranslator - Class in org.apache.beam.sdk.extensions.arrow

Converts Arrow schema to Beam row schema.

ArrowConversion.RecordBatchRowIterator - Class in org.apache.beam.sdk.extensions.arrow

arrowSchemaFromInput(InputStream) - Static method in class org.apache.beam.sdk.extensions.arrow.ArrowConversion

ArrowSchemaTranslator() - Constructor for class org.apache.beam.sdk.extensions.arrow.ArrowConversion.ArrowSchemaTranslator

ArtifactDestination() - Constructor for class org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService.ArtifactDestination

ArtifactRetrievalService - Class in org.apache.beam.runners.fnexecution.artifact

An ArtifactRetrievalService that uses FileSystems as its backing storage.

ArtifactRetrievalService() - Constructor for class org.apache.beam.runners.fnexecution.artifact.ArtifactRetrievalService

ArtifactRetrievalService(ArtifactResolver) - Constructor for class org.apache.beam.runners.fnexecution.artifact.ArtifactRetrievalService

ArtifactRetrievalService(int) - Constructor for class org.apache.beam.runners.fnexecution.artifact.ArtifactRetrievalService

ArtifactRetrievalService(ArtifactResolver, int) - Constructor for class org.apache.beam.runners.fnexecution.artifact.ArtifactRetrievalService

ArtifactStagingService - Class in org.apache.beam.runners.fnexecution.artifact

ArtifactStagingService(ArtifactStagingService.ArtifactDestinationProvider) - Constructor for class org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService

ArtifactStagingService.ArtifactDestination - Class in org.apache.beam.runners.fnexecution.artifact

A pairing of a newly created artifact type and an ouptut stream that will be readable at that type.

ArtifactStagingService.ArtifactDestinationProvider - Interface in org.apache.beam.runners.fnexecution.artifact

Provides a concrete location to which artifacts can be staged on retrieval.

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<?>, SdkComponents) - 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.

AsJsons.AsJsonsWithFailures<FailureT> - Class in org.apache.beam.sdk.extensions.jackson

A PTransform that adds exception handling to AsJsons.

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.

asOutputReference(PValue, AppliedPTransform<?, ?, ?>) - Method in interface org.apache.beam.runners.dataflow.TransformTranslator.TranslationContext

Encode a PValue reference as an output reference.

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.

asQueryable(QueryProvider, SchemaPlus, String) - Method in class org.apache.beam.sdk.extensions.sql.impl.BeamCalciteTable

asResponseObserver() - Method in class org.apache.beam.runners.fnexecution.control.FnApiControlClient

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.

assertSubscriptionEventuallyCreated(String, Duration) - Method in class org.apache.beam.sdk.io.gcp.pubsub.TestPubsub

Block until a subscription is created for this test topic in the specified project.

assertThatAllRows(Schema) - Method in class org.apache.beam.sdk.io.gcp.bigquery.TestBigQuery

assertThatTopicEventuallyReceives(Matcher<PubsubMessage>...) - Method in class org.apache.beam.sdk.io.gcp.pubsub.TestPubsub

Repeatedly pull messages from TestPubsub.subscriptionPath() until receiving one for each matcher (or timeout is reached), then assert that the received messages match the expectations.

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.

assignableTo(Schema) - Method in class org.apache.beam.sdk.schemas.Schema

Returns true if this Schema can be assigned to another Schema.

assignableToIgnoreNullable(Schema) - Method in class org.apache.beam.sdk.schemas.Schema

Returns true if this Schema can be assigned to another Schema, ignoring nullable.

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

runs WindowFn.assignWindows(WindowFn.AssignContext).

assignedWindowsWithValue(WindowFn<T, W>, TimestampedValue<T>) - Static method in class org.apache.beam.sdk.testing.WindowFnTestUtils

runs WindowFn.assignWindows(WindowFn.AssignContext).

AssignShardFn(Integer) - Constructor for class org.apache.beam.sdk.transforms.Reshuffle.AssignShardFn

Deprecated.

assignShardKey(DestinationT, UserT, int) - Method in interface org.apache.beam.sdk.io.ShardingFunction

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.

AssignWindowP<T> - Class in org.apache.beam.runners.jet.processors

/** * Jet Processor implementation for Beam's Windowing primitive.

assignWindows(WindowFn<Object, IntervalWindow>.AssignContext) - Method in class org.apache.beam.sdk.extensions.sql.impl.TVFSlidingWindowFn

assignWindows(WindowFn<Object, GlobalWindow>.AssignContext) - Method in class org.apache.beam.sdk.transforms.windowing.GlobalWindows

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.

AssignWindowsFunction<T> - Class in org.apache.beam.runners.twister2.translators.functions

Assign Windows function.

AssignWindowsFunction(WindowFn<T, BoundedWindow>, PipelineOptions) - Constructor for class org.apache.beam.runners.twister2.translators.functions.AssignWindowsFunction

assignWindowsMapFunction(WindowFn<T, W>) - Static method in class org.apache.beam.runners.spark.structuredstreaming.translation.helpers.WindowingHelpers

AssignWindowTranslatorBatch<T> - Class in org.apache.beam.runners.twister2.translators.batch

Assign Window translator.

AssignWindowTranslatorBatch() - Constructor for class org.apache.beam.runners.twister2.translators.batch.AssignWindowTranslatorBatch

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.

assumeSingleMessageSchema() - Method in class org.apache.beam.sdk.extensions.sbe.SbeSchema.IrOptions

ASTERISK - Static variable in class org.apache.beam.sdk.extensions.sql.impl.cep.Quantifier

ASTERISK_RELUCTANT - Static variable in class org.apache.beam.sdk.extensions.sql.impl.cep.Quantifier

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

attachValues(List<Object>) - Method in class org.apache.beam.sdk.values.Row.Builder

attachValues(Object...) - Method in class org.apache.beam.sdk.values.Row.Builder

attempted(MetricKey, T) - Static method in class org.apache.beam.sdk.metrics.MetricResult

ATTRIBUTE_ARRAY_ENTRY_SCHEMA - Static variable in class org.apache.beam.sdk.io.gcp.pubsub.PubsubSchemaIOProvider

ATTRIBUTE_ARRAY_FIELD_TYPE - Static variable in class org.apache.beam.sdk.io.gcp.pubsub.PubsubSchemaIOProvider

ATTRIBUTE_MAP_FIELD_TYPE - Static variable in class org.apache.beam.sdk.io.gcp.pubsub.PubsubSchemaIOProvider

AttributeValueCoder - Class in org.apache.beam.sdk.io.aws.dynamodb

A Coder that serializes and deserializes the AttributeValue objects.

AttributeValueCoder - Class in org.apache.beam.sdk.io.aws2.dynamodb

A Coder that serializes and deserializes the AttributeValue objects.

AttributeValueCoderProviderRegistrar - Class in org.apache.beam.sdk.io.aws.dynamodb

A CoderProviderRegistrar for standard types used with DynamoDBIO.

AttributeValueCoderProviderRegistrar() - Constructor for class org.apache.beam.sdk.io.aws.dynamodb.AttributeValueCoderProviderRegistrar

AUTH_VALIDATION_GROUP - Static variable in interface org.apache.beam.sdk.io.snowflake.SnowflakePipelineOptions

AuthenticatedRetryInitializer(GoogleCredentials) - Constructor for class org.apache.beam.sdk.io.gcp.healthcare.HttpHealthcareApiClient.AuthenticatedRetryInitializer

AUTO - Static variable in interface org.apache.beam.runners.flink.FlinkPipelineOptions

autoCastField(Schema.Field, Object) - Static method in class org.apache.beam.sdk.extensions.sql.impl.schema.BeamTableUtils

Attempt to cast an object to a specified Schema.Field.Type.

autoLoadUserDefinedFunctions() - Method in class org.apache.beam.sdk.extensions.sql.impl.BeamSqlEnv.BeamSqlEnvBuilder

Load UDF/UDAFs from UdfUdafProvider.

AutoScaler - Interface in org.apache.beam.sdk.io.jms

Enables users to specify their own `JMS` backlog reporters enabling JmsIO to report UnboundedSource.UnboundedReader#getTotalBacklogBytes().

AutoValueSchema - Class in org.apache.beam.sdk.schemas

A SchemaProvider for AutoValue classes.

AutoValueSchema() - Constructor for class org.apache.beam.sdk.schemas.AutoValueSchema

AutoValueSchema.AbstractGetterTypeSupplier - Class in org.apache.beam.sdk.schemas

FieldValueTypeSupplier that's based on AutoValue getters.

AutoValueUtils - Class in org.apache.beam.sdk.schemas.utils

Utilities for managing AutoValue schemas.

AutoValueUtils() - Constructor for class org.apache.beam.sdk.schemas.utils.AutoValueUtils

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

AvroCoder(Class<T>, Schema, boolean) - Constructor for class org.apache.beam.sdk.coders.AvroCoder

AvroCoder.JodaTimestampConversion - Class in org.apache.beam.sdk.coders

Conversion for DateTime.

AvroConvertType(boolean) - Constructor for class org.apache.beam.sdk.schemas.utils.AvroUtils.AvroConvertType

AvroGenericCoder - Class in org.apache.beam.sdk.coders

AvroCoder specialisation for GenericRecord.

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

PTransforms for reading and writing Avro files.

AvroIO.Parse<T> - Class in org.apache.beam.sdk.io

Implementation of

AvroIO.parseGenericRecords(org.apache.beam.sdk.transforms.SerializableFunction<org.apache.avro.generic.GenericRecord, T>)

AvroIO.ParseAll<T> - Class in org.apache.beam.sdk.io

Deprecated.

See AvroIO.parseAllGenericRecords(SerializableFunction) for details.

AvroIO.ParseFiles<T> - Class in org.apache.beam.sdk.io

Implementation of

AvroIO.parseFilesGenericRecords(org.apache.beam.sdk.transforms.SerializableFunction<org.apache.avro.generic.GenericRecord, T>)

AvroIO.Read<T> - Class in org.apache.beam.sdk.io

Implementation of AvroIO.read(java.lang.Class<T>) and AvroIO.readGenericRecords(org.apache.avro.Schema).

AvroIO.ReadAll<T> - Class in org.apache.beam.sdk.io

Deprecated.

See AvroIO.readAll(Class) for details.

AvroIO.ReadFiles<T> - Class in org.apache.beam.sdk.io

Implementation of AvroIO.readFiles(java.lang.Class<T>).

AvroIO.RecordFormatter<ElementT> - Interface in org.apache.beam.sdk.io

Deprecated.

Users can achieve the same by providing this transform in a ParDo before using write in AvroIO AvroIO.write(Class).

AvroIO.Sink<ElementT> - Class in org.apache.beam.sdk.io

Implementation of AvroIO.sink(java.lang.Class<ElementT>) and AvroIO.sinkViaGenericRecords(org.apache.avro.Schema, org.apache.beam.sdk.io.AvroIO.RecordFormatter<ElementT>).

AvroIO.TypedWrite<UserT,DestinationT,OutputT> - Class in org.apache.beam.sdk.io

Implementation of AvroIO.write(java.lang.Class<T>).

AvroIO.Write<T> - Class in org.apache.beam.sdk.io

This class is used as the default return value of AvroIO.write(java.lang.Class<T>)

AvroPayloadSerializerProvider - Class in org.apache.beam.sdk.schemas.io.payloads

AvroPayloadSerializerProvider() - Constructor for class org.apache.beam.sdk.schemas.io.payloads.AvroPayloadSerializerProvider

AvroReader(AvroSource<T>) - Constructor for class org.apache.beam.sdk.io.AvroSource.AvroReader

Reads Avro records of type T from the specified source.

AvroRecordSchema - Class in org.apache.beam.sdk.schemas

A SchemaProvider for AVRO generated SpecificRecords and POJOs.

AvroRecordSchema() - Constructor for class org.apache.beam.sdk.schemas.AvroRecordSchema

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

An implementation of SchemaIOProvider for reading and writing Avro files with AvroIO.

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

AvroSink<UserT,DestinationT,OutputT> - Class in org.apache.beam.sdk.io

A FileBasedSink for Avro files.

AvroSink.DatumWriterFactory<T> - Interface in org.apache.beam.sdk.io

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.

AvroSource.DatumReaderFactory<T> - Interface in org.apache.beam.sdk.io

AvroTableProvider - Class in org.apache.beam.sdk.extensions.sql.meta.provider.avro

TableProvider for AvroIO for consumption by Beam SQL.

AvroTableProvider() - Constructor for class org.apache.beam.sdk.extensions.sql.meta.provider.avro.AvroTableProvider

AvroUtils - Class in org.apache.beam.sdk.schemas.utils

Utils to convert AVRO records to Beam rows.

AvroUtils.AvroConvertType - Class in org.apache.beam.sdk.schemas.utils

AvroUtils.AvroConvertValueForGetter - Class in org.apache.beam.sdk.schemas.utils

AvroUtils.AvroConvertValueForSetter - Class in org.apache.beam.sdk.schemas.utils

AvroUtils.FixedBytesField - Class in org.apache.beam.sdk.schemas.utils

Wrapper for fixed byte fields.

AvroWriteRequest<T> - Class in org.apache.beam.sdk.io.gcp.bigquery

AvroWriteRequest(T, Schema) - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.AvroWriteRequest

awaitCompletion() - Method in class org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver

Deprecated.

awaitCompletion() - Method in class org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver2

Uses the callers thread to process all elements received until we receive the end of the stream from the upstream producer for all endpoints specified.

awaitCompletion() - Method in class org.apache.beam.sdk.fn.data.CompletableFutureInboundDataClient

awaitCompletion() - Method in interface org.apache.beam.sdk.fn.data.InboundDataClient

Deprecated.

Block until the client has completed reading from the inbound stream.

awaitTermination(Duration) - Method in class org.apache.beam.runners.spark.SparkPipelineResult

awaitTermination(Duration) - Method in class org.apache.beam.runners.spark.SparkRunnerDebugger.DebugSparkPipelineResult

AwsClientsProvider - Interface in org.apache.beam.sdk.io.aws.dynamodb

Provides instances of AWS clients.

AwsClientsProvider - Interface in org.apache.beam.sdk.io.aws.sns

Provides instances of AWS clients.

AWSClientsProvider - Interface in org.apache.beam.sdk.io.aws2.kinesis

Deprecated.

Configure a custom ClientBuilderFactory using AwsOptions.getClientBuilderFactory() instead.

AWSClientsProvider - Interface in org.apache.beam.sdk.io.kinesis

Provides instances of AWS clients.

AwsCoders - Class in org.apache.beam.sdk.io.aws.coders

Coders for common AWS SDK objects.

AwsCoders - Class in org.apache.beam.sdk.io.aws2.coders

Coders for common AWS SDK objects.

AwsModule - Class in org.apache.beam.sdk.io.aws.options

A Jackson Module that registers a JsonSerializer and JsonDeserializer for AWSCredentialsProvider and some subclasses.

AwsModule() - Constructor for class org.apache.beam.sdk.io.aws.options.AwsModule

AwsModule - Class in org.apache.beam.sdk.io.aws2.options

A Jackson Module that registers a JsonSerializer and JsonDeserializer for AwsCredentialsProvider and some subclasses.

AwsModule() - Constructor for class org.apache.beam.sdk.io.aws2.options.AwsModule

AwsOptions - Interface in org.apache.beam.sdk.io.aws.options

Options used to configure Amazon Web Services specific options such as credentials and region.

AwsOptions - Interface in org.apache.beam.sdk.io.aws2.options

Options used to configure Amazon Web Services specific options such as credentials and region.

AwsOptions.AwsRegionFactory - Class in org.apache.beam.sdk.io.aws.options

Attempt to load default region.

AwsOptions.AwsRegionFactory - Class in org.apache.beam.sdk.io.aws2.options

Attempt to load default region.

AwsOptions.AwsUserCredentialsFactory - Class in org.apache.beam.sdk.io.aws.options

Attempts to load AWS credentials.

AwsOptions.AwsUserCredentialsFactory - Class in org.apache.beam.sdk.io.aws2.options

Return DefaultCredentialsProvider as default provider.

AwsOptions.ClientConfigurationFactory - Class in org.apache.beam.sdk.io.aws.options

Default AWS client configuration.

AwsPipelineOptionsRegistrar - Class in org.apache.beam.sdk.io.aws.options

A registrar containing the default AWS options.

AwsPipelineOptionsRegistrar() - Constructor for class org.apache.beam.sdk.io.aws.options.AwsPipelineOptionsRegistrar

AwsPipelineOptionsRegistrar - Class in org.apache.beam.sdk.io.aws2.options

A registrar containing the default AWS options.

AwsPipelineOptionsRegistrar() - Constructor for class org.apache.beam.sdk.io.aws2.options.AwsPipelineOptionsRegistrar

AwsRegionFactory() - Constructor for class org.apache.beam.sdk.io.aws.options.AwsOptions.AwsRegionFactory

AwsRegionFactory() - Constructor for class org.apache.beam.sdk.io.aws2.options.AwsOptions.AwsRegionFactory

awsResponseMetadata() - Static method in class org.apache.beam.sdk.io.aws2.coders.AwsCoders

Returns a new coder for AwsResponseMetadata (AWS request ID only).

AwsSerializableUtils - Class in org.apache.beam.sdk.io.aws2.options

Utilities for working with AWS Serializables.

AwsSerializableUtils() - Constructor for class org.apache.beam.sdk.io.aws2.options.AwsSerializableUtils

AwsSerializableUtils - Class in org.apache.beam.sdk.io.kinesis.serde

Utilities for working with AWS Serializables.

AwsSerializableUtils() - Constructor for class org.apache.beam.sdk.io.kinesis.serde.AwsSerializableUtils

AwsUserCredentialsFactory() - Constructor for class org.apache.beam.sdk.io.aws.options.AwsOptions.AwsUserCredentialsFactory

AwsUserCredentialsFactory() - Constructor for class org.apache.beam.sdk.io.aws2.options.AwsOptions.AwsUserCredentialsFactory

AzureBlobStoreFileSystemRegistrar - Class in org.apache.beam.sdk.io.azure.blobstore

AutoService registrar for the AzureBlobStoreFileSystem.

AzureBlobStoreFileSystemRegistrar() - Constructor for class org.apache.beam.sdk.io.azure.blobstore.AzureBlobStoreFileSystemRegistrar

AzureModule - Class in org.apache.beam.sdk.io.azure.options

A Jackson Module that registers a JsonSerializer and JsonDeserializer for Azure credential providers.

AzureModule() - Constructor for class org.apache.beam.sdk.io.azure.options.AzureModule

AzurePipelineOptionsRegistrar - Class in org.apache.beam.sdk.io.azure.options

A registrar containing the default Azure options.

AzurePipelineOptionsRegistrar() - Constructor for class org.apache.beam.sdk.io.azure.options.AzurePipelineOptionsRegistrar

AzureUserCredentialsFactory() - Constructor for class org.apache.beam.sdk.io.azure.options.BlobstoreOptions.AzureUserCredentialsFactory

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.
BackOffAdapter - Class in org.apache.beam.sdk.extensions.gcp.util: An adapter for converting between Apache Beam and Google API client representations of backoffs.
BackOffAdapter() - Constructor for class org.apache.beam.sdk.extensions.gcp.util.BackOffAdapter
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.
BagUserStateSpec() - Constructor for class org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.BagUserStateSpec
baseBackoff() - Method in class org.apache.beam.sdk.io.aws2.common.RetryConfiguration
baseBackoff(Duration) - Method in class org.apache.beam.sdk.io.aws2.common.RetryConfiguration.Builder
BaseBeamTable - Class in org.apache.beam.sdk.extensions.sql.meta: Basic implementation of BeamSqlTable.
BaseBeamTable() - Constructor for class org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable
baseUrl() - Method in class org.apache.beam.sdk.io.solr.SolrIO.ReplicaInfo
BASIC_CONNECTION_INFO_VALIDATION_GROUP - Static variable in interface org.apache.beam.sdk.io.snowflake.SnowflakePipelineOptions
BasicDynamoDbClientProvider - Class in org.apache.beam.sdk.io.aws2.dynamodb: Deprecated.
Configure a custom ClientBuilderFactory using AwsOptions.getClientBuilderFactory() instead.
BasicDynamoDBProvider - Class in org.apache.beam.sdk.io.aws.dynamodb: Basic implementation of AwsClientsProvider used by default in DynamoDBIO.
batchGetDocuments() - Method in class org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.Read: Factory method to create a new type safe builder for BatchGetDocumentsRequest operations.
BatchingParams() - Constructor for class org.apache.beam.sdk.transforms.GroupIntoBatches.BatchingParams
BatchSideInputHandlerFactory - Class in org.apache.beam.runners.fnexecution.translation: StateRequestHandler that uses a BatchSideInputHandlerFactory.SideInputGetter to access side inputs.
BatchSideInputHandlerFactory.SideInputGetter - Interface in org.apache.beam.runners.fnexecution.translation: Returns the value for the side input with the given PCollection id from the runner.
batchSize() - Method in class org.apache.beam.sdk.extensions.ml.RecommendationAIImportCatalogItems
batchSize() - Method in class org.apache.beam.sdk.extensions.ml.RecommendationAIImportUserEvents
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.
BatchTransformTranslator<TransformT extends PTransform> - Interface in org.apache.beam.runners.twister2.translators: Batch TransformTranslator interface.
batchWrite() - Method in class org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.Write: Factory method to create a new type safe builder for Write operations.
BEAM_INSTANCE_PROPERTY - Static variable in class org.apache.beam.io.debezium.KafkaSourceConsumerFn
BEAM_SOURCE_OPTION - Static variable in class org.apache.beam.runners.spark.structuredstreaming.Constants
BeamAggregateProjectMergeRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: This rule is essentially a wrapper around Calcite's AggregateProjectMergeRule.
BeamAggregateProjectMergeRule(Class<? extends Aggregate>, Class<? extends Project>, RelBuilderFactory) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rule.BeamAggregateProjectMergeRule
BeamAggregationRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace a Aggregate node.
BeamAggregationRel(RelOptCluster, RelTraitSet, RelNode, ImmutableBitSet, List<ImmutableBitSet>, List<AggregateCall>, WindowFn<Row, IntervalWindow>, int) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamAggregationRel
BeamAggregationRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: Rule to detect the window/trigger settings.
BeamAggregationRule(Class<? extends Aggregate>, Class<? extends Project>, RelBuilderFactory) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rule.BeamAggregationRule
BeamBasicAggregationRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: Aggregation rule that doesn't include projection.
BeamBasicAggregationRule(Class<? extends Aggregate>, RelBuilderFactory) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rule.BeamBasicAggregationRule
BeamBatchTSetEnvironment - Class in org.apache.beam.runners.twister2: This is a shell tset environment which is used on as a central driver model to fit what beam expects.
BeamBatchTSetEnvironment() - Constructor for class org.apache.beam.runners.twister2.BeamBatchTSetEnvironment
BeamBatchWorker - Class in org.apache.beam.runners.twister2: The Twister2 worker that will execute the job logic once the job is submitted from the run method.
BeamBatchWorker() - Constructor for class org.apache.beam.runners.twister2.BeamBatchWorker
BeamBigQuerySqlDialect - Class in org.apache.beam.sdk.extensions.sql.meta.provider.bigquery
BeamBigQuerySqlDialect(SqlDialect.Context) - Constructor for class org.apache.beam.sdk.extensions.sql.meta.provider.bigquery.BeamBigQuerySqlDialect
BeamBuiltinAggregations - Class in org.apache.beam.sdk.extensions.sql.impl.transform: Built-in aggregations functions for COUNT/MAX/MIN/SUM/AVG/VAR_POP/VAR_SAMP.
BeamBuiltinAggregations() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.transform.BeamBuiltinAggregations
BeamBuiltinAggregations.BitXOr<T extends java.lang.Number> - Class in org.apache.beam.sdk.extensions.sql.impl.transform
BeamBuiltinAnalyticFunctions - Class in org.apache.beam.sdk.extensions.sql.impl.transform: Built-in Analytic Functions for the aggregation analytics functionality.
BeamBuiltinAnalyticFunctions() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.transform.BeamBuiltinAnalyticFunctions
BeamBuiltinAnalyticFunctions.PositionAwareCombineFn<InputT,AccumT,OutputT> - Class in org.apache.beam.sdk.extensions.sql.impl.transform
BeamBuiltinFunctionProvider - Class in org.apache.beam.sdk.extensions.sql.impl.udf: BeamBuiltinFunctionClass interface.
BeamBuiltinFunctionProvider() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.udf.BeamBuiltinFunctionProvider
BeamBuiltinMethods - Class in org.apache.beam.sdk.extensions.sql.zetasql.translation.impl: BeamBuiltinMethods.
BeamBuiltinMethods() - Constructor for class org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.BeamBuiltinMethods
BeamCalciteSchema - Class in org.apache.beam.sdk.extensions.sql.impl: Adapter from TableProvider to Schema.
BeamCalciteTable - Class in org.apache.beam.sdk.extensions.sql.impl: Adapter from BeamSqlTable to a calcite Table.
BeamCalcMergeRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: Planner rule to merge a BeamCalcRel with a BeamCalcRel.
BeamCalcMergeRule() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rule.BeamCalcMergeRule
BeamCalcRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace Project and Filter node.
BeamCalcRel(RelOptCluster, RelTraitSet, RelNode, RexProgram) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel
BeamCalcRel.WrappedList<T> - Class in org.apache.beam.sdk.extensions.sql.impl.rel: WrappedList translates List on access.
BeamCalcRel.WrappedMap<V> - Class in org.apache.beam.sdk.extensions.sql.impl.rel: WrappedMap translates Map on access.
BeamCalcRel.WrappedRow - Class in org.apache.beam.sdk.extensions.sql.impl.rel: WrappedRow translates Row on access.
BeamCalcRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: A ConverterRule to replace Calc with BeamCalcRel.
BeamCalcSplittingRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: A RelOptRule that converts a LogicalCalc into a chain of AbstractBeamCalcRel nodes via CalcRelSplitter.
BeamCalcSplittingRule(String) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rule.BeamCalcSplittingRule
BeamCodegenUtils - Class in org.apache.beam.sdk.extensions.sql.zetasql.translation.impl: BeamCodegenUtils.
BeamCodegenUtils() - Constructor for class org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.BeamCodegenUtils
BeamCoGBKJoinRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: A BeamJoinRel which does CoGBK Join
BeamCoGBKJoinRel(RelOptCluster, RelTraitSet, RelNode, RelNode, RexNode, Set<CorrelationId>, JoinRelType) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamCoGBKJoinRel
BeamCoGBKJoinRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: Rule to convert LogicalJoin node to BeamCoGBKJoinRel node.
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.AbstractBeamCalcRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamAggregationRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamIntersectRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamIOSinkRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamIOSourceRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamJoinRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamMatchRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamMinusRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamPushDownIOSourceRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in interface org.apache.beam.sdk.extensions.sql.impl.rel.BeamRelNode: This method is called by org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner.NonCumulativeCostImpl.
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSortRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamTableFunctionScanRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamUncollectRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamUnionRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamUnnestRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamValuesRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamWindowRel: A dummy cost computation based on a fixed multiplier.
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.zetasql.unnest.BeamZetaSqlUncollectRel
beamComputeSelfCost(RelOptPlanner, BeamRelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.zetasql.unnest.BeamZetaSqlUnnestRel
BeamCostModel - Class in org.apache.beam.sdk.extensions.sql.impl.planner: VolcanoCost represents the cost of a plan node.
BeamCostModel.Factory - Class in org.apache.beam.sdk.extensions.sql.impl.planner: Implementation of RelOptCostFactory that creates BeamCostModels.
BeamEnumerableConverter - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace a Enumerable node.
BeamEnumerableConverter(RelOptCluster, RelTraitSet, RelNode) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamEnumerableConverter
BeamEnumerableConverterRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: A ConverterRule to Convert BeamRelNode to EnumerableConvention.
beamFilesystemArtifactDestinationProvider(String) - Static method in class org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService: An ArtifactDestinationProvider that places new artifacts as files in a Beam filesystem.
BeamFnDataGrpcMultiplexer - Class in org.apache.beam.sdk.fn.data: Deprecated.
Migrate to BeamFnDataGrpcMultiplexer2.
BeamFnDataGrpcMultiplexer(Endpoints.ApiServiceDescriptor, OutboundObserverFactory, OutboundObserverFactory.BasicFactory<BeamFnApi.Elements, BeamFnApi.Elements>) - Constructor for class org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer: Deprecated.
BeamFnDataGrpcMultiplexer2 - Class in org.apache.beam.sdk.fn.data: A gRPC multiplexer for a specific Endpoints.ApiServiceDescriptor.
BeamFnDataGrpcMultiplexer2(Endpoints.ApiServiceDescriptor, OutboundObserverFactory, OutboundObserverFactory.BasicFactory<BeamFnApi.Elements, BeamFnApi.Elements>) - Constructor for class org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer2
BeamFnDataInboundObserver - Class in org.apache.beam.sdk.fn.data: Deprecated.
Migrate to BeamFnDataInboundObserver2.
BeamFnDataInboundObserver(LogicalEndpoint, FnDataReceiver<ByteString>, InboundDataClient) - Constructor for class org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver: Deprecated.
BeamFnDataInboundObserver2 - Class in org.apache.beam.sdk.fn.data: Decodes BeamFnApi.Elements partitioning them using the provided DataEndpoints and TimerEndpoints.
BeamFnDataInboundObserver2.CloseException - Exception in org.apache.beam.sdk.fn.data
BeamFnDataOutboundAggregator - Class in org.apache.beam.sdk.fn.data: An outbound data buffering aggregator with size-based buffer and time-based buffer if corresponding options are set.
BeamFnDataOutboundAggregator(PipelineOptions, Supplier<String>, StreamObserver<BeamFnApi.Elements>, boolean) - Constructor for class org.apache.beam.sdk.fn.data.BeamFnDataOutboundAggregator
BeamFnDataOutboundObserver<T> - Class in org.apache.beam.sdk.fn.data: Deprecated.
Migrate to use BeamFnDataOutboundAggregator directly.
BeamFnDataOutboundObserver(LogicalEndpoint, Coder<T>, StreamObserver<BeamFnApi.Elements>, PipelineOptions) - Constructor for class org.apache.beam.sdk.fn.data.BeamFnDataOutboundObserver: Deprecated.
BeamIntersectRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace a Intersect node.
BeamIntersectRel(RelOptCluster, RelTraitSet, List<RelNode>, boolean) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamIntersectRel
BeamIntersectRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: ConverterRule to replace Intersect with BeamIntersectRel.
BeamIOPushDownRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule
BeamIOPushDownRule(RelBuilderFactory) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rule.BeamIOPushDownRule
BeamIOSinkRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace a TableModify node.
BeamIOSinkRel(RelOptCluster, RelOptTable, Prepare.CatalogReader, RelNode, TableModify.Operation, List<String>, List<RexNode>, boolean, BeamSqlTable, Map<String, String>) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamIOSinkRel
BeamIOSinkRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: A ConverterRule to replace TableModify with BeamIOSinkRel.
BeamIOSourceRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace a TableScan node.
BeamIOSourceRel(RelOptCluster, RelTraitSet, RelOptTable, BeamSqlTable, Map<String, String>, BeamCalciteTable) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamIOSourceRel
BeamJavaTypeFactory - Class in org.apache.beam.sdk.extensions.sql.impl.planner: customized data type in Beam.
BeamJavaUdfCalcRule - Class in org.apache.beam.sdk.extensions.sql.zetasql: A BeamCalcSplittingRule to replace Calc with BeamCalcRel.
BeamJoinAssociateRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: This is very similar to JoinAssociateRule.
BeamJoinPushThroughJoinRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: This is exactly similar to JoinPushThroughJoinRule.
BeamJoinRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: An abstract BeamRelNode to implement Join Rels.
BeamJoinRel(RelOptCluster, RelTraitSet, RelNode, RelNode, RexNode, Set<CorrelationId>, JoinRelType) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamJoinRel
BeamJoinTransforms - Class in org.apache.beam.sdk.extensions.sql.impl.transform: Collections of PTransform and DoFn used to perform JOIN operation.
BeamJoinTransforms() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.transform.BeamJoinTransforms
BeamJoinTransforms.JoinAsLookup - Class in org.apache.beam.sdk.extensions.sql.impl.transform: Transform to execute Join as Lookup.
BeamKafkaCSVTable - Class in org.apache.beam.sdk.extensions.sql.meta.provider.kafka: A Kafka topic that saves records as CSV format.
BeamKafkaCSVTable(Schema, String, List<String>) - Constructor for class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaCSVTable
BeamKafkaCSVTable(Schema, String, List<String>, CSVFormat) - Constructor for class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaCSVTable
BeamKafkaTable - Class in org.apache.beam.sdk.extensions.sql.meta.provider.kafka: BeamKafkaTable represent a Kafka topic, as source or target.
BeamKafkaTable(Schema) - Constructor for class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTable
BeamKafkaTable(Schema, String, List<String>) - Constructor for class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTable
BeamKafkaTable(Schema, List<TopicPartition>, String) - Constructor for class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTable
BeamLogicalConvention - Enum in org.apache.beam.sdk.extensions.sql.impl.rel: Convertion for Beam SQL.
BeamMatchRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace a Match node.
BeamMatchRel(RelOptCluster, RelTraitSet, RelNode, RelDataType, RexNode, boolean, boolean, Map<String, RexNode>, Map<String, RexNode>, RexNode, Map<String, ? extends SortedSet<String>>, boolean, ImmutableBitSet, RelCollation, RexNode) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamMatchRel
BeamMatchRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: ConverterRule to replace Match with BeamMatchRel.
BeamMinusRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace a Minus node.
BeamMinusRel(RelOptCluster, RelTraitSet, List<RelNode>, boolean) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamMinusRel
BeamMinusRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: ConverterRule to replace Minus with BeamMinusRel.
BeamPCollectionTable<InputT> - Class in org.apache.beam.sdk.extensions.sql.impl.schema: BeamPCollectionTable converts a PCollection<Row> as a virtual table, then a downstream query can query directly.
BeamPCollectionTable(PCollection<InputT>) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.schema.BeamPCollectionTable
BeamPushDownIOSourceRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel
BeamPushDownIOSourceRel(RelOptCluster, RelTraitSet, RelOptTable, BeamSqlTable, List<String>, BeamSqlTableFilter, Map<String, String>, BeamCalciteTable) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamPushDownIOSourceRel
BeamRelDataTypeSystem - Class in org.apache.beam.sdk.extensions.sql.impl.planner: customized data type in Beam.
BeamRelMetadataQuery - Class in org.apache.beam.sdk.extensions.sql.impl.planner
BeamRelNode - Interface in org.apache.beam.sdk.extensions.sql.impl.rel: A RelNode that can also give a PTransform that implements the expression.
beamRow2CsvLine(Row, CSVFormat) - Static method in class org.apache.beam.sdk.extensions.sql.impl.schema.BeamTableUtils
BeamRowToBigtableMutation - Class in org.apache.beam.sdk.io.gcp.bigtable: Bigtable reference: .
BeamRowToBigtableMutation(Map<String, Set<String>>) - Constructor for class org.apache.beam.sdk.io.gcp.bigtable.BeamRowToBigtableMutation
BeamRowToBigtableMutation.ToBigtableRowFn - Class in org.apache.beam.sdk.io.gcp.bigtable
BeamRowToStorageApiProto - Class in org.apache.beam.sdk.io.gcp.bigquery: Utility methods for converting Beam Row objects to dynamic protocol message, for use with the Storage write API.
BeamRowToStorageApiProto() - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.BeamRowToStorageApiProto
BeamRuleSets - Class in org.apache.beam.sdk.extensions.sql.impl.planner: RuleSet used in BeamQueryPlanner.
BeamRuleSets() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.planner.BeamRuleSets
BeamSetOperatorRelBase - Class in org.apache.beam.sdk.extensions.sql.impl.rel: Delegate for Set operators: BeamUnionRel, BeamIntersectRel and BeamMinusRel.
BeamSetOperatorRelBase(BeamRelNode, BeamSetOperatorRelBase.OpType, boolean) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSetOperatorRelBase
BeamSetOperatorRelBase.OpType - Enum in org.apache.beam.sdk.extensions.sql.impl.rel: Set operator type.
BeamSetOperatorsTransforms - Class in org.apache.beam.sdk.extensions.sql.impl.transform: Collections of PTransform and DoFn used to perform Set operations.
BeamSetOperatorsTransforms() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.transform.BeamSetOperatorsTransforms
BeamSetOperatorsTransforms.BeamSqlRow2KvFn - Class in org.apache.beam.sdk.extensions.sql.impl.transform: Transform a BeamSqlRow to a KV<BeamSqlRow, BeamSqlRow>.
BeamSetOperatorsTransforms.SetOperatorFilteringDoFn - Class in org.apache.beam.sdk.extensions.sql.impl.transform: Filter function used for Set operators.
BeamSideInputJoinRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: A BeamJoinRel which does sideinput Join
BeamSideInputJoinRel(RelOptCluster, RelTraitSet, RelNode, RelNode, RexNode, Set<CorrelationId>, JoinRelType) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSideInputJoinRel
BeamSideInputJoinRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: Rule to convert LogicalJoin node to BeamSideInputJoinRel node.
BeamSideInputLookupJoinRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: A BeamJoinRel which does Lookup Join
BeamSideInputLookupJoinRel(RelOptCluster, RelTraitSet, RelNode, RelNode, RexNode, Set<CorrelationId>, JoinRelType) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSideInputLookupJoinRel
BeamSideInputLookupJoinRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: Rule to convert LogicalJoin node to BeamSideInputLookupJoinRel node.
BeamSideInputLookupJoinRule() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rule.BeamSideInputLookupJoinRule
BeamSortRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace a Sort node.
BeamSortRel(RelOptCluster, RelTraitSet, RelNode, RelCollation, RexNode, RexNode) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSortRel
BeamSortRel.BeamSqlRowComparator - Class in org.apache.beam.sdk.extensions.sql.impl.rel
BeamSortRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: ConverterRule to replace Sort with BeamSortRel.
BeamSqlCli - Class in org.apache.beam.sdk.extensions.sql: BeamSqlCli provides methods to execute Beam SQL with an interactive client.
BeamSqlCli() - Constructor for class org.apache.beam.sdk.extensions.sql.BeamSqlCli
BeamSqlDataCatalogExample - Class in org.apache.beam.sdk.extensions.sql.example: Example pipeline that uses Google Cloud Data Catalog to retrieve the table metadata.
BeamSqlDataCatalogExample() - Constructor for class org.apache.beam.sdk.extensions.sql.example.BeamSqlDataCatalogExample
BeamSqlDataCatalogExample.DCExamplePipelineOptions - Interface in org.apache.beam.sdk.extensions.sql.example: Pipeline options to specify the query and the output for the example.
BeamSqlEnv - Class in org.apache.beam.sdk.extensions.sql.impl: Contains the metadata of tables/UDF functions, and exposes APIs to query/validate/optimize/translate SQL statements.
BeamSqlEnv.BeamSqlEnvBuilder - Class in org.apache.beam.sdk.extensions.sql.impl: BeamSqlEnv's Builder.
BeamSqlOutputToConsoleFn - Class in org.apache.beam.sdk.extensions.sql.impl.transform: A test PTransform to display output in console.
BeamSqlOutputToConsoleFn(String) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.transform.BeamSqlOutputToConsoleFn
BeamSqlParser - Class in org.apache.beam.sdk.extensions.sql.impl.parser
BeamSqlPipelineOptions - Interface in org.apache.beam.sdk.extensions.sql.impl: Options used to configure BeamSQL.
BeamSqlPipelineOptionsRegistrar - Class in org.apache.beam.sdk.extensions.sql.impl: AutoService registrar for BeamSqlPipelineOptions.
BeamSqlPipelineOptionsRegistrar() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.BeamSqlPipelineOptionsRegistrar
BeamSqlRelUtils - Class in org.apache.beam.sdk.extensions.sql.impl.rel: Utilities for BeamRelNode.
BeamSqlRelUtils() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSqlRelUtils
BeamSqlRow2KvFn() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.transform.BeamSetOperatorsTransforms.BeamSqlRow2KvFn
BeamSqlRowComparator(List<Integer>, List<Boolean>, List<Boolean>) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSortRel.BeamSqlRowComparator
BeamSqlSeekableTable - Interface in org.apache.beam.sdk.extensions.sql: A seekable table converts a JOIN operator to an inline lookup.
BeamSqlTable - Interface in org.apache.beam.sdk.extensions.sql.meta: This interface defines a Beam Sql Table.
BeamSqlTableFilter - Interface in org.apache.beam.sdk.extensions.sql.meta: This interface defines Beam SQL Table Filter.
BeamSqlUdf - Interface in org.apache.beam.sdk.extensions.sql: Interface to create a UDF in Beam SQL.
BeamSqlUnparseContext - Class in org.apache.beam.sdk.extensions.sql.meta.provider.bigquery
BeamSqlUnparseContext(IntFunction<SqlNode>) - Constructor for class org.apache.beam.sdk.extensions.sql.meta.provider.bigquery.BeamSqlUnparseContext
BeamTableFunctionScanRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace TableFunctionScan.
BeamTableFunctionScanRel(RelOptCluster, RelTraitSet, List<RelNode>, RexNode, Type, RelDataType, Set<RelColumnMapping>) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamTableFunctionScanRel
BeamTableFunctionScanRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: This is the conveter rule that converts a Calcite TableFunctionScan to Beam TableFunctionScanRel.
BeamTableStatistics - Class in org.apache.beam.sdk.extensions.sql.impl: This class stores row count statistics.
BeamTableUtils - Class in org.apache.beam.sdk.extensions.sql.impl.schema: Utility methods for working with BeamTable.
BeamTableUtils() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.schema.BeamTableUtils
BeamUncollectRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to implement an uncorrelated Uncollect, aka UNNEST.
BeamUncollectRel(RelOptCluster, RelTraitSet, RelNode, boolean) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamUncollectRel
BeamUncollectRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: A ConverterRule to replace Uncollect with BeamUncollectRule.
BeamUnionRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace a Union.
BeamUnionRel(RelOptCluster, RelTraitSet, List<RelNode>, boolean) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamUnionRel
BeamUnionRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: A ConverterRule to replace Union with BeamUnionRule.
BeamUnnestRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to implement UNNEST, supporting specifically only Correlate with Uncollect.
BeamUnnestRel(RelOptCluster, RelTraitSet, RelNode, RelDataType, List<Integer>) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamUnnestRel
BeamUnnestRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: A ConverterRule to replace Correlate Uncollect with BeamUnnestRule.
BeamValuesRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace a Values node.
BeamValuesRel(RelOptCluster, RelDataType, ImmutableList<ImmutableList<RexLiteral>>, RelTraitSet) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamValuesRel
BeamValuesRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: ConverterRule to replace Values with BeamValuesRel.
BeamWindowRel - Class in org.apache.beam.sdk.extensions.sql.impl.rel: BeamRelNode to replace a Window node.
BeamWindowRel(RelOptCluster, RelTraitSet, RelNode, List<RexLiteral>, RelDataType, List<Window.Group>) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.BeamWindowRel
BeamWindowRule - Class in org.apache.beam.sdk.extensions.sql.impl.rule: A ConverterRule to replace Window with BeamWindowRel.
BeamWorkerStatusGrpcService - Class in org.apache.beam.runners.fnexecution.status: A Fn Status service which can collect run-time status information from SDK harnesses for debugging purpose.
BeamZetaSqlCalcMergeRule - Class in org.apache.beam.sdk.extensions.sql.zetasql: Planner rule to merge a BeamZetaSqlCalcRel with a BeamZetaSqlCalcRel.
BeamZetaSqlCalcMergeRule() - Constructor for class org.apache.beam.sdk.extensions.sql.zetasql.BeamZetaSqlCalcMergeRule
BeamZetaSqlCalcRel - Class in org.apache.beam.sdk.extensions.sql.zetasql: BeamRelNode to replace Project and Filter node based on the ZetaSQL expression evaluator.
BeamZetaSqlCalcRel(RelOptCluster, RelTraitSet, RelNode, RexProgram) - Constructor for class org.apache.beam.sdk.extensions.sql.zetasql.BeamZetaSqlCalcRel
BeamZetaSqlCalcRule - Class in org.apache.beam.sdk.extensions.sql.zetasql: A BeamCalcSplittingRule to replace Calc with BeamZetaSqlCalcRel.
BeamZetaSqlCalcSplittingRule - Class in org.apache.beam.sdk.extensions.sql.zetasql: A BeamCalcSplittingRule that converts a LogicalCalc to a chain of BeamZetaSqlCalcRel and/or BeamCalcRel via CalcRelSplitter.
BeamZetaSqlCatalog - Class in org.apache.beam.sdk.extensions.sql.zetasql: Catalog for registering tables and functions.
BeamZetaSqlUncollectRel - Class in org.apache.beam.sdk.extensions.sql.zetasql.unnest: BeamRelNode to implement an uncorrelated ZetaSqlUnnest, aka UNNEST.
BeamZetaSqlUncollectRel(RelOptCluster, RelTraitSet, RelNode, boolean) - Constructor for class org.apache.beam.sdk.extensions.sql.zetasql.unnest.BeamZetaSqlUncollectRel
BeamZetaSqlUncollectRule - Class in org.apache.beam.sdk.extensions.sql.zetasql.unnest: A ConverterRule to replace ZetaSqlUnnest with BeamZetaSqlUncollectRel.
BeamZetaSqlUnnestRel - Class in org.apache.beam.sdk.extensions.sql.zetasql.unnest: BeamRelNode to implement UNNEST, supporting specifically only Correlate with ZetaSqlUnnest.
BeamZetaSqlUnnestRel(RelOptCluster, RelTraitSet, RelNode, RelDataType, List<Integer>) - Constructor for class org.apache.beam.sdk.extensions.sql.zetasql.unnest.BeamZetaSqlUnnestRel
BeamZetaSqlUnnestRule - Class in org.apache.beam.sdk.extensions.sql.zetasql.unnest: A ConverterRule to replace Correlate ZetaSqlUnnest with BeamZetaSqlUnnestRel.
beforeProcessing(PipelineOptions) - Method in interface org.apache.beam.sdk.harness.JvmInitializer: Implement beforeProcessing to run some custom initialization after basic services such as logging, but before data processing begins.
beforeStart(ClientCallStreamObserver<RespT>) - Method in class org.apache.beam.sdk.fn.stream.ForwardingClientResponseObserver
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
BIG_INT - Static variable in class org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils
BIG_QUERY_INSERT_ERROR_ERROR_CONTAINER - Static variable in interface org.apache.beam.sdk.io.gcp.bigquery.ErrorContainer
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.
BigDecimalConverter - Class in org.apache.beam.sdk.extensions.sql.impl.utils: Provides converters from BigDecimal to other numeric types based on the input Schema.TypeName.
BigDecimalConverter() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.utils.BigDecimalConverter
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.
BigEndianShortCoder - Class in org.apache.beam.sdk.coders: A BigEndianShortCoder encodes Shorts in 2 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.
BIGQUERY_JOB_TEMPLATE - Static variable in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO: Template for BigQuery jobs created by BigQueryIO.
BigqueryClient - Class in org.apache.beam.sdk.io.gcp.testing: A wrapper class to call Bigquery API calls.
BigqueryClient(String) - Constructor for class org.apache.beam.sdk.io.gcp.testing.BigqueryClient
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
BigQueryDlqProvider - Class in org.apache.beam.sdk.io.gcp.bigquery
BigQueryDlqProvider() - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.BigQueryDlqProvider
BigQueryFilter - Class in org.apache.beam.sdk.extensions.sql.meta.provider.bigquery
BigQueryFilter(List<RexNode>) - Constructor for class org.apache.beam.sdk.extensions.sql.meta.provider.bigquery.BigQueryFilter
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
BigQueryInsertError - Class in org.apache.beam.sdk.io.gcp.bigquery: Model definition for BigQueryInsertError.
BigQueryInsertError(TableRow, TableDataInsertAllResponse.InsertErrors, TableReference) - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.BigQueryInsertError
BigQueryInsertErrorCoder - Class in org.apache.beam.sdk.io.gcp.bigquery: A Coder that encodes BigQuery BigQueryInsertError objects.
BigQueryInsertErrorCoder() - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.BigQueryInsertErrorCoder
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.TypedRead<T> - Class in org.apache.beam.sdk.io.gcp.bigquery: Implementation of BigQueryIO.read(SerializableFunction).
BigQueryIO.TypedRead.Method - Enum in org.apache.beam.sdk.io.gcp.bigquery: Determines the method used to read data from BigQuery.
BigQueryIO.TypedRead.QueryPriority - Enum in org.apache.beam.sdk.io.gcp.bigquery: An enumeration type for the priority of a query.
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.Method - Enum in org.apache.beam.sdk.io.gcp.bigquery: Determines the method used to insert data in BigQuery.
BigQueryIO.Write.SchemaUpdateOption - Enum in org.apache.beam.sdk.io.gcp.bigquery: An enumeration type for the BigQuery schema update options strings.
BigQueryIO.Write.WriteDisposition - Enum in org.apache.beam.sdk.io.gcp.bigquery: An enumeration type for the BigQuery write disposition strings.
BigqueryMatcher - Class in org.apache.beam.sdk.io.gcp.testing: A matcher to verify data in BigQuery by processing given query and comparing with content's checksum.
BigqueryMatcher.TableAndQuery - Class in org.apache.beam.sdk.io.gcp.testing
BigQueryOptions - Interface in org.apache.beam.sdk.io.gcp.bigquery: Properties needed when using Google BigQuery with the Apache Beam SDK.
BigQuerySchemaIOProvider - Class in org.apache.beam.sdk.io.gcp.bigquery: An implementation of SchemaIOProvider for reading and writing to BigQuery with BigQueryIO.
BigQuerySchemaIOProvider() - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.BigQuerySchemaIOProvider
BigQuerySchemaRetrievalException - Exception in org.apache.beam.sdk.io.gcp.bigquery: Exception to signal that BigQuery schema retrieval failed.
BigQueryServices - Interface in org.apache.beam.sdk.io.gcp.bigquery: An interface for real, mock, or fake implementations of Cloud BigQuery services.
BigQueryServices.BigQueryServerStream<T> - Interface in org.apache.beam.sdk.io.gcp.bigquery: Container for reading data from streaming endpoints.
BigQueryServices.DatasetService - Interface in org.apache.beam.sdk.io.gcp.bigquery: An interface to get, create and delete Cloud BigQuery datasets and tables.
BigQueryServices.JobService - Interface in org.apache.beam.sdk.io.gcp.bigquery: An interface for the Cloud BigQuery load service.
BigQueryServices.StorageClient - Interface in org.apache.beam.sdk.io.gcp.bigquery: An interface representing a client object for making calls to the BigQuery Storage API.
BigQueryServices.StreamAppendClient - Interface in org.apache.beam.sdk.io.gcp.bigquery: An interface for appending records to a Storage API write stream.
BigQueryStorageTableSource<T> - Class in org.apache.beam.sdk.io.gcp.bigquery: A Source representing reading from a table.
BigQueryTableProvider - Class in org.apache.beam.sdk.extensions.sql.meta.provider.bigquery: BigQuery table provider.
BigQueryTableProvider() - Constructor for class org.apache.beam.sdk.extensions.sql.meta.provider.bigquery.BigQueryTableProvider
BigQueryUtils - Class in org.apache.beam.sdk.io.gcp.bigquery: Utility methods for BigQuery related operations.
BigQueryUtils() - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils
BigQueryUtils.ConversionOptions - Class in org.apache.beam.sdk.io.gcp.bigquery: Options for how to convert BigQuery data to Beam data.
BigQueryUtils.ConversionOptions.Builder - Class in org.apache.beam.sdk.io.gcp.bigquery: Builder for BigQueryUtils.ConversionOptions.
BigQueryUtils.ConversionOptions.TruncateTimestamps - Enum in org.apache.beam.sdk.io.gcp.bigquery: Controls whether to truncate timestamps to millisecond precision lossily, or to crash when truncation would result.
BigQueryUtils.SchemaConversionOptions - Class in org.apache.beam.sdk.io.gcp.bigquery: Options for how to convert BigQuery schemas to Beam schemas.
BigQueryUtils.SchemaConversionOptions.Builder - Class in org.apache.beam.sdk.io.gcp.bigquery: Builder for BigQueryUtils.SchemaConversionOptions.
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.
BigtableIO.WriteWithResults - Class in org.apache.beam.sdk.io.gcp.bigtable: A PTransform that writes to Google Cloud Bigtable and emits a BigtableWriteResult for each batch written.
BigtableRowToBeamRow - Class in org.apache.beam.sdk.io.gcp.bigtable: Bigtable reference: .
BigtableRowToBeamRow(Schema) - Constructor for class org.apache.beam.sdk.io.gcp.bigtable.BigtableRowToBeamRow
BigtableRowToBeamRowFlat - Class in org.apache.beam.sdk.io.gcp.bigtable: Bigtable reference: .
BigtableRowToBeamRowFlat(Schema, Map<String, Set<String>>) - Constructor for class org.apache.beam.sdk.io.gcp.bigtable.BigtableRowToBeamRowFlat
BigtableTable - Class in org.apache.beam.sdk.extensions.sql.meta.provider.bigtable
BigtableTableProvider - Class in org.apache.beam.sdk.extensions.sql.meta.provider.bigtable: TableProvider for BigtableTable.
BigtableTableProvider() - Constructor for class org.apache.beam.sdk.extensions.sql.meta.provider.bigtable.BigtableTableProvider
BigtableUtils - Class in org.apache.beam.sdk.io.gcp.testing
BigtableUtils() - Constructor for class org.apache.beam.sdk.io.gcp.testing.BigtableUtils
BigtableWriteResult - Class in org.apache.beam.sdk.io.gcp.bigtable: The result of writing a batch of rows to Bigtable.
BigtableWriteResult() - Constructor for class org.apache.beam.sdk.io.gcp.bigtable.BigtableWriteResult
BigtableWriteResultCoder - Class in org.apache.beam.sdk.io.gcp.bigtable: A coder for BigtableWriteResult.
BigtableWriteResultCoder() - Constructor for class org.apache.beam.sdk.io.gcp.bigtable.BigtableWriteResultCoder
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
binarySchema() - Static method in class org.apache.beam.runners.spark.structuredstreaming.translation.helpers.SchemaHelpers
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
bindOrderedList(String, StateSpec<OrderedListState<T>>, Coder<T>) - 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.
BIT_XOR - Static variable in class org.apache.beam.sdk.extensions.sql.zetasql.translation.SqlOperators
BitSetCoder - Class in org.apache.beam.sdk.coders: Coder for BitSet.
BitXOr() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.transform.BeamBuiltinAggregations.BitXOr
BlobstoreClientBuilderFactory - Interface in org.apache.beam.sdk.io.azure.options: Construct BlobServiceClientBuilder from Azure pipeline options.
BlobstoreOptions - Interface in org.apache.beam.sdk.io.azure.options
BlobstoreOptions.AzureUserCredentialsFactory - Class in org.apache.beam.sdk.io.azure.options: Attempts to load Azure credentials.
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, EmptyMatchTreatment, long) - Constructor for class org.apache.beam.sdk.io.BlockBasedSource: Creates a BlockBasedSource based on a file name or pattern.
BlockBasedSource(String, long) - Constructor for class org.apache.beam.sdk.io.BlockBasedSource: Like BlockBasedSource.BlockBasedSource(String, EmptyMatchTreatment, long) but with a default EmptyMatchTreatment of EmptyMatchTreatment.DISALLOW.
BlockBasedSource(ValueProvider<String>, long) - Constructor for class org.apache.beam.sdk.io.BlockBasedSource: Like BlockBasedSource.BlockBasedSource(String, long).
BlockBasedSource(ValueProvider<String>, EmptyMatchTreatment, long) - Constructor for class org.apache.beam.sdk.io.BlockBasedSource: Like BlockBasedSource.BlockBasedSource(String, EmptyMatchTreatment, long).
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.
BlockTracker(OffsetRange, long, long) - Constructor for class org.apache.beam.sdk.io.parquet.ParquetIO.ReadFiles.BlockTracker
BOOLEAN - Static variable in class org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils
BOOLEAN - Static variable in class org.apache.beam.sdk.schemas.Schema.FieldType: The type of boolean fields.
BooleanCoder - Class in org.apache.beam.sdk.coders: A Coder for Boolean.
BooleanCoder() - Constructor for class org.apache.beam.sdk.coders.BooleanCoder
booleans() - Static method in class org.apache.beam.sdk.values.TypeDescriptors: The TypeDescriptor for Boolean.
booleanToByteArray(boolean) - Static method in class org.apache.beam.sdk.io.gcp.testing.BigtableUtils
Bounded(SparkContext, BoundedSource<T>, SerializablePipelineOptions, String) - Constructor for class org.apache.beam.runners.spark.io.SourceRDD.Bounded
BOUNDED_UNKNOWN - Static variable in class org.apache.beam.sdk.extensions.sql.impl.BeamTableStatistics
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.
BoundedSourceP<T> - Class in org.apache.beam.runners.jet.processors: Jet Processor implementation for reading from a bounded Beam source.
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
boxIfPrimitive(TypeDescriptor) - Static method in class org.apache.beam.sdk.schemas.utils.ReflectUtils
broadcast(JavaSparkContext) - Method in class org.apache.beam.runners.spark.util.SideInputBroadcast
bucketAccessible(GcsPath) - Method in class org.apache.beam.sdk.extensions.gcp.util.GcsUtil: Returns whether the GCS bucket exists and is accessible.
bucketOwner(GcsPath) - Method in class org.apache.beam.sdk.extensions.gcp.util.GcsUtil: Returns the project number of the project which owns this bucket.
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.
BufferingStreamObserver<T> - Class in org.apache.beam.sdk.fn.stream: A thread safe StreamObserver which uses a bounded queue to pass elements to a processing thread responsible for interacting with the underlying CallStreamObserver.
BufferingStreamObserver(Phaser, CallStreamObserver<T>, ExecutorService, int) - Constructor for class org.apache.beam.sdk.fn.stream.BufferingStreamObserver
build() - Method in class org.apache.beam.sdk.extensions.gcp.storage.GcsCreateOptions.Builder
build() - Method in class org.apache.beam.sdk.extensions.gcp.util.CustomHttpErrors.Builder
build() - Method in class org.apache.beam.sdk.extensions.gcp.util.GcsUtil.CreateOptions.Builder
build() - Method in class org.apache.beam.sdk.extensions.ml.AnnotateText.Builder
build() - Method in class org.apache.beam.sdk.extensions.ml.DLPDeidentifyText.Builder
build() - Method in class org.apache.beam.sdk.extensions.ml.DLPInspectText.Builder
build() - Method in class org.apache.beam.sdk.extensions.ml.DLPReidentifyText.Builder
build() - Method in class org.apache.beam.sdk.extensions.sbe.SbeSchema.IrOptions.Builder
build() - Method in class org.apache.beam.sdk.extensions.sbe.UnsignedOptions.Builder
build() - Method in class org.apache.beam.sdk.extensions.sql.impl.BeamSqlEnv.BeamSqlEnvBuilder: Build function to create an instance of BeamSqlEnv based on preset fields.
build() - Method in class org.apache.beam.sdk.extensions.sql.impl.UdfImplReflectiveFunctionBase.ParameterListBuilder
build() - Method in class org.apache.beam.sdk.extensions.sql.impl.utils.SerializableRexNode.Builder
build() - Method in class org.apache.beam.sdk.extensions.sql.meta.Table.Builder
build() - Method in class org.apache.beam.sdk.extensions.sql.zetasql.translation.UserFunctionDefinitions.Builder
build() - Method in class org.apache.beam.sdk.extensions.zetasketch.ApproximateCountDistinct.Globally.Builder
build() - Method in class org.apache.beam.sdk.extensions.zetasketch.ApproximateCountDistinct.PerKey.Builder
build() - Method in class org.apache.beam.sdk.fn.test.TestStreams.Builder
build() - Method in class org.apache.beam.sdk.io.aws.s3.S3FileSystemConfiguration.Builder
build() - Method in class org.apache.beam.sdk.io.aws2.common.ClientConfiguration.Builder
build() - Method in class org.apache.beam.sdk.io.aws2.common.HttpClientConfiguration.Builder
build() - Method in class org.apache.beam.sdk.io.aws2.common.RetryConfiguration.Builder
build() - Method in class org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.RetryConfiguration.Builder: Deprecated.
build() - Method in class org.apache.beam.sdk.io.aws2.kinesis.KinesisIO.RecordAggregation.Builder
build() - Method in class org.apache.beam.sdk.io.aws2.s3.S3FileSystemConfiguration.Builder
build() - Method in class org.apache.beam.sdk.io.aws2.s3.SSECustomerKey.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.bigquery.BigQueryUtils.ConversionOptions.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.SchemaConversionOptions.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.BatchGetDocuments.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.BatchWriteWithDeadLetterQueue.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.BatchWriteWithSummary.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.ListCollectionIds.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.ListDocuments.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.PartitionQuery.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.RunQuery.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.firestore.RpcQosOptions.Builder: Create a new instance of RpcQosOptions from the current builder state.
build() - Method in class org.apache.beam.sdk.io.gcp.pubsublite.PublisherOptions.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.pubsublite.SubscriberOptions.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.pubsublite.UuidDeduplicationOptions.Builder
build() - Method in class org.apache.beam.sdk.io.gcp.spanner.changestreams.model.ChangeStreamRecordMetadata.Builder: Builds the ChangeStreamRecordMetadata.
build() - Method in class org.apache.beam.sdk.io.gcp.spanner.changestreams.model.PartitionMetadata.Builder: Builds a PartitionMetadata from the given fields.
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.io.TextRowCountEstimator.Builder
build() - Method in class org.apache.beam.sdk.metrics.MetricsFilter.Builder
build() - Method in class org.apache.beam.sdk.schemas.FieldAccessDescriptor.FieldDescriptor.Builder
build() - Method in class org.apache.beam.sdk.schemas.io.Failure.Builder
build() - Method in class org.apache.beam.sdk.schemas.Schema.Builder
build() - Method in class org.apache.beam.sdk.schemas.Schema.Field.Builder
build() - Method in class org.apache.beam.sdk.schemas.Schema.Options.Builder
build() - Method in class org.apache.beam.sdk.transforms.JsonToRow.JsonToRowWithErrFn.ParseWithError.Builder
build() - Method in class org.apache.beam.sdk.values.Row.Builder
build() - Method in class org.apache.beam.sdk.values.Row.FieldValueBuilder
buildBeamSqlNullableSchema(Object...) - Static method in class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTableUtils
buildBeamSqlSchema(Object...) - Static method in class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTableUtils: Create a RowsBuilder with the specified row type info.
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.bigquery.BigQueryTableProvider
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.bigtable.BigtableTableProvider
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.datacatalog.DataCatalogTableProvider
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.KafkaTableProvider
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.mongodb.MongoDbTableProvider
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.parquet.ParquetTableProvider
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.pubsublite.PubsubLiteTableProvider
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.ReadOnlyTableProvider
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.SchemaIOTableProviderWrapper
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.seqgen.GenerateSequenceTableProvider
buildBeamSqlTable(Table) - Method in interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider: Build a BeamSqlTable using the given table meta info.
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTableProvider
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTableProvider
buildBeamSqlTable(Table) - Method in class org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore
buildClient(AwsOptions, BuilderT, ClientConfiguration) - Static method in interface org.apache.beam.sdk.io.aws2.common.ClientBuilderFactory: Utility to directly build a client of type ClientT using builder of BuilderT.
buildDatasource() - Method in class org.apache.beam.sdk.io.snowflake.SnowflakeIO.DataSourceConfiguration: Builds SnowflakeBasicDataSource based on the current configuration.
builder() - Static method in class org.apache.beam.runners.jobsubmission.JobPreparation
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.extensions.gcp.util.CustomHttpErrors.Builder
builder() - Static method in class org.apache.beam.sdk.extensions.gcp.util.GcsUtil.CreateOptions
Builder() - Constructor for class org.apache.beam.sdk.extensions.gcp.util.GcsUtil.CreateOptions.Builder
Builder() - Constructor for class org.apache.beam.sdk.extensions.ml.AnnotateText.Builder
Builder() - Constructor for class org.apache.beam.sdk.extensions.ml.DLPDeidentifyText.Builder
Builder() - Constructor for class org.apache.beam.sdk.extensions.ml.DLPInspectText.Builder
Builder() - Constructor for class org.apache.beam.sdk.extensions.ml.DLPReidentifyText.Builder
builder() - Static method in class org.apache.beam.sdk.extensions.sbe.SbeSchema.IrOptions
Builder() - Constructor for class org.apache.beam.sdk.extensions.sbe.SbeSchema.IrOptions.Builder
builder() - Static method in class org.apache.beam.sdk.extensions.sbe.UnsignedOptions
Builder() - Constructor for class org.apache.beam.sdk.extensions.sbe.UnsignedOptions.Builder
builder(TableProvider) - Static method in class org.apache.beam.sdk.extensions.sql.impl.BeamSqlEnv: Creates a builder with the default schema backed by the table provider.
builder() - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.JoinRelOptRuleCall
builder() - Static method in class org.apache.beam.sdk.extensions.sql.impl.UdfImplReflectiveFunctionBase: Creates a ParameterListBuilder.
builder(RexNode) - Static method in class org.apache.beam.sdk.extensions.sql.impl.utils.SerializableRexNode
Builder(RexNode) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.utils.SerializableRexNode.Builder
builder() - Static method in class org.apache.beam.sdk.extensions.sql.meta.Table
Builder() - Constructor for class org.apache.beam.sdk.extensions.sql.meta.Table.Builder
Builder() - Constructor for class org.apache.beam.sdk.extensions.sql.zetasql.translation.UserFunctionDefinitions.Builder
Builder() - Constructor for class org.apache.beam.sdk.extensions.zetasketch.ApproximateCountDistinct.Globally.Builder
Builder() - Constructor for class org.apache.beam.sdk.extensions.zetasketch.ApproximateCountDistinct.PerKey.Builder
builder() - Static method in class org.apache.beam.sdk.io.aws.s3.S3FileSystemConfiguration: Creates a new uninitialized S3FileSystemConfiguration.Builder.
Builder() - Constructor for class org.apache.beam.sdk.io.aws.s3.S3FileSystemConfiguration.Builder
builder() - Static method in class org.apache.beam.sdk.io.aws2.common.ClientConfiguration
Builder() - Constructor for class org.apache.beam.sdk.io.aws2.common.ClientConfiguration.Builder
builder() - Static method in class org.apache.beam.sdk.io.aws2.common.HttpClientConfiguration
Builder() - Constructor for class org.apache.beam.sdk.io.aws2.common.HttpClientConfiguration.Builder
builder() - Static method in class org.apache.beam.sdk.io.aws2.common.RetryConfiguration
Builder() - Constructor for class org.apache.beam.sdk.io.aws2.common.RetryConfiguration.Builder
builder() - Static method in class org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.RetryConfiguration: Deprecated.
Builder() - Constructor for class org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.RetryConfiguration.Builder: Deprecated.
builder() - Static method in class org.apache.beam.sdk.io.aws2.kinesis.KinesisIO.RecordAggregation
Builder() - Constructor for class org.apache.beam.sdk.io.aws2.kinesis.KinesisIO.RecordAggregation.Builder
builder() - Static method in class org.apache.beam.sdk.io.aws2.kinesis.WatermarkParameters
builder() - Static method in class org.apache.beam.sdk.io.aws2.s3.S3FileSystemConfiguration: Creates a new uninitialized S3FileSystemConfiguration.Builder.
Builder() - Constructor for class org.apache.beam.sdk.io.aws2.s3.S3FileSystemConfiguration.Builder
builder() - Static method in class org.apache.beam.sdk.io.aws2.s3.SSECustomerKey
builder() - Static method in class org.apache.beam.sdk.io.clickhouse.TableSchema.ColumnType
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() - Static method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.ConversionOptions
Builder() - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.ConversionOptions.Builder
builder() - Static method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.SchemaConversionOptions
Builder() - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.SchemaConversionOptions.Builder
Builder(JodaClock, FirestoreStatefulComponentFactory, RpcQosOptions) - Constructor for class org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.BatchGetDocuments.Builder
Builder(JodaClock, FirestoreStatefulComponentFactory, RpcQosOptions, boolean) - Constructor for class org.apache.beam.sdk.io.gcp.firestore.FirestoreV1.PartitionQuery.Builder
Builder() - Constructor for class org.apache.beam.sdk.io.gcp.pubsublite.PublisherOptions.Builder
Builder() - Constructor for class org.apache.beam.sdk.io.gcp.pubsublite.SubscriberOptions.Builder
Builder() - Constructor for class org.apache.beam.sdk.io.gcp.pubsublite.UuidDeduplicationOptions.Builder
Builder() - Constructor for class org.apache.beam.sdk.io.gcp.spanner.changestreams.model.ChangeStreamRecordMetadata.Builder
Builder() - Constructor for class org.apache.beam.sdk.io.gcp.spanner.changestreams.model.PartitionMetadata.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.io.kinesis.WatermarkParameters
Builder() - Constructor for class org.apache.beam.sdk.io.splunk.SplunkEvent.Builder
Builder() - Constructor for class org.apache.beam.sdk.io.splunk.SplunkWriteError.Builder
builder() - Static method in class org.apache.beam.sdk.io.TextRowCountEstimator
Builder() - Constructor for class org.apache.beam.sdk.io.TextRowCountEstimator.Builder
builder() - Static method in class org.apache.beam.sdk.metrics.MetricsFilter
Builder() - Constructor for class org.apache.beam.sdk.metrics.MetricsFilter.Builder
builder() - Static method in class org.apache.beam.sdk.schemas.FieldAccessDescriptor.FieldDescriptor
Builder() - Constructor for class org.apache.beam.sdk.schemas.FieldAccessDescriptor.FieldDescriptor.Builder
Builder() - Constructor for class org.apache.beam.sdk.schemas.FieldValueTypeInformation.Builder
Builder() - Constructor for class org.apache.beam.sdk.schemas.io.Failure.Builder
builder() - Static method in class org.apache.beam.sdk.schemas.Schema
Builder() - Constructor for class org.apache.beam.sdk.schemas.Schema.Builder
Builder() - Constructor for class org.apache.beam.sdk.schemas.Schema.Field.Builder
builder() - Static method in class org.apache.beam.sdk.schemas.Schema.Options
Builder() - Constructor for class org.apache.beam.sdk.transforms.DoFnSchemaInformation.Builder
Builder() - Constructor for class org.apache.beam.sdk.transforms.JsonToRow.JsonToRowWithErrFn.Builder
Builder() - Constructor for class org.apache.beam.sdk.transforms.JsonToRow.JsonToRowWithErrFn.ParseWithError.Builder
Builder() - Constructor for class org.apache.beam.sdk.transforms.JsonToRow.ParseResult.Builder
builderForType(TypeDescriptor<T>) - Static method in class org.apache.beam.sdk.extensions.zetasketch.ApproximateCountDistinct
builderFrom(S3Options) - Static method in class org.apache.beam.sdk.io.aws2.s3.S3FileSystemConfiguration: Creates a new S3FileSystemConfiguration.Builder with values initialized by the properties of s3Options.
buildExternal(DebeziumTransformRegistrar.ReadBuilder.Configuration) - Method in class org.apache.beam.io.debezium.DebeziumTransformRegistrar.ReadBuilder
buildExternal(ExternalRead.Configuration) - Method in class org.apache.beam.sdk.io.gcp.pubsub.ExternalRead.ReadBuilder
buildExternal(ExternalWrite.Configuration) - Method in class org.apache.beam.sdk.io.gcp.pubsub.ExternalWrite.WriteBuilder
buildExternal(SpannerTransformRegistrar.ReadBuilder.Configuration) - Method in class org.apache.beam.sdk.io.gcp.spanner.SpannerTransformRegistrar.ReadBuilder
buildExternal(KinesisTransformRegistrar.ReadDataBuilder.Configuration) - Method in class org.apache.beam.sdk.io.kinesis.KinesisTransformRegistrar.ReadDataBuilder
buildExternal(KinesisTransformRegistrar.WriteBuilder.Configuration) - Method in class org.apache.beam.sdk.io.kinesis.KinesisTransformRegistrar.WriteBuilder
buildExternal(ReadBuilder.Configuration) - Method in class org.apache.beam.sdk.io.snowflake.crosslanguage.ReadBuilder
buildExternal(WriteBuilder.Configuration) - Method in class org.apache.beam.sdk.io.snowflake.crosslanguage.WriteBuilder
buildExternal(ConfigT) - Method in interface org.apache.beam.sdk.transforms.ExternalTransformBuilder: Builds the transform after it has been configured.
buildFrom(Descriptors.Descriptor) - Static method in class org.apache.beam.sdk.extensions.protobuf.ProtoDomain
buildFrom(DescriptorProtos.FileDescriptorSet) - Static method in class org.apache.beam.sdk.extensions.protobuf.ProtoDomain
buildFrom(Descriptors.FileDescriptor) - Static method in class org.apache.beam.sdk.extensions.protobuf.ProtoDomain
buildFrom(InputStream) - Static method in class org.apache.beam.sdk.extensions.protobuf.ProtoDomain
buildHCatRecords(int) - Static method in class org.apache.beam.sdk.io.hcatalog.test.HCatalogIOTestUtils: Returns a list of HCatRecords of passed size.
buildIOReader(PBegin) - Method in class org.apache.beam.sdk.extensions.sql.impl.schema.BeamPCollectionTable
buildIOReader(PBegin, BeamSqlTableFilter, List<String>) - Method in class org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable
buildIOReader(PBegin) - Method in interface org.apache.beam.sdk.extensions.sql.meta.BeamSqlTable: create a PCollection<Row> from source.
buildIOReader(PBegin, BeamSqlTableFilter, List<String>) - Method in interface org.apache.beam.sdk.extensions.sql.meta.BeamSqlTable: create a PCollection<Row> from source with predicate and/or project pushed-down.
buildIOReader(PBegin) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.bigtable.BigtableTable
buildIOReader(PBegin, BeamSqlTableFilter, List<String>) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.bigtable.BigtableTable
buildIOReader(PBegin) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.hcatalog.HCatalogTable
buildIOReader(PBegin) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTable
buildIOReader(PBegin) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.mongodb.MongoDbTable
buildIOReader(PBegin, BeamSqlTableFilter, List<String>) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.mongodb.MongoDbTable
buildIOReader(PBegin) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestBoundedTable
buildIOReader(PBegin) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestUnboundedTable
buildIOReader(PBegin) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTable
buildIOWriter(PCollection<Row>) - Method in class org.apache.beam.sdk.extensions.sql.impl.schema.BeamPCollectionTable
buildIOWriter(PCollection<Row>) - Method in interface org.apache.beam.sdk.extensions.sql.meta.BeamSqlTable: create a IO.write() instance to write to target.
buildIOWriter(PCollection<Row>) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.bigtable.BigtableTable
buildIOWriter(PCollection<Row>) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.hcatalog.HCatalogTable
buildIOWriter(PCollection<Row>) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTable
buildIOWriter(PCollection<Row>) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.mongodb.MongoDbTable
buildIOWriter(PCollection<Row>) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestBoundedTable
buildIOWriter(PCollection<Row>) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTable
buildIOWriter(PCollection<Row>) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTable
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamAggregationRel
buildPTransform(PTransform<PCollection<Row>, ? extends POutput>) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamCalcRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamCoGBKJoinRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamIntersectRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamIOSinkRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamIOSourceRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamMatchRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamMinusRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamPushDownIOSourceRel
buildPTransform() - Method in interface org.apache.beam.sdk.extensions.sql.impl.rel.BeamRelNode
buildPTransform(PTransform<PCollection<Row>, ? extends POutput>) - Method in interface org.apache.beam.sdk.extensions.sql.impl.rel.BeamRelNode
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSideInputJoinRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSideInputLookupJoinRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSortRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamTableFunctionScanRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamUncollectRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamUnionRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamUnnestRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamValuesRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamWindowRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.zetasql.BeamZetaSqlCalcRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.zetasql.unnest.BeamZetaSqlUncollectRel
buildPTransform() - Method in class org.apache.beam.sdk.extensions.sql.zetasql.unnest.BeamZetaSqlUnnestRel
buildReader() - Method in class org.apache.beam.sdk.io.gcp.datastore.DataStoreV1SchemaIOProvider.DataStoreV1SchemaIO
buildReader() - Method in interface org.apache.beam.sdk.schemas.io.SchemaIO: Returns a schema aware reader.
buildRows(Schema, List<?>) - Static method in class org.apache.beam.sdk.extensions.sql.meta.provider.test.TestTableUtils: Convenient way to build a BeamSqlRows.
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.
buildTransform() - Method in interface org.apache.beam.sdk.schemas.transforms.SchemaTransform
buildWriter() - Method in class org.apache.beam.sdk.io.gcp.datastore.DataStoreV1SchemaIOProvider.DataStoreV1SchemaIO
buildWriter() - Method in interface org.apache.beam.sdk.schemas.io.SchemaIO: Returns a schema aware writer.
BUILTIN_AGGREGATOR_FACTORIES - Static variable in class org.apache.beam.sdk.extensions.sql.impl.transform.BeamBuiltinAggregations
BUILTIN_ANALYTIC_FACTORIES - Static variable in class org.apache.beam.sdk.extensions.sql.impl.transform.BeamBuiltinAnalyticFunctions
BuiltinHashFunctions - Class in org.apache.beam.sdk.extensions.sql.impl.udf: Hash Functions.
BuiltinHashFunctions() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.udf.BuiltinHashFunctions
BuiltinStringFunctions - Class in org.apache.beam.sdk.extensions.sql.impl.udf: BuiltinStringFunctions.
BuiltinStringFunctions() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.udf.BuiltinStringFunctions
BuiltinTrigonometricFunctions - Class in org.apache.beam.sdk.extensions.sql.impl.udf: TrigonometricFunctions.
BuiltinTrigonometricFunctions() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.udf.BuiltinTrigonometricFunctions
bulkIO() - Static method in class org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO
BulkIO() - Constructor for class org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.BulkIO
Bundle<T,CollectionT> - Interface in org.apache.beam.runners.local: An immutable collection of elements which are part of a PCollection.
BundleCheckpointHandler - Interface in org.apache.beam.runners.fnexecution.control: A handler which is invoked when the SDK returns BeamFnApi.DelayedBundleApplications as part of the bundle completion.
BundleCheckpointHandlers - Class in org.apache.beam.runners.fnexecution.control: Utility methods for creating BundleCheckpointHandlers.
BundleCheckpointHandlers() - Constructor for class org.apache.beam.runners.fnexecution.control.BundleCheckpointHandlers
BundleCheckpointHandlers.StateAndTimerBundleCheckpointHandler<T> - Class in org.apache.beam.runners.fnexecution.control: A BundleCheckpointHandler which uses TimerInternals.TimerData ans ValueState to reschedule BeamFnApi.DelayedBundleApplication.
BundleFinalizationHandler - Interface in org.apache.beam.runners.fnexecution.control: A handler for the runner when a finalization request has been received.
BundleFinalizationHandlers - Class in org.apache.beam.runners.fnexecution.control: Utility methods for creating BundleFinalizationHandlers.
BundleFinalizationHandlers() - Constructor for class org.apache.beam.runners.fnexecution.control.BundleFinalizationHandlers
BundleFinalizationHandlers.InMemoryFinalizer - Class in org.apache.beam.runners.fnexecution.control: See BundleFinalizationHandlers.inMemoryFinalizer(InstructionRequestHandler) for details.
BundleProgressHandler - Interface in org.apache.beam.runners.fnexecution.control: A handler for bundle progress messages, both during bundle execution and on its completion.
BundleSplitHandler - Interface in org.apache.beam.runners.fnexecution.control: A handler which is invoked whenever an active bundle is split.
by(SerializableFunction<UserT, DestinationT>) - Method in class org.apache.beam.sdk.io.FileIO.Write: Specifies how to partition elements into groups ("destinations").
by(Contextful<Contextful.Fn<UserT, DestinationT>>) - Method in class org.apache.beam.sdk.io.FileIO.Write: Like FileIO.Write.by(org.apache.beam.sdk.transforms.SerializableFunction<UserT, DestinationT>), but with access to context such as side inputs.
By() - Constructor for class org.apache.beam.sdk.schemas.transforms.CoGroup.By
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.
by(PredicateT) - Static method in class org.apache.beam.sdk.transforms.Filter: Binary compatibility adapter for Filter.by(ProcessFunction).
byFieldAccessDescriptor(FieldAccessDescriptor) - Static method in class org.apache.beam.sdk.schemas.transforms.Group: Returns a transform that groups all elements in the input PCollection keyed by the fields specified.
byFieldIds(Integer...) - Static method in class org.apache.beam.sdk.schemas.transforms.Group: Returns a transform that groups all elements in the input PCollection keyed by the list of fields specified.
byFieldIds(Iterable<Integer>) - Static method in class org.apache.beam.sdk.schemas.transforms.Group: Same as Group.byFieldIds(Integer...).
byFieldNames(String...) - Static method in class org.apache.beam.sdk.schemas.transforms.Group: Returns a transform that groups all elements in the input PCollection keyed by the list of fields specified.
byFieldNames(Iterable<String>) - Static method in class org.apache.beam.sdk.schemas.transforms.Group: Same as Group.byFieldNames(String...).
ByFields() - Constructor for class org.apache.beam.sdk.schemas.transforms.Group.ByFields
BYTE - Static variable in class org.apache.beam.sdk.schemas.Schema.FieldType: The type of byte fields.
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[].
ByteArrayKey(byte[]) - Constructor for class org.apache.beam.runners.jet.Utils.ByteArrayKey
ByteBuddyUtils - Class in org.apache.beam.sdk.schemas.utils
ByteBuddyUtils() - Constructor for class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils
ByteBuddyUtils.ConvertType - Class in org.apache.beam.sdk.schemas.utils: Give a Java type, returns the Java type expected for use with Row.
ByteBuddyUtils.ConvertValueForGetter - Class in org.apache.beam.sdk.schemas.utils: Takes a StackManipulation that returns a value.
ByteBuddyUtils.ConvertValueForSetter - Class in org.apache.beam.sdk.schemas.utils: Row is going to call the setter with its internal Java type, however the user object being set might have a different type internally.
ByteBuddyUtils.DefaultTypeConversionsFactory - Class in org.apache.beam.sdk.schemas.utils
ByteBuddyUtils.InjectPackageStrategy - Class in org.apache.beam.sdk.schemas.utils: A naming strategy for ByteBuddy classes.
ByteBuddyUtils.TransformingMap<K1,V1,K2,V2> - Class in org.apache.beam.sdk.schemas.utils
ByteBuddyUtils.TypeConversion<T> - Class in org.apache.beam.sdk.schemas.utils
ByteBuddyUtils.TypeConversionsFactory - Interface in org.apache.beam.sdk.schemas.utils
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.
ByteKeyRangeTracker - Class in org.apache.beam.sdk.transforms.splittabledofn: A RestrictionTracker for claiming ByteKeys in a ByteKeyRange in a monotonically increasing fashion.
BYTES - Static variable in class org.apache.beam.sdk.schemas.Schema.FieldType: The type of bytes fields.
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.
bytesToRowFn(SchemaProvider, TypeDescriptor<T>, ProcessFunction<byte[], ? extends T>) - Static method in class org.apache.beam.sdk.schemas.RowMessages
bytesToRowFn(SchemaProvider, TypeDescriptor<T>, Coder<? extends T>) - Static method in class org.apache.beam.sdk.schemas.RowMessages
byteString(byte[]) - Static method in class org.apache.beam.sdk.io.gcp.bigtable.RowUtils
byteString(byte[]) - Static method in class org.apache.beam.sdk.io.gcp.testing.BigtableUtils
ByteStringCoder - Class in org.apache.beam.runners.fnexecution.wire: A duplicate of ByteStringCoder that uses the Apache Beam vendored protobuf.
ByteStringCoder - Class in org.apache.beam.sdk.extensions.protobuf: A Coder for ByteString objects based on their encoded Protocol Buffer form.
byteStringUtf8(String) - Static method in class org.apache.beam.sdk.io.gcp.bigtable.RowUtils
byteStringUtf8(String) - Static method in class org.apache.beam.sdk.io.gcp.testing.BigtableUtils
bytesWritten() - Static method in class org.apache.beam.sdk.metrics.SinkMetrics: Counter of bytes written to a sink.
ByteToElemFunction<V> - Class in org.apache.beam.runners.twister2.translators.functions: ByteToWindow function.
ByteToElemFunction() - Constructor for class org.apache.beam.runners.twister2.translators.functions.ByteToElemFunction
ByteToElemFunction(WindowedValue.WindowedValueCoder<V>) - Constructor for class org.apache.beam.runners.twister2.translators.functions.ByteToElemFunction
ByteToWindowFunction<K,V> - Class in org.apache.beam.runners.twister2.translators.functions: ByteToWindow function.
ByteToWindowFunction() - Constructor for class org.apache.beam.runners.twister2.translators.functions.ByteToWindowFunction
ByteToWindowFunction(Coder<K>, WindowedValue.WindowedValueCoder<V>) - Constructor for class org.apache.beam.runners.twister2.translators.functions.ByteToWindowFunction
ByteToWindowFunctionPrimitive<K,V> - Class in org.apache.beam.runners.twister2.translators.functions: ByteToWindow function.
ByteToWindowFunctionPrimitive() - Constructor for class org.apache.beam.runners.twister2.translators.functions.ByteToWindowFunctionPrimitive
ByteToWindowFunctionPrimitive(Coder<K>, WindowedValue.WindowedValueCoder<V>) - Constructor for class org.apache.beam.runners.twister2.translators.functions.ByteToWindowFunctionPrimitive

C

CACHED_CREATORS - Static variable in class org.apache.beam.sdk.schemas.utils.JavaBeanUtils
CACHED_CREATORS - Static variable in class org.apache.beam.sdk.schemas.utils.POJOUtils
CachedSideInputReader - Class in org.apache.beam.runners.spark.structuredstreaming.translation.utils: SideInputReader that caches materialized views.
CachedSideInputReader - Class in org.apache.beam.runners.spark.util: SideInputReader that caches materialized views.
CachingFactory<CreatedT> - Class in org.apache.beam.sdk.schemas: A wrapper around a Factory that assumes the schema parameter never changes.
CachingFactory(Factory<CreatedT>) - Constructor for class org.apache.beam.sdk.schemas.CachingFactory
CalciteConnectionWrapper - Class in org.apache.beam.sdk.extensions.sql.impl: Abstract wrapper for CalciteConnection to simplify extension.
CalciteConnectionWrapper(CalciteConnection) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.CalciteConnectionWrapper
CalciteFactoryWrapper - Class in org.apache.beam.sdk.extensions.sql.impl: Wrapper for CalciteFactory.
CalciteQueryPlanner - Class in org.apache.beam.sdk.extensions.sql.impl: The core component to handle through a SQL statement, from explain execution plan, to generate a Beam pipeline.
CalciteQueryPlanner(JdbcConnection, Collection<RuleSet>) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner: Called by BeamSqlEnv.instantiatePlanner() reflectively.
CalciteQueryPlanner.NonCumulativeCostImpl - Class in org.apache.beam.sdk.extensions.sql.impl
CalciteUtils - Class in org.apache.beam.sdk.extensions.sql.impl.utils: Utility methods for Calcite related operations.
CalciteUtils() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils
CalciteUtils.CharType - Class in org.apache.beam.sdk.extensions.sql.impl.utils: A LogicalType corresponding to CHAR.
CalciteUtils.TimeWithLocalTzType - Class in org.apache.beam.sdk.extensions.sql.impl.utils: A LogicalType corresponding to TIME_WITH_LOCAL_TIME_ZONE.
CalcRelSplitter - Class in org.apache.beam.sdk.extensions.sql.impl.rel: CalcRelSplitter operates on a Calc with multiple RexCall sub-expressions that cannot all be implemented by a single concrete RelNode.
CalcRelSplitter(Calc, RelBuilder, CalcRelSplitter.RelType[]) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.rel.CalcRelSplitter: Constructs a CalcRelSplitter.
CalcRelSplitter.RelType - Class in org.apache.beam.sdk.extensions.sql.impl.rel: Type of relational expression.
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.
call(Tuple2<ByteArray, byte[]>) - Method in class org.apache.beam.runners.spark.coders.CoderHelpers.FromByteFunction
call(Iterator<WindowedValue<InputT>>) - Method in class org.apache.beam.runners.spark.structuredstreaming.translation.batch.DoFnFunction
call(K, Iterator<WindowedValue<KV<K, InputT>>>) - Method in class org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.GroupAlsoByWindowViaOutputBufferFn
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.jet.FailedRunningPipelineResults
cancel() - Method in class org.apache.beam.runners.jet.JetPipelineResult
cancel(JobApi.CancelJobRequest, StreamObserver<JobApi.CancelJobResponse>) - Method in class org.apache.beam.runners.jobsubmission.InMemoryJobService
cancel() - Method in class org.apache.beam.runners.jobsubmission.JobInvocation: Cancel the job.
cancel() - Method in class org.apache.beam.runners.spark.SparkPipelineResult
cancel() - Method in class org.apache.beam.runners.spark.structuredstreaming.SparkStructuredStreamingPipelineResult
cancel() - Method in class org.apache.beam.runners.twister2.Twister2PipelineResult
cancel(Exception) - Method in class org.apache.beam.sdk.fn.CancellableQueue: Causes any pending and future CancellableQueue.put(T) and CancellableQueue.take() invocations to throw an exception.
cancel() - Method in class org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver: Deprecated.
cancel() - Method in class org.apache.beam.sdk.fn.data.CompletableFutureInboundDataClient
cancel() - Method in interface org.apache.beam.sdk.fn.data.InboundDataClient: Deprecated.

Cancels the client, causing it to drop any future inbound data.
cancel() - Method in interface org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.BigQueryServerStream: Cancels the stream, releasing any client- and server-side resources.
cancel() - Method in class org.apache.beam.sdk.io.gcp.testing.FakeBigQueryServices.FakeBigQueryServerStream
cancel() - Method in interface org.apache.beam.sdk.PipelineResult: Cancels the pipeline execution.
CancellableQueue<T> - Class in org.apache.beam.sdk.fn: A simplified ThreadSafe blocking queue that can be cancelled freeing any blocked Threads and preventing future Threads from blocking.
CancellableQueue(int) - Constructor for class org.apache.beam.sdk.fn.CancellableQueue: Creates a ThreadSafe blocking queue with a maximum capacity.
cancelled() - Method in interface org.apache.beam.runners.local.PipelineMessageReceiver: Report that the pipeline has been cancelled.
canConvertConvention(Convention) - Method in enum org.apache.beam.sdk.extensions.sql.impl.rel.BeamLogicalConvention
canEqual(Object) - Method in class org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers.DecodeUsingBeamCoder
canEqual(Object) - Method in class org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers.EncodeUsingBeamCoder
canImplement(LogicalCalc, String) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.CalcRelSplitter: Returns whether a relational expression can be implemented solely in a given CalcRelSplitter.RelType.
canImplement(RexFieldAccess) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.CalcRelSplitter.RelType
canImplement(RexDynamicParam) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.CalcRelSplitter.RelType
canImplement(RexLiteral) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.CalcRelSplitter.RelType
canImplement(RexCall) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.CalcRelSplitter.RelType
canImplement(RexNode, boolean) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.CalcRelSplitter.RelType: Returns whether this RelType can implement a given expression.
canImplement(RexProgram) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.CalcRelSplitter.RelType: Returns whether this tester's RelType can implement a given program.
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.
canStopPolling(Instant, StateT) - Method in interface org.apache.beam.sdk.transforms.Watch.Growth.TerminationCondition: Called by the Watch transform to determine whether the given termination state signals that Watch should stop calling Watch.Growth.PollFn for the current input, regardless of whether the last Watch.Growth.PollResult was complete or incomplete.
CassandraIO - Class in org.apache.beam.sdk.io.cassandra: An IO to read and write from/to Apache Cassandra
CassandraIO.MutationType - Enum in org.apache.beam.sdk.io.cassandra: Specify the mutation type: either write or delete.
CassandraIO.Read<T> - Class in org.apache.beam.sdk.io.cassandra: A PTransform to read data from Apache Cassandra.
CassandraIO.ReadAll<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 mutate into Apache Cassandra.
Cast<T> - Class in org.apache.beam.sdk.schemas.transforms: Set of utilities for casting rows between schemas.
Cast() - Constructor for class org.apache.beam.sdk.schemas.transforms.Cast
Cast.CompatibilityError - Class in org.apache.beam.sdk.schemas.transforms: Describes compatibility errors during casting.
Cast.Narrowing - Class in org.apache.beam.sdk.schemas.transforms: Narrowing changes type without guarantee to preserve data.
Cast.Validator - Interface in org.apache.beam.sdk.schemas.transforms: Interface for statically validating casts.
Cast.Widening - Class in org.apache.beam.sdk.schemas.transforms: Widening changes to type that can represent any possible value of the original type.
CAST_OP - Static variable in class org.apache.beam.sdk.extensions.sql.zetasql.translation.SqlOperators
CastFunctionImpl - Class in org.apache.beam.sdk.extensions.sql.zetasql.translation.impl: ZetaSQLCastFunctionImpl.
CastFunctionImpl() - Constructor for class org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.CastFunctionImpl
castNumber(Number, Schema.TypeName, Schema.TypeName) - Static method in class org.apache.beam.sdk.schemas.transforms.Cast
castRow(Row, Schema, Schema) - Static method in class org.apache.beam.sdk.schemas.transforms.Cast
castValue(Object, Schema.FieldType, Schema.FieldType) - Static method in class org.apache.beam.sdk.schemas.transforms.Cast
catalogName() - Method in class org.apache.beam.sdk.extensions.ml.RecommendationAICreateCatalogItem
catalogName() - Method in class org.apache.beam.sdk.extensions.ml.RecommendationAIImportCatalogItems
catalogName() - Method in class org.apache.beam.sdk.extensions.ml.RecommendationAIImportUserEvents
catalogName() - Method in class org.apache.beam.sdk.extensions.ml.RecommendationAIPredict
catalogName() - Method in class org.apache.beam.sdk.extensions.ml.RecommendationAIWriteUserEvent
CEPCall - Class in org.apache.beam.sdk.extensions.sql.impl.cep: A CEPCall instance represents an operation (node) that contains an operator and a list of operands.
CEPFieldRef - Class in org.apache.beam.sdk.extensions.sql.impl.cep: A CEPFieldRef instance represents a node that points to a specified field in a Row.
CEPKind - Enum in org.apache.beam.sdk.extensions.sql.impl.cep: CEPKind corresponds to Calcite's SqlKind.
CEPLiteral - Class in org.apache.beam.sdk.extensions.sql.impl.cep: CEPLiteral represents a literal node.
CEPMeasure - Class in org.apache.beam.sdk.extensions.sql.impl.cep: The CEPMeasure class represents the Measures clause and contains information about output columns.
CEPMeasure(Schema, String, CEPOperation) - Constructor for class org.apache.beam.sdk.extensions.sql.impl.cep.CEPMeasure
CEPOperation - Class in org.apache.beam.sdk.extensions.sql.impl.cep: CEPOperation is the base class for the evaluation operations defined in the DEFINE syntax of MATCH_RECOGNIZE.
CEPOperation() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.cep.CEPOperation
CEPOperator - Class in org.apache.beam.sdk.extensions.sql.impl.cep: The CEPOperator records the operators (i.e.
CEPPattern - Class in org.apache.beam.sdk.extensions.sql.impl.cep: Core pattern class that stores the definition of a single pattern.
CEPUtils - Class in org.apache.beam.sdk.extensions.sql.impl.cep: Some utility methods for transforming Calcite's constructs into our own Beam constructs (for serialization purpose).
CEPUtils() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.cep.CEPUtils
ChangeStreamDao - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.dao: Responsible for making change stream queries for a given partition.
ChangeStreamMetrics - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams: Class to aggregate metrics related functionality.
ChangeStreamMetrics() - Constructor for class org.apache.beam.sdk.io.gcp.spanner.changestreams.ChangeStreamMetrics: Constructs a ChangeStreamMetrics instance with the following metrics enabled by default.
ChangeStreamMetrics(Set<MetricName>) - Constructor for class org.apache.beam.sdk.io.gcp.spanner.changestreams.ChangeStreamMetrics: Constructs a ChangeStreamMetrics instance with the given metrics enabled.
changeStreamQuery(String, Timestamp, Timestamp, long) - Method in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.ChangeStreamDao: Performs a change stream query.
ChangeStreamRecord - Interface in org.apache.beam.sdk.io.gcp.spanner.changestreams.model: Represents a Spanner Change Stream Record.
ChangeStreamRecordMapper - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.mapper: This class is responsible for transforming a Struct to a List of ChangeStreamRecord models.
changeStreamRecordMapper() - Method in class org.apache.beam.sdk.io.gcp.spanner.changestreams.mapper.MapperFactory: Creates and returns a singleton instance of a mapper class capable of transforming a Struct into a List of ChangeStreamRecord subclasses.
ChangeStreamRecordMetadata - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.model: Holds internal execution metrics / metadata for the processed ChangeStreamRecord.
ChangeStreamRecordMetadata.Builder - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.model
ChangeStreamResultSet - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.dao: Decorator class over a ResultSet that provides telemetry for the streamed records.
ChangeStreamResultSetMetadata - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.dao: Represents telemetry metadata gathered during the consumption of a change stream query.
ChangeStreamsConstants - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams: Single place for defining the constants used in the Spanner.readChangeStreams() connector.
ChangeStreamsConstants() - Constructor for class org.apache.beam.sdk.io.gcp.spanner.changestreams.ChangeStreamsConstants
channelNames - Static variable in class org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationLexer
CHAR - Static variable in class org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils
CHAR_LENGTH - Static variable in class org.apache.beam.sdk.extensions.sql.zetasql.translation.SqlOperators
CHAR_LENGTH_METHOD - Static variable in class org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.BeamBuiltinMethods
characters() - Static method in class org.apache.beam.sdk.values.TypeDescriptors: The TypeDescriptor for Character.
charLength(String) - Static method in class org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.StringFunctions
CharType() - Constructor for class org.apache.beam.sdk.extensions.sql.impl.utils.CalciteUtils.CharType
check(RelNode) - Method in interface org.apache.beam.sdk.extensions.sql.impl.rule.JoinRelOptRuleCall.JoinChecker
checkConfiguration(ClientConfiguration, AwsOptions) - Method in interface org.apache.beam.sdk.io.aws2.common.ClientBuilderFactory: Check if all necessary configuration is available to create clients.
checkConfiguration(ClientConfiguration, AwsOptions) - Method in class org.apache.beam.sdk.io.aws2.common.ClientBuilderFactory.DefaultClientBuilder
checkDone() - Method in class org.apache.beam.sdk.io.gcp.spanner.changestreams.restriction.TimestampRangeTracker: Checks if the restriction has been processed successfully.
checkDone() - Method in class org.apache.beam.sdk.transforms.PeriodicSequence.OutputRangeTracker
checkDone() - Method in class org.apache.beam.sdk.transforms.splittabledofn.ByteKeyRangeTracker
checkDone() - Method in class org.apache.beam.sdk.transforms.splittabledofn.OffsetRangeTracker
checkDone() - Method in class org.apache.beam.sdk.transforms.splittabledofn.RestrictionTracker: Checks whether the restriction has been fully processed.
checkIfAnySubscriptionExists(String, Duration) - Method in class org.apache.beam.sdk.io.gcp.pubsub.TestPubsub: Deprecated.
Use TestPubsub.assertSubscriptionEventuallyCreated(java.lang.String, org.joda.time.Duration).
checksum() - Method in class org.apache.beam.sdk.io.fs.MatchResult.Metadata: An optional checksum to identify the contents of a file.
child() - Method in class org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers.DecodeUsingBeamCoder
child() - Method in class org.apache.beam.runners.spark.structuredstreaming.translation.helpers.EncoderHelpers.EncodeUsingBeamCoder
ChildPartition - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.model: A child partition represents a new partition that should be queried.
ChildPartition(String, HashSet<String>) - Constructor for class org.apache.beam.sdk.io.gcp.spanner.changestreams.model.ChildPartition: Constructs a child partition, which will have its own token and the parents that it originated from.
ChildPartition(String, String) - Constructor for class org.apache.beam.sdk.io.gcp.spanner.changestreams.model.ChildPartition: Constructs a child partition, which will have its own token and the parent that it originated from.
ChildPartitionsRecord - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.model: Represents a ChildPartitionsRecord.
ChildPartitionsRecord(Timestamp, String, List<ChildPartition>, ChangeStreamRecordMetadata) - Constructor for class org.apache.beam.sdk.io.gcp.spanner.changestreams.model.ChildPartitionsRecord: Constructs a child partitions record containing one or more child partitions.
childPartitionsRecordAction(PartitionMetadataDao, ChangeStreamMetrics) - Method in class org.apache.beam.sdk.io.gcp.spanner.changestreams.action.ActionFactory: Creates and returns a singleton instance of an action class capable of process ChildPartitionsRecords.
ChildPartitionsRecordAction - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.action: This class is part of the process for ReadChangeStreamPartitionDoFn SDF.
CivilTimeEncoder - Class in org.apache.beam.sdk.io.gcp.bigquery: Encoder for TIME and DATETIME values, according to civil_time encoding.
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
ClassLoaderFileSystem - Class in org.apache.beam.sdk.io: A read-only FileSystem implementation looking up resources using a ClassLoader.
ClassLoaderFileSystem.ClassLoaderFileSystemRegistrar - Class in org.apache.beam.sdk.io: AutoService registrar for the ClassLoaderFileSystem.
ClassLoaderFileSystem.ClassLoaderResourceId - Class in org.apache.beam.sdk.io
ClassLoaderFileSystemRegistrar() - Constructor for class org.apache.beam.sdk.io.ClassLoaderFileSystem.ClassLoaderFileSystemRegistrar
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
ClassWithSchema() - Constructor for class org.apache.beam.sdk.schemas.utils.ReflectUtils.ClassWithSchema
CleanTmpFilesFromGcsFn(ValueProvider<String>, String) - Constructor for class org.apache.beam.sdk.io.snowflake.SnowflakeIO.Read.CleanTmpFilesFromGcsFn: Created object that will remove temp files from stage.
cleanup() - Method in class org.apache.beam.sdk.io.FileBasedSink.Writer
CleanUpReadChangeStreamDoFn - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.dofn
CleanUpReadChangeStreamDoFn(DaoFactory) - Constructor for class org.apache.beam.sdk.io.gcp.spanner.changestreams.dofn.CleanUpReadChangeStreamDoFn
clear(K, W) - Method in interface org.apache.beam.runners.fnexecution.state.StateRequestHandlers.BagUserStateHandler: Clears the bag user state for the given key and window.
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.structuredstreaming.aggregators.AggregatorsAccumulator
clear() - Static method in class org.apache.beam.runners.spark.structuredstreaming.metrics.MetricsAccumulator
clear() - Static method in class org.apache.beam.runners.spark.util.GlobalWatermarkHolder
clear() - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.TransformingMap
clear() - Method in interface org.apache.beam.sdk.state.State: Clear out the state location.
clear() - Method in interface org.apache.beam.sdk.state.Timer: Clears a timer.
clearCache() - Static method in class org.apache.beam.runners.spark.io.MicrobatchSource
clearOutputElements() - Method in class org.apache.beam.sdk.transforms.DoFnTester: Deprecated.
Use TestPipeline with the DirectRunner.
clearOutputElements(TupleTag<T>) - Method in class org.apache.beam.sdk.transforms.DoFnTester: Deprecated.
Use TestPipeline with the DirectRunner.
clearRange(Instant, Instant) - Method in interface org.apache.beam.sdk.state.OrderedListState: Clear a timestamp-limited subrange of the list.
clearState(ReduceFn<K, T, Iterable<T>, W>.Context) - Method in class org.apache.beam.runners.twister2.translators.functions.internal.SystemReduceFnBuffering
clearWarnings() - Method in class org.apache.beam.sdk.extensions.sql.impl.CalciteConnectionWrapper
ClickHouseIO - Class in org.apache.beam.sdk.io.clickhouse: An IO to write to ClickHouse.
ClickHouseIO() - Constructor for class org.apache.beam.sdk.io.clickhouse.ClickHouseIO
ClickHouseIO.Write<T> - Class in org.apache.beam.sdk.io.clickhouse: A PTransform to write to ClickHouse.
ClickHouseWriter - Class in org.apache.beam.sdk.io.clickhouse: Writes Rows and field values using ClickHouseRowBinaryStream.
ClickHouseWriter() - Constructor for class org.apache.beam.sdk.io.clickhouse.ClickHouseWriter
CLIENT_EXECUTION_TIMEOUT - Static variable in class org.apache.beam.sdk.io.aws.options.AwsModule
clientBuffered(ExecutorService) - Static method in class org.apache.beam.sdk.fn.stream.OutboundObserverFactory: Create a buffering OutboundObserverFactory for client-side RPCs with the specified ExecutorService and the default buffer size.
clientBuffered(ExecutorService, int) - Static method in class org.apache.beam.sdk.fn.stream.OutboundObserverFactory: Create a buffering OutboundObserverFactory for client-side RPCs with the specified ExecutorService and buffer size.
ClientBuilderFactory - Interface in org.apache.beam.sdk.io.aws2.common: Factory to build and configure any AwsClientBuilder using a specific ClientConfiguration or the globally provided settings in AwsOptions as fallback.
ClientBuilderFactory.DefaultClientBuilder - Class in org.apache.beam.sdk.io.aws2.common: Default implementation of ClientBuilderFactory.
ClientConfiguration - Class in org.apache.beam.sdk.io.aws2.common: AWS client configuration.
ClientConfiguration() - Constructor for class org.apache.beam.sdk.io.aws2.common.ClientConfiguration
ClientConfiguration.Builder - Class in org.apache.beam.sdk.io.aws2.common
ClientConfigurationFactory() - Constructor for class org.apache.beam.sdk.io.aws.options.AwsOptions.ClientConfigurationFactory
clientDirect() - Static method in class org.apache.beam.sdk.fn.stream.OutboundObserverFactory: Create the default OutboundObserverFactory for client-side RPCs, which uses basic unbuffered flow control.
Clock - Interface in org.apache.beam.runners.direct: Access to the current time.
clone() - Method in class org.apache.beam.runners.dataflow.util.CloudObject
clone() - Method in class org.apache.beam.runners.flink.metrics.MetricsAccumulator
clonesOf(OutT) - Static method in class org.apache.beam.sdk.transforms.SerializableFunctions
close() - Method in class org.apache.beam.runners.dataflow.util.PackageUtil
close() - Method in class org.apache.beam.runners.flink.metrics.FileReporter
close() - Method in class org.apache.beam.runners.fnexecution.artifact.ArtifactRetrievalService
close() - Method in class org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService
close() - Method in class org.apache.beam.runners.fnexecution.control.DefaultExecutableStageContext
close() - Method in class org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory
close() - Method in class org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory.WrappedSdkHarnessClient
close() - Method in class org.apache.beam.runners.fnexecution.control.FnApiControlClient
close() - Method in class org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
close() - Method in interface org.apache.beam.runners.fnexecution.control.RemoteBundle: Closes this bundle.
close() - Method in class org.apache.beam.runners.fnexecution.control.SdkHarnessClient.BundleProcessor.ActiveBundle: Blocks until bundle processing is finished.
close() - Method in class org.apache.beam.runners.fnexecution.control.SdkHarnessClient
close() - Method in class org.apache.beam.runners.fnexecution.control.SingleEnvironmentInstanceJobBundleFactory: Deprecated.
close() - Method in class org.apache.beam.runners.fnexecution.data.GrpcDataService
close() - Method in class org.apache.beam.runners.fnexecution.environment.ProcessEnvironment
close() - Method in interface org.apache.beam.runners.fnexecution.environment.RemoteEnvironment: .
close() - Method in class org.apache.beam.runners.fnexecution.environment.StaticRemoteEnvironment
close() - Method in class org.apache.beam.runners.fnexecution.logging.GrpcLoggingService
close() - Method in class org.apache.beam.runners.fnexecution.provisioning.StaticGrpcProvisionService
close() - Method in class org.apache.beam.runners.fnexecution.state.GrpcStateService
close() - Method in class org.apache.beam.runners.fnexecution.status.BeamWorkerStatusGrpcService
close() - Method in class org.apache.beam.runners.jet.processors.BoundedSourceP
close() - Method in class org.apache.beam.runners.jet.processors.UnboundedSourceP
close() - Method in class org.apache.beam.runners.jobsubmission.InMemoryJobService
close() - Method in class org.apache.beam.runners.portability.CloseableResource: Closes the underlying resource.
close(T) - Method in interface org.apache.beam.runners.portability.CloseableResource.Closer
close() - Method in class org.apache.beam.runners.spark.io.MicrobatchSource.Reader
close() - Method in class org.apache.beam.runners.twister2.translators.functions.DoFnFunction
close() - Method in class org.apache.beam.runners.twister2.translators.functions.Twister2SinkFunction
close() - Method in class org.apache.beam.sdk.expansion.service.ExpansionServer
close() - Method in class org.apache.beam.sdk.expansion.service.ExpansionService
close() - Method in class org.apache.beam.sdk.extensions.arrow.ArrowConversion.RecordBatchRowIterator
close() - Method in class org.apache.beam.sdk.extensions.sql.impl.CalciteConnectionWrapper
close() - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.datacatalog.DataCatalogTableProvider
close() - Method in class org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer: Deprecated.
close() - Method in class org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer2
close() - Method in class org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver2
close() - Method in class org.apache.beam.sdk.fn.data.BeamFnDataOutboundObserver: Deprecated.
close() - Method in interface org.apache.beam.sdk.fn.data.CloseableFnDataReceiver: .
close() - Method in interface org.apache.beam.sdk.fn.server.FnService: .
close() - Method in class org.apache.beam.sdk.fn.server.GrpcFnServer
close() - Method in class org.apache.beam.sdk.fn.stream.DataStreams.ElementDelimitedOutputStream
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 interface org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.StorageClient: Close the client object.
close() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubGrpcClient: Gracefully close the underlying netty channel.
close() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubJsonClient
close() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubTestClient
close() - Method in interface org.apache.beam.sdk.io.gcp.pubsublite.internal.ManagedBacklogReaderFactory
close() - Method in class org.apache.beam.sdk.io.gcp.pubsublite.internal.ManagedBacklogReaderFactoryImpl
close() - Method in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.ChangeStreamResultSet: Closes the current change stream ResultSet.
close() - Method in class org.apache.beam.sdk.io.gcp.spanner.SpannerAccessor
close() - Method in class org.apache.beam.sdk.io.gcp.testing.FakeDatasetService
close() - Method in class org.apache.beam.sdk.io.gcp.testing.FakeJobService
close() - Method in class org.apache.beam.sdk.io.hcatalog.test.EmbeddedMetastoreService
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.io.thrift.ThriftIO.ThriftWriter
close() - Method in class org.apache.beam.sdk.transforms.DoFnTester: Deprecated.
Use TestPipeline with the DirectRunner.
CloseableFnDataReceiver<T> - Interface in org.apache.beam.sdk.fn.data: A receiver of streamed data that can be closed.
CloseableResource<T> - Class in org.apache.beam.runners.portability: An AutoCloseable that wraps a resource that needs to be cleaned up but does not implement AutoCloseable itself.
CloseableResource.CloseException - Exception in org.apache.beam.runners.portability: An exception that wraps errors thrown while a resource is being closed.
CloseableResource.Closer<T> - Interface in org.apache.beam.runners.portability: A function that knows how to clean up after a resource.
CloseableThrowingConsumer<ExceptionT extends java.lang.Exception,T> - Interface in org.apache.beam.sdk.function: A ThrowingConsumer that can be closed.
closeTo(double, double) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers: A SerializableMatcher with identical criteria to Matchers.closeTo(double,double).
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.
cloudObjectClassName() - Method in class org.apache.beam.runners.dataflow.util.RowCoderCloudObjectTranslator
cloudObjectClassName() - Method in class org.apache.beam.runners.dataflow.util.SchemaCoderCloudObjectTranslator
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.
CloudPubsubTransforms - Class in org.apache.beam.sdk.io.gcp.pubsublite: A class providing transforms between Cloud Pub/Sub and Pub/Sub Lite message types.
CloudResourceManagerOptions - Interface in org.apache.beam.sdk.extensions.gcp.options: Properties needed when using Google CloudResourceManager with the Apache Beam SDK.
CloudVision - Class in org.apache.beam.sdk.extensions.ml: Factory class for implementations of AnnotateImages.
CloudVision() - Constructor for class org.apache.beam.sdk.extensions.ml.CloudVision
CloudVision.AnnotateImagesFromBytes - Class in org.apache.beam.sdk.extensions.ml: Accepts ByteString (encoded image contents) with optional DoFn.SideInput with a Map of ImageContext to the image.
CloudVision.AnnotateImagesFromBytesWithContext - Class in org.apache.beam.sdk.extensions.ml: Accepts KVs of ByteString (encoded image contents) and ImageContext.
CloudVision.AnnotateImagesFromGcsUri - Class in org.apache.beam.sdk.extensions.ml: Accepts String (image URI on GCS) with optional DoFn.SideInput with a Map of ImageContext to the image.
CloudVision.AnnotateImagesFromGcsUriWithContext - Class in org.apache.beam.sdk.extensions.ml: Accepts KVs of String (GCS URI to the image) and ImageContext.
CO_GBK_RESULT_SCHEMA - Static variable in class org.apache.beam.runners.dataflow.util.PropertyNames
CodahaleCsvSink - Class in org.apache.beam.runners.spark.structuredstreaming.metrics.sink: A Spark Sink that is tailored to report AggregatorMetric metrics to a CSV file.
CodahaleCsvSink(Properties, MetricRegistry, SecurityManager) - Constructor for class org.apache.beam.runners.spark.structuredstreaming.metrics.sink.CodahaleCsvSink
CodahaleGraphiteSink - Class in org.apache.beam.runners.spark.structuredstreaming.metrics.sink: A Spark Sink that is tailored to report AggregatorMetric metrics to Graphite.
CodahaleGraphiteSink(Properties, MetricRegistry, SecurityManager) - Constructor for class org.apache.beam.runners.spark.structuredstreaming.metrics.sink.CodahaleGraphiteSink
coder() - Method in class org.apache.beam.runners.fnexecution.control.ProcessBundleDescriptors.TimerSpec
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() - Constructor for class org.apache.beam.sdk.io.range.OffsetRange.Coder
Coder.Context - Class in org.apache.beam.sdk.coders: Deprecated.
To implement a coder, do not use any Coder.Context. Just implement only those abstract methods which do not accept a Coder.Context and leave the default implementations for methods accepting a Coder.Context.
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.
coderDecodeEncodeInContext(Coder<T>, Coder.Context, T, Matcher<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 a value of type T and tests that the matcher succeeds on the values.
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.
coderForFieldType(Schema.FieldType) - Static method in class org.apache.beam.sdk.schemas.SchemaCoder
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.
CoderHelpers - Class in org.apache.beam.runners.spark.structuredstreaming.translation.helpers: Serialization utility class.
CoderHelpers.FromByteFunction<K,V> - Class in org.apache.beam.runners.spark.coders: A function for converting a byte array pair to a key-value pair.
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, 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.
CoGroup - Class in org.apache.beam.sdk.schemas.transforms: A transform that performs equijoins across multiple schema PCollections.
CoGroup() - Constructor for class org.apache.beam.sdk.schemas.transforms.CoGroup
CoGroup.By - Class in org.apache.beam.sdk.schemas.transforms: Defines the set of fields to extract for the join key, as well as other per-input join options.
CoGroup.ExpandCrossProduct - Class in org.apache.beam.sdk.schemas.transforms: A PTransform that calculates the cross-product join.
CoGroup.Impl - Class in org.apache.beam.sdk.schemas.transforms: The implementing PTransform.
CoGroup.Result - Class in org.apache.beam.sdk.schemas.transforms
CoGroupByKey<K> - Class in org.apache.beam.sdk.transforms.join: A PTransform that performs a CoGroupByKey on a tuple of tables.
COLLECTION_TYPES - Static variable in enum org.apache.beam.sdk.schemas.Schema.TypeName
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
column(SqlParserPos, SqlIdentifier, SqlDataTypeSpec, SqlNode) - Static method in class org.apache.beam.sdk.extensions.sql.impl.parser.SqlDdlNodes: Creates a column declaration.
Column() - Constructor for class org.apache.beam.sdk.io.clickhouse.TableSchema.Column
COLUMN_CREATED_AT - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao: Metadata table column name for the timestamp at which the partition row was first created.
COLUMN_END_TIMESTAMP - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao: Metadata table column name for the timestamp to end the change stream query of the partition.
COLUMN_FINISHED_AT - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao: Metadata table column name for the timestamp at which the partition was marked as finished by the ReadChangeStreamPartitionDoFn SDF.
COLUMN_HEARTBEAT_MILLIS - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao: Metadata table column name for the change stream query heartbeat interval in millis.
COLUMN_PARENT_TOKENS - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao: Metadata table column name for parent partition tokens.
COLUMN_PARTITION_TOKEN - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao: Metadata table column name for the partition token.
COLUMN_RUNNING_AT - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao: Metadata table column name for the timestamp at which the partition was marked as running by the ReadChangeStreamPartitionDoFn SDF.
COLUMN_SCHEDULED_AT - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao: Metadata table column name for the timestamp at which the partition was scheduled by the DetectNewPartitionsDoFn SDF.
COLUMN_START_TIMESTAMP - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao: Metadata table column name for the timestamp to start the change stream query of the partition.
COLUMN_STATE - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao: Metadata table column name for the state that the partition is currently in.
COLUMN_WATERMARK - Static variable in class org.apache.beam.sdk.io.gcp.spanner.changestreams.dao.PartitionMetadataAdminDao: Metadata table column name for the current watermark of the partition.
columns() - Method in class org.apache.beam.sdk.io.clickhouse.TableSchema
COLUMNS_MAPPING - Static variable in class org.apache.beam.sdk.io.gcp.bigtable.RowUtils
columnType() - Method in class org.apache.beam.sdk.io.clickhouse.TableSchema.Column
ColumnType() - Constructor for class org.apache.beam.sdk.io.clickhouse.TableSchema.ColumnType
ColumnType - Class in org.apache.beam.sdk.io.gcp.spanner.changestreams.model: Defines a column type from a Cloud Spanner table with the following information: column name, column type, flag indicating if column is primary key and column position in the table.
ColumnType(String, TypeCode, boolean, long) - Constructor for class org.apache.beam.sdk.io.gcp.spanner.changestreams.model.ColumnType
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.
CombineFieldsByFields() - Constructor for class org.apache.beam.sdk.schemas.transforms.Group.CombineFieldsByFields
combineFn() - Static method in class org.apache.beam.sdk.extensions.sql.impl.transform.agg.CountIf
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 uniform 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.
CombineFnTester - Class in org.apache.beam.sdk.testing: Utilities for testing CombineFns.
CombineFnTester() - Constructor for class org.apache.beam.sdk.testing.CombineFnTester
CombineFnWithContext() - Constructor for class org.apache.beam.sdk.transforms.CombineWithContext.CombineFnWithContext
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.
comment(String) - Method in class org.apache.beam.sdk.extensions.sql.meta.Table.Builder
commit() - Method in class org.apache.beam.sdk.extensions.sql.impl.CalciteConnectionWrapper
commitOffsets() - Method in class org.apache.beam.sdk.io.kafka.KafkaIO.ReadSourceDescriptors: Enable committing record offset.
commitOffsetsInFinalize() - Method in class org.apache.beam.sdk.io.kafka.KafkaIO.Read: Finalized offsets are committed to Kafka.
commitWriteStreams(String, Iterable<String>) - Method in interface org.apache.beam.sdk.io.gcp.bigquery.BigQueryServices.DatasetService: Commit write streams of type PENDING.
commitWriteStreams(String, Iterable<String>) - Method in class org.apache.beam.sdk.io.gcp.testing.FakeDatasetService
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.extensions.sql.TypedCombineFnDelegate
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(Row, Row) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamSortRel.BeamSqlRowComparator
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(Path) - Method in class org.apache.beam.sdk.extensions.gcp.util.gcsfs.GcsPath
compareTo(Object) - Method in class org.apache.beam.sdk.extensions.sql.impl.cep.CEPLiteral
compareTo(ByteKey) - Method in class org.apache.beam.sdk.io.range.ByteKey: ByteKey implements Comparable<ByteKey> by comparing the arrays in lexicographic order.
compareTo(RedisCursor) - Method in class org.apache.beam.sdk.io.redis.RedisCursor: RedisCursor implements Comparable<RedisCursor> by transforming the cursors to an index of the Redis table.
compareTo(IntervalWindow) - Method in class org.apache.beam.sdk.transforms.windowing.IntervalWindow
CompatibilityError() - Constructor for class org.apache.beam.sdk.schemas.transforms.Cast.CompatibilityError
compile(List<CEPPattern>, Schema) - Static method in class org.apache.beam.sdk.extensions.sql.impl.nfa.NFA
CompletableFutureInboundDataClient - Class in org.apache.beam.sdk.fn.data: An InboundDataClient backed by a CompletableFuture.
complete() - Method in class org.apache.beam.runners.jet.processors.BoundedSourceP
complete() - Method in class org.apache.beam.runners.jet.processors.ImpulseP
complete() - Method in class org.apache.beam.runners.jet.processors.StatefulParDoP
complete() - Method in class org.apache.beam.runners.jet.processors.UnboundedSourceP
complete() - Method in class org.apache.beam.runners.jet.processors.ViewP
complete() - Method in class org.apache.beam.runners.jet.processors.WindowGroupP
complete() - Method in class org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver: Deprecated.
complete() - Method in class org.apache.beam.sdk.fn.data.CompletableFutureInboundDataClient
complete() - Method in interface org.apache.beam.sdk.fn.data.InboundDataClient: Deprecated.

Mark the client as completed.
complete(List<TimestampedValue<OutputT>>) - Static method in class org.apache.beam.sdk.transforms.Watch.Growth.PollResult: Constructs a Watch.Growth.PollResult with the given outputs and declares that there will be no new outputs for the current input.
complete(Instant, List<OutputT>) - Static method in class org.apache.beam.sdk.transforms.Watch.Growth.PollResult: Like Watch.Growth.PollResult.complete(List), but assigns the same timestamp to all new outputs.
completed() - Method in interface org.apache.beam.runners.local.PipelineMessageReceiver: Report that the pipeline has successfully completed.
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.
compose(SerializableFunction<InputT, OutputT>) - Static method in class org.apache.beam.sdk.transforms.PTransform: For a SerializableFunction<InputT, OutputT> fn, returns a PTransform given by applying fn.apply(v) to the input PCollection<InputT>.
compose(String, SerializableFunction<InputT, OutputT>) - Static method in class org.apache.beam.sdk.transforms.PTransform: Like PTransform.compose(SerializableFunction), but with a custom name.
ComposeCombineFnBuilder() - Constructor for class org.apache.beam.sdk.transforms.CombineFns.ComposeCombineFnBuilder
COMPOSITE_TYPES - Static variable in enum org.apache.beam.sdk.schemas.Schema.TypeName
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
CompositeSource - Class in org.apache.beam.runners.spark.structuredstreaming.metrics: Composite source made up of several MetricRegistry instances.
CompositeSource(String, MetricRegistry...) - Constructor for class org.apache.beam.runners.spark.structuredstreaming.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: Deprecated.
Use Compression instead
CompressedSource.DecompressingChannelFactory - Interface in org.apache.beam.sdk.io: Factory interface for creating channels that decompress the content of an underlying channel.
Compression - Enum in org.apache.beam.sdk.io: Various compression types for reading/writing files.
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
compute(Iterator<WindowedValue<T>>, RecordCollector<WindowedValue<T>>) - Method in class org.apache.beam.runners.twister2.translators.functions.AssignWindowsFunction
compute(Iterator<WindowedValue<InputT>>, RecordCollector<RawUnionValue>) - Method in class org.apache.beam.runners.twister2.translators.functions.DoFnFunction
compute(Iterator<RawUnionValue>, RecordCollector<WindowedValue<OutputT>>) - Method in class org.apache.beam.runners.twister2.translators.functions.OutputTagFilter
computeIfAbsent(K, Function<? super K, ? extends V>) - Method in interface org.apache.beam.sdk.state.MapState: A deferred read-followed-by-write.
computeSelfCost(RelOptPlanner, RelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamEnumerableConverter
computeSelfCost(RelOptPlanner, RelMetadataQuery) - Method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamIOSourceRel
concat(String) - Static method in class org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.StringFunctions
concat(String, String) - Static method in class org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.StringFunctions
concat(String, String, String) - Static method in class org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.StringFunctions
concat(String, String, String, String) - Static method in class org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.StringFunctions
concat(String, String, String, String, String) - Static method in class org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.StringFunctions
CONCAT - Static variable in class org.apache.beam.sdk.extensions.sql.zetasql.translation.SqlOperators
concat(Iterable<T>...) - Static method in class org.apache.beam.sdk.fn.stream.PrefetchableIterables: Concatentates the Iterables.
concat(Iterator<T>...) - Static method in class org.apache.beam.sdk.fn.stream.PrefetchableIterators: Concatentates the Iterators.
CONCAT_FIELD_NAMES - Static variable in class org.apache.beam.sdk.schemas.utils.SelectHelpers: This policy keeps all levels of a name.
CONCAT_METHOD - Static variable in class org.apache.beam.sdk.extensions.sql.zetasql.translation.impl.BeamBuiltinMethods
Concatenate() - Constructor for class org.apache.beam.sdk.io.snowflake.SnowflakeIO.Concatenate
concatFieldNames() - Method in class org.apache.beam.sdk.schemas.transforms.Select.Flattened: For nested fields, concatenate all the names separated by a _ character in the flattened schema.
concatIterators(Iterator<Iterator<T>>) - Static method in class org.apache.beam.sdk.fn.stream.PrefetchableIterators
CONCRETE_CLASS - Static variable in class org.apache.beam.sdk.io.WriteFiles: For internal use by runners.
config() - Method in class org.apache.beam.sdk.extensions.sql.impl.CalciteConnectionWrapper
config() - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.hcatalog.HCatalogTable
Configuration() - Constructor for class org.apache.beam.io.debezium.DebeziumTransformRegistrar.ReadBuilder.Configuration
configuration - Variable in class org.apache.beam.runners.jobsubmission.JobServerDriver
Configuration() - Constructor for class org.apache.beam.sdk.extensions.schemaio.expansion.ExternalSchemaIOTransformRegistrar.Configuration
Configuration() - Constructor for class org.apache.beam.sdk.extensions.sql.expansion.ExternalSqlTransformRegistrar.Configuration
Configuration() - Constructor for class org.apache.beam.sdk.io.gcp.pubsub.ExternalRead.Configuration
Configuration() - Constructor for class org.apache.beam.sdk.io.gcp.pubsub.ExternalWrite.Configuration
Configuration() - Constructor for class org.apache.beam.sdk.io.gcp.spanner.SpannerTransformRegistrar.ReadBuilder.Configuration
Configuration() - Constructor for class org.apache.beam.sdk.io.kafka.KafkaIO.Read.External.Configuration
Configuration() - Constructor for class org.apache.beam.sdk.io.kafka.KafkaIO.Write.External.Configuration
Configuration() - Constructor for class org.apache.beam.sdk.io.kinesis.KinesisTransformRegistrar.ReadDataBuilder.Configuration
Configuration() - Constructor for class org.apache.beam.sdk.io.kinesis.KinesisTransformRegistrar.WriteBuilder.Configuration
Configuration() - Constructor for class org.apache.beam.sdk.io.snowflake.crosslanguage.ReadBuilder.Configuration
Configuration() - Constructor for class org.apache.beam.sdk.io.snowflake.crosslanguage.WriteBuilder.Configuration
ConfigurationLocator() - Constructor for class org.apache.beam.sdk.io.hdfs.HadoopFileSystemOptions.ConfigurationLocator
configurationSchema() - Method in class org.apache.beam.sdk.io.AvroSchemaIOProvider: Returns the expected schema of the configuration object.
configurationSchema() - Method in class org.apache.beam.sdk.io.gcp.bigquery.BigQuerySchemaIOProvider: Returns the expected schema of the configuration object.
configurationSchema() - Method in class org.apache.beam.sdk.io.gcp.datastore.DataStoreV1SchemaIOProvider: Returns the expected schema of the configuration object.
configurationSchema() - Method in class org.apache.beam.sdk.io.gcp.pubsub.PubsubSchemaIOProvider: Returns the expected schema of the configuration object.
configurationSchema() - Method in class org.apache.beam.sdk.io.jdbc.JdbcSchemaIOProvider: Returns the expected schema of the configuration object.
configurationSchema() - Method in interface org.apache.beam.sdk.schemas.io.SchemaIOProvider: Returns the expected schema of the configuration object.
configurationSchema() - Method in interface org.apache.beam.sdk.schemas.transforms.SchemaTransformProvider: Returns the expected schema of the configuration object.
configurationSchema() - Method in class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider
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.
ConfluentSchemaRegistryDeserializerProvider<T> - Class in org.apache.beam.sdk.io.kafka: A DeserializerProvider that uses Confluent Schema Registry to resolve a Deserializers and Coder given a subject.
connect(String, Properties) - Method in class org.apache.beam.sdk.extensions.sql.impl.JdbcDriver: Configures Beam-specific options and opens a JDBC connection to Calcite.
connect(TableProvider, PipelineOptions) - Static method in class org.apache.beam.sdk.extensions.sql.impl.JdbcDriver: Connects to the driver using standard JdbcDriver.connect(String, Properties) call, but overrides the initial schema factory.
connect() - Method in class org.apache.beam.sdk.io.redis.RedisConnectionConfiguration: Connect to the Redis instance.
CONNECT_STRING_PREFIX - Static variable in class org.apache.beam.sdk.extensions.sql.impl.JdbcDriver
connection() - Method in class org.apache.beam.sdk.extensions.sql.impl.CalciteConnectionWrapper
CONNECTION_MAX_IDLE_TIME - Static variable in class org.apache.beam.sdk.io.aws.options.AwsModule
CONNECTION_TIME_TO_LIVE - Static variable in class org.apache.beam.sdk.io.aws.options.AwsModule
CONNECTION_TIMEOUT - Static variable in class org.apache.beam.sdk.io.aws.options.AwsModule
connectionAcquisitionTimeout(Integer) - Method in class org.apache.beam.sdk.io.aws2.common.HttpClientConfiguration.Builder: Milliseconds to wait when acquiring a connection from the pool before giving up and timing out.
connectionAcquisitionTimeout() - Method in class org.apache.beam.sdk.io.aws2.common.HttpClientConfiguration: Milliseconds to wait when acquiring a connection from the pool before giving up and timing out.
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
ConnectionConfiguration() - Constructor for class org.apache.beam.sdk.io.solr.SolrIO.ConnectionConfiguration
ConnectionManager - Class in org.apache.beam.sdk.io.cassandra
ConnectionManager() - Constructor for class org.apache.beam.sdk.io.cassandra.ConnectionManager
connectionMaxIdleTime(Integer) - Method in class org.apache.beam.sdk.io.aws2.common.HttpClientConfiguration.Builder: Maximum milliseconds a connection should be allowed to remain open while idle.
connectionMaxIdleTime() - Method in class org.apache.beam.sdk.io.aws2.common.HttpClientConfiguration: Maximum milliseconds a connection should be allowed to remain open while idle.
connectionTimeout(Integer) - Method in class org.apache.beam.sdk.io.aws2.common.HttpClientConfiguration.Builder: Milliseconds to wait when initially establishing a connection before giving up and timing out.
connectionTimeout() - Method in class org.apache.beam.sdk.io.aws2.common.HttpClientConfiguration: Milliseconds to wait when initially establishing a connection before giving up and timing out.
connectionTimeToLive(Integer) - Method in class org.apache.beam.sdk.io.aws2.common.HttpClientConfiguration.Builder: Maximum milliseconds a connection should be allowed to remain open, regardless of usage frequency.
connectionTimeToLive() - Method in class org.apache.beam.sdk.io.aws2.common.HttpClientConfiguration: Maximum milliseconds a connection should be allowed to remain open, regardless of usage frequency.
ConnectorConfiguration() - Constructor for class org.apache.beam.io.debezium.DebeziumIO.ConnectorConfiguration
Connectors - Enum in org.apache.beam.io.debezium: Enumeration of debezium connectors.
consistentWithEquals() - Method in class org.apache.beam.runners.dataflow.util.RandomAccessData.RandomAccessDataCoder
consistentWithEquals() - Method in class org.apache.beam.runners.fnexecution.wire.ByteStringCoder: Returns true if this Coder is injective with respect to Object.equals(java.lang.Object).
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.BigEndianShortCoder: 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.BooleanCoder
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.DequeCoder
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.FloatCoder: 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.ListCoder
consistentWithEquals() - Method in class org.apache.beam.sdk.coders.MapCoder
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.SerializableCoder
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.TimestampPrefixingWindowCoder
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.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.fn.windowing.EncodedBoundedWindow.Coder
consistentWithEquals() - Method in class org.apache.beam.sdk.io.fs.MetadataCoder
consistentWithEquals() - Method in class org.apache.beam.sdk.io.fs.MetadataCoderV2
consistentWithEquals() - Method in class org.apache.beam.sdk.io.fs.ResourceIdCoder
consistentWithEquals() - Method in class org.apache.beam.sdk.io.kafka.KafkaRecordCoder
consistentWithEquals() - Method in class org.apache.beam.sdk.io.kafka.ProducerRecordCoder
consistentWithEquals() - Method in class org.apache.beam.sdk.io.range.OffsetRange.Coder
consistentWithEquals() - Method in class org.apache.beam.sdk.schemas.SchemaCoder
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 to console.
ConsoleIO.Write.Unbound<T> - Class in org.apache.beam.runners.spark.io: PTransform writing PCollection to the console.
constant(FileBasedSink.FilenamePolicy, SerializableFunction<UserT, OutputT>) - Static method in class org.apache.beam.sdk.io.DynamicFileDestinations: Returns a FileBasedSink.DynamicDestinations that always returns the same FileBasedSink.FilenamePolicy.
constant(FileBasedSink.FilenamePolicy) - Static method in class org.apache.beam.sdk.io.DynamicFileDestinations: A specialization of #constant(FilenamePolicy, SerializableFunction) for the case where UserT and OutputT are the same type and the format function is the identity.
constant(OutT) - Static method in class org.apache.beam.sdk.transforms.SerializableFunctions
CONSTANT_WINDOW_SIZE - Static variable in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamIOSourceRel
constantDestinations(FileBasedSink.FilenamePolicy, Schema, Map<String, Object>, CodecFactory, SerializableFunction<UserT, OutputT>) - Static method in class org.apache.beam.sdk.io.AvroIO: Returns a DynamicAvroDestinations that always returns the same FileBasedSink.FilenamePolicy, schema, metadata, and codec.
constantDestinations(FileBasedSink.FilenamePolicy, Schema, Map<String, Object>, CodecFactory, SerializableFunction<UserT, OutputT>, AvroSink.DatumWriterFactory<OutputT>) - Static method in class org.apache.beam.sdk.io.AvroIO: Returns a DynamicAvroDestinations that always returns the same FileBasedSink.FilenamePolicy, schema, metadata, and codec.
Constants - Class in org.apache.beam.runners.spark.structuredstreaming
Constants() - Constructor for class org.apache.beam.runners.spark.structuredstreaming.Constants
constructFilter(List<RexNode>) - Method in class org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable
constructFilter(List<RexNode>) - Method in interface org.apache.beam.sdk.extensions.sql.meta.BeamSqlTable: Generate an IO implementation of BeamSqlTableFilter for predicate push-down.
constructFilter(List<RexNode>) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.bigtable.BigtableTable
constructFilter(List<RexNode>) - Method in class org.apache.beam.sdk.extensions.sql.meta.provider.mongodb.MongoDbTable
consumesProjection() - Method in interface org.apache.beam.sdk.schemas.ProjectionConsumer: Returns a map from input TupleTag id to a FieldAccessDescriptor describing which Schema fields this must access from the corresponding input PCollection to complete successfully.
contains(PCollectionView<T>) - Method in class org.apache.beam.runners.spark.structuredstreaming.translation.batch.functions.SparkSideInputReader
contains(PCollectionView<T>) - Method in class org.apache.beam.runners.spark.structuredstreaming.translation.utils.CachedSideInputReader
contains(PCollectionView<T>) - Method in class org.apache.beam.runners.spark.util.CachedSideInputReader
contains(PCollectionView<T>) - Method in class org.apache.beam.runners.spark.util.SparkSideInputReader
contains(PCollectionView<T>) - Method in class org.apache.beam.runners.twister2.utils.Twister2SideInputReader
contains(Descriptors.Descriptor) - Method in class org.apache.beam.sdk.extensions.protobuf.ProtoDomain
contains(T) - Method in interface org.apache.beam.sdk.state.SetState: Returns a ReadableState whose ReadableState.read() method will return true if this set contains the specified element at the point when that ReadableState.read() call returns.
contains(T...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers: A SerializableMatcher with identical criteria to Matchers.contains(Object[]).
contains(Coder<T>, T...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers: A SerializableMatcher with identical criteria to Matchers.contains(Object[]).
contains(SerializableMatcher<? super T>...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers: A SerializableMatcher with identical criteria to Matchers.contains(Matcher[]).
contains(List<SerializableMatcher<? super T>>) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers: A SerializableMatcher with identical criteria to Matchers.contains(List).
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(SerializableMatcher<? super T>...) - Method in interface org.apache.beam.sdk.testing.PAssert.IterableAssert: Asserts that the iterable in question matches the provided elements.
containsInAnyOrder() - Method in interface org.apache.beam.sdk.testing.PAssert.IterableAssert: Deprecated.
Prefer PAssert.IterableAssert.empty() to this method.
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.
containsInAnyOrder(SerializableMatcher<? super T>...) - Method in class org.apache.beam.sdk.testing.PAssert.PCollectionContentsAssert: Checks that the Iterable contains elements that match the provided matchers, in any order.
containsInAnyOrder() - Method in class org.apache.beam.sdk.testing.PAssert.PCollectionContentsAssert
containsInAnyOrder(T...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers: A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Object[]).
containsInAnyOrder(Coder<T>, T...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers: A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Object[]).
containsInAnyOrder(SerializableMatcher<? super T>...) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers: A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Matcher[]).
containsInAnyOrder(Collection<SerializableMatcher<? super T>>) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers: A SerializableMatcher with identical criteria to Matchers.containsInAnyOrder(Collection).
containsKey(ByteKey) - Method in class org.apache.beam.sdk.io.range.ByteKeyRange: Returns true if the specified ByteKey is contained within this range.
containsKey(Object) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.TransformingMap
containsSeekableInput(RelNode) - Static method in class org.apache.beam.sdk.extensions.sql.impl.rel.BeamJoinRel: This method returns whether any of the children of the relNode are Seekable.
containsString(String) - Static method in class org.apache.beam.sdk.testing.SerializableMatchers: A SerializableMatcher with identical criteria to Matchers.containsString(java.lang.String).
containsValue(Object) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.TransformingMap
Context(boolean) - Constructor for class org.apache.beam.sdk.coders.Coder.Context: Deprecated.
Context(TableDataInsertAllResponse.InsertErrors) - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.InsertRetryPolicy.Context
Context() - Constructor for class org.apache.beam.sdk.schemas.utils.SchemaZipFold.Context
Context() - Constructor for class org.apache.beam.sdk.transforms.CombineWithContext.Context
Context() - Constructor for class org.apache.beam.sdk.transforms.Contextful.Fn.Context
Contextful<ClosureT> - Class in org.apache.beam.sdk.transforms: Pair of a bit of user code (a "closure") and the Requirements needed to run it.
Contextful.Fn<InputT,OutputT> - Interface in org.apache.beam.sdk.transforms: A function from an input to an output that may additionally access Contextful.Fn.Context when computing the result.
Contextful.Fn.Context - Class in org.apache.beam.sdk.transforms: An accessor for additional capabilities available in Contextful.Fn.apply(InputT, org.apache.beam.sdk.transforms.Contextful.Fn.Context).
ContextualTextIO - Class in org.apache.beam.sdk.io.contextualtextio: PTransforms that read text files and collect contextual information of the elements in the input.
ContextualTextIO.Read - Class in org.apache.beam.sdk.io.contextualtextio: Implementation of ContextualTextIO.read().
ContextualTextIO.ReadFiles - Class in org.apache.beam.sdk.io.contextualtextio: Implementation of ContextualTextIO.readFiles().
continuously(Duration, Watch.Growth.TerminationCondition<String, ?>) - Method in class org.apache.beam.sdk.io.FileIO.Match: See FileIO.MatchConfiguration.continuously(org.joda.time.Duration, org.apache.beam.sdk.transforms.Watch.Growth.TerminationCondition<java.lang.String, ?>).
continuously(Duration, Watch.Growth.TerminationCondition<String, ?>) - Method in class org.apache.beam.sdk.io.FileIO.MatchAll: Like FileIO.Match.continuously(org.joda.time.Duration, org.apache.beam.sdk.transforms.Watch.Growth.TerminationCondition<java.lang.String, ?>).
continuously(Duration, Watch.Growth.TerminationCondition<String, ?>) - Method in class org.apache.beam.sdk.io.FileIO.MatchConfiguration: Continuously watches for new files at the given interval until the given termination condition is reached, where the input to the condition is the filepattern.
control(StreamObserver<BeamFnApi.InstructionRequest>) - Method in class org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService: Called by gRPC for each incoming connection from an SDK harness, and enqueue an available SDK harness client.
ControlClientPool - Interface in org.apache.beam.runners.fnexecution.control: A pool of control clients that brokers incoming SDK harness connections (in the form of InstructionRequestHandlers.
ControlClientPool.Sink - Interface in org.apache.beam.runners.fnexecution.control: A sink for InstructionRequestHandlers keyed by worker id.
ControlClientPool.Source - Interface in org.apache.beam.runners.fnexecution.control: A source of InstructionRequestHandlers.
ConversionContext - Class in org.apache.beam.sdk.extensions.sql.zetasql.translation: Conversion context, some rules need this data to convert the nodes.
ConversionOptions() - Constructor for class org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.ConversionOptions
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamCalcRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamEnumerableConverterRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamIntersectRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamIOSinkRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamMatchRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamMinusRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamSideInputLookupJoinRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamSortRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamTableFunctionScanRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamUncollectRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamUnionRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamValuesRule
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.impl.rule.BeamWindowRule
convert() - Static method in class org.apache.beam.sdk.extensions.sql.meta.provider.mongodb.MongoDbTable.RowToDocument
convert(ResolvedNodes.ResolvedQueryStmt, List<RelNode>) - Method in class org.apache.beam.sdk.extensions.sql.zetasql.translation.QueryStatementConverter
convert(RelNode) - Method in class org.apache.beam.sdk.extensions.sql.zetasql.unnest.BeamZetaSqlUncollectRule
Convert - Class in org.apache.beam.sdk.schemas.transforms: A set of utilities for converting between different objects supporting schemas.
Convert() - Constructor for class org.apache.beam.sdk.schemas.transforms.Convert
convert(TypeDescriptor) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.TypeConversion
convertArray(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertType
convertArray(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertValueForGetter
convertArray(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertValueForSetter
convertArray(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.TypeConversion
convertAvroFieldStrict(Object, Schema, Schema.FieldType) - Static method in class org.apache.beam.sdk.schemas.utils.AvroUtils: Strict conversion from AVRO to Beam, strict because it doesn't do widening or narrowing during conversion.
convertAvroFormat(Schema.FieldType, Object, BigQueryUtils.ConversionOptions) - Static method in class org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils: Tries to convert an Avro decoded value to a Beam field value based on the target type of the Beam field.
convertByteBuffer(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertType
convertByteBuffer(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertValueForGetter
convertByteBuffer(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertValueForSetter
convertByteBuffer(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.TypeConversion
convertCharSequence(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertType
convertCharSequence(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertValueForGetter
convertCharSequence(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertValueForSetter
convertCharSequence(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.TypeConversion
convertCollection(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertType
convertCollection(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertValueForGetter
convertCollection(TypeDescriptor<?>) - Method in class org.apache.beam.sdk.schemas.utils.ByteBuddyUtils.ConvertValueForSetter