Path	Lines of Code
build.sbt	1737
catalog-info.yaml	7
codecov.yaml	5
integration/src/main/resources/avro-integration-test/folder-a/folder-b/shakespeare-schema.avsc	17
integration/src/main/scala/com/spotify/scio/PopulateTestData.scala	31
integration/src/main/scala/com/spotify/scio/bigquery/PopulateTestData.scala	208
integration/src/main/scala/com/spotify/scio/jdbc/PopulateTestData.scala	36
integration/src/main/scala/com/spotify/scio/jdbc/SqlServer.scala	19
project/BuildCredentials.scala	34
project/CheckBeamDependencies.scala	57
project/Exclude.scala	15
project/JavaOptions.scala	95
project/ScalacOptions.scala	63
project/SoccoIndex.scala	110
project/plugins.sbt	26
scalafix/build.sbt	183
scalafix/input-0_10/src/main/scala/fix/v0_10_0/FixCoderPropagation.scala	12
scalafix/input-0_12/src/main/scala/fix/v0_12_0/FixBqSaveAsTable.scala	23
scalafix/input-0_12/src/main/scala/fix/v0_12_0/FixPubsubSpecializations.scala	98
scalafix/input-0_13/src/main/scala/fix/v0_13_0/FixSkewedJoins.scala	36
scalafix/input-0_13/src/main/scala/fix/v0_13_0/FixTaps.scala	21
scalafix/input-0_13/src/main/scala/fix/v0_13_0/FixTfParameter.scala	17
scalafix/input-0_14/src/main/scala/fix/v0_14_0/AvroRecords.scala	14
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder1.scala	10
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder10.scala	13
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder11.scala	10
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder12.scala	9
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder13.scala	7
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder14.scala	7
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder15.scala	9
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder16.scala	7
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder2.scala	9
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder3.scala	6
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder4.scala	6
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder5.scala	8
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder6.scala	5
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder7.scala	5
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder8.scala	9
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder9.scala	22
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroSchemasPackage1.scala	7
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroSchemasPackage2.scala	5
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroSchemasPackage3.scala	6
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixAvroSchemasPackage4.scala	7
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixDynamicAvro1.scala	11
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixDynamicAvro2.scala	8
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixDynamicAvro3.scala	10
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixGenericAvro.scala	18
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixLogicalTypeSuppliers.scala	77
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixQuery.scala	13
scalafix/input-0_14/src/main/scala/fix/v0_14_0/FixSMBCharSequenceKey.scala	23
scalafix/input-0_7/src/main/scala/fix/v0_7_0/AddMissingImports.scala	13
scalafix/input-0_7/src/main/scala/fix/v0_7_0/BQClientRefactoring.scala	38
scalafix/input-0_7/src/main/scala/fix/v0_7_0/FixAvroIO.scala	37
scalafix/input-0_7/src/main/scala/fix/v0_7_0/RewriteSysProp.scala	11
scalafix/input-0_8/src/main/scala/fix/v0_8_0/FixBigQueryDeprecations.scala	13
scalafix/input-0_8/src/main/scala/fix/v0_8_0/FixContextClose.scala	8
scalafix/input-0_8/src/main/scala/fix/v0_8_0/FixJoinNames.scala	58
scalafix/input-0_8/src/main/scala/fix/v0_8_0/FixRunWithContext.scala	38
scalafix/input-0_8/src/main/scala/fix/v0_8_0/FixScioIO.scala	27
scalafix/input-0_8/src/main/scala/fix/v0_8_0/FixSyntaxImports.scala	13
scalafix/input-0_8/src/main/scala/fix/v0_8_0/FixTensorflow.scala	9
scalafix/output-0_10/src/main/scala/fix/v0_10_0/FixCoderPropagation.scala	12
scalafix/output-0_12/src/main/scala/fix/v0_12_0/FixBqSaveAsTable.scala	25
scalafix/output-0_12/src/main/scala/fix/v0_12_0/FixPubsubSpecializations.scala	98
scalafix/output-0_13/src/main/scala/fix/v0_13_0/FixSkewedJoins.scala	13
scalafix/output-0_13/src/main/scala/fix/v0_13_0/FixTaps.scala	24
scalafix/output-0_13/src/main/scala/fix/v0_13_0/FixTfParameter.scala	17
scalafix/output-0_14/src/main/scala/fix/v0_14_0/AvroRecords.scala	14
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder1.scala	10
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder10.scala	13
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder11.scala	11
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder12.scala	10
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder13.scala	8
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder14.scala	8
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder15.scala	10
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder16.scala	8
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder2.scala	10
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder3.scala	7
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder4.scala	7
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder5.scala	9
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder6.scala	6
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder7.scala	6
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder8.scala	10
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroCoder9.scala	23
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroSchemasPackage1.scala	8
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroSchemasPackage2.scala	6
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroSchemasPackage3.scala	7
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixAvroSchemasPackage4.scala	7
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixDynamicAvro1.scala	12
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixDynamicAvro2.scala	9
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixDynamicAvro3.scala	11
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixGenericAvro.scala	18
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixLogicalTypeSuppliers.scala	28
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixQuery.scala	13
scalafix/output-0_14/src/main/scala/fix/v0_14_0/FixSMBCharSequenceKey.scala	23
scalafix/output-0_7/src/main/scala/fix/v0_7_0/AddMissingImports.scala	14
scalafix/output-0_7/src/main/scala/fix/v0_7_0/BQClientRefactoring.scala	39
scalafix/output-0_7/src/main/scala/fix/v0_7_0/FixAvroIO.scala	40
scalafix/output-0_7/src/main/scala/fix/v0_7_0/RewriteSysProp.scala	11
scalafix/output-0_8/src/main/scala/fix/v0_8_0/FixBigQueryDeprecations.scala	13
scalafix/output-0_8/src/main/scala/fix/v0_8_0/FixContextClose.scala	8
scalafix/output-0_8/src/main/scala/fix/v0_8_0/FixJoinNames.scala	58
scalafix/output-0_8/src/main/scala/fix/v0_8_0/FixRunWithContext.scala	38
scalafix/output-0_8/src/main/scala/fix/v0_8_0/FixScioIO.scala	27
scalafix/output-0_8/src/main/scala/fix/v0_8_0/FixSyntaxImports.scala	13
scalafix/output-0_8/src/main/scala/fix/v0_8_0/FixTensorflow.scala	9
scalafix/project/ConfigAxis.scala	2
scalafix/project/Scio.scala	11
scalafix/project/plugins.sbt	4
scalafix/rules/src/main/scala/fix/v0_10_0/FixCoderPropagation.scala	19
scalafix/rules/src/main/scala/fix/v0_12_0/FixBqSaveAsTable.scala	30
scalafix/rules/src/main/scala/fix/v0_12_0/FixPubsubSpecializations.scala	164
scalafix/rules/src/main/scala/fix/v0_13_0/FixSkewedJoins.scala	69
scalafix/rules/src/main/scala/fix/v0_13_0/FixTaps.scala	50
scalafix/rules/src/main/scala/fix/v0_13_0/FixTfParameter.scala	18
scalafix/rules/src/main/scala/fix/v0_14_0/FixAvroCoder.scala	218
scalafix/rules/src/main/scala/fix/v0_14_0/FixAvroSchemasPackage.scala	107
scalafix/rules/src/main/scala/fix/v0_14_0/FixDynamicAvro.scala	21
scalafix/rules/src/main/scala/fix/v0_14_0/FixGenericAvro.scala	28
scalafix/rules/src/main/scala/fix/v0_14_0/FixLogicalTypeSupplier.scala	101
scalafix/rules/src/main/scala/fix/v0_14_0/FixQuery.scala	25
scalafix/rules/src/main/scala/fix/v0_14_0/FixSMBCharSequenceKey.scala	30
scalafix/rules/src/main/scala/fix/v0_7_0/AddMissingImports.scala	41
scalafix/rules/src/main/scala/fix/v0_7_0/BQClientRefactoring.scala	48
scalafix/rules/src/main/scala/fix/v0_7_0/FixAvroIO.scala	54
scalafix/rules/src/main/scala/fix/v0_7_0/RewriteSysProp.scala	88
scalafix/rules/src/main/scala/fix/v0_8_0/ConsistenceJoinNames.scala	60
scalafix/rules/src/main/scala/fix/v0_8_0/FixBigQueryDeprecations.scala	20
scalafix/rules/src/main/scala/fix/v0_8_0/FixContextClose.scala	14
scalafix/rules/src/main/scala/fix/v0_8_0/FixRunWithContext.scala	29
scalafix/rules/src/main/scala/fix/v0_8_0/FixScioIO.scala	23
scalafix/rules/src/main/scala/fix/v0_8_0/FixSyntaxImports.scala	28
scalafix/rules/src/main/scala/fix/v0_8_0/FixTensorflow.scala	9
scio-avro/src/main/scala/com/spotify/scio/avro/AvroDatumFactory.scala	90
scio-avro/src/main/scala/com/spotify/scio/avro/AvroIO.scala	153
scio-avro/src/main/scala/com/spotify/scio/avro/AvroSysProps.scala	9
scio-avro/src/main/scala/com/spotify/scio/avro/AvroTypedIO.scala	40
scio-avro/src/main/scala/com/spotify/scio/avro/ObjectFileIO.scala	31
scio-avro/src/main/scala/com/spotify/scio/avro/ProtobufIO.scala	28
scio-avro/src/main/scala/com/spotify/scio/avro/dynamic/package.scala	2
scio-avro/src/main/scala/com/spotify/scio/avro/dynamic/syntax/AvroDynamicSCollectionSyntax.scala	149
scio-avro/src/main/scala/com/spotify/scio/avro/io/AvroFileStorage.scala	53
scio-avro/src/main/scala/com/spotify/scio/avro/package.scala	7
scio-avro/src/main/scala/com/spotify/scio/avro/schemas/instances/AvroInstances.scala	63
scio-avro/src/main/scala/com/spotify/scio/avro/schemas/package.scala	2
scio-avro/src/main/scala/com/spotify/scio/avro/syntax/SCollectionSyntax.scala	228
scio-avro/src/main/scala/com/spotify/scio/avro/syntax/ScioContextSyntax.scala	86
scio-avro/src/main/scala/com/spotify/scio/avro/syntax/Syntax.scala	2
scio-avro/src/main/scala/com/spotify/scio/avro/taps.scala	105
scio-avro/src/main/scala/com/spotify/scio/avro/types/AvroType.scala	63
scio-avro/src/main/scala/com/spotify/scio/avro/types/ConverterProvider.scala	148
scio-avro/src/main/scala/com/spotify/scio/avro/types/MacroUtil.scala	25
scio-avro/src/main/scala/com/spotify/scio/avro/types/SchemaProvider.scala	90
scio-avro/src/main/scala/com/spotify/scio/avro/types/SchemaUtil.scala	138
scio-avro/src/main/scala/com/spotify/scio/avro/types/TypeProvider.scala	393
scio-avro/src/main/scala/com/spotify/scio/avro/types/types.scala	7
scio-avro/src/main/scala/com/spotify/scio/coders/AvroBytesUtil.scala	37
scio-avro/src/main/scala/com/spotify/scio/coders/AvroKryoRegistrar.scala	12
scio-avro/src/main/scala/com/spotify/scio/coders/avro/AvroCoders.scala	88
scio-avro/src/main/scala/com/spotify/scio/coders/instances/kryo/AvroSerializer.scala	41
scio-avro/src/main/scala/com/spotify/scio/protobuf/util/ProtobufUtil.scala	22
scio-cassandra/cassandra3/src/main/java/com/spotify/scio/cassandra/CompatUtil.java	53
scio-cassandra/cassandra3/src/main/java/org/apache/cassandra/hadoop/cql3/CqlBulkRecordWriterUtil.java	42
scio-cassandra/cassandra3/src/main/scala/com/spotify/scio/cassandra/BulkOperations.scala	110
scio-cassandra/cassandra3/src/main/scala/com/spotify/scio/cassandra/CassandraIO.scala	31
scio-cassandra/cassandra3/src/main/scala/com/spotify/scio/cassandra/DataTypeExternalizer.scala	52
scio-cassandra/cassandra3/src/main/scala/com/spotify/scio/cassandra/package.scala	22
scio-core/src/main/java/com/spotify/scio/options/KryoOptions.java	28
scio-core/src/main/java/com/spotify/scio/options/ScioOptions.java	49
scio-core/src/main/java/com/spotify/scio/options/ScioOptionsRegistrar.java	12
scio-core/src/main/java/com/spotify/scio/transforms/BaseAsyncBatchLookupDoFn.java	308
scio-core/src/main/java/com/spotify/scio/transforms/BaseAsyncDoFn.java	110
scio-core/src/main/java/com/spotify/scio/transforms/BaseAsyncLookupDoFn.java	286
scio-core/src/main/java/com/spotify/scio/transforms/BatchDoFn.java	77
scio-core/src/main/java/com/spotify/scio/transforms/DoFnWithResource.java	86
scio-core/src/main/java/com/spotify/scio/transforms/FileDownloadDoFn.java	101
scio-core/src/main/java/com/spotify/scio/transforms/FutureHandlers.java	112
scio-core/src/main/java/com/spotify/scio/transforms/GuavaAsyncBatchLookupDoFn.java	50
scio-core/src/main/java/com/spotify/scio/transforms/GuavaAsyncDoFn.java	6
scio-core/src/main/java/com/spotify/scio/transforms/GuavaAsyncLookupDoFn.java	31
scio-core/src/main/java/com/spotify/scio/transforms/JavaAsyncBatchLookupDoFn.java	50
scio-core/src/main/java/com/spotify/scio/transforms/JavaAsyncDoFn.java	6
scio-core/src/main/java/com/spotify/scio/transforms/JavaAsyncLookupDoFn.java	31
scio-core/src/main/java/com/spotify/scio/transforms/PipeDoFn.java	168
scio-core/src/main/java/com/spotify/scio/transforms/ProcessUtil.java	48
scio-core/src/main/java/com/spotify/scio/transforms/RateLimiterDoFn.java	21
scio-core/src/main/java/com/spotify/scio/transforms/UnmatchedRequestException.java	22
scio-core/src/main/java/com/spotify/scio/util/RemoteFileUtil.java	201
scio-core/src/main/java/com/spotify/scio/util/TransformingCache.java	88
scio-core/src/main/scala-2.12/com/spotify/scio/coders/instances/JavaCollectionWrappers.scala	21
scio-core/src/main/scala-2.12/com/spotify/scio/coders/instances/TupleCoders.scala	2678
scio-core/src/main/scala-2.12/com/spotify/scio/coders/instances/kryo/JTraversableSerializer.scala	58
scio-core/src/main/scala-2.12/com/spotify/scio/util/JMapWrapper.scala	24
scio-core/src/main/scala-2.13/com/spotify/scio/coders/instances/JavaCollectionWrappers.scala	21
scio-core/src/main/scala-2.13/com/spotify/scio/coders/instances/TupleCoders.scala	2677
scio-core/src/main/scala-2.13/com/spotify/scio/coders/instances/kryo/JTraversableSerializer.scala	57
scio-core/src/main/scala-2.13/com/spotify/scio/util/JMapWrapper.scala	34
scio-core/src/main/scala/com/spotify/scio/Args.scala	100
scio-core/src/main/scala/com/spotify/scio/JavaConverters.scala	35
scio-core/src/main/scala/com/spotify/scio/ScioContext.scala	594
scio-core/src/main/scala/com/spotify/scio/ScioMetrics.scala	21
scio-core/src/main/scala/com/spotify/scio/ScioResult.scala	153
scio-core/src/main/scala/com/spotify/scio/SysProps.scala	51
scio-core/src/main/scala/com/spotify/scio/VersionUtil.scala	106
scio-core/src/main/scala/com/spotify/scio/annotations/experimental.scala	2
scio-core/src/main/scala/com/spotify/scio/coders/BeamCoders.scala	98
scio-core/src/main/scala/com/spotify/scio/coders/Coder.scala	182
scio-core/src/main/scala/com/spotify/scio/coders/CoderDerivation.scala	105
scio-core/src/main/scala/com/spotify/scio/coders/CoderMaterializer.scala	176
scio-core/src/main/scala/com/spotify/scio/coders/CustomCoder.scala	227
scio-core/src/main/scala/com/spotify/scio/coders/KryoAtomicCoder.scala	241
scio-core/src/main/scala/com/spotify/scio/coders/WrappedCoder.scala	81
scio-core/src/main/scala/com/spotify/scio/coders/instances/AlgebirdCoders.scala	21
scio-core/src/main/scala/com/spotify/scio/coders/instances/BeamTypeCoders.scala	41
scio-core/src/main/scala/com/spotify/scio/coders/instances/GuavaCoders.scala	18
scio-core/src/main/scala/com/spotify/scio/coders/instances/JavaCoders.scala	115
scio-core/src/main/scala/com/spotify/scio/coders/instances/JodaCoders.scala	107
scio-core/src/main/scala/com/spotify/scio/coders/instances/ProtobufCoders.scala	13
scio-core/src/main/scala/com/spotify/scio/coders/instances/ScalaCoders.scala	424
scio-core/src/main/scala/com/spotify/scio/coders/instances/ZstdCoder.scala	21
scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/ByteStringSerializer.scala	19
scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/CoderSerializer.scala	15
scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/GrpcSerializer.scala	21
scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/JPathSerializer.scala	11
scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/JodaSerializer.scala	71
scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/KVSerializer.scala	16
scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/ThrowableSerializer.scala	79
scio-core/src/main/scala/com/spotify/scio/coders/kryo/package.scala	7
scio-core/src/main/scala/com/spotify/scio/estimators/ApproxDistinctCounter.scala	33
scio-core/src/main/scala/com/spotify/scio/hash/ApproxFilter.scala	145
scio-core/src/main/scala/com/spotify/scio/hash/MutableScalableBloomFilter.scala	149
scio-core/src/main/scala/com/spotify/scio/hash/package.scala	51
scio-core/src/main/scala/com/spotify/scio/io/BinaryIO.scala	284
scio-core/src/main/scala/com/spotify/scio/io/FileStorage.scala	74
scio-core/src/main/scala/com/spotify/scio/io/InMemorySink.scala	19
scio-core/src/main/scala/com/spotify/scio/io/ScioIO.scala	113
scio-core/src/main/scala/com/spotify/scio/io/Tap.scala	108
scio-core/src/main/scala/com/spotify/scio/io/Taps.scala	130
scio-core/src/main/scala/com/spotify/scio/io/TextIO.scala	145
scio-core/src/main/scala/com/spotify/scio/io/ZstdDictIO.scala	109
scio-core/src/main/scala/com/spotify/scio/io/dynamic/package.scala	3
scio-core/src/main/scala/com/spotify/scio/io/dynamic/syntax/AllSyntax.scala	2
scio-core/src/main/scala/com/spotify/scio/io/dynamic/syntax/SCollectionSyntax.scala	73
scio-core/src/main/scala/com/spotify/scio/metrics/package.scala	20
scio-core/src/main/scala/com/spotify/scio/runners/dataflow/DataflowContext.scala	44
scio-core/src/main/scala/com/spotify/scio/runners/dataflow/DataflowResult.scala	113
scio-core/src/main/scala/com/spotify/scio/runners/flink/FlinkContext.scala	19
scio-core/src/main/scala/com/spotify/scio/runners/spark/SparkContext.scala	19
scio-core/src/main/scala/com/spotify/scio/schemas/PrettyPrint.scala	36
scio-core/src/main/scala/com/spotify/scio/schemas/Schema.scala	222
scio-core/src/main/scala/com/spotify/scio/schemas/SchemaMaterializer.scala	176
scio-core/src/main/scala/com/spotify/scio/schemas/To.scala	162
scio-core/src/main/scala/com/spotify/scio/schemas/instances/AllInstances.scala	6
scio-core/src/main/scala/com/spotify/scio/schemas/instances/JavaInstances.scala	63
scio-core/src/main/scala/com/spotify/scio/schemas/instances/JodaInstances.scala	8
scio-core/src/main/scala/com/spotify/scio/schemas/instances/LowPrioritySchemaDerivation.scala	27
scio-core/src/main/scala/com/spotify/scio/schemas/instances/ScalaInstances.scala	64
scio-core/src/main/scala/com/spotify/scio/streaming/package.scala	6
scio-core/src/main/scala/com/spotify/scio/testing/TestDataManager.scala	147
scio-core/src/main/scala/com/spotify/scio/testing/TestUtil.scala	17
scio-core/src/main/scala/com/spotify/scio/transforms/JavaAsyncConverters.scala	9
scio-core/src/main/scala/com/spotify/scio/transforms/ParallelismDoFns.scala	36
scio-core/src/main/scala/com/spotify/scio/transforms/ScalaAsyncBatchLookupDoFn.scala	49
scio-core/src/main/scala/com/spotify/scio/transforms/ScalaAsyncDoFn.scala	5
scio-core/src/main/scala/com/spotify/scio/transforms/ScalaAsyncLookupDoFn.scala	23
scio-core/src/main/scala/com/spotify/scio/transforms/ScalaFutureHandlers.scala	32
scio-core/src/main/scala/com/spotify/scio/transforms/WithResourceDoFns.scala	66
scio-core/src/main/scala/com/spotify/scio/transforms/package.scala	3
scio-core/src/main/scala/com/spotify/scio/transforms/syntax/AllSyntax.scala	7
scio-core/src/main/scala/com/spotify/scio/transforms/syntax/SCollectionFileDownloadSyntax.scala	44
scio-core/src/main/scala/com/spotify/scio/transforms/syntax/SCollectionParallelismSyntax.scala	27
scio-core/src/main/scala/com/spotify/scio/transforms/syntax/SCollectionPipeSyntax.scala.scala	34
scio-core/src/main/scala/com/spotify/scio/transforms/syntax/SCollectionSafeSyntax.scala	47
scio-core/src/main/scala/com/spotify/scio/transforms/syntax/SCollectionWithResourceSyntax.scala	30
scio-core/src/main/scala/com/spotify/scio/util/ArtisanJoin.scala	139
scio-core/src/main/scala/com/spotify/scio/util/Cache.scala	103
scio-core/src/main/scala/com/spotify/scio/util/CallSites.scala	69
scio-core/src/main/scala/com/spotify/scio/util/FilenamePolicySupplier.scala	76
scio-core/src/main/scala/com/spotify/scio/util/Functions.scala	301
scio-core/src/main/scala/com/spotify/scio/util/FunctionsWithSideInput.scala	38
scio-core/src/main/scala/com/spotify/scio/util/FunctionsWithSideOutput.scala	33
scio-core/src/main/scala/com/spotify/scio/util/FunctionsWithWindowedValue.scala	59
scio-core/src/main/scala/com/spotify/scio/util/MultiJoin.scala	2766
scio-core/src/main/scala/com/spotify/scio/util/NamedFn.scala	21
scio-core/src/main/scala/com/spotify/scio/util/ParallelLimitedFn.scala	22
scio-core/src/main/scala/com/spotify/scio/util/ScioUtil.scala	138
scio-core/src/main/scala/com/spotify/scio/util/StatCounter.scala	88
scio-core/src/main/scala/com/spotify/scio/util/TupleFunctions.scala	21
scio-core/src/main/scala/com/spotify/scio/util/random/RandomSampler.scala	128
scio-core/src/main/scala/com/spotify/scio/util/random/XORShiftRandom.scala	25
scio-core/src/main/scala/com/spotify/scio/values/DistCache.scala	48
scio-core/src/main/scala/com/spotify/scio/values/DoubleSCollectionFunctions.scala	117
scio-core/src/main/scala/com/spotify/scio/values/FileSCollectionFunctions.scala	118
scio-core/src/main/scala/com/spotify/scio/values/PCollectionWrapper.scala	24
scio-core/src/main/scala/com/spotify/scio/values/PairHashSCollectionFunctions.scala	97
scio-core/src/main/scala/com/spotify/scio/values/PairSCollectionFunctions.scala	462
scio-core/src/main/scala/com/spotify/scio/values/PairSkewedSCollectionFunctions.scala	276
scio-core/src/main/scala/com/spotify/scio/values/SCollection.scala	736
scio-core/src/main/scala/com/spotify/scio/values/SCollectionWithFanout.scala	101
scio-core/src/main/scala/com/spotify/scio/values/SCollectionWithHotKeyFanout.scala	110
scio-core/src/main/scala/com/spotify/scio/values/SCollectionWithSideInput.scala	88
scio-core/src/main/scala/com/spotify/scio/values/SCollectionWithSideOutput.scala	38
scio-core/src/main/scala/com/spotify/scio/values/SampleSCollectionFunctions.scala	69
scio-core/src/main/scala/com/spotify/scio/values/SideInput.scala	78
scio-core/src/main/scala/com/spotify/scio/values/SideOutput.scala	51
scio-core/src/main/scala/com/spotify/scio/values/TransformNameable.scala	29
scio-core/src/main/scala/com/spotify/scio/values/WindowedSCollection.scala	42
scio-elasticsearch/common/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java	648
scio-elasticsearch/common/src/main/java/org/apache/beam/sdk/io/elasticsearch/JsonpMapperFactory.java	6
scio-elasticsearch/common/src/main/java/org/apache/beam/sdk/io/elasticsearch/ThrowingConsumer.java	6
scio-elasticsearch/common/src/main/scala/com/spotify/scio/elasticsearch/CoderInstances.scala	6
scio-elasticsearch/common/src/main/scala/com/spotify/scio/elasticsearch/ElasticsearchIO.scala	71
scio-elasticsearch/common/src/main/scala/com/spotify/scio/elasticsearch/IndexAdmin.scala	107
scio-elasticsearch/common/src/main/scala/com/spotify/scio/elasticsearch/package.scala	47
scio-extra/src/main/scala-2.12/com/spotify/scio/extra/sparkey/instances/SparkeyMapBase.scala	7
scio-extra/src/main/scala-2.12/com/spotify/scio/extra/sparkey/instances/SparkeySetBase.scala	7
scio-extra/src/main/scala-2.12/kantan/codecs/compat.scala	8
scio-extra/src/main/scala-2.13/com/spotify/scio/extra/sparkey/instances/SparkeyMapBase.scala	7
scio-extra/src/main/scala-2.13/com/spotify/scio/extra/sparkey/instances/SparkeySetBase.scala	7
scio-extra/src/main/scala-2.13/kantan/codecs/compat.scala	3
scio-extra/src/main/scala/com/spotify/scio/coders/extra/sparkey/SparkeyCoders.scala	9
scio-extra/src/main/scala/com/spotify/scio/extra/Breeze.scala	28
scio-extra/src/main/scala/com/spotify/scio/extra/Collections.scala	60
scio-extra/src/main/scala/com/spotify/scio/extra/Iterators.scala	108
scio-extra/src/main/scala/com/spotify/scio/extra/annoy/AnnoyUri.scala	73
scio-extra/src/main/scala/com/spotify/scio/extra/annoy/package.scala	99
scio-extra/src/main/scala/com/spotify/scio/extra/bigquery/AvroConverters.scala	28
scio-extra/src/main/scala/com/spotify/scio/extra/bigquery/ToTableRow.scala	95
scio-extra/src/main/scala/com/spotify/scio/extra/bigquery/ToTableSchema.scala	105
scio-extra/src/main/scala/com/spotify/scio/extra/csv/CsvIO.scala	148
scio-extra/src/main/scala/com/spotify/scio/extra/csv/CsvSink.scala	22
scio-extra/src/main/scala/com/spotify/scio/extra/csv/dynamic/dynamic.scala	3
scio-extra/src/main/scala/com/spotify/scio/extra/csv/dynamic/syntax/AllSyntax.scala	2
scio-extra/src/main/scala/com/spotify/scio/extra/csv/dynamic/syntax/SCollectionSyntax.scala	48
scio-extra/src/main/scala/com/spotify/scio/extra/csv/package.scala	3
scio-extra/src/main/scala/com/spotify/scio/extra/csv/syntax/AllSyntax.scala	2
scio-extra/src/main/scala/com/spotify/scio/extra/csv/syntax/SCollectionSyntax.scala	47
scio-extra/src/main/scala/com/spotify/scio/extra/csv/syntax/ScioContextSyntax.scala	18
scio-extra/src/main/scala/com/spotify/scio/extra/hll/sketching/SketchHllPlusPlus.scala	35
scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/HllPlus.scala	43
scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/ZetaSketchHLL.scala	57
scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/ZetaSketchHllPlusPlus.scala	29
scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/ZetaSketchable.scala	30
scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/package.scala	3
scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/syntax/AllSyntax.scala	2
scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/syntax/SCollectionSyntax.scala	30
scio-extra/src/main/scala/com/spotify/scio/extra/json/JsonIO.scala	71
scio-extra/src/main/scala/com/spotify/scio/extra/json/package.scala	59
scio-extra/src/main/scala/com/spotify/scio/extra/rollup/package.scala	3
scio-extra/src/main/scala/com/spotify/scio/extra/rollup/syntax/SCollectionSyntax.scala	46
scio-extra/src/main/scala/com/spotify/scio/extra/sorter/SortingKey.scala	6
scio-extra/src/main/scala/com/spotify/scio/extra/sorter/package.scala	3
scio-extra/src/main/scala/com/spotify/scio/extra/sorter/syntax/SCollectionSyntax.scala	54
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/LargeHashSCollectionFunctions.scala	9
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/PairLargeHashSCollectionFunctions.scala	124
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/SparkeyIO.scala	138
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/SparkeyUri.scala	123
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/CachedStringSparkeyReader.scala	12
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/MockSparkeyReader.scala	58
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/ShardedSparkeyReader.scala	47
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/SparkeyMap.scala	26
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/SparkeyReaderInstances.scala	6
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/SparkeySet.scala	11
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/SparkeyWriter.scala	42
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/StringSparkeyReader.scala	9
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/TypedSparkeyReader.scala	26
scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/package.scala	333
scio-extra/src/main/scala/com/spotify/scio/extra/voyager/Voyager.scala	145
scio-extra/src/main/scala/com/spotify/scio/extra/voyager/package.scala	3
scio-extra/src/main/scala/com/spotify/scio/extra/voyager/syntax/AllSyntax.scala	2
scio-extra/src/main/scala/com/spotify/scio/extra/voyager/syntax/SCollectionSyntax.scala	131
scio-extra/src/main/scala/com/spotify/scio/extra/voyager/syntax/ScioContextSyntax.scala	34
scio-google-cloud-platform/src/main/java/com/spotify/scio/bigtable/BigtableBatchDoFn.java	69
scio-google-cloud-platform/src/main/java/com/spotify/scio/bigtable/BigtableBulkWriter.java	175
scio-google-cloud-platform/src/main/java/com/spotify/scio/bigtable/BigtableDoFn.java	49
scio-google-cloud-platform/src/main/java/com/spotify/scio/bigtable/BigtableUtil.java	97
scio-google-cloud-platform/src/main/java/com/spotify/scio/bigtable/ChannelPoolCreator.java	36
scio-google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryAvroUtilsWrapper.java	83
scio-google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryServicesWrapper.java	61
scio-google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableServiceHelper.java	25
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/BigQueryIO.scala	737
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/BigQueryPartitionUtil.scala	71
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/BigQuerySysProps.scala	44
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/BigQueryTypes.scala	177
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/BigQueryUtil.scala	14
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/MockBigQuery.scala	130
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/StorageUtil.scala	91
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/BigQuery.scala	221
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/BigQueryConfig.scala	55
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/Cache.scala	76
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/ExtractOps.scala	108
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/JobOps.scala	91
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/Jobs.scala	23
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/LoadOps.scala	147
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/QueryOps.scala	275
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/TableOps.scala	266
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/coders/package.scala	3
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/dynamic/DynamicDestinationsUtil.scala	35
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/dynamic/package.scala	3
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/dynamic/syntax/AllSyntax.scala	2
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/dynamic/syntax/SCollectionSyntax.scala	96
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/instances/CoderInstances.scala	7
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/package.scala	28
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/syntax/FileStorageSyntax.scala	12
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/syntax/SCollectionSyntax.scala	176
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/syntax/ScioContextSyntax.scala	133
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/syntax/TableReferenceSyntax.scala	16
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/syntax/TableRowSyntax.scala	185
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/taps.scala	141
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/BigQueryTag.scala	3
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/BigQueryType.scala	126
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/ConverterProvider.scala	338
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/MacroUtil.scala	49
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/SchemaProvider.scala	99
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/SchemaUtil.scala	110
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/TypeProvider.scala	487
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/package.scala	53
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/validation/DummyOverrideTypeProvider.scala	18
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/validation/OverrideTypeProvider.scala	15
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/validation/OverrideTypeProviderFinder.scala	29
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/validation/SampleOverrideTypeProvider.scala	92
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/validation/SetProperty.scala	20
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/BigTableIO.scala	143
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/Mutations.scala	71
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/Rows.scala	49
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/TableAdmin.scala	176
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/package.scala	3
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/syntax/AllSyntax.scala	2
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/syntax/RowSyntax.scala	52
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/syntax/SCollectionSyntax.scala	30
scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/syntax/ScioContextSyntax.scala	281
scio-google-cloud-platform/src/main/scala/com/spotify/scio/coders/GcpKryoRegistrar.scala	13
scio-google-cloud-platform/src/main/scala/com/spotify/scio/coders/instances/kryo/GcpSerializer.scala	38
scio-google-cloud-platform/src/main/scala/com/spotify/scio/datastore/DatastoreIO.scala	49
scio-google-cloud-platform/src/main/scala/com/spotify/scio/datastore/package.scala	3
scio-google-cloud-platform/src/main/scala/com/spotify/scio/datastore/syntax/SCollectionSyntax.scala	19
scio-google-cloud-platform/src/main/scala/com/spotify/scio/datastore/syntax/ScioContextSyntax.scala	19
scio-google-cloud-platform/src/main/scala/com/spotify/scio/pubsub/PubSubAdmin.scala	68
scio-google-cloud-platform/src/main/scala/com/spotify/scio/pubsub/PubsubIO.scala	299
scio-google-cloud-platform/src/main/scala/com/spotify/scio/pubsub/coders/package.scala	3
scio-google-cloud-platform/src/main/scala/com/spotify/scio/pubsub/instances/CoderInstances.scala	7
scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/SpannerIO.scala	82
scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/client/Spanner.scala	17
scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/coders/package.scala	3
scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/instances/CoderInstances.scala	15
scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/package.scala	3
scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/syntax/SCollectionSyntax.scala	20
scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/syntax/ScioContextSyntax.scala	40
scio-grpc/src/main/java/com/spotify/scio/grpc/GrpcBatchDoFn.java	158
scio-grpc/src/main/java/com/spotify/scio/grpc/GrpcDoFn.java	115
scio-grpc/src/main/java/com/spotify/scio/grpc/GrpcLookupFunctions.java	25
scio-grpc/src/main/scala/com/spotify/scio/grpc/SCollectionSyntax.scala	184
scio-grpc/src/main/scala/com/spotify/scio/grpc/package.scala	2
scio-jdbc/src/main/java/com/spotify/scio/jdbc/CloudSqlOptions.java	21
scio-jdbc/src/main/java/com/spotify/scio/jdbc/CloudSqlOptionsRegistrar.java	12
scio-jdbc/src/main/java/com/spotify/scio/jdbc/JdbcDoFn.java	46
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/JdbcConnectionOptions.scala	8
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/JdbcIO.scala	158
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/package.scala	3
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/JdbcShardedReadOptions.scala	17
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/JdbcShardedSelect.scala	28
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/JdbcShardedSource.scala	117
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/JdbcUtils.scala	26
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/Range.scala	2
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/Shard.scala	150
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/ShardQuery.scala	37
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/ShardString.scala	97
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/syntax/AllSyntax.scala	2
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/syntax/SCollectionSyntax.scala	35
scio-jdbc/src/main/scala/com/spotify/scio/jdbc/syntax/ScioContextSyntax.scala	37
scio-macros/src/main/scala/com/spotify/scio/IsJava.scala	57
scio-macros/src/main/scala/com/spotify/scio/MacroSettings.scala	36
scio-macros/src/main/scala/com/spotify/scio/MagnoliaMacros.scala	39
scio-macros/src/main/scala/com/spotify/scio/SysPropsMacros.scala	30
scio-macros/src/main/scala/com/spotify/scio/coders/CoderMacros.scala	91
scio-macros/src/main/scala/com/spotify/scio/coders/KryoRegistrar.scala	27
scio-neo4j/src/main/scala/com/spotify/scio/neo4j/Neo4jIO.scala	77
scio-neo4j/src/main/scala/com/spotify/scio/neo4j/Neo4jOptions.scala	12
scio-neo4j/src/main/scala/com/spotify/scio/neo4j/package.scala	3
scio-neo4j/src/main/scala/com/spotify/scio/neo4j/syntax/AllSyntax.scala	2
scio-neo4j/src/main/scala/com/spotify/scio/neo4j/syntax/SCollectionSyntax.scala	39
scio-neo4j/src/main/scala/com/spotify/scio/neo4j/syntax/ScioContextSyntax.scala	14
scio-parquet/src/main/java/com/spotify/parquet/tensorflow/TensorflowExampleConverters.java	119
scio-parquet/src/main/java/com/spotify/parquet/tensorflow/TensorflowExampleParquetInputFormat.java	16
scio-parquet/src/main/java/com/spotify/parquet/tensorflow/TensorflowExampleParquetOutputFormat.java	14
scio-parquet/src/main/java/com/spotify/parquet/tensorflow/TensorflowExampleParquetReader.java	27
scio-parquet/src/main/java/com/spotify/parquet/tensorflow/TensorflowExampleParquetWriter.java	61
scio-parquet/src/main/java/com/spotify/parquet/tensorflow/TensorflowExampleReadSupport.java	68
scio-parquet/src/main/java/com/spotify/parquet/tensorflow/TensorflowExampleRecordMaterializer.java	20
scio-parquet/src/main/java/com/spotify/parquet/tensorflow/TensorflowExampleSchemaConverter.java	164
scio-parquet/src/main/java/com/spotify/parquet/tensorflow/TensorflowExampleWriteSupport.java	105
scio-parquet/src/main/java/com/spotify/scio/parquet/BeamInputFile.java	47
scio-parquet/src/main/java/com/spotify/scio/parquet/BeamOutputFile.java	74
scio-parquet/src/main/java/com/spotify/scio/parquet/WriterUtils.java	60
scio-parquet/src/main/java/com/spotify/scio/parquet/avro/ParquetAvroFileBasedSink.java	86
scio-parquet/src/main/java/com/spotify/scio/parquet/tensorflow/ParquetExampleFileBasedSink.java	85
scio-parquet/src/main/java/com/spotify/scio/parquet/types/ParquetTypeFileBasedSink.java	82
scio-parquet/src/main/resources/core-site.xml	23
scio-parquet/src/main/scala/com/spotify/scio/parquet/GcsConnectorUtil.scala	71
scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/ParquetAvroIO.scala	228
scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/ParquetAvroSink.scala	31
scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/ParquetAvroTap.scala	38
scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/dynamic/package.scala	3
scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/dynamic/syntax/AllSyntax.scala	2
scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/dynamic/syntax/SCollectionSyntax.scala	63
scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/package.scala	6
scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/syntax/SCollectionSyntax.scala	47
scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/syntax/ScioContextSyntax.scala	60
scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/syntax/Syntax.scala	2
scio-parquet/src/main/scala/com/spotify/scio/parquet/package.scala	54
scio-parquet/src/main/scala/com/spotify/scio/parquet/read/ParquetRead.scala	194
scio-parquet/src/main/scala/com/spotify/scio/parquet/read/ParquetReadConfiguration.scala	37
scio-parquet/src/main/scala/com/spotify/scio/parquet/read/ParquetReadFn.scala	278
scio-parquet/src/main/scala/com/spotify/scio/parquet/read/ReadSupportFactory.scala	20
scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/ParquetExampleIO.scala	233
scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/dynamic/ParquetExampleSink.scala	24
scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/dynamic/package.scala	3
scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/dynamic/syntax/AllSyntax.scala	2
scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/dynamic/syntax/SCollectionSyntax.scala	56
scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/package.scala	3
scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/syntax/SCollectionSyntax.scala	41
scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/syntax/ScioContextSyntax.scala	24
scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/syntax/Syntax.scala	2
scio-parquet/src/main/scala/com/spotify/scio/parquet/types/ParquetTypeIO.scala	209
scio-parquet/src/main/scala/com/spotify/scio/parquet/types/dynamic/dynamic.scala	3
scio-parquet/src/main/scala/com/spotify/scio/parquet/types/dynamic/syntax/AllSyntax.scala	2
scio-parquet/src/main/scala/com/spotify/scio/parquet/types/dynamic/syntax/SCollectionSyntax.scala	52
scio-parquet/src/main/scala/com/spotify/scio/parquet/types/package.scala	29
scio-parquet/src/main/scala/com/spotify/scio/parquet/types/syntax/SCollectionSyntax.scala	40
scio-parquet/src/main/scala/com/spotify/scio/parquet/types/syntax/ScioContextSyntax.scala	22
scio-parquet/src/main/scala/com/spotify/scio/parquet/types/syntax/Syntax.scala	2
scio-redis/src/main/scala/com/spotify/scio/redis/RedisDoFn.scala	99
scio-redis/src/main/scala/com/spotify/scio/redis/RedisIO.scala	116
scio-redis/src/main/scala/com/spotify/scio/redis/RedisMutator.scala	150
scio-redis/src/main/scala/com/spotify/scio/redis/coders/package.scala	3
scio-redis/src/main/scala/com/spotify/scio/redis/instances/CoderInstances.scala	56
scio-redis/src/main/scala/com/spotify/scio/redis/package.scala	3
scio-redis/src/main/scala/com/spotify/scio/redis/syntax/SCollectionSyntax.scala	22
scio-redis/src/main/scala/com/spotify/scio/redis/syntax/ScioContextSyntax.scala	19
scio-redis/src/main/scala/com/spotify/scio/redis/types/RedisMutation.scala	41
scio-redis/src/main/scala/com/spotify/scio/redis/types/RedisType.scala	8
scio-repl/src/main/scala-2.12/com/spotify/scio/repl/ScioGenericRunner.scala	31
scio-repl/src/main/scala-2.12/com/spotify/scio/repl/compat/CsvReaderOps.scala	5
scio-repl/src/main/scala-2.12/com/spotify/scio/repl/compat/ILoop.scala	21
scio-repl/src/main/scala-2.12/com/spotify/scio/repl/compat/package.scala	5
scio-repl/src/main/scala-2.13/com/spotify/scio/repl/ScioGenericRunner.scala	21
scio-repl/src/main/scala-2.13/com/spotify/scio/repl/compat/ILoop.scala	15
scio-repl/src/main/scala-2.13/com/spotify/scio/repl/compat/package.scala	2
scio-repl/src/main/scala/com/spotify/scio/repl/IoCommands.scala	94
scio-repl/src/main/scala/com/spotify/scio/repl/ReplScioContext.scala	55
scio-repl/src/main/scala/com/spotify/scio/repl/ScioILoop.scala	149
scio-repl/src/main/scala/com/spotify/scio/repl/ScioReplClassLoader.scala	31
scio-repl/src/main/scala/com/spotify/scio/repl/ScioReplSysProps.scala	8
scio-repl/src/main/scala/com/spotify/scio/repl/ScioShell.scala	12
scio-repl/src/main/scala/com/spotify/scio/repl/package.scala	14
scio-smb/src/main/java/com/spotify/scio/smb/annotations/PatchedFromBeam.java	4
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/AvroBucketMetadata.java	169
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/AvroFileOperations.java	129
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/AvroSortedBucketIO.java	392
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/AvroUtils.java	160
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/BucketMetadata.java	399
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/BucketMetadataUtil.java	91
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/BucketShardId.java	41
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/BufferedIterator.java	39
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/CoGbkResultUtil.java	23
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/FileOperations.java	182
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/IcebergEncoder.java	88
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/JsonBucketMetadata.java	126
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/JsonFileOperations.java	82
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/JsonSortedBucketIO.java	264
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/KeyGroupIterator.java	72
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/MissingImplementationException.java	12
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/MultiSourceKeyGroupReader.java	211
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/ParquetAvroFileOperations.java	187
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/ParquetAvroSortedBucketIO.java	421
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/ParquetBucketMetadata.java	272
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/ParquetInputFile.java	31
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/ParquetOutputFile.java	62
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/ParquetUtils.java	61
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SMBFilenamePolicy.java	111
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketIO.java	541
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketOptions.java	15
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketOptionsRegistrar.java	12
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketPrimaryAndSecondaryKeyedSource.java	104
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketPrimaryKeyedSource.java	77
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketSink.java	716
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketSource.java	532
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketTransform.java	529
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SourceSpec.java	68
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/TFRecordCodec.java	83
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/TargetParallelism.java	76
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/TensorFlowBucketIO.java	266
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/TensorFlowBucketMetadata.java	141
scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/TensorFlowFileOperations.java	74
scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/BufferedExternalSorter.java	100
scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/ExternalSorter.java	56
scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/InMemorySorter.java	91
scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/NativeExternalSorter.java	35
scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/NativeFileSorter.java	186
scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/Sorter.java	7
scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/SorterSysProps.java	6
scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/package-info.java	1
scio-smb/src/main/java/org/apache/beam/sdk/io/PatchedReadableFileUtil.java	10
scio-smb/src/main/java/org/apache/beam/sdk/io/PatchedSerializableAvroCodecFactory.java	74
scio-smb/src/main/resources/core-site.xml	23
scio-smb/src/main/scala/com/spotify/scio/smb/SmbIO.scala	41
scio-smb/src/main/scala/com/spotify/scio/smb/SortMergeTransform.scala	203
scio-smb/src/main/scala/com/spotify/scio/smb/package.scala	3
scio-smb/src/main/scala/com/spotify/scio/smb/syntax/AllSyntax.scala	2
scio-smb/src/main/scala/com/spotify/scio/smb/syntax/SortMergeBucketSCollectionSyntax.scala	52
scio-smb/src/main/scala/com/spotify/scio/smb/syntax/SortMergeBucketScioContextSyntax.scala	549
scio-smb/src/main/scala/org/apache/beam/sdk/extensions/smb/ParquetTypeFileOperations.scala	100
scio-smb/src/main/scala/org/apache/beam/sdk/extensions/smb/ParquetTypeSortedBucketIO.scala	195
scio-smb/src/main/scala/org/apache/beam/sdk/extensions/smb/SortedBucketIOUtil.scala	19
scio-snowflake/src/main/scala/com/spotify/scio/snowflake/SnowflakeIO.scala	175
scio-snowflake/src/main/scala/com/spotify/scio/snowflake/SnowflakeOptions.scala	24
scio-snowflake/src/main/scala/com/spotify/scio/snowflake/package.scala	3
scio-snowflake/src/main/scala/com/spotify/scio/snowflake/syntax/AllSyntax.scala	2
scio-snowflake/src/main/scala/com/spotify/scio/snowflake/syntax/SCollectionSyntax.scala	46
scio-snowflake/src/main/scala/com/spotify/scio/snowflake/syntax/ScioContextSyntax.scala	52
scio-tensorflow/src/main/java/org/apache/beam/sdk/io/TFRecordFileBasedSink.java	42
scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/TFRecordCodec.scala	84
scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/TFRecordFileTap.scala	11
scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/TFRecordIO.scala	170
scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/package.scala	3
scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/syntax/FileStorageSyntax.scala	24
scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/syntax/SCollectionSyntax.scala	123
scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/syntax/ScioContextSyntax.scala	49
scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/syntax/Syntax.scala	2
scio-test/core/src/main/scala/com/spotify/scio/testing/ApproximationAssertions.scala	39
scio-test/core/src/main/scala/com/spotify/scio/testing/CoderAssertions.scala	162
scio-test/core/src/main/scala/com/spotify/scio/testing/EqInstances.scala	21
scio-test/core/src/main/scala/com/spotify/scio/testing/JobTest.scala	244
scio-test/core/src/main/scala/com/spotify/scio/testing/PipelineSpec.scala	38
scio-test/core/src/main/scala/com/spotify/scio/testing/PipelineTestUtils.scala	76
scio-test/core/src/main/scala/com/spotify/scio/testing/Pretty.scala	76
scio-test/core/src/main/scala/com/spotify/scio/testing/RunEnforcementJobTest.scala	46
scio-test/core/src/main/scala/com/spotify/scio/testing/SCollectionMatchers.scala	370
scio-test/core/src/main/scala/com/spotify/scio/testing/ScioIOSpec.scala	142
scio-test/core/src/main/scala/com/spotify/scio/testing/TransformFinder.scala	32
scio-test/core/src/main/scala/com/spotify/scio/testing/TransformOverride.scala	164
scio-test/core/src/main/scala/com/spotify/scio/testing/package.scala	12
scio-test/google-cloud-platform/src/main/scala/com/spotify/scio/testing/BigtableMatchers.scala	67
scio-test/parquet/src/main/scala/com/spotify/scio/testing/parquet/ParquetTestUtils.scala	62
scio-test/parquet/src/main/scala/com/spotify/scio/testing/parquet/avro/package.scala	54
scio-test/parquet/src/main/scala/com/spotify/scio/testing/parquet/tensorflow/package.scala	50
scio-test/parquet/src/main/scala/com/spotify/scio/testing/parquet/types/types.scala	22
scripts/multijoin.py	158
scripts/smb_multijoin.py	168
scripts/tuplecoders.py	61
site/src/main/paradox/_template/examples.st	9
site/src/main/paradox/_template/scaladoc.st	9