ACTIVE
StreamExecution
ADAPTIVE_EXECUTION_ENABLED
SQLConf
ADD
SnappyDDLParser SnappyParserConsts ArrayOpsExpression
ADD_ACTION
FileStreamSinkLog
ADD_URIS_TO_CLASSLOADER
RefreshMetadata
AEQHelper
util
AFTSurvivalRegression
regression
AFTSurvivalRegressionExample
ml
AFTSurvivalRegressionModel
regression
ALL
SnappyDDLParser SnappyParserConsts
ALLOWED_JOIN_TYPE_HINTS
Constant
ALS
recommendation recommendation
ALSExample
ml
ALSModel
recommendation
ALTER
SnappyDDLParser SnappyParserConsts
ALWAYS_TRUE_COLNAME
RewriteCorrelatedScalarSubquery
ANALYZE
SnappyDDLParser SnappyParserConsts
AND
SnappyDDLParser SnappyParserConsts
ANTI
SnappyDDLParser SnappyParserConsts
ANY
TaskLocality
ANY_HOST
YarnSparkHadoopUtil
AQPAverage
common
AQPCount
common
AQPDataFrame
sql
AQPDebugPoissonType
Property
AQPFunctionParameter
common
AQPInfo
common
AQPInfoStoreTestHook
common
AQPQueryAnalyzer
internal
AQPRules
common
AQPSum
common
AQP_VERSION_PROPERTIES
SnappyDataVersion
ARRAY
SnappyBaseParser SnappyParserConsts
ARRAY_TYPE
StoreUtils
AS
SnappyDDLParser SnappyParserConsts
ASC
SnappyDDLParser SnappyParserConsts
AUTHORIZATION
SnappyDDLParser SnappyParserConsts
AUTO_BROADCASTJOIN_THRESHOLD
SQLConf
Abs
expressions
AbsoluteError
loss common
AbstractFileRegion
util
AbstractMessage
protocol
AbstractMethodError
scala
AbstractParams
mllib
AbstractResponseMessage
protocol
AbstractScalaRowIterator
util
AbstractService
service
AbstractSqlParser
parser
Accumulable
spark
AccumulableInfo
scheduler v1
AccumulableParam
spark
Accumulator
spark
AccumulatorParam
spark
AccumulatorV2
util
AccumulatorV2Kryo
util
Acos
expressions
Add
expressions
AddFileCommand
command
AddJarCommand
command
AddMonths
expressions
AddSubquery
Canonicalizer
Address
snappydata
AggUtils
aggregate
Aggregate
logical
AggregateExpression
aggregate
AggregateFunction
aggregate
AggregateHashMap
vectorized
AggregateMessagesExample
graphx
AggregateMode
aggregate
AggregatePartialDataIterator
sql
AggregateWindowFunction
expressions
Aggregation
SparkStrategies
AggregationIterator
aggregate
Aggregator
spark expressions
AirlineDataJob
examples
AirlineDataSparkApp
examples
Algo
configuration Algo
Algorithm
BinaryClassification Algorithm
Alias
expressions
AllTuples
physical
AlphaComponent
annotation
AltName
internal
AlterDatabasePropertiesCommand
command
AlterTableAddColumnCommand
execution
AlterTableAddPartitionCommand
command
AlterTableDropColumnCommand
execution
AlterTableDropPartitionCommand
command
AlterTableMiscCommand
execution
AlterTableRecoverPartitionsCommand
command
AlterTableRenameCommand
command
AlterTableRenamePartitionCommand
command
AlterTableSerDePropertiesCommand
command
AlterTableSetLocationCommand
command
AlterTableSetPropertiesCommand
command
AlterTableToggleRowLevelSecurityCommand
execution
AlterTableUnsetPropertiesCommand
command
AlterViewAsCommand
command
AlterableRelation
sources
AnalysisErrorAt
analysis
AnalysisException
sql
AnalysisType
common
Analytics
graphx
AnalyzeColumnCommand
command
AnalyzeCreateTable
datasources
AnalyzeMutableOperations
SnappySessionState
AnalyzeTableCommand
command
Analyzer
analysis
AnalyzerInvocation
internal
And
expressions sources
AnonymousAuthenticationProviderImpl
auth
AnyCyclicBarrier
standalone
AnyDataType
types
AnyRef
scala
AppendColumns
logical
AppendColumnsExec
execution
AppendColumnsWithObject
logical
AppendColumnsWithObjectExec
execution
AppendOnlyMap
collection
ApplicationAttemptInfo
v1
ApplicationInfo
v1
ApplicationMaster
yarn
ApplicationMasterArguments
yarn
ApplicationStatus
v1
ApplyLimitOnExternalRelation
execution
ApplyRest
sources
ApproxColumn
bootstrap
ApproxColumnDebug
bootstrap
ApproxColumnExtractor
bootstrap
ApproxHist
QuantileStrategy
ApproxMaxCapacityOfBBMap
Property
Approximate
execution
ApproximatePercentile
aggregate
ApproximateType
execution
AqpDebug
Property
AqpDebugFixedSeed
Property
ArchiveResource
catalog
ArrayBasedMapData
util
ArrayContains
expressions
ArrayData
util
ArrayIndexOutOfBoundsException
scala
ArrayOpsExpression
bootstrap
ArrayType
types
Ascending
expressions
Ascii
expressions
Asin
expressions
AssertNotNull
objects
AssertTrue
expressions
Assignment
PowerIterationClustering
AssociationRules
fpm
AssociationRulesExample
mllib
AstBuilder
parser
AsyncInvocation
dunit
AsyncRDDActions
rdd
AtLeastNNonNulls
expressions
Atan
expressions
Atan2
expressions
AtomicType
types
Attribute
attribute expressions
AttributeEquals
expressions
AttributeGroup
attribute
AttributeMap
expressions
AttributeNameForErrorEstimate
GetErrorBounds
AttributeReference
expressions
AttributeSeq
expressions
AttributeSet
expressions
AttributeType
attribute
Authenticate
AnonymousAuthenticationProviderImpl CustomAuthenticationProviderImpl LdapAuthenticationProviderImpl PamAuthenticationProviderImpl PasswdAuthenticationProvider
AuthenticationProviderFactory
auth
AvailablePortHelper
dunit
Average
UserDefinedTypedAggregation aggregate
Avg
ErrorAggregate
Avg_Absolute
ErrorAggregate
Avg_Lower
ErrorAggregate
Avg_Relative
ErrorAggregate
Avg_Upper
ErrorAggregate
AvroConversionUtil
pythonconverters
AvroWrapperToJavaConverter
pythonconverters
a
AttributeEquals
abort
StateStore
abortJob
FileCommitProtocol HadoopMapReduceCommitProtocol ManifestFileCommitProtocol
abortTask
FileCommitProtocol HadoopMapReduceCommitProtocol ManifestFileCommitProtocol
abs
ExpressionConversions functions Decimal
absolute_error
functions
acceptsType
ObjectType
acceptsURL
DriverWrapper
accessToken
TwitterStreamRelation
accessTokenSecret
TwitterStreamRelation
accumUpdates
ExceptionFailure SparkListenerExecutorMetricsUpdate SparkListenerDriverAccumUpdates
accummulate
Hokusai
accumulable
SparkContext JavaSparkContext
accumulableCollection
SparkContext
accumulables
StageInfo TaskInfo
accumulator
SparkContext JavaSparkContext
accumulatorId
SQLMetricInfo
accumulatorUpdates
StageData TaskData
accuracy
MulticlassMetrics MultilabelMetrics
accuracyExpression
ApproximatePercentile
acos
functions
acquire
HiveSessionImpl HiveSessionImplwithUGI
acquireBufferForCompress
CompressionUtils
acquireExecutionMemory
TaskMemoryManager
acquireMemory
ByteBufferHashMap MemoryConsumer
acquireSharedLock
DUnitBB
acquireStorageMemory
SnappyUnifiedMemoryManager SharedUtils StoreCallbacksImpl
acquireStorageMemoryForObject
DefaultMemoryManager SnappyUnifiedMemoryManager StoreUnifiedManager
action
SnappyStreamingActionsCommand SinkFileStatus
active
StreamingQueryManager ReceiverInfo
activeJobs
JobProgressListener
activeSchedulerPool
SnappyConf
activeStages
JobProgressListener
activeStorageStatusList
ExecutorsListener StorageListener
activeTasks
ExecutorSummary
actualAggregateDataType
AQPFunctionParameter
actualColumn
BootstrapAddTrialsAsArray BootstrapAddTrialsAvgCountPart BootstrapSum AQPAverage
actualRow
StratumInternalRow
adaptiveExecutionEnabled
SQLConf
add
IFrequency Filter Accumulable BlockMatrix MultivariateOnlineSummarizer ExpressionSet PercentileDigest BoundedSortedSet MultiColumnOpenHashSet DoubleMutableRow StatCounterWithFullCount CountMinSketch TopKCMS SQLMetric CompactibleFileStreamLog EventTimeStats EventTimeStatsAccum SeenFilesMap FileStreamSourceLog HDFSMetadataLog MetadataLog StructType CalendarInterval AccumulatorV2 CollectionAccumulator DoubleAccumulator LegacyAccumulatorWrapper LongAccumulator OpenHashSet CountMinSketch
addAccumulator
AccumulableParam AccumulatorParam
addAndGet
DUnitBB
addAppArgs
SparkLauncher
addApplication
PersistenceEngine
addBatch
ConsoleSink FileStreamSink ForeachSink MemorySink Sink SnappyStoreSink SnappyStoreSink
addBinary
CountMinSketch
addBufferedState
CodegenContext
addColumn
AlterTableAddColumnCommand
addCredentials
SparkHadoopUtil YarnSparkHadoopUtil
addCurrentUserCredentials
SparkHadoopUtil YarnSparkHadoopUtil
addData
MemoryStream
addDictionaryString
DictionaryMap
addDriver
PersistenceEngine
addDriverJar
ContextJarUtils
addEpochData
Hokusai
addExpr
EquivalentExpressions
addExprTree
EquivalentExpressions
addExtraDriverProperties
SnappyStoreDialect JdbcExtendedDialect
addFetchRequest
TransportResponseHandler
addFile
SparkContext JavaSparkContext SparkLauncher
addFilters
JettyUtils
addFunctionArtifacts
ContextJarUtils
addGrid
ParamGridBuilder
addInPlace
AccumulableParam DoubleAccumulatorParam FloatAccumulatorParam IntAccumulatorParam LongAccumulatorParam MembershipAccumulator
addIntercept
GeneralizedLinearAlgorithm
addItems
StreamSummaryAggregation
addJar
SparkContext JavaSparkContext SparkLauncher
addJarURIs
SnappySession
addListener
SparkAppHandle StreamingQueryManager
addLocator
Host
addLong
ObjectHashSet SQLMetric CountMinSketch
addMemoryEventListener
SnappyUnifiedMemoryManager
addMissingGlobalTempSchema
SnappySessionCatalog
addMutableState
CodegenContext
addNewFunction
CodegenContext
addNull
DoubleMutableRow
addOuterScope
OuterScopes
addParamLiteral
SparkSQLPrepareImpl
addPartitionInitializationStatement
CodegenContext
addPathToEnvironment
YarnSparkHadoopUtil
addPrimitiveColumn
TableSchema
addPyFile
SparkLauncher
addQuery
StreamingRepository
addReferenceObj
CodegenContext
addRemoveUserForKey
PermissionChecker
addRow
ColumnBasedSet RowBasedSet RowSet
addRpcRequest
TransportResponseHandler
addSampleDataFrame
SnappyAQPSessionCatalog
addSecretKeyToUserCredentials
SparkHadoopUtil YarnSparkHadoopUtil
addService
CompositeService
addSparkArg
SparkLauncher
addSparkListener
SparkContext
addSplitProperty
JdbcExtendedUtils
addStreamCallback
TransportResponseHandler
addStreamingListener
StreamingContext JavaStreamingContext
addString
CountMinSketch
addStringColumn
TableSchema
addTaskCompletionListener
TaskContext
addTaskFailureListener
TaskContext
addTimestampedData
Hokusai
addToColVals
TRow
addToColumns
TRowSet TTableSchema
addToDef
ColocatedWithFilters NonColocated Replicates
addToInfoMessages
TStatus
addToRows
TRowSet
addToTableTypes
TGetTablesReq
addToTheListInCmdRegion
ContextJarUtils
addToTypes
TTypeDesc
addToValues
TBinaryColumn TBoolColumn TByteColumn TDoubleColumn TI16Column TI32Column TI64Column TStringColumn
addURIs
ToolsCallback ToolsCallbackImpl
addURIsToExecutorClassLoader
ToolsCallback ToolsCallbackImpl
addURL
ExtendibleURLClassLoader
addVM
Host
addValue
Column
addWithoutResize
OpenHashSet
addWorker
PersistenceEngine
add_months
functions
addedFunctions
CodegenContext
additionalBuiltinFunctions
SparkSnappyUtils
address
Person RDDDataDistribution
advanceNext
RowIterator
advanceToNextBatchSet
ColumnFormatIterator
afterClass
DistributedTestBase
afterColumnStorePuts
ColumnFormatEncoder
afterDeserializationWithValue
ColumnFormatKey
afterRun
Operation
age
Person User Person Person
agg
Dataset KeyValueGroupedDataset RelationalGroupedDataset
aggBufferAttributes
DenseRank NTile RankLike RowNumberLike AggregateFunction Average CentralMomentAgg Collect Corr Count Covariance First HyperLogLogPlusPlus Last Max Min PivotFirst Sum TypedImperativeAggregate ScalaUDAF TypedAggregateExpression BootstrapAverage BootstrapCount BootstrapMultiplicityAggregate BootstrapSum ClosedFormErrorEstimate AQPAverage AQPCount AQPSum
aggBufferAttributesForGroup
GroupAggregate BootstrapAverage BootstrapMultiplicityAggregate BootstrapSum ClosedFormErrorEstimate AQPSum
aggBufferSchema
AggregateFunction Collect DeclarativeAggregate HyperLogLogPlusPlus PivotFirst TypedImperativeAggregate ScalaUDAF
aggType
ClosedFormColumnExtractor StatCounterAggregator StatCounterAggregatorCreator
aggUntyped
KeyValueGroupedDataset
aggrMemoryUsageTrend
MemberSummary
aggregate
JavaRDDLike RDD expressions execution
aggregateAttributes
HashAggregateExec SnappyHashAggregateExec SortAggregateExec SnappyPartialHashAggregate SnappyPartialSortedAggregate
aggregateBufferVars
SHAMapAccessor
aggregateByKey
JavaPairRDD PairRDDFunctions
aggregateExpressions
Aggregate HashAggregateExec SnappyHashAggregateExec SortAggregateExec
aggregateFunction
AggregateExpression
aggregateFunctions
AggregationIterator
aggregateMessages
Graph
aggregateMessagesWithActiveSet
GraphImpl
aggregateName
BootstrapMultiplicity
aggregateStats
TableStatsProviderService
aggregateType
StatCounterMergerer ErrorAggregateFunction
aggregateUsingIndex
VertexRDD VertexRDDImpl
aggregates
Pivot ItemAggregation TimeAggregation
aggregation
SqlBaseParser
aggregations
GroupingSets
aggregator
ShuffleDependency TypedAggregateExpression
aic
GeneralizedLinearRegressionSummary
airlinefilePath
CreateAndLoadAirlineDataJob
airlinereftablefilePath
CreateAndLoadAirlineDataJob
algo
Params Params Params Params Params Strategy DecisionTreeModel GradientBoostedTreesModel RandomForestModel
algorithm
Params StreamingLogisticRegressionWithSGD StreamingLinearAlgorithm StreamingLinearRegressionWithSGD
alias
Column Dataset SnappyParser UnresolvedRelation SubqueryAlias DeployCommand DeployJarCommand UnDeployCommand
aliasFunc
UnresolvedAlias
alignToWords
UnsafeRowWriter
allAttributes
QueryPlan HashAggregateExec SnappyHashAggregateExec
allCompatible
Partitioning
allData
MemorySink
allDecoders
ColumnEncoding
allEntries
SeenFilesMap
allFiles
PartitioningAwareFileIndex CompactibleFileStreamLog
allImperativeAggregateFunctionPositions
AggregationIterator
allImperativeAggregateFunctions
AggregationIterator
allInterpretedLinesForReplay
RemoteInterpreterStateHolder
allKeywords
SnappyParserConsts
allNodes
SparkPlanGraph
allParamLiterals
SparkSQLPrepareImpl
allQueries
StreamsSummary
allocate
HeapMemoryAllocator MemoryAllocator UnsafeMemoryAllocator UnsafeSortDataFormat
allocateArray
MemoryConsumer
allocateExecutionMemory
MemoryManagerCallback
allocateExprID
NamedExpression
allocatePage
MemoryConsumer TaskMemoryManager
allocator
ByteBufferHashMap ColumnEncoder
allocatorTerm
SHAMapAccessor
allowCreate
ColumnDeleteDelta ColumnDelta
allowDDL
SnappyDDLParser
allowExisting
CreateViewCommand
allowOpeningOfPlaceHolderPlan
PlaceHolderPlan
allowedPlanHints
SnappyParserConsts
alpha
WeibullGenerator
alphaUnderscore
SnappyParserConsts
alreadyPolicyApplied
RowLevelSecurity
altName
SQLValue SparkValue AltName
alterDatabase
SmartConnectorExternalCatalog ExternalCatalog InMemoryCatalog SessionCatalog SnappyHiveExternalCatalog SnappySessionCatalog
alterPartitions
SmartConnectorExternalCatalog ExternalCatalog InMemoryCatalog SessionCatalog SnappyHiveExternalCatalog SnappySessionCatalog
alterTable
SmartConnectorExternalCatalog SnappyContext SnappyDDLParser SnappySession ExternalCatalog InMemoryCatalog SessionCatalog SnappyHiveExternalCatalog SnappySessionCatalog JDBCMutableRelation AlterableRelation
alterTableOrView
SnappyDDLParser
alterTableSchema
SnappyExternalCatalog ExternalCatalog InMemoryCatalog
alterTableToggleRowLevelSecurity
SnappyDDLParser
alterTempViewDefinition
SessionCatalog SnappySessionCatalog
alterView
SnappyDDLParser
analysis
catalyst
analysisException
Utils
analysisType
AQPInfo ErrorAndConfidence SampleTableQuery
analytics
clearspring
analyze
SnappyParser DslLogicalPlan
analyzed
LogicalPlan QueryExecution
analyzer
SnappySessionState AnalyzeMutableOperations SnappyAQPSessionState ResolveIndex
analyzerInvoc
ByPassErrorCalculationsConditionally EnsureSampleWeightageColumn ErrorEstimateRule GetErrorBounds MoveUpBootstrapReferencerConditionally PostReplaceSampleTableQueryRoutingRules QueryRoutingRules WeightageRule
analyzerInvocation
ReplaceWithSampleTable
and
Column
andExpression
SnappyParser
andNot
BitSet
annotation
spark
antecedent
Rule
anyNull
Row InternalRow BaseGenericInternalRow JoinedRow UnsafeRow SerializedArray SerializedRow StratumInternalRow
anyNullsSet
ColumnVector
anySet
BitSet
apache
org
api
spark sql status streaming
appAttemptId
SparkListenerApplicationStart
appId
SparkListenerApplicationStart SparkUI
appName
SparkContext JavaSparkContext ClassLoaderKey SparkListenerApplicationStart Builder SparkUI
appNameAndJars
ClassLoaderKey
appTime
ClassLoaderKey
appUIBaseAddress
SnappyDashboardTab
append
LogDivertAppender BufferedRowIterator StratifiedSampler StratifiedSamplerCached StratifiedSamplerCachedInRegion StratifiedSamplerErrorLimit StratifiedSamplerReservoir ColumnFormatSamplingRelation SchemaInsertableRelation TopKRelation Location
appendArray
ColumnVector
appendBias
MLUtils
appendBoolean
ColumnVector
appendBooleans
ColumnVector
appendByte
ColumnVector
appendByteArray
ColumnVector
appendBytes
ColumnVector
appendClause
StoreUtils
appendDouble
ColumnVector
appendDoubles
ColumnVector
appendFloat
ColumnVector
appendFloats
ColumnVector
appendInt
ColumnVector
appendInts
ColumnVector
appendLong
ColumnVector
appendLongs
ColumnVector
appendNotNull
ColumnVector
appendNotNulls
ColumnVector
appendNull
ColumnVector
appendNulls
ColumnVector
appendRow
FixedLengthRowBasedKeyValueBatch RowBasedKeyValueBatch VariableLengthRowBasedKeyValueBatch ColumnBatchRowsBuffer
appendS3AndSparkHadoopConfigurations
SparkHadoopUtil
appendShort
ColumnVector
appendShorts
ColumnVector
appendStruct
ColumnVector
appendToTempTableCache
DataFrameJavaFunctions SnappyContext SnappySession
appendableRelation
ColumnDeleteExec
applicationAttemptId
SparkContext
applicationId
SparkContext SchedulerExtensionServiceBinding SnappyCoarseGrainedSchedulerBackend
applicationRemoved
ExternalShuffleBlockHandler ExternalShuffleBlockResolver
apply
CreateNewSession GenericValidatingConverter IdentityValidatingConverter MapValidatingConverter NullValidatingConverter StructValidatingConverter ValidatingConverter Graph Pregel VertexRDD GraphImpl UnifiedMemoryManager AttributeGroup DenseMatrix DenseVector Matrix SparseMatrix Vector ParamMap DenseMatrix DenseVector Matrix SparseMatrix Vector AccumulableInfo CachedDataFrame CachedKey CollapseCollocatedPlans Column Dataset InsertCachedPlanFallback Row SnappyAggregationStrategy SnappyContext TokenizeSubqueries FunctionIdentifier InternalRow AddSubquery ConstructSubqueryExpressions NormalizedAttribute RemoveSubqueriesAboveSQLTable ResolveSQLTable TableIdentifier CTESubstitution ExtractGenerator ExtractWindowExpressions FixNullability GlobalAggregates HandleNullInputsForUDF PullOutNondeterministic ResolveAggregateFunctions ResolveAliases ResolveDeserializer ResolveFunctions ResolveGenerate ResolveGroupingAnalytics ResolveMissingReferences ResolveNaturalAndUsingJoin ResolveNewInstance ResolveOrdinalInOrderByAndGroupBy ResolvePivot ResolveReferences ResolveRelations ResolveSubquery ResolveUpCast ResolveWindowFrame ResolveWindowOrder WindowsSubstitution CleanupAliases DecimalPrecision EliminateSubqueryAliases EliminateUnions ResolveCreateNamedStruct ResolveInlineTables ResolveTableValuedFunctions SubstituteUnresolvedOrdinals TimeWindowing BooleanEquality CaseWhenCoercion DateTimeOperations Division FunctionArgumentConversion IfCoercion ImplicitTypeCasts InConversion PromoteStrings PropagateTypes WidenSetOperationTypes UnresolvedAttribute UnresolvedFunction ExpressionEncoder RowEncoder AttributeMap AttributeSeq AttributeSet CaseKeyWhen CaseWhen CreateStruct DecimalLiteral ExprId ExpressionSet ExtractValue FrameBoundary FromUnsafeProjection InterpretedMutableProjection InterpretedProjection JoinedRow Literal Rand Randn SortOrder TimeWindow UnsafeProjection AggregateExpression Count DumpByteCode CleanExpressions ExternalMapToCatalyst MapObjects NewInstance BooleanSimplification CheckCartesianProducts CollapseProject CollapseRepartition CollapseWindow ColumnPruning CombineFilters CombineLimits CombineTypedFilters CombineUnions ComputeCurrentTime ConstantFolding ConvertToLocalRelation DecimalAggregates EliminateOuterJoin EliminateSerialization EliminateSorts FoldablePropagation GetCurrentDatabase InferFiltersFromConstraints LikeSimplification LimitPushDown NullPropagation OptimizeCodegen OptimizeIn OptimizeSubqueries PropagateEmptyRelation PruneFilters PushDownPredicate PushPredicateThroughJoin PushProjectionThroughUnion RemoveDispensableExpressions RemoveLiteralFromGroupExpressions RemoveRedundantAliases RemoveRedundantProject RemoveRepetitionFromGroupExpressions ReorderAssociativeOperator ReorderJoin ReplaceDistinctWithAggregate ReplaceExceptWithAntiJoin ReplaceExpressions ReplaceIntersectWithSemiJoin RewriteCorrelatedScalarSubquery RewriteDistinctAggregates RewritePredicateSubquery SimplifyBinaryComparison SimplifyCaseConversionExpressions SimplifyCasts SimplifyConditionals GenericStrategy JoinType AppendColumns CoGroup Expand FlatMapGroupsInR Limit LocalRelation MapElements MapGroups MapPartitions MapPartitionsInR Range TypedFilter Union Rule TreeNode ArrayBasedMapData CaseInsensitiveMap StringKeyHashMap MultiColumnOpenHashMap SegmentMap BucketsBasedIterator CMSParams CollapseCodegenStages ExternalRDD GroupedIterator OptimizeMetadataOnlyQuery PlanSubqueries ReservoirRegionSegmentMap ReuseSubquery SnapshotConnectionListener Aggregation BasicOperators DDLStrategy InMemoryScans JoinSelection SpecialLimits StatefulAggregationStrategy StreamingRelationStrategy StratifiedSampler TopKWrapper TypedAggregateExpression BootstrapStructType CleanupBootstrapAnalysisExpressions PoissonCreator PropagateBootstrapColumns PruneProjects PushUpSeed ColumnBatchIterator InMemoryRelation ColumnDeleteDelta DeltaWriter UpdatedColumnDecoder ColumnDelta CreateSampleTableCommand ByPassErrorCalculationsConditionally CleanupErrorEstimateAttribute EnsureSampleWeightageColumn ErrorEstimateRule GetErrorBounds HideSubqueryNodes ImplementSnappyAggregate MakeSubqueryNodesInvisible MakeSubqueryNodesVisible MoveUpBootstrapReferencerConditionally PostReplaceSampleTableQueryRoutingRules QueryRoutingRules ReplaceWithSampleTable UnHideSubqueryNodes WeightageRule AnalyzeCreateTable DataSourceAnalysis DataSourceStrategy FileSourceStrategy FindDataSourceTable HiveOnlyCheck PartitionPath PreWriteCheck PreprocessTableInsertion ResolveDataSource CSVOptions JsonDataSource EnsureRequirements ReuseExchange ShuffleExchange ExtractPythonUDFFromAggregate ExtractPythonUDFs UserDefinedPythonFunction MapPartitionsRWrapper FileStreamSourceOffset LongOffset MemoryStream OffsetSeqMetadata SinkFileStatus StreamingExecutionRelation StreamingRelation SparkPlanGraph UserDefinedAggregateFunction UserDefinedFunction HiveConditionalRule HiveConditionalStrategy IdentifySampledRelation OptimizeSortAndFilePlans SnappyPromoteStrings AnalyzeMutableOperations ExternalRelationLimitFetch LinkPartitionsToBuckets OrderJoinConditions PushDownWindowLogicalPlan ResolveAliasInGroupBy RowLevelSecurity TokenizedLiteralFolding HiveScriptIOSchema ResolveErrorEstimateFunctions LikeEscapeSimplification SQLConfigEntry ApplyRest ColocatedWithFilters JoinOrderStrategy LargestColocationChain NonColocated Replicates ResolveIndex ResolveQueryHints StoreStrategy ProcessingTime ArrayType Decimal MapType StructType BlockId StorageLevel Milliseconds Minutes Seconds StatCounter AppendOnlyMap
applyAggregation
SnappyAggregationStrategy
applyBootstrapReferencerRule
MoveUpBootstrapReferencerConditionally
applyByPassErrorCalculationsConditionally
ByPassErrorCalculationsConditionally
applyDefaultAction
RuleUtils
applyErrorEstimateRule
ErrorEstimateRule
applyGetErrorBounds
GetErrorBounds
applyMultiplicity
DebugIndpndntPredictable
applyRecursivelyToInvisiblePlaceHolderPlan
PlaceHolderPlan
applyRule
CleanupBootstrapAnalysisExpressions PropagateBootstrapColumns PruneProjects PushUpSeed CleanupErrorEstimateAttribute ImplementSnappyAggregate IdentifySampledRelation
applySampleWeightageRule
EnsureSampleWeightageColumn
applySchema
SQLContext
applyTo
CreatePolicyCommand
applyWeightageRule
WeightageRule
approxCountDistinct
ExpressionConversions functions
approxMaxCapacity
ByteBufferHashMap
approxQuantile
DataFrameStatFunctions
approx_count_distinct
functions
approximate
sql
aqp
sql execution
aqpInfo
SnappyContextAQPFunctions
aqpRelations
SampleInsertExec
aqpTablePopulator
SnappyContextFunctions SnappyContextAQPFunctions
areaUnderPR
BinaryClassificationMetrics
areaUnderROC
BinaryLogisticRegressionSummary BinaryClassificationMetrics
argString
TreeNode CreateTempViewUsing CreateHiveTableAsSelectCommand
argmax
DenseVector SparseVector Vector DenseVector SparseVector Vector
args
ApplicationMasterArguments
argumentClass
AppendColumns MapElements TypedFilter
argumentSchema
AppendColumns MapElements TypedFilter
arguments
Invoke InvokeLike NewInstance StaticInvoke
arithmeticOperator
SnappyParserConsts SqlBaseParser
array
ColumnName ImplicitAttribute UnsafeArrayData ArrayData GenericArrayData SerializedArray functions unsafe
array1
ArrayOpsExpression
array2
ArrayOpsExpression
arrayData
ColumnVector
arrayLengthGt
ParamValidators
arrayOpsBehaviour
BootstrapFunctions
arrayOpsFunction
BootstrapFunctions
arrayType
SnappyBaseParser LegacyTypeStringParser
array_contains
functions
as
Column Dataset ImplicitOperators DslLogicalPlan
asCode
TreeNode
asConnectionProperties
JDBCOptions
asIterator
DeserializationStream
asKeyValueIterator
DeserializationStream
asLiteral
ParamLiteral
asML
DenseMatrix DenseVector Matrix SparseMatrix SparseVector Vector
asNullable
ObjectType
asProperties
JDBCOptions
asRDDId
BlockId
asc
Column ImplicitOperators functions
asc_nullsLast
ImplicitOperators
asc_nulls_first
Column functions
asc_nulls_last
Column functions
ascendingOrder
SortArray
ascii
functions
asin
functions
assertAnalyzed
QueryExecution
assertState
Operation
assertSupported
QueryExecution IncrementalExecution
assertUnresolved
ExpressionEncoder
assertValid
Broadcast
assignments
PowerIterationClusteringModel
astBuilder
SnappySqlParser AbstractSqlParser CatalystSqlParser SparkSqlParser
at
DslAttribute
atGrowThreshold
AppendOnlyMap
atan
functions
atan2
functions
attachSparkUI
HistoryServer
attachTree
errors
attachUI
SnappyHiveThriftServer2
attempt
TaskData
attemptId
StageInfo SchedulerExtensionServiceBinding ApplicationAttemptInfo StageData
attemptNumber
TaskCommitDenied TaskContext TaskInfo
attempts
ApplicationInfo
attr
Edge EdgeContext DslString ImplicitAttribute
attrType
Attribute BinaryAttribute NominalAttribute NumericAttribute UnresolvedAttribute
attribute
ml EqualNullSafe EqualTo GreaterThan GreaterThanOrEqual In IsNotNull IsNull LessThan LessThanOrEqual StringContains StringEndsWith StringStartsWith
attributeMap
LogicalRelation
attributeTransformer
GetErrorBounds
attributes
AttributeGroup InMemoryTableScanExec
attributesFor
ScalaReflection
attrs
ExpressionEncoder AttributeSeq
auth
service
authId
CreateSchemaCommand
authToken
RemoteInterpreterStateHolder
authorizeMetaGets
MetadataOperation
authorizeTableOperation
SecurityUtils
autoBroadcastJoinThreshold
SQLConf
available
LZ4BlockInputStream NioBufferedFileInputStream LimitedInputStream
availableOffsets
ProgressReporter StreamExecution
avg
RelationalGroupedDataset ExpressionConversions CentralMomentAgg EventTimeStats typed functions DoubleAccumulator LongAccumulator
avgInputRowsPerSec
StreamingQueryStatistics
avgLen
ColumnStat
avgMetrics
CrossValidatorModel
avgProcessedRowsPerSec
StreamingQueryStatistics
avgProcessingTime
StreamingQueryStatistics
await
AnyCyclicBarrier
awaitAnyTermination
StreamingQueryManager
awaitInitialization
StreamExecution
awaitResult
CommonUtils
awaitTermination
CurrentThreadExecutor StreamExecution StreamingQueryWrapper StreamingQuery StreamingContext JavaStreamingContext
awaitTerminationOrTimeout
StreamingContext JavaStreamingContext