This is an automated email from the ASF dual-hosted git repository.
linxinyuan pushed a change to branch xinyuan-renaming
in repository https://gitbox.apache.org/repos/asf/texera.git
from 75778e64f6 fix fmt
add 1676e270f8 fix fmt
No new revisions were added by this update.
Summary of changes:
.../apache/texera/AccessControlResourceSpec.scala | 18 +++++++++++---
.../apache/amber/clustering/ClusterListener.scala | 5 +++-
.../common/AkkaActorRefMappingService.scala | 7 +++++-
.../architecture/common/AmberProcessor.scala | 11 +++++++--
.../architecture/common/ExecutorDeployment.scala | 6 ++++-
.../engine/architecture/common/WorkflowActor.scala | 14 +++++++++--
.../architecture/controller/Controller.scala | 15 +++++++++---
.../controller/ControllerProcessor.scala | 7 +++++-
.../controller/ControllerTimerService.scala | 5 +++-
.../controller/WorkflowScheduler.scala | 6 ++++-
.../controller/execution/ExecutionUtils.scala | 5 +++-
.../promisehandlers/ConsoleMessageHandler.scala | 5 +++-
.../promisehandlers/DebugCommandHandler.scala | 5 +++-
.../EmbeddedControlMessageHandler.scala | 11 +++++++--
.../EvaluatePythonExpressionHandler.scala | 5 +++-
.../promisehandlers/LinkWorkersHandler.scala | 7 +++++-
.../controller/promisehandlers/PauseHandler.scala | 6 ++++-
.../promisehandlers/PortCompletedHandler.scala | 11 +++++++--
.../QueryWorkerStatisticsHandler.scala | 11 +++++++--
.../controller/promisehandlers/ResumeHandler.scala | 5 +++-
.../RetrieveWorkflowStateHandler.scala | 11 +++++++--
.../promisehandlers/RetryWorkflowHandler.scala | 6 ++++-
.../WorkerExecutionCompletedHandler.scala | 11 +++++++--
.../WorkerStateUpdatedHandler.scala | 10 ++++++--
.../messaginglayer/DeadLetterMonitorActor.scala | 5 +++-
.../messaginglayer/NetworkOutputGateway.scala | 7 +++++-
.../messaginglayer/OutputManager.scala | 11 +++++++--
.../pythonworker/PythonProxyClient.scala | 12 ++++++++--
.../pythonworker/PythonProxyServer.scala | 5 +++-
.../pythonworker/PythonWorkflowWorker.scala | 10 ++++++--
.../pythonworker/WorkerBatchInternalQueue.scala | 6 ++++-
.../scheduling/CostBasedScheduleGenerator.scala | 6 ++++-
.../ExpansionGreedyScheduleGenerator.scala | 13 ++++++++--
.../scheduling/RegionExecutionCoordinator.scala | 25 +++++++++++++++----
.../scheduling/ScheduleGenerator.scala | 5 +++-
.../engine/architecture/worker/DPThread.scala | 11 +++++++--
.../engine/architecture/worker/DataProcessor.scala | 28 ++++++++++++++++++----
.../DataProcessorRPCHandlerInitializer.scala | 7 +++++-
.../worker/EmbeddedControlMessageManager.scala | 12 ++++++++--
.../InputPortMaterializationReaderThread.scala | 21 ++++++++++++----
.../worker/managers/StatisticsManager.scala | 6 ++++-
.../promisehandlers/AddInputChannelHandler.scala | 5 +++-
.../promisehandlers/AddPartitioningHandler.scala | 5 +++-
.../FinalizeCheckpointHandler.scala | 10 ++++++--
.../InitializeExecutorHandler.scala | 5 +++-
.../promisehandlers/PrepareCheckpointHandler.scala | 10 ++++++--
.../amber/engine/common/client/AmberClient.scala | 6 ++++-
.../amber/engine/common/client/ClientActor.scala | 27 +++++++++++++++++----
.../amber/engine/common/rpc/AsyncRPCClient.scala | 13 ++++++++--
.../common/rpc/AsyncRPCHandlerInitializer.scala | 6 ++++-
.../amber/engine/common/rpc/AsyncRPCServer.scala | 6 ++++-
.../common/statetransition/StateManager.scala | 5 +++-
.../engine/common/storage/EmptyRecordStorage.scala | 5 +++-
.../engine/common/storage/HDFSRecordStorage.scala | 5 +++-
.../common/storage/SequentialRecordStorage.scala | 5 +++-
.../engine/common/storage/VFSRecordStorage.scala | 5 +++-
.../apache/texera/web/ComputingUnitMaster.scala | 5 +++-
.../apache/texera/web/TexeraWebApplication.scala | 13 ++++++++--
.../websocket/request/TexeraWebSocketRequest.scala | 5 +++-
.../dashboard/DatasetSearchQueryBuilder.scala | 6 ++++-
.../dashboard/ProjectSearchQueryBuilder.scala | 6 ++++-
.../resource/dashboard/SearchQueryBuilder.scala | 5 +++-
.../web/resource/dashboard/hub/HubResource.scala | 6 ++++-
.../user/project/ProjectAccessResource.scala | 7 +++++-
.../dashboard/user/project/ProjectResource.scala | 6 ++++-
.../user/workflow/WorkflowAccessResource.scala | 11 +++++++--
.../dashboard/user/workflow/WorkflowResource.scala | 7 +++++-
.../user/workflow/WorkflowVersionResource.scala | 5 +++-
.../web/service/ExecutionConsoleService.scala | 24 +++++++++++++++----
.../service/ExecutionReconfigurationService.scala | 5 +++-
.../web/service/ExecutionResultService.scala | 14 +++++++++--
.../web/service/ExecutionRuntimeService.scala | 5 +++-
.../texera/web/service/ExecutionStatsService.scala | 19 ++++++++++++---
.../service/FriesReconfigurationAlgorithm.scala | 5 +++-
.../texera/web/service/ResultExportService.scala | 5 +++-
.../web/service/WorkflowExecutionService.scala | 6 ++++-
.../texera/web/service/WorkflowService.scala | 16 ++++++++++---
.../texera/web/storage/ExecutionStateStore.scala | 7 +++++-
.../architecture/control/TrivialControlSpec.scala | 13 ++++++++--
.../control/utils/TrivialControlTester.scala | 6 ++++-
.../messaginglayer/OutputManagerSpec.scala | 7 +++++-
.../scheduling/DefaultCostEstimatorSpec.scala | 5 +++-
.../engine/architecture/worker/DPThreadSpec.scala | 11 +++++++--
.../architecture/worker/DataProcessorSpec.scala | 18 +++++++++++---
.../engine/architecture/worker/WorkerSpec.scala | 13 ++++++++--
.../amber/engine/e2e/DataProcessingSpec.scala | 7 +++++-
.../org/apache/amber/engine/e2e/PauseSpec.scala | 6 ++++-
.../org/apache/amber/engine/e2e/TestUtils.scala | 14 +++++++++--
.../amber/engine/faulttolerance/LoggingSpec.scala | 26 ++++++++++++++++----
.../amber/engine/faulttolerance/ReplaySpec.scala | 7 +++++-
.../dashboard/file/WorkflowResourceSpec.scala | 5 +++-
.../workflow/WorkflowExecutionsResourceSpec.scala | 14 +++++++++--
.../texera/auth/util/ComputingUnitAccess.scala | 5 +++-
.../service/ComputingUnitManagingService.scala | 6 ++++-
.../resource/ComputingUnitAccessResource.scala | 6 ++++-
.../resource/ComputingUnitManagingResource.scala | 19 ++++++++++++---
.../org/apache/texera/service/FileService.scala | 6 ++++-
.../service/resource/DatasetAccessResource.scala | 7 +++++-
.../texera/service/resource/DatasetResource.scala | 17 ++++++++++---
.../apache/amber/compiler/WorkflowCompiler.scala | 5 +++-
.../resource/WorkflowCompilationResourceSpec.scala | 7 +++++-
.../core/storage/model/DatasetFileDocument.scala | 5 +++-
.../apache/amber/core/workflow/PhysicalOp.scala | 7 +++++-
.../apache/amber/core/workflow/PhysicalPlan.scala | 6 ++++-
.../amber/core/workflow/WorkflowContext.scala | 6 ++++-
.../scala/org/apache/amber/util/ArrowUtils.scala | 12 +++++++++-
.../scala/org/apache/amber/util/IcebergUtil.scala | 9 ++++++-
.../apache/amber/util/VirtualIdentityUtils.scala | 7 +++++-
.../amber/core/tuple/AttributeTypeUtilsSpec.scala | 7 +++++-
.../result/iceberg/IcebergDocumentSpec.scala | 7 +++++-
.../result/iceberg/IcebergTableStatsSpec.scala | 7 +++++-
.../org/apache/amber/operator/LogicalOp.scala | 17 ++++++++++---
.../amber/operator/SpecialPhysicalOpFactory.scala | 6 ++++-
.../org/apache/amber/operator/TestOperators.scala | 6 ++++-
.../amber/operator/aggregate/AggregateOpDesc.scala | 6 ++++-
.../amber/operator/hashJoin/HashJoinOpDesc.scala | 11 +++++++--
.../operator/intervalJoin/IntervalJoinOpDesc.scala | 5 +++-
.../Scorer/MachineLearningScorerOpDesc.scala | 6 ++++-
.../base/SklearnAdvancedBaseDesc.scala | 5 +++-
.../operator/sklearn/SklearnClassifierOpDesc.scala | 13 ++++++++--
.../operator/sklearn/SklearnPredictionOpDesc.scala | 5 +++-
.../sklearn/training/SklearnTrainingOpDesc.scala | 13 ++++++++--
.../v2/TwitterFullArchiveSearchSourceOpDesc.scala | 6 ++++-
.../twitter/v2/TwitterSearchSourceOpDesc.scala | 6 ++++-
.../source/scan/FileScanSourceOpDesc.scala | 6 ++++-
.../source/scan/text/TextSourceOpDesc.scala | 6 ++++-
.../operator/source/sql/SQLSourceOpDesc.scala | 7 +++++-
.../sql/asterixdb/AsterixDBSourceOpDesc.scala | 17 ++++++++++---
.../sql/asterixdb/AsterixDBSourceOpExec.scala | 5 +++-
.../apache/amber/operator/split/SplitOpDesc.scala | 6 ++++-
.../ScatterMatrixChartOpDesc.scala | 5 +++-
.../visualization/wordCloud/WordCloudOpDesc.scala | 6 ++++-
.../scan/text/FileScanSourceOpDescSpec.scala | 7 +++++-
133 files changed, 974 insertions(+), 198 deletions(-)
