This is an automated email from the ASF dual-hosted git repository.
chenli pushed a change to branch feat/drop-support-for-r-udf
in repository https://gitbox.apache.org/repos/asf/texera.git
from f971d89869 Merge branch 'main' into feat/drop-support-for-r-udf
add 1771b8971c chore(deps): bump transformers from 4.53.0 to 4.57.3 (#4093)
add cecaa36571 chore(dep): Bump `pandas` version to 2.2.3 (#4096)
add 7cf3b76f09 chore(dep): Bump `numpy` version to 2.1.0 (#4098)
add de89d5fa19 feat(ci): add Github CI for creating and uploading release
candidate artifacts (#4076)
add e8c80c6f85 chore: Move `apache.amber` to `apache.texera.amber` (#4094)
add cb7da2a035 feat: add run configurations to improve developer
experience (#4087)
add e73034d722 fix(deploy): update single-node docker-compose
configuration with latest architecture (#4077)
add ab3f84004f chore(deps): bump pg8000 from 1.31.2 to 1.31.5 in /amber
(#4104)
add 6626c81d64 fix: run configurations for Windows (#4107)
add 02a2702589 Merge branch 'main' into feat/drop-support-for-r-udf
No new revisions were added by this update.
Summary of changes:
.github/release/vote-email-template.md | 85 ++++++
.github/workflows/create-release-candidate.yml | 340 +++++++++++++++++++++
.run/AccessControlService.run.xml | 33 ++
.run/ComputingUnitManagingService.run.xml | 34 +++
.run/ComputingUnitMaster.run.xml | 34 +++
.run/ComputingUnitWorker.run.xml | 34 +++
.run/ConfigService.run.xml | 34 +++
.run/FileService.run.xml | 34 +++
.run/TexeraWebApplication.run.xml | 34 +++
.run/WorkflowCompilingService.run.xml | 34 +++
.run/frontend.run.xml | 30 ++
.run/texera micro services.run.xml | 31 ++
.run/texera-lakefs.run.xml | 28 ++
.../texera/service/AccessControlService.scala | 2 +-
amber/operator-requirements.txt | 2 +-
amber/requirements.txt | 6 +-
.../engine/architecture/rpc/controlcommands.proto | 18 +-
.../architecture/rpc/controllerservice.proto | 6 +-
.../engine/architecture/rpc/controlreturns.proto | 6 +-
.../engine/architecture/rpc/testerservice.proto | 6 +-
.../engine/architecture/rpc/workerservice.proto | 6 +-
.../architecture/sendsemantics/partitionings.proto | 4 +-
.../engine/architecture/worker/statistics.proto | 4 +-
.../amber/engine/common/actormessage.proto | 2 +-
.../amber/engine/common/ambermessage.proto | 8 +-
.../engine/common/executionruntimestate.proto | 12 +-
.../handlers/actorcommand/actor_handler_base.py | 2 +-
.../handlers/actorcommand/backpressure_handler.py | 6 +-
.../handlers/actorcommand/credit_update_handler.py | 2 +-
.../handlers/control/add_input_channel_handler.py | 2 +-
.../handlers/control/add_partitioning_handler.py | 2 +-
.../handlers/control/assign_port_handler.py | 4 +-
.../handlers/control/control_handler_base.py | 2 +-
.../handlers/control/debug_command_handler.py | 2 +-
.../handlers/control/end_channel_handler.py | 5 +-
.../handlers/control/end_worker_handler.py | 2 +-
.../control/evaluate_expression_handler.py | 2 +-
.../control/initialize_executor_handler.py | 4 +-
.../handlers/control/no_operation_handler.py | 2 +-
.../handlers/control/open_executor_handler.py | 5 +-
.../handlers/control/pause_worker_handler.py | 2 +-
.../handlers/control/query_statistics_handler.py | 4 +-
.../control/replay_current_tuple_handler.py | 7 +-
.../handlers/control/resume_worker_handler.py | 2 +-
.../handlers/control/start_channel_handler.py | 5 +-
.../handlers/control/start_worker_handler.py | 6 +-
.../handlers/control/update_executor_handler.py | 2 +-
.../managers/console_message_manager.py | 2 +-
.../python/core/architecture/managers/context.py | 4 +-
.../managers/embedded_control_message_manager.py | 4 +-
.../core/architecture/managers/pause_manager.py | 4 +-
.../architecture/managers/statistics_manager.py | 4 +-
.../architecture/managers/test_pause_manager.py | 2 +-
.../architecture/managers/test_state_manager.py | 2 +-
.../managers/tuple_processing_manager.py | 2 +-
.../core/architecture/packaging/input_manager.py | 4 +-
.../core/architecture/packaging/output_manager.py | 6 +-
.../core/architecture/rpc/async_rpc_client.py | 6 +-
.../core/architecture/rpc/async_rpc_server.py | 6 +-
.../sendsemantics/broad_cast_partitioner.py | 6 +-
.../hash_based_shuffle_partitioner.py | 6 +-
.../sendsemantics/one_to_one_partitioner.py | 6 +-
.../core/architecture/sendsemantics/partitioner.py | 6 +-
.../range_based_shuffle_partitioner.py | 6 +-
.../sendsemantics/round_robin_partitioner.py | 6 +-
.../src/main/python/core/models/internal_queue.py | 6 +-
amber/src/main/python/core/models/test_tuple.py | 4 +-
.../main/python/core/runnables/data_processor.py | 2 +-
amber/src/main/python/core/runnables/main_loop.py | 6 +-
.../main/python/core/runnables/network_receiver.py | 4 +-
.../main/python/core/runnables/network_sender.py | 6 +-
.../python/core/runnables/test_console_message.py | 6 +-
.../main/python/core/runnables/test_main_loop.py | 10 +-
.../python/core/runnables/test_network_receiver.py | 6 +-
.../core/storage/iceberg/test_iceberg_document.py | 2 +-
.../input_port_materialization_reader_runnable.py | 6 +-
.../main/python/core/storage/vfs_uri_factory.py | 2 +-
.../main/python/core/util/buffer/timed_buffer.py | 2 +-
.../core/util/console_message/replace_print.py | 2 +-
.../core/util/console_message/timed_buffer.py | 4 +-
.../core/util/expression_evaluator/__init__.py | 5 +-
.../test_expression_evaluator.py | 5 +-
.../python/core/util/virtual_identity/__init__.py | 2 +-
.../org/apache/{ => texera}/amber/__init__.py | 0
.../org/apache/{ => texera}/amber/core/__init__.py | 0
.../apache/{ => texera}/amber/engine/__init__.py | 0
.../amber/engine/architecture/__init__.py | 0
.../amber/engine/architecture/rpc/__init__.py | 180 +++++------
.../engine/architecture/sendsemantics/__init__.py | 0
.../amber/engine/architecture/worker/__init__.py | 0
.../{ => texera}/amber/engine/common/__init__.py | 0
.../amber/clustering/ClusterListener.scala | 18 +-
.../amber/clustering/SingleNodeListener.scala | 4 +-
.../common/AkkaActorRefMappingService.scala | 12 +-
.../architecture/common/AkkaActorService.scala | 6 +-
.../common/AkkaMessageTransferService.scala | 14 +-
.../architecture/common/AmberProcessor.scala | 20 +-
.../architecture/common/ExecutorDeployment.scala | 18 +-
.../architecture/common/ProcessingStepCursor.scala | 6 +-
.../engine/architecture/common/WorkflowActor.scala | 18 +-
.../architecture/controller/ClientEvent.scala | 12 +-
.../architecture/controller/Controller.scala | 26 +-
.../ControllerAsyncRPCHandlerInitializer.scala | 14 +-
.../controller/ControllerProcessor.scala | 18 +-
.../controller/ControllerTimerService.scala | 12 +-
.../controller/GlobalReplayManager.scala | 4 +-
.../engine/architecture/controller/Workflow.scala | 4 +-
.../controller/WorkflowScheduler.scala | 8 +-
.../controller/execution/ChannelExecution.scala | 2 +-
.../controller/execution/ExecutionUtils.scala | 11 +-
.../controller/execution/LinkExecution.scala | 4 +-
.../controller/execution/OperatorExecution.scala | 22 +-
.../controller/execution/RegionExecution.scala | 14 +-
.../controller/execution/WorkerPortExecution.scala | 2 +-
.../controller/execution/WorkflowExecution.scala | 16 +-
.../promisehandlers/ConsoleMessageHandler.scala | 8 +-
.../promisehandlers/DebugCommandHandler.scala | 10 +-
.../EmbeddedControlMessageHandler.scala | 14 +-
.../EvaluatePythonExpressionHandler.scala | 10 +-
.../promisehandlers/LinkWorkersHandler.scala | 8 +-
.../controller/promisehandlers/PauseHandler.scala | 18 +-
.../promisehandlers/PortCompletedHandler.scala | 16 +-
.../QueryWorkerStatisticsHandler.scala | 19 +-
.../controller/promisehandlers/ResumeHandler.scala | 13 +-
.../RetrieveWorkflowStateHandler.scala | 16 +-
.../promisehandlers/RetryWorkflowHandler.scala | 10 +-
.../promisehandlers/StartWorkflowHandler.scala | 13 +-
.../TakeGlobalCheckpointHandler.scala | 20 +-
.../WorkerExecutionCompletedHandler.scala | 10 +-
.../WorkerStateUpdatedHandler.scala | 10 +-
.../architecture/deploysemantics/AddressInfo.scala | 2 +-
.../deploystrategy/DeployStrategy.scala | 2 +-
.../deploysemantics/deploystrategy/OneOnEach.scala | 2 +-
.../deploystrategy/RandomDeployment.scala | 2 +-
.../deploystrategy/RoundRobinDeployment.scala | 2 +-
.../deploysemantics/layer/WorkerExecution.scala | 10 +-
.../logreplay/AsyncReplayLogWriter.scala | 10 +-
.../architecture/logreplay/EmptyReplayLogger.scala | 9 +-
.../architecture/logreplay/OrderEnforcer.scala | 4 +-
.../logreplay/ReplayLogGenerator.scala | 8 +-
.../architecture/logreplay/ReplayLogManager.scala | 19 +-
.../architecture/logreplay/ReplayLogger.scala | 9 +-
.../architecture/logreplay/ReplayLoggerImpl.scala | 11 +-
.../logreplay/ReplayOrderEnforcer.scala | 4 +-
.../messaginglayer/AmberFIFOChannel.scala | 12 +-
.../messaginglayer/CongestionControl.scala | 4 +-
.../messaginglayer/DeadLetterMonitorActor.scala | 4 +-
.../architecture/messaginglayer/FlowControl.scala | 8 +-
.../architecture/messaginglayer/InputGateway.scala | 6 +-
.../architecture/messaginglayer/InputManager.scala | 18 +-
.../messaginglayer/NetworkInputGateway.scala | 8 +-
.../messaginglayer/NetworkOutputGateway.scala | 10 +-
.../messaginglayer/OrderingEnforcer.scala | 2 +-
.../messaginglayer/OutputManager.scala | 28 +-
.../architecture/messaginglayer/WorkerPort.scala | 6 +-
.../messaginglayer/WorkerTimerService.scala | 19 +-
.../pythonworker/PythonProxyClient.scala | 22 +-
.../pythonworker/PythonProxyServer.scala | 20 +-
.../pythonworker/PythonWorkflowWorker.scala | 26 +-
.../pythonworker/WorkerBatchInternalQueue.scala | 12 +-
.../scheduling/CostBasedScheduleGenerator.scala | 18 +-
.../architecture/scheduling/CostEstimator.scala | 18 +-
.../ExpansionGreedyScheduleGenerator.scala | 14 +-
.../engine/architecture/scheduling/Region.scala | 8 +-
.../scheduling/RegionExecutionCoordinator.scala | 34 +--
.../architecture/scheduling/RegionPlan.scala | 4 +-
.../engine/architecture/scheduling/Schedule.scala | 2 +-
.../scheduling/ScheduleGenerator.scala | 8 +-
.../architecture/scheduling/SchedulingUtils.scala | 2 +-
.../scheduling/WorkflowExecutionCoordinator.scala | 15 +-
.../scheduling/config/ChannelConfig.scala | 6 +-
.../scheduling/config/LinkConfig.scala | 8 +-
.../scheduling/config/OperatorConfig.scala | 2 +-
.../scheduling/config/PortConfig.scala | 4 +-
.../scheduling/config/ResourceConfig.scala | 6 +-
.../scheduling/config/WorkerConfig.scala | 10 +-
.../resourcePolicies/ExecutionClusterInfo.scala | 2 +-
.../resourcePolicies/ResourceAllocator.scala | 22 +-
.../partitioners/BroadcastPartitioner.scala | 8 +-
.../partitioners/HashBasedShufflePartitioner.scala | 8 +-
.../partitioners/OneToOnePartitioner.scala | 8 +-
.../sendsemantics/partitioners/Partitioner.scala | 14 +-
.../RangeBasedShufflePartitioner.scala | 8 +-
.../partitioners/RoundRobinPartitioner.scala | 8 +-
.../engine/architecture/worker/DPThread.scala | 25 +-
.../engine/architecture/worker/DataProcessor.scala | 42 +--
.../DataProcessorRPCHandlerInitializer.scala | 16 +-
.../worker/EmbeddedControlMessageManager.scala | 12 +-
.../engine/architecture/worker/PauseManager.scala | 8 +-
.../engine/architecture/worker/PauseType.scala | 4 +-
.../architecture/worker/WorkflowWorker.scala | 29 +-
.../InputPortMaterializationReaderThread.scala | 30 +-
.../managers/OutputPortResultWriterThread.scala | 6 +-
.../worker/managers/SerializationManager.scala | 16 +-
.../worker/managers/StatisticsManager.scala | 8 +-
.../promisehandlers/AddInputChannelHandler.scala | 14 +-
.../promisehandlers/AddPartitioningHandler.scala | 14 +-
.../worker/promisehandlers/AssignPortHandler.scala | 23 +-
.../worker/promisehandlers/EndChannelHandler.scala | 15 +-
.../worker/promisehandlers/EndHandler.scala | 11 +-
.../FinalizeCheckpointHandler.scala | 14 +-
.../FlushNetworkBufferHandler.scala | 11 +-
.../InitializeExecutorHandler.scala | 14 +-
.../promisehandlers/OpenExecutorHandler.scala | 11 +-
.../worker/promisehandlers/PauseHandler.scala | 20 +-
.../promisehandlers/PrepareCheckpointHandler.scala | 16 +-
.../promisehandlers/QueryStatisticsHandler.scala | 13 +-
.../worker/promisehandlers/ResumeHandler.scala | 16 +-
.../promisehandlers/RetrieveStateHandler.scala | 11 +-
.../promisehandlers/StartChannelHandler.scala | 17 +-
.../worker/promisehandlers/StartHandler.scala | 21 +-
.../amber/engine/common/AmberConfig.scala | 2 +-
.../amber/engine/common/AmberKryoInitializer.scala | 2 +-
.../amber/engine/common/AmberLogging.scala | 6 +-
.../amber/engine/common/AmberRuntime.scala | 8 +-
.../amber/engine/common/CheckpointState.scala | 2 +-
.../amber/engine/common/CheckpointSupport.scala | 6 +-
.../amber/engine/common/ElidableStatement.scala | 2 +-
.../amber/engine/common/FutureBijection.scala | 2 +-
.../amber/engine/common/SerializedState.scala | 2 +-
.../{ => texera}/amber/engine/common/Utils.scala | 4 +-
.../amberexception/BreakpointException.scala | 4 +-
.../engine/common/ambermessage/DataPayload.scala | 6 +-
.../ambermessage/DirectControlMessagePayload.scala | 2 +-
.../common/ambermessage/RecoveryPayload.scala | 4 +-
.../ambermessage/WorkflowFIFOMessagePayload.scala | 2 +-
.../common/ambermessage/WorkflowMessage.scala | 4 +-
.../amber/engine/common/client/AmberClient.scala | 23 +-
.../amber/engine/common/client/ClientActor.scala | 35 ++-
.../amber/engine/common/rpc/AsyncRPCClient.scala | 24 +-
.../common/rpc/AsyncRPCHandlerInitializer.scala | 14 +-
.../amber/engine/common/rpc/AsyncRPCServer.scala | 17 +-
.../common/statetransition/StateManager.scala | 8 +-
.../statetransition/WorkerStateManager.scala | 8 +-
.../engine/common/storage/EmptyRecordStorage.scala | 4 +-
.../engine/common/storage/HDFSRecordStorage.scala | 4 +-
.../common/storage/SequentialRecordStorage.scala | 6 +-
.../engine/common/storage/VFSRecordStorage.scala | 4 +-
.../amber/engine/common/virtualidentity/util.scala | 4 +-
.../{ => texera}/amber/error/ErrorUtils.scala | 12 +-
.../apache/texera/web/ComputingUnitMaster.scala | 26 +-
.../apache/texera/web/ComputingUnitWorker.scala | 2 +-
.../scala/org/apache/texera/web/SessionState.scala | 2 +-
.../apache/texera/web/TexeraWebApplication.scala | 6 +-
.../texera/web/WorkflowLifecycleManager.scala | 8 +-
.../http/response/SchemaPropagationResponse.scala | 2 +-
.../websocket/event/PaginatedResultEvent.scala | 2 +-
.../model/websocket/event/WorkflowErrorEvent.scala | 2 +-
.../event/python/ConsoleUpdateEvent.scala | 2 +-
.../request/EditingTimeCompilationRequest.scala | 2 +-
.../websocket/request/ModifyLogicRequest.scala | 2 +-
.../websocket/request/WorkflowExecuteRequest.scala | 4 +-
.../python/PythonExpressionEvaluateResponse.scala | 2 +-
.../web/resource/CollaborationResource.scala | 2 +-
.../web/resource/SystemMetadataResource.scala | 2 +-
.../web/resource/WorkflowWebsocketResource.scala | 12 +-
.../resource/aiassistant/AiAssistantManager.scala | 2 +-
.../dashboard/DatasetSearchQueryBuilder.scala | 2 +-
.../web/resource/dashboard/hub/HubResource.scala | 2 +-
.../user/workflow/WorkflowExecutionsResource.scala | 23 +-
.../dashboard/user/workflow/WorkflowResource.scala | 4 +-
.../user/workflow/WorkflowVersionResource.scala | 2 +-
.../web/service/EmailNotificationService.scala | 2 +-
.../web/service/ExecutionConsoleService.scala | 30 +-
.../service/ExecutionReconfigurationService.scala | 6 +-
.../web/service/ExecutionResultService.scala | 32 +-
.../web/service/ExecutionRuntimeService.scala | 12 +-
.../texera/web/service/ExecutionStatsService.scala | 33 +-
.../service/ExecutionsMetadataPersistService.scala | 2 +-
.../service/FriesReconfigurationAlgorithm.scala | 8 +-
.../texera/web/service/ResultExportService.scala | 14 +-
.../texera/web/service/WorkflowEmailNotifier.scala | 4 +-
.../web/service/WorkflowExecutionService.scala | 16 +-
.../texera/web/service/WorkflowService.scala | 27 +-
.../storage/ExecutionReconfigurationStore.scala | 6 +-
.../texera/web/storage/ExecutionStateStore.scala | 6 +-
.../org/apache/texera/web/storage/StateStore.scala | 2 +-
.../texera/web/storage/WorkflowStateStore.scala | 2 +-
.../org/apache/texera/workflow/LogicalLink.scala | 4 +-
.../org/apache/texera/workflow/LogicalPlan.scala | 8 +-
.../apache/texera/workflow/WorkflowCompiler.scala | 6 +-
.../GitVersionControlLocalFileStorageSpec.java | 4 +-
.../breakpoint/ExceptionBreakpointSpec.scala | 2 +-
.../architecture/control/TrivialControlSpec.scala | 22 +-
.../architecture/control/utils/ChainHandler.scala | 6 +-
.../control/utils/CollectHandler.scala | 6 +-
.../architecture/control/utils/ErrorHandler.scala | 6 +-
.../control/utils/MultiCallHandler.scala | 8 +-
.../architecture/control/utils/NestedHandler.scala | 6 +-
.../control/utils/PingPongHandler.scala | 6 +-
.../control/utils/RecursionHandler.scala | 6 +-
.../utils/TesterAsyncRPCHandlerInitializer.scala | 12 +-
.../control/utils/TrivialControlTester.scala | 24 +-
.../architecture/controller/ControllerSpec.scala | 4 +-
.../messaginglayer/NetworkInputGatewaySpec.scala | 8 +-
.../messaginglayer/OutputManagerSpec.scala | 12 +-
.../messaginglayer/RangeBasedShuffleSpec.scala | 10 +-
.../pythonworker/PythonWorkflowWorkerSpec.scala | 30 +-
.../CostBasedScheduleGeneratorSpec.scala | 10 +-
.../scheduling/DefaultCostEstimatorSpec.scala | 30 +-
.../ExpansionGreedyScheduleGeneratorSpec.scala | 19 +-
.../engine/architecture/worker/DPThreadSpec.scala | 31 +-
.../architecture/worker/DataProcessorSpec.scala | 34 +--
.../engine/architecture/worker/WorkerSpec.scala | 40 +--
.../engine/e2e/BatchSizePropagationSpec.scala | 18 +-
.../amber/engine/e2e/DataProcessingSpec.scala | 30 +-
.../{ => texera}/amber/engine/e2e/PauseSpec.scala | 23 +-
.../{ => texera}/amber/engine/e2e/TestUtils.scala | 10 +-
.../engine/faulttolerance/CheckpointSpec.scala | 25 +-
.../amber/engine/faulttolerance/LoggingSpec.scala | 28 +-
.../amber/engine/faulttolerance/ReplaySpec.scala | 25 +-
.../workflow/WorkflowVersionResourceSpec.scala | 2 +-
.../web/service/ExecutionConsoleServiceSpec.scala | 7 +-
.../web/service/ExecutionResultServiceSpec.scala | 2 +-
.../storage/ReadonlyLocalFileDocumentSpec.scala | 6 +-
bin/single-node/.env | 11 +-
bin/single-node/docker-compose.yml | 87 +++---
bin/single-node/nginx.conf | 12 +
common/config/src/main/resources/cluster.conf | 2 +-
.../{ => texera}/amber/config/AkkaConfig.scala | 2 +-
.../amber/config/ApplicationConfig.scala | 2 +-
.../amber/config/EnvironmentalVariable.scala | 2 +-
.../{ => texera}/amber/config/StorageConfig.scala | 4 +-
.../{ => texera}/amber/config/UdfConfig.scala | 2 +-
.../{ => texera}/amber/util/ConfigParserUtil.scala | 2 +-
.../apache/{ => texera}/amber/core/executor.proto | 4 +-
.../{ => texera}/amber/core/virtualidentity.proto | 2 +-
.../apache/{ => texera}/amber/core/workflow.proto | 4 +-
.../amber/core/workflowruntimestate.proto | 2 +-
.../amber/core/WorkflowRuntimeException.scala | 4 +-
.../amber/core/executor/ExecFactory.scala | 2 +-
.../core/executor/JavaRuntimeCompilation.scala | 4 +-
.../amber/core/executor/OperatorExecutor.scala | 8 +-
.../core/executor/SourceOperatorExecutor.scala | 6 +-
.../{ => texera}/amber/core/state/State.scala | 4 +-
.../amber/core/storage/DocumentFactory.scala | 20 +-
.../amber/core/storage/FileResolver.scala | 2 +-
.../core/storage/IcebergCatalogInstance.scala | 6 +-
.../amber/core/storage/VFSURIFactory.scala | 14 +-
.../core/storage/model/BufferedItemWriter.scala | 2 +-
.../core/storage/model/DatasetFileDocument.scala | 10 +-
.../amber/core/storage/model/OnDataset.scala | 2 +-
.../storage/model/ReadonlyLocalFileDocument.scala | 2 +-
.../storage/model/ReadonlyVirtualDocument.scala | 2 +-
.../core/storage/model/VirtualCollection.scala | 2 +-
.../amber/core/storage/model/VirtualDocument.scala | 2 +-
.../amber/core/storage/result/ResultSchema.scala | 4 +-
.../core/storage/result/WorkflowResultStore.scala | 4 +-
.../storage/result/iceberg/IcebergDocument.scala | 10 +-
.../result/iceberg/IcebergTableWriter.scala | 8 +-
.../core/storage/result/iceberg/OnIceberg.scala | 4 +-
.../core/storage/util/LakeFSStorageClient.scala | 4 +-
.../amber/core/storage/util/StorageUtil.scala | 2 +-
.../dataset/GitVersionControlLocalFileStorage.java | 2 +-
.../storage/util/dataset/JGitVersionControl.java | 2 +-
.../storage/util/dataset/PhysicalFileNode.java | 2 +-
.../{ => texera}/amber/core/tuple/Attribute.java | 2 +-
.../amber/core/tuple/AttributeType.java | 2 +-
.../amber/core/tuple/AttributeTypeUtils.scala | 2 +-
.../{ => texera}/amber/core/tuple/BigObject.java | 4 +-
.../{ => texera}/amber/core/tuple/Schema.scala | 2 +-
.../{ => texera}/amber/core/tuple/Tuple.scala | 4 +-
.../{ => texera}/amber/core/tuple/TupleLike.scala | 4 +-
.../{ => texera}/amber/core/tuple/TupleUtils.scala | 8 +-
.../amber/core/workflow/LocationPreference.scala | 2 +-
.../amber/core/workflow/PartitionInfo.scala | 2 +-
.../amber/core/workflow/PhysicalOp.scala | 8 +-
.../amber/core/workflow/PhysicalPlan.scala | 8 +-
.../amber/core/workflow/WorkflowContext.scala | 6 +-
.../amber/core/workflow/WorkflowSettings.scala | 2 +-
.../{ => texera}/amber/util/ArrowUtils.scala | 6 +-
.../{ => texera}/amber/util/IcebergUtil.scala | 6 +-
.../apache/{ => texera}/amber/util/JSONUtils.scala | 6 +-
.../amber/util/VirtualIdentityUtils.scala | 4 +-
.../amber/util/serde/GlobalPortIdentitySerde.scala | 6 +-
.../util/serde/PortIdentityKeyDeserializer.scala | 4 +-
.../util/serde/PortIdentityKeySerializer.scala | 6 +-
.../texera/service/util/BigObjectInputStream.scala | 2 +-
.../service/util/BigObjectOutputStream.scala | 2 +-
.../texera/service/util/S3StorageClient.scala | 2 +-
.../core/storage/model/VirtualDocumentSpec.scala | 2 +-
.../amber/core/tuple/AttributeTypeUtilsSpec.scala | 6 +-
.../{ => texera}/amber/core/tuple/SchemaSpec.scala | 2 +-
.../{ => texera}/amber/core/tuple/TupleSpec.scala | 4 +-
.../amber/storage/FileResolverSpec.scala | 4 +-
.../IcebergDocumentConsoleMessagesSpec.scala | 12 +-
.../result/iceberg/IcebergDocumentSpec.scala | 14 +-
.../result/iceberg/IcebergTableStatsSpec.scala | 14 +-
.../{ => texera}/amber/util/IcebergUtilSpec.scala | 6 +-
.../service/util/BigObjectInputStreamSpec.scala | 2 +-
.../texera/service/util/BigObjectManagerSpec.scala | 2 +-
.../service/util/BigObjectOutputStreamSpec.scala | 2 +-
.../texera/service/util/S3StorageTestBase.scala | 2 +-
.../amber/operator/DummyProperties.scala | 2 +-
.../{ => texera}/amber/operator/LogicalOp.scala | 203 ++++++------
.../amber/operator/PortDescriptor.scala | 4 +-
.../amber/operator/PythonOperatorDescriptor.scala | 10 +-
.../amber/operator/SpecialPhysicalOpFactory.scala | 12 +-
.../amber/operator/TestOperators.scala | 20 +-
.../amber/operator/aggregate/AggregateOpDesc.scala | 25 +-
.../amber/operator/aggregate/AggregateOpExec.scala | 8 +-
.../operator/aggregate/AggregationFunction.java | 2 +-
.../operator/aggregate/AggregationOperation.scala | 6 +-
.../aggregate/DistributedAggregation.scala | 4 +-
.../cartesianProduct/CartesianProductOpDesc.scala | 18 +-
.../cartesianProduct/CartesianProductOpExec.scala | 8 +-
.../dictionary/DictionaryMatcherOpDesc.scala | 25 +-
.../dictionary/DictionaryMatcherOpExec.scala | 8 +-
.../amber/operator/dictionary/MatchingType.java | 2 +-
.../operator/difference/DifferenceOpDesc.scala | 14 +-
.../operator/difference/DifferenceOpExec.scala | 6 +-
.../amber/operator/distinct/DistinctOpDesc.scala | 14 +-
.../amber/operator/distinct/DistinctOpExec.scala | 6 +-
.../amber/operator/dummy/DummyOpDesc.scala | 8 +-
.../amber/operator/filter/ComparisonType.java | 2 +-
.../amber/operator/filter/FilterOpDesc.scala | 8 +-
.../amber/operator/filter/FilterOpExec.scala | 6 +-
.../amber/operator/filter/FilterPredicate.java | 16 +-
.../operator/filter/SpecializedFilterOpDesc.scala | 14 +-
.../operator/filter/SpecializedFilterOpExec.scala | 6 +-
.../amber/operator/flatmap/FlatMapOpDesc.scala | 4 +-
.../amber/operator/flatmap/FlatMapOpExec.scala | 6 +-
.../operator/hashJoin/HashJoinBuildOpExec.scala | 8 +-
.../amber/operator/hashJoin/HashJoinOpDesc.scala | 24 +-
.../operator/hashJoin/HashJoinProbeOpExec.scala | 10 +-
.../amber/operator/hashJoin/JoinType.java | 2 +-
.../HuggingFaceIrisLogisticRegressionOpDesc.scala | 12 +-
.../HuggingFaceSentimentAnalysisOpDesc.scala | 12 +-
.../HuggingFaceSpamSMSDetectionOpDesc.scala | 12 +-
.../HuggingFaceTextSummarizationOpDesc.scala | 12 +-
.../amber/operator/ifStatement/IfOpDesc.scala | 16 +-
.../amber/operator/ifStatement/IfOpExec.scala | 12 +-
.../amber/operator/intersect/IntersectOpDesc.scala | 14 +-
.../amber/operator/intersect/IntersectOpExec.scala | 6 +-
.../operator/intervalJoin/IntervalJoinOpDesc.scala | 20 +-
.../operator/intervalJoin/IntervalJoinOpExec.scala | 12 +-
.../operator/intervalJoin/TimeIntervalType.java | 2 +-
.../keywordSearch/KeywordSearchOpDesc.scala | 18 +-
.../keywordSearch/KeywordSearchOpExec.scala | 8 +-
.../amber/operator/limit/LimitOpDesc.scala | 16 +-
.../amber/operator/limit/LimitOpExec.scala | 8 +-
.../Scorer/MachineLearningScorerOpDesc.scala | 12 +-
.../Scorer/classificationMetricsFnc.java | 2 +-
.../Scorer/regressionMetricsFnc.java | 2 +-
...SklearnAdvancedKNNClassifierTrainerOpDesc.scala | 4 +-
.../KNNTrainer/SklearnAdvancedKNNParameters.java | 4 +-
.../SklearnAdvancedKNNRegressorTrainerOpDesc.scala | 4 +-
.../SVCTrainer/SklearnAdvancedSVCParameters.java | 4 +-
.../SklearnAdvancedSVCTrainerOpDesc.scala | 4 +-
.../SVRTrainer/SklearnAdvancedSVRParameters.java | 4 +-
.../SklearnAdvancedSVRTrainerOpDesc.scala | 4 +-
.../sklearnAdvanced/base/HyperParameters.java | 6 +-
.../base/SklearnAdvancedBaseDesc.scala | 12 +-
.../amber/operator/map/MapOpDesc.scala | 8 +-
.../amber/operator/map/MapOpExec.scala | 6 +-
.../amber/operator/metadata/OPVersion.java | 2 +-
.../operator/metadata/OperatorGroupConstants.scala | 2 +-
.../metadata/OperatorMetadataGenerator.scala | 10 +-
.../operator/metadata/PropertyNameConstants.scala | 2 +-
.../annotations/AutofillAttributeName.java | 2 +-
.../annotations/AutofillAttributeNameLambda.java | 2 +-
.../annotations/AutofillAttributeNameList.java | 2 +-
.../annotations/AutofillAttributeNameOnPort1.java | 2 +-
.../metadata/annotations/BatchByColumn.java | 2 +-
.../annotations/CommonOpDescAnnotation.java | 2 +-
.../metadata/annotations/EnablePresets.java | 2 +-
.../metadata/annotations/HideAnnotation.java | 2 +-
.../operator/metadata/annotations/UIWidget.java | 2 +-
.../amber/operator/projection/AttributeUnit.java | 4 +-
.../operator/projection/ProjectionOpDesc.scala | 20 +-
.../operator/projection/ProjectionOpExec.scala | 8 +-
.../randomksampling/RandomKSamplingOpDesc.scala | 16 +-
.../randomksampling/RandomKSamplingOpExec.scala | 6 +-
.../amber/operator/regex/RegexOpDesc.scala | 18 +-
.../amber/operator/regex/RegexOpExec.scala | 8 +-
.../ReservoirSamplingOpDesc.scala | 16 +-
.../ReservoirSamplingOpExec.scala | 10 +-
.../amber/operator/sink/ProgressiveUtils.scala | 4 +-
.../sklearn/SklearnAdaptiveBoostingOpDesc.scala | 2 +-
.../operator/sklearn/SklearnBaggingOpDesc.scala | 2 +-
.../sklearn/SklearnBernoulliNaiveBayesOpDesc.scala | 2 +-
.../operator/sklearn/SklearnClassifierOpDesc.scala | 12 +-
.../SklearnComplementNaiveBayesOpDesc.scala | 2 +-
.../sklearn/SklearnDecisionTreeOpDesc.scala | 2 +-
.../sklearn/SklearnDummyClassifierOpDesc.scala | 2 +-
.../operator/sklearn/SklearnExtraTreeOpDesc.scala | 2 +-
.../operator/sklearn/SklearnExtraTreesOpDesc.scala | 2 +-
.../sklearn/SklearnGaussianNaiveBayesOpDesc.scala | 2 +-
.../sklearn/SklearnGradientBoostingOpDesc.scala | 2 +-
.../amber/operator/sklearn/SklearnKNNOpDesc.scala | 2 +-
.../sklearn/SklearnLinearRegressionOpDesc.scala | 12 +-
.../operator/sklearn/SklearnLinearSVMOpDesc.scala | 2 +-
.../SklearnLogisticRegressionCVOpDesc.scala | 2 +-
.../sklearn/SklearnLogisticRegressionOpDesc.scala | 2 +-
.../SklearnMultiLayerPerceptronOpDesc.scala | 2 +-
.../SklearnMultinomialNaiveBayesOpDesc.scala | 2 +-
.../sklearn/SklearnNearestCentroidOpDesc.scala | 2 +-
.../sklearn/SklearnPassiveAggressiveOpDesc.scala | 2 +-
.../operator/sklearn/SklearnPerceptronOpDesc.scala | 2 +-
.../operator/sklearn/SklearnPredictionOpDesc.scala | 12 +-
.../SklearnProbabilityCalibrationOpDesc.scala | 2 +-
.../sklearn/SklearnRandomForestOpDesc.scala | 2 +-
.../operator/sklearn/SklearnRidgeCVOpDesc.scala | 2 +-
.../operator/sklearn/SklearnRidgeOpDesc.scala | 2 +-
.../amber/operator/sklearn/SklearnSDGOpDesc.scala | 2 +-
.../amber/operator/sklearn/SklearnSVMOpDesc.scala | 2 +-
.../SklearnTrainingAdaptiveBoostingOpDesc.scala | 2 +-
.../training/SklearnTrainingBaggingOpDesc.scala | 2 +-
.../SklearnTrainingBernoulliNaiveBayesOpDesc.scala | 2 +-
...SklearnTrainingComplementNaiveBayesOpDesc.scala | 2 +-
.../SklearnTrainingDecisionTreeOpDesc.scala | 2 +-
.../SklearnTrainingDummyClassifierOpDesc.scala | 2 +-
.../training/SklearnTrainingExtraTreeOpDesc.scala | 2 +-
.../training/SklearnTrainingExtraTreesOpDesc.scala | 2 +-
.../SklearnTrainingGaussianNaiveBayesOpDesc.scala | 2 +-
.../SklearnTrainingGradientBoostingOpDesc.scala | 2 +-
.../training/SklearnTrainingKNNOpDesc.scala | 2 +-
.../SklearnTrainingLinearRegressionOpDesc.scala | 2 +-
.../training/SklearnTrainingLinearSVMOpDesc.scala | 2 +-
...SklearnTrainingLogisticRegressionCVOpDesc.scala | 2 +-
.../SklearnTrainingLogisticRegressionOpDesc.scala | 2 +-
...SklearnTrainingMultiLayerPerceptronOpDesc.scala | 2 +-
...klearnTrainingMultinomialNaiveBayesOpDesc.scala | 2 +-
.../SklearnTrainingNearestCentroidOpDesc.scala | 2 +-
.../sklearn/training/SklearnTrainingOpDesc.scala | 12 +-
.../SklearnTrainingPassiveAggressiveOpDesc.scala | 2 +-
.../training/SklearnTrainingPerceptronOpDesc.scala | 2 +-
...learnTrainingProbabilityCalibrationOpDesc.scala | 2 +-
.../SklearnTrainingRandomForestOpDesc.scala | 2 +-
.../training/SklearnTrainingRidgeCVOpDesc.scala | 2 +-
.../training/SklearnTrainingRidgeOpDesc.scala | 2 +-
.../training/SklearnTrainingSDGOpDesc.scala | 2 +-
.../training/SklearnTrainingSVMOpDesc.scala | 2 +-
.../amber/operator/sleep/SleepOpDesc.scala | 16 +-
.../amber/operator/sleep/SleepOpExec.scala | 8 +-
.../amber/operator/sort/SortCriteriaUnit.java | 6 +-
.../amber/operator/sort/SortOpDesc.scala | 10 +-
.../amber/operator/sort/SortPreference.java | 2 +-
.../operator/sort/StableMergeSortOpDesc.scala | 16 +-
.../operator/sort/StableMergeSortOpExec.scala | 8 +-
.../sortPartitions/SortPartitionsOpDesc.scala | 18 +-
.../sortPartitions/SortPartitionsOpExec.scala | 8 +-
.../amber/operator/source/BufferedBlockReader.java | 2 +-
.../source/PythonSourceOperatorDescriptor.scala | 4 +-
.../operator/source/SourceOperatorDescriptor.scala | 6 +-
.../apis/reddit/RedditSearchSourceOpDesc.scala | 10 +-
.../apis/reddit/RedditSourceOperatorFunction.java | 2 +-
.../source/apis/twitter/TwitterSourceOpDesc.scala | 8 +-
.../source/apis/twitter/TwitterSourceOpExec.scala | 6 +-
.../v2/TwitterFullArchiveSearchSourceOpDesc.scala | 18 +-
.../v2/TwitterFullArchiveSearchSourceOpExec.scala | 10 +-
.../twitter/v2/TwitterSearchSourceOpDesc.scala | 18 +-
.../twitter/v2/TwitterSearchSourceOpExec.scala | 10 +-
.../source/apis/twitter/v2/TwitterUtils.scala | 4 +-
.../operator/source/cache/CacheSourceOpExec.scala | 10 +-
.../operator/source/fetcher/DecodingMethod.java | 2 +-
.../operator/source/fetcher/RandomUserAgent.java | 2 +-
.../operator/source/fetcher/URLFetchUtil.scala | 2 +-
.../operator/source/fetcher/URLFetcherOpDesc.scala | 18 +-
.../operator/source/fetcher/URLFetcherOpExec.scala | 10 +-
.../operator/source/scan/AutoClosingIterator.scala | 2 +-
.../operator/source/scan/FileAttributeType.java | 4 +-
.../operator/source/scan/FileDecodingMethod.java | 2 +-
.../source/scan/FileScanSourceOpDesc.scala | 18 +-
.../source/scan/FileScanSourceOpExec.scala | 12 +-
.../operator/source/scan/ScanSourceOpDesc.scala | 12 +-
.../source/scan/arrow/ArrowSourceOpDesc.scala | 20 +-
.../source/scan/arrow/ArrowSourceOpExec.scala | 12 +-
.../source/scan/csv/CSVScanSourceOpDesc.scala | 20 +-
.../source/scan/csv/CSVScanSourceOpExec.scala | 10 +-
.../scan/csv/ParallelCSVScanSourceOpDesc.scala | 20 +-
.../scan/csv/ParallelCSVScanSourceOpExec.scala | 12 +-
.../scan/csvOld/CSVOldScanSourceOpDesc.scala | 20 +-
.../scan/csvOld/CSVOldScanSourceOpExec.scala | 10 +-
.../source/scan/json/JSONLScanSourceOpDesc.scala | 20 +-
.../source/scan/json/JSONLScanSourceOpExec.scala | 14 +-
.../amber/operator/source/scan/json/JSONUtil.scala | 2 +-
.../source/scan/text/TextInputSourceOpDesc.scala | 20 +-
.../source/scan/text/TextInputSourceOpExec.scala | 12 +-
.../source/scan/text/TextSourceOpDesc.scala | 6 +-
.../operator/source/sql/SQLSourceOpDesc.scala | 8 +-
.../operator/source/sql/SQLSourceOpExec.scala | 10 +-
.../source/sql/asterixdb/AsterixDBConnUtil.scala | 2 +-
.../sql/asterixdb/AsterixDBSourceOpDesc.scala | 24 +-
.../sql/asterixdb/AsterixDBSourceOpExec.scala | 12 +-
.../operator/source/sql/mysql/MySQLConnUtil.scala | 2 +-
.../source/sql/mysql/MySQLSourceOpDesc.scala | 18 +-
.../source/sql/mysql/MySQLSourceOpExec.scala | 10 +-
.../source/sql/postgresql/PostgreSQLConnUtil.scala | 2 +-
.../sql/postgresql/PostgreSQLSourceOpDesc.scala | 20 +-
.../sql/postgresql/PostgreSQLSourceOpExec.scala | 10 +-
.../amber/operator/split/SplitOpDesc.scala | 18 +-
.../amber/operator/split/SplitOpExec.scala | 10 +-
.../substringSearch/SubstringSearchOpDesc.scala | 18 +-
.../substringSearch/SubstringSearchOpExec.scala | 8 +-
.../SymmetricDifferenceOpDesc.scala | 14 +-
.../SymmetricDifferenceOpExec.scala | 6 +-
.../operator/timeSeriesPlot/TimeSeriesPlot.scala | 14 +-
.../operator/typecasting/TypeCastingOpDesc.scala | 18 +-
.../operator/typecasting/TypeCastingOpExec.scala | 8 +-
.../operator/typecasting/TypeCastingUnit.java | 6 +-
.../amber/operator/udf/java/JavaUDFOpDesc.scala | 20 +-
.../python/DualInputPortsPythonUDFOpDescV2.scala | 14 +-
.../operator/udf/python/LambdaAttributeUnit.java | 8 +-
.../udf/python/PythonLambdaFunctionOpDesc.scala | 10 +-
.../udf/python/PythonTableReducerOpDesc.scala | 10 +-
.../operator/udf/python/PythonUDFOpDescV2.scala | 14 +-
.../python/source/PythonUDFSourceOpDescV2.scala | 14 +-
.../amber/operator/udf/r/RUDFOpDesc.scala | 14 +-
.../amber/operator/udf/r/RUDFSourceOpDesc.scala | 14 +-
.../amber/operator/union/UnionOpDesc.scala | 14 +-
.../amber/operator/union/UnionOpExec.scala | 6 +-
.../operator/unneststring/UnnestStringOpDesc.scala | 25 +-
.../operator/unneststring/UnnestStringOpExec.scala | 8 +-
.../operator/util/OperatorDescriptorUtils.scala | 2 +-
.../visualization/DotPlot/DotPlotOpDesc.scala | 14 +-
.../IcicleChart/IcicleChartOpDesc.scala | 16 +-
.../operator/visualization/ImageUtility.scala | 2 +-
.../ImageViz/ImageVisualizerOpDesc.scala | 14 +-
.../ScatterMatrixChartOpDesc.scala | 14 +-
.../visualization/barChart/BarChartOpDesc.scala | 14 +-
.../boxViolinPlot/BoxViolinPlotOpDesc.scala | 14 +-
.../BoxViolinPlotQuartileFunction.java | 2 +-
.../bubbleChart/BubbleChartOpDesc.scala | 14 +-
.../bulletChart/BulletChartOpDesc.scala | 14 +-
.../bulletChart/BulletChartStepDefinition.scala | 2 +-
.../candlestickChart/CandlestickChartOpDesc.scala | 14 +-
.../choroplethMap/ChoroplethMapOpDesc.scala | 14 +-
.../continuousErrorBands/BandConfig.scala | 6 +-
.../ContinuousErrorBandsOpDesc.scala | 12 +-
.../contourPlot/ContourPlotColoringFunction.java | 2 +-
.../contourPlot/ContourPlotOpDesc.scala | 14 +-
.../dendrogram/DendrogramOpDesc.scala | 14 +-
.../dumbbellPlot/DumbbellDotConfig.scala | 4 +-
.../dumbbellPlot/DumbbellPlotOpDesc.scala | 14 +-
.../FigureFactoryTableConfig.scala | 4 +-
.../FigureFactoryTableOpDesc.scala | 12 +-
.../filledAreaPlot/FilledAreaPlotOpDesc.scala | 14 +-
.../funnelPlot/FunnelPlotOpDesc.scala | 14 +-
.../ganttChart/GanttChartOpDesc.scala | 14 +-
.../gaugeChart/GaugeChartOpDesc.scala | 14 +-
.../visualization/gaugeChart/GaugeChartSteps.scala | 2 +-
.../visualization/heatMap/HeatMapOpDesc.scala | 14 +-
.../hierarchychart/HierarchyChartOpDesc.scala | 14 +-
.../hierarchychart/HierarchyChartType.java | 2 +-
.../hierarchychart/HierarchySection.scala | 4 +-
.../histogram/HistogramChartOpDesc.scala | 14 +-
.../histogram2d/Histogram2DOpDesc.scala | 14 +-
.../histogram2d/NormalizationType.java | 2 +-
.../visualization/htmlviz/HtmlVizOpDesc.scala | 27 +-
.../visualization/htmlviz/HtmlVizOpExec.scala | 8 +-
.../visualization/lineChart/LineChartOpDesc.scala | 12 +-
.../visualization/lineChart/LineConfig.scala | 4 +-
.../operator/visualization/lineChart/LineMode.java | 2 +-
.../nestedTable/NestedTableConfig.scala | 4 +-
.../nestedTable/NestedTableOpDesc.scala | 12 +-
.../networkGraph/NetworkGraphOpDesc.scala | 14 +-
.../visualization/pieChart/PieChartOpDesc.scala | 14 +-
.../quiverPlot/QuiverPlotOpDesc.scala | 14 +-
.../RangeSliderHandleDuplicateFunction.java | 2 +-
.../rangeSlider/RangeSliderOpDesc.scala | 14 +-
.../sankeyDiagram/SankeyDiagramOpDesc.scala | 14 +-
.../scatter3DChart/Scatter3dChartOpDesc.scala | 14 +-
.../scatterplot/ScatterplotOpDesc.scala | 14 +-
.../stripChart/StripChartOpDesc.scala | 14 +-
.../visualization/tablesChart/TablesConfig.scala | 4 +-
.../tablesChart/TablesPlotOpDesc.scala | 12 +-
.../ternaryPlot/TernaryPlotOpDesc.scala | 14 +-
.../visualization/treeplot/TreeplotOpDesc.scala | 14 +-
.../visualization/urlviz/UrlVizOpDesc.scala | 27 +-
.../visualization/urlviz/UrlVizOpExec.scala | 8 +-
.../volcanoPlot/VolcanoPlotOpDesc.scala | 14 +-
.../waterfallChart/WaterfallChartOpDesc.scala | 14 +-
.../visualization/wordCloud/WordCloudOpDesc.scala | 16 +-
.../amber/util/ObjectMapperUtils.scala | 4 +-
.../amber/operator/aggregate/AggregateOpSpec.scala | 6 +-
.../CartesianProductOpExecSpec.scala | 6 +-
.../dictionary/DictionaryMatcherOpExecSpec.scala | 8 +-
.../operator/difference/DifferenceOpExecSpec.scala | 4 +-
.../operator/distinct/DistinctOpExecSpec.scala | 4 +-
.../filter/SpecializedFilterOpExecSpec.scala | 6 +-
.../amber/operator/hashJoin/HashJoinOpSpec.scala | 10 +-
.../operator/intersect/IntersectOpExecSpec.scala | 8 +-
.../operator/intervalJoin/IntervalOpExecSpec.scala | 10 +-
.../keywordSearch/KeywordSearchOpExecSpec.scala | 6 +-
.../operator/projection/ProjectionOpDescSpec.scala | 6 +-
.../operator/projection/ProjectionOpExecSpec.scala | 6 +-
.../operator/sort/StableMergeSortOpExecSpec.scala | 6 +-
.../sortPartitions/SortPartitionsOpExecSpec.scala | 6 +-
.../source/fetcher/URLFetcherOpExecSpec.scala | 6 +-
.../source/scan/FileScanSourceOpExecSpec.scala | 6 +-
.../source/scan/csv/CSVScanSourceOpDescSpec.scala | 13 +-
.../scan/text/FileScanSourceOpDescSpec.scala | 12 +-
.../scan/text/TextInputSourceOpDescSpec.scala | 10 +-
.../SymmetricDifferenceOpExecSpec.scala | 4 +-
.../typecasting/TypeCastingOpExecSpec.scala | 6 +-
.../python/PythonLambdaFunctionOpDescSpec.scala | 6 +-
.../unneststring/UnnestStringOpExecSpec.scala | 8 +-
.../visualization/DotPlot/DotPlotOpDescSpec.scala | 2 +-
.../ImageViz/ImageVisualizerOpDescSpec.scala | 2 +-
.../barChart/BarChartOpDescSpec.scala | 2 +-
.../bubbleChart/BubbleChartOpDescSpec.scala | 2 +-
.../filledAreaPlot/FilledAreaPlotOpDescSpec.scala | 2 +-
.../ganttChart/GanttChartOpDescSpec.scala | 2 +-
.../hierarchychart/HierarchyChartOpDescSpec.scala | 2 +-
.../visualization/htmlviz/HtmlVizOpExecSpec.scala | 8 +-
.../pieChart/PieChartOpDescSpec.scala | 2 +-
.../scatterplot/ScatterPlotOpDescSpec.scala | 2 +-
.../{ => texera}/amber/util/ArrowUtilsSpec.scala | 6 +-
.../service/ComputingUnitManagingService.scala | 2 +-
.../resource/ComputingUnitManagingResource.scala | 2 +-
.../org/apache/texera/service/ConfigService.scala | 2 +-
.../org/apache/texera/service/FileService.scala | 4 +-
.../texera/service/resource/DatasetResource.scala | 8 +-
.../service/type/dataset/DatasetFileNode.scala | 2 +-
.../org/apache/texera/service/MockLakeFS.scala | 2 +-
.../service/resource/DatasetResourceSpec.scala | 2 +-
frontend/src/app/common/type/physical-plan.ts | 4 +-
.../amber/engine/common/virtualidentity.ts | 2 +-
.../{ => texera}/amber/engine/common/workflow.ts | 2 +-
.../src/app/common/util/port-identity-serde.ts | 2 +-
.../amber/compiler/WorkflowCompiler.scala | 21 +-
.../amber/compiler/model/LogicalLink.scala | 6 +-
.../amber/compiler/model/LogicalPlan.scala | 12 +-
.../amber/compiler/model/LogicalPlanPojo.scala | 4 +-
.../texera/service/WorkflowCompilingService.scala | 4 +-
.../resource/WorkflowCompilationResource.scala | 14 +-
.../resource/WorkflowCompilationResourceSpec.scala | 18 +-
728 files changed, 4094 insertions(+), 3072 deletions(-)
create mode 100644 .github/release/vote-email-template.md
create mode 100644 .github/workflows/create-release-candidate.yml
create mode 100644 .run/AccessControlService.run.xml
create mode 100644 .run/ComputingUnitManagingService.run.xml
create mode 100644 .run/ComputingUnitMaster.run.xml
create mode 100644 .run/ComputingUnitWorker.run.xml
create mode 100644 .run/ConfigService.run.xml
create mode 100644 .run/FileService.run.xml
create mode 100644 .run/TexeraWebApplication.run.xml
create mode 100644 .run/WorkflowCompilingService.run.xml
create mode 100644 .run/frontend.run.xml
create mode 100644 .run/texera micro services.run.xml
create mode 100644 .run/texera-lakefs.run.xml
rename amber/src/main/protobuf/org/apache/{ =>
texera}/amber/engine/architecture/rpc/controlcommands.proto (90%)
rename amber/src/main/protobuf/org/apache/{ =>
texera}/amber/engine/architecture/rpc/controllerservice.proto (90%)
rename amber/src/main/protobuf/org/apache/{ =>
texera}/amber/engine/architecture/rpc/controlreturns.proto (93%)
rename amber/src/main/protobuf/org/apache/{ =>
texera}/amber/engine/architecture/rpc/testerservice.proto (87%)
rename amber/src/main/protobuf/org/apache/{ =>
texera}/amber/engine/architecture/rpc/workerservice.proto (91%)
rename amber/src/main/protobuf/org/apache/{ =>
texera}/amber/engine/architecture/sendsemantics/partitionings.proto (93%)
rename amber/src/main/protobuf/org/apache/{ =>
texera}/amber/engine/architecture/worker/statistics.proto (93%)
rename amber/src/main/protobuf/org/apache/{ =>
texera}/amber/engine/common/actormessage.proto (96%)
rename amber/src/main/protobuf/org/apache/{ =>
texera}/amber/engine/common/ambermessage.proto (84%)
rename amber/src/main/protobuf/org/apache/{ =>
texera}/amber/engine/common/executionruntimestate.proto (86%)
rename amber/src/main/python/proto/org/apache/{ => texera}/amber/__init__.py
(100%)
rename amber/src/main/python/proto/org/apache/{ =>
texera}/amber/core/__init__.py (100%)
rename amber/src/main/python/proto/org/apache/{ =>
texera}/amber/engine/__init__.py (100%)
rename amber/src/main/python/proto/org/apache/{ =>
texera}/amber/engine/architecture/__init__.py (100%)
rename amber/src/main/python/proto/org/apache/{ =>
texera}/amber/engine/architecture/rpc/__init__.py (87%)
rename amber/src/main/python/proto/org/apache/{ =>
texera}/amber/engine/architecture/sendsemantics/__init__.py (100%)
rename amber/src/main/python/proto/org/apache/{ =>
texera}/amber/engine/architecture/worker/__init__.py (100%)
rename amber/src/main/python/proto/org/apache/{ =>
texera}/amber/engine/common/__init__.py (100%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/clustering/ClusterListener.scala (88%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/clustering/SingleNodeListener.scala (89%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/common/AkkaActorRefMappingService.scala (91%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/common/AkkaActorService.scala (92%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/common/AkkaMessageTransferService.scala (91%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/common/AmberProcessor.scala (74%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/common/ExecutorDeployment.scala (79%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/common/ProcessingStepCursor.scala (86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/common/WorkflowActor.scala (92%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/ClientEvent.scala (78%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/Controller.scala (88%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/ControllerAsyncRPCHandlerInitializer.scala
(75%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/ControllerProcessor.scala (79%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/ControllerTimerService.scala (78%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/GlobalReplayManager.scala (91%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/Workflow.scala (87%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/WorkflowScheduler.scala (86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/execution/ChannelExecution.scala
(92%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/execution/ExecutionUtils.scala
(92%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/execution/LinkExecution.scala (89%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/execution/OperatorExecution.scala
(84%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/execution/RegionExecution.scala
(90%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/execution/WorkerPortExecution.scala
(92%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/execution/WorkflowExecution.scala
(90%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/ConsoleMessageHandler.scala
(78%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/DebugCommandHandler.scala
(74%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/EmbeddedControlMessageHandler.scala
(86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/EvaluatePythonExpressionHandler.scala
(81%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/LinkWorkersHandler.scala
(86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/PauseHandler.scala
(86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/PortCompletedHandler.scala
(86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/QueryWorkerStatisticsHandler.scala
(88%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/ResumeHandler.scala
(84%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/RetrieveWorkflowStateHandler.scala
(75%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/RetryWorkflowHandler.scala
(79%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/StartWorkflowHandler.scala
(76%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/TakeGlobalCheckpointHandler.scala
(81%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/WorkerExecutionCompletedHandler.scala
(86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/promisehandlers/WorkerStateUpdatedHandler.scala
(83%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/deploysemantics/AddressInfo.scala (93%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/deploysemantics/deploystrategy/DeployStrategy.scala
(92%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/deploysemantics/deploystrategy/OneOnEach.scala
(93%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/deploysemantics/deploystrategy/RandomDeployment.scala
(93%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/deploysemantics/deploystrategy/RoundRobinDeployment.scala
(93%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/deploysemantics/layer/WorkerExecution.scala
(88%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/logreplay/AsyncReplayLogWriter.scala (89%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/logreplay/EmptyReplayLogger.scala (82%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/logreplay/OrderEnforcer.scala (87%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/logreplay/ReplayLogGenerator.scala (85%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/logreplay/ReplayLogManager.scala (86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/logreplay/ReplayLogger.scala (81%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/logreplay/ReplayLoggerImpl.scala (89%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/logreplay/ReplayOrderEnforcer.scala (95%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/AmberFIFOChannel.scala (88%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/CongestionControl.scala (95%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/DeadLetterMonitorActor.scala
(89%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/FlowControl.scala (94%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/InputGateway.scala (85%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/InputManager.scala (88%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/NetworkInputGateway.scala (90%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/NetworkOutputGateway.scala
(90%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/OrderingEnforcer.scala (95%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/OutputManager.scala (92%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/WorkerPort.scala (84%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/WorkerTimerService.scala (77%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/pythonworker/PythonProxyClient.scala (91%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/pythonworker/PythonProxyServer.scala (90%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/pythonworker/PythonWorkflowWorker.scala (86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/pythonworker/WorkerBatchInternalQueue.scala
(89%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/CostBasedScheduleGenerator.scala
(97%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/CostEstimator.scala (90%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/ExpansionGreedyScheduleGenerator.scala
(97%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/Region.scala (92%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/RegionExecutionCoordinator.scala
(94%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/RegionPlan.scala (93%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/Schedule.scala (95%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/ScheduleGenerator.scala (94%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/SchedulingUtils.scala (96%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/WorkflowExecutionCoordinator.scala
(89%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/config/ChannelConfig.scala (90%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/config/LinkConfig.scala (91%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/config/OperatorConfig.scala (93%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/config/PortConfig.scala (93%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/config/ResourceConfig.scala (82%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/config/WorkerConfig.scala (83%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/resourcePolicies/ExecutionClusterInfo.scala
(91%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/resourcePolicies/ResourceAllocator.scala
(90%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/sendsemantics/partitioners/BroadcastPartitioner.scala
(79%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/sendsemantics/partitioners/HashBasedShufflePartitioner.scala
(82%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/sendsemantics/partitioners/OneToOnePartitioner.scala
(79%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/sendsemantics/partitioners/Partitioner.scala
(77%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/sendsemantics/partitioners/RangeBasedShufflePartitioner.scala
(86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/sendsemantics/partitioners/RoundRobinPartitioner.scala
(80%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/DPThread.scala (89%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/DataProcessor.scala (86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/DataProcessorRPCHandlerInitializer.scala
(78%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/EmbeddedControlMessageManager.scala
(87%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/PauseManager.scala (89%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/PauseType.scala (88%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/WorkflowWorker.scala (85%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/managers/InputPortMaterializationReaderThread.scala
(80%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/managers/OutputPortResultWriterThread.scala
(89%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/managers/SerializationManager.scala
(79%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/managers/StatisticsManager.scala (94%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/AddInputChannelHandler.scala
(74%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/AddPartitioningHandler.scala
(74%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/AssignPortHandler.scala
(75%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/EndChannelHandler.scala
(82%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/EndHandler.scala (83%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/FinalizeCheckpointHandler.scala
(83%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/FlushNetworkBufferHandler.scala
(75%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/InitializeExecutorHandler.scala
(78%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/OpenExecutorHandler.scala
(74%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/PauseHandler.scala
(71%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/PrepareCheckpointHandler.scala
(84%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/QueryStatisticsHandler.scala
(71%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/ResumeHandler.scala
(72%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/RetrieveStateHandler.scala
(74%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/StartChannelHandler.scala
(69%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/promisehandlers/StartHandler.scala
(75%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/AmberConfig.scala (95%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/AmberKryoInitializer.scala (96%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/AmberLogging.scala (86%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/AmberRuntime.scala (94%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/CheckpointState.scala (96%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/CheckpointSupport.scala (88%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/ElidableStatement.scala (96%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/FutureBijection.scala (97%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/SerializedState.scala (97%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/Utils.scala (97%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/amberexception/BreakpointException.scala (88%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/ambermessage/DataPayload.scala (90%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/ambermessage/DirectControlMessagePayload.scala (93%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/ambermessage/RecoveryPayload.scala (91%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/ambermessage/WorkflowFIFOMessagePayload.scala (93%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/ambermessage/WorkflowMessage.scala (90%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/client/AmberClient.scala (83%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/client/ClientActor.scala (80%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/rpc/AsyncRPCClient.scala (88%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/rpc/AsyncRPCHandlerInitializer.scala (82%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/rpc/AsyncRPCServer.scala (87%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/statetransition/StateManager.scala (90%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/statetransition/WorkerStateManager.scala (83%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/storage/EmptyRecordStorage.scala (92%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/storage/HDFSRecordStorage.scala (95%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/storage/SequentialRecordStorage.scala (95%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/storage/VFSRecordStorage.scala (94%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/engine/common/virtualidentity/util.scala (88%)
rename amber/src/main/scala/org/apache/{ =>
texera}/amber/error/ErrorUtils.scala (90%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/breakpoint/ExceptionBreakpointSpec.scala (99%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/control/TrivialControlSpec.scala (85%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/control/utils/ChainHandler.scala (85%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/control/utils/CollectHandler.scala (87%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/control/utils/ErrorHandler.scala (84%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/control/utils/MultiCallHandler.scala (81%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/control/utils/NestedHandler.scala (86%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/control/utils/PingPongHandler.scala (88%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/control/utils/RecursionHandler.scala (85%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/control/utils/TesterAsyncRPCHandlerInitializer.scala
(72%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/control/utils/TrivialControlTester.scala (73%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/controller/ControllerSpec.scala (99%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/NetworkInputGatewaySpec.scala
(89%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/OutputManagerSpec.scala (88%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/messaginglayer/RangeBasedShuffleSpec.scala
(91%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/pythonworker/PythonWorkflowWorkerSpec.scala
(83%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/CostBasedScheduleGeneratorSpec.scala
(96%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/DefaultCostEstimatorSpec.scala
(91%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/scheduling/ExpansionGreedyScheduleGeneratorSpec.scala
(95%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/DPThreadSpec.scala (89%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/DataProcessorSpec.scala (85%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/architecture/worker/WorkerSpec.scala (86%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/e2e/BatchSizePropagationSpec.scala (94%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/e2e/DataProcessingSpec.scala (91%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/e2e/PauseSpec.scala (86%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/e2e/TestUtils.scala (94%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/faulttolerance/CheckpointSpec.scala (86%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/faulttolerance/LoggingSpec.scala (80%)
rename amber/src/test/scala/org/apache/{ =>
texera}/amber/engine/faulttolerance/ReplaySpec.scala (83%)
rename common/config/src/main/scala/org/apache/{ =>
texera}/amber/config/AkkaConfig.scala (96%)
rename common/config/src/main/scala/org/apache/{ =>
texera}/amber/config/ApplicationConfig.scala (99%)
rename common/config/src/main/scala/org/apache/{ =>
texera}/amber/config/EnvironmentalVariable.scala (99%)
rename common/config/src/main/scala/org/apache/{ =>
texera}/amber/config/StorageConfig.scala (98%)
rename common/config/src/main/scala/org/apache/{ =>
texera}/amber/config/UdfConfig.scala (97%)
rename common/config/src/main/scala/org/apache/{ =>
texera}/amber/util/ConfigParserUtil.scala (97%)
rename common/workflow-core/src/main/protobuf/org/apache/{ =>
texera}/amber/core/executor.proto (93%)
rename common/workflow-core/src/main/protobuf/org/apache/{ =>
texera}/amber/core/virtualidentity.proto (97%)
rename common/workflow-core/src/main/protobuf/org/apache/{ =>
texera}/amber/core/workflow.proto (95%)
rename common/workflow-core/src/main/protobuf/org/apache/{ =>
texera}/amber/core/workflowruntimestate.proto (97%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/WorkflowRuntimeException.scala (93%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/executor/ExecFactory.scala (97%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/executor/JavaRuntimeCompilation.scala (97%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/executor/OperatorExecutor.scala (88%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/executor/SourceOperatorExecutor.scala (90%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/state/State.scala (93%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/DocumentFactory.scala (91%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/FileResolver.scala (99%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/IcebergCatalogInstance.scala (94%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/VFSURIFactory.scala (93%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/model/BufferedItemWriter.scala (97%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/model/DatasetFileDocument.scala (95%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/model/OnDataset.scala (94%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/model/ReadonlyLocalFileDocument.scala (97%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/model/ReadonlyVirtualDocument.scala (97%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/model/VirtualCollection.scala (96%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/model/VirtualDocument.scala (99%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/result/ResultSchema.scala (92%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/result/WorkflowResultStore.scala (89%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/result/iceberg/IcebergDocument.scala (98%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/result/iceberg/IcebergTableWriter.scala (95%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/result/iceberg/OnIceberg.scala (94%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/util/LakeFSStorageClient.scala (99%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/util/StorageUtil.scala (96%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/util/dataset/GitVersionControlLocalFileStorage.java
(99%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/util/dataset/JGitVersionControl.java (99%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/storage/util/dataset/PhysicalFileNode.java (98%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/tuple/Attribute.java (98%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/tuple/AttributeType.java (99%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/tuple/AttributeTypeUtils.scala (99%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/tuple/BigObject.java (96%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/tuple/Schema.scala (99%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/tuple/Tuple.scala (98%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/tuple/TupleLike.scala (98%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/tuple/TupleUtils.scala (91%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/workflow/LocationPreference.scala (96%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/workflow/PartitionInfo.scala (98%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/workflow/PhysicalOp.scala (98%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/workflow/PhysicalPlan.scala (98%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/workflow/WorkflowContext.scala (87%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/core/workflow/WorkflowSettings.scala (95%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/util/ArrowUtils.scala (98%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/util/IcebergUtil.scala (98%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/util/JSONUtils.scala (96%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/util/VirtualIdentityUtils.scala (97%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/util/serde/GlobalPortIdentitySerde.scala (93%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/util/serde/PortIdentityKeyDeserializer.scala (92%)
rename common/workflow-core/src/main/scala/org/apache/{ =>
texera}/amber/util/serde/PortIdentityKeySerializer.scala (88%)
rename common/workflow-core/src/test/scala/org/apache/{ =>
texera}/amber/core/storage/model/VirtualDocumentSpec.scala (99%)
rename common/workflow-core/src/test/scala/org/apache/{ =>
texera}/amber/core/tuple/AttributeTypeUtilsSpec.scala (98%)
rename common/workflow-core/src/test/scala/org/apache/{ =>
texera}/amber/core/tuple/SchemaSpec.scala (99%)
rename common/workflow-core/src/test/scala/org/apache/{ =>
texera}/amber/core/tuple/TupleSpec.scala (98%)
rename common/workflow-core/src/test/scala/org/apache/{ =>
texera}/amber/storage/FileResolverSpec.scala (97%)
rename common/workflow-core/src/test/scala/org/apache/{ =>
texera}/amber/storage/result/iceberg/IcebergDocumentConsoleMessagesSpec.scala
(88%)
rename common/workflow-core/src/test/scala/org/apache/{ =>
texera}/amber/storage/result/iceberg/IcebergDocumentSpec.scala (92%)
rename common/workflow-core/src/test/scala/org/apache/{ =>
texera}/amber/storage/result/iceberg/IcebergTableStatsSpec.scala (94%)
rename common/workflow-core/src/test/scala/org/apache/{ =>
texera}/amber/util/IcebergUtilSpec.scala (98%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/DummyProperties.scala (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/LogicalOp.scala (70%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/PortDescriptor.scala (92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/PythonOperatorDescriptor.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/SpecialPhysicalOpFactory.scala (86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/TestOperators.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/aggregate/AggregateOpDesc.scala (85%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/aggregate/AggregateOpExec.scala (92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/aggregate/AggregationFunction.java (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/aggregate/AggregationOperation.scala (97%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/aggregate/DistributedAggregation.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/cartesianProduct/CartesianProductOpDesc.scala (86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/cartesianProduct/CartesianProductOpExec.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/dictionary/DictionaryMatcherOpDesc.scala (79%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/dictionary/DictionaryMatcherOpExec.scala (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/dictionary/MatchingType.java (97%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/difference/DifferenceOpDesc.scala (80%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/difference/DifferenceOpExec.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/distinct/DistinctOpDesc.scala (74%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/distinct/DistinctOpExec.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/dummy/DummyOpDesc.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/filter/ComparisonType.java (97%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/filter/FilterOpDesc.scala (81%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/filter/FilterOpExec.scala (87%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/filter/FilterPredicate.java (91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/filter/SpecializedFilterOpDesc.scala (78%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/filter/SpecializedFilterOpExec.scala (87%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/flatmap/FlatMapOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/flatmap/FlatMapOpExec.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/hashJoin/HashJoinBuildOpExec.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/hashJoin/HashJoinOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/hashJoin/HashJoinProbeOpExec.scala (93%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/hashJoin/JoinType.java (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/huggingFace/HuggingFaceIrisLogisticRegressionOpDesc.scala
(91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/huggingFace/HuggingFaceSentimentAnalysisOpDesc.scala
(91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/huggingFace/HuggingFaceSpamSMSDetectionOpDesc.scala (87%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/huggingFace/HuggingFaceTextSummarizationOpDesc.scala
(88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/ifStatement/IfOpDesc.scala (81%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/ifStatement/IfOpExec.scala (83%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/intersect/IntersectOpDesc.scala (77%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/intersect/IntersectOpExec.scala (91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/intervalJoin/IntervalJoinOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/intervalJoin/IntervalJoinOpExec.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/intervalJoin/TimeIntervalType.java (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/keywordSearch/KeywordSearchOpDesc.scala (76%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/keywordSearch/KeywordSearchOpExec.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/limit/LimitOpDesc.scala (81%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/limit/LimitOpExec.scala (84%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/Scorer/MachineLearningScorerOpDesc.scala
(93%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/Scorer/classificationMetricsFnc.java
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/Scorer/regressionMetricsFnc.java (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/sklearnAdvanced/KNNTrainer/SklearnAdvancedKNNClassifierTrainerOpDesc.scala
(85%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/sklearnAdvanced/KNNTrainer/SklearnAdvancedKNNParameters.java
(89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/sklearnAdvanced/KNNTrainer/SklearnAdvancedKNNRegressorTrainerOpDesc.scala
(85%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/sklearnAdvanced/SVCTrainer/SklearnAdvancedSVCParameters.java
(89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/sklearnAdvanced/SVCTrainer/SklearnAdvancedSVCTrainerOpDesc.scala
(85%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/sklearnAdvanced/SVRTrainer/SklearnAdvancedSVRParameters.java
(90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/sklearnAdvanced/SVRTrainer/SklearnAdvancedSVRTrainerOpDesc.scala
(85%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/sklearnAdvanced/base/HyperParameters.java
(91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/machineLearning/sklearnAdvanced/base/SklearnAdvancedBaseDesc.scala
(92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/map/MapOpDesc.scala (81%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/map/MapOpExec.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/OPVersion.java (97%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/OperatorGroupConstants.scala (98%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/OperatorMetadataGenerator.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/PropertyNameConstants.scala (97%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/annotations/AutofillAttributeName.java (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/annotations/AutofillAttributeNameLambda.java
(97%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/annotations/AutofillAttributeNameList.java (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/annotations/AutofillAttributeNameOnPort1.java
(96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/annotations/BatchByColumn.java (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/annotations/CommonOpDescAnnotation.java (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/annotations/EnablePresets.java (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/annotations/HideAnnotation.java (97%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/metadata/annotations/UIWidget.java (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/projection/AttributeUnit.java (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/projection/ProjectionOpDesc.scala (83%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/projection/ProjectionOpExec.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/randomksampling/RandomKSamplingOpDesc.scala (76%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/randomksampling/RandomKSamplingOpExec.scala (86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/regex/RegexOpDesc.scala (78%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/regex/RegexOpExec.scala (86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/reservoirsampling/ReservoirSamplingOpDesc.scala (76%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/reservoirsampling/ReservoirSamplingOpExec.scala (84%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sink/ProgressiveUtils.scala (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnAdaptiveBoostingOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnBaggingOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnBernoulliNaiveBayesOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnClassifierOpDesc.scala (92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnComplementNaiveBayesOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnDecisionTreeOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnDummyClassifierOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnExtraTreeOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnExtraTreesOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnGaussianNaiveBayesOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnGradientBoostingOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnKNNOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnLinearRegressionOpDesc.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnLinearSVMOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnLogisticRegressionCVOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnLogisticRegressionOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnMultiLayerPerceptronOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnMultinomialNaiveBayesOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnNearestCentroidOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnPassiveAggressiveOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnPerceptronOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnPredictionOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnProbabilityCalibrationOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnRandomForestOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnRidgeCVOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnRidgeOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnSDGOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/SklearnSVMOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingAdaptiveBoostingOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingBaggingOpDesc.scala (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingBernoulliNaiveBayesOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingComplementNaiveBayesOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingDecisionTreeOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingDummyClassifierOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingExtraTreeOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingExtraTreesOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingGaussianNaiveBayesOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingGradientBoostingOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingKNNOpDesc.scala (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingLinearRegressionOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingLinearSVMOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingLogisticRegressionCVOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingLogisticRegressionOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingMultiLayerPerceptronOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingMultinomialNaiveBayesOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingNearestCentroidOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingOpDesc.scala (91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingPassiveAggressiveOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingPerceptronOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingProbabilityCalibrationOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingRandomForestOpDesc.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingRidgeCVOpDesc.scala (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingRidgeOpDesc.scala (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingSDGOpDesc.scala (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sklearn/training/SklearnTrainingSVMOpDesc.scala (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sleep/SleepOpDesc.scala (76%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sleep/SleepOpExec.scala (82%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sort/SortCriteriaUnit.java (85%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sort/SortOpDesc.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sort/SortPreference.java (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sort/StableMergeSortOpDesc.scala (80%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sort/StableMergeSortOpExec.scala (97%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sortPartitions/SortPartitionsOpDesc.scala (79%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/sortPartitions/SortPartitionsOpExec.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/BufferedBlockReader.java (98%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/PythonSourceOperatorDescriptor.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/SourceOperatorDescriptor.scala (86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/apis/reddit/RedditSearchSourceOpDesc.scala (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/apis/reddit/RedditSourceOperatorFunction.java
(95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/apis/twitter/TwitterSourceOpDesc.scala (86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/apis/twitter/TwitterSourceOpExec.scala (91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/apis/twitter/v2/TwitterFullArchiveSearchSourceOpDesc.scala
(86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/apis/twitter/v2/TwitterFullArchiveSearchSourceOpExec.scala
(93%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/apis/twitter/v2/TwitterSearchSourceOpDesc.scala
(85%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/apis/twitter/v2/TwitterSearchSourceOpExec.scala
(93%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/apis/twitter/v2/TwitterUtils.scala (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/cache/CacheSourceOpExec.scala (79%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/fetcher/DecodingMethod.java (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/fetcher/RandomUserAgent.java (99%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/fetcher/URLFetchUtil.scala (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/fetcher/URLFetcherOpDesc.scala (78%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/fetcher/URLFetcherOpExec.scala (82%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/AutoClosingIterator.scala (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/FileAttributeType.java (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/FileDecodingMethod.java (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/FileScanSourceOpDesc.scala (82%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/FileScanSourceOpExec.scala (92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/ScanSourceOpDesc.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/arrow/ArrowSourceOpDesc.scala (79%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/arrow/ArrowSourceOpExec.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/csv/CSVScanSourceOpDesc.scala (84%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/csv/CSVScanSourceOpExec.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/csv/ParallelCSVScanSourceOpDesc.scala (82%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/csv/ParallelCSVScanSourceOpExec.scala (91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/csvOld/CSVOldScanSourceOpDesc.scala (82%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/csvOld/CSVOldScanSourceOpExec.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/json/JSONLScanSourceOpDesc.scala (82%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/json/JSONLScanSourceOpExec.scala (85%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/json/JSONUtil.scala (98%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/text/TextInputSourceOpDesc.scala (74%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/text/TextInputSourceOpExec.scala (81%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/scan/text/TextSourceOpDesc.scala (93%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/sql/SQLSourceOpDesc.scala (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/sql/SQLSourceOpExec.scala (98%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/sql/asterixdb/AsterixDBConnUtil.scala (98%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/sql/asterixdb/AsterixDBSourceOpDesc.scala (86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/sql/asterixdb/AsterixDBSourceOpExec.scala (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/sql/mysql/MySQLConnUtil.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/sql/mysql/MySQLSourceOpDesc.scala (73%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/sql/mysql/MySQLSourceOpExec.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/sql/postgresql/PostgreSQLConnUtil.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/sql/postgresql/PostgreSQLSourceOpDesc.scala (76%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/source/sql/postgresql/PostgreSQLSourceOpExec.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/split/SplitOpDesc.scala (84%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/split/SplitOpExec.scala (84%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/substringSearch/SubstringSearchOpDesc.scala (77%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/substringSearch/SubstringSearchOpExec.scala (85%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/symmetricDifference/SymmetricDifferenceOpDesc.scala (81%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/symmetricDifference/SymmetricDifferenceOpExec.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/timeSeriesPlot/TimeSeriesPlot.scala (91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/typecasting/TypeCastingOpDesc.scala (79%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/typecasting/TypeCastingOpExec.scala (83%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/typecasting/TypeCastingUnit.java (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/udf/java/JavaUDFOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/udf/python/DualInputPortsPythonUDFOpDescV2.scala (92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/udf/python/LambdaAttributeUnit.java (92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/udf/python/PythonLambdaFunctionOpDesc.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/udf/python/PythonTableReducerOpDesc.scala (86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/udf/python/PythonUDFOpDescV2.scala (92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/udf/python/source/PythonUDFSourceOpDescV2.scala (85%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/udf/r/RUDFOpDesc.scala (92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/udf/r/RUDFSourceOpDesc.scala (86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/union/UnionOpDesc.scala (74%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/union/UnionOpExec.scala (84%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/unneststring/UnnestStringOpDesc.scala (78%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/unneststring/UnnestStringOpExec.scala (84%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/util/OperatorDescriptorUtils.scala (97%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/DotPlot/DotPlotOpDesc.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/IcicleChart/IcicleChartOpDesc.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/ImageUtility.scala (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/ImageViz/ImageVisualizerOpDesc.scala (87%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/ScatterMatrixChart/ScatterMatrixChartOpDesc.scala
(87%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/barChart/BarChartOpDesc.scala (91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/boxViolinPlot/BoxViolinPlotOpDesc.scala
(91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/boxViolinPlot/BoxViolinPlotQuartileFunction.java
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/bubbleChart/BubbleChartOpDesc.scala (91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/bulletChart/BulletChartOpDesc.scala (95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/bulletChart/BulletChartStepDefinition.scala
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/candlestickChart/CandlestickChartOpDesc.scala
(87%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/choroplethMap/ChoroplethMapOpDesc.scala
(89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/continuousErrorBands/BandConfig.scala (86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/continuousErrorBands/ContinuousErrorBandsOpDesc.scala
(92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/contourPlot/ContourPlotColoringFunction.java
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/contourPlot/ContourPlotOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/dendrogram/DendrogramOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/dumbbellPlot/DumbbellDotConfig.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/dumbbellPlot/DumbbellPlotOpDesc.scala (93%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/figureFactoryTable/FigureFactoryTableConfig.scala
(87%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/figureFactoryTable/FigureFactoryTableOpDesc.scala
(91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/filledAreaPlot/FilledAreaPlotOpDesc.scala
(92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/funnelPlot/FunnelPlotOpDesc.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/ganttChart/GanttChartOpDesc.scala (91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/gaugeChart/GaugeChartOpDesc.scala (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/gaugeChart/GaugeChartSteps.scala (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/heatMap/HeatMapOpDesc.scala (87%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/hierarchychart/HierarchyChartOpDesc.scala
(90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/hierarchychart/HierarchyChartType.java
(94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/hierarchychart/HierarchySection.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/histogram/HistogramChartOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/histogram2d/Histogram2DOpDesc.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/histogram2d/NormalizationType.java (94%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/htmlviz/HtmlVizOpDesc.scala (72%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/htmlviz/HtmlVizOpExec.scala (82%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/lineChart/LineChartOpDesc.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/lineChart/LineConfig.scala (93%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/lineChart/LineMode.java (96%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/nestedTable/NestedTableConfig.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/nestedTable/NestedTableOpDesc.scala (92%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/networkGraph/NetworkGraphOpDesc.scala (93%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/pieChart/PieChartOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/quiverPlot/QuiverPlotOpDesc.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/rangeSlider/RangeSliderHandleDuplicateFunction.java
(95%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/rangeSlider/RangeSliderOpDesc.scala (90%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/sankeyDiagram/SankeyDiagramOpDesc.scala
(91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/scatter3DChart/Scatter3dChartOpDesc.scala
(89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/scatterplot/ScatterplotOpDesc.scala (91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/stripChart/StripChartOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/tablesChart/TablesConfig.scala (88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/tablesChart/TablesPlotOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/ternaryPlot/TernaryPlotOpDesc.scala (91%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/treeplot/TreeplotOpDesc.scala (93%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/urlviz/UrlVizOpDesc.scala (73%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/urlviz/UrlVizOpExec.scala (86%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/volcanoPlot/VolcanoPlotOpDesc.scala (89%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/waterfallChart/WaterfallChartOpDesc.scala
(88%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/operator/visualization/wordCloud/WordCloudOpDesc.scala (87%)
rename common/workflow-operator/src/main/scala/org/apache/{ =>
texera}/amber/util/ObjectMapperUtils.scala (92%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/aggregate/AggregateOpSpec.scala (98%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/cartesianProduct/CartesianProductOpExecSpec.scala (97%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/dictionary/DictionaryMatcherOpExecSpec.scala (97%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/difference/DifferenceOpExecSpec.scala (97%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/distinct/DistinctOpExecSpec.scala (96%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/filter/SpecializedFilterOpExecSpec.scala (96%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/hashJoin/HashJoinOpSpec.scala (95%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/intersect/IntersectOpExecSpec.scala (94%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/intervalJoin/IntervalOpExecSpec.scala (97%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/keywordSearch/KeywordSearchOpExecSpec.scala (97%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/projection/ProjectionOpDescSpec.scala (94%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/projection/ProjectionOpExecSpec.scala (97%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/sort/StableMergeSortOpExecSpec.scala (99%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/sortPartitions/SortPartitionsOpExecSpec.scala (93%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/source/fetcher/URLFetcherOpExecSpec.scala (92%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/source/scan/FileScanSourceOpExecSpec.scala (96%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/source/scan/csv/CSVScanSourceOpDescSpec.scala (93%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/source/scan/text/FileScanSourceOpDescSpec.scala (95%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/source/scan/text/TextInputSourceOpDescSpec.scala (95%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/symmetricDifference/SymmetricDifferenceOpExecSpec.scala
(97%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/typecasting/TypeCastingOpExecSpec.scala (95%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/udf/python/PythonLambdaFunctionOpDescSpec.scala (94%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/unneststring/UnnestStringOpExecSpec.scala (96%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/visualization/DotPlot/DotPlotOpDescSpec.scala (95%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/visualization/ImageViz/ImageVisualizerOpDescSpec.scala
(94%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/visualization/barChart/BarChartOpDescSpec.scala (96%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/visualization/bubbleChart/BubbleChartOpDescSpec.scala
(95%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/visualization/filledAreaPlot/FilledAreaPlotOpDescSpec.scala
(96%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/visualization/ganttChart/GanttChartOpDescSpec.scala (97%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/visualization/hierarchychart/HierarchyChartOpDescSpec.scala
(96%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/visualization/htmlviz/HtmlVizOpExecSpec.scala (91%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/visualization/pieChart/PieChartOpDescSpec.scala (94%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/operator/visualization/scatterplot/ScatterPlotOpDescSpec.scala
(95%)
rename common/workflow-operator/src/test/scala/org/apache/{ =>
texera}/amber/util/ArrowUtilsSpec.scala (97%)
rename frontend/src/app/common/type/proto/org/apache/{ =>
texera}/amber/engine/common/virtualidentity.ts (99%)
rename frontend/src/app/common/type/proto/org/apache/{ =>
texera}/amber/engine/common/workflow.ts (99%)
rename workflow-compiling-service/src/main/scala/org/apache/{ =>
texera}/amber/compiler/WorkflowCompiler.scala (93%)
rename workflow-compiling-service/src/main/scala/org/apache/{ =>
texera}/amber/compiler/model/LogicalLink.scala (88%)
rename workflow-compiling-service/src/main/scala/org/apache/{ =>
texera}/amber/compiler/model/LogicalPlan.scala (92%)
rename workflow-compiling-service/src/main/scala/org/apache/{ =>
texera}/amber/compiler/model/LogicalPlanPojo.scala (90%)