C
SnappySQLJob SnappySessionFactory SnappyStreamingContextFactory SnappyStreamingJob
CACHE
SnappyDDLParser SnappyParserConsts
CALL
SnappyDDLParser SnappyParserConsts
CASCADE
SnappyDDLParser SnappyParserConsts
CASE
SnappyDDLParser SnappyParserConsts
CASE_SENSITIVE
SQLConf
CAST
SnappyDDLParser SnappyParserConsts
CATALOG_IMPLEMENTATION
StaticSQLConf
CDCExample
structuredstreaming
CHANGEABLE_JAR_NAME
Constant
CHAR
SnappyBaseParser SnappyParserConsts
CHAR_TYPE_BASE_PROP
Constant
CHAR_TYPE_SIZE_PROP
Constant
CHECK
SnappyDDLParser SnappyParserConsts
CHECKPOINT_LOCATION
SQLConf
CLEAR
SnappyDDLParser SnappyParserConsts
CLEAR_CODEGEN_CACHE
RefreshMetadata
CLIService
cli
CLIServiceClient
cli
CLIServiceUtils
cli
CLOB
SnappyBaseParser SnappyParserConsts
CLUSTER
SnappyDDLParser SnappyParserConsts
CLUSTERED
SnappyDDLParser SnappyParserConsts
CLUSTER_ID
Constant
CMSCompressException
CountMinSketch
CMSMergeException
CountMinSketch
CMSParams
execution
CODEGEN
SnappyDDLParser SnappyParserConsts
COLOCATE_WITH
StoreUtils
COLUMN
SnappyDDLParser SnappyParserConsts
COLUMNS
SnappyDDLParser SnappyParserConsts
COLUMN_BATCH_SIZE
ExternalStoreUtils SQLConf
COLUMN_BATCH_SIZE_TRANSIENT
ExternalStoreUtils
COLUMN_MAX_DELTA_ROWS
ExternalStoreUtils
COLUMN_MAX_DELTA_ROWS_TRANSIENT
ExternalStoreUtils
COLUMN_NAME_OF_CORRUPT_RECORD
SQLConf
COLUMN_SOURCE
SnappyParserConsts
COLUMN_TABLE_INDEX_PREFIX
Constant
COMMENT
SnappyDDLParser SnappyParserConsts
COMPACT_FILE_SUFFIX
CompactibleFileStreamLog
COMPLEX_TYPE_AS_JSON_DEFAULT
Constant
COMPLEX_TYPE_AS_JSON_HINT
Constant
COMPRESSION_CODEC
ExternalStoreUtils
COMPRESSION_CODEC_DEPRECATED
StoreUtils
COMPRESSION_MIN_SIZE
Constant
COMPRESS_CACHED
SQLConf
COMPUTE
SnappyDDLParser SnappyParserConsts
CONF
FileStreamRelation
CONFIDENCE
SnappyAQPParser SnappyParserConsts
CONNECTION_PROPERTY
Constant
CONSTRAINT
SnappyDDLParser SnappyParserConsts
CONSTRAINT_PROPAGATION_ENABLED
SQLConf
CONVERT_CTAS
SQLConf
COUNT_ATTRIBUTE
ColumnStatsSchema
COUNT_INDEX_IN_SCHEMA
ColumnStatsSchema
CPUS_PER_TASK_PROP
Constant
CREATE
SnappyDDLParser SnappyParserConsts
CROSS
SnappyDDLParser SnappyParserConsts
CROSS_JOINS_ENABLED
SQLConf
CSVFileFormat
csv
CSVFileSourceExampleWithSnappySink
structuredstreaming
CSVKafkaSourceExampleWithSnappySink
structuredstreaming
CSVOptions
csv
CSVRelation
csv
CTESubstitution
Analyzer
CUBE
SnappyDDLParser SnappyParserConsts
CURRENT
SnappyDDLParser SnappyParserConsts
CURRENT_DATE
SnappyDDLParser SnappyParserConsts
CURRENT_TIMESTAMP
SnappyDDLParser SnappyParserConsts
CURRENT_USER
SnappyDDLParser SnappyParserConsts
CacheManager
execution
CacheTableCommand
command
CachedData
execution
CachedDataFrame
sql
CachedFieldWrapper
bootstrap
CachedKey
sql
CalendarInterval
types
CalendarIntervalType
types
CallMethodViaReflection
expressions
CallbackColumnInsert
columnar
CancelDelegationToken
ThriftCLIService
CancelOperation
ThriftCLIService
CanonicalRandomVertexCut
PartitionStrategy
Canonicalize
expressions
Canonicalizer
SQLBuilder
CartesianProductExec
joins
CaseInsensitiveMap
util
CaseInsensitiveMutableHashMap
ExternalStoreUtils
CaseKeyWhen
expressions
CaseWhen
expressions
CaseWhenBase
expressions
CaseWhenCodegen
expressions
CaseWhenCoercion
TypeCoercion
Cast
expressions
CastDouble
sources
CastLongTime
sources
Catalog
catalog
CatalogCacheSize
Property
CatalogDatabase
catalog
CatalogFileIndex
datasources
CatalogFunction
catalog
CatalogImpl
internal
CatalogObjectType
catalog
CatalogRelation
catalog
CatalogStaleException
execution
CatalogStorageFormat
catalog
CatalogTable
catalog
CatalogTablePartition
catalog
CatalogTableType
catalog
CatalogTypes
catalog
CatalogUtils
catalog
CatalystConf
catalyst
CatalystScan
sources
CatalystSerde
logical
CatalystSqlParser
parser
CatalystTypeConverters
catalyst
CatchErrorPlan
common
Categorical
FeatureType
CategoricalSplit
tree
Cbrt
expressions
Ceil
expressions
CentralMomentAgg
aggregate
ChangeValue
collection
CharType
types
CheckAnalysis
analysis
CheckCartesianProducts
optimizer
CheckOverflow
expressions
ChiSqSelector
feature feature
ChiSqSelectorExample
ml mllib
ChiSqSelectorModel
feature feature
ChiSqTestResult
test
ChildVM
standalone
ChunkFetchFailure
protocol
ChunkFetchFailureException
client
ChunkFetchRequest
protocol
ChunkFetchSuccess
protocol
ChunkReceivedCallback
client
ClassCastException
scala
ClassLoaderKey
SnappyExecutor
ClassicTableTypeMapping
operation
Classification
Algo
ClassificationModel
classification classification
Classifier
classification
CleanExpressions
ExpressionCanonicalizer
CleanupAliases
analysis
CleanupBootstrapAnalysisExpressions
bootstrap
CleanupErrorEstimateAttribute
common
ClearCacheCommand
command
Client
deploy
CloseOperation
ThriftCLIService
CloseSession
ThriftCLIService
ClosedFormColumnExtractor
closedform
ClosedFormErrorEstimate
closedform
ClosedFormEstimates
Property
ClosedFormStats
closedform
Closedform
AnalysisType
ClusterCallbacksImpl
gemxd
ClusterDetails
v1
ClusterMode
sql
ClusterSummary
v1
ClusterUtils
bootstrap
ClusteredColumnIterator
impl
ClusteredDistribution
physical
ClusteringSummary
clustering
CoGroup
logical
CoGroupExec
execution
CoGroupFunction
function
CoGroupedIterator
execution
CoGroupedRDD
rdd
Coalesce
expressions
CoalesceDisparateTypes
common
CoalesceExec
execution
CoalescedPartitioner
execution
CodeAndComment
codegen
CodeFormatter
codegen
CodeGenerationException
internal
CodeGenerator
codegen
CodecStreams
datasources
CodegenContext
codegen
CodegenFallback
codegen
CodegenMetrics
source
CodegenSparkFallback
execution
CodegenSupport
execution
CodegenSupportOnExecutor
execution
CollapseCodegenStages
execution
CollapseCollocatedPlans
sql
CollapseProject
optimizer
CollapseRepartition
optimizer
CollapseWindow
optimizer
Collect
aggregate
CollectAggregateExec
aggregate
CollectLimitExec
execution
CollectList
aggregate
CollectSet
aggregate
CollectionAccumulator
util
CollocatedJoinExample
snappydata
ColocatedWithFilters
sources
Column
CatalogObjectType cli sql catalog
ColumnBasedSet
cli
ColumnBatch
columnar
ColumnBatchCreator
columnar
ColumnBatchIterator
columnar
ColumnBatchIteratorOnRS
columnar
ColumnBatchRowsBuffer
columnar
ColumnBatchSize
Property
ColumnCompactionRatio
Property
ColumnCompactor
impl
ColumnDecoder
encoding
ColumnDeleteDecoder
encoding
ColumnDeleteDelta
encoding
ColumnDeleteEncoder
encoding
ColumnDeleteExec
columnar
ColumnDelta
impl
ColumnDeltaDecoder
encoding
ColumnDeltaEncoder
encoding
ColumnDescriptor
cli
ColumnDirectionMap
SnappyDDLParser
ColumnEncoder
encoding
ColumnEncoding
encoding
ColumnExec
columnar
ColumnFormatEncoder
impl
ColumnFormatEntry
impl
ColumnFormatIterator
impl
ColumnFormatKey
impl
ColumnFormatRelation
impl
ColumnFormatSamplingRelation
sampling
ColumnFormatValue
impl
ColumnInsertExec
columnar
ColumnMaxDeltaRows
Property
ColumnName
sql
ColumnPartitionResolver
impl
ColumnPartitioner
store
ColumnPruning
optimizer
ColumnPutIntoExec
columnar
ColumnStat
logical
ColumnStatsSchema
encoding
ColumnTableBulkOps
internal
ColumnUpdateCompactionRatio
Property
ColumnUpdateExec
columnar
ColumnValue
cli
ColumnVector
vectorized
ColumnVectorUtils
vectorized
ColumnWriter
columnar
ColumnarBatch
vectorized
ColumnarIterator
columnar
ColumnarStorePartitionedRDD
impl
ColumnsAsClob
QueryHint
CombineFilters
optimizer
CombineLimits
optimizer
CombineTypedFilters
optimizer
CombineUnions
optimizer
Command
logical
CommonUtils
execution
CompactExecRowIteratorOnRS
row
CompactExecRowIteratorOnScan
row
CompactibleFileStreamLog
streaming
CompactionResult
impl
Complete
aggregate
CompletePlan
sources
ComplexFutureAction
spark
ComplexTypeAsJson
QueryHint
ComplexTypeSerializerImpl
impl
CompositeService
service
ComprehensiveExample
graphx
CompressionCodec
io
CompressionCodecId
store
CompressionCodecs
util
CompressionUtils
store
ComputeCurrentTime
optimizer
Concat
expressions
ConcatWs
expressions
Conf
SVDPlusPlus
Confidence
Property common
ConfigLocator
log4j
ConfigProvider
util
ConnectedComponents
lib
ConnectedComponentsExample
graphx
ConnectionConf
jdbc
ConnectionConfBuilder
jdbc
ConnectionFactory
JdbcRDD
ConnectionPool
execution
ConnectionProperties
sources
ConnectionPropertiesSerializer
serializer
ConnectionType
columnar ConnectionType
ConnectionUtil
jdbc
ConnectorExternalCatalog
catalog
ConsoleSink
streaming
ConsoleSinkProvider
streaming
Constant
snappydata
ConstantAbsoluteError
common
ConstantErrorEstimate
common
ConstantFolding
optimizer
ConstantInputDStream
dstream
ConstantLowerBound
common
ConstantRelativeError
common
ConstantUpperBound
common
ConstructSubqueryExpressions
Canonicalizer
ConstructorCleaner
repl
Contains
expressions
ContextJarUtils
internal
ContinueOptimizations
JOS sources
Continuous
FeatureType
ContinuousSplit
tree
Conv
expressions
ConvertToLocalRelation
optimizer
Converter
python
CookieSigner
service
CoordinateMatrix
distributed
Corr
aggregate
Correlations
mllib
CorrelationsExample
mllib
Cos
expressions
Cosh
expressions
CosineSimilarity
mllib
Count
aggregate ErrorAggregate
CountMinSketch
cms sketch
CountVectorizer
feature
CountVectorizerExample
ml
CountVectorizerModel
feature
Count_Absolute
ErrorAggregate
Count_Lower
ErrorAggregate
Count_Relative
ErrorAggregate
Count_Upper
ErrorAggregate
Counter
stream
CovPopulation
aggregate
CovSample
aggregate
Covariance
aggregate
Crc32
expressions
CreatableRelationProvider
sources
CreateAndLoadAirlineDataJob
examples
CreateArray
expressions
CreateColumnTable
snappydata
CreateDataSourceTableAsSelectCommand
command
CreateDataSourceTableCommand
command
CreateDatabaseCommand
command
CreateExternalRow
objects
CreateFunctionCommand
command
CreateHiveTableAsSelectCommand
execution
CreateIndexCommand
execution
CreateMap
expressions
CreateNamedStruct
expressions
CreateNamedStructLike
expressions
CreateNamedStructUnsafe
expressions
CreateNewSession
gemxd
CreatePartitionedRowTable
snappydata
CreatePolicyCommand
execution
CreateReplicatedRowTable
snappydata
CreateSampleTableCommand
command
CreateSchemaCommand
execution
CreateStruct
expressions
CreateTable
datasources
CreateTableCommand
command
CreateTableLikeCommand
command
CreateTableUsingCommand
execution
CreateTempViewUsing
datasources
CreateViewCommand
command
Cross
plans
CrossValidator
tuning
CrossValidatorModel
tuning
Cube
expressions
CumeDist
expressions
CurrentBatchTimestamp
expressions
CurrentDatabase
expressions
CurrentDate
expressions
CurrentOrigin
trees
CurrentRow
expressions
CurrentThreadExecutor
bootstrap
CurrentTimestamp
expressions
CurrentUser
policy
CustomAuthenticationProviderImpl
auth
CustomReceiver
streaming
cParent
ObjectHashMapAccessor
cache
JavaDoubleRDD JavaPairRDD JavaRDD Graph EdgeRDDImpl GraphImpl VertexRDDImpl BlockMatrix RDD Dataset SnappyDDLParser SchemaDStream JavaDStream JavaPairDStream DStream
cacheMetrics
HistoryServer
cacheNodeIds
Params Params Params
cacheQuery
CacheManager
cacheSize
ConnectorExternalCatalog SparkExecutorInfo DoubleMutableRow StorageStatus
cacheTable
SQLContext Catalog CatalogImpl
cacheThreadLocalRawStore
ThreadWithGarbageCleanup
cachedBootstrapCurrentSeed
BootstrapMultiplicityAggregate
cachedBootstrapCurrentState
BootstrapMultiplicityAggregate
cachedBootstrapResultField
BootstrapMultiplicityAggregate
cachedBootstrapSeedArray
BootstrapMultiplicityAggregate
cachedCatalogTables
SnappyHiveExternalCatalog
cachedColumnBuffers
InMemoryRelation
cachedDataSourceTables
SnappySessionCatalog
cachedFieldName
CachedFieldWrapper
cachedRepresentation
CachedData
cachedWeightField
BootstrapMultiplicityAggregate
calcAvgOfGivenTrend
StreamingQueryStatistics
calculate
Entropy Gini Impurity Variance
calculateBitSetWidthInBytes
SerializedRowData
calculateCov
StatFunctions
calculateMultiplicityResultSize
BootstrapMultiplicity
calculateNumberOfBytesForNullBits
SHAMapAccessor
calculateTotalSize
AnalyzeTableCommand
calculateWeightageColumn
StratumReservoir
call
CoGroupFunction DoubleFlatMapFunction DoubleFunction FilterFunction FlatMapFunction FlatMapFunction2 FlatMapGroupsFunction ForeachFunction ForeachPartitionFunction Function Function0 Function2 Function3 Function4 MapFunction MapGroupsFunction MapPartitionsFunction PairFlatMapFunction PairFunction ReduceFunction VoidFunction VoidFunction2 UDF1 UDF10 UDF11 UDF12 UDF13 UDF14 UDF15 UDF16 UDF17 UDF18 UDF19 UDF2 UDF20 UDF21 UDF22 UDF3 UDF4 UDF5 UDF6 UDF7 UDF8 UDF9
callFunction
ExpressionConversions
callSite
RDDInfo
callUDF
functions
callbackBeforeClearing
AQPInfoStoreTestHook
canAlter
SnappyDDLParser
canBeNull
DslAttribute
canBeOnBuildSide
ColumnFormatSamplingRelation SamplingRelation
canBuildFrom
MultiColumnOpenHashMap MultiColumnOpenHashSet
canCast
Cast
canConsume
BatchConsumer SnappyHashAggregateExec HashJoinExec
canCreate
SnappyEmbeddedModeClusterManager
canEqual
ExecutorInfo JDBCAppendableRelation ConstantErrorEstimate UnevaluableErrorEstimate OpLogTableScan JDBCMutableRelation MutablePair
canEvaluate
PredicateHelper
canEvaluateWithinJoin
PredicateHelper
canHandle
SnappyDataPoolDialect SnappyStoreClientDialect JdbcDialect SnappyStoreDialect
canHaveSingleKeyCase
DictionaryOptimizedMapAccessor
canSortFullyWithPrefix
SortPrefixUtils
canSupport
GenerateUnsafeProjection
canTraverseLeftToRight
RuleUtils
cancel
Operation SQLOperation ComplexFutureAction FutureAction SimpleFutureAction
cancelAllJobs
SparkContext JavaSparkContext
cancelDelegationToken
HiveAuthFactory CLIService CLIServiceClient EmbeddedCLIServiceClient ICLIService HiveSession HiveSessionImpl HiveSessionImplwithUGI ThriftCLIServiceClient
cancelJob
SparkContext
cancelJobGroup
ClusterCallbacksImpl SparkContext JavaSparkContext
cancelOperation
CLIService EmbeddedCLIServiceClient ICLIService OperationManager HiveSession HiveSessionImpl ThriftCLIServiceClient
cancelStage
SparkContext
canonicalize
CodeGenerator GenerateMutableProjection GenerateOrdering GeneratePredicate GenerateSafeProjection GenerateUnsafeProjection GenerateUnsafeRowJoiner GenerateColumnAccessor
canonicalized
Expression RuntimeReplaceable AggregateExpression QueryPlan LogicalPlan
capacity
ByteBufferData ByteBufferHashMap MultiColumnOpenHashSet StreamSummaryAggregation ColumnarBatch BitSet OpenHashSet
cardinality
BitSet BitSet
cartesian
JavaRDDLike RDD
cascade
DropSchemaCommand DropDatabaseCommand
caseInsensitiveResolution
analysis
caseSensitive
StopWordsRemover SnappyBaseParser
caseSensitiveAnalysis
SimpleCatalystConf SQLConf
caseSensitiveInferenceMode
SQLConf
caseSensitiveResolution
analysis
cast
Column ImplicitOperators
castToDouble
BootstrapAddTrialsAsArray
castType
CastDouble CastLongTime
catalog
sql SparkSession sql catalyst OptimizeMetadataOnlyQuery ReplaceWithSampleTable PreWriteCheck SnappySessionState SnappyAQPSessionState ResolveIndex
catalogSchemaName
StoreHiveCatalog
catalogSchemaVersion
RelationInfo TableExec
catalogStaleFailure
CachedDataFrame
catalogString
ArrayType DataType MapType StructType
catalogTable
CatalogRelation SimpleCatalogRelation DataSource InsertIntoHadoopFsRelationCommand LogicalRelation
catalogTableCount
RecoveryService
catalyst
sql
catalysts
sql
categoricalFeaturesInfo
Strategy
categories
Split
categoryMaps
VectorIndexerModel
cause
AnalysisException StreamingQueryException
cbrt
functions
ceil
functions Decimal
cfmerge
StatCounterWithFullCount
chain
ReplacementSet
changeOffHeapOwnerToStorage
DefaultMemoryManager SnappyUnifiedMemoryManager StoreUnifiedManager
changePrecision
Decimal
changeValue
MultiColumnOpenHashMap SegmentMap ReservoirRegionSegmentMap AppendOnlyMap
channelActive
TransportResponseHandler MessageHandler RpcHandler TransportChannelHandler TransportRequestHandler
channelInactive
TransportResponseHandler MessageHandler RpcHandler TransportChannelHandler TransportRequestHandler TransportFrameDecoder
channelRead
TransportChannelHandler TransportFrameDecoder
channelSize
ColumnFormatValue
charMetadata
Utils
charToEscape
ExternalCatalogUtils
charType
SnappyBaseParser
charset
Decode Encode
check
StatsPredicate
checkAnalysis
CheckAnalysis
checkAuthorization
OneForOneStreamManager StreamManager
checkBufferSize
ColumnEncoding
checkBuiltinCatalog
SnappySessionCatalog
checkCacheFlush
StratifiedSamplerErrorLimit
checkCapacity
SharedUtils
checkClusterRestrictions
ClusterUtils
checkCredentials
SecurityUtils
checkDuplicateKeys
ParserUtils
checkExists
SnappyDDLParser
checkExit
NoExitSecurityManager
checkFor
ErrorAggregate
checkForBatch
UnsupportedOperationChecker
checkForNumericExpr
TypeUtils
checkForOrderingExpr
TypeUtils
checkForSameTypeInputExpr
TypeUtils
checkForStreaming
UnsupportedOperationChecker
checkInit
ExternalShuffleClient
checkInputDataTypes
ArrayContains BinaryOperator CallMethodViaReflection CaseWhenBase Cast Coalesce CreateArray CreateMap CreateNamedStructLike DynamicFoldableExpression Elt EqualNullSafe EqualTo ExpectsInputTypes ExplodeBase Expression Greatest HashExpression If In Inline IntervalExpression JsonTuple Least NTile ParseUrl ReferenceToExpressions RoundBase SortArray SortOrder Stack StringToMap StructToJson TimeWindow ApproximatePercentile Average CollectSet Max Min Percentile Sum XPathExtract BootstrapAverage BootstrapSum AQPAverage AQPSum
checkItemExists
ContextJarUtils
checkPermission
NoExitSecurityManager
checkPorts
MesosSchedulerUtils
checkPositiveNum
ExternalStoreUtils
checkSchemaPermission
ToolsCallback ToolsCallbackImpl SnappyExternalCatalog StoreCallbacksImpl
checkSingleKeyCase
DictionaryOptimizedMapAccessor
checkStatus
ThriftCLIServiceClient
checkStatusForWait
LeaderLauncher
checkType
TColumn TColumnValue TGetInfoValue TTypeEntry TTypeQualifierValue
checkTypesInternal
Pmod
checkpoint
JavaRDDLike Graph EdgeRDDImpl GraphImpl VertexRDDImpl HadoopRDD RDD Dataset SchemaDStream StreamingContext JavaDStreamLike JavaStreamingContext DStream
checkpointDir
Params Params Params Params
checkpointFile
SparkContext JavaSparkContext
checkpointInterval
Params Params Params Params Strategy
checkpointLocation
IncrementalExecution OperatorStateId StateStoreId SQLConf
checkpointRoot
StreamExecution
chiSqTest
Statistics
child
DMLExternalTable MultiAlias UnresolvedAlias UnresolvedDeserializer UnresolvedExtractValue Abs Acos Alias Ascii Asin AssertTrue Atan BRound Base64 Bin BitwiseNot Cast Cbrt Ceil CheckOverflow Cos Cosh Crc32 DayOfMonth DayOfYear DynamicFoldableExpression DynamicInSet Exp Explode Expm1 Factorial Floor GetArrayItem GetArrayStructFields GetMapValue GetStructField Grouping Hex Hour IfNull InSet InitCap Inline IsNaN IsNotNull IsNull JsonToStruct LastDay Length Log Log10 Log1p Log2 Lower MakeDecimal MapKeys MapValues Md5 Minute Month Not NullIf Nvl Nvl2 PosExplode PreciseTimestamp PrintToStderr PromotePrecision Quarter Rand Randn Rint Round Second Sha1 Signum Sin Sinh Size SortOrder SortPrefix SoundEx Sqrt StringReverse StringSpace StringTrim StringTrimLeft StringTrimRight StructToJson Tan Tanh TimeWindow ToDate ToDegrees ToRadians UnBase64 UnaryExpression UnaryMinus UnaryPositive Unhex UnresolvedWindowExpression UnscaledValue UpCast Upper WeekOfYear Year ApproximatePercentile Average Collect CollectList CollectSet First HyperLogLogPlusPlus Kurtosis Last Max Min Percentile Skewness StddevPop StddevSamp Sum VariancePop VarianceSamp AssertNotNull DecodeUsingSerializer EncodeUsingSerializer ExternalMapToCatalyst GetExternalRowField UnwrapOption ValidateExternalType WrapOption Aggregate AppendColumns AppendColumnsWithObject BroadcastHint DeserializeToObject Distinct EventTimeWatermark Expand Filter FlatMapGroupsInR Generate GlobalLimit GroupingSets InsertIntoTable LocalLimit MapElements MapGroups MapPartitions MapPartitionsInR Pivot Project Repartition RepartitionByExpression ReturnAnswer Sample ScriptTransformation SerializeFromObject Sort Subquery SubqueryAlias TypedFilter UnaryNode Window With WithWindowDefinition SnappyUnaryNode AppendColumnsExec AppendColumnsWithObjectExec CoalesceExec CodegenSparkFallback CollectLimitExec DeserializeToObjectExec ExecutePlan ExpandExec FilterExec FlatMapGroupsInRExec GenerateExec GlobalLimitExec InSubquery InputAdapter LocalLimitExec MapElementsExec MapGroupsExec MapPartitionsExec ObjectHashMapAccessor OutputFakerExec ProjectExec SampleExec SerializeFromObjectExec SnappySortExec SortExec StratifiedSample StratifiedSampleExecute SubqueryExec TakeOrderedAndProjectExec UnaryExecNode WholeStageCodegenExec CollectAggregateExec HashAggregateExec SnappyHashAggregateExec SortAggregateExec ApproxColumnExtractor BootstrapReferencer BootstrapResultEvalAndCache ResamplePlaceholder SuperPoisson TaggedAlias ClosedFormColumnExtractor ClosedFormErrorEstimate ColumnDeleteExec ColumnInsertExec ColumnUpdateExec InMemoryRelation CreateViewCommand AQPSum AbsoluteError Behavior Confidence ConstantErrorEstimate Error ErrorAggregateNumericConverter ErrorAndConfidence ErrorDefaults LowerBound MapColumnToWeight PlaceHolderPlan RelativeError TokenizedLiteralWrapper UnevaluableErrorEstimate UpperBound BroadcastExchangeExec ReusedExchangeExec ShuffleExchange BatchEvalPythonExec RowDeleteExec RowInsertExec RowUpdateExec EventTimeWatermarkExec StateStoreRestoreExec StateStoreSaveExec WindowExec SampledRelation InsertIntoHiveTable ScriptTransformation BypassRowLevelSecurity MarkerForCreateTableAsSelect Delete Not PutIntoTable SampleTableQuery Update WindowLogicalPlan WindowPhysicalPlan
childOutput
ExternalTableDMLCmd
childSchema
GetStructField
childSerializer
AppendColumnsWithObject
children
UnresolvedFunction UnresolvedGenerator AtLeastNNonNulls BinaryExpression CallMethodViaReflection CaseWhenBase Coalesce Concat ConcatWs Conv CreateArray CreateMap CreateNamedStruct CreateNamedStructUnsafe DenseRank Elt Exists FormatString Greatest Grouping GroupingID GroupingSet HiveHash If In IntervalExpression JsonTuple LeafExpression Least ListQuery Murmur3Hash NTile OffsetWindowFunction ParseUrl PercentRank PredicateSubquery Rank ReferenceToExpressions RegExpExtract RegExpReplace RowNumberLike ScalaUDF ScalarSubquery Sentences Stack StringLPad StringLocate StringRPad StringToMap StringTranslate Substring SubstringIndex UnaryExpression UserDefinedGenerator WindowExpression WindowSpecDefinition XxHash64 AggregateExpression ApproximatePercentile Average CentralMomentAgg Collect Corr Count Covariance First HyperLogLogPlusPlus Last Max Min NoOp Percentile PivotFirst Sum CreateExternalRow InitializeJavaBean Invoke MapObjects NewInstance StaticInvoke BinaryNode EventTimeWatermark InsertIntoTable LeafNode UnaryNode Union HashPartitioning PartitioningCollection RangePartitioning TreeNode SnappyUnaryNode BinaryExecNode InSubquery LeafExecNode OutputFakerExec SHAMapAccessor ScalarSubquery SparkPlanInfo UnaryExecNode UnionExec ScalaUDAF TypedAggregateExpression SampleInsertExec ApproxColumn ApproxColumnDebug ArrayOpsExpression BootstrapAddTrialsAsArray BootstrapAddTrialsAvgCountPart BootstrapAddTrialsAvgSumPart BootstrapAverage BootstrapCount BootstrapMultiplicityAggregate BootstrapSum MergeMultiplicityExpression TaggedAlias UpdateMultiplicityExpression ClosedFormErrorEstimate StatCounterUpdater StartsWithForStats ExecutedCommandExec AQPAverage AQPCount AQPFunctionParameter AQPSum CoalesceDisparateTypes BatchEvalPythonExec PythonUDF EventTimeWatermarkExec Delete PutIntoTable SampleTableQuery Update LogicalDStreamPlan PhysicalDStreamPlan
childrenResolved
Expression LogicalPlan
chooseIndexForFilter
RuleUtils
city
Address Person
ck
Corr Covariance
classForName
Utils
className
ExceptionFailure Function CatalogFunction CachedFieldWrapper ColumnDeleteDelta ColumnDelta ColumnFormatValue CreateFunctionCommand DataSource
classPrefix
ObjectHashMapAccessor SHAMapAccessor
classTag
JavaDoubleRDD JavaPairRDD JavaRDD JavaRDDLike JavaDStream JavaDStreamLike JavaInputDStream JavaPairDStream JavaReceiverInputDStream
classification
ml mllib
classpathEntries
EnvironmentListener
clean
WriteAheadLog LocalDirectoryCleanupUtil
cleanArgs
QueryPlan RangeExec LogicalRelation
cleanExpression
QueryPlan
cleanJobConfig
SnappySessionFactory
cleanUpAllAllocatedMemory
TaskMemoryManager
cleanupOperationLog
Operation
cleanupResources
UnsafeKVExternalSorter UnsafeExternalSorter
clear
TableSchema TArrayTypeEntry TBinaryColumn TBoolColumn TBoolValue TByteColumn TByteValue TCancelDelegationTokenReq TCancelDelegationTokenResp TCancelOperationReq TCancelOperationResp TCloseOperationReq TCloseOperationResp TCloseSessionReq TCloseSessionResp TColumnDesc TDoubleColumn TDoubleValue TExecuteStatementReq TExecuteStatementResp TFetchResultsReq TFetchResultsResp TGetCatalogsReq TGetCatalogsResp TGetColumnsReq TGetColumnsResp TGetDelegationTokenReq TGetDelegationTokenResp TGetFunctionsReq TGetFunctionsResp TGetInfoReq TGetInfoResp TGetOperationStatusReq TGetOperationStatusResp TGetResultSetMetadataReq TGetResultSetMetadataResp TGetSchemasReq TGetSchemasResp TGetTableTypesReq TGetTableTypesResp TGetTablesReq TGetTablesResp TGetTypeInfoReq TGetTypeInfoResp THandleIdentifier TI16Column TI16Value TI32Column TI32Value TI64Column TI64Value TMapTypeEntry TOpenSessionReq TOpenSessionResp TOperationHandle TPrimitiveTypeEntry TRenewDelegationTokenReq TRenewDelegationTokenResp TRow TRowSet TSessionHandle TStatus TStringColumn TStringValue TStructTypeEntry TTableSchema TTypeDesc TTypeQualifiers TUnionTypeEntry TUserDefinedTypeEntry DefaultMemoryManager SnappyUnifiedMemoryManager StoreUnifiedManager Params KryoSerializerPool SnappyContext SnappyContextFunctions SnappySession EmptyFunctionRegistry FunctionRegistry SimpleFunctionRegistry GlobalTempViewManager StringKeyHashMap MultiColumnOpenHashMap MultiColumnOpenHashSet ConnectionPool SnappyContextAQPFunctions BitSet MemorySink SQLConf SnappyConf ExecutionListenerManager BitSet OpenHashSet
clearAQPInfo
AQPRules
clearActive
SQLContext
clearActiveSession
SparkSession
clearAllCache
SnappySession
clearBroadcasts
ToolsCallback ToolsCallbackImpl SparkPlan
clearBucket
SegmentMap ReservoirRegionSegmentMap
clearCache
SQLContext Catalog CacheManager CatalogImpl
clearCallSite
SparkContext JavaSparkContext
clearConnectionPools
StoreCallbacksImpl
clearDefaultSerializerAndCodec
Utils
clearDefaultSession
SparkSession
clearDependencies
CoGroupedRDD RDD ShuffledRDD UnionRDD ShuffledRowRDD
clearJobGroup
SparkContext JavaSparkContext
clearMemoryEventListener
SnappyUnifiedMemoryManager
clearPlanCache
SnappySession
clearQueryHints
SnappyBaseParser
clearSessionCache
StoreCallbacksImpl
clearSessionDependencies
SnappyUtils
clearSnappySessionForConnection
ClusterCallbacksImpl
clearSource
ColumnEncoder
clearStatic
SnappyContextFunctions
clearStaticArtifacts
ServiceUtils SnappyContext
clearStreams
StreamSqlHelper
clearTempTables
SessionCatalog
clearThreshold
LogisticRegressionModel SVMModel
clearUntil
BitSet
clearspring
com
cli
service
clickstream
streaming
client
network SnappyHiveCatalogBase
clientThreads
TransportConf
clients
MemberSummary
clock
ProcessingTimeExecutor
clone
SparkConf StratifiedSamplerCached StratifiedSamplerErrorLimit StratifiedSamplerReservoir CountMinSketch Decimal StorageLevel UTF8String SortedIterator BernoulliCellSampler BernoulliSampler PoissonSampler RandomSampler
cloneComplement
BernoulliCellSampler
cloneDelta
ColumnDeleteDelta ColumnDelta
cloneIfRequired
StringUtils UTF8String
cloneStringIfRequired
ObjectHashMapAccessor
close
RemoteInterpreterStateHolder ConnectorExternalCatalog SmartConnectorHelper SnappyExternalCatalog StoreHiveCatalog LogConsumer SparkOrcNewRecordReader HiveCommandOperation MetadataOperation Operation SQLOperation HiveSession HiveSessionImpl HiveSessionImplwithUGI JavaSparkContext PersistenceEngine NioBufferedFileInputStream DefaultMemoryManager SnappyUnifiedMemoryManager StoreUnifiedManager TransportClient TransportClientFactory TransportServer ExternalShuffleBlockHandler ExternalShuffleClient MesosExternalShuffleClient ByteArrayWritableChannel LimitedInputStream DeserializationStream SerializationStream ForeachWriter SnappySession SparkSession RowBasedKeyValueBatch GenerateFlatIterator KVSorterIterator ColumnBatchIterator ColumnBatchIteratorOnRS ResultSetIterator ColumnDecoder ColumnDeltaDecoder ColumnEncoder DictionaryDecoderBase NullableEncoder StringDictionary UpdatedColumnDecoderBase ColumnFormatIterator ColumnPartitionResolver RemoteEntriesIterator HadoopFileLinesReader OutputWriter RecordReaderIterator SpecificParquetRecordReaderBase VectorizedParquetRecordReader TextOutputWriter HashedObjectCache ColumnVector ColumnarBatch OffHeapColumnVector OnHeapColumnVector SnappyHiveExternalCatalog SnappyHiveThriftServer2 TimeTrackingOutputStream JavaStreamingContext WriteAheadLog KVIterator UnsafeSorterSpillReader UnsafeSorterSpillWriter
closeAndClearScalaInterpreter
ToolsCallback ToolsCallbackImpl
closeAndReopenInterpreterServer
LeadImpl
closeCurrentPage
UnsafeExternalSorter
closeExpiredOperations
HiveSession HiveSessionImpl
closeJsonGenerator
Utils
closeOperation
CLIService EmbeddedCLIServiceClient ICLIService OperationManager HiveSession HiveSessionImpl ThriftCLIServiceClient
closeRemoteInterpreter
SnappyInterpreterExecute
closeSession
CLIService EmbeddedCLIServiceClient ICLIService SessionManager ThriftCLIServiceClient
closedform
execution
closestPoint
LocalKMeans SparkKMeans
closureSerializer
SparkEnv
cls
NewInstance ObjectType
clsTag
Encoder ExpressionEncoder
cluster
snappydata ClusteringSummary Assignment scheduler
clusterCenters
BisectingKMeansModel KMeansModel BisectingKMeansModel KMeansModel StreamingKMeansModel
clusterInfo
ClusterSummary
clusterSizes
ClusteringSummary
clusterStats
SnappyDashboardPage
clusterStatsTitle
SnappyDashboardPage
clusterStatsTitleTooltip
SnappyDashboardPage
clusterWeights
StreamingKMeansModel
clustering
ml mllib ClusteredDistribution OrderedDistribution
cm
SnappyClusterManager
cmd
AlterTableRecoverPartitionsCommand ExecutedCommandExec SqlCmd
cms
TopKWrapper execution
cmsParams
Hokusai
coalesce
JavaDoubleRDD JavaPairRDD JavaRDD PartitionCoalescer RDD Dataset functions
code
ExprCode InterpretCodeCommand
codeChunk
SnappyDDLParser
codeForLenOfSkippedTerm
SHAMapAccessor
codeGenOnExecutor
ExternalStoreUtils
codeSplit
SHAMapAccessor
codeSplitFuncParamsSize
SHAMapAccessor SnappyHashAggregateExec
codeSplitThresholdSize
SnappyHashAggregateExec
codecCompress
CompressionUtils
codecDecompress
CompressionUtils
codecDecompressIfRequired
CompressionUtils
codegen
expressions debug ExplainCommand
codes
SubExprCodes
coefficientMatrix
LogisticRegressionModel
coefficientStandardErrors
GeneralizedLinearRegressionTrainingSummary LinearRegressionSummary
coefficients
LogisticRegressionModel AFTSurvivalRegressionModel GeneralizedLinearRegressionModel LinearRegressionModel
cogroup
JavaPairRDD PairRDDFunctions KeyValueGroupedDataset DslLogicalPlan JavaPairDStream PairDStreamFunctions
col
Dataset TopKUtil StatCounterUpdater functions
col1
Data
col2
Data
col3
Data
colDataType
StatCounterUpdater
colIter
DenseMatrix Matrix SparseMatrix DenseMatrix Matrix SparseMatrix
colNames
PutIntoValuesColumnTable
colPtrs
SparseMatrix SparseMatrix
colStats
Statistics Statistics
colTable
CreateAndLoadAirlineDataJob
colType
SqlBaseParser
colTypeList
SqlBaseParser
collect
JavaRDDLike EdgeRDDImpl RDD CachedDataFrame Dataset TreeNode
collectAsList
CachedDataFrame Dataset
collectAsMap
JavaPairRDD PairRDDFunctions
collectAsync
JavaRDDLike AsyncRDDActions
collectEdges
GraphOps
collectFirst
TreeNode
collectInternal
CachedDataFrame
collectLeaves
TreeNode
collectNeighborIds
GraphOps
collectNeighbors
GraphOps
collectPartitions
JavaRDDLike
collectPlaceholders
QueryPlanner SparkPlanner
collectSamples
SnappyContextFunctions SnappyContextAQPFunctions
collectViewsAndPrepareCatalog
RecoveryService
collectWithHandler
CachedDataFrame
collect_list
functions
collect_set
functions
collection
snappydata sql util
collectionAccumulator
SparkContext
colocatedGroups
PartialPlan
colsPerBlock
BlockMatrix
colsWithDirection
SnappyDDLParser
column
SnappyDDLParser AlterTableDropColumnCommand ApproxColumn ApproxColumnDebug ColumnarBatch functions
columnBatchCount
BootstrapMultiplicityAggregate
columnBatchSize
StratifiedSamplerCached StratifiedSamplerErrorLimit ColumnInsertExec SQLConf
columnBatchTableName
ColumnFormatRelation StoreCallbacksImpl OpLogFormatRelation
columnBeginPosition
ColumnEncoder
columnBuffer
ColumnFormatValue
columnBytes
ColumnEncoder
columnCharType
SnappyBaseParser
columnData
ColumnEncoder
columnDataType
SnappyBaseParser
columnEndPosition
ColumnEncoder
columnExpression
BootstrapAverage
columnIndex
Utils
columnList
RowFormatScanRDD
columnMaxDeltaRows
ColumnInsertExec
columnNameOfCorruptRecord
SQLConf
columnNames
AnalyzeColumnCommand
columnRelation
ColumnUpdateExec
columnSimilarities
IndexedRowMatrix RowMatrix
columnTable
ColumnDeleteExec ColumnInsertExec ColumnUpdateExec
columnTableName
ColumnBatchCreator
columnTableScan
StoreCallbacksImpl
columnar
execution
columns
Dataset MultiColumnOpenHashSet QCSSQLColumnHandler BootstrapCount AQPCount AQPFunctionParameter SchemaDStream
com
root util
combineByKey
JavaPairRDD PairRDDFunctions JavaPairDStream PairDStreamFunctions
combineByKeyWithClassTag
PairRDDFunctions
combineCombinersByKey
Aggregator
combineValuesByKey
Aggregator
combinedViewsMapSortedSet
RecoveryService
commaSep
SnappyBaseParser
command
DMLExternalTable ParseException ParserUtils execution ExternalTableDMLCmd
commandMethod
RemoteInterpreterStateHolder
commands
RemoteILoop SparkILoop TestTable
comment
CatalogTable CodeAndComment CreateDatabaseCommand CreateViewCommand
commentBody
SnappyBaseParser
commentBodyOrHint
SnappyBaseParser
commentHolder
CodeFormatter
commit
FileStreamSource MemoryStream Source TextSocketSource StateStore JDBCSource
commitJob
FileCommitProtocol HadoopMapReduceCommitProtocol ManifestFileCommitProtocol
commitOrRollback
ExternalStore
commitTask
FileCommitProtocol HadoopMapReduceCommitProtocol SparkHadoopMapRedUtil ManifestFileCommitProtocol
committedOffsets
ProgressReporter StreamExecution
common
execution
commonArrayDataType
DeclarativeBootstrapAggregateFunction
commonDataType
DeclarativeBootstrapAggregateFunction
commonMetadata
FileTypes
compact
ColumnCompactor
compactInterval
CompactibleFileStreamLog
compactLogs
CompactibleFileStreamLog FileStreamSinkLog FileStreamSourceLog
compactMap
Utils
compactionMetricName
ColumnExec
compare
RegionDiskViewOrdering Contains EndsWith InterpretedOrdering StartsWith StringPredicate BaseOrdering LazilyGeneratedOrdering Approximate RecordBinaryComparator ReplacementSet Decimal RDDInfo UTF8String PrefixComparator RecordComparator
compareBinary
TypeUtils
compareOrderAndSet
StratifiedSampler
compareTo
OffHeapChunkInfo TArrayTypeEntry TBinaryColumn TBoolColumn TBoolValue TByteColumn TByteValue TCancelDelegationTokenReq TCancelDelegationTokenResp TCancelOperationReq TCancelOperationResp TCloseOperationReq TCloseOperationResp TCloseSessionReq TCloseSessionResp TColumn TColumnDesc TColumnValue TDoubleColumn TDoubleValue TExecuteStatementReq TExecuteStatementResp TFetchResultsReq TFetchResultsResp TGetCatalogsReq TGetCatalogsResp TGetColumnsReq TGetColumnsResp TGetDelegationTokenReq TGetDelegationTokenResp TGetFunctionsReq TGetFunctionsResp TGetInfoReq TGetInfoResp TGetInfoValue TGetOperationStatusReq TGetOperationStatusResp TGetResultSetMetadataReq TGetResultSetMetadataResp TGetSchemasReq TGetSchemasResp TGetTableTypesReq TGetTableTypesResp TGetTablesReq TGetTablesResp TGetTypeInfoReq TGetTypeInfoResp THandleIdentifier TI16Column TI16Value TI32Column TI32Value TI64Column TI64Value TMapTypeEntry TOpenSessionReq TOpenSessionResp TOperationHandle TPrimitiveTypeEntry TRenewDelegationTokenReq TRenewDelegationTokenResp TRow TRowSet TSessionHandle TStatus TStringColumn TStringValue TStructTypeEntry TTableSchema TTypeDesc TTypeEntry TTypeQualifierValue TTypeQualifiers TUnionTypeEntry TUserDefinedTypeEntry UTF8String
comparisonExpression
SnappyParser
comparisonOperator
SqlBaseParser
compatibleSchema
SnappySessionCatalog
compatibleWith
BroadcastMode BroadcastPartitioning HashPartitioning IdentityBroadcastMode Partitioning PartitioningCollection RangePartitioning RoundRobinPartitioning SinglePartition UnknownPartitioning
compile
StringRegexExpression CodeGenerator
compileFilter
JDBCRDD
completed
ApplicationAttemptInfo
completedJobs
JobProgressListener
completedStages
JobProgressListener
completedTasks
ExecutorSummary
completionTime
StageInfo JobData StageData
complexColType
SqlBaseParser
complexColTypeList
SqlBaseParser
compress
CompressionCodec LZ4CompressionCodec LZFCompressionCodec SnappyCompressionCodec QuantileSummaries CountMinSketch
compressMultiplicty
BootstrapFunctions
compressThreshold
QuantileSummaries
compressed
Vector Vector CatalogStorageFormat
compressedInputStream
CompressionCodec LZ4CompressionCodec LZFCompressionCodec SnappyCompressionCodec
compressedOutputStream
CompressionCodec LZ4CompressionCodec LZFCompressionCodec SnappyCompressionCodec
compressionCodec
ColumnBatchCreator ColumnDeleteExec ColumnInsertExec ColumnUpdateExec
compressionCodecId
ColumnFormatValue
compressionCodecName
CachedDataFrame
compressorFunc
BootstrapFunctions
compute
EdgeRDD VertexRDD Gradient HingeGradient L1Updater LeastSquaresGradient LogisticGradient SimpleUpdater SquaredL2Updater Updater CoGroupedRDD HadoopRDD JdbcRDD NewHadoopRDD PartitionPruningRDD RDD ShuffledRDD UnionRDD DelegateRDD SampledCachedRDD ExecutorLocalRDD FixedPartitionRDD ShuffledRowRDD StratifiedSampledRDD WholeStageCodegenRDD ColumnarStorePartitionedRDD SmartConnectorColumnRDD FileScanRDD UnsafeCartesianRDD OpLogRdd RowFormatScanRDD StateStoreRDD DummyRDD SchemaDStream JavaDStream JavaPairDStream ConstantInputDStream DStream ReceiverInputDStream
computeColumnHash
StoreHashFunction
computeColumnStats
AnalyzeColumnCommand
computeColumnSummaryStatistics
RowMatrix
computeCost
BisectingKMeansModel KMeansModel BisectingKMeansModel KMeansModel
computeCovariance
RowMatrix
computeError
Loss
computeGramianMatrix
IndexedRowMatrix RowMatrix
computeHash
HashExpression HiveHash Murmur3Hash XxHash64 StoreHashFunction
computeInitialPredictionAndError
GradientBoostedTreesModel
computeInternal
WholeStageCodegenRDD
computePreferredLocations
InputFormatInfo
computePrincipalComponents
RowMatrix
computePrincipalComponentsAndExplainedVariance
RowMatrix
computeResultSet
SmartConnectorRowRDD RowFormatScanRDD
computeRmse
MovieLensALS
computeSVD
IndexedRowMatrix RowMatrix
computeVariance
MultiTableStatCounterWithFullCount StatCounterWithFullCount
concat
functions
concat_ws
functions
concurrency
SampleOptions StratifiedSampler
condition
Filter Join FilterExec BroadcastHashJoinExec BroadcastNestedLoopJoinExec CartesianProductExec HashJoin HashJoinExec ShuffledHashJoinExec SortMergeJoinExec
conditionEvaluator
RowLevelSecurity
conditionString
PlanExpression
conditions
PartialPlan ReplacementSet
conf
SparkEnv SparkHadoopUtil Main SparkSession CheckCartesianProducts EliminateOuterJoin InferFiltersFromConstraints OptimizeCodegen OptimizeIn PruneFilters CollapseCodegenStages OptimizeMetadataOnlyQuery ReuseSubquery SparkPlanner ReplaceWithSampleTable DataSourceAnalysis PreWriteCheck PreprocessTableInsertion EnsureRequirements ReuseExchange SnappyHiveExternalCatalog SnappySessionState SparkUI
confFactor
ClosedFormColumnExtractor ErrorAggregateFunction
confidence
Rule BoundedDouble CMSParams ApproxColumn ClosedFormColumnExtractor CountMinSketch AQPInfo ErrorAggregateFunction ErrorAndConfidence SampleTableQuery CountMinSketch
confidenceExpr
Confidence
config
Builder
configEntry
SQLValue SparkValue AltName
configuration
tree InputFormatInfo
configureAuthenticatorForSJS
LeadImpl
confusionMatrix
MulticlassMetrics
connFactory
JDBCAppendableRelation JDBCMutableRelation NativeTableRelation
connId
RemoteInterpreterStateHolder
connProperties
ExternalStore JDBCAppendableRelation JDBCSourceAsColumnarStore RowFormatScanRDD JDBCMutableRelation NativeTableRelation
connProps
ConnectionConf ColumnDeleteExec ColumnUpdateExec RowDeleteExec RowExec RowInsertExec RowUpdateExec ConnectionProperties
connTerm
RowExec
connect
DriverWrapper
connectedComponents
GraphOps
connection
SnapshotConnectionListener
connectionParams
JDBCStreamBuilder
connectionTerminated
OneForOneStreamManager StreamManager
connectionTimeoutMs
TransportConf
connectionType
PartitionedDataSourceScan BaseColumnFormatRelation JDBCSourceAsColumnarStore SmartConnectorRowRDD RowFormatRelation RowFormatScanRDD ColumnFormatSamplingRelation
connectorHelper
ConnectorExternalCatalog
consequent
Rule
constant
SqlBaseParser
constantList
SqlBaseParser
constantPartition
DummyRDD
constraintMapping
JettyUtils
constraintPropagationEnabled
SimpleCatalystConf SQLConf
constraints
QueryPlan
constructCreateIndexSQL
RowFormatRelation JDBCMutableRelation
constructParams
ScalaReflection
consume
LogConsumer CodegenSupport
consumer
ObjectHashMapAccessor
consumerKey
TwitterStreamRelation
consumerSecret
TwitterStreamRelation
contains
SparkConf ParamMap Column RuntimeConfig ImplicitOperators AttributeSet ExpressionSet CaseInsensitiveMap BoundedSortedSet MultiColumnOpenHashMap MultiColumnOpenHashSet SegmentMap ReservoirRegionSegmentMap SQLConf Metadata UTF8String OpenHashSet
containsAggregate
ResolveAggregateFunctions
containsAggregates
GlobalAggregates
containsBlock
StorageStatus
containsChild
TreeNode
containsMultipleGenerators
CheckAnalysis
containsNull
GetArrayStructFields ArrayType
containsStar
ResolveReferences
contentType
ServletParams
context
InterruptibleIterator JavaRDDLike MLReader MLWriter RDD StreamBaseRelation JavaDStreamLike DStream
contextFunctions
SnappySessionState SnappyAQPSessionState
conv
functions
convergeDist
LocalKMeans
convert
Converter AvroWrapperToJavaConverter IndexedRecordToJavaConverter Lower String2StringExpression StringReverse StringTrim StringTrimLeft StringTrimRight Upper NumberConverter LongOffset MyStreamConverter StreamConverter SnappyStoreSink
convertCTAS
SQLConf
convertCharTypesInMetadata
SnappySessionCatalog
convertEpochToIntervals
TimeEpoch
convertExternalTableStatstoMetrics
SnappyTableMetrics
convertFrom
ByteUnit
convertIdentifierPattern
MetadataOperation
convertIntervalBySwappingEnds
TimeAndItemAggregation
convertMatrixColumnsFromML
MLUtils
convertMatrixColumnsToML
MLUtils
convertPopularTweetsToRow
StreamingUtils
convertSchemaPattern
MetadataOperation
convertStaticPartitions
DataSourceAnalysis
convertStatsToMetrics
SnappyMemberMetrics SnappyMetricsSystem SnappyTableMetrics
convertTo
ByteUnit
convertToAQPFrame
snappy
convertToBypassErrorCalcFunction
BootstrapAverage BootstrapCount BootstrapSum ClosedFormErrorEstimate ErrorAggregateFunction
convertToCanonicalEdges
GraphOps
convertToCatalyst
CatalystTypeConverters
convertToNetty
FileSegmentManagedBuffer ManagedBuffer NettyManagedBuffer NioManagedBuffer
convertToScala
CatalystTypeConverters
convertToStratifiedSample
SnappyContextFunctions SnappyContextAQPFunctions
convertTweetToRow
StreamingUtils
convertTz
DateTimeUtils
convertVectorColumnsFromML
MLUtils
convertVectorColumnsToML
MLUtils
coordinates
DeployCommand
coordinator
ShuffleExchange
copy
Estimator Model Pipeline PipelineModel PipelineStage Predictor Transformer UnaryTransformer DecisionTreeClassificationModel DecisionTreeClassifier GBTClassificationModel GBTClassifier LogisticRegression LogisticRegressionModel MultilayerPerceptronClassificationModel MultilayerPerceptronClassifier NaiveBayes NaiveBayesModel OneVsRest OneVsRestModel RandomForestClassificationModel RandomForestClassifier BisectingKMeans BisectingKMeansModel DistributedLDAModel GaussianMixture GaussianMixtureModel KMeans KMeansModel LDA LocalLDAModel BinaryClassificationEvaluator Evaluator MulticlassClassificationEvaluator RegressionEvaluator Binarizer BucketedRandomProjectionLSH BucketedRandomProjectionLSHModel Bucketizer ChiSqSelector ChiSqSelectorModel CountVectorizer CountVectorizerModel HashingTF IDF IDFModel IndexToString Interaction MaxAbsScaler MaxAbsScalerModel MinHashLSH MinHashLSHModel MinMaxScaler MinMaxScalerModel OneHotEncoder PCA PCAModel PolynomialExpansion QuantileDiscretizer RFormula RFormulaModel RegexTokenizer SQLTransformer StandardScaler StandardScalerModel StopWordsRemover StringIndexer StringIndexerModel Tokenizer VectorAssembler VectorIndexer VectorIndexerModel VectorSlicer Word2Vec Word2VecModel DenseMatrix DenseVector Matrix SparseMatrix SparseVector Vector ParamMap Params ALS ALSModel AFTSurvivalRegression AFTSurvivalRegressionModel DecisionTreeRegressionModel DecisionTreeRegressor GBTRegressionModel GBTRegressor GeneralizedLinearRegression GeneralizedLinearRegressionModel IsotonicRegression IsotonicRegressionModel LinearRegression LinearRegressionModel RandomForestRegressionModel RandomForestRegressor CrossValidator CrossValidatorModel TrainValidationSplit TrainValidationSplitModel DenseMatrix DenseVector Matrix SparseMatrix SparseVector Vector ExponentialGenerator GammaGenerator LogNormalGenerator PoissonGenerator RandomDataGenerator StandardNormalGenerator UniformGenerator WeibullGenerator Strategy Row InternalRow SimpleFunctionRegistry GenericInternalRow GenericRow JoinedRow MutableAny MutableBoolean MutableByte MutableDouble MutableFloat MutableInt MutableLong MutableShort MutableValue SpecificInternalRow UnsafeArrayData UnsafeMapData UnsafeRow ArrayBasedMapData ArrayData GenericArrayData MapData SerializedArray SerializedMap SerializedRow InternalRowToRow ReusableRow RowToInternalRow WrappedInternalRow RowWithWeight StratumInternalRow ByteMutableRow DoubleMutableRow PoissonGenerator ClosedFormStats MultiTableStatCounterWithFullCount StatCounterAggregator StatCounterWithFullCount MutableUnsafeRow ColumnDeleteDelta ColumnDelta ColumnFormatValue SnappySortMergeJoinExec SQLMetric EventTimeStatsAccum Insert StatCounter StatVarianceCounter AccumulatorV2 CollectionAccumulator DoubleAccumulator LegacyAccumulatorWrapper LongAccumulator StatCounter
copyAndReset
AccumulatorV2 CollectionAccumulator
copyDataFromSourceListener
SnappySQLListener
copyElement
UnsafeSortDataFormat
copyFrom
UnsafeRow
copyRange
UnsafeSortDataFormat
copyResult
CodegenContext
copyTo
ColumnEncoder
copyToHeap
ColumnFormatValue
copyUTF8String
DirectStringConsumer
copyValue
QCSSQLColumnHandler
copyValues
Params
cores
MemberSummary
coresGranted
ApplicationInfo
coresPerExecutor
ApplicationInfo
corr
Statistics DataFrameStatFunctions functions
cos
functions
cosh
functions
count
JavaRDDLike Average EdgeRDDImpl VertexRDDImpl MultivariateOnlineSummarizer MultivariateStatisticalSummary RDD CachedDataFrame Dataset KeyValueGroupedDataset RelationalGroupedDataset ExpressionConversions QuantileSummaries EventTimeStats typed functions StatVarianceCounter JavaDStreamLike DStream DoubleAccumulator LongAccumulator StatCounter
countApprox
JavaRDDLike RDD
countApproxDistinct
JavaRDDLike RDD
countApproxDistinctByKey
JavaPairRDD PairRDDFunctions
countAsync
JavaRDDLike AsyncRDDActions
countByKey
JavaPairRDD PairRDDFunctions
countByKeyApprox
JavaPairRDD PairRDDFunctions
countByValue
JavaRDDLike RDD JavaDStreamLike DStream
countByValueAndWindow
JavaDStreamLike DStream
countByValueApprox
JavaRDDLike RDD
countByWindow
JavaDStreamLike DStream
countDistinct
ExpressionConversions functions
countExpr
SubstringIndex
countMinSketch
DataFrameStatFunctions
countTowardsTaskFailures
ExecutorLostFailure FetchFailed TaskCommitDenied TaskFailedReason TaskKilled
country
Person Sentences
cov
MultivariateGaussian DataFrameStatFunctions
covar_pop
functions
covar_samp
functions
cpuActive
MemberSummary
cpuUsageTrend
MemberSummary
crc32
functions
create
JdbcRDD PartitionPruningRDD GlobalTempViewManager InterpretedPredicate Literal UnsafeProjection CodeGenerator GenerateMutableProjection GenerateOrdering GeneratePredicate GenerateSafeProjection GenerateUnsafeProjection GenerateUnsafeRowJoiner TopKHokusai GenerateColumnAccessor DeltaWriterFactory FileContextManager FileManager FileSystemManager StreamSummaryAggregation ProcessingTime TopKRelation RateEstimator
createActorSystem
LeadImpl
createActualTables
BaseColumnFormatRelation JDBCMutableRelation NativeTableRowLevelSecurityRelation
createAggregationBuffer
ApproximatePercentile Percentile TypedImperativeAggregate
createAndGetDataDir
CollocatedJoinExample CreateColumnTable CreatePartitionedRowTable CreateReplicatedRowTable StreamingExample SynopsisDataExample WorkingWithJson WorkingWithObjects
createAndStoreBatch
ColumnBatchCreator
createApproxTSTopK
SnappyContext SnappySession
createBaseRdd
JsonDataSource TextInputJsonDataSource WholeFileJsonDataSource
createCatalystConverter
Utils
createClient
TransportClientFactory
createClientFactory
TransportContext
createCode
GenerateUnsafeProjection
createColumnBatch
StoreCallbacksImpl
createColumnBatchBuffer
ColumnBatchCreator
createColumnExtractorSubstituedExpression
ResultsExpressionCreator
createColumnTableInferredSchema
CreateColumnTable
createColumnTableUsingAPI
CreateColumnTable
createColumnTableUsingSQL
CreateColumnTable
createCombinedSortedSet
RecoveryService
createCombiner
Aggregator
createCompressionCodec
SparkEnv
createConnection
SmartConnectorRDDHelper SmartConnectorRowRDD RowFormatScanRDD
createConnectionFactory
JDBCRelationUtil JdbcUtils
createContext
RecoverableNetworkWordCount
createDataFrame
SQLContext SnappyContext SnappySession SparkSession
createDataFrameUsingRDD
SnappyContext SnappySession
createDatabase
SmartConnectorExternalCatalog ExternalCatalog InMemoryCatalog SessionCatalog SnappyHiveExternalCatalog SnappySessionCatalog
createDataset
SQLContext SnappySession SparkSession
createDriverEndpoint
SnappyCoarseGrainedSchedulerBackend
createDummy
TopKHokusai
createExecutorEnv
SparkCallbacks
createExternalTable
SQLContext SnappySession Catalog CatalogImpl
createFailureResponse
AbstractResponseMessage ChunkFetchSuccess RpcResponse StreamResponse
createFileFormat
SqlBaseParser
createFilterPlan
PolicyProperties
createFromParser
CaseWhen
createFunction
SmartConnectorExternalCatalog SnappyDDLParser ExternalCatalog InMemoryCatalog SessionCatalog SnappyHiveExternalCatalog SnappySessionCatalog
createGauge
SnappyMetricsSystem
createGetters
BufferSetterGetterUtils
createGlobalTempView
Dataset SessionCatalog
createHashMap
HashAggregateExec
createHistogram
SnappyMetricsSystem
createHiveTable
SnappyDDLParser
createIndex
SnappyContext SnappyDDLParser SnappySession JDBCAppendableRelation ColumnFormatRelation JDBCMutableRelation IndexableRelation
createInputStream
FileSegmentManagedBuffer ManagedBuffer NettyManagedBuffer NioManagedBuffer CodecStreams
createIterator
ColumnBatchIterator SingleColumnBatchIterator PRValuesIterator
createJoin
RuleUtils
createLeaderElectionAgent
StandaloneRecoveryModeFactory
createListeners
SQLHistoryListenerFactory
createMetric
SQLMetrics
createMetrics
ColumnExec
createModel
LogisticRegressionWithLBFGS LogisticRegressionWithSGD SVMWithSGD GeneralizedLinearAlgorithm LassoWithSGD LinearRegressionWithSGD RidgeRegressionWithSGD
createNewExpression
ErrorEstimateRule
createOperationLog
Operation
createOrReplaceTempView
Dataset
createOrderedJoin
ReorderJoin
createOutputStream
CodecStreams
createOutputStreamWriter
CodecStreams
createParser
JsonDataSource TextInputJsonDataSource WholeFileJsonDataSource
createPartition
ExecutorLocalRDD
createPartitionedRowTableUsingAPI
CreatePartitionedRowTable
createPartitionedRowTableUsingSQL
CreatePartitionedRowTable
createPartitions
SmartConnectorExternalCatalog ExternalCatalog InMemoryCatalog SessionCatalog SnappyHiveExternalCatalog SnappySessionCatalog
createPersistenceEngine
StandaloneRecoveryModeFactory
createPolicy
SnappyExternalCatalog SmartConnectorExternalCatalog SnappyDDLParser SnappyHiveExternalCatalog SnappySessionCatalog
createPrefixGenerator
SortPrefixUtils
createProxyHandler
JettyUtils
createProxyLocationHeader
JettyUtils
createProxyURI
JettyUtils
createRDDWithLocalProperties
DStream
createRawLSHModel
BucketedRandomProjectionLSH MinHashLSH
createRedirectHandler
JettyUtils
createRelation
DefaultSource JdbcRelationProvider DefaultSource DefaultSource DefaultSource CreatableRelationProvider RelationProvider SchemaRelationProvider DirectKafkaStreamSource FileStreamSource RabbitMQStreamSource RawSocketStreamSource SocketStreamSource TextSocketStreamSource TwitterStreamSource DefaultSource
createReplicatedRowTableUsingAPI
CreateReplicatedRowTable
createReplicatedRowTableUsingSQL
CreateReplicatedRowTable
createResource
MesosSchedulerUtils
createResultExpressions
ResultsExpressionCreator
createResultProjection
HashJoin
createRowStream
DirectKafkaStreamRelation FileStreamRelation RabbitMQStreamRelation RawSocketStreamRelation SocketStreamRelation StreamBaseRelation TextSocketStreamRelation TwitterStreamRelation
createSampleDataFrameContract
SnappyContextFunctions SnappyContextAQPFunctions
createSampleOrTopK
SnappyAQPParser
createSampleTable
SnappyContext SnappySession
createScalaConverter
Utils
createSchedulerBackend
SnappyEmbeddedModeClusterManager
createSchedulerDriver
MesosSchedulerUtils
createSchema
SnappyDDLParser SnappyDataBaseDialect AstBuilder JdbcExtendedDialect JdbcExtendedUtils
createSchemaDStream
StreamSqlHelper SnappyStreamingContext JavaSnappyStreamingContext
createSchemasMap
RecoveryService
createServer
TransportContext
createServlet
JettyUtils
createServletHandler
JettyUtils
createSetters
BufferSetterGetterUtils
createSink
DataSource ConsoleSinkProvider StreamSinkProvider SnappyStoreSinkProvider SnappyStoreSinkProvider
createSizeMetric
SQLMetrics
createSorter
SortExec
createSource
DataSource TextSocketSourceProvider StreamSourceProvider JdbcStreamProvider
createSparkILoop
RemoteInterpreterStateHolder
createSparkInterpreter
RemoteILoop
createSparkSession
Main
createStaticHandler
JettyUtils
createStatsBuffer
SharedUtils
createStream
SnappyDDLParser RabbitMQUtils TwitterUtils
createStructType
AstBuilder
createTable
SmartConnectorExternalCatalog SnappyContext SnappyDDLParser SnappySession ExternalCatalog InMemoryCatalog SessionCatalog JDBCAppendableRelation JdbcUtils SnappyAQPSessionCatalog SnappyHiveExternalCatalog SnappySessionCatalog NativeTableRowLevelSecurityRelation
createTableHeader
SqlBaseParser
createTableLike
SnappyDDLParser
createTableOptions
JDBCOptions
createTableWithComplexType
JDBCWithComplexTypes
createTaskScheduler
SnappyEmbeddedModeClusterManager
createTempFunction
SessionCatalog
createTempView
Dataset SessionCatalog
createTempViewUsing
SnappyDDLParser
createTime
CatalogTable SnappyHiveExternalCatalog
createTimingMetric
SQLMetrics
createToCatalystConverter
CatalystTypeConverters
createToScalaConverter
CatalystTypeConverters
createTopK
SnappyContextFunctions SnappyContextAQPFunctions
createTopKRDD
TopKUtil
createTopic
EmbeddedKafkaUtils
createTransformFunc
MyTransformer UnaryTransformer DCT ElementwiseProduct NGram Normalizer PolynomialExpansion RegexTokenizer Tokenizer
createUnmanagedClient
TransportClientFactory
createUnsafe
Decimal
createUnsafeJoiner
HashAggregateExec
createVersionFile
SnappyDataVersion
createView
SnappyDDLParser
createZeroCMS
Hokusai TopKHokusai
createdTempDir
InsertIntoHiveTable
credentialsRequired
ServiceCredentialProvider
criteria
QueryRoutingRules
crossJoin
Dataset
crossJoinEnabled
SimpleCatalystConf SQLConf
crossTabulate
StatFunctions
crosstab
DataFrameStatFunctions
csv
DataFrameReader DataFrameWriter datasources DataStreamReader
csvParser
CSVRelation
cteRelations
With
ctes
SnappyParser SqlBaseParser
ctx
SparkSQLExecuteImpl SparkSQLPrepareImpl SparkSampleInsertExecuteImpl ObjectHashMapAccessor SHAMapAccessor
cube
Dataset
cubeRollUpGroupingSet
SnappyParser
cume_dist
functions
curColocatedIndex
PartialPlan
curPlan
PartialPlan
currSchema
CachedKey
currStateOpNumRowsTotal
StreamingQueryStatistics
currStateOpNumRowsUpdated
StreamingQueryStatistics
currentAttemptId
SparkStageInfo
currentBatchId
IncrementalExecution ProgressReporter StreamExecution StreamingQueryStatistics
currentBlockId
MemoryStream
currentColocatedGroup
PartialPlan SubPlan
currentColumns
ColumnBatchIterator
currentCursor
ColumnDecoder
currentDatabase
Catalog CatalogImpl
currentDb
SessionCatalog
currentDeltaBuffer
UpdatedColumnDecoderBase
currentDeltaStats
ColumnBatchIterator
currentEventTimeWatermark
IncrementalExecution
currentFabricServiceInstance
ServiceManager
currentFunctionIdentifier
SnappyExternalCatalog
currentGroup
GroupedIterator
currentIterator
GroupedIterator
currentKeyPartitionId
ColumnBatchIterator
currentKeyUUID
ColumnBatchIterator
currentLogOffset
FileStreamSource
currentOffSetForMapLookupUpdt
SHAMapAccessor
currentOffset
MemoryStream TextSocketSource
currentPlanAnalysis
SnappyContextAQPFunctions
currentRow
GroupedIterator ReservoirRegionSegmentMap Window
currentRun
BooleanRunLengthEncoder
currentRunSize
BooleanRunLengthEncoder
currentStats
EventTimeStatsAccum
currentStatus
ProgressReporter
currentUser
CreatePolicyCommand
currentVal
ColumnBatchIterator CompactExecRowIteratorOnScan PRValuesIterator
currentValue
InterpretedMutableProjection MutableProjection
currentVars
CodegenContext
current_date
functions
current_timestamp
functions
customAuthenticator
JettyUtils
customFunction
JDBCStreamBuilder
customJFunction
JDBCStreamBuilder
customPartitionLocations
OutputSpec InsertIntoHadoopFsRelationCommand
customTransformations
JDBCStreamBuilder