SparkQA commented on pull request #32031: URL: https://github.com/apache/spark/pull/32031#issuecomment-985939585
**[Test build #145918 has finished](https://amplab.cs.berkeley.edu/jenkins/job/SparkPullRequestBuilder/145918/testReport)** for PR 32031 at commit [`2300dc4`](https://github.com/apache/spark/commit/2300dc405206e053e38ea2ccdb5936969c2271ef). * This patch passes all tests. * This patch merges cleanly. * This patch adds the following public classes _(experimental)_: * `public class NettyLogger ` * `public final class LZ4Compressor ` * `public final class LZ4Factory ` * `public final class LZ4SafeDecompressor ` * `public class JavaModuleOptions ` * `class SparkConf(object):` * `class ProbabilisticClassifier(Classifier, _ProbabilisticClassifierParams, metaclass=ABCMeta):` * `class ProbabilisticClassificationModel(` * `class _JavaProbabilisticClassifier(ProbabilisticClassifier, _JavaClassifier, metaclass=ABCMeta):` * `class _JavaProbabilisticClassificationModel(` * `class _LinearSVCParams(` * `class LinearSVCModel(` * `class _LogisticRegressionParams(` * `class LogisticRegression(` * `class LogisticRegressionModel(` * `class BinaryLogisticRegressionSummary(_BinaryClassificationSummary, LogisticRegressionSummary):` * `class BinaryLogisticRegressionTrainingSummary(` * `class DecisionTreeClassifier(` * `class DecisionTreeClassificationModel(` * `class RandomForestClassifier(` * `class RandomForestClassificationModel(` * `class RandomForestClassificationTrainingSummary(` * `class BinaryRandomForestClassificationTrainingSummary(` * `class GBTClassifier(` * `class GBTClassificationModel(` * `class NaiveBayes(` * `class NaiveBayesModel(` * `class _MultilayerPerceptronParams(` * `class MultilayerPerceptronClassifier(` * `class MultilayerPerceptronClassificationModel(` * `class MultilayerPerceptronClassificationTrainingSummary(` * `class FMClassifier(` * `class FMClassificationModel(` * `class _GaussianMixtureParams(` * `class GaussianMixtureModel(` * `class _KMeansParams(` * `class KMeansModel(` * `class _BisectingKMeansParams(` * `class BisectingKMeansModel(` * `class PowerIterationClustering(` * `class BinaryClassificationEvaluator(` * `class RegressionEvaluator(` * `class MulticlassClassificationEvaluator(` * `class MultilabelClassificationEvaluator(` * `class ClusteringEvaluator(` * `class RankingEvaluator(` * `class Binarizer(` * `class BucketedRandomProjectionLSH(` * `class BucketedRandomProjectionLSHModel(` * `class Bucketizer(` * `class ElementwiseProduct(` * `class FeatureHasher(` * `class HashingTF(` * `class _OneHotEncoderParams(` * `class PolynomialExpansion(` * `class QuantileDiscretizer(` * `class _StringIndexerParams(` * `class StopWordsRemover(` * `class VectorAssembler(` * `class VectorSizeHint(` * `class VarianceThresholdSelector(` * `class VarianceThresholdSelectorModel(` * `class UnivariateFeatureSelector(` * `class UnivariateFeatureSelectorModel(` * `class _LinearRegressionParams(` * `class LinearRegressionModel(` * `class IsotonicRegression(` * `class IsotonicRegressionModel(JavaModel, _IsotonicRegressionParams, JavaMLWritable, JavaMLReadable):` * `class DecisionTreeRegressor(` * `class RandomForestRegressor(` * `class _AFTSurvivalRegressionParams(` * `class AFTSurvivalRegression(` * `class AFTSurvivalRegressionModel(` * `class _GeneralizedLinearRegressionParams(` * `class GeneralizedLinearRegression(` * `class GeneralizedLinearRegressionModel(` * `class _FactorizationMachinesParams(` * `class FMRegressionModel(` * `class CrossValidator(` * `class TrainValidationSplit(` * ` + \"class name ` * `class MultivariateGaussian(NamedTuple):` * `class DatetimeNTZOps(DatetimeOps):` * `class TimedeltaOps(DataTypeOps):` * `class TimedeltaIndex(Index):` * `class MissingPandasLikeTimedeltaIndex(MissingPandasLikeIndex):` * `class MissingPandasLikeMultiIndex(object):` * `class HistogramPlotBase(NumericPlotBase):` * `class KdePlotBase(NumericPlotBase):` * `class SQLStringFormatter(string.Formatter):` * `class IndexNameTypeHolder(object):` * ` new_class = type(NameTypeHolder.short_name, (NameTypeHolder,), ` * ` new_class = param.type if isinstance(param, np.dtype) else param` * `class PandasAPIOnSparkAdviceWarning(Warning):` * `class UDFBasicProfiler(BasicProfiler):` * `class ResultIterable(Iterable[T]):` * `class CloudPickleSerializer(FramedSerializer):` * `class Database(NamedTuple):` * `class Table(NamedTuple):` * `class Column(NamedTuple):` * `class Function(NamedTuple):` * `class ArrowStreamUDFSerializer(ArrowStreamSerializer):` * `class OptionUtils(object):` * `class TimestampNTZType(AtomicType, metaclass=DataTypeSingleton):` * `class DayTimeIntervalType(AtomicType):` * `class DatetimeNTZConverter(object):` * `class DayTimeIntervalTypeConverter(object):` * `class SparkUpgradeException(CapturedException):` * `class SparkJobInfo(NamedTuple):` * `class SparkStageInfo(NamedTuple):` * `class ExecutorPodsPollingSnapshotSource(` * `class ExecutorPodsWatchSnapshotSource(` * ` protected class YarnSchedulerEndpoint(override val rpcEnv: RpcEnv)` * `public class ExpressionImplUtils ` * `public final class TableIndex ` * `public final class AlwaysFalse extends Filter ` * `public final class AlwaysTrue extends Filter ` * `public final class And extends BinaryFilter ` * `abstract class BinaryComparison extends Filter ` * `abstract class BinaryFilter extends Filter ` * `public final class EqualNullSafe extends BinaryComparison ` * `public final class EqualTo extends BinaryComparison ` * `public abstract class Filter implements Expression, Serializable ` * `public final class GreaterThan extends BinaryComparison ` * `public final class GreaterThanOrEqual extends BinaryComparison ` * `public final class In extends Filter ` * `public final class IsNotNull extends Filter ` * `public final class IsNull extends Filter ` * `public final class LessThan extends BinaryComparison ` * `public final class LessThanOrEqual extends BinaryComparison ` * `public final class Not extends Filter ` * `public final class Or extends BinaryFilter ` * `public final class StringContains extends StringPredicate ` * `public final class StringEndsWith extends StringPredicate ` * `abstract class StringPredicate extends Filter ` * `public final class StringStartsWith extends StringPredicate ` * `public class NumericHistogram ` * ` * The Coord class defines a histogram bin, which is just an (x,y) pair.` * ` public static class Coord implements Comparable ` * `public class ColumnarBatch implements AutoCloseable ` * `public final class ColumnarBatchRow extends InternalRow ` * `class IndexAlreadyExistsException(message: String, cause: Option[Throwable] = None)` * ` class AnsiCombinedTypeCoercionRule(rules: Seq[TypeCoercionRule]) extends` * `trait ExpressionBuilder ` * `class NoSuchIndexException(message: String, cause: Option[Throwable] = None)` * `case class RelationTimeTravel(` * `case class AsOfTimestamp(timestamp: Long) extends TimeTravelSpec` * `case class AsOfVersion(version: String) extends TimeTravelSpec` * ` class CombinedTypeCoercionRule(rules: Seq[TypeCoercionRule]) extends TypeCoercionRule ` * `trait FunctionExpressionBuilder ` * `case class ExpressionStats(expr: Expression)(var useCount: Int)` * `case class PrettyPythonUDF(` * `case class HistogramNumeric(` * `trait ExtractValue extends Expression with NullIntolerant ` * `case class CastTimestampNTZToLong(child: Expression) extends TimestampToLongBase ` * `case class Sec(child: Expression)` * `case class Csc(child: Expression)` * `case class AesEncrypt(input: Expression, key: Expression, child: Expression)` * `case class AesDecrypt(input: Expression, key: Expression, child: Expression)` * `case class ILike(` * `trait PadExpressionBuilderBase extends ExpressionBuilder ` * `case class StringLPad(str: Expression, len: Expression, pad: Expression)` * `case class BinaryLPad(str: Expression, len: Expression, pad: Expression, child: Expression)` * `case class BinaryRPad(str: Expression, len: Expression, pad: Expression, child: Expression)` * `case class UnclosedCommentProcessor(` * `trait OperationHelper extends AliasHelper with PredicateHelper ` * `case class AsOfJoin(` * `case class PythonMapInArrow(` * `case class CreateTable(` * `case class SetCatalogAndNamespace(child: LogicalPlan) extends UnaryCommand ` * `case class CreateFunction(` * `case class CreateView(` * `case class CreateIndex(` * `case class DropIndex(` * `case class TableSpec(` * `trait SupportsPushDownCatalystFilters ` * `class SQLOpenHashSet[@specialized(Long, Int, Double, Float) T: ClassTag](` * `public class ColumnIOUtil ` * `public class OrcColumnStatistics ` * `public class OrcFooterReader ` * `case class OptimizeSkewedJoin(ensureRequirements: EnsureRequirements)` * `case class SkewJoinChildWrapper(plan: SparkPlan) extends LeafExecNode ` * `case class SimpleCostEvaluator(forceOptimizeSkewedJoin: Boolean) extends CostEvaluator ` * `case class SetCatalogCommand(catalogName: String) extends LeafRunnableCommand ` * `case class SetNamespaceCommand(namespace: Seq[String]) extends LeafRunnableCommand ` * `case class ShowCatalogsCommand(pattern: Option[String]) extends LeafRunnableCommand ` * `case class ShowCurrentNamespaceCommand() extends LeafRunnableCommand ` * `case class WriterBucketSpec(` * `case class ParquetColumn(` * `case class CreateIndexExec(` * `case class DropIndexExec(` * `case class PushedDownOperators(` * `case class TableSampleInfo(` * `case class EnsureRequirements(` * `trait MapInBatchExec extends UnaryExecNode ` * `case class PythonMapInArrowExec(` * `class AvailableNowDataStreamWrapper(val delegate: SparkDataStream)` * `class AvailableNowMicroBatchStreamWrapper(delegate: MicroBatchStream)` * `class AvailableNowSourceWrapper(delegate: Source)` * `case class SingleBatchExecutor() extends TriggerExecutor ` * `case class MultiBatchExecutor() extends TriggerExecutor ` * `class RatePerMicroBatchProvider extends SimpleTableProvider with DataSourceRegister ` * `class RatePerMicroBatchTable(` * `class RatePerMicroBatchStream(` * `case class RatePerMicroBatchStreamOffset(offset: Long, timestamp: Long) extends Offset ` * `case class RatePerMicroBatchStreamInputPartition(` * `class RatePerMicroBatchStreamPartitionReader(` * ` // When this is enabled, this class does additional lookup on write operations (put/delete) to` * `class SparkUDFExpressionBuilder extends FunctionExpressionBuilder ` * `class HiveThriftServer2AppStatusStore(store: KVStore) ` -- 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]
