spark
Apache Spark - 대규모 데이터 처리를 위한 통합 분석 엔진
파일 탐색기
최종 버전 다운로드 (.zip)파일 수가 많아 일부만 표시됩니다. 전체 파일은 위 다운로드 버튼으로 확인해 주세요.
- action.yml
- workflow-enable-button.png
- benchmark.yml
- branch35_scheduler.yml
- branch40_scheduler.yml
- branch41_scheduler.yml
- branch42_scheduler.yml
- branch43_scheduler.yml
- branch4x_scheduler.yml
- build_and_test.yml
- build_codegen_jdk.yml
- build_coverage.yml
- build_infra_images_cache.yml
- build_java17.yml
- build_java21.yml
- build_java25.yml
- build_main.yml
- build_maven.yml
- build_maven_java21.yml
- build_maven_java21_arm.yml
- build_maven_java21_macos26.yml
- build_maven_java25.yml
- build_non_ansi.yml
- build_python_3.11.yml
- build_python_3.12_arm.yml
- build_python_3.12_classic_only.yml
- build_python_3.12_macos26.yml
- build_python_3.12_pandas_3.yml
- build_python_3.13.yml
- build_python_3.14.yml
- build_python_3.14_nogil.yml
- build_python_3.9.yml
- build_python_connect.yml
- build_python_connect40.yml
- build_python_minimum.yml
- build_python_pypy3.10.yml
- build_rockdb_as_ui_backend.yml
- build_scala213.yml
- build_sparkr_window.yml
- build_uds.yml
- maven_test.yml
- notify_test_workflow.yml
- pages.yml
- publish_snapshot.yml
- python_hosted_runner_test.yml
- release.yml
- stale.yml
- test_report.yml
- update_build_status.yml
- PULL_REQUEST_TEMPLATE
- jvm.config
- maven.config
- pom.xml
- beeline
- beeline.cmd
- docker-image-tool.sh
- find-spark-home
- find-spark-home.cmd
- load-spark-env.cmd
- load-spark-env.sh
- pyspark
- pyspark.cmd
- pyspark2.cmd
- run-example
- run-example.cmd
- spark-class
- spark-class.cmd
- spark-class2.cmd
- spark-connect-shell
- spark-pipelines
- spark-shell
- spark-shell.cmd
- spark-shell2.cmd
- spark-sql
- spark-sql.cmd
- spark-sql2.cmd
- spark-submit
- spark-submit.cmd
- spark-submit2.cmd
- sparkR
- sparkR.cmd
- sparkR2.cmd
- Dockerfile
- postBuild
- mvn
- sbt
- sbt-launch-lib.bash
- spark-build-info
- spark-build-info.ps1
- util.sh
- ConfigRegistry.java
- config_schema.proto
- buf.yaml
- sql.textproto
- sql.textproto
- ConfigRegistrySuite.java
- duplicate_key_file2.textproto
- invalid_missing_binding_policy.textproto
- invalid_missing_doc.textproto
- invalid_missing_key.textproto
- invalid_missing_mutability.textproto
- invalid_missing_scope.textproto
- invalid_missing_value_type.textproto
- invalid_missing_visibility.textproto
- invalid_testdefault_without_default.textproto
- invalid_unordered.textproto
- test_configs.textproto
- pom.xml
- README.md
- ArrayWrappers.java
- InMemoryStore.java
- KVIndex.java
- KVStore.java
- KVStoreIterator.java
- KVStoreSerializer.java
- KVStoreView.java
- KVTypeInfo.java
- LevelDB.java
- LevelDBIterator.java
- LevelDBTypeInfo.java
- RocksDB.java
- RocksDBIterator.java
- RocksDBTypeInfo.java
- UnsupportedStoreVersionException.java
- ArrayKeyIndexType.java
- ArrayWrappersSuite.java
- CustomType1.java
- CustomType2.java
- DBIteratorCompareSuite.java
- DBIteratorSuite.java
- InMemoryIteratorSuite.java
- InMemoryStoreSuite.java
- IntKeyType.java
- LevelDBBenchmark.java
- LevelDBIteratorSuite.java
- LevelDBSuite.java
- LevelDBTypeInfoSuite.java
- RocksDBIteratorSuite.java
- RocksDBSuite.java
- RocksDBTypeInfoSuite.java
- log4j2.properties
- pom.xml
- FileSegmentManagedBuffer.java
- ManagedBuffer.java
- NettyManagedBuffer.java
- NioManagedBuffer.java
- BaseResponseCallback.java
- ChunkFetchFailureException.java
- ChunkReceivedCallback.java
- MergedBlockMetaResponseCallback.java
- RpcResponseCallback.java
- StreamCallback.java
- StreamCallbackWithID.java
- StreamInterceptor.java
- TransportClient.java
- TransportClientBootstrap.java
- TransportClientFactory.java
- TransportResponseHandler.java
- AuthClientBootstrap.java
- AuthEngine.java
- AuthMessage.java
- AuthRpcHandler.java
- AuthServerBootstrap.java
- CtrTransportCipher.java
- GcmTransportCipher.java
- README.md
- TransportCipher.java
- TransportCipherUtil.java
- AbstractMessage.java
- AbstractResponseMessage.java
- ChunkFetchFailure.java
- ChunkFetchRequest.java
- ChunkFetchSuccess.java
- Encodable.java
- Encoders.java
- EncryptedMessageWithHeader.java
- MergedBlockMetaRequest.java
- MergedBlockMetaSuccess.java
- Message.java
- MessageDecoder.java
- MessageEncoder.java
- MessageWithHeader.java
- OneWayMessage.java
- RequestMessage.java
- ResponseMessage.java
- RpcFailure.java
- RpcRequest.java
- RpcResponse.java
- SslMessageEncoder.java
- StreamChunkId.java
- StreamFailure.java
- StreamRequest.java
- StreamResponse.java
- UploadStream.java
- SaslClientBootstrap.java
- SaslEncryption.java
- SaslEncryptionBackend.java
- SaslMessage.java
- SaslRpcHandler.java
- SaslServerBootstrap.java
- SaslTimeoutException.java
- SecretKeyHolder.java
- SparkSaslClient.java
- SparkSaslServer.java
- AbstractAuthRpcHandler.java
- BlockPushNonFatalFailure.java
- ChunkFetchRequestHandler.java
- MessageHandler.java
- NoOpRpcHandler.java
- OneForOneStreamManager.java
- RpcHandler.java
- StreamManager.java
- TransportChannelHandler.java
- TransportRequestHandler.java
- TransportServer.java
- TransportServerBootstrap.java
- CreditControlMessage.java
- DataMessage.java
- ShuffleChecksum.java
- StreamingShuffleMessage.java
- StreamingShuffleMessageType.java
- TerminationAckMessage.java
- TerminationControlMessage.java
- DB.java
- DBBackend.java
- DBIterator.java
- LevelDB.java
- LevelDBIterator.java
- RocksDB.java
- RocksDBIterator.java
- StoreVersion.java
- ReloadingX509TrustManager.java
- SSLFactory.java
- AbstractFileRegion.java
- ByteArrayReadableChannel.java
- ByteArrayWritableChannel.java
- ByteBufferWriteableChannel.java
- ConfigProvider.java
- CryptoUtils.java
- DBProvider.java
- IOMode.java
- LevelDBProvider.java
- LimitedInputStream.java
- MapConfigProvider.java
- NettyLogger.java
- NettyMemoryMetrics.java
- NettyUtils.java
- RocksDBProvider.java
- TimerWithCustomTimeUnit.java
- TransportConf.java
- TransportFrameDecoder.java
- TransportContext.java
- SslTransportClientFactorySuite.java
- TransportClientFactorySuite.java
- TransportClientSuite.java
- AuthEngineSuite.java
- AuthIntegrationSuite.java
- AuthMessagesSuite.java
- CtrAuthEngineSuite.java
- GcmAuthEngineSuite.java
- TransportCipherSuite.java
- EncodersSuite.java
- EncryptedMessageWithHeaderSuite.java
- MergedBlockMetaSuccessSuite.java
- MessageWithHeaderSuite.java
- SparkSaslSuite.java
- OneForOneStreamManagerSuite.java
- StreamingShuffleMessageSuite.java
- ReloadingX509TrustManagerSuite.java
- SSLFactorySuite.java
- SslSampleConfigs.java
- CryptoUtilsSuite.java
- DBProviderSuite.java
- JavaUtilsSuite.java
- NettyMemoryMetricsSuite.java
- TimerWithCustomUnitSuite.java
- TransportFrameDecoderSuite.java
- ChunkFetchIntegrationSuite.java
- ChunkFetchRequestHandlerSuite.java
- ExtendedChannelPromise.java
- ProtocolSuite.java
- RequestTimeoutIntegrationSuite.java
- RpcIntegrationSuite.java
- SslChunkFetchIntegrationSuite.java
- StreamSuite.java
- StreamTestHelper.java
- TestManagedBuffer.java
- TestUtils.java
- TransportConfSuite.java
- TransportRequestHandlerSuite.java
- TransportResponseHandlerSuite.java
- certchain.pem
- key.pem
- keystore
- log4j2.properties
- truststore
- unencrypted-certchain.pem
- unencrypted-key.pem
- untrusted-keystore
- pom.xml
- ShuffleSecretManager.java
- Cause.java
- ShuffleChecksumHelper.java
- AbstractFetchShuffleBlocks.java
- BlockPushReturnCode.java
- BlocksRemoved.java
- BlockTransferMessage.java
- CorruptionCause.java
- DiagnoseCorruption.java
- ExecutorShuffleInfo.java
- FetchShuffleBlockChunks.java
- FetchShuffleBlocks.java
- FinalizeShuffleMerge.java
- GetLocalDirsForExecutors.java
- LocalDirsForExecutors.java
- MergeStatuses.java
- OpenBlocks.java
- PushBlockStream.java
- RegisterExecutor.java
- RemoveBlocks.java
- RemoveShuffleMerge.java
- StreamHandle.java
- UploadBlock.java
- UploadBlockStream.java
- AppsWithRecoveryDisabled.java
- BlockFetchingListener.java
- BlockPushingListener.java
- BlockStoreClient.java
- BlockTransferListener.java
- Constants.java
- DownloadFile.java
- DownloadFileManager.java
- DownloadFileWritableChannel.java
- ErrorHandler.java
- ExecutorDiskUtils.java
- ExternalBlockHandler.java
- ExternalBlockStoreClient.java
- ExternalShuffleBlockResolver.java
- LocalDirValidator.java
- MergedBlockMeta.java
- MergedBlocksMetaListener.java
- MergedShuffleFileManager.java
- MergeFinalizerListener.java
- NoOpMergedShuffleFileManager.java
- OneForOneBlockFetcher.java
- OneForOneBlockPusher.java
- RemoteBlockPushResolver.java
- RetryingBlockTransferor.java
- ShuffleIndexInformation.java
- ShuffleIndexRecord.java
- ShuffleTransportContext.java
- SimpleDownloadFile.java
- SaslIntegrationSuite.java
- ShuffleSecretManagerSuite.java
- FetchShuffleBlockChunksSuite.java
- FetchShuffleBlocksSuite.java
- AppIsolationSuite.java
- BlockTransferMessagesSuite.java
- CleanupNonShuffleServiceServedFilesSuite.java
- ErrorHandlerSuite.java
- ExternalBlockHandlerSuite.java
- ExternalShuffleBlockResolverSuite.java
- ExternalShuffleCleanupSuite.java
- ExternalShuffleIntegrationSuite.java
- ExternalShuffleSecuritySuite.java
- LocalDirValidatorSuite.java
- OneForOneBlockFetcherSuite.java
- OneForOneBlockPusherSuite.java
- RemoteBlockPushResolverSuite.java
- RetryingBlockTransferorSuite.java
- ShuffleIndexInformationSuite.java
- ShuffleTransportContextSuite.java
- SimpleDownloadFileSuite.java
- SslExternalShuffleIntegrationSuite.java
- SslExternalShuffleSecuritySuite.java
- SslShuffleTransportContextSuite.java
- TestShuffleDataContext.java
- certchain.pem
- key.pem
- keystore
- log4j2.properties
- truststore
- unencrypted-certchain.pem
- unencrypted-key.pem
- untrusted-keystore
- pom.xml
- HadoopConfigProvider.java
- YarnShuffleService.java
- YarnShuffleServiceMetrics.java
- pom.xml
- BitArray.java
- BloomFilter.java
- BloomFilterBase.java
- BloomFilterImpl.java
- BloomFilterImplV2.java
- CountMinSketch.java
- CountMinSketchImpl.java
- IncompatibleMergeException.java
- Murmur3_x86_32.java
- Platform.java
- Utils.java
- SparkBloomFilterSuite.java
- BitArraySuite.scala
- BloomFilterSuite.scala
- CountMinSketchSuite.scala
- pom.xml
- AlphaComponent.java
- ClassicOnly.java
- DeveloperApi.java
- Evolving.java
- Experimental.java
- Private.java
- Stable.java
- Unstable.java
- package-info.java
- package.scala
- Since.scala
- AmmoniteTest.java
- ChromeUITest.java
- DockerTest.java
- ExtendedHiveTest.java
- ExtendedLevelDBTest.java
- ExtendedSQLTest.java
- ExtendedYarnTest.java
- SlowHiveTest.java
- SlowSQLTest.java
- WebBrowserTest.java
- pom.xml
- README.md
- HiveHasher.java
- CollationAwareUTF8String.java
- CollationFactory.java
- CollationNames.java
- CollationSupport.java
- DateTimeConstants.java
- SpecialCodePointConstants.java
- ByteArrayMethods.java
- LongArray.java
- BitSetMethods.java
- Murmur3_x86_32.java
- HeapMemoryAllocator.java
- MemoryAllocator.java
- MemoryBlock.java
- MemoryLocation.java
- UnsafeMemoryAllocator.java
- BinaryView.java
- ByteArray.java
- CalendarInterval.java
- TimestampNanosVal.java
- UTF8String.java
- VariantVal.java
- KVIterator.java
- Platform.java
- UnsafeAlignedOffset.java
- UTF8StringBuilder.java
- ByteArraySuite.java
- LongArraySuite.java
- Murmur3_x86_32Suite.java
- BinaryViewSuite.java
- CalendarIntervalSuite.java
- CollationSupportSuite.java
- TimestampNanosSuite.java
- UTF8StringSuite.java
- PlatformUtilSuite.java
- CollationFactorySuite.scala
- UTF8StringPropertyCheckSuite.scala
- pom.xml
- StorageLevelMapper.java
- SparkThrowable.java
- error-classes.json
- error-conditions.json
- error-states.json
- README.md
- package.scala
- ConfigBindingPolicy.scala
- ConfigBuilder.scala
- ConfigEntry.scala
- ConfigProvider.scala
- ConfigReader.scala
- Logging.scala
- SparkListenerEvent.scala
- StreamingQueryException.scala
- StorageLevel.scala
- ArrayImplicits.scala
- ClosureCleaner.scala
- CompletionIterator.scala
- JsonUtils.scala
- LexicalThreadLocal.scala
- LogUtils.scala
- MavenUtils.scala
- SparkClassUtils.scala
- SparkCollectionUtils.scala
- SparkEnvUtils.scala
- SparkErrorUtils.scala
- SparkFatalException.scala
- SparkFileUtils.scala
- SparkSchemaUtils.scala
- SparkSerDeUtils.scala
- SparkStreamUtils.scala
- SparkStringUtils.scala
- SparkSystemUtils.scala
- SparkTestUtils.scala
- SparkThreadUtils.scala
- VersionUtils.scala
- ErrorClassesJSONReader.scala
- SparkBuildInfo.scala
- SparkException.scala
- SparkThrowableHelper.scala
- StringSubstitutor.scala
- log4j2.properties
- StreamingQueryExceptionSuite.scala
- IvyTestUtils.scala
- LogKeysSuite.scala
- LogThrottlingSuite.scala
- MavenUtilsSuite.scala
- MaybeNull.scala
- MDCSuite.scala
- PatternLoggingSuite.scala
- SparkErrorUtilsSuite.scala
- SparkFileUtilsSuite.scala
- SparkStringUtilsSuite.scala
- SparkTestUtilsSuite.scala
- StructuredLoggingSuite.scala
- VersionUtilsSuite.scala
- StringSubstitutorSuite.scala
- pom.xml
- CoGroupFunction.java
- DoubleFlatMapFunction.java
- DoubleFunction.java
- FilterFunction.java
- FlatMapFunction.java
- FlatMapFunction2.java
- FlatMapGroupsFunction.java
- ForeachFunction.java
- ForeachPartitionFunction.java
- Function.java
- Function0.java
- Function2.java
- Function3.java
- Function4.java
- MapFunction.java
- MapGroupsFunction.java
- MapPartitionsFunction.java
- package-info.java
- PairFlatMapFunction.java
- PairFunction.java
- ReduceFunction.java
- VoidFunction.java
- VoidFunction2.java
- LogKey.java
- LogKeys.java
- MDC.java
- SparkLogger.java
- SparkLoggerFactory.java
- MemoryMode.java
- ByteUnit.java
- JavaUtils.java
- ByteArrayUtils.java
- Pair.java
- UUIDv7Generator.java
- QueryContext.java
- QueryContextType.java
- log4j2-defaults.properties
- log4j2-json-layout.properties
- SparkLayout.json
- ByteUnitSuite.java
- CustomLogKeys.java
- PatternSparkLoggerSuite.java
- SparkLoggerSuiteBase.java
- StructuredSparkLoggerSuite.java
- UUIDv7GeneratorSuite.java
- log4j2.properties
- pom.xml
- ShreddingUtils.java
- Variant.java
- VariantBuilder.java
- VariantPathTypeMismatchException.java
- VariantSchema.java
- VariantShreddingWriter.java
- VariantSizeLimitException.java
- VariantUtil.java
- VariantUtf8DecodeSuite.scala
- pom.xml
- README.md
- fairscheduler.xml.template
- log4j2-json-layout.properties.template
- log4j2.properties.template
- metrics.properties.template
- spark-defaults.conf.template
- spark-env.sh.template
- workers.template
- AvroReadBenchmark-jdk21-results.txt
- AvroReadBenchmark-jdk25-results.txt
- AvroReadBenchmark-results.txt
- AvroWriteBenchmark-jdk21-results.txt
- AvroWriteBenchmark-jdk25-results.txt
- AvroWriteBenchmark-results.txt
- org.apache.spark.sql.sources.DataSourceRegister
- AvroDataToCatalyst.scala
- AvroExpressionEvalUtils.scala
- CatalystDataToAvro.scala
- package.scala
- SchemaOfAvro.scala
- AvroDataSourceV2.scala
- AvroPartitionReaderFactory.scala
- AvroScan.scala
- AvroScanBuilder.scala
- AvroTable.scala
- AvroWrite.scala
- JavaAvroFunctionsSuite.java
- part-r-00000.avro
- part-r-00001.avro
- part-r-00002.avro
- part-r-00003.avro
- part-r-00004.avro
- part-r-00005.avro
- part-r-00006.avro
- part-r-00007.avro
- part-r-00008.avro
- part-r-00009.avro
- part-r-00010.avro
- before_1582_date_v2_4_5.avro
- before_1582_date_v2_4_6.avro
- before_1582_date_v3_2_0.avro
- before_1582_timestamp_micros_v2_4_5.avro
- before_1582_timestamp_micros_v2_4_6.avro
- before_1582_timestamp_micros_v3_2_0.avro
- before_1582_timestamp_millis_v2_4_5.avro
- before_1582_timestamp_millis_v2_4_6.avro
- before_1582_timestamp_millis_v3_2_0.avro
- empty_blocks.avro
- empty_file.avro
- episodes.avro
- log4j2.properties
- test.avro
- test.avsc
- test.json
- test_sub.avsc
- AvroCatalystDataConversionSuite.scala
- AvroCodecSuite.scala
- AvroFunctionsSuite.scala
- AvroLogicalTypeInitSuite.scala
- AvroLogicalTypeSuite.scala
- AvroRowReaderSuite.scala
- AvroScanSuite.scala
- AvroSchemaHelperSuite.scala
- AvroSerdeSuite.scala
- AvroSuite.scala
- DeprecatedAvroFunctionsSuite.scala
- AvroReadBenchmark.scala
- AvroWriteBenchmark.scala
- AvroArchiveReadBase.scala
- AvroReadSchemaSuite.scala
- pom.xml
- AwsStsCredentialProvider.java
- org.apache.spark.security.CredentialProvider
- AwsStsCredentialProviderSuite.java
- pom.xml
- db2-krb-setup.sh
- log4j2.properties
- mariadb-docker-entrypoint.sh
- mariadb-krb-setup.sh
- postgres-krb-setup.sh
- CrossDbmsQueryTestSuite.scala
- GeneratedSubquerySuite.scala
- PostgresSQLQueryTestSuite.scala
- MsSqlServerJoinPushdownIntegrationSuite.scala
- MySQLJoinPushdownIntegrationSuite.scala
- OracleJoinPushdownIntegrationSuite.scala
- PostgresJoinPushdownIntegrationSuite.scala
- DB2IntegrationSuite.scala
- DB2NamespaceSuite.scala
- DockerJDBCIntegrationV2Suite.scala
- MsSqlServerIntegrationSuite.scala
- MsSqlServerNamespaceSuite.scala
- MySQLIntegrationSuite.scala
- MySQLNamespaceSuite.scala
- OracleIntegrationSuite.scala
- OracleNamespaceSuite.scala
- PostgresIntegrationSuite.scala
- PostgresNamespaceSuite.scala
- V2JDBCNamespaceTest.scala
- V2JDBCTest.scala
- DB2DatabaseOnDocker.scala
- DB2IntegrationSuite.scala
- DB2KrbIntegrationSuite.scala
- DockerIntegrationFunSuite.scala
- DockerJDBCIntegrationSuite.scala
- DockerKrbJDBCIntegrationSuite.scala
- MariaDBDatabaseOnDocker.scala
- MariaDBKrbIntegrationSuite.scala
- MsSQLServerDatabaseOnDocker.scala
- MsSqlServerIntegrationSuite.scala
- MySQLDatabaseOnDocker.scala
- MySQLIntegrationSuite.scala
- OracleDatabaseOnDocker.scala
- OracleIntegrationSuite.scala
- PostgresDatabaseOnDocker.scala
- PostgresIntegrationSuite.scala
- PostgresKrbIntegrationSuite.scala
- SharedJDBCIntegrationSuite.scala
- StarRocksDatabaseOnDocker.scala
- StarRocksIntegrationSuite.scala
- DockerUtils.scala
- pom.xml
- README.md
- ConsumerStrategy.scala
- DirectKafkaInputDStream.scala
- KafkaDataConsumer.scala
- KafkaRDD.scala
- KafkaRDDPartition.scala
- KafkaUtils.scala
- LocationStrategy.scala
- OffsetRange.scala
- package-info.java
- package.scala
- PerPartitionConfig.scala
- JavaConsumerStrategySuite.java
- JavaDirectKafkaStreamSuite.java
- JavaKafkaRDDSuite.java
- JavaLocationStrategySuite.java
- log4j2.properties
- MockScheduler.scala
- MockTime.scala
- DirectKafkaStreamSuite.scala
- KafkaDataConsumerSuite.scala
- KafkaRDDSuite.scala
- KafkaTestUtils.scala
- pom.xml
- pom.xml
- RTMKafkaKafkaBenchmark-results.txt
- kafka-error-conditions.json
- org.apache.spark.sql.sources.DataSourceRegister
- FetchedDataPool.scala
- InternalKafkaConsumerPool.scala
- KafkaDataConsumer.scala
- CachedKafkaProducer.scala
- InternalKafkaProducerPool.scala
- ConsumerStrategy.scala
- JsonUtils.scala
- KafkaBatch.scala
- KafkaBatchPartitionReader.scala
- KafkaBatchWrite.scala
- KafkaContinuousStream.scala
- KafkaDataWriter.scala
- KafkaExceptions.scala
- KafkaMicroBatchStream.scala
- KafkaOffsetRangeCalculator.scala
- KafkaOffsetRangeLimit.scala
- KafkaOffsetReader.scala
- KafkaOffsetReaderAdmin.scala
- KafkaOffsetReaderConsumer.scala
- KafkaRecordToRowConverter.scala
- KafkaRelation.scala
- KafkaSink.scala
- KafkaSource.scala
- KafkaSourceInitialOffsetWriter.scala
- KafkaSourceOffset.scala
- KafkaSourceProvider.scala
- KafkaSourceRDD.scala
- KafkaStreamingWrite.scala
- KafkaWrite.scala
- KafkaWriter.scala
- KafkaWriteTask.scala
- package-info.java
- package.scala
- 0
- 0
- 0
- 1.delta
- 1.delta
- 1.delta
- 1.delta
- 1.delta
- metadata
- kafka-source-initial-offset-future-version.bin
- kafka-source-initial-offset-version-2.1.0.bin
- kafka-source-offset-version-2.1.0.txt
- log4j2.properties
- RTMKafkaKafkaBenchmark.scala
- FetchedDataPoolSuite.scala
- InternalKafkaConsumerPoolSuite.scala
- KafkaDataConsumerSuite.scala
- InternalKafkaProducerPoolSuite.scala
- ConsumerStrategySuite.scala
- JsonUtilsSuite.scala
- KafkaContinuousSourceSuite.scala
- KafkaContinuousTest.scala
- KafkaDelegationTokenSuite.scala
- KafkaDontFailOnDataLossSuite.scala
- KafkaMicroBatchSourceSuite.scala
- KafkaOffsetRangeCalculatorSuite.scala
- KafkaOffsetReaderSuite.scala
- KafkaRealTimeIntegrationSuite.scala
- KafkaRealTimeModeAggregationSuite.scala
- KafkaRealTimeModeBaseSuite.scala
- KafkaRealTimeModeSuite.scala
- KafkaRealTimeModeWindowSuite.scala
- KafkaRelationSuite.scala
- KafkaSinkSuite.scala
- KafkaSourceOffsetSuite.scala
- KafkaSourceProviderSuite.scala
- KafkaSparkConfSuite.scala
- KafkaTest.scala
- KafkaTestUtils.scala
- RecordBuilder.scala
- pom.xml
- kafka-token-provider-error-conditions.json
- org.apache.spark.security.HadoopDelegationTokenProvider
- KafkaConfigUpdater.scala
- KafkaDelegationTokenProvider.scala
- KafkaRedactionUtil.scala
- KafkaTokenProviderException.scala
- KafkaTokenSparkConf.scala
- KafkaTokenUtil.scala
- log4j2.properties
- KafkaConfigUpdaterSuite.scala
- KafkaDelegationTokenTest.scala
- KafkaHadoopDelegationTokenManagerSuite.scala
- KafkaRedactionUtilSuite.scala
- KafkaTokenSparkConfSuite.scala
- KafkaTokenUtilSuite.scala
- pom.xml
- JavaKinesisWordCountASL.java
- KinesisInitialPositions.java
- kinesis_wordcount_asl.py
- log4j2.properties
- KinesisExampleUtils.scala
- KinesisWordCountASL.scala
- KinesisBackedBlockRDD.scala
- KinesisCheckpointer.scala
- KinesisInputDStream.scala
- KinesisReadConfigurations.scala
- KinesisReceiver.scala
- KinesisRecordProcessor.scala
- KinesisUtilsPythonHelper.scala
- SparkAWSCredentials.scala
- JavaKinesisInputDStreamBuilderSuite.java
- log4j2.properties
- KinesisBackedBlockRDDSuite.scala
- KinesisCheckpointerSuite.scala
- KinesisFunSuite.scala
- KinesisInputDStreamBuilderSuite.scala
- KinesisReceiverSuite.scala
- KinesisStreamSuite.scala
- KinesisTestUtils.scala
- KPLBasedKinesisTestUtils.scala
- SparkAWSCredentialsBuilderSuite.scala
- pom.xml
- pom.xml
- package.scala
- ProfilerPlugin.scala
- SparkAsyncProfiler.scala
- pom.xml
- README.md
- ProtobufOptions.scala
- ProtobufUtils.scala
- SchemaConverters.scala
- CatalystDataToProtobuf.scala
- package.scala
- ProtobufDataToCatalyst.scala
- ProtobufDeserializer.scala
- ProtobufSerializer.scala
- basicmessage.proto
- catalyst_types.proto
- duration.proto
- functions_suite.proto
- nestedenum.proto
- proto2_messages.proto
- proto2_messages_ext.proto
- pyspark_test.proto
- serde_suite.proto
- timestamp.proto
- log4j2.properties
- ProtobufCatalystDataConversionSuite.scala
- ProtobufDescriptorFileReadSuite.scala
- ProtobufExtensionsSuite.scala
- ProtobufFunctionsSuite.scala
- ProtobufSerdeSuite.scala
- ProtobufTestBase.scala
- pom.xml
- README.md
- GangliaReporter.java
- GangliaSink.scala
- pom.xml
- ChecksumBenchmark-jdk21-results.txt
- ChecksumBenchmark-jdk25-results.txt
- ChecksumBenchmark-results.txt
- CoalescedRDDBenchmark-jdk21-results.txt
- CoalescedRDDBenchmark-jdk25-results.txt
- CoalescedRDDBenchmark-results.txt
- KryoBenchmark-jdk21-results.txt
- KryoBenchmark-jdk25-results.txt
- KryoBenchmark-results.txt
- KryoIteratorBenchmark-jdk21-results.txt
- KryoIteratorBenchmark-jdk25-results.txt
- KryoIteratorBenchmark-results.txt
- KryoSerializerBenchmark-jdk21-results.txt
- KryoSerializerBenchmark-jdk25-results.txt
- KryoSerializerBenchmark-results.txt
- LZ4TPCDSDataBenchmark-jdk21-results.txt
- LZ4TPCDSDataBenchmark-jdk25-results.txt
- LZ4TPCDSDataBenchmark-results.txt
- LZFBenchmark-jdk21-results.txt
- LZFBenchmark-jdk25-results.txt
- LZFBenchmark-results.txt
- MapStatusesConvertBenchmark-jdk21-results.txt
- MapStatusesConvertBenchmark-jdk25-results.txt
- MapStatusesConvertBenchmark-results.txt
- MapStatusesSerDeserBenchmark-jdk21-results.txt
- MapStatusesSerDeserBenchmark-jdk25-results.txt
- MapStatusesSerDeserBenchmark-results.txt
- NettyTransportBenchmark-jdk21-results.txt
- NettyTransportBenchmark-jdk25-results.txt
- NettyTransportBenchmark-results.txt
- OpenHashMapBenchmark-jdk21-results.txt
- OpenHashMapBenchmark-jdk25-results.txt
- OpenHashMapBenchmark-results.txt
- PercentileHeapBenchmark-jdk21-results.txt
- PercentileHeapBenchmark-jdk25-results.txt
- PercentileHeapBenchmark-results.txt
- PersistenceEngineBenchmark-jdk21-results.txt
- PersistenceEngineBenchmark-jdk25-results.txt
- PersistenceEngineBenchmark-results.txt
- PlatformBenchmark-jdk21-results.txt
- PlatformBenchmark-jdk25-results.txt
- PlatformBenchmark-results.txt
- PropertiesCloneBenchmark-jdk21-results.txt
- PropertiesCloneBenchmark-jdk25-results.txt
- PropertiesCloneBenchmark-results.txt
- RddBlockChecksumBenchmark-jdk21-results.txt
- RddBlockChecksumBenchmark-jdk25-results.txt
- RddBlockChecksumBenchmark-results.txt
- RocksDBBenchmark-jdk21-results.txt
- RocksDBBenchmark-jdk25-results.txt
- RocksDBBenchmark-results.txt
- SorterBenchmark-jdk21-results.txt
- SorterBenchmark-jdk25-results.txt
- SorterBenchmark-results.txt
- XORShiftRandomBenchmark-jdk21-results.txt
- XORShiftRandomBenchmark-jdk25-results.txt
- XORShiftRandomBenchmark-results.txt
- ZStandardBenchmark-jdk21-results.txt
- ZStandardBenchmark-jdk25-results.txt
- ZStandardBenchmark-results.txt
- ZStandardTPCDSDataBenchmark-jdk21-results.txt
- ZStandardTPCDSDataBenchmark-jdk25-results.txt
- ZStandardTPCDSDataBenchmark-results.txt
- JavaFutureAction.java
- Optional.java
- StorageLevels.java
- DriverPlugin.java
- ExecutorPlugin.java
- PluginContext.java
- SparkPlugin.java
- ResourceDiscoveryPlugin.java
- NioBufferedFileInputStream.java
- ReadAheadInputStream.java
- MemoryConsumer.java
- SparkOutOfMemoryError.java
- TaskMemoryManager.java
- TooLargePageException.java
- CredentialProvider.java
- CredentialProviderLoader.java
- CredentialResolutionException.java
- FileTokenIngestor.java
- ServiceCredential.java
- TokenIngestor.java
- UserContext.java
- UserCredentials.java
- DummySerializerInstance.java
- MapOutputCommitMessage.java
- MapOutputMetadata.java
- ShuffleDataIO.java
- ShuffleDriverComponents.java
- ShuffleExecutorComponents.java
- ShuffleMapOutputWriter.java
- ShufflePartitionWriter.java
- SingleSpillShuffleMapOutputWriter.java
- WritableByteChannelWrapper.java
- RowBasedChecksum.scala
- ShuffleChecksumSupport.java
- LocalDiskShuffleDataIO.java
- LocalDiskShuffleDriverComponents.java
- LocalDiskShuffleExecutorComponents.java
- LocalDiskShuffleMapOutputWriter.java
- LocalDiskSingleSpillMapOutputWriter.java
- BypassMergeSortShuffleWriter.java
- PackedRecordPointer.java
- ShuffleExternalSorter.java
- ShuffleInMemorySorter.java
- ShuffleSortDataFormat.java
- SpillInfo.java
- UnsafeShuffleWriter.java
- ApplicationStatus.java
- StageStatus.java
- TaskSorting.java
- TaskStatus.java
- TimeTrackingOutputStream.java
- BytesToBytesMap.java
- HashMapGrowthStrategy.java
- PrefixComparator.java
- PrefixComparators.java
- RadixSort.java
- RecordComparator.java
- RecordPointerAndKeyPrefix.java
- UnsafeExternalSorter.java
- UnsafeInMemorySorter.java
- UnsafeSortDataFormat.java
- UnsafeSorterBoundedSpillMerger.java
- UnsafeSorterIterator.java
- UnsafeSorterSpillMerger.java
- UnsafeSorterSpillReader.java
- UnsafeSorterSpillWriter.java
- TimSort.java
- BestEffortLazyVal.java
- ChildFirstURLClassLoader.java
- EnumUtil.java
- ExposedBufferByteArrayOutputStream.java
- MutableURLClassLoader.java
- ParentClassLoader.java
- TransientBestEffortLazyVal.java
- JobExecutionStatus.java
- package-info.java
- SparkExecutorInfo.java
- SparkFirehoseListener.java
- SparkJobInfo.java
- SparkStageInfo.java
- store_types.proto
- buf.yaml
- org.apache.spark.deploy.history.EventFilterBuilder
- org.apache.spark.security.HadoopDelegationTokenProvider
- org.apache.spark.status.protobuf.ProtobufSerDe
- LICENSE
- NOTICE
- bootstrap.bundle.min.js
- bootstrap.min.css
- d3-flamegraph.css
- d3-flamegraph.min.js
- d3.min.js
- dagre-d3.min.js
- dataTables.bootstrap5.min.css
- dataTables.bootstrap5.min.js
- dataTables.rowsGroup.js
- environmentpage.js
- executorspage-template.html
- executorspage.js
- flamegraph.js
- graphlib-dot.min.js
- historypage-common.js
- historypage-template.html
- historypage.js
- initialize-tooltips.js
- jquery.dataTables.min.css
- jquery.dataTables.min.js
- jquery.min.js
- log-view.js
- package.json
- scroll-button.js
- sorttable.js
- spark-dag-viz.css
- spark-dag-viz.js
- spark-logo-rev.svg
- spark-logo.svg
- stagepage.js
- stagespage-template.html
- streaming-page.css
- streaming-page.js
- structured-streaming-page.js
- table.js
- timeline-view.css
- timeline-view.js
- utils.js
- vis-timeline-graph2d.min.css
- vis-timeline-graph2d.min.js
- webui-dataTables.css
- webui.css
- webui.js
- JavaDoubleRDD.scala
- JavaHadoopRDD.scala
- JavaNewHadoopRDD.scala
- JavaPairRDD.scala
- JavaRDD.scala
- JavaRDDLike.scala
- JavaSparkContext.scala
- JavaSparkStatusTracker.scala
- JavaUtils.scala
- package-info.java
- package.scala
- Py4JServer.scala
- PythonErrorUtils.scala
- PythonGatewayServer.scala
- PythonHadoopUtil.scala
- PythonPartitioner.scala
- PythonRDD.scala
- PythonRunner.scala
- PythonUtils.scala
- PythonWorkerFactory.scala
- PythonWorkerHandle.scala
- PythonWorkerLogCapture.scala
- PythonWorkerUtils.scala
- SerDeUtil.scala
- StreamingPythonRunner.scala
- BaseRRunner.scala
- JVMObjectTracker.scala
- RAuthHelper.scala
- RBackend.scala
- RBackendAuthHandler.scala
- RBackendHandler.scala
- RRDD.scala
- RRunner.scala
- RUtils.scala
- SerDe.scala
- Broadcast.scala
- BroadcastFactory.scala
- BroadcastManager.scala
- package-info.java
- package.scala
- TorrentBroadcast.scala
- TorrentBroadcastFactory.scala
- StandaloneAppClient.scala
- StandaloneAppClientListener.scala
- ApplicationCache.scala
- ApplicationHistoryProvider.scala
- BasicEventFilterBuilder.scala
- EventFilter.scala
- EventLogFileCompactor.scala
- EventLogFileReaders.scala
- EventLogFileWriters.scala
- FsHistoryProvider.scala
- HistoryAppStatusStore.scala
- HistoryPage.scala
- HistoryServer.scala
- HistoryServerArguments.scala
- HistoryServerDiskManager.scala
- HistoryServerMemoryManager.scala
- HybridStore.scala
- LogPage.scala
- ApplicationPage.scala
- EnvironmentPage.scala
- LogPage.scala
- MasterPage.scala
- MasterWebUI.scala
- ApplicationInfo.scala
- ApplicationSource.scala
- ApplicationState.scala
- DriverInfo.scala
- DriverState.scala
- ExecutorDesc.scala
- ExecutorResourceDescription.scala
- FileSystemPersistenceEngine.scala
- LeaderElectionAgent.scala
- Master.scala
- MasterArguments.scala
- MasterMessages.scala
- MasterSource.scala
- PersistenceEngine.scala
- RecoveryModeFactory.scala
- RecoveryState.scala
- RocksDBPersistenceEngine.scala
- WorkerInfo.scala
- WorkerState.scala
- ZooKeeperLeaderElectionAgent.scala
- ZooKeeperPersistenceEngine.scala
- RestSubmissionClient.scala
- RestSubmissionServer.scala
- StandaloneRestServer.scala
- SubmitRestProtocolException.scala
- SubmitRestProtocolMessage.scala
- SubmitRestProtocolRequest.scala
- SubmitRestProtocolResponse.scala
- HadoopDelegationTokenManager.scala
- HadoopFSDelegationTokenProvider.scala
- HBaseDelegationTokenProvider.scala
- README.md
- UserCredentialManager.scala
- LogPage.scala
- WorkerPage.scala
- WorkerWebUI.scala
- CommandUtils.scala
- DriverRunner.scala
- DriverWrapper.scala
- ExecutorRunner.scala
- Worker.scala
- WorkerArguments.scala
- WorkerSource.scala
- WorkerWatcher.scala
- ApplicationDescription.scala
- Client.scala
- ClientArguments.scala
- Command.scala
- DeployMessage.scala
- DriverDescription.scala
- DriverTimeoutPlugin.scala
- ExecutorDescription.scala
- ExecutorFailureTracker.scala
- ExecutorState.scala
- ExternalShuffleService.scala
- ExternalShuffleServiceSource.scala
- FaultToleranceTest.scala
- JsonProtocol.scala
- LocalSparkCluster.scala
- PythonRunner.scala
- RedirectConsolePlugin.scala
- RPackageUtils.scala
- RRunner.scala
- SparkApplication.scala
- SparkCuratorUtil.scala
- SparkHadoopUtil.scala
- SparkPipelines.scala
- SparkSubmit.scala
- SparkSubmitArguments.scala
- StandaloneResourceUtils.scala
- Utils.scala
- SparkCoreErrors.scala
- CoarseGrainedExecutorBackend.scala
- CommitDeniedException.scala
- Executor.scala
- ExecutorBackend.scala
- ExecutorClassLoader.scala
- ExecutorExitCode.scala
- ExecutorLogUrlHandler.scala
- ExecutorMetrics.scala
- ExecutorMetricsPoller.scala
- ExecutorMetricsSource.scala
- ExecutorSource.scala
- InputMetrics.scala
- OutputMetrics.scala
- package-info.java
- package.scala
- ProcfsMetricsGetter.scala
- ShuffleReadMetrics.scala
- ShuffleWriteMetrics.scala
- TaskMetrics.scala
- FixedLengthBinaryInputFormat.scala
- FixedLengthBinaryRecordReader.scala
- PortableDataStream.scala
- WholeTextFileInputFormat.scala
- WholeTextFileRecordReader.scala
- Deploy.scala
- History.scala
- Kryo.scala
- Network.scala
- package.scala
- Python.scala
- R.scala
- SparkConfigProvider.scala
- Status.scala
- Streaming.scala
- Tests.scala
- UI.scala
- Worker.scala
- FileCommitProtocol.scala
- HadoopMapRedCommitProtocol.scala
- HadoopMapReduceCommitProtocol.scala
- HadoopWriteConfigUtil.scala
- SparkHadoopWriter.scala
- SparkHadoopWriterUtils.scala
- PluginContainer.scala
- PluginContextImpl.scala
- PluginEndpoint.scala
- CompressionCodec.scala
- HadoopCodecStreams.scala
- MutableCheckedOutputStream.scala
- package-info.java
- package.scala
- LauncherBackend.scala
- SparkSubmitArgumentsParser.scala
- WorkerCommandBuilder.scala
- SparkHadoopMapRedUtil.scala
- ExecutionMemoryPool.scala
- MemoryManager.scala
- MemoryPool.scala
- package.scala
- StorageMemoryPool.scala
- UnifiedMemoryManager.scala
- UnmanagedMemoryConsumer.scala
- ConsoleSink.scala
- CsvSink.scala
- GraphiteSink.scala
- JmxSink.scala
- MetricsServlet.scala
- package.scala
- PrometheusServlet.scala
- Sink.scala
- Slf4jSink.scala
- StatsdReporter.scala
- StatsdSink.scala
- AccumulatorSource.scala
- JVMCPUSource.scala
- JvmSource.scala
- package.scala
- Source.scala
- StaticSources.scala
- ExecutorMetricType.scala
- MetricsConfig.scala
- MetricsSystem.scala
- NettyBlockRpcServer.scala
- NettyBlockTransferService.scala
- SparkTransportConf.scala
- BlockDataManager.scala
- BlockTransferService.scala
- ApproximateActionListener.scala
- ApproximateEvaluator.scala
- BoundedDouble.scala
- CountEvaluator.scala
- GroupedCountEvaluator.scala
- MeanEvaluator.scala
- package.scala
- PartialResult.scala
- SumEvaluator.scala
- SparkPath.scala
- PeriodicRDDCheckpointer.scala
- AsyncRDDActions.scala
- BinaryFileRDD.scala
- BlockRDD.scala
- CartesianRDD.scala
- CheckpointRDD.scala
- coalesce-public.scala
- CoalescedRDD.scala
- CoGroupedRDD.scala
- DoubleRDDFunctions.scala
- EmptyRDD.scala
- HadoopRDD.scala
- InputFileBlockHolder.scala
- JdbcRDD.scala
- LocalCheckpointRDD.scala
- LocalRDDCheckpointData.scala
- MapPartitionsRDD.scala
- MapPartitionsWithEvaluatorRDD.scala
- NewHadoopRDD.scala
- OrderedRDDFunctions.scala
- package-info.java
- package.scala
- PairRDDFunctions.scala
- ParallelCollectionRDD.scala
- PartitionerAwareUnionRDD.scala
- PartitionPruningRDD.scala
- PartitionwiseSampledRDD.scala
- PipedRDD.scala
- RDD.scala
- RDDBarrier.scala
- RDDCheckpointData.scala
- RDDOperationScope.scala
- ReliableCheckpointRDD.scala
- ReliableRDDCheckpointData.scala
- SequenceFileRDDFunctions.scala
- ShuffledRDD.scala
- SortedMergeCoalescedRDD.scala
- SubtractedRDD.scala
- UnionRDD.scala
- WholeTextFileRDD.scala
- ZippedPartitionsRDD.scala
- ZippedPartitionsWithEvaluatorRDD.scala
- ZippedWithIndexRDD.scala
- CpuAmount.scala
- ExecutorResourceRequest.scala
- ExecutorResourceRequests.scala
- ResourceAllocator.scala
- ResourceDiscoveryScriptPlugin.scala
- ResourceInformation.scala
- ResourceProfile.scala
- ResourceProfileBuilder.scala
- ResourceProfileManager.scala
- ResourceUtils.scala
- TaskResourceRequest.scala
- TaskResourceRequests.scala
- Dispatcher.scala
- Inbox.scala
- MessageLoop.scala
- NettyRpcCallContext.scala
- NettyRpcEnv.scala
- NettyStreamManager.scala
- Outbox.scala
- RpcEndpointVerifier.scala
- RpcAddress.scala
- RpcCallContext.scala
- RpcEndpoint.scala
- RpcEndpointAddress.scala
- RpcEndpointNotFoundException.scala
- RpcEndpointRef.scala
- RpcEnv.scala
- RpcEnvStoppedException.scala
- RpcTimeout.scala
- CoarseGrainedClusterMessage.scala
- CoarseGrainedSchedulerBackend.scala
- ExecutorData.scala
- ExecutorInfo.scala
- SchedulerBackendUtils.scala
- StandaloneSchedulerBackend.scala
- ExecutorMonitor.scala
- LocalSchedulerBackend.scala
- AccumulableInfo.scala
- ActiveJob.scala
- AsyncEventQueue.scala
- BarrierJobAllocationFailed.scala
- DAGScheduler.scala
- DAGSchedulerEvent.scala
- DAGSchedulerSource.scala
- EventLoggingListener.scala
- ExecutorDecommissionInfo.scala
- ExecutorFailuresInTaskSet.scala
- ExecutorLossReason.scala
- ExecutorResourceInfo.scala
- ExecutorResourcesAmounts.scala
- ExternalClusterManager.scala
- HealthTracker.scala
- InputFormatInfo.scala
- JobListener.scala
- JobResult.scala
- JobWaiter.scala
- LiveListenerBus.scala
- MapStatus.scala
- MergeStatus.scala
- MiscellaneousProcessDetails.scala
- OutputCommitCoordinator.scala
- package-info.java
- package.scala
- Pool.scala
- ReplayListenerBus.scala
- ResultStage.scala
- ResultTask.scala
- Schedulable.scala
- SchedulableBuilder.scala
- SchedulerBackend.scala
- SchedulingAlgorithm.scala
- SchedulingMode.scala
- ShuffleMapStage.scala
- ShuffleMapTask.scala
- SparkListener.scala
- SparkListenerBus.scala
- SplitInfo.scala
- Stage.scala
- StageInfo.scala
- StatsReportListener.scala
- StructuredStreamingIdAwareSchedulerLogging.scala
- SupportsDelegationToken.scala
- Task.scala
- TaskDescription.scala
- TaskInfo.scala
- TaskLocality.scala
- TaskLocation.scala
- TaskResult.scala
- TaskResultGetter.scala
- TaskScheduler.scala
- TaskSchedulerImpl.scala
- TaskSet.scala
- TaskSetExcludeList.scala
- TaskSetManager.scala
- WorkerOffer.scala
- CryptoStreamUtils.scala
- GroupMappingServiceProvider.scala
- HadoopDelegationTokenProvider.scala
- SecurityConfigurationLock.scala
- ShellBasedGroupsMappingProvider.scala
- SocketAuthHelper.scala
- SocketAuthServer.scala
- GenericAvroSerializer.scala
- JavaSerializer.scala
- KryoSerializer.scala
- package-info.java
- package.scala
- SerializationDebugger.scala
- Serializer.scala
- SerializerHelper.scala
- SerializerManager.scala
- SortShuffleManager.scala
- SortShuffleWriter.scala
- MultiShuffleManager.scala
- StreamingShuffleClientHandler.scala
- StreamingShuffleManager.scala
- StreamingShuffleReader.scala
- StreamingShuffleServerHandler.scala
- StreamingShuffleWriter.scala
- TaskContextAwareLogging.scala
- BaseShuffleHandle.scala
- BlockStoreShuffleReader.scala
- FetchFailedException.scala
- IndexShuffleBlockResolver.scala
- metrics.scala
- MigratableResolver.scala
- ShuffleBlockInfo.scala
- ShuffleBlockPusher.scala
- ShuffleBlockResolver.scala
- ShuffleChecksumUtils.scala
- ShuffleDataIOUtils.scala
- ShuffleHandle.scala
- ShuffleManager.scala
- ShufflePartitionPairsWriter.scala
- ShuffleReader.scala
- ShuffleWriteProcessor.scala
- ShuffleWriter.scala
- api.scala
- ApiRootResource.scala
- ApplicationListResource.scala
- JacksonMessageWriter.scala
- OneApplicationResource.scala
- PrometheusResource.scala
- SimpleDateParam.scala
- StagesResource.scala
- AccumulableInfoSerializer.scala
- ApplicationEnvironmentInfoWrapperSerializer.scala
- ApplicationInfoWrapperSerializer.scala
- AppSummarySerializer.scala
- CachedQuantileSerializer.scala
- ExecutorMetricsSerializer.scala
- ExecutorStageSummarySerializer.scala
- ExecutorStageSummaryWrapperSerializer.scala
- ExecutorSummaryWrapperSerializer.scala
- JobDataWrapperSerializer.scala
- JobExecutionStatusSerializer.scala
- KVStoreProtobufSerializer.scala
- PoolDataSerializer.scala
- ProcessSummaryWrapperSerializer.scala
- ProtobufSerDe.scala
- RDDOperationGraphWrapperSerializer.scala
- RDDStorageInfoWrapperSerializer.scala
- ResourceProfileWrapperSerializer.scala
- SpeculationStageSummaryWrapperSerializer.scala
- StageDataWrapperSerializer.scala
- StageStatusSerializer.scala
- StreamBlockDataSerializer.scala
- TaskDataWrapperSerializer.scala
- Utils.scala
- AppHistoryServerPlugin.scala
- AppStatusListener.scala
- AppStatusSource.scala
- AppStatusStore.scala
- AppStatusUtils.scala
- ElementTrackingStore.scala
- KVUtils.scala
- LiveEntity.scala
- storeTypes.scala
- MemoryStore.scala
- BlockException.scala
- BlockId.scala
- BlockInfoManager.scala
- BlockManager.scala
- BlockManagerDecommissioner.scala
- BlockManagerId.scala
- BlockManagerManagedBuffer.scala
- BlockManagerMaster.scala
- BlockManagerMasterEndpoint.scala
- BlockManagerMasterHeartbeatEndpoint.scala
- BlockManagerMessages.scala
- BlockManagerSource.scala
- BlockManagerStorageEndpoint.scala
- BlockNotFoundException.scala
- BlockReplicationPolicy.scala
- BlockSavedOnDecommissionedBlockManagerException.scala
- BlockUpdatedInfo.scala
- DiskBlockManager.scala
- DiskBlockObjectWriter.scala
- DiskStore.scala
- FallbackStorage.scala
- FileSegment.scala
- LogBlockIdGenerator.scala
- LogBlockWriter.scala
- LogLine.scala
- PushBasedFetchHelper.scala
- RDDInfo.scala
- RollingLogWriter.scala
- ShuffleBlockFetcherIterator.scala
- ShuffleManagerNotInitializedException.scala
- StorageUtils.scala
- TopologyMapper.scala
- EnvironmentPage.scala
- ExecutorHeapHistogramPage.scala
- ExecutorsTab.scala
- ExecutorThreadDumpPage.scala
- FlamegraphNode.scala
- AllJobsPage.scala
- AllStagesPage.scala
- JobDataUtil.scala
- JobPage.scala
- JobsTab.scala
- PoolPage.scala
- PoolTable.scala
- StageDataUtil.scala
- StagePage.scala
- StagesTab.scala
- StageTable.scala
- TaskThreadDumpPage.scala
- RDDOperationGraph.scala
- RDDPage.scala
- StoragePage.scala
- StorageTab.scala
- ToolTips.scala
- ConsoleProgressBar.scala
- CspNonce.scala
- DriverLogPage.scala
- GraphUIData.scala
- HttpSecurityFilter.scala
- JettyUtils.scala
- JWSFilter.scala
- PagedTable.scala
- SparkUI.scala
- ToolTips.scala
- UIUtils.scala
- UIWorkloadGenerator.scala
- WebUI.scala
- AppendOnlyMap.scala
- BitSet.scala
- CompactBuffer.scala
- ExternalAppendOnlyMap.scala
- ExternalSorter.scala
- ImmutableBitSet.scala
- OpenHashMap.scala
- OpenHashSet.scala
- PairsWriter.scala
- PartitionedAppendOnlyMap.scala
- PartitionedPairBuffer.scala
- PercentileHeap.scala
- PrimitiveVector.scala
- SizeTracker.scala
- SizeTrackingAppendOnlyMap.scala
- SizeTrackingVector.scala
- SortDataFormat.scala
- Sorter.scala
- Spillable.scala
- Utils.scala
- WritablePartitionedPairCollection.scala
- ChunkedByteBuffer.scala
- ChunkedByteBufferFileRegion.scala
- ChunkedByteBufferOutputStream.scala
- DriverLogger.scala
- FileAppender.scala
- RollingFileAppender.scala
- RollingPolicy.scala
- package-info.java
- package.scala
- Pseudorandom.scala
- RandomSampler.scala
- SamplingUtils.scala
- StratifiedSamplingUtils.scala
- XORShiftRandom.scala
- AccumulatorV2.scala
- BlockingThreadPoolExecutorService.scala
- BoundedPriorityQueue.scala
- ByteBufferInputStream.scala
- ByteBufferOutputStream.scala
- CausedBy.scala
- Clock.scala
- CollectionsUtils.scala
- CommandLineUtils.scala
- DependencyUtils.scala
- DirectByteBufferOutputStream.scala
- Distribution.scala
- ErrorNotifier.scala
- EventLoop.scala
- HadoopFSUtils.scala
- IdGenerator.scala
- IntParam.scala
- JsonProtocol.scala
- KeyLock.scala
- LastAttemptAccumulator.scala
- LazyTry.scala
- ListenerBus.scala
- ManualClock.scala
- MemoryParam.scala
- MetricUtils.scala
- MutablePair.scala
- NextIterator.scala
- NonFateSharingCache.scala
- package-info.java
- package.scala
- PeriodicCheckpointer.scala
- RpcUtils.scala
- SecurityUtils.scala
- SerializableBuffer.scala
- SerializableConfiguration.scala
- SerializableJobConf.scala
- ShutdownHookManager.scala
- SignalUtils.scala
- SizeEstimator.scala
- SparkClosureCleaner.scala
- SparkExitCode.scala
- SparkUDFWorkerLogger.scala
- SparkUncaughtExceptionHandler.scala
- StatCounter.scala
- StubClassLoader.scala
- taskListeners.scala
- ThreadUtils.scala
- UninterruptibleThread.scala
- UninterruptibleThreadRunner.scala
- Utils.scala
- Aggregator.scala
- BarrierCoordinator.scala
- BarrierTaskContext.scala
- BarrierTaskInfo.scala
- ContextAwareIterator.scala
- ContextCleaner.scala
- Dependency.scala
- ExecutorAllocationClient.scala
- ExecutorAllocationManager.scala
- FutureAction.scala
- Heartbeater.scala
- HeartbeatReceiver.scala
- InternalAccumulator.scala
- InterruptibleIterator.scala
- JobArtifactSet.scala
- MapOutputStatistics.scala
- MapOutputTracker.scala
- package.scala
- Partition.scala
- Partitioner.scala
- PartitionEvaluator.scala
- PartitionEvaluatorFactory.scala
- SecurityManager.scala
- SerializableWritable.scala
- SparkConf.scala
- SparkContext.scala
- SparkEnv.scala
- SparkFileAlreadyExistsException.scala
- SparkFiles.scala
- SparkStatusTracker.scala
- SSLOptions.scala
- StatusAPIImpl.scala
- StreamingShuffleOutputTracker.scala
- TaskContext.scala
- TaskContextImpl.scala
- TaskEndReason.scala
- TaskKilledException.scala
- TaskNotSerializableException.scala
- TaskOutputFileAlreadyExistException.scala
- TaskState.scala
- TestUtils.scala
- OptionalSuite.java
- GenericFileInputStreamSuite.java
- NioBufferedInputStreamSuite.java
- ReadAheadInputStreamSuite.java
- SparkLauncherSuite.java
- TaskMemoryManagerSuite.java
- TestMemoryConsumer.java
- TestPartialSpillingMemoryConsumer.java
- JavaResourceProfileSuite.java
- AnotherFakeCredentialProvider.java
- CredentialProviderLoaderSuite.java
- CredentialTypesSuite.java
- FakeCredentialProvider.java
- FileTokenIngestorSuite.java
- ContainsProxyClass.java
- TestJavaSerializerImpl.java
- PackedRecordPointerSuite.java
- ShuffleInMemoryRadixSorterSuite.java
- ShuffleInMemorySorterSuite.java
- UnsafeShuffleWriterSuite.java
- AbstractBytesToBytesMapSuite.java
- BytesToBytesMapOffHeapSuite.java
- BytesToBytesMapOnHeapSuite.java
- PlatformBenchmarkTestUtils.java
- UnsafeExternalSorterRadixSortSuite.java
- UnsafeExternalSorterSuite.java
- UnsafeInMemorySorterRadixSortSuite.java
- UnsafeInMemorySorterSuite.java
- TestTimSort.java
- SerializableConfigurationSuite.java
- JavaJdbcRDDSuite.java
- Java8RDDAPISuite.java
- JavaAPISuite.java
- JavaSparkContextSuite.java
- JavaTaskContextCompileCheck.java
- app_environment_expectation.json
- application_list_json_expectation.json
- complete_stage_list_json_expectation.json
- completed_app_list_json_expectation.json
- excludeOnFailure_for_stage_expectation.json
- excludeOnFailure_node_for_stage_expectation.json
- executor_list_json_expectation.json
- executor_list_with_executor_metrics_json_expectation.json
- executor_memory_usage_expectation.json
- executor_node_excludeOnFailure_expectation.json
- executor_node_excludeOnFailure_unexcluding_expectation.json
- executor_resource_information_expectation.json
- failed_stage_list_json_expectation.json
- job_list_from_multi_attempt_app_json_1__expectation.json
- job_list_from_multi_attempt_app_json_2__expectation.json
- job_list_json_expectation.json
- limit_app_list_json_expectation.json
- maxDate2_app_list_json_expectation.json
- maxDate_app_list_json_expectation.json
- maxEndDate_app_list_json_expectation.json
- minDate_and_maxEndDate_app_list_json_expectation.json
- minDate_app_list_json_expectation.json
- minEndDate_and_maxEndDate_app_list_json_expectation.json
- minEndDate_app_list_json_expectation.json
- miscellaneous_process_expectation.json
- multiple_resource_profiles_expectation.json
- one_app_json_expectation.json
- one_app_multi_attempt_json_expectation.json
- one_app_with_non_zero_exit_code_json_expectation.json
- one_job_json_expectation.json
- one_rdd_storage_json_expectation.json
- one_stage_attempt_json_details_with_failed_task_expectation.json
- one_stage_attempt_json_expectation.json
- one_stage_json_expectation.json
- one_stage_json_with_details_expectation.json
- one_stage_json_with_partitionId_expectation.json
- rdd_list_storage_json_expectation.json
- running_app_list_json_expectation.json
- stage_list_json_expectation.json
- stage_list_with_accumulable_json_expectation.json
- stage_list_with_peak_metrics_expectation.json
- stage_task_list_expectation.json
- stage_task_list_from_multi_attempt_app_json_1__expectation.json
- stage_task_list_from_multi_attempt_app_json_2__expectation.json
- stage_task_list_w__offset___length_expectation.json
- stage_task_list_w__sortBy_expectation.json
- stage_task_list_w__sortBy_short_names___runtime_expectation.json
- stage_task_list_w__sortBy_short_names__runtime_expectation.json
- stage_task_list_w__status___offset___length_expectation.json
- stage_task_list_w__status___sortBy_short_names__runtime_expectation.json
- stage_task_list_w__status_expectation.json
- stage_task_list_with_partitionId_expectation.json
- stage_task_summary_w__custom_quantiles_expectation.json
- stage_task_summary_w_shuffle_read_expectation.json
- stage_task_summary_w_shuffle_write_expectation.json
- stage_with_accumulable_json_expectation.json
- stage_with_peak_metrics_expectation.json
- stage_with_speculation_summary_expectation.json
- stage_with_summaries_expectation.json
- succeeded_failed_job_list_json_expectation.json
- succeeded_job_list_json_expectation.json
- org.apache.spark.scheduler.ExternalClusterManager
- org.apache.spark.security.CredentialProvider
- org.apache.spark.security.HadoopDelegationTokenProvider
- stat
- stat
- stat
- .appstatus_local-1766844910796.crc
- appstatus_local-1766844910796
- events_1_local-1766844910796
- app-20161115172038-0000
- app-20161116163331-0000
- app-20180109111548-0000
- app-20200706201101-0003
- application_1516285256255_0012
- application_1553914137147_0018
- application_1555004656427_0144
- application_1578436911597_0052
- application_1628109047826_1317105
- local-1422981759269
- local-1422981780767
- local-1425081759269
- local-1426533911241
- local-1426633911242
- local-1430917381534
- local-1430917381535_1
- local-1430917381535_2
- local-1430917381536
- local-1642039451826
- application_1656321732247_0006_1
- application_1656321732247_0006_2
- application_1656321732247_0006_1
- application_1656321732247_0006_2
- certchain.pem
- fairscheduler-with-invalid-data.xml
- fairscheduler-with-valid-data.xml
- fairscheduler.xml
- hive-site.xml
- key.pem
- keystore
- log4j2.properties
- spark.keystore
- test_metrics_config.properties
- test_metrics_system.properties
- truststore
- unencrypted-certchain.pem
- unencrypted-key.pem
- untrusted-keystore
- JavaUtilsSuite.scala
- BasePythonRunnerSuite.scala
- PythonBroadcastSuite.scala
- PythonHadoopUtilSuite.scala
- PythonRDDSuite.scala
- PythonWorkerFactorySuite.scala
- PythonWorkerHandleSuite.scala
- SerDeUtilSuite.scala
- WriteInputFormatTestDataGenerator.scala
- BaseRRunnerSuite.scala
- JVMObjectTrackerSuite.scala
- RBackendSuite.scala
- Benchmark.scala
- BenchmarkBase.scala
- Benchmarks.scala
- BroadcastSuite.scala
- AppClientSuite.scala
- TestExecutor.scala
- ApplicationCacheSuite.scala
- BasicEventFilterBuilderSuite.scala
- BasicEventFilterSuite.scala
- ChromeUIHistoryServerSuite.scala
- EventLogFileCompactorSuite.scala
- EventLogFileReadersSuite.scala
- EventLogFileWritersSuite.scala
- EventLogTestHelper.scala
- FsHistoryProviderSuite.scala
- HistoryServerArgumentsSuite.scala
- HistoryServerDiskManagerSuite.scala
- HistoryServerMemoryManagerSuite.scala
- HistoryServerPageSuite.scala
- HistoryServerSuite.scala
- HybridStoreSuite.scala
- LogPageSuite.scala
- RealBrowserUIHistoryServerSuite.scala
- ApplicationPageSuite.scala
- MasterWebUIAclSuite.scala
- MasterWebUISuite.scala
- ReadOnlyMasterWebUISuite.scala
- CustomRecoveryModeFactory.scala
- MasterDecommissionSuite.scala
- MasterSuite.scala
- MasterSuiteBase.scala
- MasterWorkerUISuite.scala
- PersistenceEngineBenchmark.scala
- PersistenceEngineSuite.scala
- RecoverySuite.scala
- ResourceProfilesSuite.scala
- WorkerSelectionSuite.scala
- StandaloneRestSubmitSuite.scala
- SubmitRestProtocolSuite.scala
- HadoopDelegationTokenManagerSuite.scala
- HadoopFSDelegationTokenProviderSuite.scala
- NonKerberosCredentialsSuite.scala
- OidcCredentialIntegrationSuite.scala
- UserCredentialManagerSuite.scala
- LogPageSuite.scala
- CommandUtilsSuite.scala
- DriverRunnerTest.scala
- ExecutorRunnerTest.scala
- WorkerArgumentsTest.scala
- WorkerSuite.scala
- WorkerWatcherSuite.scala
- ClientSuite.scala
- DecommissionWorkerSuite.scala
- DeployTestUtils.scala
- ExecutorFailureTrackerSuite.scala
- ExternalShuffleServiceDbSuite.scala
- ExternalShuffleServiceLocalDirsSuite.scala
- ExternalShuffleServiceMetricsSuite.scala
- JsonProtocolSuite.scala
- LogUrlsStandaloneSuite.scala
- PythonRunnerSuite.scala
- RPackageUtilsSuite.scala
- SparkHadoopUtilSuite.scala
- SparkPipelinesSuite.scala
- SparkSubmitSuite.scala
- SparkSubmitTestUtils.scala
- StandaloneDynamicAllocationSuite.scala
- ClassLoaderIsolationSuite.scala
- CoarseGrainedExecutorBackendSuite.scala
- ExecutorClassLoaderSuite.scala
- ExecutorMetricsPollerSuite.scala
- ExecutorSideSessionManagementSuite.scala
- ExecutorSuite.scala
- ProcfsMetricsGetterSuite.scala
- TaskMetricsSuite.scala
- WholeTextFileInputFormatSuite.scala
- WholeTextFileRecordReaderSuite.scala
- ConfigEntrySuite.scala
- ConfigReaderSuite.scala
- FileCommitProtocolInstantiationSuite.scala
- SparkHadoopWriterUtilsSuite.scala
- PluginContainerSuite.scala
- LoggingSuite.scala
- ChunkedByteBufferFileRegionSuite.scala
- ChunkedByteBufferSuite.scala
- CompressionCodecSuite.scala
- LZ4TPCDSDataBenchmark.scala
- LZFBenchmark.scala
- TPCDSDataBenchmark.scala
- ZStandardBenchmark.scala
- ZStandardTPCDSDataBenchmark.scala
- LauncherBackendSuite.scala
- MemoryManagerSuite.scala
- MemoryTestingUtils.scala
- TestMemoryManager.scala
- TestMemoryManagerSuite.scala
- UnifiedMemoryManagerSuite.scala
- GraphiteSinkSuite.scala
- PrometheusServletSuite.scala
- StatsdSinkSuite.scala
- AccumulatorSourceSuite.scala
- SourceConfigSuite.scala
- InputOutputMetricsSuite.scala
- MetricsConfigSuite.scala
- MetricsSystemSuite.scala
- NettyBlockRpcServerSuite.scala
- NettyBlockTransferSecuritySuite.scala
- NettyBlockTransferServiceSuite.scala
- SparkTransportConfSuite.scala
- BlockTransferServiceSuite.scala
- NettyTransportBenchmark.scala
- CountEvaluatorSuite.scala
- MeanEvaluatorSuite.scala
- SumEvaluatorSuite.scala
- AsyncRDDActionsSuite.scala
- CoalescedRDDBenchmark.scala
- DoubleRDDSuite.scala
- HadoopRDDSuite.scala
- JdbcRDDSuite.scala
- LocalCheckpointSuite.scala
- PairRDDFunctionsSuite.scala
- ParallelCollectionSplitSuite.scala
- PartitionPruningRDDSuite.scala
- PartitionwiseSampledRDDSuite.scala
- PipedRDDSuite.scala
- RDDBarrierSuite.scala
- RDDCleanerSuite.scala
- RDDOperationScopeSuite.scala
- RDDSuite.scala
- RDDSuiteUtils.scala
- SortedMergeCoalescedRDDSuite.scala
- SortingSuite.scala
- ZippedPartitionsSuite.scala
- ResourceDiscoveryPluginSuite.scala
- ResourceInformationSuite.scala
- ResourceProfileManagerSuite.scala
- ResourceProfileSuite.scala
- ResourceUtilsSuite.scala
- TestResourceIDs.scala
- InboxSuite.scala
- NettyRpcAddressSuite.scala
- NettyRpcEnvSuite.scala
- NettyRpcHandlerSuite.scala
- NettyStreamManagerSuite.scala
- RpcAddressSuite.scala
- RpcEnvSuite.scala
- TestRpcEndpoint.scala
- ExecutorMonitorSuite.scala
- AdaptiveSchedulingSuite.scala
- AQEShuffledRDD.scala
- BarrierTaskContextSuite.scala
- CoarseGrainedSchedulerBackendSuite.scala
- DAGSchedulerSuite.scala
- EventLoggingListenerSuite.scala
- ExecutorResourceInfoSuite.scala
- ExecutorResourcesAmountsSuite.scala
- ExecutorResourceUtils.scala
- ExternalClusterManagerSuite.scala
- FakeTask.scala
- HealthTrackerIntegrationSuite.scala
- HealthTrackerSuite.scala
- JobWaiterSuite.scala
- MapStatusSuite.scala
- NotSerializableFakeTask.scala
- OutputCommitCoordinatorIntegrationSuite.scala
- OutputCommitCoordinatorSuite.scala
- PoolSuite.scala
- ReplayListenerSuite.scala
- SchedulerIntegrationSuite.scala
- SparkListenerSuite.scala
- SparkListenerWithClusterSuite.scala
- StructuredStreamingIdAwareSchedulerLoggingSuite.scala
- TaskContextSuite.scala
- TaskDescriptionSuite.scala
- TaskInfoSuite.scala
- TaskResultGetterSuite.scala
- TaskSchedulerImplSuite.scala
- TaskSetExcludelistSuite.scala
- TaskSetManagerSuite.scala
- WorkerDecommissionExtendedSuite.scala
- WorkerDecommissionSuite.scala
- CryptoStreamUtilsSuite.scala
- EncryptionFunSuite.scala
- SocketAuthHelperSuite.scala
- GenericAvroSerializerSuite.scala
- JavaSerializerSuite.scala
- KryoBenchmark.scala
- KryoIteratorBenchmark.scala
- KryoSerializerBenchmark.scala
- KryoSerializerDistributedSuite.scala
- KryoSerializerResizableOutputSuite.scala
- KryoSerializerSuite.scala
- ProactiveClosureSerializationSuite.scala
- SerializationDebuggerSuite.scala
- SerializerManagerSuite.scala
- SerializerPropertiesSuite.scala
- TestSerializer.scala
- UnsafeKryoSerializerSuite.scala
- OutputStreamRowBasedChecksum.scala
- LocalDiskShuffleMapOutputWriterSuite.scala
- BypassMergeSortShuffleWriterSuite.scala
- IndexShuffleBlockResolverSuite.scala
- ShuffleExternalSorterSuite.scala
- SortShuffleManagerSuite.scala
- SortShuffleWriterSuite.scala
- MultiShuffleManagerSuite.scala
- StreamingShuffleManagerSuite.scala
- StreamingShuffleReaderSuite.scala
- StreamingShuffleSuite.scala
- StreamingShuffleWriterSuite.scala
- BlockStoreShuffleReaderSuite.scala
- ChecksumBenchmark.scala
- HostLocalShuffleReadingSuite.scala
- PipelinedShuffleRoutingSuite.scala
- ShuffleBlockPusherSuite.scala
- ShuffleChecksumTestHelper.scala
- ShuffleDependencySuite.scala
- ShuffleDriverComponentsSuite.scala
- AppStatusListenerSuite.scala
- AppStatusStoreSuite.scala
- AppStatusUtilsSuite.scala
- AutoCleanupLiveUIDirSuite.scala
- ElementTrackingStoreSuite.scala
- ListenerEventsTestHelper.scala
- LiveEntitySuite.scala
- AccumulatorSuite.scala
- BarrierStageOnSubmittedSuite.scala
- CheckErrorHelper.scala
- CheckpointSuite.scala
- ContextCleanerSuite.scala
- DebugFilesystem.scala
- DistributedSuite.scala
- DriverSuite.scala
- ExecutorAllocationManagerSuite.scala
- ExternalShuffleServiceSuite.scala
- FailureSuite.scala
- FeatureSpecSparkTestSuite.scala
- FileSuite.scala
- FlatSpecSparkTestSuite.scala
- FreeSpecSparkTestSuite.scala
- FunSpecSparkTestSuite.scala
- FutureActionSuite.scala
- HeartbeatReceiverSuite.scala
- ImplicitOrderingSuite.scala
- InternalAccumulatorSuite.scala
- JobArtifactSetSuite.scala
- JobCancellationSuite.scala
- JsonTestUtils.scala
- LocalRootDirsTest.scala
- LocalSparkContext.scala
- MapOutputTrackerSuite.scala
- MapStatusesConvertBenchmark.scala
- MapStatusesSerDeserBenchmark.scala
- PartitioningSuite.scala
- ProcessTestUtils.scala
- PropSpecSparkTestSuite.scala
- RefSpecSparkTestSuite.scala
- SecurityManagerSuite.scala
- SerializerTestUtils.scala
- SharedSparkContext.scala
- ShuffleNettySuite.scala
- ShuffleOldFetchProtocolSuite.scala
- ShuffleSuite.scala
- Smuggle.scala
- SortShuffleSuite.scala
- SparkConfSuite.scala
- SparkContextInfoSuite.scala
- SparkContextSchedulerCreationSuite.scala
- SparkContextSuite.scala
- SparkFunSuite.scala
- SparkTestSuite.scala
- SparkThrowableSuite.scala
- SslExternalShuffleServiceSuite.scala
- SSLOptionsSuite.scala
- SslShuffleNettySuite.scala
- StatusTrackerSuite.scala
- StreamingShuffleOutputTrackerSuite.scala
- TempLocalSparkContext.scala
- TestShuffleDataIOWithMockedComponents.scala
- ThreadAudit.scala
- ThreadingSuite.scala
- UnpersistSuite.scala
- WordSpecSparkTestSuite.scala
- pom.xml
- general.R
- shell.R
- test_basic.R
- daemon.R
- worker.R
- _pkgdown_template.yml
- extra.css
- backend.R
- broadcast.R
- catalog.R
- client.R
- column.R
- context.R
- DataFrame.R
- deserialize.R
- functions.R
- generics.R
- group.R
- install.R
- jobj.R
- jvm.R
- mllib_classification.R
- mllib_clustering.R
- mllib_fpm.R
- mllib_recommendation.R
- mllib_regression.R
- mllib_stat.R
- mllib_tree.R
- mllib_utils.R
- pairRDD.R
- RDD.R
- schema.R
- serialize.R
- sparkR.R
- SQLContext.R
- stats.R
- streaming.R
- types.R
- utils.R
- window.R
- WindowSpec.R
- zzz.R
- Makefile
- Makefile.win
- string_hash_code.c
- test_utils_utf.json
- jarTest.R
- packageInAJarTest.R
- test_binary_function.R
- test_binaryFile.R
- test_broadcast.R
- test_client.R
- test_context.R
- test_includePackage.R
- test_jvm_api.R
- test_mllib_classification.R
- test_mllib_clustering.R
- test_mllib_fpm.R
- test_mllib_recommendation.R
- test_mllib_regression.R
- test_mllib_stat.R
- test_mllib_tree.R
- test_parallelize_collect.R
- test_rdd.R
- test_Serde.R
- test_shuffle.R
- test_sparkR.R
- test_sparkSQL.R
- test_sparkSQL_arrow.R
- test_sparkSQL_eager.R
- test_streaming.R
- test_take.R
- test_textFile.R
- test_utils.R
- test_Windows.R
- run-all.R
- sparkr-vignettes.Rmd
- .gitignore
- .lintr
- .Rbuildignore
- DESCRIPTION
- NAMESPACE
- README.md
- .gitignore
- check-cran.sh
- CRAN_RELEASE.md
- create-docs.sh
- create-rd.sh
- DOCUMENTATION.md
- find-r.sh
- install-dev.bat
- install-dev.sh
- install-source-package.sh
- log4j2.properties
- run-tests.sh
- WINDOWS.md
- .asf.yaml
- .gitattributes
- .gitignore
- .nojekyll
- .pre-commit-config.yaml
- .sbtopts
- AGENTS.md
- CLAUDE.md
- CONTRIBUTING.md
- LICENSE
- LICENSE-binary
- NOTICE
- NOTICE-binary
- README.md
- SECURITY.md
# 설치 가이드
1. 코드 내려받기
git clone https://github.com/apache/spark
깃허브에서 프로젝트 코드 전체를 내 컴퓨터로 내려받습니다.
cd spark
방금 내려받은 프로젝트 폴더 안으로 이동합니다.
2. Docker
쉬움 추천사전 준비물
- Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
- Docker Desktop 컨테이너를 빌드하고 실행하려면 필요합니다. 설치 후 실행해서 백그라운드에 켜두세요.
docker build -f binder/Dockerfile -t spark .
Dockerfile을 기반으로 실행 가능한 이미지를 빌드합니다.
docker run -p 8080:80 spark
빌드된 이미지를 실제 컨테이너로 실행합니다.
터미널에 docker compose ps 를 입력해 컨테이너들이 Up 상태인지 확인하세요. README에 포트 번호가 적혀있다면 브라우저에서 http://localhost:포트번호 로 접속해보세요.
3. Maven (Java)
보통사전 준비물
- Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
- JDK (Java) Java 프로젝트를 빌드/실행하려면 필요합니다.
- Maven mvn 명령어를 쓰기 위한 빌드 도구입니다.
./build/mvn -DskipTests clean package
Maven으로 의존성 설치와 빌드를 진행합니다.
BUILD SUCCESS 메시지가 뜨면 성공입니다. target/ 폴더에 결과물이 생성됩니다.
이 레포의 README에 적힌 실제 명령어를 그대로 가져왔습니다.
4. Node.js
쉬움사전 준비물
⚠️ 이 프로젝트는 규모가 큰 저장소라, 이 방법이 실제 핵심 제품이 아니라 내부 하위 패키지를 가리키는 것일 수 있습니다. README 전체를 함께 확인해보세요.
cd core/src/main/resources/org/apache/spark/ui/static
이 프로젝트의 관련 파일이 하위 폴더 안에 있어서, 먼저 그 폴더로 이동합니다.
npm install
package.json에 명시된 라이브러리들을 내려받아 설치합니다.
npm start
개발/실행 서버를 켭니다.
명령어 실행 후 터미널에 나타나는 주소(보통 http://localhost:3000 형태)를 브라우저에서 열어보세요.
5. Make
보통사전 준비물
- Git GitHub에서 프로젝트 코드를 내려받으려면 필요합니다.
- Make Linux/macOS는 보통 기본 설치되어 있습니다. Windows는 별도 설치(예: MSYS2, WSL)가 필요합니다.
⚠️ 이 프로젝트는 규모가 큰 저장소라, 이 방법이 실제 핵심 제품이 아니라 내부 하위 패키지를 가리키는 것일 수 있습니다. README 전체를 함께 확인해보세요.
cd R/pkg/src-native
이 프로젝트의 관련 파일이 하위 폴더 안에 있어서, 먼저 그 폴더로 이동합니다.
make
생성된 빌드 설정을 바탕으로 실제 컴파일을 진행해 실행 파일을 만듭니다.
에러 없이 끝나면 성공입니다. 생성된 실행 파일을 직접 실행해보세요.
// repository documentation
Was this content helpful?
(0 ratings)
