R
LocalKMeans LocalLR SparkLR QRDecomposition
RABBITMQ_STREAM_SOURCE
SnappyContext
RACK_LOCAL
TaskLocality
RADIX_SORT_ENABLED
SQLConf
RANDOM
KMeans
RANGE
SnappyDDLParser SnappyParserConsts
RAW_ESTIMATE_DATA
HyperLogLogPlusPlus
RAW_SOCKET_STREAM_SOURCE
SnappyContext
RDD
rdd BlockId
RDDBlockId
storage
RDDConversions
execution
RDDDataDistribution
v1
RDDExtensions
snappy
RDDFunctions
rdd
RDDInfo
storage
RDDJavaFunctions
spark
RDDKryo
execution
RDDPartitionInfo
v1
RDDRelation
sql
RDDScanExec
execution
RDDStorageInfo
v1
RDDs
sql
RDG
expressions
REAL
SnappyBaseParser SnappyParserConsts
RECOVERYDELAY
StoreUtils
RECOVER_MODE_URL
Constant
REDIRECT_CONNECTOR_NAME
JettyUtils
REDUNDANCY
StoreUtils
REFRESH
SnappyDDLParser SnappyParserConsts
REGEXP
SnappyDDLParser SnappyParserConsts
REGISTERS_PER_WORD
HyperLogLogPlusPlus
REGISTER_SIZE
HyperLogLogPlusPlus
REGISTER_WORD_MASK
HyperLogLogPlusPlus
RELATION_FOR_SAMPLE
ExternalStoreUtils
REMOVE_CACHED_OBJECTS
RefreshMetadata
REMOVE_FUNCTION_JAR
RefreshMetadata
REMOVE_LOADER_WITH_REPL
RefreshMetadata
REMOVE_URIS_FROM_CLASSLOADER
RefreshMetadata
RENAME
SnappyDDLParser SnappyParserConsts
REPLACE
SnappyDDLParser SnappyParserConsts
REPLACE_WITH_SAMPLE_TABLE
RuleNumbers
REPLICATE
ExternalStoreUtils StoreUtils
REPL_OUTPUT_DIR
Constant
REPOS
SnappyDDLParser SnappyParserConsts
REROUTE_TO_BASE
HAC
RESERVOIR_AS_REGION
Constant
RESET
SnappyDDLParser SnappyParserConsts
RESTRICT
SnappyDDLParser SnappyParserConsts
RETURNS
SnappyDDLParser SnappyParserConsts
REVOKE
SnappyDDLParser SnappyParserConsts
RFormula
feature
RFormulaExample
ml
RFormulaModel
feature
RIGHT
SnappyDDLParser SnappyParserConsts
RLIKE
SnappyDDLParser SnappyParserConsts
RLike
expressions
RMATa
GraphGenerators
RMATb
GraphGenerators
RMATc
GraphGenerators
RMATd
GraphGenerators
RMIException
dunit
RM_REQUEST_PRIORITY
YarnSparkHadoopUtil
ROLLUP
SnappyDDLParser SnappyParserConsts
ROUND_CEILING
Decimal
ROUND_FLOOR
Decimal
ROUND_HALF_EVEN
Decimal
ROUND_HALF_UP
Decimal
ROW
SnappyDDLParser SnappyParserConsts
ROWID_COLUMN_DEFINITION
StoreUtils
ROWID_COLUMN_NAME
StoreUtils
ROWS
SnappyDDLParser SnappyParserConsts
ROW_SOURCE
SnappyParserConsts
RRunner
deploy
RUN_SQL_ON_FILES
SQLConf
RabbitMQDecoder
streaming
RabbitMQInputDStream
streaming
RabbitMQReceiver
streaming
RabbitMQStreamRelation
streaming
RabbitMQStreamSource
streaming
RabbitMQStringDecoder
streaming
RabbitMQUtils
streaming
RadixSort
sort
Rand
expressions
Randn
expressions
Random
InitializationMode
RandomBlockReplicationPolicy
storage
RandomDataGenerator
random
RandomForest
tree
RandomForestClassificationExample
mllib
RandomForestClassificationModel
classification
RandomForestClassifier
classification
RandomForestClassifierExample
ml
RandomForestExample
ml
RandomForestModel
model
RandomForestRegressionExample
mllib
RandomForestRegressionModel
regression
RandomForestRegressor
regression
RandomForestRegressorExample
ml
RandomRDDGeneration
mllib
RandomRDDs
random
RandomSampler
random
RandomVertexCut
PartitionStrategy
Range
logical scala
RangeDependency
spark
RangeExec
execution
RangeFrame
expressions
RangePartitioner
spark
RangePartitioning
physical
Rank
expressions
RankLike
expressions
RankingMetrics
evaluation
RankingMetricsExample
mllib
RateController
scheduler
RateEstimator
rate
Rating
ALSExample ALS recommendation
RawNetworkGrep
streaming
RawSocketStreamRelation
streaming
RawSocketStreamSource
streaming
ReadWriteLock
LockUtils
Real
PoissonType
Receiver
receiver
ReceiverInfo
scheduler
ReceiverInputDStream
dstream
RecommendationExample
mllib
Record
sql SparkHiveExample streaming
RecordBinaryComparator
execution
RecordComparator
sort
RecordPointerAndKeyPrefix
sort
RecordReaderIterator
datasources
RecoverableNetworkWordCount
streaming
RecoveryService
recovery
RecurringFuture
snappydata
ReduceFunction
function
RefParamLiteral
expressions
ReferenceToExpressions
expressions
RefreshMetadata
execution
RefreshResource
datasources
RefreshTable
datasources
RegExpExtract
expressions
RegExpReplace
expressions
RegType
BinaryClassification RegType LinearRegression RegType
RegexTokenizer
feature
RegionDiskViewOrdering
recovery
RegisterDriver
mesos
RegisterExecutor
protocol
Regression
Algo
RegressionEvaluator
evaluation
RegressionMetrics
evaluation
RegressionMetricsExample
mllib
RegressionModel
regression regression
RelationInfo
catalog
RelationProvider
sources
RelationalGroupedDataset
sql
RelativeError
common
Remainder
expressions
RemoteDUnitVM
standalone
RemoteDUnitVMIF
dunit
RemoteEntriesIterator
impl
RemoteILoop
interpreter
RemoteInterpreterStateHolder
interpreter
RemoveDispensableExpressions
optimizer
RemoveLiteralFromGroupExpressions
optimizer
RemoveRedundantAliases
optimizer
RemoveRedundantProject
optimizer
RemoveRepetitionFromGroupExpressions
optimizer
RemoveSubqueriesAboveSQLTable
Canonicalizer
RenewDelegationToken
ThriftCLIService
ReorderAssociativeOperator
optimizer
ReorderJoin
optimizer
Repartition
logical
RepartitionByExpression
logical
RepeatableRunnable
dunit
ReplaceDistinctWithAggregate
optimizer
ReplaceExceptWithAntiJoin
optimizer
ReplaceExpressions
optimizer
ReplaceIntersectWithSemiJoin
optimizer
ReplaceWithSampleTable
common
Replacement
sources
ReplacementSet
sources
Replicates
sources
RequestMessage
protocol
ResamplePlaceholder
bootstrap
ReservoirRegionSegmentMap
execution
ReservoirSegment
StratifiedSampler
ResetCommand
command
ResolveAggregateFunctions
Analyzer
ResolveAliasInGroupBy
SnappySessionState
ResolveAliases
Analyzer
ResolveCreateNamedStruct
analysis
ResolveDataSource
datasources
ResolveDeserializer
Analyzer
ResolveErrorEstimateFunctions
AQPQueryAnalyzer
ResolveFunctions
Analyzer
ResolveGenerate
Analyzer
ResolveGroupingAnalytics
Analyzer
ResolveIndex
sources
ResolveInlineTables
analysis
ResolveMissingReferences
Analyzer
ResolveNaturalAndUsingJoin
Analyzer
ResolveNewInstance
Analyzer
ResolveOrdinalInOrderByAndGroupBy
Analyzer
ResolvePivot
Analyzer
ResolveQueryHints
sources
ResolveReferences
Analyzer
ResolveRelations
Analyzer
ResolveSQLTable
Canonicalizer
ResolveSubquery
Analyzer
ResolveTableValuedFunctions
analysis
ResolveUpCast
Analyzer
ResolveWindowFrame
Analyzer
ResolveWindowOrder
Analyzer
ResolvedStar
analysis
Resolver
analysis
Responder
JettyUtils
ResponseMessage
protocol
Resubmitted
spark
ResultPersistenceTimeout
Property
ResultSetDecoder
row
ResultSetIterator
columnar
ResultSetNullHolder
row
ResultSetTraversal
row
ResultsExpressionCreator
common
RetryingBlockFetcher
shuffle
ReturnAnswer
logical
ReturnType
ExtractEquiJoinKeys PhysicalAggregation PhysicalOperation PhysicalScan HasColocatedEntities
ReusableRow
collection
ReuseExchange
exchange
ReuseSubquery
execution
ReusedExchangeExec
exchange
RewriteCorrelatedScalarSubquery
optimizer
RewriteDistinctAggregates
optimizer
RewritePredicateSubquery
optimizer
RichAttribute
DeclarativeAggregate
RidgeRegressionModel
regression
RidgeRegressionWithSGD
regression
Right
scala
RightOuter
plans
Rint
expressions
Rollup
expressions
Round
expressions
RoundBase
expressions
RoundRobinPartitioning
physical
Row
CatalogObjectType sql
RowBasedHashMapGenerator
aggregate
RowBasedKeyValueBatch
expressions
RowBasedSet
cli
RowDataSourceScanExec
execution
RowDeleteExec
row
RowEncoder
encoders
RowExec
row
RowFactory
sql
RowFormatRelation
row
RowFormatScanRDD
row
RowFrame
expressions
RowInsertExec
row
RowInsertableRelation
sources
RowIterator
execution
RowLevelSecurity
SnappySessionState
RowLevelSecurityRelation
sources
RowMatrix
distributed
RowNumber
expressions
RowNumberLike
expressions
RowOrdering
expressions
RowOrdinal
ColumnDelta
RowPutRelation
sources
RowSet
cli
RowSetFactory
cli
RowToInternalRow
collection
RowUpdateExec
row
RowWithWeight
StratifiedSampler
RowsConverter
snappydata
RpcFailure
protocol
RpcHandler
server
RpcRequest
protocol
RpcResponse
protocol
RpcResponseCallback
client
Rule
AssociationRules rules
RuleExecutor
rules
RuleNumbers
common
RuleUtils
sources
RunLengthDecoder
encoding
RunLengthDecoderBase
encoding
RunLengthDecoderNullable
encoding
RunLengthDecoding
encoding
RunLengthEncoding
encoding
RunnableCommand
command
RuntimeConfig
sql
RuntimeException
scala
RuntimeReplaceable
expressions
r
execution
r2
LinearRegressionSummary RegressionMetrics
radians
functions
rand
LocalFileLR LocalKMeans LocalLR SparkHdfsLR SparkLR SparkTC DenseMatrix Matrices DenseMatrix Matrices functions
randn
DenseMatrix Matrices DenseMatrix Matrices functions
random
mllib util
randomElement
GsRandom
randomJavaRDD
RandomRDDs
randomJavaVectorRDD
RandomRDDs
randomRDD
RandomRDDs
randomReadableString
GsRandom
randomSplit
JavaRDD RDD Dataset
randomSplitAsList
Dataset
randomString
GsRandom
randomUID
Identifiable
randomVectorRDD
RandomRDDs
range
SparkContext SQLContext SparkSession RangeExec
rangeBetween
Window WindowSpec
rank
Params Conf ALSModel GeneralizedLinearRegressionSummary MatrixFactorizationModel RankLike functions
rankSource
DenseRank RankLike
rate
scheduler
rateController
InputDStream ReceiverInputDStream
rating
Rating Rating Rating
raw2prediction
ClassificationModel LogisticRegressionModel ProbabilisticClassificationModel
raw2probability
ProbabilisticClassificationModel
raw2probabilityInPlace
DecisionTreeClassificationModel LogisticRegressionModel NaiveBayesModel ProbabilisticClassificationModel RandomForestClassificationModel
rawSocketStream
StreamingContext JavaStreamingContext
rawWeight
ClosedFormErrorEstimate StatCounterUpdater MapColumnToWeight
rdd
Dependency NarrowDependency ShuffleDependency JavaDoubleRDD JavaPairRDD JavaRDD JavaRDDLike mllib spark Dataset EncoderScanExec ExternalRDD ExternalRDDScanExec LogicalRDD RDDScanExec RowDataSourceScanExec
rddBlocks
ExecutorSummary StorageStatus
rddBlocksById
StorageStatus
rddId
SparkListenerUnpersistRDD CachedDataFrame RDDBlockId
rddInfoList
StorageListener
rddInfos
StageInfo
rddStorageLevel
StorageStatus
rddToAsyncRDDActions
RDD
rddToDatasetHolder
SQLImplicits
rddToOrderedRDDFunctions
RDD
rddToPairRDDFunctions
RDD
rddToSequenceFileRDDFunctions
RDD
rdds
CoGroupedRDD UnionRDD
read
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 PersistenceEngine InputMetrics OutputMetrics ShuffleReadMetrics ShuffleWriteMetrics TaskMetrics LZ4BlockInputStream NioBufferedFileInputStream Pipeline PipelineModel DecisionTreeClassificationModel GBTClassificationModel LogisticRegressionModel MultilayerPerceptronClassificationModel NaiveBayesModel OneVsRest OneVsRestModel RandomForestClassificationModel BisectingKMeansModel DistributedLDAModel GaussianMixtureModel KMeansModel LDA LocalLDAModel BucketedRandomProjectionLSHModel ChiSqSelectorModel CountVectorizerModel IDFModel MaxAbsScalerModel MinHashLSHModel MinMaxScalerModel PCAModel RFormulaModel StandardScalerModel StringIndexerModel VectorIndexerModel Word2VecModel ALSModel AFTSurvivalRegressionModel DecisionTreeRegressionModel GBTRegressionModel GeneralizedLinearRegressionModel IsotonicRegressionModel LinearRegressionModel RandomForestRegressionModel CrossValidator CrossValidatorModel TrainValidationSplit TrainValidationSplitModel DefaultParamsReadable MLReadable LimitedInputStream ConnectionPropertiesSerializer PartitionResultSerializer StructTypeSerializer CachedDataFrame SQLContext SparkSession DynamicFoldableExpression ParamLiteral TokenLiteral UnsafeRow LazilyGeneratedOrdering SerializedMap SerializedRowData MultiBucketExecutorPartition SmartExecutorBucketPartition CMSParams IntervalTracker RDDKryo TopKHokusai WholeStageCodegenRDD ByteMutableRow DoubleMutableRow CountMinSketch ColumnarStorePartitionedRDD JDBCSourceAsColumnarStore SmartConnectorColumnRDD SmartConnectorRowRDD OpLogRdd RowFormatScanRDD StreamSummaryAggregationKryoSerializer TopkHokusaiKryoSerializer StreamMetadata StreamSummaryAggregation RDDBlockId WriteAheadLog UTF8String AccumulatorV2Kryo BitSet
readAll
WriteAheadLog
readAndEncode
DeltaWriter
readAndTransformClass
ExecutorClassLoader
readArray
ColumnDecoder ColumnDeltaDecoder UncompressedDecoderBase ResultSetDecoder UnsafeRowDecoder
readBatches
InMemoryTableScanExec
readBinary
ColumnDecoder ColumnDeltaDecoder UncompressedDecoderBase VectorizedPlainValuesReader VectorizedRleValuesReader VectorizedValuesReader ResultSetDecoder UnsafeRowDecoder
readBinarys
VectorizedRleValuesReader
readBoolean
BooleanBitSetDecoderBase ColumnDecoder ColumnDeltaDecoder RunLengthDecoderBase UncompressedDecoderBase VectorizedPlainValuesReader VectorizedRleValuesReader VectorizedValuesReader ResultSetDecoder UnsafeRowDecoder
readBooleanRLE
BooleanRunLengthDecoder
readBooleans
VectorizedPlainValuesReader VectorizedRleValuesReader VectorizedValuesReader
readByte
ColumnDecoder ColumnDeltaDecoder RunLengthDecoderBase UncompressedDecoderBase VectorizedPlainValuesReader VectorizedRleValuesReader VectorizedValuesReader ResultSetDecoder UnsafeRowDecoder
readBytes
VectorizedPlainValuesReader VectorizedRleValuesReader VectorizedValuesReader ShuffleReadMetricDistributions
readComplexType
JDBCWithComplexTypes
readDataType
ClusterCallbacksImpl
readDate
ColumnDecoder ColumnDeltaDecoder ResultSetDecoder
readDecimal
ColumnDecoder ColumnDeltaDecoder UncompressedDecoderBase ResultSetDecoder UnsafeRowDecoder
readDictionaryIndex
BigDictionaryDecoderBase ColumnDecoder DictionaryDecoderBase UpdatedColumnDecoderBase
readDouble
ColumnDecoder ColumnDeltaDecoder ColumnEncoding UncompressedDecoderBase VectorizedPlainValuesReader VectorizedValuesReader ResultSetDecoder UnsafeRowDecoder
readDoubles
VectorizedPlainValuesReader VectorizedRleValuesReader VectorizedValuesReader
readExternal
Counter JavaSerializer BlockAndExecutorId UnsafeRow SerializedMap SerializedRowData ByteMutableRow DoubleMutableRow BlockManagerId StorageLevel UTF8String
readFields
TestWritable
readFile
JsonDataSource TextInputJsonDataSource WholeFileJsonDataSource
readFloat
ColumnDecoder ColumnDeltaDecoder ColumnEncoding UncompressedDecoderBase VectorizedPlainValuesReader VectorizedValuesReader ResultSetDecoder UnsafeRowDecoder
readFloats
VectorizedPlainValuesReader VectorizedRleValuesReader VectorizedValuesReader
readInt
BigDictionaryDecoderBase ColumnDecoder ColumnDeltaDecoder ColumnEncoding DictionaryDecoderBase RunLengthDecoderBase UncompressedDecoderBase ResultSetDecoder UnsafeRowDecoder
readIntBigEndian
ColumnEncoding
readInteger
VectorizedPlainValuesReader VectorizedRleValuesReader VectorizedValuesReader
readIntegers
VectorizedPlainValuesReader VectorizedRleValuesReader VectorizedValuesReader
readInterval
ColumnDecoder ColumnDeltaDecoder UncompressedDecoderBase ResultSetDecoder UnsafeRowDecoder
readKey
DeserializationStream
readKryo
SQLMetric AccumulatorV2Kryo CollectionAccumulator DoubleAccumulator LongAccumulator
readLock
ReadWriteLock
readLong
BigDictionaryDecoderBase ColumnDecoder ColumnDeltaDecoder ColumnEncoding DictionaryDecoderBase RunLengthDecoderBase UncompressedDecoderBase VectorizedPlainValuesReader VectorizedValuesReader ResultSetDecoder UnsafeRowDecoder
readLongBigEndian
ColumnEncoding
readLongDecimal
ColumnDecoder ColumnDeltaDecoder UncompressedDecoderBase ResultSetDecoder UnsafeRowDecoder
readLongs
VectorizedPlainValuesReader VectorizedRleValuesReader VectorizedValuesReader
readMap
ColumnDecoder ColumnDeltaDecoder UncompressedDecoderBase ResultSetDecoder UnsafeRowDecoder
readMetadata
TypeUtilities
readNotNull
ColumnDeltaDecoder UpdatedColumnDecoder UpdatedColumnDecoderBase UpdatedColumnDecoderNullable
readNullBitsCode
SHAMapAccessor
readObject
DeserializationStream
readPartitions
InMemoryTableScanExec
readPersistedData
PersistenceEngine
readProperties
TypeUtilities
readRecords
ShuffleReadMetricDistributions
readRunLength
RunLengthDecoding
readSchemaFromFooter
ParquetFileFormat
readShort
ColumnDecoder ColumnDeltaDecoder ColumnEncoding RunLengthDecoderBase UncompressedDecoderBase ResultSetDecoder UnsafeRowDecoder
readShorts
VectorizedRleValuesReader
readSplitProperty
JdbcExtendedUtils
readStream
SQLContext SparkSession
readStruct
ColumnDecoder ColumnDeltaDecoder UncompressedDecoderBase ResultSetDecoder UnsafeRowDecoder
readTimestamp
ColumnDecoder ColumnDeltaDecoder ResultSetDecoder
readType
StructTypeSerializer
readUTF8String
BigDictionaryDecoderBase ColumnDecoder ColumnDeltaDecoder ColumnEncoding DictionaryDecoderBase RunLengthDecoderBase UncompressedDecoderBase ResultSetDecoder UnsafeRowDecoder
readValue
DeserializationStream
readValueDictionaryId
VectorizedRleValuesReader
readVarsFromBBMap
SHAMapAccessor
ready
ComplexFutureAction FutureAction SimpleFutureAction
realExprId
ErrorEstimateAttribute
reason
ExecutorLostFailure SparkListenerExecutorRemoved SparkListenerTaskEnd SnappyJobInvalid
recacheByPath
CacheManager
recacheByPlan
CacheManager
recall
MulticlassMetrics MultilabelMetrics
recallByThreshold
BinaryLogisticRegressionSummary BinaryClassificationMetrics
receive
NettyBlockRpcServer NoOpRpcHandler RpcHandler ExternalShuffleBlockHandler
receiveBuf
TransportConf
receiver
streaming
receiverInfo
StreamingListenerReceiverError StreamingListenerReceiverStarted StreamingListenerReceiverStopped
receiverInputDStream
JavaPairReceiverInputDStream JavaReceiverInputDStream
receiverStream
StreamingContext JavaStreamingContext
recentProgress
ProgressReporter StreamingQueryWrapper StreamingQuery
recommendProducts
MatrixFactorizationModel
recommendProductsForUsers
MatrixFactorizationModel
recommendUsers
MatrixFactorizationModel
recommendUsersForProducts
MatrixFactorizationModel
recommendation
ml mllib
recordReader
HiveScriptIOSchema
recordReaderClass
ScriptInputOutputSchema HiveScriptIOSchema
recordWriter
HiveScriptIOSchema
recordWriterClass
ScriptInputOutputSchema HiveScriptIOSchema
recordsRead
InputMetrics ShuffleReadMetrics InputMetricDistributions InputMetrics ShuffleReadMetrics
recordsWritten
OutputMetrics ShuffleWriteMetrics OutputMetricDistributions OutputMetrics ShuffleWriteMetrics
recoverPartitions
Catalog CatalogImpl
recovery
snappydata
recoveryStats
RecoveryService
redirectError
SparkLauncher
redirectOutput
SparkLauncher
redirectToLog
SparkLauncher
reduce
JavaRDDLike MyAverage RDD Dataset TypedAverage TypedCount TypedSumDouble TypedSumLong Aggregator JavaDStreamLike DStream
reduceByKey
JavaPairRDD PairRDDFunctions JavaPairDStream PairDStreamFunctions
reduceByKeyAndWindow
JavaPairDStream PairDStreamFunctions
reduceByKeyLocally
JavaPairRDD PairRDDFunctions
reduceByWindow
JavaDStreamLike DStream
reduceGroups
KeyValueGroupedDataset
reduceId
FetchFailed ShuffleBlockId ShuffleDataBlockId ShuffleIndexBlockId
redundancy
TableSummary
redundancyImpaired
TableSummary
references
Attribute Expression Grouping GroupingID PredicateSubquery ScalarSubquery AggregateExpression CodegenContext QueryPlan Expand ObjectConsumer ScriptTransformation ExpandExec ObjectConsumerExec StratifiedSample WholeStageCodegenRDD TypedAggregateExpression BootstrapCount BootstrapReferencer ErrorEstimateAttribute And EqualNullSafe EqualTo Filter GreaterThan GreaterThanOrEqual In IsNotNull IsNull LessThan LessThanOrEqual Not Or StringContains StringEndsWith StringStartsWith
refresh
LogicalPlan CatalogFileIndex FileIndex InMemoryFileIndex LogicalRelation MetadataLogFileIndex
refreshAndGetTableSizeStats
TableStatsProviderService
refreshByPath
Catalog CatalogImpl
refreshFunction
InsertIntoHadoopFsRelationCommand
refreshLdapGroupCallback
ToolsCallback ToolsCallbackImpl
refreshOnLdapGroupRefresh
SnappyInterpreterExecute
refreshPolicies
StoreCallbacksImpl SnappyHiveExternalCatalog
refreshTable
SnappyDDLParser Catalog SessionCatalog HiveContext CatalogImpl SnappySessionCatalog
refreshTableSchema
NativeTableRowLevelSecurityRelation
regParam
Params Params Params Params
regType
Params Params
regexp
RegExpExtract RegExpReplace
regexp_extract
functions
regexp_replace
functions
region
PartitionedDataSourceScan RowFormatScanRDD ColumnFormatSamplingRelation NativeTableRowLevelSecurityRelation
regionContext
ColumnFormatValue
regionViewMapSortedSet
RecoveryService
register
AbstractService FilterService Service SparkContext SnappyDataPoolDialect UDFRegistration DriverRegistry ExecutionListenerManager
registerApp
ShuffleSecretManager
registerAsTable
SchemaDStream
registerAvroSchemas
SparkConf
registerBuiltinDrivers
ExternalStoreUtils
registerCQ
SnappyStreamingContext JavaSnappyStreamingContext
registerCatalogSchemaChange
StoreCallbacksImpl SnappyHiveExternalCatalog
registerChannel
OneForOneStreamManager StreamManager
registerClasses
KryoRegistrator SnappyKryoRegistrator
registerComment
CodegenContext
registerDialect
JdbcDialects
registerDriver
Utils
registerDriverUrl
Utils
registerDriverWithShuffleService
MesosExternalShuffleClient
registerExchange
ExchangeCoordinator
registerExecutor
SnappyCoarseGrainedExecutorBackend ExternalShuffleBlockResolver
registerFunction
EmptyFunctionRegistry FunctionRegistry SimpleFunctionRegistry
registerKryoClasses
SparkConf GraphXUtils
registerPicklers
EvaluatePython
registerPython
UDFRegistration
registerPythonCQ
JavaSnappyStreamingContext
registerSampleTable
SampleDataFrame SampleDataFrameContract SampleDataFrameContractImpl
registerSnappyFunctions
SnappyContextFunctions SnappyContextAQPFunctions
registerStream
StreamingTest OneForOneStreamManager
registerStreamTables
SnappyStreamingContext
registerTempTable
Dataset
registerTestTable
TestHiveSparkSession
registerTopK
SnappyAQPSessionCatalog
registerTypes
ColumnFormatEntry StoreCallbacksImpl
registerWithShuffleServer
ExternalShuffleClient
registryEntry
CreateStruct
regression
ml mllib
rehashIfNeeded
MultiColumnOpenHashSet OpenHashSet
reindex
VertexRDD VertexRDDImpl
relation
SnappyParser SqlBaseParser DataSourceScanExec FileSourceScanExec RowDataSourceScanExec TableExec ColumnDeleteExec ColumnInsertExec ColumnUpdateExec InMemoryTableScanExec LogicalRelation RowDeleteExec RowInsertExec RowUpdateExec
relationFactor
SnappyParser
relationInfo
NativeTableRowLevelSecurityRelation
relationInfoAndRegion
NativeTableRowLevelSecurityRelation
relationLeaf
SnappyParser
relationPrimary
SqlBaseParser
relationWithExternal
SnappyParser
relations
SnappyParser
relativeDirection
Edge
relativeError
QuantileSummaries CountMinSketch
relativeErrorsExprIDs
SnappyHashAggregate SnappySortAggregate
relativeSD
HyperLogLogPlusPlus
relative_error
functions
release
ByteBufferData ByteBufferHashMap HiveSessionImpl FileSegmentManagedBuffer ManagedBuffer NettyManagedBuffer NioManagedBuffer KryoSerializerPool
releaseBuffer
ColumnFormatValue
releaseExecutionMemory
ExecutionFreeMemory MemoryManagerCallback SnappyUnifiedMemoryManager TaskMemoryManager
releaseForReuse
ColumnEncoder
releaseSharedLock
DUnitBB
releaseStorageMemory
SnappyUnifiedMemoryManager SharedUtils StoreCallbacksImpl
releaseStorageMemoryForObject
DefaultMemoryManager SnappyUnifiedMemoryManager StoreUnifiedManager
remainder
ParserUtils Decimal
remainingParamLiterals
SparkSQLPrepareImpl
remember
StreamingContext JavaStreamingContext
remote
snappydata
remoteBlocksFetched
ShuffleReadMetrics ShuffleReadMetricDistributions ShuffleReadMetrics
remoteBytesRead
ShuffleReadMetrics ShuffleReadMetricDistributions ShuffleReadMetrics
remove
SnappyMetricsSystem DUnitBB SparkConf ParamMap GlobalTempViewManager StringKeyHashMap MultiColumnOpenHashMap CaseInsensitiveMutableHashMap StateStore SQLAltName MetadataBuilder State MapIterator
removeAddedJar
SparkContext
removeApplication
PersistenceEngine
removeCachedObjects
ExternalStoreUtils
removeDriver
PersistenceEngine
removeDriverJar
ContextJarUtils
removeErrorAndConfidence
QueryRoutingRules
removeExpiredOperations
OperationManager
removeExternalTableMetrics
SnappyTableMetrics
removeExternalTableMetricsIfTableDeleted
SnappyMetricsSystem
removeFetchRequest
TransportResponseHandler
removeFile
SparkContext
removeFromTheListInCmdRegion
ContextJarUtils
removeFunctionArtifacts
ContextJarUtils
removeFunctionJars
ToolsCallback ToolsCallbackImpl
removeInternalPropsAndGetTable
ExternalStoreUtils
removeJarFiles
ToolsCallbackImpl
removeJarsFromExecutorLoader
SnappyExecutor
removeListener
StreamingQueryManager
removePackage
ToolsCallback ToolsCallbackImpl
removePoolReference
ConnectionPool
removeRpcRequest
TransportClient TransportResponseHandler
removeSampler
StratifiedSampler StoreCallbacksImpl
removeSamplingOptions
ExternalStoreUtils
removeSelfEdges
GraphOps
removeService
CompositeService
removeSnappySession
SnappySessionPerConnection
removeTableIfExists
StoreHiveCatalog
removeTableMetrics
SnappyTableMetrics
removeTableMetricsIfTableDeleted
SnappyMetricsSystem
removeTableUnsafeIfExists
StoreHiveCatalog
removeURIs
ToolsCallback ToolsCallbackImpl
removeURIsFromExecutorClassLoader
ToolsCallback ToolsCallbackImpl
removeWorker
PersistenceEngine
rename
GlobalTempViewManager FileContextManager FileManager FileSystemManager
renameFunction
SmartConnectorExternalCatalog ExternalCatalog InMemoryCatalog SnappyHiveExternalCatalog
renamePartitions
SmartConnectorExternalCatalog ExternalCatalog InMemoryCatalog SessionCatalog SnappyHiveExternalCatalog SnappySessionCatalog
renameTable
SmartConnectorExternalCatalog ExternalCatalog InMemoryCatalog SessionCatalog SnappyHiveExternalCatalog SnappySessionCatalog
render
ExecutionPage
renewDelegationToken
HiveAuthFactory CLIService CLIServiceClient EmbeddedCLIServiceClient ICLIService HiveSession HiveSessionImpl HiveSessionImplwithUGI ThriftCLIServiceClient
rep
RegExpReplace
repartition
JavaDoubleRDD JavaPairRDD JavaRDD RDD Dataset DslLogicalPlan SchemaDStream JavaDStream JavaPairDStream DStream
repartitionAndSortWithinPartitions
JavaPairRDD OrderedRDDFunctions
repeat
functions UTF8String
repl
spark
replOutputDir
RemoteInterpreterStateHolder
replOutputDirStr
RemoteInterpreterStateHolder
replace
DataFrameNaFunctions CreateViewCommand CreateTempViewUsing
replaceAlias
PredicateHelper
replaceAttribute
Entity
replaceCharType
HiveStringType
replaceExpr
StringTranslate
replaceNonSupportedErrorEstimate
PostReplaceSampleTableQueryRoutingRules
replaceNonSupportedErrorEstimates
PostReplaceSampleTableQueryRoutingRules
replaced
CompletePlan PartialPlan
replacedPlan
Replacement
replayCmd
RemoteInterpreterStateHolder
replicatedTableJoin
HashJoinExec
replicatedVertexView
GraphImpl
replicates
PartialPlan
replication
StorageLevel
reportError
Receiver
reportFailure
CurrentThreadExecutor
reportTimeTaken
ProgressReporter
repos
DeployCommand
requestExecutors
SparkContext
requestTotalExecutors
SparkContext
requireDbExists
SnappyExternalCatalog ExternalCatalog
requireFunctionExists
SnappyExternalCatalog ExternalCatalog
requireFunctionNotExists
SnappyExternalCatalog ExternalCatalog
requireHiddenGroupBy
AQPRules
requireHiddenRelativeErrors
AQPRules
requireTableExists
SnappyExternalCatalog ExternalCatalog
requiredChildDistribution
CoGroupExec FlatMapGroupsInRExec GlobalLimitExec MapGroupsExec SnappySortExec SortExec SparkPlan TableExec CollectAggregateExec HashAggregateExec SnappyHashAggregateExec SortAggregateExec ColumnExec BroadcastHashJoinExec BroadcastNestedLoopJoinExec HashJoinExec ShuffledHashJoinExec SnappyJoinLike SortMergeJoinExec WindowExec
requiredChildDistributionExpressions
HashAggregateExec SnappyHashAggregateExec SortAggregateExec
requiredChildOrdering
CoGroupExec FlatMapGroupsInRExec MapGroupsExec SparkPlan SortAggregateExec ColumnExec SortMergeJoinExec WindowExec
reregisterExecutor
ExternalShuffleBlockHandler
res
LocalizedMessages
reserve
ColumnVector
reserveDictionaryIds
ColumnVector
reserveInternal
ColumnVector OffHeapColumnVector OnHeapColumnVector
reservedKeywords
SnappyParserConsts
reservoir
StratumReservoir
reservoirInRegion
StratifiedSampler StratifiedSamplerCachedInRegion
reservoirRegionName
ColumnFormatSamplingRelation
reservoirSize
StratifiedSamplerReservoir StratumReservoir
reset
ByteBufferData ByteBufferHashMap DataInputBuffer DataOutputBuffer LZ4BlockInputStream HiveCatalogMetrics ByteArrayWritableChannel LimitedInputStream SnappyDDLParser SessionCatalog BufferHolder UnsafeRowWriter CurrentOrigin StratumCache StratumReservoir StatCounterWithFullCount ReplaceWithSampleTable SQLMetric EventTimeStatsAccum MemoryStream ColumnVector ColumnarBatch TestHiveContext TestHiveSparkSession SnappySessionCatalog BytesToBytesMap AccumulatorV2 CollectionAccumulator DoubleAccumulator LegacyAccumulatorWrapper LongAccumulator UnsafeInMemorySorter
resetCmd
RemoteInterpreterStateHolder
resetCommand
SparkILoop
resetForTesting
FileStatusCache
resetInsertions
CallbackColumnInsert
resetLogger
Logging
resetMemoryManager
MemoryManagerCallback StoreCallbacksImpl
resetMetrics
SparkPlan
resetNullBitsetCode
SHAMapAccessor
resetTerminated
StreamingQueryManager
resetTime
RuleExecutor
residualDegreeOfFreedom
GeneralizedLinearRegressionSummary
residualDegreeOfFreedomNull
GeneralizedLinearRegressionSummary
residuals
GeneralizedLinearRegressionSummary LinearRegressionSummary
resize
ByteBufferData
resolve
LogicalPlan
resolveAndBind
ExpressionEncoder
resolveChildren
LogicalPlan
resolveExistingTable
SnappySessionCatalog
resolveExpression
Analyzer
resolveExpressions
LogicalPlan
resolveMavenCoordinates
PackageAndDepUtils
resolveOperators
LogicalPlan
resolvePartitions
PartitioningUtils
resolveQCS
Utils
resolveQuoted
LogicalPlan
resolveRelation
DataSource SnappySessionCatalog
resolveRelationWithAlias
SnappySessionCatalog
resolveTable
JDBCRDD
resolveTableIdentifier
SnappySessionCatalog
resolved
DMLExternalTable GetColumnByOrdinal MultiAlias Star UnresolvedAlias UnresolvedAttribute UnresolvedDeserializer UnresolvedExtractValue UnresolvedFunction UnresolvedGenerator UnresolvedInlineTable UnresolvedOrdinal UnresolvedRelation UnresolvedTableValuedFunction SimpleCatalogRelation Alias BinaryArithmetic Exists Expression GroupingSet ListQuery NamePlaceholder PredicateSubquery ScalarSubquery TimeWindow UnresolvedWindowExpression UpCast WindowSpecDefinition NewInstance Aggregate Generate GroupingSets InsertIntoTable Join LogicalPlan Project SetOperation Union TypedAggregateExpression ApproxColumn ApproxColumnDebug ApproxColumnExtractor ClosedFormColumnExtractor StatCounterMergerer StatCounterUpdater CoalesceDisparateTypes PlaceHolderPlan PutIntoColumnTable Delete PutIntoTable
resolvedExceptNatural
Join
resolvedName
ColumnExec JDBCAppendableRelation RowDeleteExec RowExec RowInsertExec RowUpdateExec JDBCMutableRelation PlanInsertableRelation RowLevelSecurityRelation
resolver
Analyzer DataSourceAnalysis SQLConf
resource
SqlBaseParser
resourceToBytes
util
resourceToString
util
resourceType
SnappyStorageEvictor SnappyDDLParser FunctionResource FunctionResourceType
resources
CatalogFunction CreateFunctionCommand
responder
ServletParams
response
SparkSaslClient SparkSaslServer
restart
DeployCommand DeployJarCommand Receiver
restartExecutor
ExecutorInitiator
result
RecurringFuture ComplexFutureAction FutureAction SimpleFutureAction ReferenceToExpressions MultiColumnOpenHashMap MultiColumnOpenHashSet ProcessRows RowExec
resultAttribute
AggregateExpression
resultBatch
VectorizedParquetRecordReader
resultBuffer
RemoteInterpreterStateHolder
resultExpressions
HashAggregateExec SnappyHashAggregateExec SortAggregateExec SnappyHashAggregate SnappyPartialHashAggregate SnappyPartialSortedAggregate SnappySortAggregate
resultId
AggregateExpression
resultSerializationTime
TaskMetrics TaskMetricDistributions TaskMetrics
resultSetToObjectArray
JdbcRDD
resultSetToRows
JdbcUtils
resultSetToSparkInternalRows
Utils
resultSize
TaskMetrics TaskMetricDistributions TaskMetrics
retain
FileSegmentManagedBuffer ManagedBuffer NettyManagedBuffer NioManagedBuffer AbstractFileRegion
retainData
AlterTableDropPartitionCommand
retainedJobs
JobProgressListener
retainedStages
JobProgressListener
retainedTasks
JobProgressListener
retryOnStaleCatalogException
CachedDataFrame
returnPlan
RuleUtils
retweetCnt
TwitterSchema
retweetTxt
TwitterSchema
reuseUsedSize
ColumnEncoder
reverse
EdgeDirection EdgeRDD Graph EdgeRDDImpl GraphImpl functions UTF8String
reverseRoutingTables
VertexRDD VertexRDDImpl
revokedLeadership
LeaderElectable
rewrite
RewriteDistinctAggregates
right
Add AddMonths And ArrayContains Atan2 BinaryExpression BitwiseAnd BitwiseOr BitwiseXor Contains DateAdd DateDiff DateFormatClass DateSub Decode Divide Encode EndsWith EqualNullSafe EqualTo FindInSet FormatNumber FromUTCTimestamp FromUnixTime GetArrayItem GetJsonObject GetMapValue GreaterThan GreaterThanOrEqual Hypot IfNull LessThan LessThanOrEqual Levenshtein Like Logarithm MonthsBetween Multiply NaNvl NextDay NullIf Nvl Or Pmod Pow RLike Remainder RoundBase Sha2 ShiftLeft ShiftRight ShiftRightUnsigned SortArray StartsWith StringInstr StringRepeat StringSplit Subtract TimeAdd TimeSub ToUTCTimestamp ToUnixTimestamp TruncDate UnixTimestamp CovPopulation CovSample RichAttribute XPathExtract BinaryNode CoGroup Except Intersect Join BinaryExecNode CoGroupExec StatCounterMergerer ColumnPutIntoExec BroadcastHashJoinExec BroadcastNestedLoopJoinExec CartesianProductExec HashJoin HashJoinExec ShuffledHashJoinExec SnappyJoinLike SortMergeJoinExec PutIntoColumnTable And Or
rightArray
MergeMultiplicityExpression
rightAttr
CoGroup CoGroupExec
rightCategories
CategoricalSplit
rightChild
InternalNode
rightConstraints
SetOperation
rightDeserializer
CoGroup CoGroupExec
rightGroup
CoGroup CoGroupExec
rightImpurity
InformationGainStats
rightKeys
BroadcastHashJoinExec HashJoin HashJoinExec ShuffledHashJoinExec SnappyJoinLike SortMergeJoinExec
rightNode
Node
rightOuterJoin
JavaPairRDD PairRDDFunctions JavaPairDStream PairDStreamFunctions
rightPredict
InformationGainStats
rightSizeInBytes
HashJoinExec SnappyJoinLike SnappySortMergeJoinExec
rightWeight
StatCounterWithFullCount
rint
functions
rlike
Column ImplicitOperators
rlsAppliedCondition
PolicyProperties
rlsConditionChecker
RowLevelSecurity
rlsConditionString
PolicyProperties
rlsConditionStringUtf8
PolicyProperties
rmatGraph
GraphGenerators
rmse
LocalALS SparkALS
rng
RDG StratifiedSampler
roc
BinaryLogisticRegressionSummary BinaryClassificationMetrics
rolloverMetricName
ColumnExec
rollup
Dataset
rootDir
Main
rootMeanSquaredError
LinearRegressionSummary RegressionMetrics
rootNode
DecisionTreeClassificationModel DecisionTreeRegressionModel
rootPaths
CatalogFileIndex FileIndex InMemoryFileIndex MetadataLogFileIndex
round
functions
row
execution sql
rowConverter
StreamBaseRelation
rowCount
EmptyIteratorWithRowCount Statistics RowExec TableSummary
rowFormat
SqlBaseParser
rowFormatterMap
OpLogRdd
rowHolder
InternalRowToRow RowToInternalRow
rowIndices
SparseMatrix SparseMatrix
rowInsertStr
BaseColumnFormatRelation JDBCMutableRelation
rowIter
Matrix Matrix
rowIterator
FixedLengthRowBasedKeyValueBatch RowBasedKeyValueBatch VariableLengthRowBasedKeyValueBatch ColumnarBatch
rowNumber
RankLike RowNumberLike
rowStream
PhysicalDStreamPlan StreamBaseRelation StreamPlan WindowPhysicalPlan
rowTable
CreateAndLoadAirlineDataJob
rowToColumnStat
ColumnStat
rowToInternalRowConverter
QCSSQLColumnHandler
rowToRowRdd
RDDConversions
rowToTupleConverter
TopKWrapper
row_number
functions
rows
IndexedRowMatrix RowMatrix UnresolvedInlineTable LocalTableScanExec
rowsBetween
Window WindowSpec
rowsPerBlock
BlockMatrix
rpad
functions UTF8String
rpcEnv
SnappyCoarseGrainedExecutorBackend SnappyCoarseGrainedSchedulerBackend
rs
ResultSetTraversal
rtrim
functions
ruleName
Rule
ruleNumProcessing
ErrorAndConfidence SampleTableQuery
ruleState
ReplaceWithSampleTable
rules
catalyst Batch
run
ExecutorRunnable RemoteInterpreterStateHolder AsyncInvocation LeaderLauncher LocatorLauncher ServerLauncher Operation ThriftBinaryCLIService ThriftCLIService ThriftHttpCLIService DataFrameExample DecisionTreeExample GBTExample LinearRegressionExample LogisticRegressionExample RandomForestExample BinaryClassification Correlations CosineSimilarity DecisionTreeRunner DenseKMeans FPGrowthExample GradientBoostedTreesRunner LinearRegression MovieLensALS MultivariateSummarizer PowerIterationClusteringExample SampledRDDs SparseNaiveBayes ConnectedComponents LabelPropagation PageRank SVDPlusPlus ShortestPaths StronglyConnectedComponents TriangleCount ExecutionFreeMemory LogisticRegressionWithLBFGS NaiveBayes BisectingKMeans GaussianMixture KMeans LDA PowerIterationClustering AssociationRules FPGrowth PrefixSpan ALS GeneralizedLinearAlgorithm IsotonicRegression DecisionTree GradientBoostedTrees SparkILoop AlterTableAddColumnCommand AlterTableDropColumnCommand AlterTableMiscCommand AlterTableToggleRowLevelSecurityCommand CreateIndexCommand CreatePolicyCommand CreateSchemaCommand CreateTableUsingCommand DeployCommand DeployJarCommand DescribeSnappyTableCommand DropIndexCommand DropPolicyCommand DropSchemaCommand DropTableOrViewCommand GrantRevokeIntpCommand GrantRevokeOnExternalTable InterpretCodeCommand ListPackageJarsCommand PutIntoValuesColumnTable SetSchemaCommand SetSnappyCommand ShowSnappyTablesCommand ShowViewsCommand SnappyCacheTableCommand SnappyStreamingActionsCommand TruncateManagedTableCommand UnDeployCommand AddFileCommand AddJarCommand AlterDatabasePropertiesCommand AlterTableAddPartitionCommand AlterTableDropPartitionCommand AlterTableRecoverPartitionsCommand AlterTableRenameCommand AlterTableRenamePartitionCommand AlterTableSerDePropertiesCommand AlterTableSetLocationCommand AlterTableSetPropertiesCommand AlterTableUnsetPropertiesCommand AlterViewAsCommand AnalyzeColumnCommand AnalyzeTableCommand CacheTableCommand ClearCacheCommand CreateDataSourceTableAsSelectCommand CreateDataSourceTableCommand CreateDatabaseCommand CreateFunctionCommand CreateSampleTableCommand CreateTableCommand CreateTableLikeCommand CreateViewCommand DescribeDatabaseCommand DescribeFunctionCommand DescribeTableCommand DropDatabaseCommand DropFunctionCommand DropTableCommand ExplainCommand ListFilesCommand ListJarsCommand LoadDataCommand ResetCommand RunnableCommand SetCommand SetDatabaseCommand ShowColumnsCommand ShowCreateTableCommand ShowDatabasesCommand ShowFunctionsCommand ShowPartitionsCommand ShowTablePropertiesCommand ShowTablesCommand StreamingExplainCommand TruncateTableCommand UncacheTableCommand CreateTempViewUsing InsertIntoDataSourceCommand InsertIntoHadoopFsRelationCommand RefreshResource RefreshTable CreateHiveTableAsSelectCommand ExternalTableDMLCmd
runApproximateJob
SparkContext
runAsSparkUser
SparkHadoopUtil
runCollocatedJoinQuery
CollocatedJoinExample
runId
ProgressReporter StreamExecution StreamingQueryWrapper StreamingQuery QueryStartedEvent QueryTerminatedEvent StreamingQueryProgress
runInternal
GetCatalogsOperation GetColumnsOperation GetFunctionsOperation GetSchemasOperation GetTableTypesOperation GetTablesOperation GetTypeInfoOperation HiveCommandOperation Operation SQLOperation
runJob
SparkContext SnappySQLJob SnappyStreamingJob JavaSnappyStreamingJob
runLBFGS
LBFGS
runLocalWordCount
DFSReadWriteTest
runMiniBatchSGD
GradientDescent
runParallelPersonalizedPageRank
PageRank
runPreCanonicalized
TriangleCount
runRepeatingIfNecessary
RepeatableRunnable
runSQLonFile
SimpleCatalystConf SQLConf
runShutdownHook
RemoteDUnitVM
runSnappyJob
AirlineDataJob CreateAndLoadAirlineDataJob DataUpdateJob JavaCreateAndLoadAirlineDataJob JavaTwitterPopularTagsJob SnappyDataTestJob TwitterPopularTagsJob CollocatedJoinExample CreateColumnTable CreatePartitionedRowTable CreateReplicatedRowTable SynopsisDataExample WorkingWithJson WorkingWithObjects JSONFileSourceExampleWithSnappySink SnappySQLJob SnappyStreamingJob JavaSnappyStreamingJob
runSynopsisDataExample
SynopsisDataExample
runUUID
StreamingQueryStatistics
runUntilConvergence
PageRank
runUntilConvergenceWithOptions
PageRank
runWithOptions
PageRank
runWithValidation
GradientBoostedTrees
running
SnappyMetricsSystem TaskInfo Status
rwLock
ReadWriteLock