Path	Lines of Code
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