SparkQA commented on pull request #31847:
URL: https://github.com/apache/spark/pull/31847#issuecomment-874148755


   **[Test build #140649 has 
finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/140649/testReport)**
 for PR 31847 at commit 
[`b4f298e`](https://github.com/apache/spark/commit/b4f298e9a97ad4d3afd1b099cba1887efbcf734d).
    * This patch passes all tests.
    * This patch merges cleanly.
    * This patch adds the following public classes _(experimental)_:
     * `public class MergedBlockMetaRequest extends AbstractMessage implements 
RequestMessage `
     * `public class MergedBlockMetaSuccess extends AbstractResponseMessage `
     * `public abstract class AbstractFetchShuffleBlocks extends 
BlockTransferMessage `
     * `public class FetchShuffleBlockChunks extends AbstractFetchShuffleBlocks 
`
     * `public class FetchShuffleBlocks extends AbstractFetchShuffleBlocks `
     * `      throw new IllegalArgumentException(s\"Cannot find error class 
'$errorClass'\"))`
     * `trait SparkError extends Throwable `
     * `class SparkException(`
     * `class SparkArithmeticException(`
     * `final case class FileNameSpec(prefix: String, suffix: String)`
     * `case class ShuffleBlockInfo(shuffleId: Int, mapId: Long) `
     * `case class ShuffleBlockChunkId(`
     * `case class ShuffleMergedDataBlockId(appId: String, shuffleId: Int, 
reduceId: Int) extends BlockId `
     * `case class ShuffleMergedIndexBlockId(`
     * `case class ShuffleMergedMetaBlockId(`
     * `  case class FetchRequest(`
     * `  class AvroSchemaHelper(`
     * `class DecimalOps(FractionalOps):`
     * `class IntegralExtensionOps(IntegralOps):`
     * `class FractionalExtensionOps(FractionalOps):`
     * `class StringExtensionOps(StringOps):`
     * `            new_class = type(\"NameType\", (NameTypeHolder,), `
     * `class GroupBy(Generic[FrameLike], metaclass=ABCMeta):`
     * `class DataFrameGroupBy(GroupBy[DataFrame]):`
     * `class SeriesGroupBy(GroupBy[Series]):`
     * `        new_class = type(\"NameType\", (NameTypeHolder,), `
     * `class SparkIndexOpsMethods(Generic[IndexOpsLike], metaclass=ABCMeta):`
     * `class SparkSeriesMethods(SparkIndexOpsMethods[\"ps.Series\"]):`
     * `class SparkIndexMethods(SparkIndexOpsMethods[\"ps.Index\"]):`
     * `class RollingAndExpanding(Generic[FrameLike], metaclass=ABCMeta):`
     * `class RollingLike(RollingAndExpanding[FrameLike]):`
     * `class Rolling(RollingLike[FrameLike]):`
     * `class RollingGroupby(RollingLike[FrameLike]):`
     * `class ExpandingLike(RollingAndExpanding[FrameLike]):`
     * `class Expanding(ExpandingLike[FrameLike]):`
     * `class ExpandingGroupby(ExpandingLike[FrameLike]):`
     * `class KubernetesLocalDiskShuffleDataIO(sparkConf: SparkConf) extends 
ShuffleDataIO `
     * `class KubernetesLocalDiskShuffleExecutorComponents(sparkConf: 
SparkConf)`
     * `case class TempResolvedColumn(child: Expression, nameParts: 
Seq[String]) extends UnaryExpression`
     * `sealed trait FieldName extends LeafExpression with Unevaluable `
     * `case class UnresolvedFieldName(name: Seq[String]) extends FieldName `
     * `sealed trait FieldPosition extends LeafExpression with Unevaluable `
     * `case class UnresolvedFieldPosition(`
     * `case class ResolvedFieldName(path: Seq[String], field: StructField) 
extends FieldName `
     * `case class ResolvedFieldPosition(position: ColumnPosition) extends 
FieldPosition`
     * `case class Cast(`
     * `case class ExpressionEquals(e: Expression) `
     * `case class ExpressionStats(expr: Expression)(var useCount: Int = 1) `
     * `case class Average(`
     * `case class Sum(`
     * `case class SubExprEliminationState(eval: ExprCode, children: 
Seq[SubExprEliminationState])`
     * `case class ArraysZip(children: Seq[Expression], names: Seq[Expression])`
     * `case class GetTimestampNTZ(`
     * `case class ParseToTimestampNTZ(`
     * `case class MakeDTInterval(`
     * `case class MakeYMInterval(years: Expression, months: Expression)`
     * `trait InvokeLike extends Expression with NonSQLExpression with 
ImplicitCastInputTypes `
     * `case class LateralSubquery(`
     * `case class RebalancePartitions(`
     * `case class LateralJoin(`
     * `trait AlterTableCommand extends UnaryCommand `
     * `case class AlterTableDropColumns(`
     * `case class AlterTableRenameColumn(`
     * `case class AlterTableAlterColumn(`
     * `    new AnalysisException(s\"UDF class $className doesn't implement any 
UDF interface\")`
     * `    new AnalysisException(s\"UDF class with $n type arguments is not 
supported.\")`
     * `    new AnalysisException(s\"Can not instantiate class $className, 
please make sure\" +`
     * `    new AnalysisException(s\"Can not load class $className, please make 
sure it is on the classpath\")`
     * `    new SparkException(s\"Cannot find catalog plugin class for catalog 
'$name': $pluginClassName\")`
     * `    new SparkException(\"Cannot instantiate abstract catalog plugin 
class for \" +`
     * `    new SparkException(s\"Can not load in UserDefinedType $`
     * `case class DayTimeIntervalType(startField: Byte, endField: Byte) 
extends AtomicType `
     * `case class YearMonthIntervalType(startField: Byte, endField: Byte) 
extends AtomicType `
     * `final class ParquetReadState `
     * `public class ParquetVectorUpdaterFactory `
     * `case class CommandResult(`
     * `case class MergingSessionsExec(`
     * `class MergingSessionsIterator(`
     * `case class ShowCreateTableExec(`
     * `class RocksDB(`
     * `class ByteArrayPair(var key: Array[Byte] = null, var value: Array[Byte] 
= null) `
     * `case class RocksDBConf(`
     * `case class AcquiredThreadInfo() `
     * `case class StateStoreCustomSumMetric(name: String, desc: String) 
extends StateStoreCustomMetric `
     * `case class StateStoreCustomSizeMetric(name: String, desc: String) 
extends StateStoreCustomMetric `
     * `case class StateStoreCustomTimingMetric(name: String, desc: String) 
extends StateStoreCustomMetric `
     * `trait StatefulOperatorCustomMetric `
     * `case class StatefulOperatorCustomSumMetric(name: String, desc: String)`
     * `trait WatermarkSupport extends SparkPlan `
     * `trait TestGroupState[S] extends GroupState[S] `


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]



---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to