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: [email protected]
For additional commands, e-mail: [email protected]
