This is an automated email from the ASF dual-hosted git repository. wenchen pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/spark.git.
from 53908be [SPARK-38644][SQL] DS V2 topN push-down supports project with alias add b112528 [SPARK-38569][BUILD] Rename `external` top level dir to `connector` No new revisions were added by this update. Summary of changes: R/run-tests.sh | 2 +- .../benchmarks/AvroReadBenchmark-jdk11-results.txt | 0 .../benchmarks/AvroReadBenchmark-jdk17-results.txt | 0 .../avro/benchmarks/AvroReadBenchmark-results.txt | 0 .../benchmarks/AvroWriteBenchmark-jdk11-results.txt | 0 .../benchmarks/AvroWriteBenchmark-jdk17-results.txt | 0 .../avro/benchmarks/AvroWriteBenchmark-results.txt | 0 {external => connector}/avro/pom.xml | 0 .../spark/sql/avro/SparkAvroKeyOutputFormat.java | 0 .../org.apache.spark.sql.sources.DataSourceRegister | 0 .../apache/spark/sql/avro/AvroDataToCatalyst.scala | 0 .../org/apache/spark/sql/avro/AvroDeserializer.scala | 0 .../org/apache/spark/sql/avro/AvroFileFormat.scala | 0 .../scala/org/apache/spark/sql/avro/AvroOptions.scala | 0 .../org/apache/spark/sql/avro/AvroOutputWriter.scala | 0 .../spark/sql/avro/AvroOutputWriterFactory.scala | 0 .../org/apache/spark/sql/avro/AvroSerializer.scala | 0 .../scala/org/apache/spark/sql/avro/AvroUtils.scala | 0 .../apache/spark/sql/avro/CatalystDataToAvro.scala | 0 .../org/apache/spark/sql/avro/SchemaConverters.scala | 0 .../scala/org/apache/spark/sql/avro/functions.scala | 0 .../scala/org/apache/spark/sql/avro/package.scala | 0 .../apache/spark/sql/v2/avro/AvroDataSourceV2.scala | 0 .../sql/v2/avro/AvroPartitionReaderFactory.scala | 0 .../scala/org/apache/spark/sql/v2/avro/AvroScan.scala | 0 .../apache/spark/sql/v2/avro/AvroScanBuilder.scala | 0 .../org/apache/spark/sql/v2/avro/AvroTable.scala | 0 .../org/apache/spark/sql/v2/avro/AvroWrite.scala | 0 .../apache/spark/sql/avro/JavaAvroFunctionsSuite.java | 0 .../src/test/resources/before_1582_date_v2_4_5.avro | Bin .../src/test/resources/before_1582_date_v2_4_6.avro | Bin .../src/test/resources/before_1582_date_v3_2_0.avro | Bin .../before_1582_timestamp_micros_v2_4_5.avro | Bin .../before_1582_timestamp_micros_v2_4_6.avro | Bin .../before_1582_timestamp_micros_v3_2_0.avro | Bin .../before_1582_timestamp_millis_v2_4_5.avro | Bin .../before_1582_timestamp_millis_v2_4_6.avro | Bin .../before_1582_timestamp_millis_v3_2_0.avro | Bin .../avro/src/test/resources/episodes.avro | Bin .../avro}/src/test/resources/log4j2.properties | 0 .../test-random-partitioned/part-r-00000.avro | Bin .../test-random-partitioned/part-r-00001.avro | Bin .../test-random-partitioned/part-r-00002.avro | Bin .../test-random-partitioned/part-r-00003.avro | Bin .../test-random-partitioned/part-r-00004.avro | Bin .../test-random-partitioned/part-r-00005.avro | Bin .../test-random-partitioned/part-r-00006.avro | Bin .../test-random-partitioned/part-r-00007.avro | Bin .../test-random-partitioned/part-r-00008.avro | Bin .../test-random-partitioned/part-r-00009.avro | Bin .../test-random-partitioned/part-r-00010.avro | Bin .../avro/src/test/resources/test.avro | Bin .../avro/src/test/resources/test.avsc | 0 .../avro/src/test/resources/test.json | 0 .../avro/src/test/resources/test_sub.avsc | 0 .../sql/avro/AvroCatalystDataConversionSuite.scala | 0 .../org/apache/spark/sql/avro/AvroCodecSuite.scala | 0 .../apache/spark/sql/avro/AvroFunctionsSuite.scala | 0 .../apache/spark/sql/avro/AvroLogicalTypeSuite.scala | 0 .../apache/spark/sql/avro/AvroRowReaderSuite.scala | 0 .../org/apache/spark/sql/avro/AvroScanSuite.scala | 0 .../apache/spark/sql/avro/AvroSchemaHelperSuite.scala | 0 .../org/apache/spark/sql/avro/AvroSerdeSuite.scala | 0 .../scala/org/apache/spark/sql/avro/AvroSuite.scala | 0 .../spark/sql/avro/DeprecatedAvroFunctionsSuite.scala | 0 .../sql/execution/benchmark/AvroReadBenchmark.scala | 0 .../sql/execution/benchmark/AvroWriteBenchmark.scala | 0 .../execution/datasources/AvroReadSchemaSuite.scala | 0 .../docker-integration-tests/pom.xml | 0 .../src/test/resources/db2_krb_setup.sh | 0 .../src/test/resources/log4j2.properties | 0 .../src/test/resources/mariadb_docker_entrypoint.sh | 0 .../src/test/resources/mariadb_krb_setup.sh | 0 .../src/test/resources/postgres_krb_setup.sh | 0 .../apache/spark/sql/jdbc/DB2IntegrationSuite.scala | 0 .../spark/sql/jdbc/DB2KrbIntegrationSuite.scala | 0 .../spark/sql/jdbc/DockerIntegrationFunSuite.scala | 0 .../spark/sql/jdbc/DockerJDBCIntegrationSuite.scala | 0 .../sql/jdbc/DockerKrbJDBCIntegrationSuite.scala | 0 .../spark/sql/jdbc/MariaDBKrbIntegrationSuite.scala | 0 .../spark/sql/jdbc/MsSqlServerIntegrationSuite.scala | 0 .../apache/spark/sql/jdbc/MySQLIntegrationSuite.scala | 0 .../spark/sql/jdbc/OracleIntegrationSuite.scala | 0 .../spark/sql/jdbc/PostgresIntegrationSuite.scala | 0 .../spark/sql/jdbc/PostgresKrbIntegrationSuite.scala | 0 .../spark/sql/jdbc/v2/DB2IntegrationSuite.scala | 0 .../apache/spark/sql/jdbc/v2/DB2NamespaceSuite.scala | 0 .../sql/jdbc/v2/DockerJDBCIntegrationV2Suite.scala | 0 .../sql/jdbc/v2/MsSqlServerIntegrationSuite.scala | 0 .../spark/sql/jdbc/v2/MsSqlServerNamespaceSuite.scala | 0 .../spark/sql/jdbc/v2/MySQLIntegrationSuite.scala | 0 .../spark/sql/jdbc/v2/MySQLNamespaceSuite.scala | 0 .../spark/sql/jdbc/v2/OracleIntegrationSuite.scala | 0 .../spark/sql/jdbc/v2/OracleNamespaceSuite.scala | 0 .../spark/sql/jdbc/v2/PostgresIntegrationSuite.scala | 0 .../spark/sql/jdbc/v2/PostgresNamespaceSuite.scala | 0 .../spark/sql/jdbc/v2/V2JDBCNamespaceTest.scala | 0 .../org/apache/spark/sql/jdbc/v2/V2JDBCTest.scala | 0 .../scala/org/apache/spark/util/DockerUtils.scala | 0 {external => connector}/docker/README.md | 0 {external => connector}/docker/build | 0 {external => connector}/docker/spark-test/README.md | 0 .../docker/spark-test/base/Dockerfile | 0 {external => connector}/docker/spark-test/build | 0 .../docker/spark-test/master/Dockerfile | 0 .../docker/spark-test/master/default_cmd | 0 .../docker/spark-test/worker/Dockerfile | 0 .../docker/spark-test/worker/default_cmd | 0 {external => connector}/kafka-0-10-assembly/pom.xml | 0 {external => connector}/kafka-0-10-sql/pom.xml | 0 .../org.apache.spark.sql.sources.DataSourceRegister | 0 .../apache/spark/sql/kafka010/ConsumerStrategy.scala | 0 .../org/apache/spark/sql/kafka010/JsonUtils.scala | 0 .../org/apache/spark/sql/kafka010/KafkaBatch.scala | 0 .../sql/kafka010/KafkaBatchPartitionReader.scala | 0 .../apache/spark/sql/kafka010/KafkaBatchWrite.scala | 0 .../spark/sql/kafka010/KafkaContinuousStream.scala | 0 .../apache/spark/sql/kafka010/KafkaDataWriter.scala | 0 .../spark/sql/kafka010/KafkaMicroBatchStream.scala | 0 .../sql/kafka010/KafkaOffsetRangeCalculator.scala | 0 .../spark/sql/kafka010/KafkaOffsetRangeLimit.scala | 0 .../apache/spark/sql/kafka010/KafkaOffsetReader.scala | 0 .../spark/sql/kafka010/KafkaOffsetReaderAdmin.scala | 0 .../sql/kafka010/KafkaOffsetReaderConsumer.scala | 0 .../sql/kafka010/KafkaRecordToRowConverter.scala | 0 .../org/apache/spark/sql/kafka010/KafkaRelation.scala | 0 .../org/apache/spark/sql/kafka010/KafkaSink.scala | 0 .../org/apache/spark/sql/kafka010/KafkaSource.scala | 0 .../sql/kafka010/KafkaSourceInitialOffsetWriter.scala | 0 .../apache/spark/sql/kafka010/KafkaSourceOffset.scala | 0 .../spark/sql/kafka010/KafkaSourceProvider.scala | 0 .../apache/spark/sql/kafka010/KafkaSourceRDD.scala | 0 .../spark/sql/kafka010/KafkaStreamingWrite.scala | 0 .../org/apache/spark/sql/kafka010/KafkaWrite.scala | 0 .../apache/spark/sql/kafka010/KafkaWriteTask.scala | 0 .../org/apache/spark/sql/kafka010/KafkaWriter.scala | 0 .../spark/sql/kafka010/consumer/FetchedDataPool.scala | 0 .../kafka010/consumer/InternalKafkaConsumerPool.scala | 0 .../sql/kafka010/consumer/KafkaDataConsumer.scala | 0 .../org/apache/spark/sql/kafka010/package-info.java | 0 .../scala/org/apache/spark/sql/kafka010/package.scala | 0 .../sql/kafka010/producer/CachedKafkaProducer.scala | 0 .../kafka010/producer/InternalKafkaProducerPool.scala | 0 .../kafka-source-initial-offset-future-version.bin | 0 .../kafka-source-initial-offset-version-2.1.0.bin | 0 .../resources/kafka-source-offset-version-2.1.0.txt | 0 .../src/test/resources/log4j2.properties | 0 .../commits/0 | 0 .../metadata | 0 .../offsets/0 | 0 .../sources/0/0 | Bin .../state/0/0/1.delta | Bin .../state/0/1/1.delta | Bin .../state/0/2/1.delta | Bin .../state/0/3/1.delta | Bin .../state/0/4/1.delta | Bin .../spark/sql/kafka010/ConsumerStrategySuite.scala | 0 .../apache/spark/sql/kafka010/JsonUtilsSuite.scala | 0 .../sql/kafka010/KafkaContinuousSourceSuite.scala | 0 .../spark/sql/kafka010/KafkaContinuousTest.scala | 0 .../sql/kafka010/KafkaDelegationTokenSuite.scala | 0 .../sql/kafka010/KafkaDontFailOnDataLossSuite.scala | 0 .../sql/kafka010/KafkaMicroBatchSourceSuite.scala | 0 .../kafka010/KafkaOffsetRangeCalculatorSuite.scala | 0 .../spark/sql/kafka010/KafkaOffsetReaderSuite.scala | 0 .../spark/sql/kafka010/KafkaRelationSuite.scala | 0 .../apache/spark/sql/kafka010/KafkaSinkSuite.scala | 0 .../spark/sql/kafka010/KafkaSourceOffsetSuite.scala | 0 .../spark/sql/kafka010/KafkaSourceProviderSuite.scala | 0 .../spark/sql/kafka010/KafkaSparkConfSuite.scala | 0 .../org/apache/spark/sql/kafka010/KafkaTest.scala | 0 .../apache/spark/sql/kafka010/KafkaTestUtils.scala | 0 .../org/apache/spark/sql/kafka010/RecordBuilder.scala | 0 .../sql/kafka010/consumer/FetchedDataPoolSuite.scala | 0 .../consumer/InternalKafkaConsumerPoolSuite.scala | 0 .../kafka010/consumer/KafkaDataConsumerSuite.scala | 0 .../producer/InternalKafkaProducerPoolSuite.scala | 0 .../kafka-0-10-token-provider/pom.xml | 0 ...pache.spark.security.HadoopDelegationTokenProvider | 0 .../apache/spark/kafka010/KafkaConfigUpdater.scala | 0 .../spark/kafka010/KafkaDelegationTokenProvider.scala | 0 .../apache/spark/kafka010/KafkaRedactionUtil.scala | 0 .../apache/spark/kafka010/KafkaTokenSparkConf.scala | 0 .../org/apache/spark/kafka010/KafkaTokenUtil.scala | 0 .../src/test/resources/log4j2.properties | 0 .../spark/kafka010/KafkaConfigUpdaterSuite.scala | 0 .../spark/kafka010/KafkaDelegationTokenTest.scala | 0 .../KafkaHadoopDelegationTokenManagerSuite.scala | 0 .../spark/kafka010/KafkaRedactionUtilSuite.scala | 0 .../spark/kafka010/KafkaTokenSparkConfSuite.scala | 0 .../apache/spark/kafka010/KafkaTokenUtilSuite.scala | 0 {external => connector}/kafka-0-10/pom.xml | 0 .../spark/streaming/kafka010/ConsumerStrategy.scala | 0 .../streaming/kafka010/DirectKafkaInputDStream.scala | 0 .../spark/streaming/kafka010/KafkaDataConsumer.scala | 0 .../apache/spark/streaming/kafka010/KafkaRDD.scala | 0 .../spark/streaming/kafka010/KafkaRDDPartition.scala | 0 .../apache/spark/streaming/kafka010/KafkaUtils.scala | 0 .../spark/streaming/kafka010/LocationStrategy.scala | 0 .../apache/spark/streaming/kafka010/OffsetRange.scala | 0 .../spark/streaming/kafka010/PerPartitionConfig.scala | 0 .../apache/spark/streaming/kafka010/package-info.java | 0 .../org/apache/spark/streaming/kafka010/package.scala | 0 .../streaming/kafka010/JavaConsumerStrategySuite.java | 0 .../kafka010/JavaDirectKafkaStreamSuite.java | 0 .../spark/streaming/kafka010/JavaKafkaRDDSuite.java | 0 .../streaming/kafka010/JavaLocationStrategySuite.java | 0 .../kafka-0-10}/src/test/resources/log4j2.properties | 0 .../streaming/kafka010/DirectKafkaStreamSuite.scala | 0 .../streaming/kafka010/KafkaDataConsumerSuite.scala | 0 .../spark/streaming/kafka010/KafkaRDDSuite.scala | 0 .../spark/streaming/kafka010/KafkaTestUtils.scala | 0 .../streaming/kafka010/mocks/MockScheduler.scala | 0 .../spark/streaming/kafka010/mocks/MockTime.scala | 0 {external => connector}/kinesis-asl-assembly/pom.xml | 0 {external => connector}/kinesis-asl/pom.xml | 0 .../examples/streaming/JavaKinesisWordCountASL.java | 0 .../streaming/kinesis/KinesisInitialPositions.java | 0 .../examples/streaming/kinesis_wordcount_asl.py | 0 .../kinesis-asl/src/main/resources/log4j2.properties | 0 .../examples/streaming/KinesisExampleUtils.scala | 0 .../examples/streaming/KinesisWordCountASL.scala | 0 .../streaming/kinesis/KinesisBackedBlockRDD.scala | 0 .../spark/streaming/kinesis/KinesisCheckpointer.scala | 0 .../spark/streaming/kinesis/KinesisInputDStream.scala | 0 .../streaming/kinesis/KinesisReadConfigurations.scala | 0 .../spark/streaming/kinesis/KinesisReceiver.scala | 0 .../streaming/kinesis/KinesisRecordProcessor.scala | 0 .../spark/streaming/kinesis/KinesisTestUtils.scala | 0 .../streaming/kinesis/KinesisUtilsPythonHelper.scala | 0 .../spark/streaming/kinesis/SparkAWSCredentials.scala | 0 .../kinesis/JavaKinesisInputDStreamBuilderSuite.java | 0 .../kinesis-asl/src/test/resources/log4j2.properties | 0 .../streaming/kinesis/KPLBasedKinesisTestUtils.scala | 0 .../kinesis/KinesisBackedBlockRDDSuite.scala | 0 .../streaming/kinesis/KinesisCheckpointerSuite.scala | 0 .../spark/streaming/kinesis/KinesisFunSuite.scala | 0 .../kinesis/KinesisInputDStreamBuilderSuite.scala | 0 .../streaming/kinesis/KinesisReceiverSuite.scala | 0 .../spark/streaming/kinesis/KinesisStreamSuite.scala | 0 .../kinesis/SparkAWSCredentialsBuilderSuite.scala | 0 {external => connector}/spark-ganglia-lgpl/pom.xml | 0 .../com/codahale/metrics/ganglia/GangliaReporter.java | 0 .../org/apache/spark/metrics/sink/GangliaSink.scala | 0 docs/streaming-kinesis-integration.md | 10 +++++----- pom.xml | 18 +++++++++--------- 246 files changed, 15 insertions(+), 15 deletions(-) rename {external => connector}/avro/benchmarks/AvroReadBenchmark-jdk11-results.txt (100%) rename {external => connector}/avro/benchmarks/AvroReadBenchmark-jdk17-results.txt (100%) rename {external => connector}/avro/benchmarks/AvroReadBenchmark-results.txt (100%) rename {external => connector}/avro/benchmarks/AvroWriteBenchmark-jdk11-results.txt (100%) rename {external => connector}/avro/benchmarks/AvroWriteBenchmark-jdk17-results.txt (100%) rename {external => connector}/avro/benchmarks/AvroWriteBenchmark-results.txt (100%) rename {external => connector}/avro/pom.xml (100%) rename {external => connector}/avro/src/main/java/org/apache/spark/sql/avro/SparkAvroKeyOutputFormat.java (100%) rename {external => connector}/avro/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/AvroDataToCatalyst.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/AvroFileFormat.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/AvroOptions.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/AvroOutputWriter.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/AvroOutputWriterFactory.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/AvroUtils.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/CatalystDataToAvro.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/SchemaConverters.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/functions.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/avro/package.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/v2/avro/AvroDataSourceV2.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/v2/avro/AvroPartitionReaderFactory.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/v2/avro/AvroScan.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/v2/avro/AvroScanBuilder.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/v2/avro/AvroTable.scala (100%) rename {external => connector}/avro/src/main/scala/org/apache/spark/sql/v2/avro/AvroWrite.scala (100%) rename {external => connector}/avro/src/test/java/org/apache/spark/sql/avro/JavaAvroFunctionsSuite.java (100%) rename {external => connector}/avro/src/test/resources/before_1582_date_v2_4_5.avro (100%) rename {external => connector}/avro/src/test/resources/before_1582_date_v2_4_6.avro (100%) rename {external => connector}/avro/src/test/resources/before_1582_date_v3_2_0.avro (100%) rename {external => connector}/avro/src/test/resources/before_1582_timestamp_micros_v2_4_5.avro (100%) rename {external => connector}/avro/src/test/resources/before_1582_timestamp_micros_v2_4_6.avro (100%) rename {external => connector}/avro/src/test/resources/before_1582_timestamp_micros_v3_2_0.avro (100%) rename {external => connector}/avro/src/test/resources/before_1582_timestamp_millis_v2_4_5.avro (100%) rename {external => connector}/avro/src/test/resources/before_1582_timestamp_millis_v2_4_6.avro (100%) rename {external => connector}/avro/src/test/resources/before_1582_timestamp_millis_v3_2_0.avro (100%) rename {external => connector}/avro/src/test/resources/episodes.avro (100%) rename {external/kafka-0-10 => connector/avro}/src/test/resources/log4j2.properties (100%) rename {external => connector}/avro/src/test/resources/test-random-partitioned/part-r-00000.avro (100%) rename {external => connector}/avro/src/test/resources/test-random-partitioned/part-r-00001.avro (100%) rename {external => connector}/avro/src/test/resources/test-random-partitioned/part-r-00002.avro (100%) rename {external => connector}/avro/src/test/resources/test-random-partitioned/part-r-00003.avro (100%) rename {external => connector}/avro/src/test/resources/test-random-partitioned/part-r-00004.avro (100%) rename {external => connector}/avro/src/test/resources/test-random-partitioned/part-r-00005.avro (100%) rename {external => connector}/avro/src/test/resources/test-random-partitioned/part-r-00006.avro (100%) rename {external => connector}/avro/src/test/resources/test-random-partitioned/part-r-00007.avro (100%) rename {external => connector}/avro/src/test/resources/test-random-partitioned/part-r-00008.avro (100%) rename {external => connector}/avro/src/test/resources/test-random-partitioned/part-r-00009.avro (100%) rename {external => connector}/avro/src/test/resources/test-random-partitioned/part-r-00010.avro (100%) rename {external => connector}/avro/src/test/resources/test.avro (100%) rename {external => connector}/avro/src/test/resources/test.avsc (100%) rename {external => connector}/avro/src/test/resources/test.json (100%) rename {external => connector}/avro/src/test/resources/test_sub.avsc (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/avro/AvroCatalystDataConversionSuite.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/avro/AvroCodecSuite.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/avro/AvroFunctionsSuite.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/avro/AvroLogicalTypeSuite.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/avro/AvroRowReaderSuite.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/avro/AvroScanSuite.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/avro/AvroSchemaHelperSuite.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/avro/AvroSerdeSuite.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/avro/AvroSuite.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/avro/DeprecatedAvroFunctionsSuite.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/execution/benchmark/AvroReadBenchmark.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/execution/benchmark/AvroWriteBenchmark.scala (100%) rename {external => connector}/avro/src/test/scala/org/apache/spark/sql/execution/datasources/AvroReadSchemaSuite.scala (100%) rename {external => connector}/docker-integration-tests/pom.xml (100%) rename {external => connector}/docker-integration-tests/src/test/resources/db2_krb_setup.sh (100%) rename {external => connector}/docker-integration-tests/src/test/resources/log4j2.properties (100%) rename {external => connector}/docker-integration-tests/src/test/resources/mariadb_docker_entrypoint.sh (100%) rename {external => connector}/docker-integration-tests/src/test/resources/mariadb_krb_setup.sh (100%) rename {external => connector}/docker-integration-tests/src/test/resources/postgres_krb_setup.sh (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/DB2IntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/DB2KrbIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/DockerIntegrationFunSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/DockerJDBCIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/DockerKrbJDBCIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/MariaDBKrbIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/MsSqlServerIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/MySQLIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/OracleIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/PostgresIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/PostgresKrbIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/DB2IntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/DB2NamespaceSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/DockerJDBCIntegrationV2Suite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/MsSqlServerIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/MsSqlServerNamespaceSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/MySQLIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/MySQLNamespaceSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/OracleIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/OracleNamespaceSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/PostgresIntegrationSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/PostgresNamespaceSuite.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/V2JDBCNamespaceTest.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/sql/jdbc/v2/V2JDBCTest.scala (100%) rename {external => connector}/docker-integration-tests/src/test/scala/org/apache/spark/util/DockerUtils.scala (100%) rename {external => connector}/docker/README.md (100%) rename {external => connector}/docker/build (100%) rename {external => connector}/docker/spark-test/README.md (100%) rename {external => connector}/docker/spark-test/base/Dockerfile (100%) rename {external => connector}/docker/spark-test/build (100%) rename {external => connector}/docker/spark-test/master/Dockerfile (100%) rename {external => connector}/docker/spark-test/master/default_cmd (100%) rename {external => connector}/docker/spark-test/worker/Dockerfile (100%) rename {external => connector}/docker/spark-test/worker/default_cmd (100%) rename {external => connector}/kafka-0-10-assembly/pom.xml (100%) rename {external => connector}/kafka-0-10-sql/pom.xml (100%) rename {external => connector}/kafka-0-10-sql/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/ConsumerStrategy.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/JsonUtils.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaBatch.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaBatchPartitionReader.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaBatchWrite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaContinuousStream.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaDataWriter.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchStream.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaOffsetRangeCalculator.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaOffsetRangeLimit.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaOffsetReader.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaOffsetReaderAdmin.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaOffsetReaderConsumer.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRecordToRowConverter.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRelation.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSink.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceInitialOffsetWriter.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceOffset.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceProvider.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSourceRDD.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaStreamingWrite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaWrite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaWriteTask.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaWriter.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/consumer/FetchedDataPool.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/consumer/InternalKafkaConsumerPool.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/consumer/KafkaDataConsumer.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/package-info.java (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/package.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/producer/CachedKafkaProducer.scala (100%) rename {external => connector}/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/producer/InternalKafkaProducerPool.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/kafka-source-initial-offset-future-version.bin (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/kafka-source-initial-offset-version-2.1.0.bin (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/kafka-source-offset-version-2.1.0.txt (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/log4j2.properties (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/structured-streaming/checkpoint-version-2.4.3-kafka-include-headers-default/commits/0 (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/structured-streaming/checkpoint-version-2.4.3-kafka-include-headers-default/metadata (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/structured-streaming/checkpoint-version-2.4.3-kafka-include-headers-default/offsets/0 (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/structured-streaming/checkpoint-version-2.4.3-kafka-include-headers-default/sources/0/0 (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/structured-streaming/checkpoint-version-2.4.3-kafka-include-headers-default/state/0/0/1.delta (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/structured-streaming/checkpoint-version-2.4.3-kafka-include-headers-default/state/0/1/1.delta (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/structured-streaming/checkpoint-version-2.4.3-kafka-include-headers-default/state/0/2/1.delta (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/structured-streaming/checkpoint-version-2.4.3-kafka-include-headers-default/state/0/3/1.delta (100%) rename {external => connector}/kafka-0-10-sql/src/test/resources/structured-streaming/checkpoint-version-2.4.3-kafka-include-headers-default/state/0/4/1.delta (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/ConsumerStrategySuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/JsonUtilsSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaContinuousSourceSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaContinuousTest.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaDelegationTokenSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaDontFailOnDataLossSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaMicroBatchSourceSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaOffsetRangeCalculatorSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaOffsetReaderSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaRelationSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSinkSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceOffsetSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSourceProviderSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSparkConfSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTest.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaTestUtils.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/RecordBuilder.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/consumer/FetchedDataPoolSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/consumer/InternalKafkaConsumerPoolSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/consumer/KafkaDataConsumerSuite.scala (100%) rename {external => connector}/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/producer/InternalKafkaProducerPoolSuite.scala (100%) rename {external => connector}/kafka-0-10-token-provider/pom.xml (100%) rename {external => connector}/kafka-0-10-token-provider/src/main/resources/META-INF/services/org.apache.spark.security.HadoopDelegationTokenProvider (100%) rename {external => connector}/kafka-0-10-token-provider/src/main/scala/org/apache/spark/kafka010/KafkaConfigUpdater.scala (100%) rename {external => connector}/kafka-0-10-token-provider/src/main/scala/org/apache/spark/kafka010/KafkaDelegationTokenProvider.scala (100%) rename {external => connector}/kafka-0-10-token-provider/src/main/scala/org/apache/spark/kafka010/KafkaRedactionUtil.scala (100%) rename {external => connector}/kafka-0-10-token-provider/src/main/scala/org/apache/spark/kafka010/KafkaTokenSparkConf.scala (100%) rename {external => connector}/kafka-0-10-token-provider/src/main/scala/org/apache/spark/kafka010/KafkaTokenUtil.scala (100%) rename {external => connector}/kafka-0-10-token-provider/src/test/resources/log4j2.properties (100%) rename {external => connector}/kafka-0-10-token-provider/src/test/scala/org/apache/spark/kafka010/KafkaConfigUpdaterSuite.scala (100%) rename {external => connector}/kafka-0-10-token-provider/src/test/scala/org/apache/spark/kafka010/KafkaDelegationTokenTest.scala (100%) rename {external => connector}/kafka-0-10-token-provider/src/test/scala/org/apache/spark/kafka010/KafkaHadoopDelegationTokenManagerSuite.scala (100%) rename {external => connector}/kafka-0-10-token-provider/src/test/scala/org/apache/spark/kafka010/KafkaRedactionUtilSuite.scala (100%) rename {external => connector}/kafka-0-10-token-provider/src/test/scala/org/apache/spark/kafka010/KafkaTokenSparkConfSuite.scala (100%) rename {external => connector}/kafka-0-10-token-provider/src/test/scala/org/apache/spark/kafka010/KafkaTokenUtilSuite.scala (100%) rename {external => connector}/kafka-0-10/pom.xml (100%) rename {external => connector}/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/ConsumerStrategy.scala (100%) rename {external => connector}/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/DirectKafkaInputDStream.scala (100%) rename {external => connector}/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaDataConsumer.scala (100%) rename {external => connector}/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaRDD.scala (100%) rename {external => connector}/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaRDDPartition.scala (100%) rename {external => connector}/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaUtils.scala (100%) rename {external => connector}/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/LocationStrategy.scala (100%) rename {external => connector}/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/OffsetRange.scala (100%) rename {external => connector}/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/PerPartitionConfig.scala (100%) rename {external => connector}/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/package-info.java (100%) rename {external => connector}/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/package.scala (100%) rename {external => connector}/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaConsumerStrategySuite.java (100%) rename {external => connector}/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaDirectKafkaStreamSuite.java (100%) rename {external => connector}/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaKafkaRDDSuite.java (100%) rename {external => connector}/kafka-0-10/src/test/java/org/apache/spark/streaming/kafka010/JavaLocationStrategySuite.java (100%) rename {external/avro => connector/kafka-0-10}/src/test/resources/log4j2.properties (100%) rename {external => connector}/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/DirectKafkaStreamSuite.scala (100%) rename {external => connector}/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaDataConsumerSuite.scala (100%) rename {external => connector}/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaRDDSuite.scala (100%) rename {external => connector}/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaTestUtils.scala (100%) rename {external => connector}/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/mocks/MockScheduler.scala (100%) rename {external => connector}/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/mocks/MockTime.scala (100%) rename {external => connector}/kinesis-asl-assembly/pom.xml (100%) rename {external => connector}/kinesis-asl/pom.xml (100%) rename {external => connector}/kinesis-asl/src/main/java/org/apache/spark/examples/streaming/JavaKinesisWordCountASL.java (100%) rename {external => connector}/kinesis-asl/src/main/java/org/apache/spark/streaming/kinesis/KinesisInitialPositions.java (100%) rename {external => connector}/kinesis-asl/src/main/python/examples/streaming/kinesis_wordcount_asl.py (100%) rename {external => connector}/kinesis-asl/src/main/resources/log4j2.properties (100%) rename {external => connector}/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisExampleUtils.scala (100%) rename {external => connector}/kinesis-asl/src/main/scala/org/apache/spark/examples/streaming/KinesisWordCountASL.scala (100%) rename {external => connector}/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisBackedBlockRDD.scala (100%) rename {external => connector}/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisCheckpointer.scala (100%) rename {external => connector}/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisInputDStream.scala (100%) rename {external => connector}/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReadConfigurations.scala (100%) rename {external => connector}/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisReceiver.scala (100%) rename {external => connector}/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisRecordProcessor.scala (100%) rename {external => connector}/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisTestUtils.scala (100%) rename {external => connector}/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/KinesisUtilsPythonHelper.scala (100%) rename {external => connector}/kinesis-asl/src/main/scala/org/apache/spark/streaming/kinesis/SparkAWSCredentials.scala (100%) rename {external => connector}/kinesis-asl/src/test/java/org/apache/spark/streaming/kinesis/JavaKinesisInputDStreamBuilderSuite.java (100%) rename {external => connector}/kinesis-asl/src/test/resources/log4j2.properties (100%) rename {external => connector}/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KPLBasedKinesisTestUtils.scala (100%) rename {external => connector}/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisBackedBlockRDDSuite.scala (100%) rename {external => connector}/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisCheckpointerSuite.scala (100%) rename {external => connector}/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisFunSuite.scala (100%) rename {external => connector}/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisInputDStreamBuilderSuite.scala (100%) rename {external => connector}/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisReceiverSuite.scala (100%) rename {external => connector}/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/KinesisStreamSuite.scala (100%) rename {external => connector}/kinesis-asl/src/test/scala/org/apache/spark/streaming/kinesis/SparkAWSCredentialsBuilderSuite.scala (100%) rename {external => connector}/spark-ganglia-lgpl/pom.xml (100%) rename {external => connector}/spark-ganglia-lgpl/src/main/java/com/codahale/metrics/ganglia/GangliaReporter.java (100%) rename {external => connector}/spark-ganglia-lgpl/src/main/scala/org/apache/spark/metrics/sink/GangliaSink.scala (100%) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org