./codecov.yaml .jvmopts .scala-steward.conf .scalafix.conf .scalafmt.conf LICENSE NOTICE build.sbt project/BuildCredentials.scala project/CheckBeamDependencies.scala project/ScalacOptions.scala project/SoccoIndex.scala project/build.properties project/plugins.sbt scalafix/.jvmopts scalafix/build.sbt scalafix/input-0_10/src/main/scala/fix/FixCoderPropagation.scala scalafix/input-0_7/src/main/scala/fix/AddMissingImports.scala scalafix/input-0_7/src/main/scala/fix/BQClientRefactoring.scala scalafix/input-0_7/src/main/scala/fix/FixAvroIO.scala scalafix/input-0_7/src/main/scala/fix/RewriteSysProp.scala scalafix/input-0_8/src/main/scala/fix/FixBigQueryDeprecations.scala scalafix/input-0_8/src/main/scala/fix/FixContextClose.scala scalafix/input-0_8/src/main/scala/fix/FixJoinNames.scala scalafix/input-0_8/src/main/scala/fix/FixRunWithContext.scala scalafix/input-0_8/src/main/scala/fix/FixScioIO.scala scalafix/input-0_8/src/main/scala/fix/FixSyntaxImports.scala scalafix/input-0_8/src/main/scala/fix/FixTensorflow.scala scalafix/output-0_10/src/main/scala/fix/FixCoderPropagation.scala scalafix/output-0_7/src/main/scala/fix/AddMissingImports.scala scalafix/output-0_7/src/main/scala/fix/BQClientRefactoring.scala scalafix/output-0_7/src/main/scala/fix/FixAvroIO.scala scalafix/output-0_7/src/main/scala/fix/RewriteSysProp.scala scalafix/output-0_8/src/main/scala/fix/FixBigQueryDeprecations.scala scalafix/output-0_8/src/main/scala/fix/FixContextClose.scala scalafix/output-0_8/src/main/scala/fix/FixJoinNames.scala scalafix/output-0_8/src/main/scala/fix/FixRunWithContext.scala scalafix/output-0_8/src/main/scala/fix/FixScioIO.scala scalafix/output-0_8/src/main/scala/fix/FixSyntaxImports.scala scalafix/output-0_8/src/main/scala/fix/FixTensorflow.scala scalafix/project/Scio.scala scalafix/project/build.properties scalafix/project/plugins.sbt scalafix/rules/src/main/resources/META-INF/services/scalafix.v1.Rule scalafix/rules/src/main/scala/fix/AddMissingImports.scala scalafix/rules/src/main/scala/fix/BQClientRefactoring.scala scalafix/rules/src/main/scala/fix/FixAvroIO.scala scalafix/rules/src/main/scala/fix/FixCoderPropagation.scala scalafix/rules/src/main/scala/fix/MigrateV0_8.scala scalafix/rules/src/main/scala/fix/RewriteSysProp.scala scalafix/tests/src/test/scala/fix/RuleSuite.scala scio-avro/src/it/scala/com/spotify/scio/avro/types/AvroTapIT.scala scio-avro/src/it/scala/com/spotify/scio/avro/types/AvroTypeIT.scala scio-avro/src/it/scala/com/spotify/scio/avro/types/TypeProviderIT.scala scio-avro/src/main/scala/com/spotify/scio/avro/AvroIO.scala scio-avro/src/main/scala/com/spotify/scio/avro/AvroSysProps.scala scio-avro/src/main/scala/com/spotify/scio/avro/package.scala scio-avro/src/main/scala/com/spotify/scio/avro/syntax/SCollectionSyntax.scala scio-avro/src/main/scala/com/spotify/scio/avro/syntax/ScioContextSyntax.scala scio-avro/src/main/scala/com/spotify/scio/avro/syntax/Syntax.scala scio-avro/src/main/scala/com/spotify/scio/avro/taps.scala scio-avro/src/main/scala/com/spotify/scio/avro/types/AvroType.scala scio-avro/src/main/scala/com/spotify/scio/avro/types/ConverterProvider.scala scio-avro/src/main/scala/com/spotify/scio/avro/types/MacroUtil.scala scio-avro/src/main/scala/com/spotify/scio/avro/types/SchemaProvider.scala scio-avro/src/main/scala/com/spotify/scio/avro/types/SchemaUtil.scala scio-avro/src/main/scala/com/spotify/scio/avro/types/TypeProvider.scala scio-avro/src/main/scala/com/spotify/scio/avro/types/types.scala scio-avro/src/test/avro/scio-avro-test.avsc scio-avro/src/test/scala/com/spotify/scio/avro/types/ConverterProviderSpec.scala scio-avro/src/test/scala/com/spotify/scio/avro/types/ConverterProviderTest.scala scio-avro/src/test/scala/com/spotify/scio/avro/types/SchemaProviderTest.scala scio-avro/src/test/scala/com/spotify/scio/avro/types/SchemaUtilTest.scala scio-avro/src/test/scala/com/spotify/scio/avro/types/Schemas.scala scio-avro/src/test/scala/com/spotify/scio/avro/types/TypeProviderTest.scala scio-cassandra/cassandra3/src/it/scala/com/spotify/scio/cassandra/CassandraIT.scala scio-cassandra/cassandra3/src/main/java/com/spotify/scio/cassandra/CompatUtil.java scio-cassandra/cassandra3/src/main/java/org/apache/cassandra/hadoop/cql3/CqlBulkRecordWriterUtil.java scio-cassandra/cassandra3/src/main/scala/com/spotify/scio/cassandra/BulkOperations.scala scio-cassandra/cassandra3/src/main/scala/com/spotify/scio/cassandra/CassandraIO.scala scio-cassandra/cassandra3/src/main/scala/com/spotify/scio/cassandra/DataTypeExternalizer.scala scio-cassandra/cassandra3/src/main/scala/com/spotify/scio/cassandra/package.scala scio-cassandra/cassandra3/src/test/scala/com/spotify/scio/cassandra/CassandraIOTest.scala scio-cassandra/cassandra3/src/test/scala/com/spotify/scio/cassandra/DataTypeExternalizerTest.scala scio-core/src/it/scala/com/spotify/scio/testing/util/DefaultBucket.scala scio-core/src/it/scala/com/spotify/scio/testing/util/ItUtils.scala scio-core/src/main/java/com/spotify/scio/options/KryoOptions.java scio-core/src/main/java/com/spotify/scio/options/ScioOptions.java scio-core/src/main/java/com/spotify/scio/options/ScioOptionsRegistrar.java scio-core/src/main/java/com/spotify/scio/transforms/BaseAsyncDoFn.java scio-core/src/main/java/com/spotify/scio/transforms/BaseAsyncLookupDoFn.java scio-core/src/main/java/com/spotify/scio/transforms/DoFnWithResource.java scio-core/src/main/java/com/spotify/scio/transforms/FileDownloadDoFn.java scio-core/src/main/java/com/spotify/scio/transforms/FutureHandlers.java scio-core/src/main/java/com/spotify/scio/transforms/GuavaAsyncDoFn.java scio-core/src/main/java/com/spotify/scio/transforms/GuavaAsyncLookupDoFn.java scio-core/src/main/java/com/spotify/scio/transforms/JavaAsyncDoFn.java scio-core/src/main/java/com/spotify/scio/transforms/JavaAsyncLookupDoFn.java scio-core/src/main/java/com/spotify/scio/transforms/PipeDoFn.java scio-core/src/main/java/com/spotify/scio/transforms/ProcessUtil.java scio-core/src/main/java/com/spotify/scio/transforms/RateLimiterDoFn.java scio-core/src/main/java/com/spotify/scio/util/RemoteFileUtil.java scio-core/src/main/java/org/apache/beam/sdk/coders/shaded/AvroCoder.java scio-core/src/main/java/org/apache/beam/sdk/coders/shaded/AvroGenericCoder.java scio-core/src/main/scala-2.12/com/spotify/scio/coders/instances/TupleCoders.scala scio-core/src/main/scala-2.12/com/spotify/scio/coders/instances/kryo/JTraversableSerializer.scala scio-core/src/main/scala-2.12/com/spotify/scio/util/JMapWrapper.scala scio-core/src/main/scala-2.12/scala/collection/compat/extra/CollectionConverters.scala scio-core/src/main/scala-2.12/scala/collection/compat/extra/package.scala scio-core/src/main/scala-2.13/com/spotify/scio/coders/instances/TupleCoders.scala scio-core/src/main/scala-2.13/com/spotify/scio/coders/instances/kryo/JTraversableSerializer.scala scio-core/src/main/scala-2.13/com/spotify/scio/util/JMapWrapper.scala scio-core/src/main/scala-2.13/scala/collection/compat/extra.scala scio-core/src/main/scala/com/spotify/scio/Args.scala scio-core/src/main/scala/com/spotify/scio/JavaConverters.scala scio-core/src/main/scala/com/spotify/scio/ScioContext.scala scio-core/src/main/scala/com/spotify/scio/ScioMetrics.scala scio-core/src/main/scala/com/spotify/scio/ScioResult.scala scio-core/src/main/scala/com/spotify/scio/SysProps.scala scio-core/src/main/scala/com/spotify/scio/VersionUtil.scala scio-core/src/main/scala/com/spotify/scio/annotations/experimental.scala scio-core/src/main/scala/com/spotify/scio/coders/AvroBytesUtil.scala scio-core/src/main/scala/com/spotify/scio/coders/BeamCoders.scala scio-core/src/main/scala/com/spotify/scio/coders/Coder.scala scio-core/src/main/scala/com/spotify/scio/coders/CoderMaterializer.scala scio-core/src/main/scala/com/spotify/scio/coders/DerivedCoder.scala scio-core/src/main/scala/com/spotify/scio/coders/KryoAtomicCoder.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/AlgebirdCoders.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/AvroCoders.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/BeamTypeCoders.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/GuavaCoders.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/JavaCoders.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/JodaCoders.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/ProtobufCoders.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/ScalaCoders.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/AvroSerializer.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/ByteStringSerializer.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/CoderSerializer.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/GrpcSerializers.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/JPathSerializer.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/JodaSerializer.scala scio-core/src/main/scala/com/spotify/scio/coders/instances/kryo/KVSerializer.scala scio-core/src/main/scala/com/spotify/scio/estimators/ApproxDistinctCounter.scala scio-core/src/main/scala/com/spotify/scio/hash/ApproxFilter.scala scio-core/src/main/scala/com/spotify/scio/hash/MutableScalableBloomFilter.scala scio-core/src/main/scala/com/spotify/scio/hash/package.scala scio-core/src/main/scala/com/spotify/scio/io/BinaryIO.scala scio-core/src/main/scala/com/spotify/scio/io/FileStorage.scala scio-core/src/main/scala/com/spotify/scio/io/InMemorySink.scala scio-core/src/main/scala/com/spotify/scio/io/ScioIO.scala scio-core/src/main/scala/com/spotify/scio/io/Tap.scala scio-core/src/main/scala/com/spotify/scio/io/Taps.scala scio-core/src/main/scala/com/spotify/scio/io/TextIO.scala scio-core/src/main/scala/com/spotify/scio/io/dynamic/package.scala scio-core/src/main/scala/com/spotify/scio/io/dynamic/syntax/AllSyntax.scala scio-core/src/main/scala/com/spotify/scio/io/dynamic/syntax/SCollecionSyntax.scala scio-core/src/main/scala/com/spotify/scio/metrics/package.scala scio-core/src/main/scala/com/spotify/scio/runners/dataflow/DataflowContext.scala scio-core/src/main/scala/com/spotify/scio/runners/dataflow/DataflowResult.scala scio-core/src/main/scala/com/spotify/scio/runners/flink/FlinkContext.scala scio-core/src/main/scala/com/spotify/scio/runners/spark/SparkContext.scala scio-core/src/main/scala/com/spotify/scio/schemas/PrettyPrint.scala scio-core/src/main/scala/com/spotify/scio/schemas/Schema.scala scio-core/src/main/scala/com/spotify/scio/schemas/SchemaMaterializer.scala scio-core/src/main/scala/com/spotify/scio/schemas/To.scala scio-core/src/main/scala/com/spotify/scio/schemas/instances/AllInstances.scala scio-core/src/main/scala/com/spotify/scio/schemas/instances/AvroInstances.scala scio-core/src/main/scala/com/spotify/scio/schemas/instances/JavaInstances.scala scio-core/src/main/scala/com/spotify/scio/schemas/instances/JodaInstances.scala scio-core/src/main/scala/com/spotify/scio/schemas/instances/LowPrioritySchemaDerivation.scala scio-core/src/main/scala/com/spotify/scio/schemas/instances/ScalaInstances.scala scio-core/src/main/scala/com/spotify/scio/streaming/package.scala scio-core/src/main/scala/com/spotify/scio/testing/TestDataManager.scala scio-core/src/main/scala/com/spotify/scio/testing/TestUtil.scala scio-core/src/main/scala/com/spotify/scio/transforms/JavaAsyncConverters.scala scio-core/src/main/scala/com/spotify/scio/transforms/ParallelismDoFns.scala scio-core/src/main/scala/com/spotify/scio/transforms/ScalaAsyncDoFn.scala scio-core/src/main/scala/com/spotify/scio/transforms/ScalaAsyncLookupDoFn.scala scio-core/src/main/scala/com/spotify/scio/transforms/ScalaFutureHandlers.scala scio-core/src/main/scala/com/spotify/scio/transforms/WithResourceDoFns.scala scio-core/src/main/scala/com/spotify/scio/transforms/package.scala scio-core/src/main/scala/com/spotify/scio/transforms/syntax/AllSyntax.scala scio-core/src/main/scala/com/spotify/scio/transforms/syntax/SCollectionFileDownloadSyntax.scala scio-core/src/main/scala/com/spotify/scio/transforms/syntax/SCollectionParallelismSyntax.scala scio-core/src/main/scala/com/spotify/scio/transforms/syntax/SCollectionPipeSyntax.scala.scala scio-core/src/main/scala/com/spotify/scio/transforms/syntax/SCollectionSafeSyntax.scala scio-core/src/main/scala/com/spotify/scio/transforms/syntax/SCollectionWithResourceSyntax.scala scio-core/src/main/scala/com/spotify/scio/util/ArtisanJoin.scala scio-core/src/main/scala/com/spotify/scio/util/Cache.scala scio-core/src/main/scala/com/spotify/scio/util/CallSites.scala scio-core/src/main/scala/com/spotify/scio/util/Functions.scala scio-core/src/main/scala/com/spotify/scio/util/FunctionsWithSideInput.scala scio-core/src/main/scala/com/spotify/scio/util/FunctionsWithSideOutput.scala scio-core/src/main/scala/com/spotify/scio/util/FunctionsWithWindowedValue.scala scio-core/src/main/scala/com/spotify/scio/util/MultiJoin.scala scio-core/src/main/scala/com/spotify/scio/util/NamedFn.scala scio-core/src/main/scala/com/spotify/scio/util/ParallelLimitedFn.scala scio-core/src/main/scala/com/spotify/scio/util/ProtobufUtil.scala scio-core/src/main/scala/com/spotify/scio/util/ScioUtil.scala scio-core/src/main/scala/com/spotify/scio/util/StatCounter.scala scio-core/src/main/scala/com/spotify/scio/util/TupleFunctions.scala scio-core/src/main/scala/com/spotify/scio/util/random/RandomSampler.scala scio-core/src/main/scala/com/spotify/scio/util/random/XORShiftRandom.scala scio-core/src/main/scala/com/spotify/scio/values/DistCache.scala scio-core/src/main/scala/com/spotify/scio/values/DoubleSCollectionFunctions.scala scio-core/src/main/scala/com/spotify/scio/values/PCollectionWrapper.scala scio-core/src/main/scala/com/spotify/scio/values/PairHashSCollectionFunctions.scala scio-core/src/main/scala/com/spotify/scio/values/PairSCollectionFunctions.scala scio-core/src/main/scala/com/spotify/scio/values/PairSkewedSCollectionFunctions.scala scio-core/src/main/scala/com/spotify/scio/values/SCollection.scala scio-core/src/main/scala/com/spotify/scio/values/SCollectionWithFanout.scala scio-core/src/main/scala/com/spotify/scio/values/SCollectionWithHotKeyFanout.scala scio-core/src/main/scala/com/spotify/scio/values/SCollectionWithSideInput.scala scio-core/src/main/scala/com/spotify/scio/values/SCollectionWithSideOutput.scala scio-core/src/main/scala/com/spotify/scio/values/SideInput.scala scio-core/src/main/scala/com/spotify/scio/values/SideOutput.scala scio-core/src/main/scala/com/spotify/scio/values/TransformNameable.scala scio-core/src/main/scala/com/spotify/scio/values/WindowedSCollection.scala scio-elasticsearch/es6/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java scio-elasticsearch/es6/src/main/java/org/apache/beam/sdk/io/elasticsearch/ThrowingConsumer.java scio-elasticsearch/es6/src/main/scala/com/spotify/scio/elasticsearch/CoderInstances.scala scio-elasticsearch/es6/src/main/scala/com/spotify/scio/elasticsearch/ElasticsearchIO.scala scio-elasticsearch/es6/src/main/scala/com/spotify/scio/elasticsearch/IndexAdmin.scala scio-elasticsearch/es6/src/main/scala/com/spotify/scio/elasticsearch/package.scala scio-elasticsearch/es6/src/test/scala/com/spotify/scio/elasticsearch/CoderInstancesTest.scala scio-elasticsearch/es6/src/test/scala/com/spotify/scio/elasticsearch/ElasticsearchIOTest.scala scio-elasticsearch/es7/src/main/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIO.java scio-elasticsearch/es7/src/main/java/org/apache/beam/sdk/io/elasticsearch/ThrowingConsumer.java scio-elasticsearch/es7/src/main/scala/com/spotify/scio/elasticsearch/CoderInstances.scala scio-elasticsearch/es7/src/main/scala/com/spotify/scio/elasticsearch/ElasticsearchIO.scala scio-elasticsearch/es7/src/main/scala/com/spotify/scio/elasticsearch/IndexAdmin.scala scio-elasticsearch/es7/src/main/scala/com/spotify/scio/elasticsearch/package.scala scio-elasticsearch/es7/src/test/scala/com/spotify/scio/elasticsearch/CoderInstancesTest.scala scio-elasticsearch/es7/src/test/scala/com/spotify/scio/elasticsearch/ElasticsearchIOTest.scala scio-examples/src/main/java/org/apache/beam/examples/BeamSqlExample.java scio-examples/src/main/java/org/apache/beam/examples/DebuggingWordCount.java scio-examples/src/main/java/org/apache/beam/examples/MinimalWordCount.java scio-examples/src/main/java/org/apache/beam/examples/WindowedWordCount.java scio-examples/src/main/java/org/apache/beam/examples/WordCount.java scio-examples/src/main/java/org/apache/beam/examples/common/ExampleBigQueryTableOptions.java scio-examples/src/main/java/org/apache/beam/examples/common/ExampleOptions.java scio-examples/src/main/java/org/apache/beam/examples/common/ExamplePubsubTopicAndSubscriptionOptions.java scio-examples/src/main/java/org/apache/beam/examples/common/ExamplePubsubTopicOptions.java scio-examples/src/main/java/org/apache/beam/examples/common/ExampleUtils.java scio-examples/src/main/java/org/apache/beam/examples/common/WriteOneFilePerWindow.java scio-examples/src/main/java/org/apache/beam/examples/complete/AutoComplete.java scio-examples/src/main/java/org/apache/beam/examples/complete/StreamingWordExtract.java scio-examples/src/main/java/org/apache/beam/examples/complete/TfIdf.java scio-examples/src/main/java/org/apache/beam/examples/complete/TopWikipediaSessions.java scio-examples/src/main/java/org/apache/beam/examples/complete/TrafficMaxLaneFlow.java scio-examples/src/main/java/org/apache/beam/examples/complete/TrafficRoutes.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/GameStats.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/HourlyTeamScore.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/LeaderBoard.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/StatefulTeamScore.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/UserScore.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/injector/Injector.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/injector/InjectorUtils.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/injector/RetryHttpInitializerWrapper.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/utils/GameConstants.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToBigQuery.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/utils/WriteToText.java scio-examples/src/main/java/org/apache/beam/examples/complete/game/utils/WriteWindowedToBigQuery.java scio-examples/src/main/java/org/apache/beam/examples/cookbook/BigQueryTornadoes.java scio-examples/src/main/java/org/apache/beam/examples/cookbook/CombinePerKeyExamples.java scio-examples/src/main/java/org/apache/beam/examples/cookbook/DistinctExample.java scio-examples/src/main/java/org/apache/beam/examples/cookbook/FilterExamples.java scio-examples/src/main/java/org/apache/beam/examples/cookbook/JoinExamples.java scio-examples/src/main/java/org/apache/beam/examples/cookbook/MaxPerKeyExamples.java scio-examples/src/main/java/org/apache/beam/examples/cookbook/TriggerExample.java scio-examples/src/main/java/org/apache/beam/examples/snippets/Snippets.java scio-examples/src/main/java/org/apache/beam/examples/subprocess/Echo.cc scio-examples/src/main/java/org/apache/beam/examples/subprocess/EchoAgain.cc scio-examples/src/main/java/org/apache/beam/examples/subprocess/ExampleEchoPipeline.java scio-examples/src/main/java/org/apache/beam/examples/subprocess/SubProcessPipelineOptions.java scio-examples/src/main/java/org/apache/beam/examples/subprocess/configuration/SubProcessConfiguration.java scio-examples/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessCommandLineArgs.java scio-examples/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessIOFiles.java scio-examples/src/main/java/org/apache/beam/examples/subprocess/kernel/SubProcessKernel.java scio-examples/src/main/java/org/apache/beam/examples/subprocess/utils/CallingSubProcessUtils.java scio-examples/src/main/java/org/apache/beam/examples/subprocess/utils/ExecutableFile.java scio-examples/src/main/java/org/apache/beam/examples/subprocess/utils/FileUtils.java scio-examples/src/main/scala/com/spotify/scio/examples/DebuggingWordCount.scala scio-examples/src/main/scala/com/spotify/scio/examples/MinimalWordCount.scala scio-examples/src/main/scala/com/spotify/scio/examples/MinimalWordCountTypedArguments.scala scio-examples/src/main/scala/com/spotify/scio/examples/WindowedWordCount.scala scio-examples/src/main/scala/com/spotify/scio/examples/WordCount.scala scio-examples/src/main/scala/com/spotify/scio/examples/common/ExampleData.scala scio-examples/src/main/scala/com/spotify/scio/examples/complete/AutoComplete.scala scio-examples/src/main/scala/com/spotify/scio/examples/complete/StreamingWordExtract.scala scio-examples/src/main/scala/com/spotify/scio/examples/complete/TfIdf.scala scio-examples/src/main/scala/com/spotify/scio/examples/complete/TopWikipediaSessions.scala scio-examples/src/main/scala/com/spotify/scio/examples/complete/TrafficMaxLaneFlow.scala scio-examples/src/main/scala/com/spotify/scio/examples/complete/TrafficRoutes.scala scio-examples/src/main/scala/com/spotify/scio/examples/complete/game/GameStats.scala scio-examples/src/main/scala/com/spotify/scio/examples/complete/game/HourlyTeamScore.scala scio-examples/src/main/scala/com/spotify/scio/examples/complete/game/LeaderBoard.scala scio-examples/src/main/scala/com/spotify/scio/examples/complete/game/UserScore.scala scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/BigQueryTornadoes.scala scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/CombinePerKeyExamples.scala scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/DistinctByKeyExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/DistinctExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/FilterExamples.scala scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/JoinExamples.scala scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/MaxPerKeyExamples.scala scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/StorageBigQueryTornadoes.scala scio-examples/src/main/scala/com/spotify/scio/examples/cookbook/TriggerExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/AnnoyExamples.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/AvroExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/AvroInOut.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/BeamExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/BigtableExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/CloudSqlExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/DistCacheExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/DoFnExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/ElasticsearchMinimalExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/JavaConvertersExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/MagnolifyAvroExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/MagnolifyBigtableExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/MagnolifyDatastoreExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/MagnolifyTensorFlowExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/MetricsExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/ParquetExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/ProtobufExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/RedisExamples.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/RefreshingSideInputExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/SafeFlatMapExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/SideInOutExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/SingleGZipFileExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/SortMergeBucketExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/StatefulExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/TableRowJsonInOut.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/TapOutputExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/TapsExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/TemplateExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/TsvExample.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/TypedBigQueryTornadoes.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/TypedStorageBigQueryTornadoes.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/WordCountOrchestration.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/WordCountScioIO.scala scio-examples/src/main/scala/com/spotify/scio/examples/extra/WriteDynamicExample.scala scio-examples/src/test/java/org/apache/beam/examples/DebuggingWordCountTest.java scio-examples/src/test/java/org/apache/beam/examples/WordCountTest.java scio-examples/src/test/java/org/apache/beam/examples/complete/AutoCompleteTest.java scio-examples/src/test/java/org/apache/beam/examples/complete/TfIdfTest.java scio-examples/src/test/java/org/apache/beam/examples/complete/TopWikipediaSessionsTest.java scio-examples/src/test/java/org/apache/beam/examples/complete/game/GameStatsTest.java scio-examples/src/test/java/org/apache/beam/examples/complete/game/HourlyTeamScoreTest.java scio-examples/src/test/java/org/apache/beam/examples/complete/game/LeaderBoardTest.java scio-examples/src/test/java/org/apache/beam/examples/complete/game/StatefulTeamScoreTest.java scio-examples/src/test/java/org/apache/beam/examples/complete/game/UserScoreTest.java scio-examples/src/test/java/org/apache/beam/examples/cookbook/BigQueryTornadoesTest.java scio-examples/src/test/java/org/apache/beam/examples/cookbook/CombinePerKeyExamplesTest.java scio-examples/src/test/java/org/apache/beam/examples/cookbook/DistinctExampleTest.java scio-examples/src/test/java/org/apache/beam/examples/cookbook/FilterExamplesTest.java scio-examples/src/test/java/org/apache/beam/examples/cookbook/JoinExamplesTest.java scio-examples/src/test/java/org/apache/beam/examples/cookbook/MaxPerKeyExamplesTest.java scio-examples/src/test/java/org/apache/beam/examples/cookbook/TriggerExampleTest.java scio-examples/src/test/java/org/apache/beam/examples/snippets/SnippetsTest.java scio-examples/src/test/resources/LICENSE scio-examples/src/test/resources/scio-0.6-protobuf/part-00000-of-00002.protobuf.avro scio-examples/src/test/resources/scio-0.6-protobuf/part-00001-of-00002.protobuf.avro scio-examples/src/test/resources/scio-0.7-protobuf/part-00000-of-00002.protobuf.avro scio-examples/src/test/resources/scio-0.7-protobuf/part-00001-of-00002.protobuf.avro scio-examples/src/test/scala/com/spotify/scio/examples/WordCountTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/complete/AutoCompleteTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/complete/TfIdfTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/complete/TopWikipediaSessionsTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/complete/game/GameStatsTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/complete/game/HourlyTeamScoreTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/complete/game/LeaderBoardTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/complete/game/UserScoreTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/BigQueryTornadoesTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/CombinePerKeyExamplesTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/DistinctByKeyExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/DistinctExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/FilterExamplesTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/JoinExamplesTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/MaxPerKeyExamplesTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/StorageBigQueryTornadoesTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/cookbook/TriggerExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/AlgebirdSpec.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/AnnoyIndexSaveExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/AnnoySideInputExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/AvroExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/AvroInOutTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/BackcompatibilityTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/BigtableExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/CloudSqlExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/DistCacheExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/DoFnExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/JavaConvertersExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/MagnolifyAvroExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/MagnolifyDatastoreExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/MagnolifyTensorFlowExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/MetricsExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/ParquetExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/ProtobufExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/SafeFlatMapExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/SideInOutExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/SingleGZipFileExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/SortMergeBucketExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/TableRowJsonInOutTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/TemplateExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/TsvExampleTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/TypedBigQueryTornadoesTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/TypedStorageBigQueryTornadoesTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/WindowedWordCountTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/WordCountOrchestrationTest.scala scio-examples/src/test/scala/com/spotify/scio/examples/extra/WordCountScioIOTest.scala scio-extra/src/it/scala/com/spotify/scio/extra/annoy/AnnoyIT.scala scio-extra/src/it/scala/com/spotify/scio/extra/bigquery/BigQueryIT.scala scio-extra/src/it/scala/com/spotify/scio/extra/sparkey/SparkeyIT.scala scio-extra/src/main/scala-2.12/com/spotify/scio/extra/sparkey/instances/SparkeyMapBase.scala scio-extra/src/main/scala-2.12/com/spotify/scio/extra/sparkey/instances/SparkeySetBase.scala scio-extra/src/main/scala-2.12/kantan/codecs/compat.scala scio-extra/src/main/scala-2.13/com/spotify/scio/extra/sparkey/instances/SparkeyMapBase.scala scio-extra/src/main/scala-2.13/com/spotify/scio/extra/sparkey/instances/SparkeySetBase.scala scio-extra/src/main/scala-2.13/kantan/codecs/compat.scala scio-extra/src/main/scala/com/spotify/scio/extra/Breeze.scala scio-extra/src/main/scala/com/spotify/scio/extra/Collections.scala scio-extra/src/main/scala/com/spotify/scio/extra/Iterators.scala scio-extra/src/main/scala/com/spotify/scio/extra/annoy/AnnoyUri.scala scio-extra/src/main/scala/com/spotify/scio/extra/annoy/package.scala scio-extra/src/main/scala/com/spotify/scio/extra/bigquery/AvroConverters.scala scio-extra/src/main/scala/com/spotify/scio/extra/bigquery/ToTableRow.scala scio-extra/src/main/scala/com/spotify/scio/extra/bigquery/ToTableSchema.scala scio-extra/src/main/scala/com/spotify/scio/extra/bigquery/package.scala scio-extra/src/main/scala/com/spotify/scio/extra/bigquery/syntax/SCollectionSyntax.scala scio-extra/src/main/scala/com/spotify/scio/extra/csv/CsvIO.scala scio-extra/src/main/scala/com/spotify/scio/extra/csv/package.scala scio-extra/src/main/scala/com/spotify/scio/extra/csv/syntax/AllSyntax.scala scio-extra/src/main/scala/com/spotify/scio/extra/csv/syntax/SCollectionSyntax.scala scio-extra/src/main/scala/com/spotify/scio/extra/csv/syntax/ScioContextSyntax.scala scio-extra/src/main/scala/com/spotify/scio/extra/hll/sketching/SketchHllPlusPlus.scala scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/HllPlus.scala scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/ZetaSketchHLL.scala scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/ZetaSketchHllPlusPlus.scala scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/ZetaSketchable.scala scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/package.scala scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/syntax/AllSyntax.scala scio-extra/src/main/scala/com/spotify/scio/extra/hll/zetasketch/syntax/SCollectionSyntax.scala scio-extra/src/main/scala/com/spotify/scio/extra/json/JsonIO.scala scio-extra/src/main/scala/com/spotify/scio/extra/json/package.scala scio-extra/src/main/scala/com/spotify/scio/extra/rollup/package.scala scio-extra/src/main/scala/com/spotify/scio/extra/rollup/syntax/SCollectionSyntax.scala scio-extra/src/main/scala/com/spotify/scio/extra/sorter/SortingKey.scala scio-extra/src/main/scala/com/spotify/scio/extra/sorter/package.scala scio-extra/src/main/scala/com/spotify/scio/extra/sorter/syntax/SCollectionSyntax.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/LargeHashSCollectionFunctions.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/PairLargeHashSCollectionFunctions.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/ShardedSparkeyUri.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/SparkeyUri.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/CachedStringSparkeyReader.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/ShardedSparkeyReader.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/SparkeyMap.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/SparkeyReaderInstances.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/SparkeySet.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/StringSparkeyReader.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/instances/TypedSparkeyReader.scala scio-extra/src/main/scala/com/spotify/scio/extra/sparkey/package.scala scio-extra/src/test/avro/scio-avro-example.avsc scio-extra/src/test/avro/scio-avro-logical-type-example.avsc scio-extra/src/test/scala/com/spotify/scio/extra/BreezeSpec.scala scio-extra/src/test/scala/com/spotify/scio/extra/CollectionsSpec.scala scio-extra/src/test/scala/com/spotify/scio/extra/IteratorsSpec.scala scio-extra/src/test/scala/com/spotify/scio/extra/PropertySpec.scala scio-extra/src/test/scala/com/spotify/scio/extra/annoy/AnnoyTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/bigquery/ToTableRowTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/bigquery/ToTableSchemaTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/csv/CsvIOTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/hll/sketching/SketchHllPlusPlusTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/hll/zetasketch/DistributedZetaSketchHllTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/hll/zetasketch/ZetaSketchHllPlusPlusTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/json/JsonIOTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/rollup/RollupTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/sorter/SorterTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/sparkey/LargeHashSCollectionFunctionsTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/sparkey/PairLargeHashSCollectionFunctionsTest.scala scio-extra/src/test/scala/com/spotify/scio/extra/sparkey/SparkeyTest.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/bigquery/BigQueryClientIT.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/bigquery/BigQueryIOIT.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/bigquery/BigQueryIT.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/bigquery/BigQueryPartitionUtilIT.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/bigquery/PopulateTestData.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/bigquery/TypedBigQueryIT.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/bigquery/dynamic/DynamicBigQueryIT.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/bigquery/types/BeamSchemaIT.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/bigquery/types/BigQueryTypeIT.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/bigquery/types/StorageIT.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/bigtable/BigtableIT.scala scio-google-cloud-platform/src/it/scala/com/spotify/scio/spanner/SpannerIOIT.scala scio-google-cloud-platform/src/main/java/com/spotify/scio/bigtable/BigtableBulkWriter.java scio-google-cloud-platform/src/main/java/com/spotify/scio/bigtable/BigtableDoFn.java scio-google-cloud-platform/src/main/java/com/spotify/scio/bigtable/BigtableUtil.java scio-google-cloud-platform/src/main/java/com/spotify/scio/bigtable/ChannelPoolCreator.java scio-google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableServiceHelper.java scio-google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/gcp/bigquery/BigQueryAvroUtilsWrapper.java scio-google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/gcp/bigquery/BigQueryServicesWrapper.java scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/BigQueryIO.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/BigQueryPartitionUtil.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/BigQuerySysProps.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/BigQueryTypes.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/BigQueryUtil.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/MockBigQuery.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/StorageUtil.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/BigQuery.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/BigQueryConfig.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/Cache.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/ExtractOps.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/JobOps.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/Jobs.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/LoadOps.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/QueryOps.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/client/TableOps.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/coders/package.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/dynamic/DynamicDestinationsUtil.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/dynamic/package.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/dynamic/syntax/AllSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/dynamic/syntax/SCollectionSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/instances/CoderInstances.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/package.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/syntax/SCollectionSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/syntax/ScioContextSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/syntax/TableReferenceSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/syntax/TableRowSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/taps.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/BigQueryTag.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/BigQueryType.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/ConverterProvider.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/MacroUtil.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/SchemaProvider.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/SchemaUtil.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/TypeProvider.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/types/package.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/validation/DummyOverrideTypeProvider.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/validation/OverrideTypeProvider.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/validation/OverrideTypeProviderFinder.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/validation/SampleOverrideTypeProvider.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigquery/validation/SetProperty.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/BigTableIO.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/Mutations.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/Rows.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/TableAdmin.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/package.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/syntax/AllSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/syntax/RowSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/syntax/SCollectionSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/bigtable/syntax/ScioContextSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/datastore/DatastoreIO.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/datastore/package.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/datastore/syntax/SCollectionSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/datastore/syntax/ScioContextSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/pubsub/PubSubAdmin.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/pubsub/PubsubIO.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/pubsub/coders/package.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/pubsub/instances/CoderInstances.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/pubsub/package.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/pubsub/syntax/SCollectionSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/pubsub/syntax/ScioContextSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/SpannerIO.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/client/Spanner.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/coders/package.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/instances/CoderInstances.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/package.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/syntax/SCollectionSyntax.scala scio-google-cloud-platform/src/main/scala/com/spotify/scio/spanner/syntax/ScioContextSyntax.scala scio-google-cloud-platform/src/test/java/com/spotify/scio/bigtable/BigtableBulkWriterTest.java scio-google-cloud-platform/src/test/java/com/spotify/scio/bigtable/BigtableUtilTest.java scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/BigQueryClientTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/BigQueryIOTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/BigQueryTypesTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/BigQueryUtilTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/TableRowSyntaxTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/TimestampTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/types/ConverterProviderSpec.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/types/ConverterProviderTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/types/SchemaProviderTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/types/SchemaUtilTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/types/Schemas.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/types/TypeProviderTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigquery/validation/BigQueryValidationTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigtable/BigtableDoFnTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigtable/BigtableIOTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/bigtable/RichRowTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/datastore/DatastoreIOTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/pubsub/PubsubIOTest.scala scio-google-cloud-platform/src/test/scala/com/spotify/scio/spanner/SpannerIOTest.scala scio-jdbc/src/main/java/com/spotify/scio/jdbc/CloudSqlOptions.java scio-jdbc/src/main/java/com/spotify/scio/jdbc/CloudSqlOptionsRegistrar.java scio-jdbc/src/main/scala/com/spotify/scio/jdbc/JdbcIO.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/JdbcOptions.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/package.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/JdbcShardedReadOptions.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/JdbcShardedSelect.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/JdbcShardedSource.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/JdbcUtils.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/Range.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/Shard.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/ShardQuery.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/sharded/ShardString.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/syntax/AllSyntax.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/syntax/SCollectionSyntax.scala scio-jdbc/src/main/scala/com/spotify/scio/jdbc/syntax/ScioContextSyntax.scala scio-jdbc/src/test/scala/com/spotify/scio/jdbc/JdbcTest.scala scio-jdbc/src/test/scala/com/spotify/scio/jdbc/sharded/JdbcRangeShardTests.scala scio-jdbc/src/test/scala/com/spotify/scio/jdbc/sharded/JdbcRangeStringShardTests.scala scio-jdbc/src/test/scala/com/spotify/scio/jdbc/sharded/JdbcShardedSelectTest.scala scio-jdbc/src/test/scala/com/spotify/scio/jdbc/sharded/ShardedQueryTests.scala scio-jmh/src/test/java/com/spotify/scio/jmh/j/User.java scio-jmh/src/test/java/com/spotify/scio/jmh/j/UserId.java scio-jmh/src/test/resources/events-100-0.avro scio-jmh/src/test/resources/events-10000-0.avro scio-jmh/src/test/scala/com/spotify/scio/jmh/CoderBenchmark.scala scio-jmh/src/test/scala/com/spotify/scio/jmh/FunctionsBenchmark.scala scio-jmh/src/test/scala/com/spotify/scio/jmh/GroupByBenchmark.scala scio-jmh/src/test/scala/com/spotify/scio/jmh/JoinBenchmark.scala scio-macros/src/main/scala/com/spotify/scio/IsJava.scala scio-macros/src/main/scala/com/spotify/scio/MacroSettings.scala scio-macros/src/main/scala/com/spotify/scio/MagnoliaMacros.scala scio-macros/src/main/scala/com/spotify/scio/SysPropsMacros.scala scio-macros/src/main/scala/com/spotify/scio/coders/AvroCoderMacros.scala scio-macros/src/main/scala/com/spotify/scio/coders/CoderMacros.scala scio-macros/src/main/scala/com/spotify/scio/coders/KryoRegistrar.scala scio-parquet/src/main/java/com/spotify/scio/parquet/BeamInputFile.java scio-parquet/src/main/java/com/spotify/scio/parquet/BeamOutputFile.java scio-parquet/src/main/java/com/spotify/scio/parquet/WriterUtils.java scio-parquet/src/main/java/com/spotify/scio/parquet/avro/ParquetAvroSink.java scio-parquet/src/main/java/com/spotify/scio/parquet/tensorflow/ParquetExampleSink.java scio-parquet/src/main/java/com/spotify/scio/parquet/types/ParquetTypeSink.java scio-parquet/src/main/resources/core-site.xml scio-parquet/src/main/scala/com/spotify/scio/parquet/GcsConnectorUtil.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/ParquetAvroIO.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/package.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/syntax/SCollectionSyntax.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/syntax/ScioContextSyntax.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/avro/syntax/Syntax.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/ParquetExampleIO.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/package.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/syntax/SCollectionSyntax.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/syntax/ScioContextSyntax.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/tensorflow/syntax/Syntax.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/types/ParquetTypeIO.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/types/package.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/types/syntax/SCollectionSyntax.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/types/syntax/ScioContextSyntax.scala scio-parquet/src/main/scala/com/spotify/scio/parquet/types/syntax/Syntax.scala scio-parquet/src/test/scala/com/spotify/scio/parquet/avro/ParquetAvroIOTest.scala scio-parquet/src/test/scala/com/spotify/scio/parquet/tensorflow/ParquetExampleIOTest.scala scio-parquet/src/test/scala/com/spotify/scio/parquet/types/ParquetTypeIOTest.scala scio-redis/src/main/scala/com/spotify/scio/redis/RedisDoFn.scala scio-redis/src/main/scala/com/spotify/scio/redis/RedisIO.scala scio-redis/src/main/scala/com/spotify/scio/redis/RedisMutator.scala scio-redis/src/main/scala/com/spotify/scio/redis/coders/package.scala scio-redis/src/main/scala/com/spotify/scio/redis/instances/CoderInstances.scala scio-redis/src/main/scala/com/spotify/scio/redis/package.scala scio-redis/src/main/scala/com/spotify/scio/redis/syntax/SCollectionSyntax.scala scio-redis/src/main/scala/com/spotify/scio/redis/syntax/ScioContextSyntax.scala scio-redis/src/main/scala/com/spotify/scio/redis/types/RedisMutation.scala scio-redis/src/main/scala/com/spotify/scio/redis/types/RedisType.scala scio-repl/src/it/resources/word-count-repl.scala scio-repl/src/main/scala-2.12/com/spotify/scio/repl/ScioGenericRunner.scala scio-repl/src/main/scala-2.12/com/spotify/scio/repl/compat/CsvReaderOps.scala scio-repl/src/main/scala-2.12/com/spotify/scio/repl/compat/ILoop.scala scio-repl/src/main/scala-2.12/com/spotify/scio/repl/compat/package.scala scio-repl/src/main/scala-2.13/com/spotify/scio/repl/ScioGenericRunner.scala scio-repl/src/main/scala-2.13/com/spotify/scio/repl/compat/ILoop.scala scio-repl/src/main/scala-2.13/com/spotify/scio/repl/compat/package.scala scio-repl/src/main/scala/com/spotify/scio/repl/IoCommands.scala scio-repl/src/main/scala/com/spotify/scio/repl/ReplScioContext.scala scio-repl/src/main/scala/com/spotify/scio/repl/ScioILoop.scala scio-repl/src/main/scala/com/spotify/scio/repl/ScioReplClassLoader.scala scio-repl/src/main/scala/com/spotify/scio/repl/ScioReplSysProps.scala scio-repl/src/main/scala/com/spotify/scio/repl/ScioShell.scala scio-repl/src/main/scala/com/spotify/scio/repl/package.scala scio-schemas/src/main/avro/bytes.avsc scio-schemas/src/main/avro/schema.avsc scio-schemas/src/main/protobuf/complex.proto scio-schemas/src/main/protobuf/simple_v2.proto scio-schemas/src/main/protobuf/simple_v3.proto scio-schemas/src/main/protobuf/track.proto scio-schemas/src/main/scala/com/spotify/scio/avro/AvroUtils.scala scio-smb/src/it/java/org/apache/beam/sdk/extensions/smb/SmbIT.java scio-smb/src/it/java/org/apache/beam/sdk/extensions/smb/SmbPublicAPITest.java scio-smb/src/it/java/org/apache/beam/sdk/extensions/smb/benchmark/CoGroupByKeyBenchmark.java scio-smb/src/it/java/org/apache/beam/sdk/extensions/smb/benchmark/SinkBenchmark.java scio-smb/src/it/java/org/apache/beam/sdk/extensions/smb/benchmark/SourceBenchmark.java scio-smb/src/it/scala/com/spotify/scio/smb/SortMergeBucketParityIT.scala scio-smb/src/main/java/com/spotify/scio/smb/annotations/PatchedFromBeam.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/AvroBucketMetadata.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/AvroFileOperations.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/AvroSortedBucketIO.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/AvroUtils.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/BucketMetadata.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/BucketMetadataUtil.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/BucketShardId.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/BufferedIterator.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/CoGbkResultUtil.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/FileOperations.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/JsonBucketMetadata.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/JsonFileOperations.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/JsonSortedBucketIO.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/KeyGroupIterator.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/MultiSourceKeyGroupReader.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/ParquetAvroFileOperations.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/ParquetAvroSortedBucketIO.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/ParquetBucketMetadata.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/ParquetInputFile.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/ParquetOutputFile.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SMBFilenamePolicy.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketIO.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketOptions.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketOptionsRegistrar.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketSink.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketSource.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SortedBucketTransform.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/SourceSpec.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/TFRecordCodec.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/TargetParallelism.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/TensorFlowBucketIO.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/TensorFlowBucketMetadata.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/smb/TensorFlowFileOperations.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/BufferedExternalSorter.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/ExternalSorter.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/InMemorySorter.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/NativeExternalSorter.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/NativeFileSorter.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/Sorter.java scio-smb/src/main/java/org/apache/beam/sdk/extensions/sorter/package-info.java scio-smb/src/main/java/org/apache/beam/sdk/io/PatchedReadableFileUtil.java scio-smb/src/main/java/org/apache/beam/sdk/io/PatchedSerializableAvroCodecFactory.java scio-smb/src/main/resources/core-site.xml scio-smb/src/main/scala/com/spotify/scio/smb/package.scala scio-smb/src/main/scala/com/spotify/scio/smb/syntax/AllSyntax.scala scio-smb/src/main/scala/com/spotify/scio/smb/syntax/SortMergeBucketSCollectionSyntax.scala scio-smb/src/main/scala/com/spotify/scio/smb/syntax/SortMergeBucketScioContextSyntax.scala scio-smb/src/main/scala/com/spotify/scio/smb/util/SMBMultiJoin.scala scio-smb/src/main/scala/org/apache/beam/sdk/extensions/smb/ParquetTypeFileOperations.scala scio-smb/src/main/scala/org/apache/beam/sdk/extensions/smb/ParquetTypeSortedBucketIO.scala scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/AvroBucketMetadataTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/AvroFileOperationsTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/AvroSortedBucketIOTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/BucketMetadataTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/BucketMetadataUtilTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/JsonBucketMetadataTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/JsonFileOperationsTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/KeyGroupIteratorTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/MixedSourcesEndToEndTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/ParquetAvroFileOperationsTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/ParquetAvroSortedBucketIOTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/SMBFilenamePolicyTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/SortedBucketSinkTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/SortedBucketSourceTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/SortedBucketTransformTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/TensorFlowBucketMetadataTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/TensorFlowFileOperationsTest.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/TestBucketMetadata.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/TestFileOperations.java scio-smb/src/test/java/org/apache/beam/sdk/extensions/smb/TestUtils.java scio-smb/src/test/scala/org/apache/beam/sdk/extensions/smb/ParquetBucketMetadataTest.scala scio-smb/src/test/scala/org/apache/beam/sdk/extensions/smb/ParquetEndToEndTest.scala scio-smb/src/test/scala/org/apache/beam/sdk/extensions/smb/ParquetTypeFileOperationsTest.scala scio-smb/src/test/scala/org/apache/beam/sdk/extensions/smb/ParquetTypeSortedBucketIOTest.scala scio-tensorflow/src/main/protobuf/path.proto scio-tensorflow/src/main/protobuf/schema.proto scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/TFRecordCodec.scala scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/TFRecordFileTap.scala scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/TFRecordIO.scala scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/TensorFlowDoFns.scala scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/package.scala scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/syntax/FileStorageSyntax.scala scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/syntax/SCollectionSyntax.scala scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/syntax/ScioContextSyntax.scala scio-tensorflow/src/main/scala/com/spotify/scio/tensorflow/syntax/Syntax.scala scio-tensorflow/src/test/resources/settings.json scio-tensorflow/src/test/resources/trained_model/saved_model.pb scio-tensorflow/src/test/resources/trained_model/variables/variables.data-00000-of-00001 scio-tensorflow/src/test/resources/trained_model/variables/variables.index scio-tensorflow/src/test/scala/com/spotify/scio/tensorflow/MetadataSchemaTest.scala scio-tensorflow/src/test/scala/com/spotify/scio/tensorflow/TFExampleIOTest.scala scio-tensorflow/src/test/scala/com/spotify/scio/tensorflow/TFExampleTest.scala scio-tensorflow/src/test/scala/com/spotify/scio/tensorflow/TFSequenceExampleIOTest.scala scio-tensorflow/src/test/scala/com/spotify/scio/tensorflow/TFSequenceExampleTest.scala scio-tensorflow/src/test/scala/com/spotify/scio/tensorflow/TFTapTest.scala scio-tensorflow/src/test/scala/com/spotify/scio/tensorflow/TensorflowSpec.scala scio-test/src/it/resources/avro-integration-test/folder-a/folder-b/part-01.avro scio-test/src/it/resources/avro-integration-test/folder-a/folder-b/part-02.avro scio-test/src/it/resources/avro-integration-test/folder-a/folder-b/shakespeare-schema.avsc scio-test/src/it/resources/avro-integration-test/folder-a/folder-b/shakespeare.avro scio-test/src/it/resources/shakespeare-sample-10.avro scio-test/src/it/resources/shakespeare-sample-10.json scio-test/src/it/scala/com/spotify/DataflowIT.scala scio-test/src/it/scala/com/spotify/scio/ScioContextIT.scala scio-test/src/it/scala/com/spotify/scio/avro/TypedAvroIT.scala scio-test/src/it/scala/com/spotify/scio/values/DistCacheIT.scala scio-test/src/main/scala/com/spotify/scio/testing/ApproximationAssertions.scala scio-test/src/main/scala/com/spotify/scio/testing/BigtableMatchers.scala scio-test/src/main/scala/com/spotify/scio/testing/CoderAssertions.scala scio-test/src/main/scala/com/spotify/scio/testing/EqInstances.scala scio-test/src/main/scala/com/spotify/scio/testing/JobTest.scala scio-test/src/main/scala/com/spotify/scio/testing/PipelineSpec.scala scio-test/src/main/scala/com/spotify/scio/testing/PipelineTestUtils.scala scio-test/src/main/scala/com/spotify/scio/testing/Pretty.scala scio-test/src/main/scala/com/spotify/scio/testing/RunEnforcementJobTest.scala scio-test/src/main/scala/com/spotify/scio/testing/SCollectionMatchers.scala scio-test/src/main/scala/com/spotify/scio/testing/ScioIOSpec.scala scio-test/src/main/scala/com/spotify/scio/testing/package.scala scio-test/src/test/java/com/spotify/scio/bean/NotABean.java scio-test/src/test/java/com/spotify/scio/bean/TypeMismatch.java scio-test/src/test/java/com/spotify/scio/bean/UserBean.java scio-test/src/test/java/com/spotify/scio/coders/FixedSpecificDataExample.java scio-test/src/test/java/com/spotify/scio/coders/JavaEnumExample.java scio-test/src/test/java/com/spotify/scio/testing/TestValidationOptions.java scio-test/src/test/resources/protobuf-file.avro scio-test/src/test/scala/com/spotify/scio/ArgsTest.scala scio-test/src/test/scala/com/spotify/scio/ScioContextTest.scala scio-test/src/test/scala/com/spotify/scio/ScioResultTest.scala scio-test/src/test/scala/com/spotify/scio/SerializationTest.scala scio-test/src/test/scala/com/spotify/scio/VersionUtilTest.scala scio-test/src/test/scala/com/spotify/scio/coders/CoderTest.scala scio-test/src/test/scala/com/spotify/scio/coders/CoderTestUtils.scala scio-test/src/test/scala/com/spotify/scio/coders/KryoAtomicCoderTest.scala scio-test/src/test/scala/com/spotify/scio/coders/instances/kryo/ByteStringSerializerTest.scala scio-test/src/test/scala/com/spotify/scio/coders/instances/kryo/GrpcSerializersTest.scala scio-test/src/test/scala/com/spotify/scio/coders/instances/kryo/JTraversableSerializerTest.scala scio-test/src/test/scala/com/spotify/scio/coders/instances/kryo/JodaSerializerTest.scala scio-test/src/test/scala/com/spotify/scio/hash/ApproxFilterTest.scala scio-test/src/test/scala/com/spotify/scio/hash/MutableScalableBloomFilterTest.scala scio-test/src/test/scala/com/spotify/scio/hash/PartitionSettingsTest.scala scio-test/src/test/scala/com/spotify/scio/io/FileFormatTest.scala scio-test/src/test/scala/com/spotify/scio/io/FileStorageTest.scala scio-test/src/test/scala/com/spotify/scio/io/InMemorySinkTest.scala scio-test/src/test/scala/com/spotify/scio/io/ScioIOTest.scala scio-test/src/test/scala/com/spotify/scio/io/TapTest.scala scio-test/src/test/scala/com/spotify/scio/io/TapsTest.scala scio-test/src/test/scala/com/spotify/scio/io/dynamic/DynamicFileTest.scala scio-test/src/test/scala/com/spotify/scio/schemas/SchemaCompatTest.scala scio-test/src/test/scala/com/spotify/scio/schemas/SchemaMaterializerTest.scala scio-test/src/test/scala/com/spotify/scio/testing/BigtableMatchersTest.scala scio-test/src/test/scala/com/spotify/scio/testing/CoderAssertionsTest.scala scio-test/src/test/scala/com/spotify/scio/testing/JobTestTest.scala scio-test/src/test/scala/com/spotify/scio/testing/SCollectionMatchersTest.scala scio-test/src/test/scala/com/spotify/scio/transforms/AsyncDoFnSpec.scala scio-test/src/test/scala/com/spotify/scio/transforms/AsyncDoFnTest.scala scio-test/src/test/scala/com/spotify/scio/transforms/AsyncLookupDoFnTest.scala scio-test/src/test/scala/com/spotify/scio/transforms/CustomParallelismSCollectionTest.scala scio-test/src/test/scala/com/spotify/scio/transforms/DoFnWithResourceTest.scala scio-test/src/test/scala/com/spotify/scio/transforms/FileDownloadDoFnTest.scala scio-test/src/test/scala/com/spotify/scio/transforms/PipeDoFnTest.scala scio-test/src/test/scala/com/spotify/scio/transforms/SCollectionWithResourceFunctionsTest.scala scio-test/src/test/scala/com/spotify/scio/transforms/SpecializedFlatMapSCollectionTest.scala scio-test/src/test/scala/com/spotify/scio/util/FunctionsTest.scala scio-test/src/test/scala/com/spotify/scio/util/MockedPrintStream.scala scio-test/src/test/scala/com/spotify/scio/util/MultiJoinTest.scala scio-test/src/test/scala/com/spotify/scio/util/ProtobufUtilTest.scala scio-test/src/test/scala/com/spotify/scio/util/random/RandomSamplerTest.scala scio-test/src/test/scala/com/spotify/scio/util/random/RandomSamplerUtils.scala scio-test/src/test/scala/com/spotify/scio/values/ClosureTest.scala scio-test/src/test/scala/com/spotify/scio/values/DistCacheTest.scala scio-test/src/test/scala/com/spotify/scio/values/DoubleSCollectionFunctionsTest.scala scio-test/src/test/scala/com/spotify/scio/values/HistogramTest.scala scio-test/src/test/scala/com/spotify/scio/values/MutationTest.scala scio-test/src/test/scala/com/spotify/scio/values/NamedTransformTest.scala scio-test/src/test/scala/com/spotify/scio/values/PairHashSCollectionFunctionsTest.scala scio-test/src/test/scala/com/spotify/scio/values/PairSCollectionFunctionsTest.scala scio-test/src/test/scala/com/spotify/scio/values/PairSkewedSCollectionFunctionsTest.scala scio-test/src/test/scala/com/spotify/scio/values/SCollectionTest.scala scio-test/src/test/scala/com/spotify/scio/values/SCollectionWithFanoutTest.scala scio-test/src/test/scala/com/spotify/scio/values/SCollectionWithHotKeyFanoutTest.scala scio-test/src/test/scala/com/spotify/scio/values/SCollectionWithSideInputTest.scala scio-test/src/test/scala/com/spotify/scio/values/SCollectionWithSideOutputTest.scala scio-test/src/test/scala/com/spotify/scio/values/StateTest.scala scio-test/src/test/scala/com/spotify/scio/values/WindowedSCollectionTest.scala scripts/bigquery/07fe023d0e229e12f83b3e39c0acf54a.schema.json scripts/bigquery/3062ca1555f348ed54cf225c7432fb6f.schema.json scripts/bump_scio.sh scripts/ci_repl.sh scripts/gen_schemas.sh scripts/gha-it.json.enc scripts/gha_setup.sh scripts/make-site.sh scripts/multijoin.py scripts/smb_multijoin.py scripts/tuplecoders.py site/src/main/paradox/_template/examples.st site/src/main/paradox/_template/scaladoc.st site/src/main/paradox/images/favicon.ico <<<<<< network # path=./scio-cassandra/cassandra3/target/scala-2.13/scoverage-report/scoverage.xml <<<<<< EOF # path=./scio-cassandra/cassandra3/target/scala-2.13/coverage-report/cobertura.xml --source /home/runner/work/scio/scio/scio-cassandra/cassandra3/src/main/scala /home/runner/work/scio/scio/scio-cassandra/cassandra3/src/main/java <<<<<< EOF # path=./scio-macros/target/scala-2.13/scoverage-report/scoverage.xml <<<<<< EOF # path=./scio-macros/target/scala-2.13/coverage-report/cobertura.xml --source /home/runner/work/scio/scio/scio-macros/src/main/scala <<<<<< EOF # path=./scio-schemas/target/scala-2.13/scoverage-report/scoverage.xml <<<<<< EOF # path=./scio-schemas/target/scala-2.13/coverage-report/cobertura.xml --source /home/runner/work/scio/scio/scio-schemas/src/main/scala /home/runner/work/scio/scio/scio-schemas/target/scala-2.13/src_managed/main/compiled_protobuf /home/runner/work/scio/scio/scio-schemas/target/scala-2.13/src_managed/main/compiled_avro <<<<<< EOF # path=./scio-jdbc/target/scala-2.13/scoverage-report/scoverage.xml <<<<<< EOF # path=./scio-jdbc/target/scala-2.13/coverage-report/cobertura.xml --source /home/runner/work/scio/scio/scio-jdbc/src/main/scala /home/runner/work/scio/scio/scio-jdbc/src/main/java <<<<<< EOF # path=./codecov.yaml coverage: status: project: no patch: no changes: no <<<<<< EOF # path=./scio-redis/target/scala-2.13/scoverage-report/scoverage.xml <<<<<< EOF # path=./scio-redis/target/scala-2.13/coverage-report/cobertura.xml --source /home/runner/work/scio/scio/scio-redis/src/main/scala <<<<<< EOF # path=./scio-smb/target/scala-2.13/scoverage-report/scoverage.xml