Task Summary
Three logical-operator descriptors under common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/ have no dedicated specs:
sleep/SleepOpDesc — Sleep operator (control group, non-parallelizable, suggestedWorkerNum=1).intersect/IntersectOpDesc — Intersect operator (set group, two HashPartition-required inputs, blocking output).source/fetcher/URLFetcherOpDesc — URL fetcher (api group, decoding-method-conditional sourceSchema, source physical op).
Add unit tests covering operatorInfo (name, group, port counts), getPhysicalOp (class name, port wiring, partition requirements, parallelization flags) and the decoding-method branch of URLFetcherOpDesc.sourceSchema.
Task Type
Task Summary
Three logical-operator descriptors under
common/workflow-operator/src/main/scala/org/apache/texera/amber/operator/have no dedicated specs:sleep/SleepOpDesc— Sleep operator (control group, non-parallelizable, suggestedWorkerNum=1).intersect/IntersectOpDesc— Intersect operator (set group, two HashPartition-required inputs, blocking output).source/fetcher/URLFetcherOpDesc— URL fetcher (api group, decoding-method-conditionalsourceSchema, source physical op).Add unit tests covering
operatorInfo(name, group, port counts),getPhysicalOp(class name, port wiring, partition requirements, parallelization flags) and the decoding-method branch ofURLFetcherOpDesc.sourceSchema.Task Type