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 22bec8bda3 Merge branch 'main' into xinyuan-renaming
add 75778e64f6 fix fmt
No new revisions were added by this update.
Summary of changes:
.../texera/service/AccessControlService.scala | 11 ++---
.../service/resource/AccessControlResource.scala | 7 ++-
.../apache/texera/AccessControlResourceSpec.scala | 20 ++------
.../handlers/actorcommand/backpressure_handler.py | 4 +-
.../handlers/control/end_channel_handler.py | 2 +-
.../handlers/control/query_statistics_handler.py | 2 +-
.../handlers/control/start_channel_handler.py | 2 +-
.../handlers/control/start_worker_handler.py | 6 +--
.../python/core/architecture/managers/context.py | 9 ++--
.../core/architecture/managers/executor_manager.py | 7 ++-
.../core/architecture/managers/pause_manager.py | 8 ++--
.../managers/state_processing_manager.py | 1 +
.../architecture/managers/statistics_manager.py | 2 +-
.../core/architecture/packaging/input_manager.py | 3 +-
.../core/architecture/packaging/output_manager.py | 9 ++--
.../core/architecture/rpc/async_rpc_client.py | 2 +-
.../rpc/async_rpc_handler_initializer.py | 2 +-
.../core/architecture/rpc/async_rpc_server.py | 5 +-
.../sendsemantics/broad_cast_partitioner.py | 7 +--
.../hash_based_shuffle_partitioner.py | 8 ++--
.../sendsemantics/one_to_one_partitioner.py | 6 +--
.../core/architecture/sendsemantics/partitioner.py | 5 +-
.../range_based_shuffle_partitioner.py | 7 ++-
.../sendsemantics/round_robin_partitioner.py | 7 +--
.../src/main/python/core/models/RTableExecutor.py | 5 +-
.../src/main/python/core/models/RTupleExecutor.py | 7 +--
core/amber/src/main/python/core/models/batch.py | 3 +-
core/amber/src/main/python/core/models/operator.py | 6 +--
core/amber/src/main/python/core/models/payload.py | 1 +
core/amber/src/main/python/core/models/r_utils.py | 3 +-
.../python/core/models/schema/attribute_type.py | 5 +-
.../src/main/python/core/models/schema/schema.py | 3 +-
.../main/python/core/models/schema/test_schema.py | 2 +-
core/amber/src/main/python/core/models/state.py | 1 +
core/amber/src/main/python/core/models/table.py | 6 +--
.../main/python/core/models/test_RTableExecutor.py | 1 +
.../src/main/python/core/models/test_table.py | 3 +-
.../src/main/python/core/models/test_tuple.py | 3 +-
core/amber/src/main/python/core/models/tuple.py | 11 ++---
.../src/main/python/core/proxy/proxy_server.py | 6 +--
.../main/python/core/proxy/test_proxy_client.py | 3 +-
.../main/python/core/runnables/data_processor.py | 4 +-
.../src/main/python/core/runnables/heartbeat.py | 13 +++--
.../src/main/python/core/runnables/main_loop.py | 12 ++---
.../main/python/core/runnables/network_receiver.py | 2 +-
.../main/python/core/runnables/network_sender.py | 9 ++--
.../python/core/runnables/test_console_message.py | 7 +--
.../main/python/core/runnables/test_main_loop.py | 5 +-
.../python/core/runnables/test_network_receiver.py | 13 +++--
.../python/core/runnables/test_network_sender.py | 3 +-
.../main/python/core/storage/document_factory.py | 3 +-
.../core/storage/iceberg/iceberg_document.py | 11 ++---
.../core/storage/iceberg/test_iceberg_document.py | 3 +-
.../storage/model/readonly_virtual_document.py | 3 +-
.../python/core/storage/model/virtual_document.py | 3 +-
.../input_port_materialization_reader_runnable.py | 21 ++++----
.../core/storage/runnables/port_storage_writer.py | 1 -
.../core/util/console_message/replace_print.py | 4 +-
.../core/util/console_message/timed_buffer.py | 1 -
.../test_linked_blocking_multi_queue.py | 3 +-
.../pytexera/storage/dataset_file_document.py | 2 +-
.../udf/examples/test_count_batch_operator.py | 3 +-
.../udf/examples/test_echo_table_operator.py | 3 +-
.../src/main/python/pytexera/udf/udf_operator.py | 1 +
.../src/main/python/texera_run_python_worker.py | 1 -
.../apache/amber/clustering/ClusterListener.scala | 9 ++--
.../common/AkkaActorRefMappingService.scala | 9 +---
.../architecture/common/AkkaActorService.scala | 2 +-
.../common/AkkaMessageTransferService.scala | 4 +-
.../architecture/common/AmberProcessor.scala | 13 ++---
.../architecture/common/ExecutorDeployment.scala | 6 +--
.../architecture/common/ProcessingStepCursor.scala | 2 +-
.../engine/architecture/common/WorkflowActor.scala | 16 ++-----
.../architecture/controller/ClientEvent.scala | 2 +-
.../architecture/controller/Controller.scala | 19 ++------
.../ControllerAsyncRPCHandlerInitializer.scala | 2 +-
.../controller/ControllerProcessor.scala | 9 +---
.../controller/ControllerTimerService.scala | 5 +-
.../controller/WorkflowScheduler.scala | 6 +--
.../controller/execution/ExecutionUtils.scala | 5 +-
.../controller/execution/OperatorExecution.scala | 4 +-
.../controller/execution/RegionExecution.scala | 4 +-
.../controller/execution/WorkflowExecution.scala | 2 +-
.../promisehandlers/ConsoleMessageHandler.scala | 5 +-
.../promisehandlers/DebugCommandHandler.scala | 7 +--
.../EmbeddedControlMessageHandler.scala | 13 ++---
.../EvaluatePythonExpressionHandler.scala | 7 +--
.../promisehandlers/LinkWorkersHandler.scala | 7 +--
.../controller/promisehandlers/PauseHandler.scala | 8 +---
.../promisehandlers/PortCompletedHandler.scala | 11 +----
.../QueryWorkerStatisticsHandler.scala | 13 ++---
.../controller/promisehandlers/ResumeHandler.scala | 5 +-
.../RetrieveWorkflowStateHandler.scala | 13 ++---
.../promisehandlers/RetryWorkflowHandler.scala | 6 +--
.../TakeGlobalCheckpointHandler.scala | 2 +-
.../WorkerExecutionCompletedHandler.scala | 11 +----
.../WorkerStateUpdatedHandler.scala | 10 +---
.../deploysemantics/layer/WorkerExecution.scala | 2 +-
.../architecture/logreplay/EmptyReplayLogger.scala | 2 +-
.../logreplay/ReplayLogGenerator.scala | 2 +-
.../architecture/logreplay/ReplayLogManager.scala | 2 +-
.../architecture/logreplay/ReplayLogger.scala | 2 +-
.../architecture/logreplay/ReplayLoggerImpl.scala | 2 +-
.../messaginglayer/AmberFIFOChannel.scala | 4 +-
.../messaginglayer/DeadLetterMonitorActor.scala | 5 +-
.../architecture/messaginglayer/InputGateway.scala | 2 +-
.../messaginglayer/NetworkInputGateway.scala | 2 +-
.../messaginglayer/NetworkOutputGateway.scala | 9 +---
.../messaginglayer/OutputManager.scala | 12 ++---
.../pythonworker/PythonProxyClient.scala | 15 ++----
.../pythonworker/PythonProxyServer.scala | 5 +-
.../pythonworker/PythonWorkflowWorker.scala | 10 +---
.../pythonworker/WorkerBatchInternalQueue.scala | 12 ++---
.../scheduling/CostBasedScheduleGenerator.scala | 15 +-----
.../ExpansionGreedyScheduleGenerator.scala | 15 ++----
.../scheduling/RegionExecutionCoordinator.scala | 25 ++--------
.../scheduling/ScheduleGenerator.scala | 5 +-
.../scheduling/WorkflowExecutionCoordinator.scala | 2 +-
.../scheduling/config/ChannelConfig.scala | 11 +----
.../scheduling/config/LinkConfig.scala | 12 +----
.../scheduling/config/PortConfig.scala | 1 +
.../scheduling/config/WorkerConfig.scala | 2 +-
.../partitioners/BroadcastPartitioner.scala | 2 +-
.../partitioners/HashBasedShufflePartitioner.scala | 2 +-
.../partitioners/OneToOnePartitioner.scala | 2 +-
.../sendsemantics/partitioners/Partitioner.scala | 3 +-
.../RangeBasedShufflePartitioner.scala | 2 +-
.../partitioners/RoundRobinPartitioner.scala | 2 +-
.../engine/architecture/worker/DPThread.scala | 13 ++---
.../engine/architecture/worker/DataProcessor.scala | 44 ++++-------------
.../DataProcessorRPCHandlerInitializer.scala | 9 +---
.../worker/EmbeddedControlMessageManager.scala | 12 +----
.../engine/architecture/worker/PauseManager.scala | 2 +-
.../architecture/worker/WorkflowWorker.scala | 2 +-
.../InputPortMaterializationReaderThread.scala | 32 +++----------
.../worker/managers/StatisticsManager.scala | 6 +--
.../promisehandlers/AddInputChannelHandler.scala | 5 +-
.../promisehandlers/AddPartitioningHandler.scala | 5 +-
.../FinalizeCheckpointHandler.scala | 10 +---
.../InitializeExecutorHandler.scala | 5 +-
.../promisehandlers/PrepareCheckpointHandler.scala | 12 ++---
.../apache/amber/engine/common/AmberLogging.scala | 2 +-
.../apache/amber/engine/common/AmberRuntime.scala | 2 +-
.../amber/engine/common/client/AmberClient.scala | 12 ++---
.../amber/engine/common/client/ClientActor.scala | 29 ++---------
.../amber/engine/common/rpc/AsyncRPCClient.scala | 15 ++----
.../common/rpc/AsyncRPCHandlerInitializer.scala | 6 +--
.../amber/engine/common/rpc/AsyncRPCServer.scala | 8 +---
.../common/statetransition/StateManager.scala | 5 +-
.../statetransition/WorkerStateManager.scala | 2 +-
.../engine/common/storage/EmptyRecordStorage.scala | 5 +-
.../engine/common/storage/HDFSRecordStorage.scala | 2 +-
.../common/storage/SequentialRecordStorage.scala | 5 +-
.../engine/common/storage/VFSRecordStorage.scala | 5 +-
.../scala/org/apache/amber/error/ErrorUtils.scala | 2 +-
.../apache/texera/web/ComputingUnitMaster.scala | 20 ++++----
.../texera/web/ServletAwareConfigurator.scala | 6 +--
.../scala/org/apache/texera/web/SessionState.scala | 2 +-
.../apache/texera/web/TexeraWebApplication.scala | 22 +++------
.../org/apache/texera/web/WebsocketInput.scala | 2 +-
.../apache/texera/web/auth/GuestAuthFilter.scala | 4 +-
.../scala/org/apache/texera/web/auth/JwtAuth.scala | 5 +-
.../apache/texera/web/auth/UserAuthenticator.scala | 2 +-
.../texera/web/auth/UserRoleAuthorizer.scala | 2 +-
.../websocket/request/TexeraWebSocketRequest.scala | 5 +-
.../web/resource/CollaborationResource.scala | 2 +-
.../apache/texera/web/resource/EmailTemplate.scala | 2 +-
.../apache/texera/web/resource/GmailResource.scala | 2 +-
.../texera/web/resource/UserConfigResource.scala | 4 +-
.../web/resource/WebsocketPayloadSizeTuner.scala | 2 +-
.../web/resource/WorkflowWebsocketResource.scala | 4 +-
.../resource/aiassistant/AiAssistantResource.scala | 4 +-
.../texera/web/resource/auth/AuthResource.scala | 4 +-
.../web/resource/auth/GoogleAuthResource.scala | 4 +-
.../web/resource/dashboard/DashboardResource.scala | 3 +-
.../dashboard/DatasetSearchQueryBuilder.scala | 9 ++--
.../dashboard/ProjectSearchQueryBuilder.scala | 7 +--
.../resource/dashboard/SearchQueryBuilder.scala | 5 +-
.../admin/execution/AdminExecutionResource.scala | 4 +-
.../admin/settings/AdminSettingsResource.scala | 11 +++--
.../dashboard/admin/user/AdminUserResource.scala | 4 +-
.../web/resource/dashboard/hub/HubResource.scala | 42 +++++-----------
.../dashboard/user/dataset/DatasetResource.scala | 1 -
.../user/project/ProjectAccessResource.scala | 11 ++---
.../dashboard/user/project/ProjectResource.scala | 12 ++---
.../user/project/PublicProjectResource.scala | 4 +-
.../dashboard/user/quota/UserQuotaResource.scala | 4 +-
.../user/workflow/WorkflowAccessResource.scala | 17 ++-----
.../user/workflow/WorkflowExecutionsResource.scala | 54 +++++++++------------
.../dashboard/user/workflow/WorkflowResource.scala | 11 ++---
.../user/workflow/WorkflowVersionResource.scala | 9 ++--
.../web/service/ExecutionConsoleService.scala | 45 ++++++-----------
.../service/ExecutionReconfigurationService.scala | 5 +-
.../web/service/ExecutionResultService.scala | 22 +++------
.../web/service/ExecutionRuntimeService.scala | 7 +--
.../texera/web/service/ExecutionStatsService.scala | 38 ++++-----------
.../service/ExecutionsMetadataPersistService.scala | 2 -
.../service/FriesReconfigurationAlgorithm.scala | 7 +--
.../texera/web/service/ResultExportService.scala | 24 ++++------
.../web/service/WorkflowExecutionService.scala | 10 +---
.../texera/web/service/WorkflowService.scala | 27 ++++-------
.../storage/ExecutionReconfigurationStore.scala | 2 +-
.../texera/web/storage/ExecutionStateStore.scala | 7 +--
.../org/apache/texera/web/storage/StateStore.scala | 4 +-
.../org/apache/texera/workflow/LogicalPlan.scala | 2 +-
.../architecture/control/TrivialControlSpec.scala | 17 ++-----
.../control/utils/MultiCallHandler.scala | 2 +-
.../utils/TesterAsyncRPCHandlerInitializer.scala | 2 +-
.../control/utils/TrivialControlTester.scala | 8 +---
.../messaginglayer/NetworkInputGatewaySpec.scala | 2 +-
.../messaginglayer/OutputManagerSpec.scala | 9 +---
.../messaginglayer/RangeBasedShuffleSpec.scala | 2 +-
.../CostBasedScheduleGeneratorSpec.scala | 3 +-
.../scheduling/DefaultCostEstimatorSpec.scala | 5 +-
.../ExpansionGreedyScheduleGeneratorSpec.scala | 5 +-
.../engine/architecture/worker/DPThreadSpec.scala | 15 ++----
.../architecture/worker/DataProcessorSpec.scala | 32 +++----------
.../engine/architecture/worker/WorkerSpec.scala | 13 +----
.../engine/e2e/BatchSizePropagationSpec.scala | 3 +-
.../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 | 9 +---
.../dashboard/file/WorkflowResourceSpec.scala | 9 ++--
.../workflow/WorkflowExecutionsResourceSpec.scala | 14 +-----
.../workflow/WorkflowVersionResourceSpec.scala | 2 +-
.../web/service/ExecutionConsoleServiceSpec.scala | 3 +-
.../org/apache/texera/auth/JwtAuthFilter.scala | 7 +--
.../texera/auth/util/ComputingUnitAccess.scala | 6 +--
.../service/ComputingUnitManagingService.scala | 12 ++---
.../resource/ComputingUnitAccessResource.scala | 18 +++----
.../resource/ComputingUnitManagingResource.scala | 39 +++++----------
.../texera/service/util/KubernetesClient.scala | 2 +-
.../org/apache/texera/service/ConfigService.scala | 6 +--
.../texera/service/resource/ConfigResource.scala | 4 +-
.../org/apache/texera/config/DefaultsConfig.scala | 1 +
core/dao/build.sbt | 3 +-
.../org/apache/texera/dao/JooqCodeGenerator.scala | 2 +-
.../scala/org/apache/texera/dao/MockTexeraDB.scala | 2 +-
.../org/apache/texera/service/FileService.scala | 12 ++---
.../service/resource/DatasetAccessResource.scala | 15 ++----
.../texera/service/resource/DatasetResource.scala | 52 +++++---------------
.../service/type/dataset/DatasetFileNode.scala | 2 +-
.../texera/service/util/S3StorageClient.scala | 2 +-
.../org/apache/texera/service/MockLakeFS.scala | 12 ++---
.../service/resource/DatasetResourceSpec.scala | 2 +-
core/gui/src/app/app-routing.module.ts | 9 ++--
core/gui/src/app/app.module.ts | 13 +++--
core/gui/src/app/common/formly/formly-config.ts | 4 +-
.../preset-wrapper/preset-wrapper.component.ts | 2 +-
.../src/app/common/service/gmail/gmail.service.ts | 1 +
.../app/common/service/user/auth-guard.service.ts | 2 +-
.../src/app/common/service/user/auth.service.ts | 9 ++--
.../service/user/config/user-config.service.ts | 1 -
.../app/common/service/user/stub-auth.service.ts | 2 +-
.../workflow-persist.service.spec.ts | 36 +++++++-------
.../workflow-persist/workflow-persist.service.ts | 2 +-
core/gui/src/app/common/type/workflow.ts | 2 +-
.../app/common/util/size-formatter.util.spec.ts | 2 +-
.../component/admin/gmail/admin-gmail.component.ts | 1 +
.../component/admin/user/admin-user.component.ts | 2 +-
.../component/dashboard.component.spec.ts | 14 +++---
.../app/dashboard/component/dashboard.component.ts | 2 +-
.../files-uploader/files-uploader.component.ts | 8 +---
.../filters-instructions.component.ts | 2 +-
.../user/search-bar/search-bar.component.ts | 2 +-
.../search-results/search-results.component.ts | 2 +-
.../component/user/search/search.component.ts | 2 +-
.../user/share-access/share-access.component.ts | 2 +-
.../user/user-avatar/user-avatar.component.ts | 1 +
.../dataset-detail.component.ts | 1 -
.../user-dataset-file-renderer.component.ts | 2 +-
.../user-dataset-version-creator.component.ts | 4 +-
.../user-dataset-version-filetree.component.ts | 2 +-
.../user/user-dataset/user-dataset.component.ts | 6 +--
.../user/user-quota/user-quota.component.ts | 4 +-
.../highlight-search-terms.pipe.ts | 3 +-
.../user-workflow/user-workflow.component.spec.ts | 5 +-
.../user/user-workflow/user-workflow.component.ts | 8 +++-
.../service/admin/user/admin-user.service.ts | 4 +-
.../service/user/dataset/dataset.service.ts | 4 +-
.../service/user/download/download.service.ts | 8 ++--
.../service/user/quota/user-quota.service.ts | 2 +-
.../user/share-access/share-access.service.ts | 1 +
.../dashboard/service/user/stub-search.service.ts | 2 +-
.../dashboard/type/dashboard-dataset.interface.ts | 3 +-
.../app/dashboard/type/search-filter-parameters.ts | 1 -
.../hub/component/about/about.component.spec.ts | 2 -
.../browse-section/browse-section.component.ts | 8 ++--
core/gui/src/app/hub/component/hub.component.ts | 2 +-
.../landing-page/landing-page.component.ts | 3 +-
.../annotation-suggestion.component.ts | 2 +-
.../breakpoint-condition-input.component.spec.ts | 2 +-
.../breakpoint-condition-input.component.ts | 13 +----
.../code-debugger.component.spec.ts | 2 +-
.../codearea-custom-template.component.ts | 2 +-
.../component/left-panel/left-panel.component.ts | 3 +-
.../app/workspace/component/menu/menu.component.ts | 4 +-
.../computing-unit-selection.component.spec.ts | 4 --
.../computing-unit-selection.component.ts | 4 +-
.../property-editor/property-editor.component.ts | 11 +++--
.../type-casting-display.component.spec.ts | 2 +-
.../result-exportation.component.ts | 4 +-
.../error-frame/error-frame.component.ts | 7 +--
.../result-panel/result-panel.component.ts | 9 ++--
.../result-table-frame.component.ts | 8 +---
.../visualization-frame-content.component.ts | 2 +-
.../nz-modal-comment-box.component.ts | 5 +-
.../context-menu/context-menu.component.spec.ts | 2 +-
.../workflow-editor/workflow-editor.component.ts | 2 +-
.../service/ai-analyst/ai-analyst.service.ts | 2 +-
.../service/ai-assistant/ai-assistant.service.ts | 4 +-
.../compile-workflow/workflow-compiling.service.ts | 2 +-
.../computing-unit-status.service.ts | 8 ++--
.../service/drag-drop/drag-drop.service.spec.ts | 2 +-
.../dynamic-schema/dynamic-schema.service.spec.ts | 9 +---
.../dynamic-schema/dynamic-schema.service.ts | 3 +-
.../execute-workflow.service.spec.ts | 2 -
.../execute-workflow/execute-workflow.service.ts | 6 +--
.../service/execute-workflow/mock-result-data.ts | 2 +-
.../service/execute-workflow/mock-workflow-plan.ts | 4 +-
.../workspace/service/joint-ui/joint-ui.service.ts | 1 +
.../service/undo-redo/undo-redo.service.spec.ts | 4 +-
.../validation/validation-workflow.service.ts | 3 +-
.../workflow-computing-unit-managing.service.ts | 1 -
.../workflow-console/workflow-console.service.ts | 3 +-
.../service/workflow-graph/model/shared-model.ts | 2 +-
.../workflow-graph/model/sync-texera-model.spec.ts | 1 -
.../model/workflow-action.service.spec.ts | 18 ++++---
.../model/workflow-action.service.ts | 3 +-
.../service/workflow-graph/model/workflow-graph.ts | 3 +-
.../util/workflow-util.service.spec.ts | 2 +-
.../workflow-graph/util/workflow-util.service.ts | 4 +-
.../workflow-result-export.service.spec.ts | 13 ++---
.../workflow-result-export.service.ts | 11 ++---
.../workflow-result.service.spec.ts | 2 +-
.../workflow-result/workflow-result.service.ts | 4 +-
.../operator-reuse-cache-status.service.ts | 1 +
.../workspace/types/execute-workflow.interface.ts | 3 +-
.../types/workflow-websocket.interface.ts | 2 +-
core/gui/src/assets/svg/hub_icon.svg | 20 ++++----
.../assets/svg/operator-reuse-cache-invalid.svg | 3 +-
.../src/assets/svg/operator-reuse-cache-valid.svg | 3 +-
core/gui/src/environments/environment.default.ts | 2 -
.../src/language-server-runner.ts | 6 +--
core/pyright-language-server/src/main.ts | 8 ++--
core/pyright-language-server/src/server-commons.ts | 16 +++----
.../apache/amber/compiler/WorkflowCompiler.scala | 7 +--
.../apache/amber/compiler/model/LogicalPlan.scala | 4 +-
.../texera/service/WorkflowCompilingService.scala | 5 +-
.../resource/WorkflowCompilationResource.scala | 8 ++--
.../resource/WorkflowCompilationResourceSpec.scala | 21 ++++----
.../scala/org/apache/amber/core/state/State.scala | 1 +
.../amber/core/storage/DocumentFactory.scala | 2 +-
.../apache/amber/core/storage/FileResolver.scala | 2 +-
.../core/storage/model/DatasetFileDocument.scala | 7 +--
.../storage/result/iceberg/IcebergDocument.scala | 8 ++--
.../result/iceberg/IcebergTableWriter.scala | 2 +-
.../core/storage/util/LakeFSStorageClient.scala | 4 +-
.../storage/util/dataset/PhysicalFileNode.java | 6 +--
.../org/apache/amber/core/tuple/Attribute.java | 2 +-
.../org/apache/amber/core/tuple/AttributeType.java | 1 -
.../scala/org/apache/amber/core/tuple/Tuple.scala | 2 +-
.../org/apache/amber/core/tuple/TupleUtils.scala | 9 ++--
.../apache/amber/core/workflow/PhysicalOp.scala | 7 +--
.../apache/amber/core/workflow/PhysicalPlan.scala | 7 +--
.../amber/core/workflow/WorkflowContext.scala | 6 +--
.../scala/org/apache/amber/util/ArrowUtils.scala | 16 ++-----
.../scala/org/apache/amber/util/IcebergUtil.scala | 14 ++----
.../scala/org/apache/amber/util/JSONUtils.scala | 2 +-
.../apache/amber/util/VirtualIdentityUtils.scala | 7 +--
.../amber/core/tuple/AttributeTypeUtilsSpec.scala | 7 +--
.../apache/amber/storage/FileResolverSpec.scala | 4 +-
.../IcebergDocumentConsoleMessagesSpec.scala | 6 +--
.../result/iceberg/IcebergDocumentSpec.scala | 9 +---
.../result/iceberg/IcebergTableStatsSpec.scala | 13 ++---
.../org/apache/amber/util/IcebergUtilSpec.scala | 2 +-
.../jackson/jsonSchema/JsonSchemaGenerator.scala | 10 +---
.../org/apache/amber/operator/LogicalOp.scala | 56 ++++------------------
.../amber/operator/SpecialPhysicalOpFactory.scala | 6 +--
.../org/apache/amber/operator/TestOperators.scala | 6 +--
.../amber/operator/aggregate/AggregateOpDesc.scala | 6 +--
.../cartesianProduct/CartesianProductOpExec.scala | 1 +
.../apache/amber/operator/dummy/DummyOpDesc.scala | 2 +-
.../operator/filter/SpecializedFilterOpDesc.scala | 5 +-
.../amber/operator/hashJoin/HashJoinOpDesc.scala | 11 +----
.../HuggingFaceIrisLogisticRegressionOpDesc.scala | 2 +-
.../HuggingFaceSentimentAnalysisOpDesc.scala | 2 +-
.../HuggingFaceSpamSMSDetectionOpDesc.scala | 2 +-
.../amber/operator/ifStatement/IfOpDesc.scala | 8 +---
.../operator/intervalJoin/IntervalJoinOpDesc.scala | 10 ++--
.../operator/intervalJoin/IntervalJoinOpExec.scala | 1 +
.../keywordSearch/KeywordSearchOpDesc.scala | 7 ++-
.../apache/amber/operator/limit/LimitOpDesc.scala | 7 ++-
.../Scorer/MachineLearningScorerOpDesc.scala | 10 ++--
.../SklearnAdvancedSVRTrainerOpDesc.scala | 1 -
.../base/SklearnAdvancedBaseDesc.scala | 5 +-
.../org/apache/amber/operator/map/MapOpDesc.scala | 2 +-
.../metadata/OperatorMetadataGenerator.scala | 2 +-
.../amber/operator/projection/AttributeUnit.java | 1 +
.../apache/amber/operator/regex/RegexOpDesc.scala | 7 ++-
.../ReservoirSamplingOpDesc.scala | 5 +-
.../operator/sklearn/SklearnClassifierOpDesc.scala | 15 ++----
.../sklearn/SklearnLinearRegressionOpDesc.scala | 4 +-
.../operator/sklearn/SklearnPredictionOpDesc.scala | 7 +--
.../sklearn/training/SklearnTrainingOpDesc.scala | 13 +----
.../sortPartitions/SortPartitionsOpDesc.scala | 5 +-
.../apis/reddit/RedditSearchSourceOpDesc.scala | 2 +-
.../source/apis/twitter/TwitterSourceOpDesc.scala | 2 +-
.../source/apis/twitter/TwitterSourceOpExec.scala | 4 +-
.../v2/TwitterFullArchiveSearchSourceOpDesc.scala | 8 +---
.../v2/TwitterFullArchiveSearchSourceOpExec.scala | 8 ++--
.../twitter/v2/TwitterSearchSourceOpDesc.scala | 8 +---
.../twitter/v2/TwitterSearchSourceOpExec.scala | 8 ++--
.../source/apis/twitter/v2/TwitterUtils.scala | 2 +-
.../operator/source/fetcher/URLFetcherOpDesc.scala | 5 +-
.../source/scan/FileScanSourceOpDesc.scala | 6 +--
.../source/scan/FileScanSourceOpExec.scala | 5 +-
.../operator/source/scan/ScanSourceOpDesc.scala | 2 +-
.../source/scan/arrow/ArrowSourceOpDesc.scala | 10 ++--
.../source/scan/csv/CSVScanSourceOpDesc.scala | 2 +-
.../scan/csv/ParallelCSVScanSourceOpDesc.scala | 2 +-
.../scan/csvOld/CSVOldScanSourceOpDesc.scala | 2 +-
.../source/scan/text/TextInputSourceOpDesc.scala | 7 ++-
.../source/scan/text/TextSourceOpDesc.scala | 6 +--
.../operator/source/sql/SQLSourceOpDesc.scala | 7 +--
.../sql/asterixdb/AsterixDBSourceOpDesc.scala | 22 ++-------
.../sql/asterixdb/AsterixDBSourceOpExec.scala | 5 +-
.../source/sql/mysql/MySQLSourceOpDesc.scala | 5 +-
.../sql/postgresql/PostgreSQLSourceOpDesc.scala | 7 ++-
.../apache/amber/operator/split/SplitOpDesc.scala | 6 +--
.../apache/amber/operator/split/SplitOpExec.scala | 2 +-
.../SymmetricDifferenceOpDesc.scala | 11 +----
.../SymmetricDifferenceOpExec.scala | 1 +
.../operator/typecasting/TypeCastingOpDesc.scala | 5 +-
.../amber/operator/udf/java/JavaUDFOpDesc.scala | 10 +---
.../python/DualInputPortsPythonUDFOpDescV2.scala | 5 +-
.../udf/python/PythonLambdaFunctionOpDesc.scala | 2 +-
.../python/source/PythonUDFSourceOpDescV2.scala | 5 +-
.../apache/amber/operator/udf/r/RUDFOpDesc.scala | 12 ++---
.../amber/operator/udf/r/RUDFSourceOpDesc.scala | 5 +-
.../operator/unneststring/UnnestStringOpDesc.scala | 7 ++-
.../visualization/DotPlot/DotPlotOpDesc.scala | 4 +-
.../IcicleChart/IcicleChartOpDesc.scala | 6 +--
.../ImageViz/ImageVisualizerOpDesc.scala | 4 +-
.../ScatterMatrixChartOpDesc.scala | 9 ++--
.../boxViolinPlot/BoxViolinPlotOpDesc.scala | 7 ++-
.../bubbleChart/BubbleChartOpDesc.scala | 4 +-
.../bulletChart/BulletChartOpDesc.scala | 6 +--
.../candlestickChart/CandlestickChartOpDesc.scala | 6 +--
.../choroplethMap/ChoroplethMapOpDesc.scala | 4 +-
.../ContinuousErrorBandsOpDesc.scala | 4 +-
.../contourPlot/ContourPlotOpDesc.scala | 6 +--
.../dendrogram/DendrogramOpDesc.scala | 6 +--
.../dumbbellPlot/DumbbellPlotOpDesc.scala | 4 +-
.../FigureFactoryTableOpDesc.scala | 4 +-
.../filledAreaPlot/FilledAreaPlotOpDesc.scala | 6 +--
.../funnelPlot/FunnelPlotOpDesc.scala | 4 +-
.../ganttChart/GanttChartOpDesc.scala | 6 +--
.../gaugeChart/GaugeChartOpDesc.scala | 6 +--
.../visualization/heatMap/HeatMapOpDesc.scala | 4 +-
.../hierarchychart/HierarchyChartOpDesc.scala | 4 +-
.../histogram/HistogramChartOpDesc.scala | 4 +-
.../histogram2d/Histogram2DOpDesc.scala | 3 +-
.../visualization/htmlviz/HtmlVizOpDesc.scala | 4 +-
.../visualization/lineChart/LineChartOpDesc.scala | 4 +-
.../nestedTable/NestedTableOpDesc.scala | 4 +-
.../networkGraph/NetworkGraphOpDesc.scala | 4 +-
.../visualization/pieChart/PieChartOpDesc.scala | 4 +-
.../quiverPlot/QuiverPlotOpDesc.scala | 4 +-
.../rangeSlider/RangeSliderOpDesc.scala | 4 +-
.../sankeyDiagram/SankeyDiagramOpDesc.scala | 6 +--
.../scatter3DChart/Scatter3dChartOpDesc.scala | 6 +--
.../scatterplot/ScatterplotOpDesc.scala | 6 +--
.../tablesChart/TablesPlotOpDesc.scala | 4 +-
.../ternaryPlot/TernaryPlotOpDesc.scala | 4 +-
.../visualization/urlviz/UrlVizOpDesc.scala | 6 +--
.../volcanoPlot/VolcanoPlotOpDesc.scala | 6 +--
.../waterfallChart/WaterfallChartOpDesc.scala | 6 +--
.../visualization/wordCloud/WordCloudOpDesc.scala | 6 +--
.../CartesianProductOpExecSpec.scala | 9 +---
.../dictionary/DictionaryMatcherOpExecSpec.scala | 2 +-
.../operator/difference/DifferenceOpExecSpec.scala | 2 +-
.../operator/distinct/DistinctOpExecSpec.scala | 2 +-
.../amber/operator/hashJoin/HashJoinOpSpec.scala | 14 ++----
.../operator/intersect/IntersectOpExecSpec.scala | 2 +-
.../operator/intervalJoin/IntervalOpExecSpec.scala | 11 +----
.../scan/text/FileScanSourceOpDescSpec.scala | 7 +--
.../SymmetricDifferenceOpExecSpec.scala | 9 +---
490 files changed, 1102 insertions(+), 2170 deletions(-)
