You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@texera.apache.org by xi...@apache.org on 2025/10/11 18:51:32 UTC
(texera) branch xiaozhen-llm-chatbot updated (b5a9969b70 -> 365780cc8b)
This is an automated email from the ASF dual-hosted git repository.
xiaozhenliu pushed a change to branch xiaozhen-llm-chatbot
in repository https://gitbox.apache.org/repos/asf/texera.git
from b5a9969b70 fmt.
add a0c1918358 feat: add save button for sidebar tabs on the admin settings page (#3801)
add 989e4d0e8b feat(dataset): allow datasets to have the same name across different users (#3715)
add 61bd59b08a ci: automatically label PRs (#3536)
add 98582dd153 ci: fix labeler.yml glob pattern syntax (#3813)
add 80160aab6d ci: fix labeler configuration for file glob patterns (#3814)
add d1313346d0 feat(gui): display the owner's avatar next to each CU (#3784)
add 60c84bd175 fix(ci): explicitly load jdbc driver when accessing iceberg postgres catalog (#3817)
add 4acb11901b fix(ci): update backend file patterns in labeler.yml (#3815)
add 6c89f40c26 fix: delete button only clickable from outer ring (#3809)
add 0d3bf4ce74 chore: add bug report template (#3812)
add 1ec8022a1e chore(deps): bump @babel/helpers from 7.25.7 to 7.28.4 in /core/gui (#3795)
add 24ba25d3ce fix: conditionally show upload panels based on upload activity (#3818)
add f7482d25ef fix(image): exec format error in pylsp Docker container (#3811)
add 625a9afa36 fix(gui): keep words complete in the workspace' comment boxes (#3597)
add 1c812a5e2d chore: Improve Bug Issue Template (#3826)
add 20a38d54d7 chore(deps): bump transformers from 4.44.2 to 4.53.0 in /core/amber (#3635)
add 62dd9d4667 fix(deployment): deduplicate SQL files under `deployment` by using symlinks (#3824)
add 257fbe04c5 chore(ci): automatically assign an author of a PR (#3835)
add 83076ac501 feat(amber): enable user system by default (#3782)
add fa1470205a chore(deps): bump prismjs from 1.29.0 to 1.30.0 in /core/gui (#3796)
add 5650e9538d fix(access-control-service): fix formatting of `AccessControlResource` (#3838)
add 8d676fde4a chore(ci): revert automatically assign an author of a PR (#3839)
add e6c9d7db32 fix(access-control-service): fix service file formats (#3840)
add 8b28c196f6 feat(access-control-service): add `access-control-service` to authorize the requests to `/wsapi` and `Computing Unit` endpoints (#3598)
add 356a240e2f fix(file-service): avoid manually constructing the Dataset object through parameters (#3820)
add 84f696e1ed refactor(config): remove user-sys enabled flag (#3831)
add 379ac816a5 fix(gui): enable frontend undo-redo with bug-fix for shared editing (#3836)
add bf8c942440 feat: enable canceling pending uploads before upload begins (#3847)
add 04105b8249 feat: improve `file-service` Docker Compose file (#3834)
add 4d3c788b81 feat: prevent export of results from non-downloadable datasets (#3772)
add 13171990db feat: switch workflow result downloads to use browser native downloads (#3728)
add 97ef79c753 fix(ui): remove duplicate left sidebar border and extend to bottom of page (#3849)
add 6fb94e506d chore: rename packages to org.apache (#3848)
add 365780cc8b Merge branch 'refs/heads/main' into xiaozhen-llm-chatbot
No new revisions were added by this update.
Summary of changes:
.github/ISSUE_TEMPLATE/bug-template.yaml | 84 ++++
.github/labeler.yml | 85 ++++
.github/workflows/github-action-build.yml | 11 +-
.github/workflows/pr-labeler.yml | 31 ++
core/access-control-service/build.sbt | 5 +-
.../service/resource/AccessControlResource.scala | 132 ------
.../texera/service/AccessControlService.scala | 23 +-
.../AccessControlServiceConfiguration.scala | 2 +-
.../service/resource/AccessControlResource.scala | 205 +++++++++
.../service/resource/HealthCheckResource.scala | 2 +-
.../apache}/texera/AccessControlResourceSpec.scala | 54 ++-
core/amber/build.sbt | 2 +-
core/amber/requirements.txt | 2 +-
.../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 +-
.../apache}/amber/engine/common/actormessage.proto | 2 +-
.../apache}/amber/engine/common/ambermessage.proto | 8 +-
.../engine/common/executionruntimestate.proto | 12 +-
.../handlers/actorcommand/actor_handler_base.py | 2 +-
.../handlers/actorcommand/backpressure_handler.py | 8 +-
.../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 | 2 +-
.../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 | 2 +-
.../handlers/control/pause_worker_handler.py | 2 +-
.../handlers/control/query_statistics_handler.py | 6 +-
.../control/replay_current_tuple_handler.py | 4 +-
.../handlers/control/resume_worker_handler.py | 2 +-
.../handlers/control/start_channel_handler.py | 2 +-
.../handlers/control/start_worker_handler.py | 12 +-
.../handlers/control/update_executor_handler.py | 2 +-
.../managers/console_message_manager.py | 2 +-
.../python/core/architecture/managers/context.py | 11 +-
.../managers/embedded_control_message_manager.py | 4 +-
.../core/architecture/managers/executor_manager.py | 7 +-
.../core/architecture/managers/pause_manager.py | 8 +-
.../managers/state_processing_manager.py | 1 +
.../architecture/managers/statistics_manager.py | 6 +-
.../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 | 7 +-
.../core/architecture/packaging/output_manager.py | 15 +-
.../core/architecture/rpc/async_rpc_client.py | 6 +-
.../rpc/async_rpc_handler_initializer.py | 2 +-
.../core/architecture/rpc/async_rpc_server.py | 9 +-
.../sendsemantics/broad_cast_partitioner.py | 9 +-
.../hash_based_shuffle_partitioner.py | 10 +-
.../sendsemantics/one_to_one_partitioner.py | 8 +-
.../core/architecture/sendsemantics/partitioner.py | 9 +-
.../range_based_shuffle_partitioner.py | 9 +-
.../sendsemantics/round_robin_partitioner.py | 9 +-
.../src/main/python/core/models/RTableExecutor.py | 5 +-
.../src/main/python/core/models/RTupleExecutor.py | 7 +-
core/amber/src/main/python/core/models/batch.py | 3 +-
.../src/main/python/core/models/internal_queue.py | 6 +-
core/amber/src/main/python/core/models/operator.py | 6 +-
core/amber/src/main/python/core/models/payload.py | 1 +
core/amber/src/main/python/core/models/r_utils.py | 3 +-
.../python/core/models/schema/attribute_type.py | 7 +-
.../src/main/python/core/models/schema/schema.py | 3 +-
.../main/python/core/models/schema/test_schema.py | 2 +-
core/amber/src/main/python/core/models/state.py | 1 +
core/amber/src/main/python/core/models/table.py | 6 +-
.../main/python/core/models/test_RTableExecutor.py | 1 +
.../src/main/python/core/models/test_table.py | 3 +-
.../src/main/python/core/models/test_tuple.py | 3 +-
core/amber/src/main/python/core/models/tuple.py | 11 +-
.../src/main/python/core/proxy/proxy_server.py | 6 +-
.../main/python/core/proxy/test_proxy_client.py | 3 +-
.../main/python/core/runnables/data_processor.py | 6 +-
.../src/main/python/core/runnables/heartbeat.py | 13 +-
.../src/main/python/core/runnables/main_loop.py | 16 +-
.../main/python/core/runnables/network_receiver.py | 6 +-
.../main/python/core/runnables/network_sender.py | 13 +-
.../python/core/runnables/test_console_message.py | 11 +-
.../main/python/core/runnables/test_main_loop.py | 15 +-
.../python/core/runnables/test_network_receiver.py | 17 +-
.../python/core/runnables/test_network_sender.py | 3 +-
.../main/python/core/storage/document_factory.py | 3 +-
.../core/storage/iceberg/iceberg_document.py | 11 +-
.../core/storage/iceberg/test_iceberg_document.py | 5 +-
.../storage/model/readonly_virtual_document.py | 3 +-
.../python/core/storage/model/virtual_document.py | 3 +-
.../input_port_materialization_reader_runnable.py | 25 +-
.../core/storage/runnables/port_storage_writer.py | 1 -
.../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 | 6 +-
.../core/util/console_message/timed_buffer.py | 3 +-
.../test_linked_blocking_multi_queue.py | 3 +-
.../core/util/expression_evaluator/__init__.py | 2 +-
.../test_expression_evaluator.py | 2 +-
.../python/core/util/virtual_identity/__init__.py | 2 +-
.../python/proto/edu/uci/ics/texera/__init__.py | 16 -
.../src/main/python/proto/{edu => org}/__init__.py | 0
.../proto/{edu/uci => org/apache}/__init__.py | 0
.../{edu/uci/ics => org/apache/amber}/__init__.py | 0
.../uci/ics => org/apache}/amber/core/__init__.py | 2 +-
.../amber => org/apache/amber/engine}/__init__.py | 0
.../apache/amber/engine/architecture}/__init__.py | 0
.../amber/engine/architecture/rpc/__init__.py | 182 ++++----
.../engine/architecture/sendsemantics/__init__.py | 2 +-
.../amber/engine/architecture/worker/__init__.py | 2 +-
.../apache}/amber/engine/common/__init__.py | 2 +-
.../architecture => org/apache/texera}/__init__.py | 0
.../uci/ics => org/apache}/texera/web/__init__.py | 2 +-
.../pytexera/storage/dataset_file_document.py | 2 +-
.../udf/examples/test_count_batch_operator.py | 3 +-
.../udf/examples/test_echo_table_operator.py | 3 +-
.../src/main/python/pytexera/udf/udf_operator.py | 1 +
.../src/main/python/texera_run_python_worker.py | 1 -
.../ics/texera/web/ServletAwareConfigurator.scala | 79 ----
.../apache}/amber/clustering/ClusterListener.scala | 26 +-
.../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 | 30 +-
.../ControllerAsyncRPCHandlerInitializer.scala | 14 +-
.../controller/ControllerProcessor.scala | 18 +-
.../controller/ControllerTimerService.scala | 12 +-
.../controller/GlobalReplayManager.scala | 4 +-
.../engine/architecture/controller/Workflow.scala | 6 +-
.../controller/WorkflowScheduler.scala | 8 +-
.../controller/execution/ChannelExecution.scala | 2 +-
.../controller/execution/ExecutionUtils.scala | 8 +-
.../controller/execution/LinkExecution.scala | 4 +-
.../controller/execution/OperatorExecution.scala | 19 +-
.../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 | 12 +-
.../promisehandlers/PortCompletedHandler.scala | 16 +-
.../QueryWorkerStatisticsHandler.scala | 16 +-
.../controller/promisehandlers/ResumeHandler.scala | 10 +-
.../RetrieveWorkflowStateHandler.scala | 16 +-
.../promisehandlers/RetryWorkflowHandler.scala | 10 +-
.../promisehandlers/StartWorkflowHandler.scala | 10 +-
.../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 | 6 +-
.../architecture/logreplay/OrderEnforcer.scala | 4 +-
.../logreplay/ReplayLogGenerator.scala | 8 +-
.../architecture/logreplay/ReplayLogManager.scala | 16 +-
.../architecture/logreplay/ReplayLogger.scala | 6 +-
.../architecture/logreplay/ReplayLoggerImpl.scala | 8 +-
.../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 | 12 +-
.../messaginglayer/OrderingEnforcer.scala | 2 +-
.../messaginglayer/OutputManager.scala | 29 +-
.../architecture/messaginglayer/WorkerPort.scala | 6 +-
.../messaginglayer/WorkerTimerService.scala | 16 +-
.../pythonworker/PythonProxyClient.scala | 33 +-
.../pythonworker/PythonProxyServer.scala | 20 +-
.../pythonworker/PythonWorkflowWorker.scala | 30 +-
.../pythonworker/WorkerBatchInternalQueue.scala | 18 +-
.../scheduling/CostBasedScheduleGenerator.scala | 25 +-
.../architecture/scheduling/CostEstimator.scala | 24 +-
.../ExpansionGreedyScheduleGenerator.scala | 14 +-
.../engine/architecture/scheduling/Region.scala | 8 +-
.../scheduling/RegionExecutionCoordinator.scala | 36 +-
.../architecture/scheduling/RegionPlan.scala | 4 +-
.../engine/architecture/scheduling/Schedule.scala | 2 +-
.../scheduling/ScheduleGenerator.scala | 8 +-
.../architecture/scheduling/SchedulingUtils.scala | 2 +-
.../scheduling/WorkflowExecutionCoordinator.scala | 12 +-
.../scheduling/config/ChannelConfig.scala | 15 +-
.../scheduling/config/LinkConfig.scala | 16 +-
.../scheduling/config/OperatorConfig.scala | 2 +-
.../scheduling/config/PortConfig.scala | 5 +-
.../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 | 15 +-
.../RangeBasedShufflePartitioner.scala | 8 +-
.../partitioners/RoundRobinPartitioner.scala | 8 +-
.../engine/architecture/worker/DPThread.scala | 24 +-
.../engine/architecture/worker/DataProcessor.scala | 56 ++-
.../DataProcessorRPCHandlerInitializer.scala | 16 +-
.../worker/EmbeddedControlMessageManager.scala | 20 +-
.../engine/architecture/worker/PauseManager.scala | 8 +-
.../engine/architecture/worker/PauseType.scala | 4 +-
.../architecture/worker/WorkflowWorker.scala | 26 +-
.../InputPortMaterializationReaderThread.scala | 39 +-
.../managers/OutputPortResultWriterThread.scala | 6 +-
.../worker/managers/SerializationManager.scala | 16 +-
.../worker/managers/StatisticsManager.scala | 8 +-
.../promisehandlers/AddInputChannelHandler.scala | 10 +-
.../promisehandlers/AddPartitioningHandler.scala | 10 +-
.../worker/promisehandlers/AssignPortHandler.scala | 19 +-
.../worker/promisehandlers/EndChannelHandler.scala | 12 +-
.../worker/promisehandlers/EndHandler.scala | 8 +-
.../FinalizeCheckpointHandler.scala | 14 +-
.../FlushNetworkBufferHandler.scala | 8 +-
.../InitializeExecutorHandler.scala | 14 +-
.../promisehandlers/OpenExecutorHandler.scala | 8 +-
.../worker/promisehandlers/PauseHandler.scala | 10 +-
.../promisehandlers/PrepareCheckpointHandler.scala | 16 +-
.../promisehandlers/QueryStatisticsHandler.scala | 10 +-
.../worker/promisehandlers/ResumeHandler.scala | 10 +-
.../promisehandlers/RetrieveStateHandler.scala | 8 +-
.../promisehandlers/StartChannelHandler.scala | 14 +-
.../worker/promisehandlers/StartHandler.scala | 18 +-
.../apache}/amber/engine/common/AmberConfig.scala | 2 +-
.../amber/engine/common/AmberKryoInitializer.scala | 2 +-
.../apache}/amber/engine/common/AmberLogging.scala | 6 +-
.../apache}/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 +-
.../apache}/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 | 26 +-
.../amber/engine/common/client/ClientActor.scala | 30 +-
.../amber/engine/common/rpc/AsyncRPCClient.scala | 34 +-
.../common/rpc/AsyncRPCHandlerInitializer.scala | 14 +-
.../amber/engine/common/rpc/AsyncRPCServer.scala | 14 +-
.../common/statetransition/StateManager.scala | 8 +-
.../statetransition/WorkerStateManager.scala | 8 +-
.../engine/common/storage/EmptyRecordStorage.scala | 4 +-
.../engine/common/storage/HDFSRecordStorage.scala | 7 +-
.../common/storage/SequentialRecordStorage.scala | 6 +-
.../engine/common/storage/VFSRecordStorage.scala | 4 +-
.../amber/engine/common/virtualidentity/util.scala | 4 +-
.../apache}/amber/error/ErrorUtils.scala | 12 +-
.../apache}/texera/web/ComputingUnitMaster.scala | 93 ++--
.../apache}/texera/web/ComputingUnitWorker.scala | 4 +-
.../texera/web/ServletAwareConfigurator.scala | 121 ++++++
.../apache}/texera/web/SessionState.scala | 15 +-
.../apache}/texera/web/SubscriptionManager.scala | 2 +-
.../apache}/texera/web/TexeraWebApplication.scala | 45 +-
.../apache}/texera/web/TexeraWebConfiguration.java | 2 +-
.../apache}/texera/web/WebsocketInput.scala | 4 +-
.../texera/web/WorkflowLifecycleManager.scala | 12 +-
.../apache}/texera/web/auth/GuestAuthFilter.scala | 10 +-
.../apache}/texera/web/auth/JwtAuth.scala | 38 +-
.../texera/web/auth/UserAuthenticator.scala | 8 +-
.../texera/web/auth/UserRoleAuthorizer.scala | 6 +-
.../model/collab/event/CollabWebSocketEvent.scala | 4 +-
.../web/model/collab/event/CommandEvent.scala | 2 +-
.../web/model/collab/event/LockGrantedEvent.scala | 2 +-
.../web/model/collab/event/LockRejectedEvent.scala | 2 +-
.../web/model/collab/event/ReleaseLockEvent.scala | 2 +-
.../model/collab/event/RestoreVersionEvent.scala | 2 +-
.../model/collab/event/WorkflowAccessEvent.scala | 2 +-
.../model/collab/request/AcquireLockRequest.scala | 2 +-
.../collab/request/CollabWebSocketRequest.scala | 2 +-
.../web/model/collab/request/CommandRequest.scala | 2 +-
.../model/collab/request/HeartBeatRequest.scala | 2 +-
.../collab/request/RestoreVersionRequest.scala | 2 +-
.../web/model/collab/request/TryLockRequest.scala | 2 +-
.../web/model/collab/request/WIdRequest.scala | 2 +-
.../model/collab/response/HeartBeatResponse.scala | 4 +-
.../texera/web/model/common/AccessEntry.scala | 2 +-
.../model/http/request/auth/UserLoginRequest.scala | 2 +-
.../request/auth/UserRegistrationRequest.scala | 2 +-
.../http/request/result/ResultExportRequest.scala | 13 +-
.../http/response/SchemaPropagationResponse.scala | 4 +-
.../model/http/response/TokenIssueResponse.scala | 2 +-
.../response/result/ResultExportResponse.scala | 2 +-
.../websocket/event/CacheStatusUpdateEvent.scala | 2 +-
.../event/ExecutionDurationUpdateEvent.scala | 2 +-
.../websocket/event/ExecutionStatusEnum.scala | 0
.../event/OperatorStatisticsUpdateEvent.scala | 2 +-
.../websocket/event/PaginatedResultEvent.scala | 6 +-
.../websocket/event/TexeraWebSocketEvent.scala | 8 +-
.../websocket/event/WebResultUpdateEvent.scala | 4 +-
.../event/WorkerAssignmentUpdateEvent.scala | 2 +-
.../event/WorkflowAvailableResultEvent.scala | 6 +-
.../model/websocket/event/WorkflowErrorEvent.scala | 4 +-
.../model/websocket/event/WorkflowStateEvent.scala | 2 +-
.../event/python/ConsoleUpdateEvent.scala | 6 +-
.../request/EditingTimeCompilationRequest.scala | 6 +-
.../model/websocket/request/HeartBeatRequest.scala | 2 +-
.../websocket/request/ModifyLogicRequest.scala | 4 +-
.../request/ResultPaginationRequest.scala | 2 +-
.../web/model/websocket/request/RetryRequest.scala | 2 +-
.../model/websocket/request/SkipTupleRequest.scala | 2 +-
.../websocket/request/TexeraWebSocketRequest.scala | 4 +-
.../request/WorkflowCheckpointRequest.scala | 2 +-
.../websocket/request/WorkflowExecuteRequest.scala | 8 +-
.../websocket/request/WorkflowKillRequest.scala | 2 +-
.../websocket/request/WorkflowPauseRequest.scala | 2 +-
.../websocket/request/WorkflowResumeRequest.scala | 2 +-
.../request/python/DebugCommandRequest.scala | 4 +-
.../python/PythonExpressionEvaluateRequest.scala | 4 +-
.../response/ClusterStatusUpdateEvent.scala | 4 +-
.../websocket/response/HeartBeatResponse.scala | 4 +-
.../websocket/response/ModifyLogicResponse.scala | 4 +-
.../python/PythonExpressionEvaluateResponse.scala | 6 +-
.../web/resource/CollaborationResource.scala | 18 +-
.../texera/web/resource/EmailTemplate.scala | 6 +-
.../texera/web/resource/GmailResource.scala | 18 +-
.../texera/web/resource/HealthCheckResource.scala | 2 +-
.../web/resource/MockKillWorkerResource.scala | 2 +-
.../web/resource/SuccessExecutionResult.scala | 2 +-
.../web/resource/SystemMetadataResource.scala | 4 +-
.../texera/web/resource/UserConfigResource.scala | 12 +-
.../web/resource/WebsocketPayloadSizeTuner.scala | 4 +-
.../web/resource/WorkflowWebsocketResource.scala | 42 +-
.../resource/aiassistant/AiAssistantManager.scala | 4 +-
.../resource/aiassistant/AiAssistantResource.scala | 6 +-
.../aiassistant/test_type_annotation_visitor.py | 0
.../aiassistant/type_annotation_visitor.py | 0
.../texera/web/resource/auth/AuthResource.scala | 26 +-
.../web/resource/auth/GoogleAuthResource.scala | 20 +-
.../web/resource/dashboard/DashboardResource.scala | 19 +-
.../dashboard/DatasetSearchQueryBuilder.scala | 29 +-
.../dashboard/FulltextSearchQueryUtils.scala | 2 +-
.../dashboard/ProjectSearchQueryBuilder.scala | 11 +-
.../resource/dashboard/SearchQueryBuilder.scala | 8 +-
.../resource/dashboard/UnifiedResourceSchema.scala | 12 +-
.../dashboard/WorkflowSearchQueryBuilder.scala | 12 +-
.../admin/execution/AdminExecutionResource.scala | 10 +-
.../admin/settings/AdminSettingsResource.scala | 15 +-
.../dashboard/admin/user/AdminUserResource.scala | 22 +-
.../web/resource/dashboard/hub/ActionType.scala | 2 +-
.../web/resource/dashboard/hub/EntityTables.scala | 6 +-
.../web/resource/dashboard/hub/EntityType.scala | 2 +-
.../web/resource/dashboard/hub/HubResource.scala | 56 +--
.../dashboard/user/dataset/DatasetResource.scala | 5 +-
.../dataset/utils/DatasetStatisticsUtils.scala | 8 +-
.../user/project/ProjectAccessResource.scala | 20 +-
.../dashboard/user/project/ProjectResource.scala | 28 +-
.../user/project/PublicProjectResource.scala | 14 +-
.../dashboard/user/quota/UserQuotaResource.scala | 16 +-
.../user/workflow/WorkflowAccessResource.scala | 22 +-
.../user/workflow/WorkflowExecutionsResource.scala | 477 +++++++++++++--------
.../dashboard/user/workflow/WorkflowResource.scala | 30 +-
.../user/workflow/WorkflowVersionResource.scala | 22 +-
.../web/service/EmailNotificationService.scala | 4 +-
.../web/service/ExecutionConsoleService.scala | 90 ++--
.../service/ExecutionReconfigurationService.scala | 20 +-
.../web/service/ExecutionResultService.scala | 48 +--
.../web/service/ExecutionRuntimeService.scala | 22 +-
.../texera/web/service/ExecutionStatsService.scala | 171 ++++----
.../service/ExecutionsMetadataPersistService.scala | 17 +-
.../service/FriesReconfigurationAlgorithm.scala | 10 +-
.../texera/web/service/ResultExportService.scala | 131 ++++--
.../texera/web/service/WorkflowEmailNotifier.scala | 10 +-
.../web/service/WorkflowExecutionService.scala | 37 +-
.../texera/web/service/WorkflowService.scala | 106 +++--
.../storage/ExecutionReconfigurationStore.scala | 8 +-
.../texera/web/storage/ExecutionStateStore.scala | 10 +-
.../apache}/texera/web/storage/StateStore.scala | 6 +-
.../texera/web/storage/WorkflowStateStore.scala | 4 +-
.../apache}/texera/workflow/LogicalLink.scala | 6 +-
.../apache}/texera/workflow/LogicalPlan.scala | 12 +-
.../apache}/texera/workflow/WorkflowCompiler.scala | 10 +-
.../GitVersionControlLocalFileStorageSpec.java | 6 +-
.../edu/uci/ics/amber/engine/e2e/TestUtils.scala | 43 --
.../breakpoint/ExceptionBreakpointSpec.scala | 2 +-
.../architecture/control/TrivialControlSpec.scala | 24 +-
.../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 | 26 +-
.../architecture/controller/ControllerSpec.scala | 4 +-
.../messaginglayer/NetworkInputGatewaySpec.scala | 8 +-
.../messaginglayer/OutputManagerSpec.scala | 12 +-
.../messaginglayer/RangeBasedShuffleSpec.scala | 10 +-
.../pythonworker/PythonWorkflowWorkerSpec.scala | 34 +-
.../CostBasedScheduleGeneratorSpec.scala | 15 +-
.../scheduling/DefaultCostEstimatorSpec.scala | 40 +-
.../ExpansionGreedyScheduleGeneratorSpec.scala | 19 +-
.../engine/architecture/worker/DPThreadSpec.scala | 28 +-
.../architecture/worker/DataProcessorSpec.scala | 40 +-
.../engine/architecture/worker/WorkerSpec.scala | 34 +-
.../engine/e2e/BatchSizePropagationSpec.scala | 21 +-
.../amber/engine/e2e/DataProcessingSpec.scala | 75 ++--
.../apache}/amber/engine/e2e/PauseSpec.scala | 39 +-
.../org/apache/amber/engine/e2e/TestUtils.scala | 132 ++++++
.../engine/faulttolerance/CheckpointSpec.scala | 24 +-
.../amber/engine/faulttolerance/LoggingSpec.scala | 28 +-
.../amber/engine/faulttolerance/ReplaySpec.scala | 22 +-
.../dashboard/file/WorkflowResourceSpec.scala | 28 +-
.../workflow/WorkflowExecutionsResourceSpec.scala | 10 +-
.../workflow/WorkflowVersionResourceSpec.scala | 14 +-
.../web/service/ExecutionConsoleServiceSpec.scala | 7 +-
.../web/service/ExecutionResultServiceSpec.scala | 4 +-
.../storage/ReadonlyLocalFileDocumentSpec.scala | 6 +-
core/auth/build.sbt | 2 +-
.../ics => org/apache}/texera/auth/JwtAuth.scala | 6 +-
.../apache}/texera/auth/JwtAuthFilter.scala | 11 +-
.../ics => org/apache}/texera/auth/JwtParser.scala | 8 +-
.../apache}/texera/auth/SessionUser.scala | 6 +-
.../texera/auth/util/ComputingUnitAccess.scala | 9 +-
.../apache}/texera/auth/util/HeaderField.scala | 2 +-
core/build.sbt | 5 +-
core/computing-unit-managing-service/build.sbt | 2 +-
.../service/ComputingUnitManagingService.scala | 22 +-
...ComputingUnitManagingServiceConfiguration.scala | 2 +-
.../resource/ComputingUnitAccessResource.scala | 32 +-
.../resource/ComputingUnitManagingResource.scala | 96 +++--
.../service/resource/ComputingUnitState.scala | 2 +-
.../service/resource/HealthCheckResource.scala | 2 +-
.../texera/service/util/ComputingUnitHelpers.scala | 10 +-
.../ComputingUnitManagingServiceException.scala | 2 +-
.../texera/service/util/KubernetesClient.scala | 4 +-
core/config-service/build.sbt | 2 +-
.../apache}/texera/service/ConfigService.scala | 18 +-
.../service/ConfigServiceConfiguration.scala | 2 +-
.../texera/service/resource/ConfigResource.scala | 9 +-
.../service/resource/HealthCheckResource.scala | 2 +-
core/config/build.sbt | 2 +-
core/config/src/main/resources/cluster.conf | 2 +-
core/config/src/main/resources/gui.conf | 4 +-
core/config/src/main/resources/storage.conf | 6 +
core/config/src/main/resources/udf.conf | 2 +-
core/config/src/main/resources/user-system.conf | 3 -
.../apache}/amber/config/AkkaConfig.scala | 2 +-
.../apache}/amber/config/ApplicationConfig.scala | 2 +-
.../amber/config/EnvironmentalVariable.scala | 2 +-
.../apache}/amber/config/StorageConfig.scala | 13 +-
.../apache}/amber/config/UdfConfig.scala | 2 +-
.../apache}/amber/util/ConfigParserUtil.scala | 2 +-
.../ics => org/apache}/amber/util/PathUtils.scala | 2 +-
.../apache}/texera/config/AuthConfig.scala | 2 +-
.../texera/config/ComputingUnitConfig.scala | 2 +-
.../apache}/texera/config/DefaultsConfig.scala | 3 +-
.../apache}/texera/config/GuiConfig.scala | 2 +-
.../apache}/texera/config/KubernetesConfig.scala | 2 +-
.../apache}/texera/config/UserSystemConfig.scala | 3 +-
core/dao/.gitignore | 2 +-
core/dao/build.sbt | 7 +-
core/dao/src/main/resources/jooq-conf.xml | 2 +-
.../apache}/texera/dao/JooqCodeGenerator.scala | 4 +-
.../ics => org/apache}/texera/dao/SqlServer.scala | 6 +-
.../apache}/texera/dao/MockTexeraDB.scala | 12 +-
core/file-service/build.sbt | 8 +-
.../src/main/resources/docker-compose.yml | 26 +-
.../apache}/texera/service/FileService.scala | 26 +-
.../texera/service/FileServiceConfiguration.scala | 2 +-
.../service/resource/DatasetAccessResource.scala | 30 +-
.../texera/service/resource/DatasetResource.scala | 265 +++++++-----
.../service/resource/HealthCheckResource.scala | 2 +-
.../service/type/dataset/DatasetFileNode.scala | 4 +-
.../type/serde/DatasetFileNodeSerializer.java | 4 +-
.../texera/service/util/S3StorageClient.scala | 6 +-
.../org/apache/texera/service/MockLakeFS.scala | 118 +++++
.../service/resource/DatasetResourceSpec.scala | 206 +++++++++
core/gui/src/app/app-routing.module.ts | 13 +-
core/gui/src/app/app.module.ts | 13 +-
.../preset-wrapper/preset-wrapper.component.ts | 2 +-
.../src/app/common/service/gmail/gmail.service.ts | 1 +
.../app/common/service/gui-config.service.mock.ts | 1 -
.../src/app/common/service/gui-config.service.ts | 6 +-
.../app/common/service/user/auth-guard.service.ts | 4 +-
.../src/app/common/service/user/auth.service.ts | 9 +-
.../service/user/config/user-config.service.ts | 1 -
.../app/common/service/user/stub-auth.service.ts | 2 +-
.../src/app/common/service/user/user.service.ts | 7 +-
.../workflow-persist/workflow-persist.service.ts | 2 +-
core/gui/src/app/common/type/gui-config.ts | 1 -
core/gui/src/app/common/type/physical-plan.ts | 4 +-
.../apache}/amber/engine/common/virtualidentity.ts | 4 +-
.../apache}/amber/engine/common/workflow.ts | 4 +-
core/gui/src/app/common/type/user.ts | 2 +-
core/gui/src/app/common/type/workflow.ts | 2 +-
.../gui/src/app/common/util/port-identity-serde.ts | 4 +-
.../component/admin/gmail/admin-gmail.component.ts | 1 +
.../admin/settings/admin-settings.component.html | 39 +-
.../admin/settings/admin-settings.component.scss | 6 +
.../admin/settings/admin-settings.component.ts | 20 +-
.../component/admin/user/admin-user.component.ts | 2 +-
.../dashboard/component/dashboard.component.html | 2 +-
.../dashboard/component/dashboard.component.scss | 15 +-
.../component/dashboard.component.spec.ts | 14 +-
.../app/dashboard/component/dashboard.component.ts | 2 +-
.../files-uploader/files-uploader.component.ts | 8 +-
.../filters-instructions.component.ts | 2 +-
.../user/search-bar/search-bar.component.ts | 2 +-
.../search-results/search-results.component.ts | 2 +-
.../component/user/search/search.component.ts | 2 +-
.../user/share-access/share-access.component.html | 4 +-
.../user/share-access/share-access.component.ts | 2 +-
.../user/user-avatar/user-avatar.component.ts | 1 +
.../dataset-detail.component.html | 58 ++-
.../dataset-detail.component.scss | 1 -
.../dataset-detail.component.ts | 27 +-
.../user-dataset-file-renderer.component.ts | 2 +-
...user-dataset-staged-objects-list.component.html | 3 +-
...user-dataset-staged-objects-list.component.scss | 4 +
.../user-dataset-version-creator.component.ts | 4 +-
.../user-dataset-version-filetree.component.ts | 2 +-
.../user/user-dataset/user-dataset.component.ts | 6 +-
.../user/user-quota/user-quota.component.ts | 4 +-
.../highlight-search-terms.pipe.ts | 1 +
.../user-workflow/user-workflow.component.spec.ts | 5 +-
.../service/admin/user/admin-user.service.ts | 4 +-
.../service/user/dataset/dataset.service.ts | 23 +-
.../service/user/download/download.service.ts | 138 ++++--
.../service/user/quota/user-quota.service.ts | 2 +-
.../user/share-access/share-access.service.ts | 1 +
.../dashboard/service/user/stub-search.service.ts | 2 +-
.../dashboard/type/dashboard-dataset.interface.ts | 3 +-
.../app/dashboard/type/dashboard-file.interface.ts | 2 +-
.../app/dashboard/type/search-filter-parameters.ts | 1 -
.../hub/component/about/about.component.spec.ts | 2 -
.../browse-section/browse-section.component.ts | 8 +-
core/gui/src/app/hub/component/hub.component.ts | 2 +-
.../landing-page/landing-page.component.ts | 3 +-
.../annotation-suggestion.component.ts | 2 +-
.../breakpoint-condition-input.component.ts | 13 +-
.../codearea-custom-template.component.ts | 2 +-
.../input-autocomplete.component.ts | 2 +-
.../component/left-panel/left-panel.component.ts | 6 +-
.../workspace/component/menu/menu.component.html | 57 +--
.../app/workspace/component/menu/menu.component.ts | 23 +-
.../computing-unit-selection.component.html | 16 +
.../computing-unit-selection.component.spec.ts | 4 -
.../computing-unit-selection.component.ts | 4 +-
.../operator-property-edit-frame.component.ts | 1 -
.../property-editor/property-editor.component.ts | 7 +-
.../type-casting-display.component.spec.ts | 2 +-
.../result-exportation.component.html | 248 ++++++-----
.../result-exportation.component.ts | 108 ++++-
.../error-frame/error-frame.component.ts | 7 +-
.../result-panel/result-panel.component.ts | 9 +-
.../result-table-frame.component.ts | 8 +-
.../visualization-frame-content.component.ts | 2 +-
.../nz-modal-comment-box.component.scss | 5 +-
.../nz-modal-comment-box.component.ts | 3 +-
.../context-menu/context-menu.component.spec.ts | 2 +-
.../workflow-editor.component.spec.ts | 100 +++--
.../workflow-editor/workflow-editor.component.ts | 49 +--
.../app/workspace/component/workspace.component.ts | 108 ++---
.../service/ai-analyst/ai-analyst.service.ts | 2 +-
.../service/ai-assistant/ai-assistant.service.ts | 4 +-
.../compile-workflow/workflow-compiling.service.ts | 2 +-
.../computing-unit-status.service.ts | 4 +-
.../dynamic-schema/dynamic-schema.service.spec.ts | 9 +-
.../dynamic-schema/dynamic-schema.service.ts | 3 +-
.../execute-workflow.service.spec.ts | 2 -
.../execute-workflow/execute-workflow.service.ts | 6 +-
.../service/execute-workflow/mock-result-data.ts | 2 +-
.../service/execute-workflow/mock-workflow-plan.ts | 4 +-
.../workspace/service/joint-ui/joint-ui.service.ts | 1 +
.../service/undo-redo/undo-redo.service.spec.ts | 4 +-
.../validation/validation-workflow.service.ts | 3 +-
.../workflow-cache/workflow-cache.service.spec.ts | 234 ----------
.../workflow-cache/workflow-cache.service.ts | 41 --
.../workflow-computing-unit-managing.service.ts | 1 -
.../workflow-console/workflow-console.service.ts | 3 +-
.../model/shared-model-change-handler.ts | 36 +-
.../service/workflow-graph/model/shared-model.ts | 2 +-
.../workflow-graph/model/sync-texera-model.spec.ts | 1 -
.../model/workflow-action.service.spec.ts | 18 +-
.../model/workflow-action.service.ts | 3 +-
.../service/workflow-graph/model/workflow-graph.ts | 16 +-
.../util/workflow-util.service.spec.ts | 2 +-
.../workflow-graph/util/workflow-util.service.ts | 4 +-
.../workflow-result-export.service.spec.ts | 38 +-
.../workflow-result-export.service.ts | 291 ++++++++++---
.../workflow-result.service.spec.ts | 2 +-
.../workflow-result/workflow-result.service.ts | 4 +-
.../operator-reuse-cache-status.service.ts | 1 +
.../workflow-websocket.service.ts | 4 +-
.../workspace/types/execute-workflow.interface.ts | 3 +-
.../workspace/types/workflow-common.interface.ts | 2 +-
.../app/workspace/types/workflow-computing-unit.ts | 2 +
.../types/workflow-websocket.interface.ts | 2 +-
core/gui/src/assets/svg/hub_icon.svg | 20 +-
.../assets/svg/operator-reuse-cache-invalid.svg | 3 +-
.../src/assets/svg/operator-reuse-cache-valid.svg | 3 +-
core/gui/src/environments/environment.default.ts | 2 -
core/gui/src/styles.scss | 6 +
core/gui/yarn.lock | 75 +++-
.../src/language-server-runner.ts | 6 +-
core/pyright-language-server/src/main.ts | 8 +-
core/pyright-language-server/src/server-commons.ts | 16 +-
core/scripts/sql/texera_ddl.sql | 18 +-
core/scripts/sql/updates/15.sql | 38 ++
core/workflow-compiling-service/build.sbt | 2 +-
.../service/resource/HealthCheckResource.scala | 30 --
.../apache}/amber/compiler/WorkflowCompiler.scala | 16 +-
.../apache}/amber/compiler/model/LogicalLink.scala | 6 +-
.../apache}/amber/compiler/model/LogicalPlan.scala | 12 +-
.../amber/compiler/model/LogicalPlanPojo.scala | 4 +-
.../texera/service/WorkflowCompilingService.scala | 15 +-
.../WorkflowCompilingServiceConfiguration.scala | 2 +-
.../service/resource/HealthCheckResource.scala | 2 +-
.../resource/WorkflowCompilationResource.scala | 18 +-
.../resource/WorkflowCompilationResourceSpec.scala | 28 +-
core/workflow-core/build.sbt | 2 +-
.../ics => org/apache}/amber/core/executor.proto | 4 +-
.../apache}/amber/core/virtualidentity.proto | 2 +-
.../ics => org/apache}/amber/core/workflow.proto | 4 +-
.../apache}/amber/core/workflowruntimestate.proto | 2 +-
.../storage/result/ExecutionResourcesMapping.scala | 75 ----
.../amber/core/WorkflowRuntimeException.scala | 4 +-
.../apache}/amber/core/executor/ExecFactory.scala | 2 +-
.../core/executor/JavaRuntimeCompilation.scala | 4 +-
.../amber/core/executor/OperatorExecutor.scala | 8 +-
.../core/executor/SourceOperatorExecutor.scala | 6 +-
.../apache}/amber/core/state/State.scala | 5 +-
.../amber/core/storage/DocumentFactory.scala | 20 +-
.../apache}/amber/core/storage/FileResolver.scala | 78 +++-
.../core/storage/IcebergCatalogInstance.scala | 6 +-
.../apache}/amber/core/storage/VFSURIFactory.scala | 14 +-
.../core/storage/model/BufferedItemWriter.scala | 2 +-
.../core/storage/model/DatasetFileDocument.scala | 32 +-
.../amber/core/storage/model/OnDataset.scala | 4 +-
.../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 | 18 +-
.../result/iceberg/IcebergTableWriter.scala | 10 +-
.../core/storage/result/iceberg/OnIceberg.scala | 4 +-
.../core/storage/util/LakeFSStorageClient.scala | 22 +-
.../amber/core/storage/util/StorageUtil.scala | 2 +-
.../dataset/GitVersionControlLocalFileStorage.java | 2 +-
.../storage/util/dataset/JGitVersionControl.java | 2 +-
.../storage/util/dataset/PhysicalFileNode.java | 8 +-
.../apache}/amber/core/tuple/Attribute.java | 4 +-
.../apache}/amber/core/tuple/AttributeType.java | 13 +-
.../amber/core/tuple/AttributeTypeUtils.scala | 2 +-
.../apache}/amber/core/tuple/Schema.scala | 2 +-
.../apache}/amber/core/tuple/Tuple.scala | 4 +-
.../apache}/amber/core/tuple/TupleLike.scala | 4 +-
.../apache}/amber/core/tuple/TupleUtils.scala | 11 +-
.../amber/core/workflow/LocationPreference.scala | 2 +-
.../amber/core/workflow/PartitionInfo.scala | 2 +-
.../apache}/amber/core/workflow/PhysicalOp.scala | 8 +-
.../apache}/amber/core/workflow/PhysicalPlan.scala | 9 +-
.../amber/core/workflow/WorkflowContext.scala | 6 +-
.../amber/core/workflow/WorkflowSettings.scala | 2 +-
.../ics => org/apache}/amber/util/ArrowUtils.scala | 8 +-
.../apache}/amber/util/IcebergUtil.scala | 14 +-
.../ics => org/apache}/amber/util/JSONUtils.scala | 6 +-
.../apache}/amber/util/VirtualIdentityUtils.scala | 4 +-
.../amber/util/serde/GlobalPortIdentitySerde.scala | 6 +-
.../util/serde/PortIdentityKeyDeserializer.scala | 4 +-
.../util/serde/PortIdentityKeySerializer.scala | 6 +-
.../core/storage/model/VirtualDocumentSpec.scala | 2 +-
.../amber/core/tuple/AttributeTypeUtilsSpec.scala | 6 +-
.../apache}/amber/core/tuple/SchemaSpec.scala | 2 +-
.../apache}/amber/core/tuple/TupleSpec.scala | 4 +-
.../apache}/amber/storage/FileResolverSpec.scala | 19 +-
.../IcebergDocumentConsoleMessagesSpec.scala | 16 +-
.../result/iceberg/IcebergDocumentSpec.scala | 14 +-
.../result/iceberg/IcebergTableStatsSpec.scala | 18 +-
.../apache}/amber/util/IcebergUtilSpec.scala | 8 +-
core/workflow-operator/build.sbt | 2 +-
.../jackson/jsonSchema/JsonSchemaGenerator.scala | 10 +-
.../apache}/amber/operator/DummyProperties.scala | 2 +-
.../apache}/amber/operator/LogicalOp.scala | 223 +++++-----
.../apache}/amber/operator/PortDescriptor.scala | 4 +-
.../amber/operator/PythonOperatorDescriptor.scala | 10 +-
.../amber/operator/SpecialPhysicalOpFactory.scala | 12 +-
.../apache}/amber/operator/TestOperators.scala | 22 +-
.../amber/operator/aggregate/AggregateOpDesc.scala | 22 +-
.../amber/operator/aggregate/AggregateOpExec.scala | 8 +-
.../operator/aggregate/AggregationFunction.java | 2 +-
.../operator/aggregate/AggregationOperation.scala | 8 +-
.../aggregate/DistributedAggregation.scala | 4 +-
.../cartesianProduct/CartesianProductOpDesc.scala | 16 +-
.../cartesianProduct/CartesianProductOpExec.scala | 9 +-
.../dictionary/DictionaryMatcherOpDesc.scala | 20 +-
.../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 +-
.../apache}/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 | 15 +-
.../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 +-
.../apache}/amber/operator/hashJoin/JoinType.java | 2 +-
.../HuggingFaceIrisLogisticRegressionOpDesc.scala | 12 +-
.../HuggingFaceSentimentAnalysisOpDesc.scala | 12 +-
.../HuggingFaceSpamSMSDetectionOpDesc.scala | 12 +-
.../HuggingFaceTextSummarizationOpDesc.scala | 12 +-
.../amber/operator/ifStatement/IfOpDesc.scala | 22 +-
.../amber/operator/ifStatement/IfOpExec.scala | 12 +-
.../amber/operator/intersect/IntersectOpDesc.scala | 14 +-
.../amber/operator/intersect/IntersectOpExec.scala | 6 +-
.../operator/intervalJoin/IntervalJoinOpDesc.scala | 21 +-
.../operator/intervalJoin/IntervalJoinOpExec.scala | 13 +-
.../operator/intervalJoin/TimeIntervalType.java | 2 +-
.../keywordSearch/KeywordSearchOpDesc.scala | 19 +-
.../keywordSearch/KeywordSearchOpExec.scala | 8 +-
.../apache}/amber/operator/limit/LimitOpDesc.scala | 17 +-
.../apache}/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 | 5 +-
.../sklearnAdvanced/base/HyperParameters.java | 6 +-
.../base/SklearnAdvancedBaseDesc.scala | 12 +-
.../apache}/amber/operator/map/MapOpDesc.scala | 8 +-
.../apache}/amber/operator/map/MapOpExec.scala | 6 +-
.../apache}/amber/operator/metadata/OPVersion.java | 4 +-
.../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 | 5 +-
.../operator/projection/ProjectionOpDesc.scala | 20 +-
.../operator/projection/ProjectionOpExec.scala | 8 +-
.../randomksampling/RandomKSamplingOpDesc.scala | 16 +-
.../randomksampling/RandomKSamplingOpExec.scala | 6 +-
.../apache}/amber/operator/regex/RegexOpDesc.scala | 19 +-
.../apache}/amber/operator/regex/RegexOpExec.scala | 8 +-
.../ReservoirSamplingOpDesc.scala | 17 +-
.../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 +-
.../apache}/amber/operator/sleep/SleepOpDesc.scala | 16 +-
.../apache}/amber/operator/sleep/SleepOpExec.scala | 8 +-
.../amber/operator/sort/SortCriteriaUnit.java | 6 +-
.../apache}/amber/operator/sort/SortOpDesc.scala | 10 +-
.../amber/operator/sort/SortPreference.java | 2 +-
.../sortPartitions/SortPartitionsOpDesc.scala | 19 +-
.../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 | 19 +-
.../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 | 17 +-
.../operator/source/scan/ScanSourceOpDesc.scala | 12 +-
.../source/scan/arrow/ArrowSourceOpDesc.scala | 28 +-
.../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 | 21 +-
.../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 | 27 +-
.../sql/asterixdb/AsterixDBSourceOpExec.scala | 12 +-
.../operator/source/sql/mysql/MySQLConnUtil.scala | 2 +-
.../source/sql/mysql/MySQLSourceOpDesc.scala | 19 +-
.../source/sql/mysql/MySQLSourceOpExec.scala | 10 +-
.../source/sql/postgresql/PostgreSQLConnUtil.scala | 2 +-
.../sql/postgresql/PostgreSQLSourceOpDesc.scala | 21 +-
.../sql/postgresql/PostgreSQLSourceOpExec.scala | 10 +-
.../apache}/amber/operator/split/SplitOpDesc.scala | 18 +-
.../apache}/amber/operator/split/SplitOpExec.scala | 10 +-
.../SymmetricDifferenceOpDesc.scala | 21 +-
.../SymmetricDifferenceOpExec.scala | 7 +-
.../operator/timeSeriesPlot/TimeSeriesPlot.scala | 14 +-
.../operator/typecasting/TypeCastingOpDesc.scala | 19 +-
.../operator/typecasting/TypeCastingOpExec.scala | 8 +-
.../operator/typecasting/TypeCastingUnit.java | 6 +-
.../amber/operator/udf/java/JavaUDFOpDesc.scala | 26 +-
.../python/DualInputPortsPythonUDFOpDescV2.scala | 15 +-
.../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 | 15 +-
.../apache}/amber/operator/udf/r/RUDFOpDesc.scala | 20 +-
.../amber/operator/udf/r/RUDFSourceOpDesc.scala | 15 +-
.../apache}/amber/operator/union/UnionOpDesc.scala | 14 +-
.../apache}/amber/operator/union/UnionOpExec.scala | 6 +-
.../operator/unneststring/UnnestStringOpDesc.scala | 21 +-
.../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 | 17 +-
.../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 | 15 +-
.../histogram2d/NormalizationType.java | 2 +-
.../visualization/htmlviz/HtmlVizOpDesc.scala | 22 +-
.../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 +-
.../visualization/tablesChart/TablesConfig.scala | 4 +-
.../tablesChart/TablesPlotOpDesc.scala | 12 +-
.../ternaryPlot/TernaryPlotOpDesc.scala | 14 +-
.../visualization/treeplot/TreeplotOpDesc.scala | 14 +-
.../visualization/urlviz/UrlVizOpDesc.scala | 22 +-
.../visualization/urlviz/UrlVizOpExec.scala | 8 +-
.../volcanoPlot/VolcanoPlotOpDesc.scala | 14 +-
.../waterfallChart/WaterfallChartOpDesc.scala | 14 +-
.../visualization/wordCloud/WordCloudOpDesc.scala | 16 +-
.../apache}/amber/util/ObjectMapperUtils.scala | 4 +-
.../CartesianProductOpExecSpec.scala | 15 +-
.../dictionary/DictionaryMatcherOpExecSpec.scala | 8 +-
.../operator/difference/DifferenceOpExecSpec.scala | 4 +-
.../operator/distinct/DistinctOpExecSpec.scala | 4 +-
.../filter/SpecializedFilterOpExecSpec.scala | 6 +-
.../amber/operator/hashJoin/HashJoinOpSpec.scala | 18 +-
.../operator/intersect/IntersectOpExecSpec.scala | 8 +-
.../operator/intervalJoin/IntervalOpExecSpec.scala | 17 +-
.../keywordSearch/KeywordSearchOpExecSpec.scala | 6 +-
.../operator/projection/ProjectionOpDescSpec.scala | 6 +-
.../operator/projection/ProjectionOpExecSpec.scala | 6 +-
.../sortPartitions/SortPartitionsOpExecSpec.scala | 6 +-
.../source/fetcher/URLFetcherOpExecSpec.scala | 6 +-
.../source/scan/csv/CSVScanSourceOpDescSpec.scala | 10 +-
.../scan/text/FileScanSourceOpDescSpec.scala | 12 +-
.../scan/text/TextInputSourceOpDescSpec.scala | 10 +-
.../SymmetricDifferenceOpExecSpec.scala | 11 +-
.../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 +-
.../apache}/amber/util/ArrowUtilsSpec.scala | 6 +-
deployment/access-control-service.dockerfile | 54 +++
.../files/iceberg_postgres_catalog.sql | 1 +
.../k8s/texera-helmchart/files/texera_ddl.sql | 470 +-------------------
.../k8s/texera-helmchart/files/texera_lakefs.sql | 1 +
.../access-control-service-deployment.yaml | 60 +++
...ig.yaml => access-control-service-service.yaml} | 24 +-
.../texera-helmchart/templates/envoy-config.yaml | 42 ++
.../templates/envoy-deployment.yaml | 2 +-
.../templates/postgresql-init-script-config.yaml | 20 +-
deployment/k8s/texera-helmchart/values.yaml | 11 +-
deployment/pylsp/Dockerfile | 3 +-
1022 files changed, 7165 insertions(+), 6584 deletions(-)
create mode 100644 .github/ISSUE_TEMPLATE/bug-template.yaml
create mode 100644 .github/labeler.yml
create mode 100644 .github/workflows/pr-labeler.yml
delete mode 100644 core/access-control-service/src/main/scala/edu/uci/ics/texera/service/resource/AccessControlResource.scala
rename core/access-control-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/AccessControlService.scala (84%)
rename core/access-control-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/AccessControlServiceConfiguration.scala (96%)
create mode 100644 core/access-control-service/src/main/scala/org/apache/texera/service/resource/AccessControlResource.scala
copy core/access-control-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/resource/HealthCheckResource.scala (96%)
rename core/access-control-service/src/test/scala/{edu/uci/ics => org/apache}/texera/AccessControlResourceSpec.scala (88%)
rename core/amber/src/main/protobuf/{edu/uci/ics => org/apache}/amber/engine/architecture/rpc/controlcommands.proto (91%)
rename core/amber/src/main/protobuf/{edu/uci/ics => org/apache}/amber/engine/architecture/rpc/controllerservice.proto (91%)
rename core/amber/src/main/protobuf/{edu/uci/ics => org/apache}/amber/engine/architecture/rpc/controlreturns.proto (93%)
rename core/amber/src/main/protobuf/{edu/uci/ics => org/apache}/amber/engine/architecture/rpc/testerservice.proto (89%)
rename core/amber/src/main/protobuf/{edu/uci/ics => org/apache}/amber/engine/architecture/rpc/workerservice.proto (92%)
rename core/amber/src/main/protobuf/{edu/uci/ics => org/apache}/amber/engine/architecture/sendsemantics/partitionings.proto (94%)
rename core/amber/src/main/protobuf/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/statistics.proto (94%)
rename core/amber/src/main/protobuf/{edu/uci/ics => org/apache}/amber/engine/common/actormessage.proto (96%)
rename core/amber/src/main/protobuf/{edu/uci/ics => org/apache}/amber/engine/common/ambermessage.proto (86%)
rename core/amber/src/main/protobuf/{edu/uci/ics => org/apache}/amber/engine/common/executionruntimestate.proto (88%)
delete mode 100644 core/amber/src/main/python/proto/edu/uci/ics/texera/__init__.py
rename core/amber/src/main/python/proto/{edu => org}/__init__.py (100%)
rename core/amber/src/main/python/proto/{edu/uci => org/apache}/__init__.py (100%)
rename core/amber/src/main/python/proto/{edu/uci/ics => org/apache/amber}/__init__.py (100%)
rename core/amber/src/main/python/proto/{edu/uci/ics => org/apache}/amber/core/__init__.py (96%)
rename core/amber/src/main/python/proto/{edu/uci/ics/amber => org/apache/amber/engine}/__init__.py (100%)
rename core/amber/src/main/python/proto/{edu/uci/ics/amber/engine => org/apache/amber/engine/architecture}/__init__.py (100%)
rename core/amber/src/main/python/proto/{edu/uci/ics => org/apache}/amber/engine/architecture/rpc/__init__.py (88%)
rename core/amber/src/main/python/proto/{edu/uci/ics => org/apache}/amber/engine/architecture/sendsemantics/__init__.py (97%)
rename core/amber/src/main/python/proto/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/__init__.py (96%)
rename core/amber/src/main/python/proto/{edu/uci/ics => org/apache}/amber/engine/common/__init__.py (97%)
rename core/amber/src/main/python/proto/{edu/uci/ics/amber/engine/architecture => org/apache/texera}/__init__.py (100%)
rename core/amber/src/main/python/proto/{edu/uci/ics => org/apache}/texera/web/__init__.py (98%)
delete mode 100644 core/amber/src/main/scala/edu/uci/ics/texera/web/ServletAwareConfigurator.scala
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/clustering/ClusterListener.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/clustering/SingleNodeListener.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/common/AkkaActorRefMappingService.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/common/AkkaActorService.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/common/AkkaMessageTransferService.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/common/AmberProcessor.scala (75%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/common/ExecutorDeployment.scala (81%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/common/ProcessingStepCursor.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/common/WorkflowActor.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/ClientEvent.scala (80%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/Controller.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/ControllerAsyncRPCHandlerInitializer.scala (76%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/ControllerProcessor.scala (80%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/ControllerTimerService.scala (80%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/GlobalReplayManager.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/Workflow.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/WorkflowScheduler.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/execution/ChannelExecution.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/execution/ExecutionUtils.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/execution/LinkExecution.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/execution/OperatorExecution.scala (85%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/execution/RegionExecution.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/execution/WorkerPortExecution.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/execution/WorkflowExecution.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/ConsoleMessageHandler.scala (79%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/DebugCommandHandler.scala (75%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/EmbeddedControlMessageHandler.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/EvaluatePythonExpressionHandler.scala (82%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/LinkWorkersHandler.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/PauseHandler.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/PortCompletedHandler.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/QueryWorkerStatisticsHandler.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/ResumeHandler.scala (85%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/RetrieveWorkflowStateHandler.scala (76%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/RetryWorkflowHandler.scala (80%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/StartWorkflowHandler.scala (77%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/TakeGlobalCheckpointHandler.scala (82%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/WorkerExecutionCompletedHandler.scala (86%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/promisehandlers/WorkerStateUpdatedHandler.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/deploysemantics/AddressInfo.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/deploysemantics/deploystrategy/DeployStrategy.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/deploysemantics/deploystrategy/OneOnEach.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/deploysemantics/deploystrategy/RandomDeployment.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/deploysemantics/deploystrategy/RoundRobinDeployment.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/deploysemantics/layer/WorkerExecution.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/logreplay/AsyncReplayLogWriter.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/logreplay/EmptyReplayLogger.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/logreplay/OrderEnforcer.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/logreplay/ReplayLogGenerator.scala (86%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/logreplay/ReplayLogManager.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/logreplay/ReplayLogger.scala (83%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/logreplay/ReplayLoggerImpl.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/logreplay/ReplayOrderEnforcer.scala (95%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/AmberFIFOChannel.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/CongestionControl.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/DeadLetterMonitorActor.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/FlowControl.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/InputGateway.scala (86%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/InputManager.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/NetworkInputGateway.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/NetworkOutputGateway.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/OrderingEnforcer.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/OutputManager.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/WorkerPort.scala (85%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/WorkerTimerService.scala (78%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/pythonworker/PythonProxyClient.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/pythonworker/PythonProxyServer.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/pythonworker/PythonWorkflowWorker.scala (86%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/pythonworker/WorkerBatchInternalQueue.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/CostBasedScheduleGenerator.scala (97%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/CostEstimator.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/ExpansionGreedyScheduleGenerator.scala (97%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/Region.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/RegionExecutionCoordinator.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/RegionPlan.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/Schedule.scala (95%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/ScheduleGenerator.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/SchedulingUtils.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/WorkflowExecutionCoordinator.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/config/ChannelConfig.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/config/LinkConfig.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/config/OperatorConfig.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/config/PortConfig.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/config/ResourceConfig.scala (83%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/config/WorkerConfig.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/resourcePolicies/ExecutionClusterInfo.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/resourcePolicies/ResourceAllocator.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/sendsemantics/partitioners/BroadcastPartitioner.scala (80%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/sendsemantics/partitioners/HashBasedShufflePartitioner.scala (83%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/sendsemantics/partitioners/OneToOnePartitioner.scala (80%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/sendsemantics/partitioners/Partitioner.scala (79%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/sendsemantics/partitioners/RangeBasedShufflePartitioner.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/sendsemantics/partitioners/RoundRobinPartitioner.scala (81%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/DPThread.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/DataProcessor.scala (86%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/DataProcessorRPCHandlerInitializer.scala (79%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/EmbeddedControlMessageManager.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/PauseManager.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/PauseType.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/WorkflowWorker.scala (86%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/managers/InputPortMaterializationReaderThread.scala (80%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/managers/OutputPortResultWriterThread.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/managers/SerializationManager.scala (81%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/managers/StatisticsManager.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/AddInputChannelHandler.scala (76%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/AddPartitioningHandler.scala (75%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/AssignPortHandler.scala (77%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/EndChannelHandler.scala (83%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/EndHandler.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/FinalizeCheckpointHandler.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/FlushNetworkBufferHandler.scala (76%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/InitializeExecutorHandler.scala (79%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/OpenExecutorHandler.scala (76%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/PauseHandler.scala (73%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/PrepareCheckpointHandler.scala (85%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/QueryStatisticsHandler.scala (73%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/ResumeHandler.scala (74%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/RetrieveStateHandler.scala (76%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/StartChannelHandler.scala (71%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/promisehandlers/StartHandler.scala (76%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/AmberConfig.scala (95%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/AmberKryoInitializer.scala (97%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/AmberLogging.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/AmberRuntime.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/CheckpointState.scala (97%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/CheckpointSupport.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/ElidableStatement.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/FutureBijection.scala (97%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/SerializedState.scala (97%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/Utils.scala (98%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/amberexception/BreakpointException.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/ambermessage/DataPayload.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/ambermessage/DirectControlMessagePayload.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/ambermessage/RecoveryPayload.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/ambermessage/WorkflowFIFOMessagePayload.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/ambermessage/WorkflowMessage.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/client/AmberClient.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/client/ClientActor.scala (82%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/rpc/AsyncRPCClient.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/rpc/AsyncRPCHandlerInitializer.scala (83%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/rpc/AsyncRPCServer.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/statetransition/StateManager.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/statetransition/WorkerStateManager.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/storage/EmptyRecordStorage.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/storage/HDFSRecordStorage.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/storage/SequentialRecordStorage.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/storage/VFSRecordStorage.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/engine/common/virtualidentity/util.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/amber/error/ErrorUtils.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/ComputingUnitMaster.scala (75%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/ComputingUnitWorker.scala (95%)
create mode 100644 core/amber/src/main/scala/org/apache/texera/web/ServletAwareConfigurator.scala
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/SessionState.scala (82%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/SubscriptionManager.scala (97%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/TexeraWebApplication.scala (82%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/TexeraWebConfiguration.java (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/WebsocketInput.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/WorkflowLifecycleManager.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/auth/GuestAuthFilter.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/auth/JwtAuth.scala (56%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/auth/UserAuthenticator.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/auth/UserRoleAuthorizer.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/event/CollabWebSocketEvent.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/event/CommandEvent.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/event/LockGrantedEvent.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/event/LockRejectedEvent.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/event/ReleaseLockEvent.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/event/RestoreVersionEvent.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/event/WorkflowAccessEvent.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/request/AcquireLockRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/request/CollabWebSocketRequest.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/request/CommandRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/request/HeartBeatRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/request/RestoreVersionRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/request/TryLockRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/request/WIdRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/collab/response/HeartBeatResponse.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/common/AccessEntry.scala (95%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/http/request/auth/UserLoginRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/http/request/auth/UserRegistrationRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/http/request/result/ResultExportRequest.scala (81%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/http/response/SchemaPropagationResponse.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/http/response/TokenIssueResponse.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/http/response/result/ResultExportResponse.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/CacheStatusUpdateEvent.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/ExecutionDurationUpdateEvent.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/ExecutionStatusEnum.scala (100%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/OperatorStatisticsUpdateEvent.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/PaginatedResultEvent.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/TexeraWebSocketEvent.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/WebResultUpdateEvent.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/WorkerAssignmentUpdateEvent.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/WorkflowAvailableResultEvent.scala (82%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/WorkflowErrorEvent.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/WorkflowStateEvent.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/event/python/ConsoleUpdateEvent.scala (81%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/EditingTimeCompilationRequest.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/HeartBeatRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/ModifyLogicRequest.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/ResultPaginationRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/RetryRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/SkipTupleRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/TexeraWebSocketRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/WorkflowCheckpointRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/WorkflowExecuteRequest.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/WorkflowKillRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/WorkflowPauseRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/WorkflowResumeRequest.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/python/DebugCommandRequest.scala (86%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/request/python/PythonExpressionEvaluateRequest.scala (86%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/response/ClusterStatusUpdateEvent.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/response/HeartBeatResponse.scala (87%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/response/ModifyLogicResponse.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/model/websocket/response/python/PythonExpressionEvaluateResponse.scala (81%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/CollaborationResource.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/EmailTemplate.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/GmailResource.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/HealthCheckResource.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/MockKillWorkerResource.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/SuccessExecutionResult.scala (95%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/SystemMetadataResource.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/UserConfigResource.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/WebsocketPayloadSizeTuner.scala (97%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/WorkflowWebsocketResource.scala (76%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/aiassistant/AiAssistantManager.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/aiassistant/AiAssistantResource.scala (98%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/aiassistant/test_type_annotation_visitor.py (100%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/aiassistant/type_annotation_visitor.py (100%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/auth/AuthResource.scala (79%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/auth/GoogleAuthResource.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/DashboardResource.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/DatasetSearchQueryBuilder.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/FulltextSearchQueryUtils.scala (99%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/ProjectSearchQueryBuilder.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/SearchQueryBuilder.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/UnifiedResourceSchema.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/WorkflowSearchQueryBuilder.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/admin/execution/AdminExecutionResource.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/admin/settings/AdminSettingsResource.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/admin/user/AdminUserResource.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/hub/ActionType.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/hub/EntityTables.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/hub/EntityType.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/hub/HubResource.scala (94%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/dataset/DatasetResource.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/dataset/utils/DatasetStatisticsUtils.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/project/ProjectAccessResource.scala (89%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/project/ProjectResource.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/project/PublicProjectResource.scala (85%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/quota/UserQuotaResource.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/workflow/WorkflowAccessResource.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/workflow/WorkflowExecutionsResource.scala (64%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/workflow/WorkflowResource.scala (96%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/workflow/WorkflowVersionResource.scala (95%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/EmailNotificationService.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/ExecutionConsoleService.scala (81%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/ExecutionReconfigurationService.scala (88%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/ExecutionResultService.scala (91%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/ExecutionRuntimeService.scala (84%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/ExecutionStatsService.scala (64%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/ExecutionsMetadataPersistService.scala (81%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/FriesReconfigurationAlgorithm.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/ResultExportService.scala (82%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/WorkflowEmailNotifier.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/WorkflowExecutionService.scala (79%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/service/WorkflowService.scala (78%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/storage/ExecutionReconfigurationStore.scala (83%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/storage/ExecutionStateStore.scala (86%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/storage/StateStore.scala (93%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/web/storage/WorkflowStateStore.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/workflow/LogicalLink.scala (90%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/workflow/LogicalPlan.scala (92%)
rename core/amber/src/main/scala/{edu/uci/ics => org/apache}/texera/workflow/WorkflowCompiler.scala (95%)
rename core/amber/src/test/java/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/dataset/GitVersionControlLocalFileStorageSpec.java (97%)
delete mode 100644 core/amber/src/test/scala/edu/uci/ics/amber/engine/e2e/TestUtils.scala
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/breakpoint/ExceptionBreakpointSpec.scala (99%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/control/TrivialControlSpec.scala (86%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/control/utils/ChainHandler.scala (87%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/control/utils/CollectHandler.scala (88%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/control/utils/ErrorHandler.scala (85%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/control/utils/MultiCallHandler.scala (82%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/control/utils/NestedHandler.scala (87%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/control/utils/PingPongHandler.scala (89%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/control/utils/RecursionHandler.scala (86%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/control/utils/TesterAsyncRPCHandlerInitializer.scala (73%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/control/utils/TrivialControlTester.scala (75%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/controller/ControllerSpec.scala (99%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/NetworkInputGatewaySpec.scala (90%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/OutputManagerSpec.scala (89%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/messaginglayer/RangeBasedShuffleSpec.scala (92%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/pythonworker/PythonWorkflowWorkerSpec.scala (82%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/CostBasedScheduleGeneratorSpec.scala (95%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/DefaultCostEstimatorSpec.scala (90%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/scheduling/ExpansionGreedyScheduleGeneratorSpec.scala (94%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/DPThreadSpec.scala (90%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/DataProcessorSpec.scala (84%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/architecture/worker/WorkerSpec.scala (87%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/e2e/BatchSizePropagationSpec.scala (93%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/e2e/DataProcessingSpec.scala (83%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/e2e/PauseSpec.scala (76%)
create mode 100644 core/amber/src/test/scala/org/apache/amber/engine/e2e/TestUtils.scala
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/faulttolerance/CheckpointSpec.scala (86%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/faulttolerance/LoggingSpec.scala (81%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/amber/engine/faulttolerance/ReplaySpec.scala (84%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/file/WorkflowResourceSpec.scala (96%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/workflow/WorkflowExecutionsResourceSpec.scala (95%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/texera/web/resource/dashboard/user/workflow/WorkflowVersionResourceSpec.scala (94%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/texera/web/service/ExecutionConsoleServiceSpec.scala (95%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/texera/web/service/ExecutionResultServiceSpec.scala (99%)
rename core/amber/src/test/scala/{edu/uci/ics => org/apache}/texera/workflow/common/storage/ReadonlyLocalFileDocumentSpec.scala (95%)
rename core/auth/src/main/scala/{edu/uci/ics => org/apache}/texera/auth/JwtAuth.scala (94%)
rename core/auth/src/main/scala/{edu/uci/ics => org/apache}/texera/auth/JwtAuthFilter.scala (92%)
rename core/auth/src/main/scala/{edu/uci/ics => org/apache}/texera/auth/JwtParser.scala (92%)
rename core/auth/src/main/scala/{edu/uci/ics => org/apache}/texera/auth/SessionUser.scala (87%)
rename core/auth/src/main/scala/{edu/uci/ics => org/apache}/texera/auth/util/ComputingUnitAccess.scala (88%)
rename core/auth/src/main/scala/{edu/uci/ics => org/apache}/texera/auth/util/HeaderField.scala (96%)
rename core/computing-unit-managing-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/ComputingUnitManagingService.scala (87%)
rename core/computing-unit-managing-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/ComputingUnitManagingServiceConfiguration.scala (96%)
rename core/computing-unit-managing-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/resource/ComputingUnitAccessResource.scala (90%)
rename core/computing-unit-managing-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/resource/ComputingUnitManagingResource.scala (90%)
rename core/computing-unit-managing-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/resource/ComputingUnitState.scala (95%)
rename core/{file-service/src/main/scala/edu/uci/ics => computing-unit-managing-service/src/main/scala/org/apache}/texera/service/resource/HealthCheckResource.scala (96%)
rename core/computing-unit-managing-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/util/ComputingUnitHelpers.scala (83%)
rename core/computing-unit-managing-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/util/ComputingUnitManagingServiceException.scala (98%)
rename core/computing-unit-managing-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/util/KubernetesClient.scala (98%)
rename core/config-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/ConfigService.scala (90%)
rename core/config-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/ConfigServiceConfiguration.scala (96%)
rename core/config-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/resource/ConfigResource.scala (92%)
rename core/{computing-unit-managing-service/src/main/scala/edu/uci/ics => config-service/src/main/scala/org/apache}/texera/service/resource/HealthCheckResource.scala (96%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/amber/config/AkkaConfig.scala (97%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/amber/config/ApplicationConfig.scala (99%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/amber/config/EnvironmentalVariable.scala (99%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/amber/config/StorageConfig.scala (91%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/amber/config/UdfConfig.scala (97%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/amber/util/ConfigParserUtil.scala (97%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/amber/util/PathUtils.scala (99%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/texera/config/AuthConfig.scala (98%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/texera/config/ComputingUnitConfig.scala (97%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/texera/config/DefaultsConfig.scala (97%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/texera/config/GuiConfig.scala (99%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/texera/config/KubernetesConfig.scala (98%)
rename core/config/src/main/scala/{edu/uci/ics => org/apache}/texera/config/UserSystemConfig.scala (95%)
rename core/dao/src/main/scala/{edu/uci/ics => org/apache}/texera/dao/JooqCodeGenerator.scala (98%)
rename core/dao/src/main/scala/{edu/uci/ics => org/apache}/texera/dao/SqlServer.scala (96%)
rename core/dao/src/test/scala/{edu/uci/ics => org/apache}/texera/dao/MockTexeraDB.scala (94%)
rename core/file-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/FileService.scala (86%)
rename core/file-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/FileServiceConfiguration.scala (96%)
rename core/file-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/resource/DatasetAccessResource.scala (90%)
rename core/file-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/resource/DatasetResource.scala (86%)
rename core/{config-service/src/main/scala/edu/uci/ics => file-service/src/main/scala/org/apache}/texera/service/resource/HealthCheckResource.scala (96%)
rename core/file-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/type/dataset/DatasetFileNode.scala (98%)
rename core/file-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/type/serde/DatasetFileNodeSerializer.java (95%)
rename core/file-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/util/S3StorageClient.scala (98%)
create mode 100644 core/file-service/src/test/scala/org/apache/texera/service/MockLakeFS.scala
create mode 100644 core/file-service/src/test/scala/org/apache/texera/service/resource/DatasetResourceSpec.scala
rename core/gui/src/app/common/type/proto/{edu/uci/ics => org/apache}/amber/engine/common/virtualidentity.ts (99%)
rename core/gui/src/app/common/type/proto/{edu/uci/ics => org/apache}/amber/engine/common/workflow.ts (99%)
delete mode 100644 core/gui/src/app/workspace/service/workflow-cache/workflow-cache.service.spec.ts
delete mode 100644 core/gui/src/app/workspace/service/workflow-cache/workflow-cache.service.ts
create mode 100644 core/scripts/sql/updates/15.sql
delete mode 100644 core/workflow-compiling-service/src/main/scala/edu/uci/ics/texera/service/resource/HealthCheckResource.scala
rename core/workflow-compiling-service/src/main/scala/{edu/uci/ics => org/apache}/amber/compiler/WorkflowCompiler.scala (94%)
rename core/workflow-compiling-service/src/main/scala/{edu/uci/ics => org/apache}/amber/compiler/model/LogicalLink.scala (89%)
rename core/workflow-compiling-service/src/main/scala/{edu/uci/ics => org/apache}/amber/compiler/model/LogicalPlan.scala (92%)
rename core/workflow-compiling-service/src/main/scala/{edu/uci/ics => org/apache}/amber/compiler/model/LogicalPlanPojo.scala (91%)
rename core/workflow-compiling-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/WorkflowCompilingService.scala (86%)
rename core/workflow-compiling-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/WorkflowCompilingServiceConfiguration.scala (96%)
rename core/{access-control-service/src/main/scala/edu/uci/ics => workflow-compiling-service/src/main/scala/org/apache}/texera/service/resource/HealthCheckResource.scala (96%)
rename core/workflow-compiling-service/src/main/scala/{edu/uci/ics => org/apache}/texera/service/resource/WorkflowCompilationResource.scala (88%)
rename core/workflow-compiling-service/src/test/scala/{edu/uci/ics => org/apache}/texera/service/resource/WorkflowCompilationResourceSpec.scala (92%)
rename core/workflow-core/src/main/protobuf/{edu/uci/ics => org/apache}/amber/core/executor.proto (94%)
rename core/workflow-core/src/main/protobuf/{edu/uci/ics => org/apache}/amber/core/virtualidentity.proto (97%)
rename core/workflow-core/src/main/protobuf/{edu/uci/ics => org/apache}/amber/core/workflow.proto (96%)
rename core/workflow-core/src/main/protobuf/{edu/uci/ics => org/apache}/amber/core/workflowruntimestate.proto (97%)
delete mode 100644 core/workflow-core/src/main/scala/edu/uci/ics/amber/core/storage/result/ExecutionResourcesMapping.scala
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/WorkflowRuntimeException.scala (93%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/executor/ExecFactory.scala (98%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/executor/JavaRuntimeCompilation.scala (97%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/executor/OperatorExecutor.scala (89%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/executor/SourceOperatorExecutor.scala (91%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/state/State.scala (94%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/DocumentFactory.scala (92%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/FileResolver.scala (71%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/IcebergCatalogInstance.scala (95%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/VFSURIFactory.scala (94%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/model/BufferedItemWriter.scala (97%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/model/DatasetFileDocument.scala (86%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/model/OnDataset.scala (92%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/model/ReadonlyLocalFileDocument.scala (98%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/model/ReadonlyVirtualDocument.scala (98%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/model/VirtualCollection.scala (97%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/model/VirtualDocument.scala (99%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/result/ResultSchema.scala (93%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/result/WorkflowResultStore.scala (90%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/result/iceberg/IcebergDocument.scala (98%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/result/iceberg/IcebergTableWriter.scala (96%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/result/iceberg/OnIceberg.scala (94%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/util/LakeFSStorageClient.scala (95%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/util/StorageUtil.scala (96%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/util/dataset/GitVersionControlLocalFileStorage.java (99%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/util/dataset/JGitVersionControl.java (99%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/storage/util/dataset/PhysicalFileNode.java (95%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/tuple/Attribute.java (98%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/tuple/AttributeType.java (87%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/tuple/AttributeTypeUtils.scala (99%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/tuple/Schema.scala (99%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/tuple/Tuple.scala (98%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/tuple/TupleLike.scala (98%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/tuple/TupleUtils.scala (92%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/workflow/LocationPreference.scala (97%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/workflow/PartitionInfo.scala (99%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/workflow/PhysicalOp.scala (98%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/workflow/PhysicalPlan.scala (98%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/workflow/WorkflowContext.scala (88%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/core/workflow/WorkflowSettings.scala (95%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/util/ArrowUtils.scala (97%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/util/IcebergUtil.scala (97%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/util/JSONUtils.scala (96%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/util/VirtualIdentityUtils.scala (97%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/util/serde/GlobalPortIdentitySerde.scala (94%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/util/serde/PortIdentityKeyDeserializer.scala (93%)
rename core/workflow-core/src/main/scala/{edu/uci/ics => org/apache}/amber/util/serde/PortIdentityKeySerializer.scala (89%)
rename core/workflow-core/src/test/scala/{edu/uci/ics => org/apache}/amber/core/storage/model/VirtualDocumentSpec.scala (99%)
rename core/workflow-core/src/test/scala/{edu/uci/ics => org/apache}/amber/core/tuple/AttributeTypeUtilsSpec.scala (98%)
rename core/workflow-core/src/test/scala/{edu/uci/ics => org/apache}/amber/core/tuple/SchemaSpec.scala (99%)
rename core/workflow-core/src/test/scala/{edu/uci/ics => org/apache}/amber/core/tuple/TupleSpec.scala (98%)
rename core/workflow-core/src/test/scala/{edu/uci/ics => org/apache}/amber/storage/FileResolverSpec.scala (86%)
rename core/workflow-core/src/test/scala/{edu/uci/ics => org/apache}/amber/storage/result/iceberg/IcebergDocumentConsoleMessagesSpec.scala (89%)
rename core/workflow-core/src/test/scala/{edu/uci/ics => org/apache}/amber/storage/result/iceberg/IcebergDocumentSpec.scala (92%)
rename core/workflow-core/src/test/scala/{edu/uci/ics => org/apache}/amber/storage/result/iceberg/IcebergTableStatsSpec.scala (95%)
rename core/workflow-core/src/test/scala/{edu/uci/ics => org/apache}/amber/util/IcebergUtilSpec.scala (98%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/DummyProperties.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/LogicalOp.scala (69%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/PortDescriptor.scala (93%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/PythonOperatorDescriptor.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/SpecialPhysicalOpFactory.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/TestOperators.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/aggregate/AggregateOpDesc.scala (86%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/aggregate/AggregateOpExec.scala (93%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/aggregate/AggregationFunction.java (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/aggregate/AggregationOperation.scala (97%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/aggregate/DistributedAggregation.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/cartesianProduct/CartesianProductOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/cartesianProduct/CartesianProductOpExec.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/dictionary/DictionaryMatcherOpDesc.scala (80%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/dictionary/DictionaryMatcherOpExec.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/dictionary/MatchingType.java (97%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/difference/DifferenceOpDesc.scala (82%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/difference/DifferenceOpExec.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/distinct/DistinctOpDesc.scala (76%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/distinct/DistinctOpExec.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/dummy/DummyOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/filter/ComparisonType.java (97%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/filter/FilterOpDesc.scala (83%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/filter/FilterOpExec.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/filter/FilterPredicate.java (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/filter/SpecializedFilterOpDesc.scala (78%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/filter/SpecializedFilterOpExec.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/flatmap/FlatMapOpDesc.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/flatmap/FlatMapOpExec.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/hashJoin/HashJoinBuildOpExec.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/hashJoin/HashJoinOpDesc.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/hashJoin/HashJoinProbeOpExec.scala (94%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/hashJoin/JoinType.java (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/huggingFace/HuggingFaceIrisLogisticRegressionOpDesc.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/huggingFace/HuggingFaceSentimentAnalysisOpDesc.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/huggingFace/HuggingFaceSpamSMSDetectionOpDesc.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/huggingFace/HuggingFaceTextSummarizationOpDesc.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/ifStatement/IfOpDesc.scala (80%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/ifStatement/IfOpExec.scala (85%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/intersect/IntersectOpDesc.scala (78%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/intersect/IntersectOpExec.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/intervalJoin/IntervalJoinOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/intervalJoin/IntervalJoinOpExec.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/intervalJoin/TimeIntervalType.java (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/keywordSearch/KeywordSearchOpDesc.scala (76%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/keywordSearch/KeywordSearchOpExec.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/limit/LimitOpDesc.scala (81%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/limit/LimitOpExec.scala (85%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/Scorer/MachineLearningScorerOpDesc.scala (94%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/Scorer/classificationMetricsFnc.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/Scorer/regressionMetricsFnc.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/sklearnAdvanced/KNNTrainer/SklearnAdvancedKNNClassifierTrainerOpDesc.scala (86%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/sklearnAdvanced/KNNTrainer/SklearnAdvancedKNNParameters.java (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/sklearnAdvanced/KNNTrainer/SklearnAdvancedKNNRegressorTrainerOpDesc.scala (86%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/sklearnAdvanced/SVCTrainer/SklearnAdvancedSVCParameters.java (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/sklearnAdvanced/SVCTrainer/SklearnAdvancedSVCTrainerOpDesc.scala (85%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/sklearnAdvanced/SVRTrainer/SklearnAdvancedSVRParameters.java (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/sklearnAdvanced/SVRTrainer/SklearnAdvancedSVRTrainerOpDesc.scala (79%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/sklearnAdvanced/base/HyperParameters.java (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/machineLearning/sklearnAdvanced/base/SklearnAdvancedBaseDesc.scala (93%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/map/MapOpDesc.scala (83%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/map/MapOpExec.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/OPVersion.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/OperatorGroupConstants.scala (98%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/OperatorMetadataGenerator.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/PropertyNameConstants.scala (98%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/annotations/AutofillAttributeName.java (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/annotations/AutofillAttributeNameLambda.java (97%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/annotations/AutofillAttributeNameList.java (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/annotations/AutofillAttributeNameOnPort1.java (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/annotations/BatchByColumn.java (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/annotations/CommonOpDescAnnotation.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/annotations/EnablePresets.java (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/annotations/HideAnnotation.java (97%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/metadata/annotations/UIWidget.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/projection/AttributeUnit.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/projection/ProjectionOpDesc.scala (84%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/projection/ProjectionOpExec.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/randomksampling/RandomKSamplingOpDesc.scala (78%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/randomksampling/RandomKSamplingOpExec.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/regex/RegexOpDesc.scala (78%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/regex/RegexOpExec.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/reservoirsampling/ReservoirSamplingOpDesc.scala (76%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/reservoirsampling/ReservoirSamplingOpExec.scala (85%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sink/ProgressiveUtils.scala (94%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnAdaptiveBoostingOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnBaggingOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnBernoulliNaiveBayesOpDesc.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnClassifierOpDesc.scala (93%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnComplementNaiveBayesOpDesc.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnDecisionTreeOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnDummyClassifierOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnExtraTreeOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnExtraTreesOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnGaussianNaiveBayesOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnGradientBoostingOpDesc.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnKNNOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnLinearRegressionOpDesc.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnLinearSVMOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnLogisticRegressionCVOpDesc.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnLogisticRegressionOpDesc.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnMultiLayerPerceptronOpDesc.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnMultinomialNaiveBayesOpDesc.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnNearestCentroidOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnPassiveAggressiveOpDesc.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnPerceptronOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnPredictionOpDesc.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnProbabilityCalibrationOpDesc.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnRandomForestOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnRidgeCVOpDesc.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnRidgeOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnSDGOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/SklearnSVMOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingAdaptiveBoostingOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingBaggingOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingBernoulliNaiveBayesOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingComplementNaiveBayesOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingDecisionTreeOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingDummyClassifierOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingExtraTreeOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingExtraTreesOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingGaussianNaiveBayesOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingGradientBoostingOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingKNNOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingLinearRegressionOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingLinearSVMOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingLogisticRegressionCVOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingLogisticRegressionOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingMultiLayerPerceptronOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingMultinomialNaiveBayesOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingNearestCentroidOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingOpDesc.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingPassiveAggressiveOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingPerceptronOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingProbabilityCalibrationOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingRandomForestOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingRidgeCVOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingRidgeOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingSDGOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sklearn/training/SklearnTrainingSVMOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sleep/SleepOpDesc.scala (78%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sleep/SleepOpExec.scala (84%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sort/SortCriteriaUnit.java (86%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sort/SortOpDesc.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sort/SortPreference.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sortPartitions/SortPartitionsOpDesc.scala (79%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/sortPartitions/SortPartitionsOpExec.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/BufferedBlockReader.java (98%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/PythonSourceOperatorDescriptor.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/SourceOperatorDescriptor.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/apis/reddit/RedditSearchSourceOpDesc.scala (94%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/apis/reddit/RedditSourceOperatorFunction.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/apis/twitter/TwitterSourceOpDesc.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/apis/twitter/TwitterSourceOpExec.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/apis/twitter/v2/TwitterFullArchiveSearchSourceOpDesc.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/apis/twitter/v2/TwitterFullArchiveSearchSourceOpExec.scala (94%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/apis/twitter/v2/TwitterSearchSourceOpDesc.scala (86%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/apis/twitter/v2/TwitterSearchSourceOpExec.scala (93%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/apis/twitter/v2/TwitterUtils.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/cache/CacheSourceOpExec.scala (81%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/fetcher/DecodingMethod.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/fetcher/RandomUserAgent.java (99%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/fetcher/URLFetchUtil.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/fetcher/URLFetcherOpDesc.scala (78%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/fetcher/URLFetcherOpExec.scala (84%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/AutoClosingIterator.scala (97%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/FileAttributeType.java (94%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/FileDecodingMethod.java (97%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/FileScanSourceOpDesc.scala (83%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/FileScanSourceOpExec.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/ScanSourceOpDesc.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/arrow/ArrowSourceOpDesc.scala (79%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/arrow/ArrowSourceOpExec.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/csv/CSVScanSourceOpDesc.scala (85%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/csv/CSVScanSourceOpExec.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/csv/ParallelCSVScanSourceOpDesc.scala (83%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/csv/ParallelCSVScanSourceOpExec.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/csvOld/CSVOldScanSourceOpDesc.scala (84%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/csvOld/CSVOldScanSourceOpExec.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/json/JSONLScanSourceOpDesc.scala (83%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/json/JSONLScanSourceOpExec.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/json/JSONUtil.scala (98%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/text/TextInputSourceOpDesc.scala (74%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/text/TextInputSourceOpExec.scala (82%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/text/TextSourceOpDesc.scala (93%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/sql/SQLSourceOpDesc.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/sql/SQLSourceOpExec.scala (98%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/sql/asterixdb/AsterixDBConnUtil.scala (98%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/sql/asterixdb/AsterixDBSourceOpDesc.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/sql/asterixdb/AsterixDBSourceOpExec.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/sql/mysql/MySQLConnUtil.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/sql/mysql/MySQLSourceOpDesc.scala (74%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/sql/mysql/MySQLSourceOpExec.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/sql/postgresql/PostgreSQLConnUtil.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/sql/postgresql/PostgreSQLSourceOpDesc.scala (77%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/source/sql/postgresql/PostgreSQLSourceOpExec.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/split/SplitOpDesc.scala (85%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/split/SplitOpExec.scala (86%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/symmetricDifference/SymmetricDifferenceOpDesc.scala (79%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/symmetricDifference/SymmetricDifferenceOpExec.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/timeSeriesPlot/TimeSeriesPlot.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/typecasting/TypeCastingOpDesc.scala (77%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/typecasting/TypeCastingOpExec.scala (84%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/typecasting/TypeCastingUnit.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/udf/java/JavaUDFOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/udf/python/DualInputPortsPythonUDFOpDescV2.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/udf/python/LambdaAttributeUnit.java (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/udf/python/PythonLambdaFunctionOpDesc.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/udf/python/PythonTableReducerOpDesc.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/udf/python/PythonUDFOpDescV2.scala (93%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/udf/python/source/PythonUDFSourceOpDescV2.scala (85%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/udf/r/RUDFOpDesc.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/udf/r/RUDFSourceOpDesc.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/union/UnionOpDesc.scala (75%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/union/UnionOpExec.scala (86%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/unneststring/UnnestStringOpDesc.scala (78%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/unneststring/UnnestStringOpExec.scala (85%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/util/OperatorDescriptorUtils.scala (97%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/DotPlot/DotPlotOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/IcicleChart/IcicleChartOpDesc.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/ImageUtility.scala (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/ImageViz/ImageVisualizerOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/ScatterMatrixChart/ScatterMatrixChartOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/barChart/BarChartOpDesc.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/boxViolinPlot/BoxViolinPlotOpDesc.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/boxViolinPlot/BoxViolinPlotQuartileFunction.java (94%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/bubbleChart/BubbleChartOpDesc.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/bulletChart/BulletChartOpDesc.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/bulletChart/BulletChartStepDefinition.scala (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/candlestickChart/CandlestickChartOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/choroplethMap/ChoroplethMapOpDesc.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/continuousErrorBands/BandConfig.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/continuousErrorBands/ContinuousErrorBandsOpDesc.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/contourPlot/ContourPlotColoringFunction.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/contourPlot/ContourPlotOpDesc.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/dendrogram/DendrogramOpDesc.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/dumbbellPlot/DumbbellDotConfig.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/dumbbellPlot/DumbbellPlotOpDesc.scala (93%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/figureFactoryTable/FigureFactoryTableConfig.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/figureFactoryTable/FigureFactoryTableOpDesc.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/filledAreaPlot/FilledAreaPlotOpDesc.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/funnelPlot/FunnelPlotOpDesc.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/ganttChart/GanttChartOpDesc.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/gaugeChart/GaugeChartOpDesc.scala (94%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/gaugeChart/GaugeChartSteps.scala (94%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/heatMap/HeatMapOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/hierarchychart/HierarchyChartOpDesc.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/hierarchychart/HierarchyChartType.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/hierarchychart/HierarchySection.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/histogram/HistogramChartOpDesc.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/histogram2d/Histogram2DOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/histogram2d/NormalizationType.java (94%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/htmlviz/HtmlVizOpDesc.scala (74%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/htmlviz/HtmlVizOpExec.scala (84%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/lineChart/LineChartOpDesc.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/lineChart/LineConfig.scala (93%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/lineChart/LineMode.java (96%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/nestedTable/NestedTableConfig.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/nestedTable/NestedTableOpDesc.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/networkGraph/NetworkGraphOpDesc.scala (94%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/pieChart/PieChartOpDesc.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/quiverPlot/QuiverPlotOpDesc.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/rangeSlider/RangeSliderHandleDuplicateFunction.java (95%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/rangeSlider/RangeSliderOpDesc.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/sankeyDiagram/SankeyDiagramOpDesc.scala (91%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/scatter3DChart/Scatter3dChartOpDesc.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/scatterplot/ScatterplotOpDesc.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/tablesChart/TablesConfig.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/tablesChart/TablesPlotOpDesc.scala (90%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/ternaryPlot/TernaryPlotOpDesc.scala (92%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/treeplot/TreeplotOpDesc.scala (93%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/urlviz/UrlVizOpDesc.scala (75%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/urlviz/UrlVizOpExec.scala (87%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/volcanoPlot/VolcanoPlotOpDesc.scala (89%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/waterfallChart/WaterfallChartOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/wordCloud/WordCloudOpDesc.scala (88%)
rename core/workflow-operator/src/main/scala/{edu/uci/ics => org/apache}/amber/util/ObjectMapperUtils.scala (93%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/cartesianProduct/CartesianProductOpExecSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/dictionary/DictionaryMatcherOpExecSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/difference/DifferenceOpExecSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/distinct/DistinctOpExecSpec.scala (95%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/filter/SpecializedFilterOpExecSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/hashJoin/HashJoinOpSpec.scala (94%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/intersect/IntersectOpExecSpec.scala (94%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/intervalJoin/IntervalOpExecSpec.scala (97%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/keywordSearch/KeywordSearchOpExecSpec.scala (97%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/projection/ProjectionOpDescSpec.scala (95%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/projection/ProjectionOpExecSpec.scala (97%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/sortPartitions/SortPartitionsOpExecSpec.scala (94%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/source/fetcher/URLFetcherOpExecSpec.scala (92%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/csv/CSVScanSourceOpDescSpec.scala (94%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/text/FileScanSourceOpDescSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/source/scan/text/TextInputSourceOpDescSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/symmetricDifference/SymmetricDifferenceOpExecSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/typecasting/TypeCastingOpExecSpec.scala (95%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/udf/python/PythonLambdaFunctionOpDescSpec.scala (94%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/unneststring/UnnestStringOpExecSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/DotPlot/DotPlotOpDescSpec.scala (95%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/ImageViz/ImageVisualizerOpDescSpec.scala (95%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/barChart/BarChartOpDescSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/bubbleChart/BubbleChartOpDescSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/filledAreaPlot/FilledAreaPlotOpDescSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/ganttChart/GanttChartOpDescSpec.scala (97%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/hierarchychart/HierarchyChartOpDescSpec.scala (96%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/htmlviz/HtmlVizOpExecSpec.scala (92%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/pieChart/PieChartOpDescSpec.scala (95%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/operator/visualization/scatterplot/ScatterPlotOpDescSpec.scala (95%)
rename core/workflow-operator/src/test/scala/{edu/uci/ics => org/apache}/amber/util/ArrowUtilsSpec.scala (97%)
create mode 100644 deployment/access-control-service.dockerfile
create mode 120000 deployment/k8s/texera-helmchart/files/iceberg_postgres_catalog.sql
mode change 100644 => 120000 deployment/k8s/texera-helmchart/files/texera_ddl.sql
create mode 120000 deployment/k8s/texera-helmchart/files/texera_lakefs.sql
create mode 100644 deployment/k8s/texera-helmchart/templates/access-control-service-deployment.yaml
copy deployment/k8s/texera-helmchart/templates/{postgresql-init-script-config.yaml => access-control-service-service.yaml} (67%)