Path	Lines of Code
sdks/go/cmd/beamctl/cmd/artifact.go	68
sdks/go/cmd/beamctl/cmd/provision.go	35
sdks/go/cmd/beamctl/cmd/root.go	30
sdks/go/cmd/beamctl/main.go	12
sdks/go/cmd/specialize/main.go	168
sdks/go/cmd/starcgen/starcgen.go	129
sdks/go/cmd/symtab/main.go	62
sdks/go/container/boot.go	116
sdks/go/pkg/beam/artifact/gcsproxy/retrieval.go	115
sdks/go/pkg/beam/artifact/gcsproxy/staging.go	136
sdks/go/pkg/beam/artifact/materialize.go	402
sdks/go/pkg/beam/artifact/stage.go	196
sdks/go/pkg/beam/beam.shims.go	272
sdks/go/pkg/beam/coder.go	295
sdks/go/pkg/beam/combine.go	54
sdks/go/pkg/beam/core/core.go	5
sdks/go/pkg/beam/core/funcx/doc.go	1
sdks/go/pkg/beam/core/funcx/fn.go	403
sdks/go/pkg/beam/core/funcx/output.go	43
sdks/go/pkg/beam/core/funcx/sideinput.go	56
sdks/go/pkg/beam/core/funcx/signature.go	162
sdks/go/pkg/beam/core/graph/bind.go	235
sdks/go/pkg/beam/core/graph/coder/bool.go	34
sdks/go/pkg/beam/core/graph/coder/bytes.go	38
sdks/go/pkg/beam/core/graph/coder/coder.go	303
sdks/go/pkg/beam/core/graph/coder/double.go	20
sdks/go/pkg/beam/core/graph/coder/int.go	42
sdks/go/pkg/beam/core/graph/coder/iterable.go	113
sdks/go/pkg/beam/core/graph/coder/map.go	86
sdks/go/pkg/beam/core/graph/coder/registry.go	54
sdks/go/pkg/beam/core/graph/coder/row.go	151
sdks/go/pkg/beam/core/graph/coder/row_decoder.go	276
sdks/go/pkg/beam/core/graph/coder/row_encoder.go	237
sdks/go/pkg/beam/core/graph/coder/stringutf8.go	56
sdks/go/pkg/beam/core/graph/coder/testutil/testutil.go	96
sdks/go/pkg/beam/core/graph/coder/time.go	19
sdks/go/pkg/beam/core/graph/coder/varint.go	53
sdks/go/pkg/beam/core/graph/coder/windows.go	22
sdks/go/pkg/beam/core/graph/doc.go	1
sdks/go/pkg/beam/core/graph/edge.go	350
sdks/go/pkg/beam/core/graph/fn.go	796
sdks/go/pkg/beam/core/graph/graph.go	88
sdks/go/pkg/beam/core/graph/mtime/time.go	64
sdks/go/pkg/beam/core/graph/node.go	50
sdks/go/pkg/beam/core/graph/scope.go	15
sdks/go/pkg/beam/core/graph/window/fn.go	68
sdks/go/pkg/beam/core/graph/window/strategy.go	13
sdks/go/pkg/beam/core/graph/window/windows.go	44
sdks/go/pkg/beam/core/graph/xlang.go	71
sdks/go/pkg/beam/core/metrics/dumper.go	79
sdks/go/pkg/beam/core/metrics/metrics.go	409
sdks/go/pkg/beam/core/metrics/store.go	84
sdks/go/pkg/beam/core/runtime/coderx/coderx.shims.go	257
sdks/go/pkg/beam/core/runtime/coderx/doc.go	1
sdks/go/pkg/beam/core/runtime/coderx/float.go	46
sdks/go/pkg/beam/core/runtime/coderx/int.go	59
sdks/go/pkg/beam/core/runtime/coderx/string.go	15
sdks/go/pkg/beam/core/runtime/coderx/varint.go	105
sdks/go/pkg/beam/core/runtime/exec/coder.go	840
sdks/go/pkg/beam/core/runtime/exec/cogbk.go	117
sdks/go/pkg/beam/core/runtime/exec/combine.go	378
sdks/go/pkg/beam/core/runtime/exec/data.go	28
sdks/go/pkg/beam/core/runtime/exec/datasink.go	64
sdks/go/pkg/beam/core/runtime/exec/datasource.go	415
sdks/go/pkg/beam/core/runtime/exec/decode.go	60
sdks/go/pkg/beam/core/runtime/exec/discard.go	26
sdks/go/pkg/beam/core/runtime/exec/emit.go	78
sdks/go/pkg/beam/core/runtime/exec/encode.go	60
sdks/go/pkg/beam/core/runtime/exec/flatten.go	43
sdks/go/pkg/beam/core/runtime/exec/fn.go	256
sdks/go/pkg/beam/core/runtime/exec/fn_arity.go	190
sdks/go/pkg/beam/core/runtime/exec/fullvalue.go	114
sdks/go/pkg/beam/core/runtime/exec/hash.go	134
sdks/go/pkg/beam/core/runtime/exec/input.go	136
sdks/go/pkg/beam/core/runtime/exec/multiplex.go	35
sdks/go/pkg/beam/core/runtime/exec/optimized/callers.go	470
sdks/go/pkg/beam/core/runtime/exec/optimized/decoders.go	1856
sdks/go/pkg/beam/core/runtime/exec/optimized/encoders.go	1772
sdks/go/pkg/beam/core/runtime/exec/optimized/gen.go	1
sdks/go/pkg/beam/core/runtime/exec/pardo.go	244
sdks/go/pkg/beam/core/runtime/exec/plan.go	157
sdks/go/pkg/beam/core/runtime/exec/reshuffle.go	117
sdks/go/pkg/beam/core/runtime/exec/sdf.go	393
sdks/go/pkg/beam/core/runtime/exec/sdf_invokers.go	218
sdks/go/pkg/beam/core/runtime/exec/sideinput.go	98
sdks/go/pkg/beam/core/runtime/exec/status.go	26
sdks/go/pkg/beam/core/runtime/exec/translate.go	494
sdks/go/pkg/beam/core/runtime/exec/unit.go	23
sdks/go/pkg/beam/core/runtime/exec/util.go	44
sdks/go/pkg/beam/core/runtime/exec/window.go	61
sdks/go/pkg/beam/core/runtime/genx/genx.go	121
sdks/go/pkg/beam/core/runtime/graphx/coder.go	459
sdks/go/pkg/beam/core/runtime/graphx/cogbk.go	49
sdks/go/pkg/beam/core/runtime/graphx/dataflow.go	278
sdks/go/pkg/beam/core/runtime/graphx/doc.go	1
sdks/go/pkg/beam/core/runtime/graphx/schema/logicaltypes.go	95
sdks/go/pkg/beam/core/runtime/graphx/schema/schema.go	610
sdks/go/pkg/beam/core/runtime/graphx/serialize.go	700
sdks/go/pkg/beam/core/runtime/graphx/translate.go	856
sdks/go/pkg/beam/core/runtime/graphx/tree.go	51
sdks/go/pkg/beam/core/runtime/graphx/user.go	69
sdks/go/pkg/beam/core/runtime/graphx/v1/gen.go	1
sdks/go/pkg/beam/core/runtime/graphx/v1/v1.pb.go	1503
sdks/go/pkg/beam/core/runtime/graphx/v1/v1.proto	213
sdks/go/pkg/beam/core/runtime/graphx/xlang.go	202
sdks/go/pkg/beam/core/runtime/harness/datamgr.go	399
sdks/go/pkg/beam/core/runtime/harness/gen.go	1
sdks/go/pkg/beam/core/runtime/harness/harness.go	368
sdks/go/pkg/beam/core/runtime/harness/init/init.go	76
sdks/go/pkg/beam/core/runtime/harness/logging.go	111
sdks/go/pkg/beam/core/runtime/harness/monitoring.go	154
sdks/go/pkg/beam/core/runtime/harness/session.go	163
sdks/go/pkg/beam/core/runtime/harness/session.proto	59
sdks/go/pkg/beam/core/runtime/harness/session/session.pb.go	374
sdks/go/pkg/beam/core/runtime/harness/statemgr.go	331
sdks/go/pkg/beam/core/runtime/init.go	20
sdks/go/pkg/beam/core/runtime/metricsx/metricsx.go	104
sdks/go/pkg/beam/core/runtime/metricsx/urns.go	120
sdks/go/pkg/beam/core/runtime/options.go	55
sdks/go/pkg/beam/core/runtime/pipelinex/clone.go	67
sdks/go/pkg/beam/core/runtime/pipelinex/replace.go	206
sdks/go/pkg/beam/core/runtime/pipelinex/util.go	74
sdks/go/pkg/beam/core/runtime/symbols.go	65
sdks/go/pkg/beam/core/runtime/types.go	32
sdks/go/pkg/beam/core/runtime/xlangx/expand.go	73
sdks/go/pkg/beam/core/runtime/xlangx/namespace.go	77
sdks/go/pkg/beam/core/runtime/xlangx/payload.go	38
sdks/go/pkg/beam/core/runtime/xlangx/resolve.go	55
sdks/go/pkg/beam/core/sdf/lock.go	39
sdks/go/pkg/beam/core/sdf/sdf.go	9
sdks/go/pkg/beam/core/typex/class.go	131
sdks/go/pkg/beam/core/typex/fulltype.go	304
sdks/go/pkg/beam/core/typex/special.go	34
sdks/go/pkg/beam/core/util/dot/dot.go	109
sdks/go/pkg/beam/core/util/hooks/hooks.go	108
sdks/go/pkg/beam/core/util/ioutilx/read.go	49
sdks/go/pkg/beam/core/util/ioutilx/write.go	9
sdks/go/pkg/beam/core/util/jsonx/jsonx.go	24
sdks/go/pkg/beam/core/util/protox/any.go	66
sdks/go/pkg/beam/core/util/protox/base64.go	27
sdks/go/pkg/beam/core/util/protox/protox.go	9
sdks/go/pkg/beam/core/util/reflectx/call.go	65
sdks/go/pkg/beam/core/util/reflectx/calls.go	1058
sdks/go/pkg/beam/core/util/reflectx/functions.go	21
sdks/go/pkg/beam/core/util/reflectx/structs.go	38
sdks/go/pkg/beam/core/util/reflectx/tags.go	43
sdks/go/pkg/beam/core/util/reflectx/types.go	76
sdks/go/pkg/beam/core/util/reflectx/util.go	60
sdks/go/pkg/beam/core/util/stringx/bytes.go	7
sdks/go/pkg/beam/core/util/stringx/map.go	27
sdks/go/pkg/beam/core/util/symtab/symtab.go	126
sdks/go/pkg/beam/create.go	78
sdks/go/pkg/beam/doc.go	1
sdks/go/pkg/beam/encoding.go	245
sdks/go/pkg/beam/external.go	62
sdks/go/pkg/beam/flatten.go	35
sdks/go/pkg/beam/forward.go	66
sdks/go/pkg/beam/gbk.go	63
sdks/go/pkg/beam/impulse.go	16
sdks/go/pkg/beam/internal/errors/errors.go	120
sdks/go/pkg/beam/io/avroio/avroio.go	146
sdks/go/pkg/beam/io/bigqueryio/bigquery.go	218
sdks/go/pkg/beam/io/databaseio/database.go	168
sdks/go/pkg/beam/io/databaseio/loader.go	7
sdks/go/pkg/beam/io/databaseio/mapper.go	104
sdks/go/pkg/beam/io/databaseio/util.go	51
sdks/go/pkg/beam/io/databaseio/writer.go	76
sdks/go/pkg/beam/io/datastoreio/datastore.go	173
sdks/go/pkg/beam/io/filesystem/filesystem.go	45
sdks/go/pkg/beam/io/filesystem/gcs/gcs.go	96
sdks/go/pkg/beam/io/filesystem/local/local.go	41
sdks/go/pkg/beam/io/filesystem/memfs/memory.go	79
sdks/go/pkg/beam/io/filesystem/util.go	23
sdks/go/pkg/beam/io/pubsubio/pubsubio.go	62
sdks/go/pkg/beam/io/pubsubio/v1/gen.go	2
sdks/go/pkg/beam/io/pubsubio/v1/v1.pb.go	98
sdks/go/pkg/beam/io/pubsubio/v1/v1.proto	35
sdks/go/pkg/beam/io/rtrackers/offsetrange/offsetrange.go	135
sdks/go/pkg/beam/io/synthetic/rand.go	5
sdks/go/pkg/beam/io/synthetic/source.go	145
sdks/go/pkg/beam/io/synthetic/step.go	110
sdks/go/pkg/beam/io/textio/sdf.go	125
sdks/go/pkg/beam/io/textio/textio.go	129
sdks/go/pkg/beam/log/log.go	93
sdks/go/pkg/beam/log/standard.go	14
sdks/go/pkg/beam/metrics.go	35
sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api.pb.go	5022
sdks/go/pkg/beam/model/fnexecution_v1/beam_provision_api.pb.go	430
sdks/go/pkg/beam/model/gen.go	1
sdks/go/pkg/beam/model/jobmanagement_v1/beam_artifact_api.pb.go	1911
sdks/go/pkg/beam/model/jobmanagement_v1/beam_expansion_api.pb.go	321
sdks/go/pkg/beam/model/jobmanagement_v1/beam_job_api.pb.go	2323
sdks/go/pkg/beam/model/pipeline_v1/endpoints.pb.go	201
sdks/go/pkg/beam/model/pipeline_v1/external_transforms.pb.go	143
sdks/go/pkg/beam/model/pipeline_v1/metrics.pb.go	1119
sdks/go/pkg/beam/model/pipeline_v1/schema.pb.go	1614
sdks/go/pkg/beam/model/pipeline_v1/standard_window_fns.pb.go	483
sdks/go/pkg/beam/option.go	32
sdks/go/pkg/beam/options/gcpopts/options.go	35
sdks/go/pkg/beam/options/jobopts/options.go	98
sdks/go/pkg/beam/options/jobopts/stringSlice.go	15
sdks/go/pkg/beam/pardo.go	125
sdks/go/pkg/beam/partition.go	118
sdks/go/pkg/beam/pcollection.go	40
sdks/go/pkg/beam/pipeline.go	44
sdks/go/pkg/beam/provision/provision.go	54
sdks/go/pkg/beam/runner.go	22
sdks/go/pkg/beam/runners/dataflow/dataflow.go	184
sdks/go/pkg/beam/runners/dataflow/dataflowlib/execute.go	109
sdks/go/pkg/beam/runners/dataflow/dataflowlib/fixup.go	7
sdks/go/pkg/beam/runners/dataflow/dataflowlib/job.go	263
sdks/go/pkg/beam/runners/dataflow/dataflowlib/messages.go	132
sdks/go/pkg/beam/runners/dataflow/dataflowlib/metrics.go	85
sdks/go/pkg/beam/runners/dataflow/dataflowlib/stage.go	33
sdks/go/pkg/beam/runners/dataflow/dataflowlib/translate.go	290
sdks/go/pkg/beam/runners/direct/buffer.go	117
sdks/go/pkg/beam/runners/direct/direct.go	226
sdks/go/pkg/beam/runners/direct/gbk.go	104
sdks/go/pkg/beam/runners/direct/impulse.go	39
sdks/go/pkg/beam/runners/dot/dot.go	28
sdks/go/pkg/beam/runners/flink/flink.go	13
sdks/go/pkg/beam/runners/session/session.go	238
sdks/go/pkg/beam/runners/spark/spark.go	13
sdks/go/pkg/beam/runners/universal/extworker/extworker.go	83
sdks/go/pkg/beam/runners/universal/runnerlib/compile.go	58
sdks/go/pkg/beam/runners/universal/runnerlib/execute.go	85
sdks/go/pkg/beam/runners/universal/runnerlib/job.go	103
sdks/go/pkg/beam/runners/universal/runnerlib/stage.go	123
sdks/go/pkg/beam/runners/universal/universal.go	70
sdks/go/pkg/beam/runners/vet/testpipeline/functions.go	16
sdks/go/pkg/beam/runners/vet/testpipeline/testpipeline.go	44
sdks/go/pkg/beam/runners/vet/testpipeline/testpipeline.shims.go	135
sdks/go/pkg/beam/runners/vet/vet.go	444
sdks/go/pkg/beam/schema.go	17
sdks/go/pkg/beam/testing/passert/count.go	39
sdks/go/pkg/beam/testing/passert/equals.go	67
sdks/go/pkg/beam/testing/passert/hash.go	39
sdks/go/pkg/beam/testing/passert/passert.go	116
sdks/go/pkg/beam/testing/passert/passert.shims.go	455
sdks/go/pkg/beam/testing/passert/sum.go	28
sdks/go/pkg/beam/testing/ptest/ptest.go	62
sdks/go/pkg/beam/transforms/filter/distinct.go	16
sdks/go/pkg/beam/transforms/filter/filter.go	33
sdks/go/pkg/beam/transforms/filter/filter.shims.go	135
sdks/go/pkg/beam/transforms/stats/count.go	25
sdks/go/pkg/beam/transforms/stats/max.go	12
sdks/go/pkg/beam/transforms/stats/max_switch.go	107
sdks/go/pkg/beam/transforms/stats/mean.go	40
sdks/go/pkg/beam/transforms/stats/min.go	12
sdks/go/pkg/beam/transforms/stats/min_switch.go	107
sdks/go/pkg/beam/transforms/stats/quantiles.go	549
sdks/go/pkg/beam/transforms/stats/stats.shims.go	437
sdks/go/pkg/beam/transforms/stats/sum.go	12
sdks/go/pkg/beam/transforms/stats/sum_switch.go	71
sdks/go/pkg/beam/transforms/stats/util.go	22
sdks/go/pkg/beam/transforms/stats/util_gen.go	1
sdks/go/pkg/beam/transforms/top/top.go	190
sdks/go/pkg/beam/transforms/top/top.shims.go	127
sdks/go/pkg/beam/util.go	63
sdks/go/pkg/beam/util/errorx/guarded.go	20
sdks/go/pkg/beam/util/execx/exec.go	12
sdks/go/pkg/beam/util/gcsx/gcs.go	87
sdks/go/pkg/beam/util/grpcx/dial.go	19
sdks/go/pkg/beam/util/grpcx/hook.go	48
sdks/go/pkg/beam/util/grpcx/metadata.go	30
sdks/go/pkg/beam/util/pubsubx/pubsub.go	74
sdks/go/pkg/beam/util/shimx/generate.go	356
sdks/go/pkg/beam/util/starcgenx/starcgenx.go	585
sdks/go/pkg/beam/util/syscallx/syscall.go	5
sdks/go/pkg/beam/util/syscallx/syscall_default.go	7
sdks/go/pkg/beam/util/syscallx/syscall_linux.go	16
sdks/go/pkg/beam/validate.go	53
sdks/go/pkg/beam/windowing.go	20
sdks/go/pkg/beam/x/beamx/run.go	23
sdks/go/pkg/beam/x/debug/debug.shims.go	303
sdks/go/pkg/beam/x/debug/doc.go	1
sdks/go/pkg/beam/x/debug/head.go	37
sdks/go/pkg/beam/x/debug/print.go	54
sdks/go/pkg/beam/x/hooks/perf/perf.go	174
sdks/go/pkg/beam/xlang.go	88
sdks/java/build-tools/src/main/java/org/apache/beam/buildtools/NonnullByDefault.java	21
sdks/java/build-tools/src/main/java/org/apache/beam/buildtools/package-info.java	1
sdks/java/build-tools/src/main/resources/beam/beam-codestyle.xml	313
sdks/java/build-tools/src/main/resources/beam/spotbugs-filter.xml	27
sdks/java/build-tools/src/main/resources/beam/suppressions.xml	82
sdks/java/container/boot.go	129
sdks/java/container/license_scripts/dep_urls_java.yaml	27
sdks/java/container/license_scripts/pull_licenses_java.py	254
sdks/java/core/src/main/java/org/apache/beam/sdk/Pipeline.java	433
sdks/java/core/src/main/java/org/apache/beam/sdk/PipelineResult.java	36
sdks/java/core/src/main/java/org/apache/beam/sdk/PipelineRunner.java	36
sdks/java/core/src/main/java/org/apache/beam/sdk/annotations/Experimental.java	38
sdks/java/core/src/main/java/org/apache/beam/sdk/annotations/Internal.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/annotations/package-info.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/AtomicCoder.java	26
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/AvroCoder.java	468
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/AvroGenericCoder.java	11
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigDecimalCoder.java	58
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianIntegerCoder.java	53
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianLongCoder.java	53
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigEndianShortCoder.java	53
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BigIntegerCoder.java	50
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BitSetCoder.java	42
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/BooleanCoder.java	37
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ByteArrayCoder.java	86
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ByteCoder.java	55
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CannotProvideCoderException.java	43
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java	147
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderException.java	13
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderProvider.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderProviderRegistrar.java	9
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderProviders.java	139
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CoderRegistry.java	456
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CollectionCoder.java	22
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/CustomCoder.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/DefaultCoder.java	79
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/DelegateCoder.java	117
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/DequeCoder.java	44
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/DoubleCoder.java	56
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/DurationCoder.java	57
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/FloatCoder.java	56
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/InstantCoder.java	57
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/IterableCoder.java	30
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/IterableLikeCoder.java	160
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/KvCoder.java	95
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/LengthPrefixCoder.java	59
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ListCoder.java	42
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/MapCoder.java	131
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/NullableCoder.java	110
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoder.java	43
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/RowCoderGenerator.java	316
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/SerializableCoder.java	133
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/SetCoder.java	28
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/ShardedKeyCoder.java	37
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/SnappyCoder.java	35
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StringDelegateCoder.java	73
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StringUtf8Coder.java	90
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StructuralByteArray.java	30
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/StructuredCoder.java	42
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/TextualIntegerCoder.java	54
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VarIntCoder.java	52
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VarLongCoder.java	58
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/VoidCoder.java	39
sdks/java/core/src/main/java/org/apache/beam/sdk/coders/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/expansion/ExternalTransformRegistrar.java	43
sdks/java/core/src/main/java/org/apache/beam/sdk/expansion/package-info.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/function/CloseableThrowingConsumer.java	3
sdks/java/core/src/main/java/org/apache/beam/sdk/function/ThrowingBiConsumer.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/function/ThrowingBiFunction.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/function/ThrowingConsumer.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/function/ThrowingFunction.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/function/ThrowingRunnable.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/function/package-info.java	1
sdks/java/core/src/main/java/org/apache/beam/sdk/harness/JvmInitializer.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/harness/package-info.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java	1030
sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSchemaIOProvider.java	85
sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSink.java	109
sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroSource.java	583
sdks/java/core/src/main/java/org/apache/beam/sdk/io/BlockBasedSource.java	110
sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedReadFromUnboundedSource.java	191
sdks/java/core/src/main/java/org/apache/beam/sdk/io/BoundedSource.java	40
sdks/java/core/src/main/java/org/apache/beam/sdk/io/ClassLoaderFileSystem.java	121
sdks/java/core/src/main/java/org/apache/beam/sdk/io/CompressedSource.java	286
sdks/java/core/src/main/java/org/apache/beam/sdk/io/Compression.java	226
sdks/java/core/src/main/java/org/apache/beam/sdk/io/ConstantAvroDestination.java	114
sdks/java/core/src/main/java/org/apache/beam/sdk/io/CountingSource.java	311
sdks/java/core/src/main/java/org/apache/beam/sdk/io/DefaultFilenamePolicy.java	267
sdks/java/core/src/main/java/org/apache/beam/sdk/io/DynamicAvroDestinations.java	21
sdks/java/core/src/main/java/org/apache/beam/sdk/io/DynamicFileDestinations.java	99
sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSink.java	742
sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileBasedSource.java	392
sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileIO.java	870
sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystem.java	26
sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystemRegistrar.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystemUtils.java	55
sdks/java/core/src/main/java/org/apache/beam/sdk/io/FileSystems.java	358
sdks/java/core/src/main/java/org/apache/beam/sdk/io/GenerateSequence.java	173
sdks/java/core/src/main/java/org/apache/beam/sdk/io/LocalFileSystem.java	231
sdks/java/core/src/main/java/org/apache/beam/sdk/io/LocalFileSystemRegistrar.java	15
sdks/java/core/src/main/java/org/apache/beam/sdk/io/LocalResourceId.java	109
sdks/java/core/src/main/java/org/apache/beam/sdk/io/LocalResources.java	26
sdks/java/core/src/main/java/org/apache/beam/sdk/io/OffsetBasedSource.java	177
sdks/java/core/src/main/java/org/apache/beam/sdk/io/Read.java	742
sdks/java/core/src/main/java/org/apache/beam/sdk/io/ReadAllViaFileBasedSource.java	84
sdks/java/core/src/main/java/org/apache/beam/sdk/io/ReadableFileCoder.java	26
sdks/java/core/src/main/java/org/apache/beam/sdk/io/SerializableAvroCodecFactory.java	75
sdks/java/core/src/main/java/org/apache/beam/sdk/io/ShardNameTemplate.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/io/ShardingFunction.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/io/Source.java	41
sdks/java/core/src/main/java/org/apache/beam/sdk/io/TFRecordIO.java	476
sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextIO.java	689
sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextRowCountEstimator.java	140
sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextSink.java	97
sdks/java/core/src/main/java/org/apache/beam/sdk/io/TextSource.java	184
sdks/java/core/src/main/java/org/apache/beam/sdk/io/UnboundedSource.java	57
sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFiles.java	780
sdks/java/core/src/main/java/org/apache/beam/sdk/io/WriteFilesResult.java	45
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/CreateOptions.java	19
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/EmptyMatchTreatment.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/MatchResult.java	71
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/MetadataCoder.java	42
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/MetadataCoderV2.java	36
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/MoveOptions.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResolveOptions.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceId.java	19
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceIdCoder.java	31
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/ResourceIdTester.java	122
sdks/java/core/src/main/java/org/apache/beam/sdk/io/fs/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/io/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKey.java	83
sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKeyRange.java	197
sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/ByteKeyRangeTracker.java	131
sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRange.java	110
sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/OffsetRangeTracker.java	172
sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/RangeTracker.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/io/range/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Counter.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/DelegatingCounter.java	41
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/DelegatingDistribution.java	39
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/DelegatingHistogram.java	30
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Distribution.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/DistributionResult.java	20
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Gauge.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/GaugeResult.java	30
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Histogram.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metric.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricFiltering.java	58
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricKey.java	19
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricName.java	27
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricNameFilter.java	27
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricQueryResults.java	50
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricResult.java	59
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricResults.java	15
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Metrics.java	67
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsContainer.java	14
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsEnvironment.java	79
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsFilter.java	35
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsOptions.java	47
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/MetricsSink.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/SinkMetrics.java	19
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/SourceMetrics.java	47
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/package-info.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/options/ApplicationNameOptions.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/options/Default.java	91
sdks/java/core/src/main/java/org/apache/beam/sdk/options/DefaultPipelineOptionsRegistrar.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/options/DefaultValueFactory.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/options/Description.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/options/ExperimentalOptions.java	54
sdks/java/core/src/main/java/org/apache/beam/sdk/options/FileStagingOptions.java	11
sdks/java/core/src/main/java/org/apache/beam/sdk/options/Hidden.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/options/ManualDockerEnvironmentOptions.java	20
sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptionSpec.java	16
sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptions.java	128
sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptionsFactory.java	1322
sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptionsReflector.java	57
sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptionsRegistrar.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/options/PipelineOptionsValidator.java	87
sdks/java/core/src/main/java/org/apache/beam/sdk/options/PortablePipelineOptions.java	76
sdks/java/core/src/main/java/org/apache/beam/sdk/options/ProxyInvocationHandler.java	528
sdks/java/core/src/main/java/org/apache/beam/sdk/options/RemoteEnvironmentOptions.java	19
sdks/java/core/src/main/java/org/apache/beam/sdk/options/SdkHarnessOptions.java	77
sdks/java/core/src/main/java/org/apache/beam/sdk/options/StreamingOptions.java	9
sdks/java/core/src/main/java/org/apache/beam/sdk/options/Validation.java	14
sdks/java/core/src/main/java/org/apache/beam/sdk/options/ValueProvider.java	252
sdks/java/core/src/main/java/org/apache/beam/sdk/options/ValueProviders.java	28
sdks/java/core/src/main/java/org/apache/beam/sdk/options/package-info.java	1
sdks/java/core/src/main/java/org/apache/beam/sdk/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/runners/AppliedPTransform.java	47
sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformMatcher.java	19
sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformOverride.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PTransformOverrideFactory.java	45
sdks/java/core/src/main/java/org/apache/beam/sdk/runners/PipelineRunnerRegistrar.java	9
sdks/java/core/src/main/java/org/apache/beam/sdk/runners/TransformHierarchy.java	392
sdks/java/core/src/main/java/org/apache/beam/sdk/runners/package-info.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/AutoValueSchema.java	87
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/AvroRecordSchema.java	28
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/CachingFactory.java	43
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Factory.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldAccessDescriptor.java	444
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldTypeDescriptors.java	115
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldValueGetter.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldValueSetter.java	9
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FieldValueTypeInformation.java	231
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/FromRowUsingCreator.java	210
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/GetterBasedSchemaProvider.java	69
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/JavaBeanSchema.java	144
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/JavaFieldSchema.java	94
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/NoSuchSchemaException.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/RowMessages.java	97
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/Schema.java	984
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoder.java	187
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaCoderHelpers.java	138
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaProvider.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaProviderRegistrar.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaRegistry.java	207
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaTranslation.java	457
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaUserTypeCreator.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SchemaUtils.java	74
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/SetterBasedCreatorFactory.java	35
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/annotations/DefaultSchema.java	112
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/annotations/SchemaCaseFormat.java	19
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/annotations/SchemaCreate.java	16
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/annotations/SchemaFieldName.java	20
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/annotations/SchemaIgnore.java	16
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/annotations/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/DeadLetteredTransform.java	63
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/Failure.java	25
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/GenericDlq.java	30
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/GenericDlqProvider.java	13
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/InvalidConfigurationException.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/InvalidLocationException.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/InvalidSchemaException.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/Providers.java	28
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/SchemaIO.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/SchemaIOProvider.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/payloads/AvroPayloadSerializerProvider.java	22
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/payloads/JsonPayloadSerializerProvider.java	31
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/payloads/PayloadSerializer.java	28
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/payloads/PayloadSerializerProvider.java	12
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/payloads/PayloadSerializers.java	25
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/io/payloads/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/Date.java	32
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/DateTime.java	47
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/EnumerationType.java	118
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/FixedBytes.java	55
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/MicrosInstant.java	39
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/NanosDuration.java	20
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/NanosInstant.java	20
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/NanosType.java	27
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/OneOfType.java	153
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/PassThroughLogicalType.java	47
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/SqlTypes.java	14
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/Time.java	32
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/logicaltypes/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/package-info.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/parser/FieldAccessDescriptorParser.java	116
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/parser/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/AddFields.java	307
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Cast.java	295
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/CoGroup.java	522
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Convert.java	105
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/DropFields.java	88
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Filter.java	145
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Group.java	741
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Join.java	180
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/RenameFields.java	129
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/SchemaAggregateFn.java	285
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/Select.java	192
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AutoValueUtils.java	255
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroByteBuddyUtils.java	102
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/AvroUtils.java	993
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyLocalVariableManager.java	50
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ByteBuddyUtils.java	1164
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ConvertHelpers.java	172
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/FieldValueTypeSupplier.java	14
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/JavaBeanUtils.java	360
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/POJOUtils.java	440
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/ReflectUtils.java	189
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/RowSelector.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SchemaZipFold.java	107
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SelectByteBuddyHelpers.java	686
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/SelectHelpers.java	346
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/StaticSchemaInference.java	132
sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/utils/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/state/BagState.java	12
sdks/java/core/src/main/java/org/apache/beam/sdk/state/CombiningState.java	16
sdks/java/core/src/main/java/org/apache/beam/sdk/state/GroupingState.java	12
sdks/java/core/src/main/java/org/apache/beam/sdk/state/MapState.java	21
sdks/java/core/src/main/java/org/apache/beam/sdk/state/OrderedListState.java	12
sdks/java/core/src/main/java/org/apache/beam/sdk/state/ReadableState.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/state/ReadableStates.java	18
sdks/java/core/src/main/java/org/apache/beam/sdk/state/SetState.java	11
sdks/java/core/src/main/java/org/apache/beam/sdk/state/State.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/state/StateBinder.java	31
sdks/java/core/src/main/java/org/apache/beam/sdk/state/StateContext.java	12
sdks/java/core/src/main/java/org/apache/beam/sdk/state/StateContexts.java	49
sdks/java/core/src/main/java/org/apache/beam/sdk/state/StateKeySpec.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/state/StateSpec.java	52
sdks/java/core/src/main/java/org/apache/beam/sdk/state/StateSpecs.java	540
sdks/java/core/src/main/java/org/apache/beam/sdk/state/TimeDomain.java	11
sdks/java/core/src/main/java/org/apache/beam/sdk/state/Timer.java	14
sdks/java/core/src/main/java/org/apache/beam/sdk/state/TimerMap.java	9
sdks/java/core/src/main/java/org/apache/beam/sdk/state/TimerSpec.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/state/TimerSpecs.java	18
sdks/java/core/src/main/java/org/apache/beam/sdk/state/Timers.java	15
sdks/java/core/src/main/java/org/apache/beam/sdk/state/ValueState.java	9
sdks/java/core/src/main/java/org/apache/beam/sdk/state/WatermarkHoldState.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/state/package-info.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/Annotations.java	23
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/CoderProperties.java	293
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/CombineFnTester.java	113
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/CrashingRunner.java	25
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/FileChecksumMatcher.java	73
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/FlattenWithHeterogeneousCoders.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/GatherAllPanes.java	40
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/JsonMatcher.java	64
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/LargeKeys.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/MatcherDeserializer.java	21
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/MatcherSerializer.java	22
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/NeedsRunner.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PAssert.java	1125
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/PaneExtractors.java	136
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/RegexMatcher.java	24
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SerializableMatcher.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SerializableMatchers.java	452
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SourceTestUtils.java	644
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/StaticWindows.java	97
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/StreamingIT.java	3
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/SuccessOrFailure.java	61
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipeline.java	370
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestPipelineOptions.java	49
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/TestStream.java	274
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesAttemptedMetrics.java	3
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesBoundedSplittableParDo.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesBundleFinalizer.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesCommittedMetrics.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesCounterMetrics.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesCrossLanguageTransforms.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesCustomWindowMerging.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesDistributionMetrics.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesFailureMessage.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesGaugeMetrics.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesImpulse.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesKeyInParDo.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesKms.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesMapState.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesMetricsPusher.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesOnWindowExpiration.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesOrderedListState.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesParDoLifecycle.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesPythonExpansionService.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesRequiresTimeSortedInput.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesSchema.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesSetState.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesSideInputs.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesSideInputsWithDifferentCoders.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesSplittableParDoWithWindowedSideInputs.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesStatefulParDo.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesStrictTimerOrdering.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesSystemMetrics.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesTestStream.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesTestStreamWithMultipleStages.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesTestStreamWithOutputTimestamp.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesTestStreamWithProcessingTime.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesTimerMap.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesTimersInParDo.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesUnboundedPCollections.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/UsesUnboundedSplittableParDo.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/ValidatesRunner.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/WindowFnTestUtils.java	226
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/WindowSupplier.java	58
sdks/java/core/src/main/java/org/apache/beam/sdk/testing/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateQuantiles.java	426
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ApproximateUnique.java	218
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Combine.java	1332
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFnBase.java	76
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineFns.java	524
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/CombineWithContext.java	35
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Contextful.java	64
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Count.java	115
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Create.java	488
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Deduplicate.java	157
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Distinct.java	120
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFn.java	273
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnOutputReceivers.java	105
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnSchemaInformation.java	178
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/DoFnTester.java	575
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ExternalTransformBuilder.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Filter.java	66
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/FlatMapElements.java	232
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Flatten.java	76
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupByKey.java	120
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/GroupIntoBatches.java	241
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Impulse.java	24
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/InferableFunction.java	62
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/JsonToRow.java	240
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Keys.java	21
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/KvSwap.java	21
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Latest.java	110
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/MapElements.java	220
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Materialization.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Materializations.java	68
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Max.java	120
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Mean.java	102
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Min.java	120
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PTransform.java	106
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ParDo.java	531
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Partition.java	120
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PeriodicImpulse.java	50
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/PeriodicSequence.java	161
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ProcessFunction.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Regex.java	426
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Reify.java	209
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ReifyTimestamps.java	50
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Requirements.java	42
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Reshuffle.java	94
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sample.java	210
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/SerializableBiConsumer.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/SerializableBiFunction.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/SerializableComparator.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/SerializableFunction.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/SerializableFunctions.java	35
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sets.java	148
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/SimpleFunction.java	52
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Sum.java	87
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ToJson.java	44
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ToString.java	77
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Top.java	263
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Values.java	21
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/View.java	361
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/ViewFn.java	12
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Wait.java	74
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Watch.java	881
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithFailures.java	91
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithKeys.java	63
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/WithTimestamps.java	52
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/display/DisplayData.java	506
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/display/HasDisplayData.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/display/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResult.java	285
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGbkResultSchema.java	58
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/CoGroupByKey.java	93
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/KeyedPCollectionTuple.java	124
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/RawUnionValue.java	40
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/UnionCoder.java	91
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/join/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/ByteBuddyDoFnInvokerFactory.java	979
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/ByteBuddyOnTimerInvokerFactory.java	261
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvoker.java	342
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvokerFactory.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnInvokers.java	44
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignature.java	882
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/DoFnSignatures.java	2064
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/OnTimerInvoker.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/OnTimerInvokerFactory.java	8
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/OnTimerInvokers.java	14
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/OnTimerMethodSpecifier.java	12
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/StableInvokerNamingStrategy.java	24
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/reflect/package-info.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/ResourceHint.java	12
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/ResourceHints.java	219
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/ResourceHintsOptions.java	21
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/resourcehints/package-info.java	1
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/ByteKeyRangeTracker.java	158
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/GrowableOffsetRangeTracker.java	83
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/HasDefaultTracker.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/HasDefaultWatermarkEstimator.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/ManualWatermarkEstimator.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/OffsetRangeTracker.java	112
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/RestrictionTracker.java	42
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/SplitResult.java	15
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/TimestampObservingWatermarkEstimator.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/WatermarkEstimator.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/WatermarkEstimators.java	76
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/splittabledofn/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterAll.java	46
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterEach.java	41
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterFirst.java	44
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterPane.java	56
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterProcessingTime.java	98
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterSynchronizedProcessingTime.java	37
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/AfterWatermark.java	110
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/BoundedWindow.java	34
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/CalendarWindows.java	263
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/DefaultTrigger.java	30
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/FixedWindows.java	80
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/GlobalWindow.java	54
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/GlobalWindows.java	62
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/IncompatibleWindowException.java	14
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/IntervalWindow.java	115
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/MergeOverlappingIntervalWindows.java	62
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Never.java	26
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/NonMergingWindowFn.java	9
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/OrFinallyTrigger.java	40
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/PaneInfo.java	207
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/PartitioningWindowFn.java	29
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Repeatedly.java	34
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/ReshuffleTrigger.java	29
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Sessions.java	72
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/SlidingWindows.java	132
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/TimestampCombiner.java	84
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/TimestampTransform.java	33
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Trigger.java	113
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/Window.java	241
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/WindowFn.java	45
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/WindowMappingFn.java	19
sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/windowing/package-info.java	4
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ApiSurface.java	522
sdks/java/core/src/main/java/org/apache/beam/sdk/util/AppliedCombineFn.java	100
sdks/java/core/src/main/java/org/apache/beam/sdk/util/BackOff.java	25
sdks/java/core/src/main/java/org/apache/beam/sdk/util/BackOffUtils.java	14
sdks/java/core/src/main/java/org/apache/beam/sdk/util/BitSetCoder.java	38
sdks/java/core/src/main/java/org/apache/beam/sdk/util/BucketingFunction.java	78
sdks/java/core/src/main/java/org/apache/beam/sdk/util/BufferedElementCountingOutputStream.java	108
sdks/java/core/src/main/java/org/apache/beam/sdk/util/CoderUtils.java	109
sdks/java/core/src/main/java/org/apache/beam/sdk/util/CombineContextFactory.java	35
sdks/java/core/src/main/java/org/apache/beam/sdk/util/CombineFnUtil.java	128
sdks/java/core/src/main/java/org/apache/beam/sdk/util/DoFnInfo.java	112
sdks/java/core/src/main/java/org/apache/beam/sdk/util/DoFnWithExecutionInformation.java	25
sdks/java/core/src/main/java/org/apache/beam/sdk/util/EmptyOnDeserializationThreadLocal.java	14
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ExplicitShardedFile.java	77
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ExposedByteArrayInputStream.java	27
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ExposedByteArrayOutputStream.java	66
sdks/java/core/src/main/java/org/apache/beam/sdk/util/FilePatternMatchingShardedFile.java	90
sdks/java/core/src/main/java/org/apache/beam/sdk/util/FluentBackoff.java	129
sdks/java/core/src/main/java/org/apache/beam/sdk/util/HistogramData.java	179
sdks/java/core/src/main/java/org/apache/beam/sdk/util/IdentityWindowFn.java	63
sdks/java/core/src/main/java/org/apache/beam/sdk/util/IllegalMutationException.java	22
sdks/java/core/src/main/java/org/apache/beam/sdk/util/InstanceBuilder.java	138
sdks/java/core/src/main/java/org/apache/beam/sdk/util/LzoCompression.java	20
sdks/java/core/src/main/java/org/apache/beam/sdk/util/MimeTypes.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/util/MoreFutures.java	135
sdks/java/core/src/main/java/org/apache/beam/sdk/util/MovingFunction.java	69
sdks/java/core/src/main/java/org/apache/beam/sdk/util/MutationDetector.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/util/MutationDetectors.java	88
sdks/java/core/src/main/java/org/apache/beam/sdk/util/NameUtils.java	79
sdks/java/core/src/main/java/org/apache/beam/sdk/util/NoopLock.java	38
sdks/java/core/src/main/java/org/apache/beam/sdk/util/NumberedShardedFile.java	119
sdks/java/core/src/main/java/org/apache/beam/sdk/util/Preconditions.java	251
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ReleaseInfo.java	74
sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowJson.java	426
sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowJsonUtils.java	43
sdks/java/core/src/main/java/org/apache/beam/sdk/util/RowJsonValueExtractors.java	145
sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableThrowable.java	41
sdks/java/core/src/main/java/org/apache/beam/sdk/util/SerializableUtils.java	146
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ShardedFile.java	10
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ShardedKey.java	105
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ShardingWritableByteChannel.java	54
sdks/java/core/src/main/java/org/apache/beam/sdk/util/Sleeper.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/util/StreamUtils.java	40
sdks/java/core/src/main/java/org/apache/beam/sdk/util/StringUtils.java	81
sdks/java/core/src/main/java/org/apache/beam/sdk/util/SystemDoFnInternal.java	12
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ThrowingRunnable.java	5
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ThrowingSupplier.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/util/UnownedInputStream.java	47
sdks/java/core/src/main/java/org/apache/beam/sdk/util/UnownedOutputStream.java	34
sdks/java/core/src/main/java/org/apache/beam/sdk/util/UserCodeException.java	55
sdks/java/core/src/main/java/org/apache/beam/sdk/util/VarInt.java	61
sdks/java/core/src/main/java/org/apache/beam/sdk/util/Weighted.java	6
sdks/java/core/src/main/java/org/apache/beam/sdk/util/WeightedValue.java	21
sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowTracing.java	15
sdks/java/core/src/main/java/org/apache/beam/sdk/util/WindowedValue.java	614
sdks/java/core/src/main/java/org/apache/beam/sdk/util/ZipFiles.java	155
sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/ElementByteSizeObservableIterable.java	24
sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/ElementByteSizeObservableIterator.java	12
sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/ElementByteSizeObserver.java	42
sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/ReflectHelpers.java	230
sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/Reiterable.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/Reiterator.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/util/common/package-info.java	1
sdks/java/core/src/main/java/org/apache/beam/sdk/util/package-info.java	3
sdks/java/core/src/main/java/org/apache/beam/sdk/values/FailsafeValueInSingleWindow.java	98
sdks/java/core/src/main/java/org/apache/beam/sdk/values/KV.java	75
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PBegin.java	30
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollection.java	271
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionList.java	126
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionTuple.java	168
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionView.java	35
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionViews.java	996
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PDone.java	26
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PInput.java	7
sdks/java/core/src/main/java/org/apache/beam/sdk/values/POutput.java	9
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PValue.java	16
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PValueBase.java	74
sdks/java/core/src/main/java/org/apache/beam/sdk/values/PValues.java	74
sdks/java/core/src/main/java/org/apache/beam/sdk/values/Row.java	529
sdks/java/core/src/main/java/org/apache/beam/sdk/values/RowUtils.java	506
sdks/java/core/src/main/java/org/apache/beam/sdk/values/RowWithGetters.java	142
sdks/java/core/src/main/java/org/apache/beam/sdk/values/RowWithStorage.java	31
sdks/java/core/src/main/java/org/apache/beam/sdk/values/SchemaVerification.java	22
sdks/java/core/src/main/java/org/apache/beam/sdk/values/ShardedKey.java	38
sdks/java/core/src/main/java/org/apache/beam/sdk/values/TaggedPValue.java	17
sdks/java/core/src/main/java/org/apache/beam/sdk/values/TimestampedValue.java	103
sdks/java/core/src/main/java/org/apache/beam/sdk/values/TupleTag.java	71
sdks/java/core/src/main/java/org/apache/beam/sdk/values/TupleTagList.java	47
sdks/java/core/src/main/java/org/apache/beam/sdk/values/TypeDescriptor.java	188
sdks/java/core/src/main/java/org/apache/beam/sdk/values/TypeDescriptors.java	134
sdks/java/core/src/main/java/org/apache/beam/sdk/values/TypeParameter.java	33
sdks/java/core/src/main/java/org/apache/beam/sdk/values/ValueInSingleWindow.java	83
sdks/java/core/src/main/java/org/apache/beam/sdk/values/ValueWithRecordId.java	97
sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowingStrategy.java	342
sdks/java/core/src/main/java/org/apache/beam/sdk/values/package-info.java	4
sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionServer.java	46
sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java	420
sdks/java/expansion-service/src/main/java/org/apache/beam/sdk/expansion/service/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/annotation/audience/Audience.java	18
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/annotation/audience/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/annotation/operator/Basic.java	10
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/annotation/operator/Derived.java	10
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/annotation/operator/Recommended.java	11
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/annotation/operator/StateComplexity.java	8
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/annotation/operator/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/annotation/stability/Experimental.java	17
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/annotation/stability/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/accumulators/Accumulator.java	4
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/accumulators/AccumulatorProvider.java	20
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/accumulators/Counter.java	7
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/accumulators/Histogram.java	7
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/accumulators/Timer.java	11
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/accumulators/VoidAccumulatorProvider.java	77
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/accumulators/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/BinaryFunction.java	8
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/BinaryFunctor.java	9
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/CombinableBinaryFunction.java	5
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/CombinableReduceFunction.java	5
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/CompositeUnaryFunction.java	20
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/Consumer.java	8
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/ExtractEventTime.java	8
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/ReduceFunction.java	6
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/ReduceFunctor.java	23
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/SameArgsBinaryFunction.java	6
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/Supplier.java	6
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/TernaryFunction.java	8
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/UnaryFunction.java	11
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/UnaryFunctionEnv.java	9
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/UnaryFunctor.java	9
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/UnaryPredicate.java	5
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/VoidFunction.java	8
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/functional/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/io/Collector.java	7
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/io/Context.java	4
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/io/Environment.java	11
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/io/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/lib/Split.java	75
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/lib/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/AssignEventTime.java	99
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/CompositeOperator.java	6
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/CountByKey.java	193
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/Distinct.java	290
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/Filter.java	86
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/FlatMap.java	123
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/FullJoin.java	93
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/Join.java	248
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/LeftJoin.java	92
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/MapElements.java	100
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/OutputValues.java	28
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceByKey.java	505
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/ReduceWindow.java	465
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/RightJoin.java	93
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/SumByKey.java	214
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/TopPerKey.java	284
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/Union.java	62
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/WindowBuilder.java	78
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/base/Builders.java	73
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/base/Operator.java	27
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/base/OptionalMethodBuilder.java	18
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/base/ShuffleOperator.java	37
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/base/WindowAware.java	8
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/base/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/hint/ComputationHint.java	7
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/hint/OutputHint.java	6
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/hint/SizeHint.java	7
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/hint/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/type/TypeAware.java	15
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/type/TypeAwareness.java	13
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/type/TypeUtils.java	35
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/type/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/util/Fold.java	32
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/util/Max.java	16
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/util/PCollectionLists.java	10
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/util/Sums.java	52
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/util/Triple.java	45
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/client/util/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/AbstractJoinTranslator.java	50
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/BeamAccumulatorProvider.java	113
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/BroadcastHashJoinTranslator.java	138
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/CompositeOperatorTranslator.java	22
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/EuphoriaOptions.java	33
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/ExtractKey.java	43
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/FlatMapTranslator.java	77
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/JoinTranslator.java	217
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/LazyAccumulatorProvider.java	43
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/OperatorTransform.java	48
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/OperatorTranslator.java	13
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/ReduceByKeyTranslator.java	198
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/SingleValueContext.java	59
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/TimestampExtractTransform.java	58
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/TranslatorProvider.java	11
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/UnionTranslator.java	19
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/collector/AdaptableCollector.java	57
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/collector/CollectorAdapter.java	7
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/collector/SingleValueCollector.java	46
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/collector/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/provider/CompositeProvider.java	37
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/provider/GenericTranslatorProvider.java	135
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/translate/provider/package-info.java	1
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/util/IOUtils.java	29
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/util/InstanceUtils.java	34
sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/util/package-info.java	1
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/auth/CredentialFactory.java	7
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/auth/GcpCredentialFactory.java	33
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/auth/NoopCredentialFactory.java	41
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/auth/NullCredentialInitializer.java	34
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/auth/package-info.java	1
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/CloudResourceManagerOptions.java	10
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/GcpOptions.java	326
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/GcpPipelineOptionsRegistrar.java	16
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/GcsOptions.java	101
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/GoogleApiDebugOptions.java	45
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/options/package-info.java	1
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/GcsCreateOptions.java	17
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/GcsFileSystem.java	231
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/GcsFileSystemRegistrar.java	20
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/GcsPathValidator.java	67
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/GcsResourceId.java	88
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/NoopPathValidator.java	21
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/PathValidator.java	10
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/package-info.java	4
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/BackOffAdapter.java	17
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/CustomHttpErrors.java	59
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GceMetadataUtil.java	43
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/GcsUtil.java	619
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/HttpCallCustomError.java	4
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/HttpCallMatcher.java	4
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/HttpRequestWrapper.java	12
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/HttpResponseWrapper.java	11
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/LatencyRecordingHttpRequestInitializer.java	52
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/RetryHttpRequestInitializer.java	201
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/Transport.java	89
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/UploadIdResponseInterceptor.java	34
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/GcsPath.java	406
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/gcsfs/package-info.java	1
sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util/package-info.java	1
sdks/java/extensions/jackson/src/main/java/org/apache/beam/sdk/extensions/jackson/AsJsons.java	125
sdks/java/extensions/jackson/src/main/java/org/apache/beam/sdk/extensions/jackson/ParseJsons.java	126
sdks/java/extensions/jackson/src/main/java/org/apache/beam/sdk/extensions/jackson/package-info.java	1
sdks/java/extensions/join-library/src/main/java/org/apache/beam/sdk/extensions/joinlibrary/Join.java	280
sdks/java/extensions/join-library/src/main/java/org/apache/beam/sdk/extensions/joinlibrary/package-info.java	1
sdks/java/extensions/kryo/src/main/java/org/apache/beam/sdk/extensions/kryo/KryoCoder.java	144
sdks/java/extensions/kryo/src/main/java/org/apache/beam/sdk/extensions/kryo/KryoCoderProvider.java	78
sdks/java/extensions/kryo/src/main/java/org/apache/beam/sdk/extensions/kryo/KryoOptions.java	25
sdks/java/extensions/kryo/src/main/java/org/apache/beam/sdk/extensions/kryo/KryoRegistrar.java	8
sdks/java/extensions/kryo/src/main/java/org/apache/beam/sdk/extensions/kryo/KryoState.java	73
sdks/java/extensions/kryo/src/main/java/org/apache/beam/sdk/extensions/kryo/package-info.java	3
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateImages.java	131
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateText.java	55
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateVideoBytesWithContextFn.java	27
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateVideoFn.java	66
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateVideoFromBytesFn.java	32
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateVideoFromURIFn.java	31
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/AnnotateVideoURIWithContextFn.java	26
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/BatchRequestForDLP.java	75
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/CloudVision.java	139
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/DLPDeidentifyText.java	173
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/DLPInspectText.java	147
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/DLPReidentifyText.java	172
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/MapStringToDlpRow.java	27
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/VideoIntelligence.java	91
sdks/java/extensions/ml/src/main/java/org/apache/beam/sdk/extensions/ml/package-info.java	3
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ByteStringCoder.java	66
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/DynamicProtoCoder.java	122
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoByteBuddyUtils.java	942
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoCoder.java	196
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDomain.java	257
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoDynamicMessageSchema.java	650
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoMessageSchema.java	131
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoPayloadSerializerProvider.java	61
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoSchemaLogicalTypes.java	82
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoSchemaTranslator.java	241
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtobufCoderProviderRegistrar.java	18
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtobufUtil.java	111
sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/package-info.java	1
sdks/java/extensions/schemaio-expansion-service/src/main/java/org/apache/beam/sdk/extensions/schemaio/expansion/ExternalSchemaIOTransformRegistrar.java	119
sdks/java/extensions/schemaio-expansion-service/src/main/java/org/apache/beam/sdk/extensions/schemaio/expansion/package-info.java	4
sdks/java/extensions/sketching/src/main/java/org/apache/beam/sdk/extensions/sketching/ApproximateDistinct.java	247
sdks/java/extensions/sketching/src/main/java/org/apache/beam/sdk/extensions/sketching/SketchFrequencies.java	240
sdks/java/extensions/sketching/src/main/java/org/apache/beam/sdk/extensions/sketching/TDigestQuantiles.java	154
sdks/java/extensions/sketching/src/main/java/org/apache/beam/sdk/extensions/sketching/package-info.java	3
sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/BufferedExternalSorter.java	93
sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/ExternalSorter.java	55
sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/HadoopExternalSorter.java	143
sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/InMemorySorter.java	91
sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/NativeExternalSorter.java	35
sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/NativeFileSorter.java	187
sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/SortValues.java	138
sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/Sorter.java	7
sdks/java/extensions/sorter/src/main/java/org/apache/beam/sdk/extensions/sorter/package-info.java	1
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/example/BeamSqlDataCatalogExample.java	71
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/example/package-info.java	3
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/BigQueryTableFactory.java	45
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/ChainedTableFactory.java	25
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/DataCatalogPipelineOptions.java	17
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/DataCatalogPipelineOptionsRegistrar.java	12
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/DataCatalogTableProvider.java	190
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/GcsTableFactory.java	34
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/PubsubTableFactory.java	36
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/SchemaUtils.java	151
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/TableFactory.java	7
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/ZetaSqlIdUtils.java	40
sdks/java/extensions/sql/datacatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog/package-info.java	3
sdks/java/extensions/sql/expansion-service/src/main/java/org/apache/beam/sdk/extensions/sql/expansion/ExternalSqlTransformRegistrar.java	58
sdks/java/extensions/sql/expansion-service/src/main/java/org/apache/beam/sdk/extensions/sql/expansion/package-info.java	1
sdks/java/extensions/sql/hcatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/hcatalog/DatabaseProvider.java	63
sdks/java/extensions/sql/hcatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/hcatalog/HCatalogTable.java	59
sdks/java/extensions/sql/hcatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/hcatalog/HCatalogTableProvider.java	68
sdks/java/extensions/sql/hcatalog/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/hcatalog/package-info.java	3
sdks/java/extensions/sql/jdbc/src/main/java/org/apache/beam/sdk/extensions/sql/jdbc/BeamSqlLine.java	48
sdks/java/extensions/sql/jdbc/src/main/java/org/apache/beam/sdk/extensions/sql/jdbc/package-info.java	3
sdks/java/extensions/sql/src/main/codegen/includes/parserImpls.ftl	329
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/BeamSqlCli.java	50
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/BeamSqlSeekableTable.java	11
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/BeamSqlUdf.java	7
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/SqlTransform.java	189
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/TableNameExtractionUtils.java	55
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/BeamSqlExample.java	58
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/BeamSqlPojoExample.java	75
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Customer.java	69
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/Order.java	47
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/model/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/example/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamCalciteSchema.java	104
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamCalciteSchemaFactory.java	108
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamCalciteTable.java	110
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSqlEnv.java	209
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSqlPipelineOptions.java	20
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamSqlPipelineOptionsRegistrar.java	12
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/BeamTableStatistics.java	62
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CalciteConnectionWrapper.java	301
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CalciteFactoryWrapper.java	76
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CalciteQueryPlanner.java	200
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JavaUdfLoader.java	217
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcConnection.java	77
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcDriver.java	98
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/JdbcFactory.java	65
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/LazyAggregateCombineFn.java	69
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ParseException.java	9
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/QueryPlanner.java	47
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ScalarFnReflector.java	38
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ScalarFunctionImpl.java	162
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/SqlConversionException.java	13
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/TVFSlidingWindowFn.java	44
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/TableName.java	36
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/TableResolutionUtils.java	117
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdafImpl.java	77
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdfImpl.java	33
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/UdfImplReflectiveFunctionBase.java	92
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/ZetaSqlUserDefinedSQLNativeTableValuedFunction.java	28
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPCall.java	52
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPFieldRef.java	23
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPKind.java	22
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPLiteral.java	315
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPMeasure.java	27
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPOperation.java	23
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPOperator.java	43
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPPattern.java	85
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/CEPUtils.java	171
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/OrderKey.java	40
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/PatternCondition.java	10
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/Quantifier.java	25
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/cep/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/nfa/NFA.java	640
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/nfa/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlCheckConstraint.java	44
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlColumnDeclaration.java	46
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlCreateExternalTable.java	132
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlDdlNodes.java	53
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlDropObject.java	60
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlDropTable.java	13
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlSetOptionBeam.java	39
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamCostModel.java	183
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamJavaTypeFactory.java	23
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamRelDataTypeSystem.java	31
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/BeamRuleSets.java	125
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/NodeStats.java	45
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/NodeStatsMetadata.java	17
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/RelMdNodeStats.java	42
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/planner/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/AbstractBeamCalcRel.java	54
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamAggregationRel.java	296
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamCalcRel.java	660
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamCoGBKJoinRel.java	153
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamEnumerableConverter.java	370
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamIOSinkRel.java	111
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamIOSourceRel.java	109
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamIntersectRel.java	51
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamJoinRel.java	188
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamLogicalConvention.java	43
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMatchRel.java	375
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamMinusRel.java	47
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamPushDownIOSourceRel.java	86
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamRelNode.java	42
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSetOperatorRelBase.java	65
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSideInputJoinRel.java	139
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSideInputLookupJoinRel.java	86
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSortRel.java	282
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamSqlRelUtils.java	65
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamTableFunctionScanRel.java	291
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamUncollectRel.java	76
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamUnionRel.java	48
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamUnnestRel.java	128
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamValuesRel.java	70
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/BeamWindowRel.java	367
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/CalcRelSplitter.java	571
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rel/package-info.java	4
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamAggregateProjectMergeRule.java	55
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamAggregationRule.java	117
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamBasicAggregationRule.java	93
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamCalcMergeRule.java	16
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamCalcRule.java	46
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamCalcSplittingRule.java	43
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamCoGBKJoinRule.java	47
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamEnumerableConverterRule.java	23
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamIOPushDownRule.java	224
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamIOSinkRule.java	22
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamIntersectRule.java	29
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamJoinAssociateRule.java	26
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamJoinPushThroughJoinRule.java	41
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamMatchRule.java	35
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamMinusRule.java	25
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamSideInputJoinRule.java	49
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamSideInputLookupJoinRule.java	40
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamSortRule.java	26
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamTableFunctionScanRule.java	47
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamUncollectRule.java	24
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamUnionRule.java	23
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamUnnestRule.java	79
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamValuesRule.java	23
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/BeamWindowRule.java	25
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/JoinRelOptRuleCall.java	68
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/LogicalCalcMergeRule.java	16
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/rule/package-info.java	4
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamPCollectionTable.java	36
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/schema/BeamTableUtils.java	133
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/schema/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamBuiltinAggregations.java	406
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamBuiltinAnalyticFunctions.java	227
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamJoinTransforms.java	148
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamSetOperatorsTransforms.java	85
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/BeamSqlOutputToConsoleFn.java	14
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/AggregationCombineFnAdapter.java	149
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/CountIf.java	43
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/CovarianceAccumulator.java	77
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/CovarianceFn.java	81
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/VarianceAccumulator.java	46
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/VarianceFn.java	74
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/agg/package-info.java	4
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/transform/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udaf/ArrayAgg.java	31
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udaf/StringAgg.java	42
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udaf/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/BeamBuiltinFunctionProvider.java	21
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/BuiltinHashFunctions.java	71
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/BuiltinStringFunctions.java	212
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/BuiltinTrigonometricFunctions.java	39
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/IsInf.java	21
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/IsNan.java	21
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/UDF.java	13
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/udf/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/BigDecimalConverter.java	26
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/CalciteUtils.java	243
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/SerializableRexFieldAccess.java	27
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/SerializableRexInputRef.java	11
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/SerializableRexNode.java	25
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/TVFStreamingUtils.java	8
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/utils/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/BaseBeamTable.java	30
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/BeamSqlTable.java	20
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/BeamSqlTableFilter.java	16
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/CustomTableResolver.java	7
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/DefaultTableFilter.java	17
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/ProjectSupport.java	12
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/SchemaBaseBeamTable.java	13
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/Table.java	29
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/FullNameTableProvider.java	81
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/InMemoryMetaTableProvider.java	18
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/InvalidTableException.java	12
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/ReadOnlyTableProvider.java	49
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/SchemaIOTableProviderWrapper.java	93
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/TableProvider.java	28
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/UdfUdafProvider.java	20
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/avro/AvroTableProvider.java	18
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/avro/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BeamBigQuerySqlDialect.java	346
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BeamSqlUnparseContext.java	169
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BigQueryFilter.java	102
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BigQueryTable.java	210
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/BigQueryTableProvider.java	29
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigtable/BigtableFilter.java	91
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigtable/BigtableTable.java	189
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigtable/BigtableTableProvider.java	21
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigtable/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datastore/DataStoreV1TableProvider.java	35
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/datastore/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/BeamKafkaCSVTable.java	89
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/BeamKafkaTable.java	196
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/KafkaTableProvider.java	87
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/NestedPayloadKafkaTable.java	153
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/PayloadSerializerKafkaTable.java	52
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/Schemas.java	79
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/kafka/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTable.java	361
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/MongoDbTableProvider.java	17
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/mongodb/package-info.java	4
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/parquet/ParquetTable.java	102
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/parquet/ParquetTableProvider.java	18
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/parquet/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/PubsubTableProvider.java	22
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsub/package-info.java	4
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/PubsubLiteSubscriptionTable.java	49
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/PubsubLiteTableProvider.java	161
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/PubsubLiteTopicTable.java	48
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/RowHandler.java	139
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/pubsublite/package-info.java	4
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/seqgen/GenerateSequenceTable.java	51
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/seqgen/GenerateSequenceTableProvider.java	17
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/seqgen/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/text/TextJsonTable.java	14
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/text/TextTable.java	82
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/text/TextTableProvider.java	215
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/text/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/store/InMemoryMetaStore.java	72
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/store/MetaStore.java	5
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/store/package-info.java	1
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/package-info.java	1
sdks/java/extensions/sql/udf/src/main/java/org/apache/beam/sdk/extensions/sql/udf/AggregateFn.java	11
sdks/java/extensions/sql/udf/src/main/java/org/apache/beam/sdk/extensions/sql/udf/ScalarFn.java	11
sdks/java/extensions/sql/udf/src/main/java/org/apache/beam/sdk/extensions/sql/udf/UdfProvider.java	11
sdks/java/extensions/sql/udf/src/main/java/org/apache/beam/sdk/extensions/sql/udf/package-info.java	1
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamCalcRelType.java	120
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamJavaUdfCalcRule.java	18
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCalcMergeRule.java	19
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCalcRel.java	255
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCalcRule.java	16
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCalcSplittingRule.java	16
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlCatalog.java	470
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/BeamZetaSqlRelType.java	60
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/DateTimeUtils.java	164
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/QueryTrait.java	44
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SqlAnalyzer.java	133
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/SupportedZetaSqlBuiltinFunctions.java	213
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/TableResolution.java	64
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSQLPlannerImpl.java	82
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSQLQueryPlanner.java	210
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSqlBeamTranslationUtils.java	249
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSqlCalciteTranslationUtils.java	297
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/ZetaSqlException.java	11
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/package-info.java	3
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/AggregateScanConverter.java	201
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ArrayScanColumnRefToUncollect.java	93
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ArrayScanLiteralToUncollectConverter.java	36
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ArrayScanToJoinConverter.java	75
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ConversionContext.java	60
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ExpressionConverter.java	806
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/FilterScanConverter.java	29
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/JoinScanConverter.java	76
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/LimitOffsetScanToLimitConverter.java	54
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/LimitOffsetScanToOrderByLimitConverter.java	79
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/OrderByScanUnsupportedConverter.java	13
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ProjectScanConverter.java	25
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/QueryStatementConverter.java	80
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/RelConverter.java	50
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SetOperationScanConverter.java	73
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SingleRowScanConverter.java	17
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlCaseWithValueOperatorRewriter.java	32
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlCoalesceOperatorRewriter.java	29
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlIfNullOperatorRewriter.java	22
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlNullIfOperatorRewriter.java	27
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlOperatorMappingTable.java	72
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlOperatorRewriter.java	7
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlOperators.java	242
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/SqlWindowTableFunction.java	76
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/TVFScanConverter.java	76
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/TableScanConverter.java	73
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/UserFunctionDefinitions.java	43
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/WithRefScanConverter.java	23
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/WithScanConverter.java	22
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/ZetaSqlScalarFunctionImpl.java	32
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/impl/BeamBuiltinMethods.java	41
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/impl/BeamCodegenUtils.java	18
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/impl/CastFunctionImpl.java	72
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/impl/DateFunctions.java	19
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/impl/StringFunctions.java	124
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/impl/TimestampFunctions.java	28
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/impl/package-info.java	3
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/translation/package-info.java	3
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/BeamZetaSqlUncollectRel.java	72
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/BeamZetaSqlUncollectRule.java	23
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/BeamZetaSqlUnnestRel.java	114
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/BeamZetaSqlUnnestRule.java	74
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/ZetaSqlUnnest.java	75
sdks/java/extensions/sql/zetasql/src/main/java/org/apache/beam/sdk/extensions/sql/zetasql/unnest/package-info.java	3
sdks/java/extensions/zetasketch/src/main/java/org/apache/beam/sdk/extensions/zetasketch/ApproximateCountDistinct.java	165
sdks/java/extensions/zetasketch/src/main/java/org/apache/beam/sdk/extensions/zetasketch/HllCount.java	130
sdks/java/extensions/zetasketch/src/main/java/org/apache/beam/sdk/extensions/zetasketch/HllCountInitFn.java	104
sdks/java/extensions/zetasketch/src/main/java/org/apache/beam/sdk/extensions/zetasketch/HllCountMergePartialFn.java	80
sdks/java/extensions/zetasketch/src/main/java/org/apache/beam/sdk/extensions/zetasketch/HyperLogLogPlusPlusCoder.java	32
sdks/java/extensions/zetasketch/src/main/java/org/apache/beam/sdk/extensions/zetasketch/package-info.java	3
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/IdGenerator.java	4
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/IdGenerators.java	12
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/JvmInitializers.java	16
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/channel/ManagedChannelFactory.java	71
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/channel/SocketAddressFactory.java	35
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/channel/package-info.java	1
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataBufferingOutboundObserver.java	60
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataGrpcMultiplexer.java	158
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataInboundObserver.java	65
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataSizeBasedBufferingOutboundObserver.java	106
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataTimeBasedBufferingOutboundObserver.java	85
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/CloseableFnDataReceiver.java	7
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/CompletableFutureInboundDataClient.java	40
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/DecodingFnDataReceiver.java	22
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/FnDataReceiver.java	4
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/InboundDataClient.java	10
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/LogicalEndpoint.java	23
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/RemoteGrpcPortRead.java	39
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/RemoteGrpcPortWrite.java	40
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/package-info.java	1
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/package-info.java	1
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/RestrictionTrackers.java	74
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/WatermarkEstimators.java	69
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/splittabledofn/package-info.java	4
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/AdvancingPhaser.java	11
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/BufferingStreamObserver.java	114
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DataStreams.java	223
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/DirectStreamObserver.java	78
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/ForwardingClientResponseObserver.java	33
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/OutboundObserverFactory.java	82
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/SynchronizedStreamObserver.java	29
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/stream/package-info.java	1
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/windowing/EncodedBoundedWindow.java	53
sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/windowing/package-info.java	1
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/AssignWindowsRunner.java	77
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/BeamFnDataReadRunner.java	272
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/BeamFnDataWriteRunner.java	140
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/CombineRunners.java	202
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FlattenRunner.java	92
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnApiDoFnRunner.java	2203
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/FnHarness.java	255
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/GroupingTable.java	8
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/HandlesSplits.java	20
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/MapFnRunners.java	148
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PTransformRunnerFactory.java	52
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/PrecombineGroupingTable.java	395
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/ToStringFnRunner.java	28
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/WindowMappingFnRunner.java	38
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/WindowMergingFnRunner.java	102
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/AddHarnessIdInterceptor.java	16
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/BeamFnControlClient.java	129
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/BundleSplitListener.java	29
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/FinalizeBundleHandler.java	113
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java	697
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/package-info.java	1
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnDataClient.java	28
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnDataGrpcClient.java	69
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnTimerClient.java	12
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnTimerGrpcClient.java	68
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/PCollectionConsumerRegistry.java	284
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/PTransformFunctionRegistry.java	67
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/QueueingBeamFnDataClient.java	203
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/package-info.java	1
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/logging/BeamFnLoggingClient.java	260
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/logging/package-info.java	1
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/package-info.java	1
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BagUserState.java	98
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BeamFnStateClient.java	8
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/BeamFnStateGrpcClientCache.java	111
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiStateAccessor.java	432
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/IterableSideInput.java	43
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/LazyCachingIteratorToIterable.java	55
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/MultimapSideInput.java	69
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/SideInputSpec.java	26
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateBackedIterable.java	164
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/StateFetchingIterators.java	167
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/package-info.java	1
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/BeamFnStatusClient.java	186
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/MemoryMonitor.java	401
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/status/package-info.java	1
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/stream/HarnessStreamObserverFactories.java	31
sdks/java/harness/src/main/java/org/apache/beam/fn/harness/stream/package-info.java	1
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/coders/AwsCoders.java	89
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/coders/package-info.java	1
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/dynamodb/AttributeValueCoder.java	130
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/dynamodb/AttributeValueCoderProviderRegistrar.java	17
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/dynamodb/AwsClientsProvider.java	8
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/dynamodb/BasicDynamoDBProvider.java	50
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/dynamodb/DynamoDBIO.java	371
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/dynamodb/package-info.java	4
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/options/AwsModule.java	311
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/options/AwsOptions.java	57
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/options/AwsPipelineOptionsRegistrar.java	15
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/options/S3ClientBuilderFactory.java	5
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/options/S3Options.java	58
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/options/package-info.java	4
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/DefaultS3ClientBuilderFactory.java	32
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3FileSystem.java	521
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3FileSystemRegistrar.java	20
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3ReadableSeekableByteChannel.java	135
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3ResourceId.java	154
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/S3WritableByteChannel.java	160
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/s3/package-info.java	4
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sns/AwsClientsProvider.java	8
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sns/BasicSnsProvider.java	50
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sns/PublishResultCoders.java	76
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sns/SnsCoderProviderRegistrar.java	18
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sns/SnsIO.java	231
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sns/package-info.java	4
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsCheckpointMark.java	41
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsConfiguration.java	55
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsIO.java	111
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsUnboundedReader.java	125
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsUnboundedSource.java	67
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/package-info.java	4
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/AttributeValueCoder.java	124
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java	56
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/DynamoDBIO.java	372
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/DynamoDbClientProvider.java	6
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/package-info.java	4
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/AWSClientsProvider.java	8
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/BasicKinesisProvider.java	53
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/CheckpointGenerator.java	5
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/CustomOptional.java	61
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/DynamicCheckpointGenerator.java	45
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/GetKinesisRecordsResult.java	35
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisClientThrottledException.java	7
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisIO.java	163
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisReader.java	156
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisReaderCheckpoint.java	37
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisRecord.java	103
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisRecordCoder.java	52
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisShardClosedException.java	6
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisSource.java	118
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/RateLimitPolicy.java	6
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/RateLimitPolicyFactory.java	34
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/RecordFilter.java	14
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardCheckpoint.java	119
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardReadersPool.java	237
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/ShardRecordsIterator.java	111
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/SimplifiedKinesisClient.java	202
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPoint.java	55
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StartingPointShardsFinder.java	92
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/StaticCheckpointGenerator.java	17
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/TimeUtil.java	17
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/TransientKinesisException.java	7
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/WatermarkParameters.java	50
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/WatermarkPolicy.java	7
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/WatermarkPolicyFactory.java	87
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/package-info.java	4
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options/AwsModule.java	267
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options/AwsOptions.java	52
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options/AwsPipelineOptionsRegistrar.java	12
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options/AwsSerializableUtils.java	28
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options/S3ClientBuilderFactory.java	5
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options/S3Options.java	62
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options/package-info.java	4
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/DefaultS3ClientBuilderFactory.java	37
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3FileSystem.java	551
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3FileSystemRegistrar.java	20
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3ReadableSeekableByteChannel.java	145
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3ResourceId.java	153
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3WritableByteChannel.java	173
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/SSECustomerKey.java	59
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/package-info.java	4
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsAsyncClientProvider.java	56
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/BasicSnsClientProvider.java	56
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/PublishResponseCoder.java	24
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/SnsAsyncClientProvider.java	6
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/SnsClientProvider.java	6
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/SnsCoderProviderRegistrar.java	18
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/SnsIO.java	307
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/SnsResponse.java	27
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/SnsResponseCoder.java	67
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/package-info.java	4
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/BasicSqsClientProvider.java	56
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/MessageCoder.java	26
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/MessageCoderRegistrar.java	17
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SendMessageRequestCoder.java	27
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SendMessageRequestCoderRegistrar.java	18
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsCheckpointMark.java	40
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsClientProvider.java	6
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsIO.java	120
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsMessage.java	29
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsUnboundedReader.java	137
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/SqsUnboundedSource.java	57
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sqs/package-info.java	4
sdks/java/io/amqp/src/main/java/org/apache/beam/sdk/io/amqp/AmqpIO.java	231
sdks/java/io/amqp/src/main/java/org/apache/beam/sdk/io/amqp/AmqpMessageCoder.java	45
sdks/java/io/amqp/src/main/java/org/apache/beam/sdk/io/amqp/AmqpMessageCoderProviderRegistrar.java	17
sdks/java/io/amqp/src/main/java/org/apache/beam/sdk/io/amqp/package-info.java	4
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzfsResourceId.java	184
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystem.java	350
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystemRegistrar.java	19
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzureReadableSeekableByteChannel.java	85
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/DefaultBlobstoreClientBuilderFactory.java	47
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/package-info.java	4
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/AzureModule.java	136
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/AzurePipelineOptionsRegistrar.java	14
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/BlobstoreClientBuilderFactory.java	5
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/BlobstoreOptions.java	74
sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/package-info.java	4
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/CassandraIO.java	888
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/DefaultObjectMapper.java	26
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/DefaultObjectMapperFactory.java	22
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/Mapper.java	13
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/RingRange.java	26
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/SplitGenerator.java	120
sdks/java/io/cassandra/src/main/java/org/apache/beam/sdk/io/cassandra/package-info.java	4
sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/ClickHouseIO.java	300
sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/ClickHouseWriter.java	123
sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/TableSchema.java	241
sdks/java/io/clickhouse/src/main/java/org/apache/beam/sdk/io/clickhouse/package-info.java	4
sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIO.java	408
sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/ContextualTextIOSource.java	237
sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/RecordWithMetadata.java	64
sdks/java/io/contextualtextio/src/main/java/org/apache/beam/sdk/io/contextualtextio/package-info.java	3
sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/DebeziumIO.java	199
sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/KafkaSourceConsumerFn.java	255
sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/SourceRecordJson.java	148
sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/SourceRecordMapper.java	7
sdks/java/io/debezium/src/main/java/org/apache/beam/io/debezium/package-info.java	4
sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java	973
sdks/java/io/elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch/package-info.java	4
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/AvroRowWriter.java	40
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/AvroWriteRequest.java	16
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchLoads.java	593
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BatchedStreamingWrite.java	317
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BeamRowToStorageApiProto.java	278
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryAvroUtils.java	341
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryCoderProviderRegistrar.java	17
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryDlqProvider.java	61
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryHelpers.java	506
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java	1640
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOMetadata.java	37
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertError.java	43
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryInsertErrorCoder.java	58
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryOptions.java	67
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryQueryHelper.java	144
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryQuerySource.java	56
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryQuerySourceDef.java	142
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryResourceNaming.java	54
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryRowWriter.java	52
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySchemaRetrievalException.java	6
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServices.java	107
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesImpl.java	1218
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySourceBase.java	198
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQuerySourceDef.java	16
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageQuerySource.java	119
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageSourceBase.java	110
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageStreamSource.java	292
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryStorageTableSource.java	84
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryTableSource.java	72
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryTableSourceDef.java	80
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryUtils.java	715
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/CivilTimeEncoder.java	288
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/CreateTableHelpers.java	120
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/CreateTables.java	98
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/DynamicDestinations.java	84
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/DynamicDestinationsHelpers.java	328
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/ErrorContainer.java	31
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/GenerateShardedTable.java	23
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/InsertRetryPolicy.java	51
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/Mode.java	6
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/PassThroughThenCleanup.java	82
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/PrepareWrite.java	63
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/ReifyAsIterable.java	32
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/RetryManager.java	225
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/RowWriterFactory.java	102
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/SchemaAndRecord.java	17
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StandardSQLTypeName.java	16
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinations.java	48
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsBeamRow.java	41
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiDynamicDestinationsTableRow.java	46
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFinalizeWritesDoFn.java	139
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiFlushAndFinalizeDoFn.java	163
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiLoads.java	120
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWriteUnshardedRecords.java	262
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StorageApiWritesShardedRecords.java	420
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StreamingInserts.java	226
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/StreamingWriteTables.java	308
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableDestination.java	148
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableDestinationCoder.java	37
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableDestinationCoderV2.java	32
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableDestinationCoderV3.java	38
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowInfo.java	10
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowInfoCoder.java	45
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowJsonCoder.java	53
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowToStorageApiProto.java	259
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TableRowWriter.java	22
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TagWithUniqueIds.java	27
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TestBigQuery.java	284
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TestBigQueryOptions.java	11
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/TwoLevelMessageConverterCache.java	30
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteBundlesToFiles.java	210
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteGroupedRecordsToFiles.java	47
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WritePartition.java	140
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteRename.java	229
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteResult.java	73
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/WriteTables.java	391
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/package-info.java	1
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BeamRowToBigtableMutation.java	73
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableConfig.java	170
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java	815
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadOptions.java	55
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableRowToBeamRow.java	118
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableRowToBeamRowFlat.java	56
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableRowToBeamRowFn.java	22
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableService.java	33
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableServiceImpl.java	217
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteResult.java	14
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteResultCoder.java	31
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/CellValueParser.java	82
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/RowUtils.java	15
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/VendoredListenableFutureAdapter.java	38
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/package-info.java	4
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/common/GcpIoPipelineOptionsRegistrar.java	19
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/common/package-info.java	1
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/AdaptiveThrottler.java	53
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DataStoreV1SchemaIOProvider.java	122
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreIO.java	7
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/DatastoreV1.java	903
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/EntityToRow.java	105
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/MovingAverage.java	37
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/RowToEntity.java	139
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/package-info.java	4
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/DicomIO.java	98
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirIO.java	1023
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameter.java	68
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/FhirSearchParameterCoder.java	33
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java	423
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2Message.java	98
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HL7v2MessageCoder.java	49
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HealthcareApiClient.java	72
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HealthcareIOError.java	62
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HealthcareIOErrorCoder.java	45
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HealthcareIOErrorToTableRow.java	47
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/HttpHealthcareApiClient.java	797
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/JsonArrayCoder.java	26
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/WebPathParser.java	37
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/healthcare/package-info.java	4
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/AddTimestampAttribute.java	40
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/ExternalRead.java	80
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/ExternalWrite.java	62
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/NestedRowToMessage.java	64
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubSubPayloadTranslation.java	126
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubClient.java	271
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubCoderProviderRegistrar.java	22
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubDlqProvider.java	42
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java	294
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java	671
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubJsonClient.java	279
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessage.java	57
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessagePayloadOnlyCoder.java	31
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessageToRow.java	193
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessageWithAttributesAndMessageIdCoder.java	40
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessageWithAttributesCoder.java	45
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessageWithMessageIdCoder.java	30
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubMessages.java	47
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubOptions.java	49
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubSchemaIOProvider.java	252
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubTestClient.java	334
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSink.java	321
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubUnboundedSource.java	904
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsub.java	315
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsubOptions.java	5
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/TestPubsubSignal.java	323
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/package-info.java	1
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/AddUuidsTransform.java	27
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/CloudPubsubChecks.java	20
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/DlqProvider.java	53
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/InitialOffsetReader.java	8
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/InitialOffsetReaderImpl.java	31
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/LimitingTopicBacklogReader.java	55
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/OffsetByteProgress.java	11
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/OffsetByteRangeTracker.java	124
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PerServerPublisherCache.java	5
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PerSubscriptionPartitionSdf.java	90
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PublisherCache.java	49
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PublisherOptions.java	25
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PublisherOrError.java	24
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/Publishers.java	40
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java	33
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/PubsubLiteSink.java	119
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SerializableSubscriberFactory.java	13
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SerializableSupplier.java	5
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscribeTransform.java	114
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriberOptions.java	142
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartition.java	14
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartitionCoder.java	42
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartitionLoader.java	79
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartitionProcessor.java	11
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartitionProcessorFactory.java	13
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/SubscriptionPartitionProcessorImpl.java	124
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/TopicBacklogReader.java	9
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/TopicBacklogReaderImpl.java	46
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/TopicBacklogReaderSettings.java	55
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/Uuid.java	34
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/UuidCoder.java	26
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/UuidDeduplicationOptions.java	51
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/UuidDeduplicationTransform.java	28
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsublite/package-info.java	5
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/BatchSpannerRead.java	127
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/CreateTransactionFn.java	27
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationCellCounter.java	26
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationGroup.java	56
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationKeyEncoder.java	185
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationSizeEstimator.java	141
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/MutationUtils.java	316
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/NaiveSpannerRead.java	85
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/OrderedCode.java	450
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/ReadOperation.java	62
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/ReadSpannerSchema.java	77
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerAccessor.java	248
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerConfig.java	113
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIO.java	1044
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerSchema.java	127
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerTransformRegistrar.java	306
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/SpannerWriteResult.java	43
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/StructUtils.java	349
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/Transaction.java	15
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/spanner/package-info.java	4
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/BigqueryClient.java	421
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/BigqueryMatcher.java	139
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/BigtableUtils.java	24
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeBigQueryServices.java	93
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeDatasetService.java	464
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/FakeJobService.java	478
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/TableContainer.java	41
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/testing/package-info.java	3
sdks/java/io/hadoop-common/src/main/java/org/apache/beam/sdk/io/hadoop/SerializableConfiguration.java	70
sdks/java/io/hadoop-common/src/main/java/org/apache/beam/sdk/io/hadoop/WritableCoder.java	109
sdks/java/io/hadoop-common/src/main/java/org/apache/beam/sdk/io/hadoop/package-info.java	4
sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/HadoopFileSystem.java	298
sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/HadoopFileSystemModule.java	57
sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/HadoopFileSystemOptions.java	91
sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/HadoopFileSystemOptionsRegistrar.java	12
sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/HadoopFileSystemRegistrar.java	61
sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/HadoopResourceId.java	74
sdks/java/io/hadoop-file-system/src/main/java/org/apache/beam/sdk/io/hdfs/package-info.java	4
sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/ExternalSynchronization.java	11
sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HDFSSynchronization.java	115
sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormatIO.java	1244
sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/HadoopFormats.java	107
sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/IterableCombinerFn.java	81
sdks/java/io/hadoop-format/src/main/java/org/apache/beam/sdk/io/hadoop/format/package-info.java	4
sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseCoderProviderRegistrar.java	18
sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseIO.java	525
sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseMutationCoder.java	72
sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseReadSplittableDoFn.java	63
sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseResultCoder.java	25
sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/HBaseUtils.java	96
sdks/java/io/hbase/src/main/java/org/apache/beam/sdk/io/hbase/package-info.java	4
sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/HCatToRow.java	46
sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/HCatalogBeamSchema.java	56
sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/HCatalogIO.java	402
sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/HCatalogUtils.java	63
sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/PartitionPollerFn.java	37
sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/PartitionReaderFn.java	84
sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/SchemaUtils.java	67
sdks/java/io/hcatalog/src/main/java/org/apache/beam/sdk/io/hcatalog/package-info.java	4
sdks/java/io/hcatalog/src/main/resources/hive-site.xml	217
sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/DBShardInformation.java	35
sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/InfluxDbIO.java	509
sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/ShardInformation.java	32
sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/ShardInformationByStartDate.java	12
sdks/java/io/influxdb/src/main/java/org/apache/beam/sdk/io/influxdb/package-info.java	1
sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/BeamSchemaInferenceException.java	6
sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcIO.java	1016
sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcSchemaIOProvider.java	140
sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/JdbcUtil.java	215
sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/LogicalTypes.java	207
sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/SchemaUtil.java	320
sdks/java/io/jdbc/src/main/java/org/apache/beam/sdk/io/jdbc/package-info.java	4
sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsCheckpointMark.java	80
sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsIO.java	418
sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/JmsRecord.java	119
sdks/java/io/jms/src/main/java/org/apache/beam/sdk/io/jms/package-info.java	4
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ConfluentSchemaRegistryDeserializerProvider.java	108
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ConsumerSpEL.java	141
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/CustomTimestampPolicyWithLimitedDelay.java	46
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/DeserializerProvider.java	13
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCheckpointMark.java	76
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaCommitOffset.java	104
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaExactlyOnceSink.java	513
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java	1333
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIOUtils.java	73
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaPublishTimestampFunction.java	10
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaRecord.java	90
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaRecordCoder.java	108
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaSourceDescriptor.java	63
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaTimestampType.java	19
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedReader.java	544
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaUnboundedSource.java	115
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaWriter.java	105
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/LocalDeserializerProvider.java	62
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ProducerRecordCoder.java	118
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ProducerSpEL.java	94
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/ReadFromKafkaDoFn.java	316
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/TimestampPolicy.java	11
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/TimestampPolicyFactory.java	102
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/TopicPartitionCoder.java	33
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/WatchKafkaTopicPartitionDoFn.java	133
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/package-info.java	4
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/serialization/InstantDeserializer.java	19
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/serialization/InstantSerializer.java	19
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/serialization/package-info.java	4
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/AWSClientsProvider.java	11
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/BasicKinesisProvider.java	81
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/CheckpointGenerator.java	5
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/CustomOptional.java	61
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/DynamicCheckpointGenerator.java	45
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/GetKinesisRecordsResult.java	35
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisClientThrottledException.java	7
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisIO.java	421
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisPartitioner.java	6
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisReader.java	156
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisReaderCheckpoint.java	37
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisRecord.java	92
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisRecordCoder.java	52
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisShardClosedException.java	6
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisSource.java	118
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisTransformRegistrar.java	216
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/RateLimitPolicy.java	6
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/RateLimitPolicyFactory.java	34
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/RecordFilter.java	14
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardCheckpoint.java	119
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardReadersPool.java	237
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/ShardRecordsIterator.java	111
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/SimplifiedKinesisClient.java	189
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPoint.java	55
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPointShardsFinder.java	96
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StaticCheckpointGenerator.java	17
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/TransientKinesisException.java	7
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/WatermarkParameters.java	50
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/WatermarkPolicy.java	7
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/WatermarkPolicyFactory.java	87
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/package-info.java	4
sdks/java/io/kudu/src/main/java/org/apache/beam/sdk/io/kudu/KuduIO.java	279
sdks/java/io/kudu/src/main/java/org/apache/beam/sdk/io/kudu/KuduService.java	18
sdks/java/io/kudu/src/main/java/org/apache/beam/sdk/io/kudu/KuduServiceImpl.java	193
sdks/java/io/kudu/src/main/java/org/apache/beam/sdk/io/kudu/TableAndRecord.java	16
sdks/java/io/kudu/src/main/java/org/apache/beam/sdk/io/kudu/package-info.java	4
sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/AggregationQuery.java	46
sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/FindQuery.java	70
sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbGridFSIO.java	477
sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/MongoDbIO.java	587
sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/SSLUtils.java	44
sdks/java/io/mongodb/src/main/java/org/apache/beam/sdk/io/mongodb/package-info.java	4
sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/MqttIO.java	399
sdks/java/io/mqtt/src/main/java/org/apache/beam/sdk/io/mqtt/package-info.java	4
sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet/ParquetIO.java	898
sdks/java/io/parquet/src/main/java/org/apache/beam/sdk/io/parquet/package-info.java	4
sdks/java/io/rabbitmq/src/main/java/org/apache/beam/sdk/io/rabbitmq/RabbitMqIO.java	449
sdks/java/io/rabbitmq/src/main/java/org/apache/beam/sdk/io/rabbitmq/RabbitMqMessage.java	265
sdks/java/io/rabbitmq/src/main/java/org/apache/beam/sdk/io/rabbitmq/package-info.java	4
sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisConnectionConfiguration.java	92
sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/RedisIO.java	476
sdks/java/io/redis/src/main/java/org/apache/beam/sdk/io/redis/package-info.java	4
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/KeyPairUtils.java	43
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakeIO.java	1150
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/SnowflakePipelineOptions.java	92
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/crosslanguage/CrossLanguageConfiguration.java	130
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/crosslanguage/ReadBuilder.java	41
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/crosslanguage/SnowflakeTransformRegistrar.java	18
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/crosslanguage/WriteBuilder.java	66
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/crosslanguage/package-info.java	7
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/SnowflakeColumn.java	51
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/SnowflakeDataType.java	59
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/SnowflakeTableSchema.java	34
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/datetime/SnowflakeDate.java	12
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/datetime/SnowflakeDateTime.java	7
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/datetime/SnowflakeTime.java	12
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/datetime/SnowflakeTimestamp.java	7
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/datetime/SnowflakeTimestampLTZ.java	12
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/datetime/SnowflakeTimestampNTZ.java	12
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/datetime/SnowflakeTimestampTZ.java	12
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/datetime/package-info.java	1
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/logical/SnowflakeBoolean.java	12
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/logical/package-info.java	1
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/numeric/SnowflakeDecimal.java	10
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/numeric/SnowflakeDouble.java	7
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/numeric/SnowflakeFloat.java	12
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/numeric/SnowflakeInteger.java	7
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/numeric/SnowflakeNumber.java	34
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/numeric/SnowflakeNumeric.java	10
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/numeric/SnowflakeReal.java	7
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/numeric/package-info.java	1
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/package-info.java	1
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/structured/SnowflakeArray.java	12
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/structured/SnowflakeObject.java	12
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/structured/SnowflakeVariant.java	12
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/structured/package-info.java	1
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/text/SnowflakeBinary.java	37
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/text/SnowflakeChar.java	9
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/text/SnowflakeString.java	13
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/text/SnowflakeText.java	13
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/text/SnowflakeVarBinary.java	6
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/text/SnowflakeVarchar.java	37
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data/text/package-info.java	1
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/enums/CreateDisposition.java	5
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/enums/StreamingLogLevel.java	5
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/enums/WriteDisposition.java	6
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/enums/package-info.java	1
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/package-info.java	1
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/ServiceConfig.java	2
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/SnowflakeBatchServiceConfig.java	104
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/SnowflakeBatchServiceImpl.java	242
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/SnowflakeService.java	6
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/SnowflakeStreamingServiceConfig.java	23
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/SnowflakeStreamingServiceImpl.java	40
sdks/java/io/snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/services/package-info.java	1
sdks/java/io/solr/src/main/java/org/apache/beam/sdk/io/solr/AuthorizedSolrClient.java	57
sdks/java/io/solr/src/main/java/org/apache/beam/sdk/io/solr/JavaBinCodecCoder.java	68
sdks/java/io/solr/src/main/java/org/apache/beam/sdk/io/solr/SolrIO.java	432
sdks/java/io/solr/src/main/java/org/apache/beam/sdk/io/solr/package-info.java	4
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/HttpEventPublisher.java	185
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkEvent.java	60
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkEventWriter.java	249
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkIO.java	140
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/SplunkWriteError.java	39
sdks/java/io/splunk/src/main/java/org/apache/beam/sdk/io/splunk/package-info.java	4
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/BundleSplitter.java	37
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticBoundedSource.java	183
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticOptions.java	229
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticRecordsCheckpoint.java	41
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticSourceOptions.java	63
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticStep.java	120
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticUnboundedSource.java	148
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/SyntheticWatermark.java	40
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/delay/ReaderDelay.java	24
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/delay/SyntheticDelay.java	56
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/delay/package-info.java	4
sdks/java/io/synthetic/src/main/java/org/apache/beam/sdk/io/synthetic/package-info.java	4
sdks/java/io/thrift/src/main/java/org/apache/beam/sdk/io/thrift/ThriftCoder.java	48
sdks/java/io/thrift/src/main/java/org/apache/beam/sdk/io/thrift/ThriftIO.java	166
sdks/java/io/thrift/src/main/java/org/apache/beam/sdk/io/thrift/ThriftPayloadSerializerProvider.java	81
sdks/java/io/thrift/src/main/java/org/apache/beam/sdk/io/thrift/ThriftSchema.java	298
sdks/java/io/thrift/src/main/java/org/apache/beam/sdk/io/thrift/package-info.java	4
sdks/java/io/tika/src/main/java/org/apache/beam/sdk/io/tika/ParseResult.java	97
sdks/java/io/tika/src/main/java/org/apache/beam/sdk/io/tika/TikaIO.java	170
sdks/java/io/tika/src/main/java/org/apache/beam/sdk/io/tika/package-info.java	4
sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/JAXBCoder.java	151
sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/XmlIO.java	363
sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/XmlSource.java	278
sdks/java/io/xml/src/main/java/org/apache/beam/sdk/io/xml/package-info.java	4
sdks/java/maven-archetypes/gcp-bom-examples/src/main/resources/META-INF/maven/archetype-metadata.xml	26
sdks/java/maven-archetypes/starter/src/main/resources/META-INF/maven/archetype-metadata.xml	20
sdks/java/maven-archetypes/starter/src/main/resources/archetype-resources/src/main/java/StarterPipeline.java	32
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/Main.java	396
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/Monitor.java	42
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkConfiguration.java	549
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkLauncher.java	1130
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkOptions.java	334
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkPerf.java	74
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkQueryName.java	58
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkSuite.java	108
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/NexmarkUtils.java	571
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/PubsubHelper.java	158
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Auction.java	200
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionBid.java	76
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionCount.java	77
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/AuctionPrice.java	77
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Bid.java	135
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/BidsPerSession.java	75
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/CategoryPrice.java	83
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Done.java	73
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Event.java	151
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/IdNameReserve.java	86
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/KnownSize.java	4
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/NameCityStateId.java	97
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/Person.java	167
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/SellerPrice.java	76
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/package-info.java	1
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/sql/SelectEvent.java	47
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/sql/adapter/package-info.java	1
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/model/sql/package-info.java	1
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/package-info.java	1
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/AbstractSimulator.java	120
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/AuctionOrBid.java	9
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/BoundedSideInputJoin.java	50
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/BoundedSideInputJoinModel.java	51
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/NexmarkQuery.java	62
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/NexmarkQueryModel.java	63
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/NexmarkQueryTransform.java	26
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/NexmarkQueryUtil.java	137
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query0.java	41
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query0Model.java	34
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query1.java	33
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query10.java	312
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query11.java	58
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query12.java	53
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query13.java	76
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query1Model.java	45
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query2.java	32
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query2Model.java	48
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query3.java	181
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query3Model.java	80
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query4.java	65
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query4Model.java	137
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5.java	120
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query5Model.java	118
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query6.java	102
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query6Model.java	102
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query7.java	47
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query7Model.java	88
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query8.java	62
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query8Model.java	98
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query9.java	20
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/Query9Model.java	20
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/SessionSideInputJoin.java	65
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/SessionSideInputJoinModel.java	111
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBids.java	277
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/WinningBidsSimulator.java	138
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/package-info.java	1
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql/SqlBoundedSideInputJoin.java	105
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql/SqlQuery0.java	69
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql/SqlQuery1.java	38
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql/SqlQuery2.java	41
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql/SqlQuery3.java	70
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql/SqlQuery5.java	67
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql/SqlQuery7.java	48
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql/package-info.java	1
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/BoundedEventSource.java	117
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/UnboundedEventSource.java	239
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/Generator.java	156
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/GeneratorCheckpoint.java	49
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/GeneratorConfig.java	204
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/model/AuctionGenerator.java	78
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/model/BidGenerator.java	34
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/model/LongGenerator.java	11
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/model/PersonGenerator.java	73
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/model/PriceGenerator.java	7
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/model/StringsGenerator.java	42
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/model/package-info.java	1
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/generator/package-info.java	1
sdks/java/testing/nexmark/src/main/java/org/apache/beam/sdk/nexmark/sources/package-info.java	1
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/NamedTestResult.java	45
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/TestResult.java	5
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/metrics/ByteMonitor.java	16
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/metrics/IOITMetrics.java	56
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/metrics/MetricsReader.java	114
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/metrics/TimeMonitor.java	15
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/metrics/package-info.java	1
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/package-info.java	1
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/publishing/BigQueryClient.java	78
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/publishing/BigQueryResultsPublisher.java	35
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/publishing/ConsoleResultPublisher.java	15
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/publishing/InfluxDBPublisher.java	149
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/publishing/InfluxDBSettings.java	66
sdks/java/testing/test-utils/src/main/java/org/apache/beam/sdk/testutils/publishing/package-info.java	1
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/BeamSqlEnvRunner.java	153
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/BeamTpcds.java	6
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/CsvToRow.java	31
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/QueryReader.java	9
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/RowToCsv.java	25
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SqlTransformRunner.java	131
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/SummaryGenerator.java	122
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TableSchemaJSONLoader.java	68
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsOptions.java	27
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsOptionsRegistrar.java	12
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsParametersReader.java	65
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsRun.java	29
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsRunResult.java	72
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/TpcdsSchemas.java	632
sdks/java/testing/tpcds/src/main/java/org/apache/beam/sdk/tpcds/package-info.java	1
sdks/java/testing/tpcds/src/main/resources/queries/query1.sql	22
sdks/java/testing/tpcds/src/main/resources/queries/query10.sql	56
sdks/java/testing/tpcds/src/main/resources/queries/query11.sql	78
sdks/java/testing/tpcds/src/main/resources/queries/query12.sql	31
sdks/java/testing/tpcds/src/main/resources/queries/query13.sql	48
sdks/java/testing/tpcds/src/main/resources/queries/query14a.sql	78
sdks/java/testing/tpcds/src/main/resources/queries/query14b.sql	94
sdks/java/testing/tpcds/src/main/resources/queries/query15.sql	17
sdks/java/testing/tpcds/src/main/resources/queries/query16.sql	28
sdks/java/testing/tpcds/src/main/resources/queries/query17.sql	42
sdks/java/testing/tpcds/src/main/resources/queries/query18.sql	31
sdks/java/testing/tpcds/src/main/resources/queries/query19.sql	22
sdks/java/testing/tpcds/src/main/resources/queries/query2.sql	57
sdks/java/testing/tpcds/src/main/resources/queries/query20.sql	26
sdks/java/testing/tpcds/src/main/resources/queries/query21.sql	27
sdks/java/testing/tpcds/src/main/resources/queries/query22.sql	17
sdks/java/testing/tpcds/src/main/resources/queries/query23a.sql	49
sdks/java/testing/tpcds/src/main/resources/queries/query23b.sql	55
sdks/java/testing/tpcds/src/main/resources/queries/query24a.sql	19
sdks/java/testing/tpcds/src/main/resources/queries/query24b.sql	19
sdks/java/testing/tpcds/src/main/resources/queries/query25.sql	45
sdks/java/testing/tpcds/src/main/resources/queries/query26.sql	18
sdks/java/testing/tpcds/src/main/resources/queries/query27.sql	20
sdks/java/testing/tpcds/src/main/resources/queries/query28.sql	50
sdks/java/testing/tpcds/src/main/resources/queries/query29.sql	44
sdks/java/testing/tpcds/src/main/resources/queries/query3.sql	18
sdks/java/testing/tpcds/src/main/resources/queries/query30.sql	28
sdks/java/testing/tpcds/src/main/resources/queries/query31.sql	49
sdks/java/testing/tpcds/src/main/resources/queries/query32.sql	25
sdks/java/testing/tpcds/src/main/resources/queries/query33.sql	72
sdks/java/testing/tpcds/src/main/resources/queries/query34.sql	28
sdks/java/testing/tpcds/src/main/resources/queries/query35.sql	55
sdks/java/testing/tpcds/src/main/resources/queries/query36.sql	27
sdks/java/testing/tpcds/src/main/resources/queries/query37.sql	14
sdks/java/testing/tpcds/src/main/resources/queries/query38.sql	20
sdks/java/testing/tpcds/src/main/resources/queries/query39a.sql	24
sdks/java/testing/tpcds/src/main/resources/queries/query39b.sql	25
sdks/java/testing/tpcds/src/main/resources/queries/query4.sql	113
sdks/java/testing/tpcds/src/main/resources/queries/query40.sql	25
sdks/java/testing/tpcds/src/main/resources/queries/query41.sql	49
sdks/java/testing/tpcds/src/main/resources/queries/query42.sql	19
sdks/java/testing/tpcds/src/main/resources/queries/query43.sql	16
sdks/java/testing/tpcds/src/main/resources/queries/query44.sql	32
sdks/java/testing/tpcds/src/main/resources/queries/query45.sql	17
sdks/java/testing/tpcds/src/main/resources/queries/query46.sql	32
sdks/java/testing/tpcds/src/main/resources/queries/query47.sql	48
sdks/java/testing/tpcds/src/main/resources/queries/query48.sql	63
sdks/java/testing/tpcds/src/main/resources/queries/query49.sql	126
sdks/java/testing/tpcds/src/main/resources/queries/query5.sql	125
sdks/java/testing/tpcds/src/main/resources/queries/query50.sql	56
sdks/java/testing/tpcds/src/main/resources/queries/query51.sql	42
sdks/java/testing/tpcds/src/main/resources/queries/query52.sql	19
sdks/java/testing/tpcds/src/main/resources/queries/query53.sql	25
sdks/java/testing/tpcds/src/main/resources/queries/query54.sql	53
sdks/java/testing/tpcds/src/main/resources/queries/query55.sql	11
sdks/java/testing/tpcds/src/main/resources/queries/query56.sql	66
sdks/java/testing/tpcds/src/main/resources/queries/query57.sql	45
sdks/java/testing/tpcds/src/main/resources/queries/query58.sql	62
sdks/java/testing/tpcds/src/main/resources/queries/query59.sql	41
sdks/java/testing/tpcds/src/main/resources/queries/query6.sql	23
sdks/java/testing/tpcds/src/main/resources/queries/query60.sql	75
sdks/java/testing/tpcds/src/main/resources/queries/query61.sql	41
sdks/java/testing/tpcds/src/main/resources/queries/query62.sql	32
sdks/java/testing/tpcds/src/main/resources/queries/query63.sql	26
sdks/java/testing/tpcds/src/main/resources/queries/query64.sql	118
sdks/java/testing/tpcds/src/main/resources/queries/query65.sql	26
sdks/java/testing/tpcds/src/main/resources/queries/query66.sql	219
sdks/java/testing/tpcds/src/main/resources/queries/query67.sql	41
sdks/java/testing/tpcds/src/main/resources/queries/query68.sql	39
sdks/java/testing/tpcds/src/main/resources/queries/query69.sql	44
sdks/java/testing/tpcds/src/main/resources/queries/query7.sql	18
sdks/java/testing/tpcds/src/main/resources/queries/query70.sql	35
sdks/java/testing/tpcds/src/main/resources/queries/query71.sql	36
sdks/java/testing/tpcds/src/main/resources/queries/query72.sql	28
sdks/java/testing/tpcds/src/main/resources/queries/query73.sql	25
sdks/java/testing/tpcds/src/main/resources/queries/query74.sql	58
sdks/java/testing/tpcds/src/main/resources/queries/query75.sql	67
sdks/java/testing/tpcds/src/main/resources/queries/query76.sql	21
sdks/java/testing/tpcds/src/main/resources/queries/query77.sql	104
sdks/java/testing/tpcds/src/main/resources/queries/query78.sql	55
sdks/java/testing/tpcds/src/main/resources/queries/query79.sql	20
sdks/java/testing/tpcds/src/main/resources/queries/query8.sql	105
sdks/java/testing/tpcds/src/main/resources/queries/query80.sql	93
sdks/java/testing/tpcds/src/main/resources/queries/query81.sql	28
sdks/java/testing/tpcds/src/main/resources/queries/query82.sql	14
sdks/java/testing/tpcds/src/main/resources/queries/query83.sql	64
sdks/java/testing/tpcds/src/main/resources/queries/query84.sql	18
sdks/java/testing/tpcds/src/main/resources/queries/query85.sql	81
sdks/java/testing/tpcds/src/main/resources/queries/query86.sql	23
sdks/java/testing/tpcds/src/main/resources/queries/query87.sql	19
sdks/java/testing/tpcds/src/main/resources/queries/query88.sql	90
sdks/java/testing/tpcds/src/main/resources/queries/query89.sql	25
sdks/java/testing/tpcds/src/main/resources/queries/query9.sql	47
sdks/java/testing/tpcds/src/main/resources/queries/query90.sql	19
sdks/java/testing/tpcds/src/main/resources/queries/query91.sql	28
sdks/java/testing/tpcds/src/main/resources/queries/query92.sql	27
sdks/java/testing/tpcds/src/main/resources/queries/query93.sql	15
sdks/java/testing/tpcds/src/main/resources/queries/query94.sql	26
sdks/java/testing/tpcds/src/main/resources/queries/query95.sql	29
sdks/java/testing/tpcds/src/main/resources/queries/query96.sql	13
sdks/java/testing/tpcds/src/main/resources/queries/query97.sql	22
sdks/java/testing/tpcds/src/main/resources/queries/query98.sql	29
sdks/java/testing/tpcds/src/main/resources/queries/query99.sql	32
sdks/java/testing/watermarks/src/main/java/org/apache/beam/sdk/testing/watermarks/WatermarkLatency.java	180
sdks/java/testing/watermarks/src/main/java/org/apache/beam/sdk/testing/watermarks/package-info.java	1
sdks/python/MANIFEST.in	20
sdks/python/apache_beam/__init__.py	26
sdks/python/apache_beam/coders/__init__.py	3
sdks/python/apache_beam/coders/avro_record.py	8
sdks/python/apache_beam/coders/coder_impl.pxd	132
sdks/python/apache_beam/coders/coder_impl.py	900
sdks/python/apache_beam/coders/coders.py	874
sdks/python/apache_beam/coders/coders_test_common.py	563
sdks/python/apache_beam/coders/observable.py	10
sdks/python/apache_beam/coders/row_coder.py	162
sdks/python/apache_beam/coders/slow_stream.py	113
sdks/python/apache_beam/coders/stream.pxd	39
sdks/python/apache_beam/coders/stream.pyx	154
sdks/python/apache_beam/coders/typecoders.py	93
sdks/python/apache_beam/dataframe/__init__.py	1
sdks/python/apache_beam/dataframe/convert.py	130
sdks/python/apache_beam/dataframe/doctests.py	487
sdks/python/apache_beam/dataframe/expressions.py	196
sdks/python/apache_beam/dataframe/frame_base.py	413
sdks/python/apache_beam/dataframe/frames.py	2272
sdks/python/apache_beam/dataframe/io.py	447
sdks/python/apache_beam/dataframe/pandas_top_level_functions.py	135
sdks/python/apache_beam/dataframe/partitionings.py	104
sdks/python/apache_beam/dataframe/schemas.py	184
sdks/python/apache_beam/dataframe/transforms.py	346
sdks/python/apache_beam/error.py	8
sdks/python/apache_beam/internal/__init__.py	1
sdks/python/apache_beam/internal/gcp/__init__.py	1
sdks/python/apache_beam/internal/gcp/auth.py	72
sdks/python/apache_beam/internal/gcp/json_value.py	75
sdks/python/apache_beam/internal/http_client.py	23
sdks/python/apache_beam/internal/metrics/__init__.py	1
sdks/python/apache_beam/internal/metrics/cells.py	81
sdks/python/apache_beam/internal/metrics/metric.py	118
sdks/python/apache_beam/internal/pickler.py	160
sdks/python/apache_beam/internal/util.py	51
sdks/python/apache_beam/io/__init__.py	17
sdks/python/apache_beam/io/avroio.py	303
sdks/python/apache_beam/io/aws/__init__.py	1
sdks/python/apache_beam/io/aws/clients/__init__.py	1
sdks/python/apache_beam/io/aws/clients/s3/__init__.py	1
sdks/python/apache_beam/io/aws/clients/s3/boto3_client.py	175
sdks/python/apache_beam/io/aws/clients/s3/fake_client.py	136
sdks/python/apache_beam/io/aws/clients/s3/messages.py	68
sdks/python/apache_beam/io/aws/s3filesystem.py	117
sdks/python/apache_beam/io/aws/s3io.py	323
sdks/python/apache_beam/io/azure/__init__.py	1
sdks/python/apache_beam/io/azure/blobstoragefilesystem.py	115
sdks/python/apache_beam/io/azure/blobstorageio.py	335
sdks/python/apache_beam/io/concat_source.py	170
sdks/python/apache_beam/io/filebasedsink.py	287
sdks/python/apache_beam/io/filebasedsource.py	250
sdks/python/apache_beam/io/fileio.py	439
sdks/python/apache_beam/io/filesystem.py	428
sdks/python/apache_beam/io/filesystemio.py	133
sdks/python/apache_beam/io/filesystems.py	132
sdks/python/apache_beam/io/flink/__init__.py	1
sdks/python/apache_beam/io/flink/flink_streaming_impulse_source.py	40
sdks/python/apache_beam/io/gcp/__init__.py	10
sdks/python/apache_beam/io/gcp/big_query_query_to_table_pipeline.py	63
sdks/python/apache_beam/io/gcp/bigquery.py	1138
sdks/python/apache_beam/io/gcp/bigquery_avro_tools.py	73
sdks/python/apache_beam/io/gcp/bigquery_file_loads.py	818
sdks/python/apache_beam/io/gcp/bigquery_io_metadata.py	30
sdks/python/apache_beam/io/gcp/bigquery_io_read_pipeline.py	62
sdks/python/apache_beam/io/gcp/bigquery_read_internal.py	286
sdks/python/apache_beam/io/gcp/bigquery_tools.py	1162
sdks/python/apache_beam/io/gcp/bigtableio.py	67
sdks/python/apache_beam/io/gcp/datastore/__init__.py	1
sdks/python/apache_beam/io/gcp/datastore/v1new/__init__.py	1
sdks/python/apache_beam/io/gcp/datastore/v1new/adaptive_throttler.py	23
sdks/python/apache_beam/io/gcp/datastore/v1new/datastore_write_it_pipeline.py	99
sdks/python/apache_beam/io/gcp/datastore/v1new/datastoreio.py	275
sdks/python/apache_beam/io/gcp/datastore/v1new/helper.py	37
sdks/python/apache_beam/io/gcp/datastore/v1new/query_splitter.py	107
sdks/python/apache_beam/io/gcp/datastore/v1new/types.py	175
sdks/python/apache_beam/io/gcp/datastore/v1new/util.py	57
sdks/python/apache_beam/io/gcp/dicomclient.py	75
sdks/python/apache_beam/io/gcp/dicomio.py	260
sdks/python/apache_beam/io/gcp/experimental/__init__.py	1
sdks/python/apache_beam/io/gcp/experimental/spannerio.py	616
sdks/python/apache_beam/io/gcp/gce_metadata_util.py	16
sdks/python/apache_beam/io/gcp/gcsfilesystem.py	151
sdks/python/apache_beam/io/gcp/gcsio.py	401
sdks/python/apache_beam/io/gcp/gcsio_overrides.py	27
sdks/python/apache_beam/io/gcp/internal/__init__.py	1
sdks/python/apache_beam/io/gcp/internal/clients/__init__.py	1
sdks/python/apache_beam/io/gcp/internal/clients/bigquery/__init__.py	8
sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py	704
sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_messages.py	1524
sdks/python/apache_beam/io/gcp/internal/clients/storage/__init__.py	8
sdks/python/apache_beam/io/gcp/internal/clients/storage/storage_v1_client.py	904
sdks/python/apache_beam/io/gcp/internal/clients/storage/storage_v1_messages.py	801
sdks/python/apache_beam/io/gcp/pubsub.py	286
sdks/python/apache_beam/io/gcp/pubsub_it_pipeline.py	57
sdks/python/apache_beam/io/gcp/resource_identifiers.py	3
sdks/python/apache_beam/io/gcp/spanner.py	369
sdks/python/apache_beam/io/hadoopfilesystem.py	260
sdks/python/apache_beam/io/hdfs_integration_test/hdfscli.cfg	5
sdks/python/apache_beam/io/iobase.py	559
sdks/python/apache_beam/io/jdbc.py	106
sdks/python/apache_beam/io/kafka.py	83
sdks/python/apache_beam/io/kinesis.py	152
sdks/python/apache_beam/io/localfilesystem.py	150
sdks/python/apache_beam/io/mongodbio.py	345
sdks/python/apache_beam/io/parquetio.py	288
sdks/python/apache_beam/io/range_trackers.py	273
sdks/python/apache_beam/io/restriction_trackers.py	113
sdks/python/apache_beam/io/snowflake.py	212
sdks/python/apache_beam/io/source_test_utils.py	425
sdks/python/apache_beam/io/textio.py	337
sdks/python/apache_beam/io/tfrecordio.py	172
sdks/python/apache_beam/io/utils.py	36
sdks/python/apache_beam/io/watermark_estimators.py	73
sdks/python/apache_beam/metrics/__init__.py	2
sdks/python/apache_beam/metrics/cells.pxd	22
sdks/python/apache_beam/metrics/cells.py	284
sdks/python/apache_beam/metrics/execution.pxd	19
sdks/python/apache_beam/metrics/execution.py	188
sdks/python/apache_beam/metrics/metric.py	139
sdks/python/apache_beam/metrics/metricbase.py	55
sdks/python/apache_beam/metrics/monitoring_infos.py	239
sdks/python/apache_beam/ml/__init__.py	1
sdks/python/apache_beam/ml/gcp/__init__.py	1
sdks/python/apache_beam/ml/gcp/cloud_dlp.py	118
sdks/python/apache_beam/ml/gcp/naturallanguageml.py	77
sdks/python/apache_beam/ml/gcp/naturallanguageml_test_it.py	40
sdks/python/apache_beam/ml/gcp/recommendations_ai.py	359
sdks/python/apache_beam/ml/gcp/recommendations_ai_test_it.py	63
sdks/python/apache_beam/ml/gcp/videointelligenceml.py	112
sdks/python/apache_beam/ml/gcp/videointelligenceml_test_it.py	42
sdks/python/apache_beam/ml/gcp/visionml.py	152
sdks/python/apache_beam/ml/gcp/visionml_test_it.py	47
sdks/python/apache_beam/options/__init__.py	1
sdks/python/apache_beam/options/pipeline_options.py	1237
sdks/python/apache_beam/options/pipeline_options_validator.py	262
sdks/python/apache_beam/options/value_provider.py	102
sdks/python/apache_beam/pipeline.py	803
sdks/python/apache_beam/portability/__init__.py	1
sdks/python/apache_beam/portability/api/__init__.py	1
sdks/python/apache_beam/portability/common_urns.py	41
sdks/python/apache_beam/portability/python_urns.py	18
sdks/python/apache_beam/portability/utils.py	13
sdks/python/apache_beam/pvalue.py	350
sdks/python/apache_beam/runners/__init__.py	8
sdks/python/apache_beam/runners/common.pxd	98
sdks/python/apache_beam/runners/common.py	1004
sdks/python/apache_beam/runners/dataflow/__init__.py	2
sdks/python/apache_beam/runners/dataflow/dataflow_exercise_metrics_pipeline.py	132
sdks/python/apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline.py	62
sdks/python/apache_beam/runners/dataflow/dataflow_metrics.py	211
sdks/python/apache_beam/runners/dataflow/dataflow_runner.py	1152
sdks/python/apache_beam/runners/dataflow/internal/__init__.py	1
sdks/python/apache_beam/runners/dataflow/internal/apiclient.py	918
sdks/python/apache_beam/runners/dataflow/internal/clients/__init__.py	1
sdks/python/apache_beam/runners/dataflow/internal/clients/cloudbuild/__init__.py	8
sdks/python/apache_beam/runners/dataflow/internal/clients/cloudbuild/cloudbuild_v1_messages.py	549
sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/__init__.py	8
sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py	1016
sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py	2067
sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/message_matchers.py	65
sdks/python/apache_beam/runners/dataflow/internal/names.py	68
sdks/python/apache_beam/runners/dataflow/native_io/__init__.py	1
sdks/python/apache_beam/runners/dataflow/native_io/iobase.py	144
sdks/python/apache_beam/runners/dataflow/ptransform_overrides.py	211
sdks/python/apache_beam/runners/direct/__init__.py	1
sdks/python/apache_beam/runners/direct/bundle_factory.py	98
sdks/python/apache_beam/runners/direct/clock.py	17
sdks/python/apache_beam/runners/direct/consumer_tracking_pipeline_visitor.py	33
sdks/python/apache_beam/runners/direct/direct_metrics.py	84
sdks/python/apache_beam/runners/direct/direct_runner.py	401
sdks/python/apache_beam/runners/direct/direct_userstate.py	239
sdks/python/apache_beam/runners/direct/evaluation_context.py	258
sdks/python/apache_beam/runners/direct/executor.py	514
sdks/python/apache_beam/runners/direct/helper_transforms.py	72
sdks/python/apache_beam/runners/direct/sdf_direct_runner.py	338
sdks/python/apache_beam/runners/direct/transform_evaluator.py	898
sdks/python/apache_beam/runners/direct/util.py	48
sdks/python/apache_beam/runners/direct/watermark_manager.py	219
sdks/python/apache_beam/runners/interactive/__init__.py	1
sdks/python/apache_beam/runners/interactive/augmented_pipeline.py	73
sdks/python/apache_beam/runners/interactive/background_caching_job.py	164
sdks/python/apache_beam/runners/interactive/cache_manager.py	158
sdks/python/apache_beam/runners/interactive/caching/__init__.py	1
sdks/python/apache_beam/runners/interactive/caching/cacheable.py	40
sdks/python/apache_beam/runners/interactive/caching/read_cache.py	84
sdks/python/apache_beam/runners/interactive/caching/streaming_cache.py	286
sdks/python/apache_beam/runners/interactive/caching/write_cache.py	116
sdks/python/apache_beam/runners/interactive/display/__init__.py	1
sdks/python/apache_beam/runners/interactive/display/display_manager.py	107
sdks/python/apache_beam/runners/interactive/display/interactive_pipeline_graph.py	87
sdks/python/apache_beam/runners/interactive/display/pcoll_visualization.py	244
sdks/python/apache_beam/runners/interactive/display/pipeline_graph.py	149
sdks/python/apache_beam/runners/interactive/display/pipeline_graph_renderer.py	55
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/SidePanel.ts	84
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/common/HtmlView.tsx	75
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/index.ts	53
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/inspector/InspectableList.tsx	85
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/inspector/InspectableListItem.tsx	66
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/inspector/InspectableView.tsx	172
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/inspector/InspectableViewModel.ts	151
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/inspector/Inspectables.tsx	63
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/inspector/InteractiveInspector.tsx	88
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/inspector/InteractiveInspectorWidget.tsx	15
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/kernel/InterruptKernelButton.tsx	49
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/kernel/KernelCode.ts	7
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/src/kernel/KernelModel.ts	138
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/style/index.css	5
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/style/inspector/InspectableView.css	4
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/style/inspector/Inspectables.css	3
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/style/inspector/InteractiveInspector.css	4
sdks/python/apache_beam/runners/interactive/extensions/apache-beam-jupyterlab-sidepanel/style/mdc-theme.css	36
sdks/python/apache_beam/runners/interactive/interactive_beam.py	243
sdks/python/apache_beam/runners/interactive/interactive_environment.py	305
sdks/python/apache_beam/runners/interactive/interactive_runner.py	133
sdks/python/apache_beam/runners/interactive/messaging/__init__.py	1
sdks/python/apache_beam/runners/interactive/messaging/interactive_environment_inspector.py	88
sdks/python/apache_beam/runners/interactive/options/__init__.py	1
sdks/python/apache_beam/runners/interactive/options/capture_control.py	31
sdks/python/apache_beam/runners/interactive/options/capture_limiters.py	67
sdks/python/apache_beam/runners/interactive/options/interactive_options.py	15
sdks/python/apache_beam/runners/interactive/pipeline_fragment.py	143
sdks/python/apache_beam/runners/interactive/pipeline_instrument.py	493
sdks/python/apache_beam/runners/interactive/recording_manager.py	259
sdks/python/apache_beam/runners/interactive/testing/__init__.py	1
sdks/python/apache_beam/runners/interactive/testing/integration/__init__.py	1
sdks/python/apache_beam/runners/interactive/testing/integration/notebook_executor.py	103
sdks/python/apache_beam/runners/interactive/testing/integration/screen_diff.py	141
sdks/python/apache_beam/runners/interactive/testing/mock_ipython.py	14
sdks/python/apache_beam/runners/interactive/testing/pipeline_assertion.py	59
sdks/python/apache_beam/runners/interactive/user_pipeline_tracker.py	53
sdks/python/apache_beam/runners/interactive/utils.py	146
sdks/python/apache_beam/runners/internal/__init__.py	1
sdks/python/apache_beam/runners/internal/names.py	6
sdks/python/apache_beam/runners/job/__init__.py	1
sdks/python/apache_beam/runners/job/manager.py	19
sdks/python/apache_beam/runners/job/utils.py	12
sdks/python/apache_beam/runners/pipeline_context.py	210
sdks/python/apache_beam/runners/portability/__init__.py	1
sdks/python/apache_beam/runners/portability/abstract_job_service.py	258
sdks/python/apache_beam/runners/portability/artifact_service.py	271
sdks/python/apache_beam/runners/portability/expansion_service.py	66
sdks/python/apache_beam/runners/portability/flink_runner.py	83
sdks/python/apache_beam/runners/portability/flink_uber_jar_job_server.py	182
sdks/python/apache_beam/runners/portability/fn_api_runner/__init__.py	1
sdks/python/apache_beam/runners/portability/fn_api_runner/execution.py	715
sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py	831
sdks/python/apache_beam/runners/portability/fn_api_runner/translations.py	1512
sdks/python/apache_beam/runners/portability/fn_api_runner/trigger_manager.py	352
sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py	818
sdks/python/apache_beam/runners/portability/job_server.py	104
sdks/python/apache_beam/runners/portability/local_job_service.py	304
sdks/python/apache_beam/runners/portability/local_job_service_main.py	126
sdks/python/apache_beam/runners/portability/portable_metrics.py	33
sdks/python/apache_beam/runners/portability/portable_runner.py	457
sdks/python/apache_beam/runners/portability/sdk_container_builder.py	266
sdks/python/apache_beam/runners/portability/spark_runner.py	67
sdks/python/apache_beam/runners/portability/spark_uber_jar_job_server.py	199
sdks/python/apache_beam/runners/portability/stager.py	510
sdks/python/apache_beam/runners/runner.py	212
sdks/python/apache_beam/runners/sdf_utils.py	132
sdks/python/apache_beam/runners/worker/__init__.py	1
sdks/python/apache_beam/runners/worker/bundle_processor.py	1487
sdks/python/apache_beam/runners/worker/channel_factory.py	22
sdks/python/apache_beam/runners/worker/crossplatform_time.h	32
sdks/python/apache_beam/runners/worker/crossplatform_unistd.h	17
sdks/python/apache_beam/runners/worker/data_plane.py	467
sdks/python/apache_beam/runners/worker/log_handler.py	134
sdks/python/apache_beam/runners/worker/logger.py	69
sdks/python/apache_beam/runners/worker/opcounters.pxd	40
sdks/python/apache_beam/runners/worker/opcounters.py	172
sdks/python/apache_beam/runners/worker/operation_specs.py	169
sdks/python/apache_beam/runners/worker/operations.pxd	77
sdks/python/apache_beam/runners/worker/operations.py	851
sdks/python/apache_beam/runners/worker/sdk_worker.py	891
sdks/python/apache_beam/runners/worker/sdk_worker_main.py	168
sdks/python/apache_beam/runners/worker/sideinputs.py	138
sdks/python/apache_beam/runners/worker/statecache.py	142
sdks/python/apache_beam/runners/worker/statesampler.py	113
sdks/python/apache_beam/runners/worker/statesampler_fast.pxd	31
sdks/python/apache_beam/runners/worker/statesampler_fast.pyx	146
sdks/python/apache_beam/runners/worker/statesampler_slow.py	61
sdks/python/apache_beam/runners/worker/worker_id_interceptor.py	39
sdks/python/apache_beam/runners/worker/worker_pool_main.py	157
sdks/python/apache_beam/runners/worker/worker_status.py	122
sdks/python/apache_beam/testing/__init__.py	1
sdks/python/apache_beam/testing/benchmarks/__init__.py	1
sdks/python/apache_beam/testing/benchmarks/chicago_taxi/__init__.py	1
sdks/python/apache_beam/testing/benchmarks/chicago_taxi/preprocess.py	162
sdks/python/apache_beam/testing/benchmarks/chicago_taxi/process_tfma.py	127
sdks/python/apache_beam/testing/benchmarks/chicago_taxi/setup.py	19
sdks/python/apache_beam/testing/benchmarks/chicago_taxi/tfdv_analyze_and_validate.py	150
sdks/python/apache_beam/testing/benchmarks/chicago_taxi/trainer/__init__.py	1
sdks/python/apache_beam/testing/benchmarks/chicago_taxi/trainer/model.py	66
sdks/python/apache_beam/testing/benchmarks/chicago_taxi/trainer/task.py	105
sdks/python/apache_beam/testing/benchmarks/chicago_taxi/trainer/taxi.py	97
sdks/python/apache_beam/testing/benchmarks/nexmark/__init__.py	1
sdks/python/apache_beam/testing/benchmarks/nexmark/models/__init__.py	1
sdks/python/apache_beam/testing/benchmarks/nexmark/models/auction_bid.py	28
sdks/python/apache_beam/testing/benchmarks/nexmark/models/field_name.py	19
sdks/python/apache_beam/testing/benchmarks/nexmark/models/nexmark_model.py	155
sdks/python/apache_beam/testing/benchmarks/nexmark/monitor.py	28
sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_launcher.py	314
sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_perf.py	17
sdks/python/apache_beam/testing/benchmarks/nexmark/nexmark_util.py	139
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/__init__.py	1
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/nexmark_query_util.py	48
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query0.py	11
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query1.py	15
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query10.py	83
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query11.py	22
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query12.py	21
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query2.py	13
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query3.py	91
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query4.py	26
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query5.py	48
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query6.py	43
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query7.py	20
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query8.py	37
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/query9.py	8
sdks/python/apache_beam/testing/benchmarks/nexmark/queries/winning_bids.py	133
sdks/python/apache_beam/testing/data/trigger_transcripts.yaml	243
sdks/python/apache_beam/testing/datatype_inference.py	66
sdks/python/apache_beam/testing/extra_assertions.py	25
sdks/python/apache_beam/testing/load_tests/__init__.py	1
sdks/python/apache_beam/testing/load_tests/load_test_metrics_utils.py	352
sdks/python/apache_beam/testing/metric_result_matchers.py	133
sdks/python/apache_beam/testing/pipeline_verifiers.py	85
sdks/python/apache_beam/testing/synthetic_pipeline.py	653
sdks/python/apache_beam/testing/util.py	165
sdks/python/apache_beam/tools/__init__.py	1
sdks/python/apache_beam/tools/coders_microbenchmark.py	146
sdks/python/apache_beam/tools/distribution_counter_microbenchmark.py	34
sdks/python/apache_beam/tools/fn_api_runner_microbenchmark.py	71
sdks/python/apache_beam/tools/map_fn_microbenchmark.py	30
sdks/python/apache_beam/tools/runtime_type_check_microbenchmark.py	77
sdks/python/apache_beam/tools/sideinput_microbenchmark.py	43
sdks/python/apache_beam/tools/teststream_microbenchmark.py	65
sdks/python/apache_beam/tools/utils.py	83
sdks/python/apache_beam/transforms/__init__.py	11
sdks/python/apache_beam/transforms/combinefn_lifecycle_pipeline.py	81
sdks/python/apache_beam/transforms/combiners.py	661
sdks/python/apache_beam/transforms/core.py	1571
sdks/python/apache_beam/transforms/create_source.py	61
sdks/python/apache_beam/transforms/cy_combiners.pxd	72
sdks/python/apache_beam/transforms/cy_combiners.py	253
sdks/python/apache_beam/transforms/cy_dataflow_distribution_counter.pxd	19
sdks/python/apache_beam/transforms/cy_dataflow_distribution_counter.pyx	67
sdks/python/apache_beam/transforms/deduplicate.py	77
sdks/python/apache_beam/transforms/display.py	199
sdks/python/apache_beam/transforms/environments.py	597
sdks/python/apache_beam/transforms/external.py	349
sdks/python/apache_beam/transforms/external_java.py	120
sdks/python/apache_beam/transforms/periodicsequence.py	128
sdks/python/apache_beam/transforms/ptransform.py	623
sdks/python/apache_beam/transforms/py_dataflow_distribution_counter.py	77
sdks/python/apache_beam/transforms/resources.py	137
sdks/python/apache_beam/transforms/sideinputs.py	57
sdks/python/apache_beam/transforms/sql.py	17
sdks/python/apache_beam/transforms/stats.pxd	37
sdks/python/apache_beam/transforms/stats.py	548
sdks/python/apache_beam/transforms/timeutil.py	69
sdks/python/apache_beam/transforms/trigger.py	1053
sdks/python/apache_beam/transforms/userstate.py	213
sdks/python/apache_beam/transforms/util.py	754
sdks/python/apache_beam/transforms/window.py	330
sdks/python/apache_beam/typehints/__init__.py	3
sdks/python/apache_beam/typehints/decorators.py	536
sdks/python/apache_beam/typehints/decorators_test_py3.py	150
sdks/python/apache_beam/typehints/native_type_compatibility.py	210
sdks/python/apache_beam/typehints/opcodes.py	253
sdks/python/apache_beam/typehints/row_type.py	22
sdks/python/apache_beam/typehints/schemas.py	263
sdks/python/apache_beam/typehints/sharded_key_type.py	48
sdks/python/apache_beam/typehints/trivial_inference.py	388
sdks/python/apache_beam/typehints/trivial_inference_test_py3.py	20
sdks/python/apache_beam/typehints/typecheck.py	234
sdks/python/apache_beam/typehints/typecheck_test_py3.py	229
sdks/python/apache_beam/typehints/typed_pipeline_test_py3.py	368
sdks/python/apache_beam/typehints/typehints.py	671
sdks/python/apache_beam/typehints/typehints_test_py3.py	201
sdks/python/apache_beam/utils/__init__.py	1
sdks/python/apache_beam/utils/annotations.py	43
sdks/python/apache_beam/utils/counters.pxd	8
sdks/python/apache_beam/utils/counters.py	116
sdks/python/apache_beam/utils/histogram.py	163
sdks/python/apache_beam/utils/interactive_utils.py	43
sdks/python/apache_beam/utils/plugin.py	13
sdks/python/apache_beam/utils/processes.py	72
sdks/python/apache_beam/utils/profiler.py	117
sdks/python/apache_beam/utils/proto_utils.py	64
sdks/python/apache_beam/utils/retry.py	137
sdks/python/apache_beam/utils/sentinel.py	3
sdks/python/apache_beam/utils/sharded_key.py	22
sdks/python/apache_beam/utils/shared.py	57
sdks/python/apache_beam/utils/subprocess_server.py	236
sdks/python/apache_beam/utils/thread_pool_executor.py	80
sdks/python/apache_beam/utils/timestamp.py	211
sdks/python/apache_beam/utils/urns.py	90
sdks/python/apache_beam/utils/windowed_value.pxd	28
sdks/python/apache_beam/utils/windowed_value.py	215
sdks/python/apache_beam/version.py	1
sdks/python/conftest.py	17
sdks/python/container/boot.go	250
sdks/python/container/license_scripts/dep_urls_py.yaml	104
sdks/python/container/license_scripts/pull_licenses_py.py	149
sdks/python/container/piputil.go	114
sdks/python/findSupportedPython.groovy	37
sdks/python/gen_protos.py	279
sdks/python/setup.cfg	36
sdks/python/setup.py	246