Serialized Form
-
Package org.apache.hadoop.hive.ql.exec.vector
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorAppMasterEventOperator
class VectorAppMasterEventOperator extends org.apache.hadoop.hive.ql.exec.AppMasterEventOperator implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
vContext
org.apache.hadoop.hive.ql.exec.vector.VectorizationContext vContext
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorFileSinkOperator
class VectorFileSinkOperator extends org.apache.hadoop.hive.ql.exec.FileSinkOperator implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
vContext
org.apache.hadoop.hive.ql.exec.vector.VectorizationContext vContext
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorFilterOperator
class VectorFilterOperator extends org.apache.hadoop.hive.ql.exec.FilterOperator implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
conditionEvaluator
org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpression conditionEvaluator
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorGroupByOperator
class VectorGroupByOperator extends org.apache.hadoop.hive.ql.exec.Operator<org.apache.hadoop.hive.ql.plan.GroupByDesc> implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
aggregators
org.apache.hadoop.hive.ql.exec.vector.expressions.aggregates.VectorAggregateExpression[] aggregators
-
isVectorOutput
boolean isVectorOutput
-
keyExpressions
org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpression[] keyExpressions
-
memoryThreshold
float memoryThreshold
-
outputKeyLength
int outputKeyLength
-
vectorDesc
org.apache.hadoop.hive.ql.plan.VectorGroupByDesc vectorDesc
-
vOutContext
org.apache.hadoop.hive.ql.exec.vector.VectorizationContext vOutContext
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorLimitOperator
class VectorLimitOperator extends org.apache.hadoop.hive.ql.exec.LimitOperator implements Serializable- serialVersionUID:
- 1L
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorMapJoinBaseOperator
class VectorMapJoinBaseOperator extends org.apache.hadoop.hive.ql.exec.MapJoinOperator implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
vOutContext
org.apache.hadoop.hive.ql.exec.vector.VectorizationContext vOutContext
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorMapJoinOperator
class VectorMapJoinOperator extends org.apache.hadoop.hive.ql.exec.vector.VectorMapJoinBaseOperator implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
bigTableFilterExpressions
org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpression[] bigTableFilterExpressions
-
bigTableValueExpressions
org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpression[] bigTableValueExpressions
-
keyExpressions
org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpression[] keyExpressions
-
rowWriters
org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpressionWriter[] rowWriters
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorMapJoinOuterFilteredOperator
class VectorMapJoinOuterFilteredOperator extends org.apache.hadoop.hive.ql.exec.vector.VectorMapJoinBaseOperator implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
vContext
org.apache.hadoop.hive.ql.exec.vector.VectorizationContext vContext
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorMapOperator
class VectorMapOperator extends org.apache.hadoop.hive.ql.exec.AbstractMapOperator implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
currentPartDeserializer
org.apache.hadoop.hive.serde2.Deserializer currentPartDeserializer
-
currentPartRawRowObjectInspector
org.apache.hadoop.hive.serde2.objectinspector.StructObjectInspector currentPartRawRowObjectInspector
-
currentVectorAssign
org.apache.hadoop.hive.ql.exec.vector.VectorAssignRow currentVectorAssign
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorReduceSinkOperator
class VectorReduceSinkOperator extends org.apache.hadoop.hive.ql.exec.ReduceSinkOperator implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
vContext
org.apache.hadoop.hive.ql.exec.vector.VectorizationContext vContext
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorSelectOperator
class VectorSelectOperator extends org.apache.hadoop.hive.ql.exec.Operator<org.apache.hadoop.hive.ql.plan.SelectDesc> implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
projectedOutputColumns
int[] projectedOutputColumns
-
vectorDesc
org.apache.hadoop.hive.ql.plan.VectorSelectDesc vectorDesc
-
vExpressions
org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpression[] vExpressions
-
vOutContext
org.apache.hadoop.hive.ql.exec.vector.VectorizationContext vOutContext
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorSMBMapJoinOperator
class VectorSMBMapJoinOperator extends org.apache.hadoop.hive.ql.exec.SMBMapJoinOperator implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
bigTableFilterExpressions
org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpression[] bigTableFilterExpressions
-
bigTableValueExpressions
org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpression[] bigTableValueExpressions
-
keyExpressions
org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpression[] keyExpressions
-
keyOutputWriters
org.apache.hadoop.hive.ql.exec.vector.expressions.VectorExpressionWriter[] keyOutputWriters
-
vOutContext
org.apache.hadoop.hive.ql.exec.vector.VectorizationContext vOutContext
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorSparkHashTableSinkOperator
class VectorSparkHashTableSinkOperator extends org.apache.hadoop.hive.ql.exec.SparkHashTableSinkOperator implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
vContext
org.apache.hadoop.hive.ql.exec.vector.VectorizationContext vContext
-
-
Class org.apache.hadoop.hive.ql.exec.vector.VectorSparkPartitionPruningSinkOperator
class VectorSparkPartitionPruningSinkOperator extends org.apache.hadoop.hive.ql.parse.spark.SparkPartitionPruningSinkOperator implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
vContext
org.apache.hadoop.hive.ql.exec.vector.VectorizationContext vContext
-
-
-
Package org.apache.iceberg
-
Class org.apache.iceberg.AllDataFilesTable
class AllDataFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable -
Class org.apache.iceberg.AllDeleteFilesTable
class AllDeleteFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable -
Class org.apache.iceberg.AllEntriesTable
class AllEntriesTable extends org.apache.iceberg.BaseEntriesTable implements Serializable -
Class org.apache.iceberg.AllFilesTable
class AllFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable -
Class org.apache.iceberg.AllManifestsTable
class AllManifestsTable extends BaseMetadataTable implements Serializable -
Class org.apache.iceberg.BaseCombinedScanTask
class BaseCombinedScanTask extends Object implements Serializable-
Serialized Fields
-
tasks
FileScanTask[] tasks
-
-
-
Class org.apache.iceberg.BaseFileScanTask
class BaseFileScanTask extends org.apache.iceberg.BaseContentScanTask<FileScanTask,DataFile> implements Serializable -
Serialized Fields
-
deletes
DeleteFile[] deletes
-
-
-
Class org.apache.iceberg.BaseMetadataTable
class BaseMetadataTable extends org.apache.iceberg.BaseReadOnlyTable implements Serializable-
Serialization Methods
-
writeReplace
-
-
Serialized Fields
-
name
String name
-
sortOrder
SortOrder sortOrder
-
spec
PartitionSpec spec
-
table
BaseTable table
-
uuid
UUID uuid
-
-
-
Class org.apache.iceberg.BaseScanTaskGroup
class BaseScanTaskGroup extends Object implements Serializable-
Serialized Fields
-
groupingKey
StructLike groupingKey
-
tasks
Object[] tasks
-
-
-
Class org.apache.iceberg.BaseTable
class BaseTable extends Object implements Serializable-
Serialization Methods
-
writeReplace
Object writeReplace()
-
-
Serialized Fields
-
name
String name
-
ops
TableOperations ops
-
reporter
MetricsReporter reporter
-
-
-
Class org.apache.iceberg.BaseTransaction.TransactionTable
class TransactionTable extends Object implements Serializable-
Serialization Methods
-
writeReplace
Object writeReplace()
-
-
-
Class org.apache.iceberg.DataFilesTable
class DataFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable -
Class org.apache.iceberg.DeleteFilesTable
class DeleteFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable -
Class org.apache.iceberg.FilesTable
class FilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable -
Class org.apache.iceberg.GenericManifestFile
class GenericManifestFile extends Object implements Serializable-
Serialized Fields
-
addedFilesCount
Integer addedFilesCount
-
addedRowsCount
Long addedRowsCount
-
content
ManifestContent content
-
deletedFilesCount
Integer deletedFilesCount
-
deletedRowsCount
Long deletedRowsCount
-
existingFilesCount
Integer existingFilesCount
-
existingRowsCount
Long existingRowsCount
-
file
InputFile file
-
fromProjectionPos
int[] fromProjectionPos
-
keyMetadata
byte[] keyMetadata
-
length
Long length
-
manifestPath
String manifestPath
-
minSequenceNumber
long minSequenceNumber
-
partitions
ManifestFile.PartitionFieldSummary[] partitions
-
sequenceNumber
long sequenceNumber
-
snapshotId
Long snapshotId
-
specId
int specId
-
-
-
Class org.apache.iceberg.GenericPartitionFieldSummary
class GenericPartitionFieldSummary extends Object implements Serializable-
Serialized Fields
-
containsNaN
Boolean containsNaN
-
containsNull
boolean containsNull
-
fromProjectionPos
int[] fromProjectionPos
-
lowerBound
byte[] lowerBound
-
upperBound
byte[] upperBound
-
-
-
Class org.apache.iceberg.HistoryTable
class HistoryTable extends BaseMetadataTable implements Serializable -
Class org.apache.iceberg.ManifestEntriesTable
class ManifestEntriesTable extends org.apache.iceberg.BaseEntriesTable implements Serializable -
Exception org.apache.iceberg.ManifestFilterManager.DeleteException
class DeleteException extends ValidationException implements Serializable-
Serialized Fields
-
partition
String partition
-
-
-
Class org.apache.iceberg.ManifestsTable
class ManifestsTable extends BaseMetadataTable implements Serializable -
Class org.apache.iceberg.MetadataLogEntriesTable
class MetadataLogEntriesTable extends BaseMetadataTable implements Serializable -
Class org.apache.iceberg.MetadataUpdate.AddPartitionSpec
class AddPartitionSpec extends Object implements Serializable-
Serialized Fields
-
spec
UnboundPartitionSpec spec
-
-
-
Class org.apache.iceberg.MetadataUpdate.AddSchema
class AddSchema extends Object implements Serializable-
Serialized Fields
-
lastColumnId
int lastColumnId
-
schema
Schema schema
-
-
-
Class org.apache.iceberg.MetadataUpdate.AddSnapshot
class AddSnapshot extends Object implements Serializable-
Serialized Fields
-
snapshot
Snapshot snapshot
-
-
-
Class org.apache.iceberg.MetadataUpdate.AddSortOrder
class AddSortOrder extends Object implements Serializable-
Serialized Fields
-
sortOrder
UnboundSortOrder sortOrder
-
-
-
Class org.apache.iceberg.MetadataUpdate.AddViewVersion
class AddViewVersion extends Object implements Serializable-
Serialized Fields
-
viewVersion
ViewVersion viewVersion
-
-
-
Class org.apache.iceberg.MetadataUpdate.AssignUUID
class AssignUUID extends Object implements Serializable-
Serialized Fields
-
uuid
String uuid
-
-
-
Class org.apache.iceberg.MetadataUpdate.RemovePartitionStatistics
class RemovePartitionStatistics extends Object implements Serializable-
Serialized Fields
-
snapshotId
long snapshotId
-
-
-
Class org.apache.iceberg.MetadataUpdate.RemoveProperties
class RemoveProperties extends Object implements Serializable -
Class org.apache.iceberg.MetadataUpdate.RemoveSnapshot
class RemoveSnapshot extends Object implements Serializable-
Serialized Fields
-
snapshotId
long snapshotId
-
-
-
Class org.apache.iceberg.MetadataUpdate.RemoveSnapshotRef
class RemoveSnapshotRef extends Object implements Serializable-
Serialized Fields
-
refName
String refName
-
-
-
Class org.apache.iceberg.MetadataUpdate.RemoveStatistics
class RemoveStatistics extends Object implements Serializable-
Serialized Fields
-
snapshotId
long snapshotId
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetCurrentSchema
class SetCurrentSchema extends Object implements Serializable-
Serialized Fields
-
schemaId
int schemaId
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetCurrentViewVersion
class SetCurrentViewVersion extends Object implements Serializable-
Serialized Fields
-
versionId
int versionId
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetDefaultPartitionSpec
class SetDefaultPartitionSpec extends Object implements Serializable-
Serialized Fields
-
specId
int specId
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetDefaultSortOrder
class SetDefaultSortOrder extends Object implements Serializable-
Serialized Fields
-
sortOrderId
int sortOrderId
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetLocation
class SetLocation extends Object implements Serializable-
Serialized Fields
-
location
String location
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetPartitionStatistics
class SetPartitionStatistics extends Object implements Serializable-
Serialized Fields
-
partitionStatisticsFile
PartitionStatisticsFile partitionStatisticsFile
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetProperties
class SetProperties extends Object implements Serializable -
Class org.apache.iceberg.MetadataUpdate.SetSnapshotRef
class SetSnapshotRef extends Object implements Serializable -
Class org.apache.iceberg.MetadataUpdate.SetStatistics
class SetStatistics extends Object implements Serializable-
Serialized Fields
-
snapshotId
long snapshotId
-
statisticsFile
StatisticsFile statisticsFile
-
-
-
Class org.apache.iceberg.MetadataUpdate.UpgradeFormatVersion
class UpgradeFormatVersion extends Object implements Serializable-
Serialized Fields
-
formatVersion
int formatVersion
-
-
-
Class org.apache.iceberg.Metrics
class Metrics extends Object implements Serializable-
Serialization Methods
-
readObject
Implemented the method to enable deserialization of ByteBuffers.- Parameters:
in
- The stream to read from- Throws:
IOException
- On serialization errorClassNotFoundException
- If the class is not found
-
writeObject
Implemented the method to enable serialization of ByteBuffers.- Parameters:
out
- The stream where to write- Throws:
IOException
- On serialization error
-
-
Serialized Fields
-
columnSizes
Map<Integer,
Long> columnSizes -
lowerBounds
Map<Integer,
ByteBuffer> lowerBounds -
nanValueCounts
Map<Integer,
Long> nanValueCounts -
nullValueCounts
Map<Integer,
Long> nullValueCounts -
rowCount
Long rowCount
-
upperBounds
Map<Integer,
ByteBuffer> upperBounds -
valueCounts
Map<Integer,
Long> valueCounts
-
-
-
Class org.apache.iceberg.MetricsConfig
class MetricsConfig extends Object implements Serializable-
Serialized Fields
-
columnModes
Map<String,
MetricsModes.MetricsMode> columnModes -
defaultMode
MetricsModes.MetricsMode defaultMode
-
-
-
Class org.apache.iceberg.MetricsModes.Counts
class Counts extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable -
Class org.apache.iceberg.MetricsModes.Full
class Full extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable -
Class org.apache.iceberg.MetricsModes.None
class None extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable -
Class org.apache.iceberg.MetricsModes.Truncate
class Truncate extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable-
Serialized Fields
-
length
int length
-
-
-
Class org.apache.iceberg.PartitionData
class PartitionData extends Object implements Serializable-
Serialized Fields
-
data
Object[] data
-
partitionType
Types.StructType partitionType
-
size
int size
-
stringSchema
String stringSchema
-
-
-
Class org.apache.iceberg.PartitionField
class PartitionField extends Object implements Serializable -
Class org.apache.iceberg.PartitionKey
class PartitionKey extends org.apache.iceberg.StructTransform implements Serializable-
Serialized Fields
-
inputSchema
Schema inputSchema
-
spec
PartitionSpec spec
-
-
-
Class org.apache.iceberg.PartitionSpec
class PartitionSpec extends Object implements Serializable-
Serialized Fields
-
fields
PartitionField[] fields
-
lastAssignedFieldId
int lastAssignedFieldId
-
schema
Schema schema
-
specId
int specId
-
-
-
Class org.apache.iceberg.PartitionsTable
class PartitionsTable extends BaseMetadataTable implements Serializable-
Serialized Fields
-
schema
Schema schema
-
unpartitionedTable
boolean unpartitionedTable
-
-
-
Class org.apache.iceberg.PositionDeletesTable
class PositionDeletesTable extends BaseMetadataTable implements Serializable-
Serialized Fields
-
defaultSpecId
int defaultSpecId
-
schema
Schema schema
-
specs
Map<Integer,
PartitionSpec> specs
-
-
-
Class org.apache.iceberg.RefsTable
class RefsTable extends BaseMetadataTable implements Serializable -
Class org.apache.iceberg.Schema
class Schema extends Object implements Serializable-
Serialized Fields
-
highestFieldId
int highestFieldId
-
identifierFieldIds
int[] identifierFieldIds
-
schemaId
int schemaId
-
struct
Types.StructType struct
-
-
-
Class org.apache.iceberg.SerializableTable
class SerializableTable extends Object implements Serializable-
Serialized Fields
-
defaultSpecId
int defaultSpecId
-
encryption
EncryptionManager encryption
-
io
FileIO io
-
location
String location
-
metadataFileLocation
String metadataFileLocation
-
name
String name
-
properties
Map<String,
String> properties -
refs
Map<String,
SnapshotRef> refs -
schemaAsJson
String schemaAsJson
-
sortOrderAsJson
String sortOrderAsJson
-
specAsJsonMap
Map<Integer,
String> specAsJsonMap -
uuid
UUID uuid
-
-
-
Class org.apache.iceberg.SerializableTable.SerializableMetadataTable
class SerializableMetadataTable extends SerializableTable implements Serializable-
Serialized Fields
-
baseTableName
String baseTableName
-
type
MetadataTableType type
-
-
-
Class org.apache.iceberg.SnapshotRef
class SnapshotRef extends Object implements Serializable -
Class org.apache.iceberg.SnapshotsTable
class SnapshotsTable extends BaseMetadataTable implements Serializable -
Class org.apache.iceberg.SortField
class SortField extends Object implements Serializable-
Serialized Fields
-
direction
SortDirection direction
-
nullOrder
NullOrder nullOrder
-
sourceId
int sourceId
-
transform
Transform<?,
?> transform
-
-
-
Class org.apache.iceberg.SortKey
class SortKey extends org.apache.iceberg.StructTransform implements Serializable -
Class org.apache.iceberg.SortOrder
class SortOrder extends Object implements Serializable -
Class org.apache.iceberg.TableMetadata
class TableMetadata extends Object implements Serializable-
Serialized Fields
-
changes
List<MetadataUpdate> changes
-
currentSchemaId
int currentSchemaId
-
currentSnapshotId
long currentSnapshotId
-
defaultSortOrderId
int defaultSortOrderId
-
defaultSpecId
int defaultSpecId
-
formatVersion
int formatVersion
-
lastAssignedPartitionId
int lastAssignedPartitionId
-
lastColumnId
int lastColumnId
-
lastSequenceNumber
long lastSequenceNumber
-
lastUpdatedMillis
long lastUpdatedMillis
-
location
String location
-
metadataFileLocation
String metadataFileLocation
-
partitionStatisticsFiles
List<PartitionStatisticsFile> partitionStatisticsFiles
-
previousFiles
List<TableMetadata.MetadataLogEntry> previousFiles
-
properties
Map<String,
String> properties -
refs
Map<String,
SnapshotRef> refs -
schemas
List<Schema> schemas
-
schemasById
Map<Integer,
Schema> schemasById -
snapshotLog
List<HistoryEntry> snapshotLog
-
snapshots
List<Snapshot> snapshots
-
snapshotsById
Map<Long,
Snapshot> snapshotsById -
snapshotsLoaded
boolean snapshotsLoaded
-
snapshotsSupplier
SerializableSupplier<List<Snapshot>> snapshotsSupplier
-
sortOrders
List<SortOrder> sortOrders
-
sortOrdersById
Map<Integer,
SortOrder> sortOrdersById -
specs
List<PartitionSpec> specs
-
specsById
Map<Integer,
PartitionSpec> specsById -
statisticsFiles
List<StatisticsFile> statisticsFiles
-
uuid
String uuid
-
-
-
Class org.apache.iceberg.TableMetadata.SnapshotLogEntry
class SnapshotLogEntry extends Object implements Serializable-
Serialized Fields
-
snapshotId
long snapshotId
-
timestampMillis
long timestampMillis
-
-
-
-
Package org.apache.iceberg.aliyun
-
Class org.apache.iceberg.aliyun.AliyunProperties
class AliyunProperties extends Object implements Serializable
-
-
Package org.apache.iceberg.aliyun.oss
-
Class org.apache.iceberg.aliyun.oss.OSSFileIO
class OSSFileIO extends Object implements Serializable-
Serialized Fields
-
aliyunProperties
AliyunProperties aliyunProperties
-
isResourceClosed
AtomicBoolean isResourceClosed
-
metrics
MetricsContext metrics
-
oss
SerializableSupplier<com.aliyun.oss.OSS> oss
-
-
-
-
Package org.apache.iceberg.aws
-
Class org.apache.iceberg.aws.AssumeRoleAwsClientFactory
class AssumeRoleAwsClientFactory extends Object implements Serializable-
Serialized Fields
-
awsProperties
AwsProperties awsProperties
-
httpClientProperties
HttpClientProperties httpClientProperties
-
roleSessionName
String roleSessionName
-
s3FileIOProperties
S3FileIOProperties s3FileIOProperties
-
-
-
Class org.apache.iceberg.aws.AwsClientProperties
class AwsClientProperties extends Object implements Serializable -
Class org.apache.iceberg.aws.AwsProperties
class AwsProperties extends Object implements Serializable-
Serialized Fields
-
clientAssumeRoleArn
String clientAssumeRoleArn
-
clientAssumeRoleExternalId
String clientAssumeRoleExternalId
-
clientAssumeRoleRegion
String clientAssumeRoleRegion
-
clientAssumeRoleSessionName
String clientAssumeRoleSessionName
-
clientAssumeRoleTimeoutSec
int clientAssumeRoleTimeoutSec
-
clientCredentialsProvider
String clientCredentialsProvider
-
clientCredentialsProviderProperties
Map<String,
String> clientCredentialsProviderProperties -
dynamoDbEndpoint
String dynamoDbEndpoint
-
dynamoDbTableName
String dynamoDbTableName
-
glueCatalogId
String glueCatalogId
-
glueCatalogSkipArchive
boolean glueCatalogSkipArchive
-
glueCatalogSkipNameValidation
boolean glueCatalogSkipNameValidation
-
glueEndpoint
String glueEndpoint
-
glueLakeFormationEnabled
boolean glueLakeFormationEnabled
-
restAccessKeyId
String restAccessKeyId
-
restSecretAccessKey
String restSecretAccessKey
-
restSessionToken
String restSessionToken
-
restSigningName
String restSigningName
-
restSigningRegion
String restSigningRegion
-
stsClientAssumeRoleTags
Set<software.amazon.awssdk.services.sts.model.Tag> stsClientAssumeRoleTags
-
-
-
Class org.apache.iceberg.aws.HttpClientProperties
class HttpClientProperties extends Object implements Serializable
-
-
Package org.apache.iceberg.aws.lakeformation
-
Class org.apache.iceberg.aws.lakeformation.LakeFormationAwsClientFactory
class LakeFormationAwsClientFactory extends AssumeRoleAwsClientFactory implements Serializable
-
-
Package org.apache.iceberg.aws.s3
-
Class org.apache.iceberg.aws.s3.S3FileIO
class S3FileIO extends Object implements Serializable-
Serialized Fields
-
credential
String credential
-
isResourceClosed
AtomicBoolean isResourceClosed
-
metrics
MetricsContext metrics
-
properties
SerializableMap<String,
String> properties -
s3
SerializableSupplier<software.amazon.awssdk.services.s3.S3Client> s3
-
s3FileIOProperties
S3FileIOProperties s3FileIOProperties
-
-
-
Class org.apache.iceberg.aws.s3.S3FileIOProperties
class S3FileIOProperties extends Object implements Serializable-
Serialized Fields
-
accessKeyId
String accessKeyId
-
acl
software.amazon.awssdk.services.s3.model.ObjectCannedACL acl
-
allProperties
Map<String,
String> allProperties -
bucketToAccessPointMapping
Map<String,
String> bucketToAccessPointMapping -
deleteBatchSize
int deleteBatchSize
-
deleteTags
Set<software.amazon.awssdk.services.s3.model.Tag> deleteTags
-
deleteThreads
int deleteThreads
-
endpoint
String endpoint
-
isAccelerationEnabled
boolean isAccelerationEnabled
-
isChecksumEnabled
boolean isChecksumEnabled
-
isDeleteEnabled
boolean isDeleteEnabled
-
isDualStackEnabled
boolean isDualStackEnabled
-
isPathStyleAccess
boolean isPathStyleAccess
-
isPreloadClientEnabled
boolean isPreloadClientEnabled
-
isRemoteSigningEnabled
boolean isRemoteSigningEnabled
-
isS3AccessGrantsEnabled
boolean isS3AccessGrantsEnabled
-
isS3AccessGrantsFallbackToIamEnabled
boolean isS3AccessGrantsFallbackToIamEnabled
-
isUseArnRegionEnabled
boolean isUseArnRegionEnabled
-
isWriteNamespaceTagEnabled
boolean isWriteNamespaceTagEnabled
-
isWriteTableTagEnabled
boolean isWriteTableTagEnabled
-
multiPartSize
int multiPartSize
-
multipartThresholdFactor
double multipartThresholdFactor
-
multipartUploadThreads
int multipartUploadThreads
-
secretAccessKey
String secretAccessKey
-
sessionToken
String sessionToken
-
sseKey
String sseKey
-
sseMd5
String sseMd5
-
sseType
String sseType
-
stagingDirectory
String stagingDirectory
-
writeStorageClass
String writeStorageClass
-
writeTags
Set<software.amazon.awssdk.services.s3.model.Tag> writeTags
-
-
-
-
Package org.apache.iceberg.azure
-
Class org.apache.iceberg.azure.AzureProperties
class AzureProperties extends Object implements Serializable
-
-
Package org.apache.iceberg.azure.adlsv2
-
Class org.apache.iceberg.azure.adlsv2.ADLSFileIO
class ADLSFileIO extends Object implements Serializable-
Serialized Fields
-
azureProperties
AzureProperties azureProperties
-
metrics
MetricsContext metrics
-
properties
SerializableMap<String,
String> properties
-
-
-
-
Package org.apache.iceberg.connect.channel
-
Exception org.apache.iceberg.connect.channel.NotRunningException
class NotRunningException extends RuntimeException implements Serializable
-
-
Package org.apache.iceberg.dell
-
Class org.apache.iceberg.dell.DellProperties
class DellProperties extends Object implements Serializable
-
-
Package org.apache.iceberg.dell.ecs
-
Class org.apache.iceberg.dell.ecs.EcsFileIO
class EcsFileIO extends Object implements Serializable-
Serialized Fields
-
dellClientFactory
DellClientFactory dellClientFactory
-
dellProperties
DellProperties dellProperties
-
isResourceClosed
AtomicBoolean isResourceClosed
-
metrics
MetricsContext metrics
-
s3
SerializableSupplier<com.emc.object.s3.S3Client> s3
-
-
-
-
Package org.apache.iceberg.encryption
-
Class org.apache.iceberg.encryption.EncryptingFileIO
class EncryptingFileIO extends Object implements Serializable-
Serialized Fields
-
em
EncryptionManager em
-
io
FileIO io
-
-
-
Class org.apache.iceberg.encryption.PlaintextEncryptionManager
class PlaintextEncryptionManager extends Object implements Serializable -
Class org.apache.iceberg.encryption.StandardEncryptionManager
class StandardEncryptionManager extends Object implements Serializable-
Serialized Fields
-
dataKeyLength
int dataKeyLength
-
tableKeyId
String tableKeyId
-
-
-
-
Package org.apache.iceberg.exceptions
-
Exception org.apache.iceberg.exceptions.AlreadyExistsException
class AlreadyExistsException extends RuntimeException implements Serializable -
Exception org.apache.iceberg.exceptions.BadRequestException
class BadRequestException extends RESTException implements Serializable -
Exception org.apache.iceberg.exceptions.CherrypickAncestorCommitException
class CherrypickAncestorCommitException extends ValidationException implements Serializable -
Exception org.apache.iceberg.exceptions.CommitFailedException
class CommitFailedException extends RuntimeException implements Serializable -
Exception org.apache.iceberg.exceptions.CommitStateUnknownException
class CommitStateUnknownException extends RuntimeException implements Serializable -
Exception org.apache.iceberg.exceptions.DuplicateWAPCommitException
class DuplicateWAPCommitException extends ValidationException implements Serializable -
Exception org.apache.iceberg.exceptions.ForbiddenException
class ForbiddenException extends RESTException implements Serializable -
Exception org.apache.iceberg.exceptions.NamespaceNotEmptyException
class NamespaceNotEmptyException extends RuntimeException implements Serializable -
Exception org.apache.iceberg.exceptions.NoSuchIcebergTableException
class NoSuchIcebergTableException extends NoSuchTableException implements Serializable -
Exception org.apache.iceberg.exceptions.NoSuchNamespaceException
class NoSuchNamespaceException extends RuntimeException implements Serializable -
Exception org.apache.iceberg.exceptions.NoSuchTableException
class NoSuchTableException extends RuntimeException implements Serializable -
Exception org.apache.iceberg.exceptions.NoSuchViewException
class NoSuchViewException extends RuntimeException implements Serializable -
Exception org.apache.iceberg.exceptions.NotAuthorizedException
class NotAuthorizedException extends RESTException implements Serializable -
Exception org.apache.iceberg.exceptions.NotFoundException
class NotFoundException extends RuntimeException implements Serializable -
Exception org.apache.iceberg.exceptions.RESTException
class RESTException extends RuntimeException implements Serializable -
Exception org.apache.iceberg.exceptions.RuntimeIOException
class RuntimeIOException extends UncheckedIOException implements Serializable -
Exception org.apache.iceberg.exceptions.ServiceFailureException
class ServiceFailureException extends RESTException implements Serializable -
Exception org.apache.iceberg.exceptions.UnprocessableEntityException
class UnprocessableEntityException extends RESTException implements Serializable -
Exception org.apache.iceberg.exceptions.ValidationException
class ValidationException extends RuntimeException implements Serializable
-
-
Package org.apache.iceberg.expressions
-
Class org.apache.iceberg.expressions.Aggregate
class Aggregate extends Object implements Serializable-
Serialized Fields
-
op
Expression.Operation op
-
term
C extends Term term
-
-
-
Class org.apache.iceberg.expressions.And
class And extends Object implements Serializable-
Serialized Fields
-
left
Expression left
-
right
Expression right
-
-
-
Class org.apache.iceberg.expressions.BoundAggregate
-
Class org.apache.iceberg.expressions.BoundLiteralPredicate
-
Class org.apache.iceberg.expressions.BoundPredicate
-
Class org.apache.iceberg.expressions.BoundReference
class BoundReference extends Object implements Serializable-
Serialized Fields
-
accessor
Accessor<StructLike> accessor
-
field
Types.NestedField field
-
name
String name
-
-
-
Class org.apache.iceberg.expressions.BoundSetPredicate
-
Class org.apache.iceberg.expressions.BoundTransform
class BoundTransform extends Object implements Serializable-
Serialized Fields
-
func
SerializableFunction<S,
T> func -
ref
BoundReference<S> ref
-
transform
Transform<S,
T> transform
-
-
-
Class org.apache.iceberg.expressions.BoundUnaryPredicate
-
Class org.apache.iceberg.expressions.CountAggregate
-
Class org.apache.iceberg.expressions.CountNonNull
-
Serialized Fields
-
field
Types.NestedField field
-
fieldId
int fieldId
-
-
-
Class org.apache.iceberg.expressions.CountStar
-
Class org.apache.iceberg.expressions.Evaluator
class Evaluator extends Object implements Serializable-
Serialized Fields
-
expr
Expression expr
-
-
-
Class org.apache.iceberg.expressions.False
class False extends Object implements Serializable-
Serialization Methods
-
writeReplace
- Throws:
ObjectStreamException
-
-
-
Class org.apache.iceberg.expressions.MaxAggregate
class MaxAggregate extends org.apache.iceberg.expressions.ValueAggregate<T> implements Serializable-
Serialized Fields
-
comparator
Comparator<T> comparator
-
fieldId
int fieldId
-
type
Type.PrimitiveType type
-
-
-
Class org.apache.iceberg.expressions.MinAggregate
class MinAggregate extends org.apache.iceberg.expressions.ValueAggregate<T> implements Serializable-
Serialized Fields
-
comparator
Comparator<T> comparator
-
fieldId
int fieldId
-
type
Type.PrimitiveType type
-
-
-
Class org.apache.iceberg.expressions.NamedReference
class NamedReference extends Object implements Serializable-
Serialized Fields
-
name
String name
-
-
-
Class org.apache.iceberg.expressions.Not
class Not extends Object implements Serializable-
Serialized Fields
-
child
Expression child
-
-
-
Class org.apache.iceberg.expressions.Or
class Or extends Object implements Serializable-
Serialized Fields
-
left
Expression left
-
right
Expression right
-
-
-
Class org.apache.iceberg.expressions.Predicate
class Predicate extends Object implements Serializable-
Serialized Fields
-
op
Expression.Operation op
-
term
C extends Term term
-
-
-
Class org.apache.iceberg.expressions.ResidualEvaluator
class ResidualEvaluator extends Object implements Serializable-
Serialized Fields
-
caseSensitive
boolean caseSensitive
-
expr
Expression expr
-
spec
PartitionSpec spec
-
-
-
Class org.apache.iceberg.expressions.True
class True extends Object implements Serializable-
Serialization Methods
-
writeReplace
- Throws:
ObjectStreamException
-
-
-
Class org.apache.iceberg.expressions.UnboundAggregate
-
Class org.apache.iceberg.expressions.UnboundPredicate
-
Class org.apache.iceberg.expressions.UnboundTransform
class UnboundTransform extends Object implements Serializable-
Serialized Fields
-
ref
NamedReference<S> ref
-
transform
Transform<S,
T> transform
-
-
-
Class org.apache.iceberg.expressions.Zorder
class Zorder extends Object implements Serializable-
Serialized Fields
-
refs
NamedReference<?>[] refs
-
-
-
-
Package org.apache.iceberg.flink
-
Class org.apache.iceberg.flink.CatalogLoader.CustomCatalogLoader
class CustomCatalogLoader extends Object implements Serializable -
Class org.apache.iceberg.flink.CatalogLoader.HadoopCatalogLoader
class HadoopCatalogLoader extends Object implements Serializable -
Class org.apache.iceberg.flink.CatalogLoader.HiveCatalogLoader
class HiveCatalogLoader extends Object implements Serializable -
Class org.apache.iceberg.flink.CatalogLoader.RESTCatalogLoader
class RESTCatalogLoader extends Object implements Serializable-
Serialized Fields
-
catalogName
String catalogName
-
hadoopConf
SerializableConfiguration hadoopConf
-
properties
Map<String,
String> properties
-
-
-
Class org.apache.iceberg.flink.FlinkSourceFilter
class FlinkSourceFilter extends Object implements Serializable-
Serialized Fields
-
evaluator
Evaluator evaluator
-
rowType
org.apache.flink.table.types.logical.RowType rowType
-
struct
Types.StructType struct
-
wrapper
RowDataWrapper wrapper
-
-
-
Class org.apache.iceberg.flink.TableLoader.CatalogTableLoader
class CatalogTableLoader extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
catalogLoader
CatalogLoader catalogLoader
-
identifier
String identifier
-
-
Class org.apache.iceberg.flink.TableLoader.HadoopTableLoader
class HadoopTableLoader extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
hadoopConf
SerializableConfiguration hadoopConf
-
location
String location
-
-
-
Package org.apache.iceberg.flink.maintenance.operator
-
Class org.apache.iceberg.flink.maintenance.operator.MonitorSource
class MonitorSource extends SingleThreadedIteratorSource<org.apache.iceberg.flink.maintenance.operator.TableChange> implements Serializable-
Serialized Fields
-
maxReadBack
long maxReadBack
-
rateLimiterStrategy
org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy rateLimiterStrategy
-
tableLoader
TableLoader tableLoader
-
-
-
Class org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource
class SingleThreadedIteratorSource extends Object implements Serializable
-
-
Package org.apache.iceberg.flink.sink
-
Class org.apache.iceberg.flink.sink.AvroGenericRecordToRowDataMapper
class AvroGenericRecordToRowDataMapper extends Object implements Serializable-
Serialized Fields
-
converter
org.apache.flink.formats.avro.AvroToRowDataConverters.AvroToRowDataConverter converter
-
-
-
Class org.apache.iceberg.flink.sink.FlinkAppenderFactory
class FlinkAppenderFactory extends Object implements Serializable-
Serialized Fields
-
eqDeleteFlinkSchema
org.apache.flink.table.types.logical.RowType eqDeleteFlinkSchema
-
eqDeleteRowSchema
Schema eqDeleteRowSchema
-
equalityFieldIds
int[] equalityFieldIds
-
flinkSchema
org.apache.flink.table.types.logical.RowType flinkSchema
-
posDeleteFlinkSchema
org.apache.flink.table.types.logical.RowType posDeleteFlinkSchema
-
posDeleteRowSchema
Schema posDeleteRowSchema
-
props
Map<String,
String> props -
schema
Schema schema
-
spec
PartitionSpec spec
-
table
Table table
-
-
-
Class org.apache.iceberg.flink.sink.RowDataTaskWriterFactory
class RowDataTaskWriterFactory extends Object implements Serializable-
Serialized Fields
-
appenderFactory
FileAppenderFactory<org.apache.flink.table.data.RowData> appenderFactory
-
equalityFieldIds
List<Integer> equalityFieldIds
-
flinkSchema
org.apache.flink.table.types.logical.RowType flinkSchema
-
format
FileFormat format
-
schema
Schema schema
-
spec
PartitionSpec spec
-
tableSupplier
Supplier<Table> tableSupplier
-
targetFileSizeBytes
long targetFileSizeBytes
-
upsert
boolean upsert
-
-
-
-
Package org.apache.iceberg.flink.sink.shuffle
-
Class org.apache.iceberg.flink.sink.shuffle.AggregatedStatisticsSerializer
class AggregatedStatisticsSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.iceberg.flink.sink.shuffle.AggregatedStatistics> implements Serializable-
Serialized Fields
-
keyFrequencySerializer
org.apache.flink.api.common.typeutils.base.MapSerializer<SortKey,
Long> keyFrequencySerializer -
rangeBoundsSerializer
org.apache.flink.api.common.typeutils.base.ListSerializer<SortKey> rangeBoundsSerializer
-
sortKeySerializer
org.apache.flink.api.common.typeutils.TypeSerializer<SortKey> sortKeySerializer
-
statisticsTypeSerializer
org.apache.flink.api.common.typeutils.base.EnumSerializer<StatisticsType> statisticsTypeSerializer
-
-
-
Class org.apache.iceberg.flink.sink.shuffle.DataStatisticsCoordinatorProvider
class DataStatisticsCoordinatorProvider extends org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.Provider implements Serializable-
Serialized Fields
-
downstreamParallelism
int downstreamParallelism
-
operatorName
String operatorName
-
schema
Schema schema
-
sortOrder
SortOrder sortOrder
-
type
StatisticsType type
-
-
-
Class org.apache.iceberg.flink.sink.shuffle.DataStatisticsOperator
class DataStatisticsOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<StatisticsOrRecord> implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
aggregatedStatisticsSerializer
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.iceberg.flink.sink.shuffle.AggregatedStatistics> aggregatedStatisticsSerializer
-
downstreamParallelism
int downstreamParallelism
-
operatorEventGateway
org.apache.flink.runtime.operators.coordination.OperatorEventGateway operatorEventGateway
-
operatorName
String operatorName
-
rowDataWrapper
RowDataWrapper rowDataWrapper
-
sortKey
SortKey sortKey
-
statisticsType
StatisticsType statisticsType
-
taskStatisticsSerializer
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.iceberg.flink.sink.shuffle.DataStatistics> taskStatisticsSerializer
-
-
Class org.apache.iceberg.flink.sink.shuffle.StatisticsOrRecord
class StatisticsOrRecord extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
record
org.apache.flink.table.data.RowData record
-
statistics
org.apache.iceberg.flink.sink.shuffle.AggregatedStatistics statistics
-
-
-
Package org.apache.iceberg.flink.source
-
Class org.apache.iceberg.flink.source.AvroGenericRecordFileScanTaskReader
class AvroGenericRecordFileScanTaskReader extends Object implements Serializable-
Serialized Fields
-
converter
RowDataToAvroGenericRecordConverter converter
-
rowDataReader
RowDataFileScanTaskReader rowDataReader
-
-
-
Class org.apache.iceberg.flink.source.DataTaskReader
class DataTaskReader extends Object implements Serializable-
Serialized Fields
-
readSchema
Schema readSchema
-
-
-
Class org.apache.iceberg.flink.source.FlinkInputFormat
class FlinkInputFormat extends org.apache.flink.api.common.io.RichInputFormat<org.apache.flink.table.data.RowData,FlinkInputSplit> implements Serializable - serialVersionUID:
- 1L
-
Serialized Fields
-
context
ScanContext context
-
encryption
EncryptionManager encryption
-
io
FileIO io
-
rowDataReader
FileScanTaskReader rowDataReader
-
tableLoader
TableLoader tableLoader
-
-
Class org.apache.iceberg.flink.source.FlinkInputSplit
class FlinkInputSplit extends org.apache.flink.core.io.LocatableInputSplit implements Serializable-
Serialized Fields
-
task
CombinedScanTask task
-
-
-
Class org.apache.iceberg.flink.source.IcebergSource
class IcebergSource extends Object implements Serializable-
Serialized Fields
-
assignerFactory
SplitAssignerFactory assignerFactory
-
emitter
SerializableRecordEmitter<T> emitter
-
readerFunction
ReaderFunction<T> readerFunction
-
scanContext
ScanContext scanContext
-
splitComparator
SerializableComparator<IcebergSourceSplit> splitComparator
-
tableLoader
TableLoader tableLoader
-
tableName
String tableName
-
-
-
Class org.apache.iceberg.flink.source.RowDataFileScanTaskReader
class RowDataFileScanTaskReader extends Object implements Serializable-
Serialized Fields
-
caseSensitive
boolean caseSensitive
-
nameMapping
String nameMapping
-
projectedSchema
Schema projectedSchema
-
rowFilter
FlinkSourceFilter rowFilter
-
tableSchema
Schema tableSchema
-
-
-
Class org.apache.iceberg.flink.source.RowDataRewriter.RewriteMap
class RewriteMap extends org.apache.flink.api.common.functions.RichMapFunction<CombinedScanTask,List<DataFile>> implements Serializable -
Serialized Fields
-
attemptId
int attemptId
-
caseSensitive
boolean caseSensitive
-
encryptionManager
EncryptionManager encryptionManager
-
io
FileIO io
-
nameMapping
String nameMapping
-
rowDataReader
RowDataFileScanTaskReader rowDataReader
-
schema
Schema schema
-
subTaskId
int subTaskId
-
taskWriterFactory
TaskWriterFactory<org.apache.flink.table.data.RowData> taskWriterFactory
-
writer
TaskWriter<org.apache.flink.table.data.RowData> writer
-
-
-
Class org.apache.iceberg.flink.source.ScanContext
class ScanContext extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
asOfTimestamp
Long asOfTimestamp
-
branch
String branch
-
caseSensitive
boolean caseSensitive
-
endSnapshotId
Long endSnapshotId
-
endTag
String endTag
-
exposeLocality
boolean exposeLocality
-
filters
List<Expression> filters
-
includeColumnStats
boolean includeColumnStats
-
includeStatsForColumns
Collection<String> includeStatsForColumns
-
isStreaming
boolean isStreaming
-
limit
long limit
-
maxAllowedPlanningFailures
int maxAllowedPlanningFailures
-
maxPlanningSnapshotCount
int maxPlanningSnapshotCount
-
monitorInterval
Duration monitorInterval
-
nameMapping
String nameMapping
-
planParallelism
Integer planParallelism
-
schema
Schema schema
-
snapshotId
Long snapshotId
-
splitLookback
Integer splitLookback
-
splitOpenFileCost
Long splitOpenFileCost
-
splitSize
Long splitSize
-
startingStrategy
StreamingStartingStrategy startingStrategy
-
startSnapshotId
Long startSnapshotId
-
startSnapshotTimestamp
Long startSnapshotTimestamp
-
startTag
String startTag
-
tag
String tag
-
watermarkColumn
String watermarkColumn
-
watermarkColumnTimeUnit
TimeUnit watermarkColumnTimeUnit
-
-
Class org.apache.iceberg.flink.source.StreamingMonitorFunction
class StreamingMonitorFunction extends org.apache.flink.streaming.api.functions.source.RichSourceFunction<FlinkInputSplit> implements Serializable-
Serialized Fields
-
isRunning
boolean isRunning
-
lastSnapshotId
long lastSnapshotId
-
scanContext
ScanContext scanContext
-
tableLoader
TableLoader tableLoader
-
-
-
Class org.apache.iceberg.flink.source.StreamingReaderOperator
class StreamingReaderOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.table.data.RowData> implements Serializable-
Serialized Fields
-
executor
org.apache.flink.api.common.operators.MailboxExecutor executor
-
format
FlinkInputFormat format
-
-
-
-
Package org.apache.iceberg.flink.source.assigner
-
Class org.apache.iceberg.flink.source.assigner.OrderedSplitAssignerFactory
class OrderedSplitAssignerFactory extends Object implements Serializable-
Serialized Fields
-
comparator
SerializableComparator<IcebergSourceSplit> comparator
-
-
-
Class org.apache.iceberg.flink.source.assigner.SimpleSplitAssignerFactory
class SimpleSplitAssignerFactory extends Object implements Serializable
-
-
Package org.apache.iceberg.flink.source.enumerator
-
Class org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorState
class IcebergEnumeratorState extends Object implements Serializable-
Serialized Fields
-
enumerationSplitCountHistory
int[] enumerationSplitCountHistory
-
lastEnumeratedPosition
org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastEnumeratedPosition
-
pendingSplits
Collection<IcebergSourceSplitState> pendingSplits
-
-
-
-
Package org.apache.iceberg.flink.source.reader
-
Class org.apache.iceberg.flink.source.reader.AvroGenericRecordReaderFunction
class AvroGenericRecordReaderFunction extends DataIteratorReaderFunction<org.apache.avro.generic.GenericRecord> implements Serializable-
Serialized Fields
-
encryption
EncryptionManager encryption
-
io
FileIO io
-
readSchema
Schema readSchema
-
rowDataReader
RowDataFileScanTaskReader rowDataReader
-
tableName
String tableName
-
-
-
Class org.apache.iceberg.flink.source.reader.ColumnStatsWatermarkExtractor
class ColumnStatsWatermarkExtractor extends Object implements Serializable -
Class org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction
class DataIteratorReaderFunction extends Object implements Serializable-
Serialized Fields
-
batcher
DataIteratorBatcher<T> batcher
-
-
-
Class org.apache.iceberg.flink.source.reader.MetaDataReaderFunction
class MetaDataReaderFunction extends DataIteratorReaderFunction<org.apache.flink.table.data.RowData> implements Serializable-
Serialized Fields
-
encryption
EncryptionManager encryption
-
io
FileIO io
-
readSchema
Schema readSchema
-
-
-
Class org.apache.iceberg.flink.source.reader.RowDataReaderFunction
class RowDataReaderFunction extends DataIteratorReaderFunction<org.apache.flink.table.data.RowData> implements Serializable-
Serialized Fields
-
caseSensitive
boolean caseSensitive
-
encryption
EncryptionManager encryption
-
filters
List<Expression> filters
-
io
FileIO io
-
nameMapping
String nameMapping
-
readSchema
Schema readSchema
-
tableSchema
Schema tableSchema
-
-
-
-
Package org.apache.iceberg.flink.source.split
-
Class org.apache.iceberg.flink.source.split.IcebergSourceSplit
class IcebergSourceSplit extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
fileOffset
int fileOffset
-
recordOffset
long recordOffset
-
task
CombinedScanTask task
-
-
Class org.apache.iceberg.flink.source.split.SplitRequestEvent
class SplitRequestEvent extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
finishedSplitIds
Collection<String> finishedSplitIds
-
requesterHostname
String requesterHostname
-
-
-
Package org.apache.iceberg.gcp
-
Class org.apache.iceberg.gcp.GCPProperties
class GCPProperties extends Object implements Serializable-
Serialized Fields
-
clientLibToken
String clientLibToken
-
gcsChannelReadChunkSize
Integer gcsChannelReadChunkSize
-
gcsChannelWriteChunkSize
Integer gcsChannelWriteChunkSize
-
gcsDecryptionKey
String gcsDecryptionKey
-
gcsDeleteBatchSize
int gcsDeleteBatchSize
-
gcsEncryptionKey
String gcsEncryptionKey
-
gcsNoAuth
boolean gcsNoAuth
-
gcsOAuth2Token
String gcsOAuth2Token
-
gcsOAuth2TokenExpiresAt
Date gcsOAuth2TokenExpiresAt
-
gcsUserProject
String gcsUserProject
-
projectId
String projectId
-
serviceHost
String serviceHost
-
-
-
-
Package org.apache.iceberg.gcp.gcs
-
Class org.apache.iceberg.gcp.gcs.GCSFileIO
class GCSFileIO extends Object implements Serializable-
Serialized Fields
-
gcpProperties
GCPProperties gcpProperties
-
isResourceClosed
AtomicBoolean isResourceClosed
-
metrics
MetricsContext metrics
-
properties
SerializableMap<String,
String> properties -
storageSupplier
SerializableSupplier<com.google.cloud.storage.Storage> storageSupplier
-
-
-
-
Package org.apache.iceberg.hadoop
-
Class org.apache.iceberg.hadoop.HadoopFileIO
class HadoopFileIO extends Object implements Serializable-
Serialized Fields
-
hadoopConf
SerializableSupplier<org.apache.hadoop.conf.Configuration> hadoopConf
-
properties
SerializableMap<String,
String> properties
-
-
-
Class org.apache.iceberg.hadoop.HadoopMetricsContext
class HadoopMetricsContext extends Object implements Serializable-
Serialized Fields
-
scheme
String scheme
-
-
-
Class org.apache.iceberg.hadoop.HiddenPathFilter
class HiddenPathFilter extends Object implements Serializable -
Class org.apache.iceberg.hadoop.SerializableConfiguration
class SerializableConfiguration extends Object implements Serializable-
Serialization Methods
-
readObject
- Throws:
ClassNotFoundException
IOException
-
writeObject
- Throws:
IOException
-
-
-
-
Package org.apache.iceberg.hive
-
Exception org.apache.iceberg.hive.RuntimeMetaException
class RuntimeMetaException extends RuntimeException implements Serializable
-
-
Package org.apache.iceberg.inmemory
-
Class org.apache.iceberg.inmemory.InMemoryFileIO
class InMemoryFileIO extends Object implements Serializable-
Serialized Fields
-
closed
boolean closed
-
-
-
-
Package org.apache.iceberg.io
-
Exception org.apache.iceberg.io.BulkDeletionFailureException
class BulkDeletionFailureException extends RuntimeException implements Serializable-
Serialized Fields
-
numberFailedObjects
int numberFailedObjects
-
-
-
Class org.apache.iceberg.io.ResolvingFileIO
class ResolvingFileIO extends Object implements Serializable-
Serialized Fields
-
hadoopConf
SerializableSupplier<org.apache.hadoop.conf.Configuration> hadoopConf
-
ioInstances
Map<String,
DelegateFileIO> ioInstances -
isClosed
AtomicBoolean isClosed
-
properties
SerializableMap<String,
String> properties
-
-
-
Class org.apache.iceberg.io.WriteResult
class WriteResult extends Object implements Serializable-
Serialized Fields
-
dataFiles
DataFile[] dataFiles
-
deleteFiles
DeleteFile[] deleteFiles
-
referencedDataFiles
CharSequence[] referencedDataFiles
-
-
-
-
Package org.apache.iceberg.jdbc
-
Exception org.apache.iceberg.jdbc.UncheckedInterruptedException
class UncheckedInterruptedException extends RuntimeException implements Serializable -
Exception org.apache.iceberg.jdbc.UncheckedSQLException
class UncheckedSQLException extends RuntimeException implements Serializable
-
-
Package org.apache.iceberg.mapping
-
Class org.apache.iceberg.mapping.MappedField
class MappedField extends Object implements Serializable-
Serialized Fields
-
id
Integer id
-
names
Set<String> names
-
nestedMapping
MappedFields nestedMapping
-
-
-
Class org.apache.iceberg.mapping.MappedFields
class MappedFields extends Object implements Serializable-
Serialized Fields
-
fields
List<MappedField> fields
-
-
-
Class org.apache.iceberg.mapping.NameMapping
class NameMapping extends Object implements Serializable-
Serialized Fields
-
mapping
MappedFields mapping
-
-
-
-
Package org.apache.iceberg.metrics
-
Class org.apache.iceberg.metrics.DefaultMetricsContext
class DefaultMetricsContext extends Object implements Serializable
-
-
Package org.apache.iceberg.spark
-
Class org.apache.iceberg.spark.SparkTableUtil.SparkPartition
class SparkPartition extends Object implements Serializable
-
-
Package org.apache.iceberg.spark.actions
-
Class org.apache.iceberg.spark.actions.ManifestFileBean
class ManifestFileBean extends Object implements Serializable -
Class org.apache.iceberg.spark.actions.SetAccumulator
class SetAccumulator extends org.apache.spark.util.AccumulatorV2<T,Set<T>> implements Serializable
-
-
Package org.apache.iceberg.spark.functions
-
Class org.apache.iceberg.spark.functions.BucketFunction
class BucketFunction extends Object implements Serializable -
Class org.apache.iceberg.spark.functions.BucketFunction.BucketBase
class BucketBase extends org.apache.iceberg.spark.functions.BaseScalarFunction<Integer> implements Serializable -
Class org.apache.iceberg.spark.functions.BucketFunction.BucketBinary
class BucketBinary extends BucketFunction.BucketBase implements Serializable -
Class org.apache.iceberg.spark.functions.BucketFunction.BucketDecimal
class BucketDecimal extends BucketFunction.BucketBase implements Serializable-
Serialized Fields
-
precision
int precision
-
scale
int scale
-
sqlType
org.apache.spark.sql.types.DataType sqlType
-
-
-
Class org.apache.iceberg.spark.functions.BucketFunction.BucketInt
class BucketInt extends BucketFunction.BucketBase implements Serializable-
Serialized Fields
-
sqlType
org.apache.spark.sql.types.DataType sqlType
-
-
-
Class org.apache.iceberg.spark.functions.BucketFunction.BucketLong
class BucketLong extends BucketFunction.BucketBase implements Serializable-
Serialized Fields
-
sqlType
org.apache.spark.sql.types.DataType sqlType
-
-
-
Class org.apache.iceberg.spark.functions.BucketFunction.BucketString
class BucketString extends BucketFunction.BucketBase implements Serializable -
Class org.apache.iceberg.spark.functions.DaysFunction
class DaysFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable -
Class org.apache.iceberg.spark.functions.DaysFunction.DateToDaysFunction
class DateToDaysFunction extends org.apache.iceberg.spark.functions.DaysFunction.BaseToDaysFunction implements Serializable -
Class org.apache.iceberg.spark.functions.DaysFunction.TimestampNtzToDaysFunction
class TimestampNtzToDaysFunction extends org.apache.iceberg.spark.functions.DaysFunction.BaseToDaysFunction implements Serializable -
Class org.apache.iceberg.spark.functions.DaysFunction.TimestampToDaysFunction
class TimestampToDaysFunction extends org.apache.iceberg.spark.functions.DaysFunction.BaseToDaysFunction implements Serializable -
Class org.apache.iceberg.spark.functions.HoursFunction
class HoursFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable -
Class org.apache.iceberg.spark.functions.HoursFunction.TimestampNtzToHoursFunction
class TimestampNtzToHoursFunction extends org.apache.iceberg.spark.functions.BaseScalarFunction<Integer> implements Serializable -
Class org.apache.iceberg.spark.functions.HoursFunction.TimestampToHoursFunction
class TimestampToHoursFunction extends org.apache.iceberg.spark.functions.BaseScalarFunction<Integer> implements Serializable -
Class org.apache.iceberg.spark.functions.IcebergVersionFunction
class IcebergVersionFunction extends Object implements Serializable -
Class org.apache.iceberg.spark.functions.MonthsFunction
class MonthsFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable -
Class org.apache.iceberg.spark.functions.MonthsFunction.DateToMonthsFunction
class DateToMonthsFunction extends org.apache.iceberg.spark.functions.MonthsFunction.BaseToMonthsFunction implements Serializable -
Class org.apache.iceberg.spark.functions.MonthsFunction.TimestampNtzToMonthsFunction
class TimestampNtzToMonthsFunction extends org.apache.iceberg.spark.functions.MonthsFunction.BaseToMonthsFunction implements Serializable -
Class org.apache.iceberg.spark.functions.MonthsFunction.TimestampToMonthsFunction
class TimestampToMonthsFunction extends org.apache.iceberg.spark.functions.MonthsFunction.BaseToMonthsFunction implements Serializable -
Class org.apache.iceberg.spark.functions.TruncateFunction
class TruncateFunction extends Object implements Serializable -
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateBase
class TruncateBase extends org.apache.iceberg.spark.functions.BaseScalarFunction<T> implements Serializable -
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateBigInt
-
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateBinary
class TruncateBinary extends TruncateFunction.TruncateBase<byte[]> implements Serializable -
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateDecimal
class TruncateDecimal extends TruncateFunction.TruncateBase<org.apache.spark.sql.types.Decimal> implements Serializable-
Serialized Fields
-
precision
int precision
-
scale
int scale
-
-
-
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateInt
-
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateSmallInt
-
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateString
class TruncateString extends TruncateFunction.TruncateBase<org.apache.spark.unsafe.types.UTF8String> implements Serializable -
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateTinyInt
-
Class org.apache.iceberg.spark.functions.YearsFunction
class YearsFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable -
Class org.apache.iceberg.spark.functions.YearsFunction.DateToYearsFunction
class DateToYearsFunction extends org.apache.iceberg.spark.functions.YearsFunction.BaseToYearsFunction implements Serializable -
Class org.apache.iceberg.spark.functions.YearsFunction.TimestampNtzToYearsFunction
class TimestampNtzToYearsFunction extends org.apache.iceberg.spark.functions.YearsFunction.BaseToYearsFunction implements Serializable -
Class org.apache.iceberg.spark.functions.YearsFunction.TimestampToYearsFunction
class TimestampToYearsFunction extends org.apache.iceberg.spark.functions.YearsFunction.BaseToYearsFunction implements Serializable
-
-
Package org.apache.iceberg.spark.source
-
Class org.apache.iceberg.spark.source.SerializableTableWithSize
class SerializableTableWithSize extends SerializableTable implements Serializable -
Class org.apache.iceberg.spark.source.SerializableTableWithSize.SerializableMetadataTableWithSize
class SerializableMetadataTableWithSize extends SerializableTable.SerializableMetadataTable implements Serializable -
Class org.apache.iceberg.spark.source.SparkPositionDeletesRewrite.DeleteTaskCommit
class DeleteTaskCommit extends Object implements Serializable-
Serialized Fields
-
taskFiles
DeleteFile[] taskFiles
-
-
-
Class org.apache.iceberg.spark.source.SparkPositionDeltaWrite.DeltaTaskCommit
class DeltaTaskCommit extends Object implements Serializable-
Serialized Fields
-
dataFiles
DataFile[] dataFiles
-
deleteFiles
DeleteFile[] deleteFiles
-
referencedDataFiles
CharSequence[] referencedDataFiles
-
-
-
Class org.apache.iceberg.spark.source.SparkWrite.TaskCommit
class TaskCommit extends Object implements Serializable-
Serialized Fields
-
taskFiles
DataFile[] taskFiles
-
-
-
-
Package org.apache.iceberg.transforms
-
Class org.apache.iceberg.transforms.Days
class Days extends org.apache.iceberg.transforms.TimeTransform<T> implements Serializable-
Serialization Methods
-
writeReplace
- Throws:
ObjectStreamException
-
-
-
Class org.apache.iceberg.transforms.Hours
class Hours extends org.apache.iceberg.transforms.TimeTransform<T> implements Serializable-
Serialization Methods
-
writeReplace
- Throws:
ObjectStreamException
-
-
-
Class org.apache.iceberg.transforms.Months
class Months extends org.apache.iceberg.transforms.TimeTransform<T> implements Serializable-
Serialization Methods
-
writeReplace
- Throws:
ObjectStreamException
-
-
-
Class org.apache.iceberg.transforms.UnknownTransform
class UnknownTransform extends Object implements Serializable-
Serialized Fields
-
transform
String transform
-
-
-
-
Package org.apache.iceberg.types
-
Class org.apache.iceberg.types.Type.NestedType
class NestedType extends Object implements Serializable -
Class org.apache.iceberg.types.Type.PrimitiveType
class PrimitiveType extends Object implements Serializable-
Serialization Methods
-
writeReplace
- Throws:
ObjectStreamException
-
-
-
Class org.apache.iceberg.types.Types.BinaryType
class BinaryType extends Type.PrimitiveType implements Serializable -
Class org.apache.iceberg.types.Types.BooleanType
class BooleanType extends Type.PrimitiveType implements Serializable -
Class org.apache.iceberg.types.Types.DateType
class DateType extends Type.PrimitiveType implements Serializable -
Class org.apache.iceberg.types.Types.DecimalType
class DecimalType extends Type.PrimitiveType implements Serializable-
Serialized Fields
-
precision
int precision
-
scale
int scale
-
-
-
Class org.apache.iceberg.types.Types.DoubleType
class DoubleType extends Type.PrimitiveType implements Serializable -
Class org.apache.iceberg.types.Types.FixedType
class FixedType extends Type.PrimitiveType implements Serializable-
Serialized Fields
-
length
int length
-
-
-
Class org.apache.iceberg.types.Types.FloatType
class FloatType extends Type.PrimitiveType implements Serializable -
Class org.apache.iceberg.types.Types.IntegerType
class IntegerType extends Type.PrimitiveType implements Serializable -
Class org.apache.iceberg.types.Types.ListType
class ListType extends Type.NestedType implements Serializable-
Serialized Fields
-
elementField
Types.NestedField elementField
-
-
-
Class org.apache.iceberg.types.Types.LongType
class LongType extends Type.PrimitiveType implements Serializable -
Class org.apache.iceberg.types.Types.MapType
class MapType extends Type.NestedType implements Serializable-
Serialized Fields
-
keyField
Types.NestedField keyField
-
valueField
Types.NestedField valueField
-
-
-
Class org.apache.iceberg.types.Types.NestedField
class NestedField extends Object implements Serializable -
Class org.apache.iceberg.types.Types.StringType
class StringType extends Type.PrimitiveType implements Serializable -
Class org.apache.iceberg.types.Types.StructType
class StructType extends Type.NestedType implements Serializable-
Serialized Fields
-
fields
Types.NestedField[] fields
-
-
-
Class org.apache.iceberg.types.Types.TimestampType
class TimestampType extends Type.PrimitiveType implements Serializable-
Serialized Fields
-
adjustToUTC
boolean adjustToUTC
-
-
-
Class org.apache.iceberg.types.Types.TimeType
class TimeType extends Type.PrimitiveType implements Serializable -
Class org.apache.iceberg.types.Types.UUIDType
class UUIDType extends Type.PrimitiveType implements Serializable
-
-
Package org.apache.iceberg.util
-
Class org.apache.iceberg.util.CharSequenceMap
class CharSequenceMap extends Object implements Serializable- serialVersionUID:
- 1L
-
Serialized Fields
-
wrapperMap
Map<CharSequenceWrapper,
V> wrapperMap
-
-
Class org.apache.iceberg.util.CharSequenceSet
class CharSequenceSet extends Object implements Serializable-
Serialized Fields
-
wrapperSet
Set<CharSequenceWrapper> wrapperSet
-
-
-
Class org.apache.iceberg.util.CharSequenceWrapper
class CharSequenceWrapper extends Object implements Serializable-
Serialized Fields
-
wrapped
CharSequence wrapped
-
-
-
Class org.apache.iceberg.util.Pair
class Pair extends Object implements Serializable -
Class org.apache.iceberg.util.SerializableMap
class SerializableMap extends Object implements Serializable- serialVersionUID:
- -3377238354349859240L
-
Exception org.apache.iceberg.util.Tasks.UnrecoverableException
class UnrecoverableException extends RuntimeException implements Serializable
-
-
Package org.apache.iceberg.view
-
Class org.apache.iceberg.view.BaseView
class BaseView extends Object implements Serializable-
Serialized Fields
-
name
String name
-
ops
ViewOperations ops
-
-
-
-
Package org.apache.spark.sql.catalyst.analysis
-
Class org.apache.spark.sql.catalyst.analysis.AnalysisContext
class AnalysisContext extends Object implements Serializable-
Serialized Fields
-
catalogAndNamespace
scala.collection.Seq<String> catalogAndNamespace
-
maxNestedViewDepth
int maxNestedViewDepth
-
nestedViewDepth
int nestedViewDepth
-
outerPlan
scala.Option<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> outerPlan
-
referredTempFunctionNames
scala.collection.mutable.Set<String> referredTempFunctionNames
-
referredTempViewNames
scala.collection.Seq<scala.collection.Seq<String>> referredTempViewNames
-
relationCache
scala.collection.mutable.Map<scala.Tuple2<scala.collection.Seq<String>,
scala.Option<org.apache.spark.sql.catalyst.analysis.TimeTravelSpec>>, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> relationCache
-
-
-
Class org.apache.spark.sql.catalyst.analysis.AnalysisContext$
class AnalysisContext$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
Serialized Fields
-
value
ThreadLocal<org.apache.spark.sql.catalyst.analysis.AnalysisContext> value
-
-
-
Class org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveReferences$MergeResolvePolicy$
class Analyzer$ResolveReferences$MergeResolvePolicy$ extends scala.Enumeration implements Serializable-
Serialized Fields
-
BOTH
scala.Enumeration.Value BOTH
-
SOURCE
scala.Enumeration.Value SOURCE
-
TARGET
scala.Enumeration.Value TARGET
-
-
-
Class org.apache.spark.sql.catalyst.analysis.AsOfTimestamp
class AsOfTimestamp extends Object implements Serializable-
Serialized Fields
-
timestamp
long timestamp
-
-
-
Class org.apache.spark.sql.catalyst.analysis.AsOfTimestamp$
class AsOfTimestamp$ extends scala.runtime.AbstractFunction1<Object,org.apache.spark.sql.catalyst.analysis.AsOfTimestamp> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.AsOfVersion
class AsOfVersion extends Object implements Serializable-
Serialized Fields
-
version
String version
-
-
-
Class org.apache.spark.sql.catalyst.analysis.AsOfVersion$
class AsOfVersion$ extends scala.runtime.AbstractFunction1<String,org.apache.spark.sql.catalyst.analysis.AsOfVersion> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.CannotReplaceMissingTableException
class CannotReplaceMissingTableException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.CannotReplaceMissingTableException$
class CannotReplaceMissingTableException$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.DatabaseAlreadyExistsException
class DatabaseAlreadyExistsException extends org.apache.spark.sql.catalyst.analysis.NamespaceAlreadyExistsException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.ExpressionWithUnresolvedIdentifier
class ExpressionWithUnresolvedIdentifier extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
exprBuilder
scala.Function1<scala.collection.Seq<String>,
org.apache.spark.sql.catalyst.expressions.Expression> exprBuilder -
identifierExpr
org.apache.spark.sql.catalyst.expressions.Expression identifierExpr
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ExpressionWithUnresolvedIdentifier$
class ExpressionWithUnresolvedIdentifier$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.Function1<scala.collection.Seq<String>, org.apache.spark.sql.catalyst.expressions.Expression>, org.apache.spark.sql.catalyst.analysis.ExpressionWithUnresolvedIdentifier> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.FunctionAlreadyExistsException
class FunctionAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.GetColumnByOrdinal
class GetColumnByOrdinal extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
dataType
org.apache.spark.sql.types.DataType dataType
-
ordinal
int ordinal
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.GetColumnByOrdinal$
class GetColumnByOrdinal$ extends scala.runtime.AbstractFunction2<Object,org.apache.spark.sql.types.DataType, org.apache.spark.sql.catalyst.analysis.GetColumnByOrdinal> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.GetViewColumnByNameAndOrdinal
class GetViewColumnByNameAndOrdinal extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.GetViewColumnByNameAndOrdinal$
class GetViewColumnByNameAndOrdinal$ extends scala.runtime.AbstractFunction5<String,String, Object, Object, scala.Option<String>, org.apache.spark.sql.catalyst.analysis.GetViewColumnByNameAndOrdinal> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.IndexAlreadyExistsException
class IndexAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.IndexAlreadyExistsException$
class IndexAlreadyExistsException$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.MultiAlias
class MultiAlias extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
child
org.apache.spark.sql.catalyst.expressions.Expression child
-
names
scala.collection.Seq<String> names
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.MultiAlias$
class MultiAlias$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.collection.Seq<String>, org.apache.spark.sql.catalyst.analysis.MultiAlias> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NamedParameter
class NamedParameter extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
name
String name
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NamedParameter$
class NamedParameter$ extends scala.runtime.AbstractFunction1<String,org.apache.spark.sql.catalyst.analysis.NamedParameter> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NameParameterizedQuery
class NameParameterizedQuery extends org.apache.spark.sql.catalyst.analysis.ParameterizedQuery implements Serializable-
Serialized Fields
-
args
scala.collection.immutable.Map<String,
org.apache.spark.sql.catalyst.expressions.Expression> args -
child
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NameParameterizedQuery$
class NameParameterizedQuery$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,scala.collection.immutable.Map<String, org.apache.spark.sql.catalyst.expressions.Expression>, org.apache.spark.sql.catalyst.analysis.NameParameterizedQuery> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.NamespaceAlreadyExistsException
class NamespaceAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable -
Exception org.apache.spark.sql.catalyst.analysis.NonEmptyNamespaceException
class NonEmptyNamespaceException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.NonEmptyNamespaceException$
class NonEmptyNamespaceException$ extends scala.runtime.AbstractFunction2<String,scala.Option<Throwable>, org.apache.spark.sql.catalyst.analysis.NonEmptyNamespaceException> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.NoSuchDatabaseException
class NoSuchDatabaseException extends org.apache.spark.sql.AnalysisException implements Serializable -
Exception org.apache.spark.sql.catalyst.analysis.NoSuchFunctionException
class NoSuchFunctionException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.NoSuchFunctionException$
class NoSuchFunctionException$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.NoSuchIndexException
class NoSuchIndexException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.NoSuchIndexException$
class NoSuchIndexException$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException
class NoSuchNamespaceException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException$
class NoSuchNamespaceException$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.NoSuchPartitionException
class NoSuchPartitionException extends org.apache.spark.sql.AnalysisException implements Serializable -
Exception org.apache.spark.sql.catalyst.analysis.NoSuchPartitionsException
class NoSuchPartitionsException extends org.apache.spark.sql.AnalysisException implements Serializable -
Exception org.apache.spark.sql.catalyst.analysis.NoSuchPermanentFunctionException
class NoSuchPermanentFunctionException extends org.apache.spark.sql.AnalysisException implements Serializable -
Exception org.apache.spark.sql.catalyst.analysis.NoSuchProcedureException
class NoSuchProcedureException extends org.apache.spark.sql.AnalysisException implements Serializable -
Exception org.apache.spark.sql.catalyst.analysis.NoSuchTableException
class NoSuchTableException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.NoSuchTableException$
class NoSuchTableException$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.NoSuchTempFunctionException
class NoSuchTempFunctionException extends org.apache.spark.sql.AnalysisException implements Serializable -
Exception org.apache.spark.sql.catalyst.analysis.NoSuchViewException
class NoSuchViewException extends org.apache.spark.sql.AnalysisException implements Serializable -
Exception org.apache.spark.sql.catalyst.analysis.PartitionAlreadyExistsException
class PartitionAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable -
Exception org.apache.spark.sql.catalyst.analysis.PartitionsAlreadyExistException
class PartitionsAlreadyExistException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.PlanWithUnresolvedIdentifier
class PlanWithUnresolvedIdentifier extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
identifierExpr
org.apache.spark.sql.catalyst.expressions.Expression identifierExpr
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
planBuilder
scala.Function1<scala.collection.Seq<String>,
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> planBuilder -
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.PlanWithUnresolvedIdentifier$
class PlanWithUnresolvedIdentifier$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.Function1<scala.collection.Seq<String>, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>, org.apache.spark.sql.catalyst.analysis.PlanWithUnresolvedIdentifier> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.PosParameter
class PosParameter extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
pos
int pos
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.PosParameter$
class PosParameter$ extends scala.runtime.AbstractFunction1<Object,org.apache.spark.sql.catalyst.analysis.PosParameter> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.PosParameterizedQuery
class PosParameterizedQuery extends org.apache.spark.sql.catalyst.analysis.ParameterizedQuery implements Serializable-
Serialized Fields
-
args
org.apache.spark.sql.catalyst.expressions.Expression[] args
-
child
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child
-
-
-
Class org.apache.spark.sql.catalyst.analysis.PosParameterizedQuery$
class PosParameterizedQuery$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,org.apache.spark.sql.catalyst.expressions.Expression[], org.apache.spark.sql.catalyst.analysis.PosParameterizedQuery> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.RelationTimeTravel
class RelationTimeTravel extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
relation
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan relation
-
resolved
boolean resolved
-
timestamp
scala.Option<org.apache.spark.sql.catalyst.expressions.Expression> timestamp
-
version
scala.Option<String> version
-
-
-
Class org.apache.spark.sql.catalyst.analysis.RelationTimeTravel$
class RelationTimeTravel$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,scala.Option<org.apache.spark.sql.catalyst.expressions.Expression>, scala.Option<String>, org.apache.spark.sql.catalyst.analysis.RelationTimeTravel> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.RelationWrapper
class RelationWrapper extends Object implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.RelationWrapper$
class RelationWrapper$ extends scala.runtime.AbstractFunction2<Class<?>,scala.collection.Seq<Object>, org.apache.spark.sql.catalyst.analysis.RelationWrapper> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolveColumnDefaultInInsert$
class ResolveColumnDefaultInInsert$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
Serialized Fields
-
org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions
scala.collection.Seq<scala.Tuple3<String,
scala.Function0<org.apache.spark.sql.catalyst.expressions.Expression>, scala.Function1<org.apache.spark.sql.catalyst.expressions.Expression, String>>> org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedFieldName
class ResolvedFieldName extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable-
Serialized Fields
-
field
org.apache.spark.sql.types.StructField field
-
path
scala.collection.Seq<String> path
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedFieldName$
class ResolvedFieldName$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<String>,org.apache.spark.sql.types.StructField, org.apache.spark.sql.catalyst.analysis.ResolvedFieldName> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedFieldPosition
class ResolvedFieldPosition extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable-
Serialized Fields
-
position
org.apache.spark.sql.connector.catalog.TableChange.ColumnPosition position
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedFieldPosition$
class ResolvedFieldPosition$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.connector.catalog.TableChange.ColumnPosition,org.apache.spark.sql.catalyst.analysis.ResolvedFieldPosition> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedIdentifier
class ResolvedIdentifier extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
catalog
org.apache.spark.sql.connector.catalog.CatalogPlugin catalog
-
identifier
org.apache.spark.sql.connector.catalog.Identifier identifier
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedIdentifier$
class ResolvedIdentifier$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.connector.catalog.CatalogPlugin,org.apache.spark.sql.connector.catalog.Identifier, org.apache.spark.sql.catalyst.analysis.ResolvedIdentifier> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedInlineTable
class ResolvedInlineTable extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
output
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output
-
rows
scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>> rows
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedInlineTable$
class ResolvedInlineTable$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>>,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>, org.apache.spark.sql.catalyst.analysis.ResolvedInlineTable> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedNamespace
class ResolvedNamespace extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
catalog
org.apache.spark.sql.connector.catalog.CatalogPlugin catalog
-
namespace
scala.collection.Seq<String> namespace
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedNamespace$
class ResolvedNamespace$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.connector.catalog.CatalogPlugin,scala.collection.Seq<String>, org.apache.spark.sql.catalyst.analysis.ResolvedNamespace> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedNonPersistentFunc
class ResolvedNonPersistentFunc extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
func
org.apache.spark.sql.connector.catalog.functions.UnboundFunction func
-
name
String name
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedNonPersistentFunc$
class ResolvedNonPersistentFunc$ extends scala.runtime.AbstractFunction2<String,org.apache.spark.sql.connector.catalog.functions.UnboundFunction, org.apache.spark.sql.catalyst.analysis.ResolvedNonPersistentFunc> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedPartitionSpec
class ResolvedPartitionSpec extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.ResolvedPartitionSpec$
class ResolvedPartitionSpec$ extends scala.runtime.AbstractFunction3<scala.collection.Seq<String>,org.apache.spark.sql.catalyst.InternalRow, scala.Option<String>, org.apache.spark.sql.catalyst.analysis.ResolvedPartitionSpec> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedPersistentFunc
class ResolvedPersistentFunc extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
catalog
org.apache.spark.sql.connector.catalog.FunctionCatalog catalog
-
func
org.apache.spark.sql.connector.catalog.functions.UnboundFunction func
-
identifier
org.apache.spark.sql.connector.catalog.Identifier identifier
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedPersistentFunc$
class ResolvedPersistentFunc$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.connector.catalog.FunctionCatalog,org.apache.spark.sql.connector.catalog.Identifier, org.apache.spark.sql.connector.catalog.functions.UnboundFunction, org.apache.spark.sql.catalyst.analysis.ResolvedPersistentFunc> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedPersistentView
class ResolvedPersistentView extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
catalog
org.apache.spark.sql.connector.catalog.CatalogPlugin catalog
-
identifier
org.apache.spark.sql.connector.catalog.Identifier identifier
-
viewSchema
org.apache.spark.sql.types.StructType viewSchema
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedPersistentView$
class ResolvedPersistentView$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.connector.catalog.CatalogPlugin,org.apache.spark.sql.connector.catalog.Identifier, org.apache.spark.sql.types.StructType, org.apache.spark.sql.catalyst.analysis.ResolvedPersistentView> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedStar
class ResolvedStar extends org.apache.spark.sql.catalyst.analysis.Star implements Serializable-
Serialized Fields
-
expressions
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression> expressions
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedStar$
class ResolvedStar$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression>,org.apache.spark.sql.catalyst.analysis.ResolvedStar> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedTable
class ResolvedTable extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
catalog
org.apache.spark.sql.connector.catalog.TableCatalog catalog
-
identifier
org.apache.spark.sql.connector.catalog.Identifier identifier
-
outputAttributes
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> outputAttributes
-
table
org.apache.spark.sql.connector.catalog.Table table
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedTable$
class ResolvedTable$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedTempView
class ResolvedTempView extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
identifier
org.apache.spark.sql.connector.catalog.Identifier identifier
-
viewSchema
org.apache.spark.sql.types.StructType viewSchema
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedTempView$
class ResolvedTempView$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.connector.catalog.Identifier,org.apache.spark.sql.types.StructType, org.apache.spark.sql.catalyst.analysis.ResolvedTempView> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolveLateralColumnAliasReference.AliasEntry
class AliasEntry extends Object implements Serializable-
Serialized Fields
-
alias
org.apache.spark.sql.catalyst.expressions.Alias alias
-
index
int index
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolveLateralColumnAliasReference.AliasEntry$
class AliasEntry$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Alias,Object, org.apache.spark.sql.catalyst.analysis.ResolveLateralColumnAliasReference.AliasEntry> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolveProcedures
class ResolveProcedures extends org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> implements Serializable-
Serialized Fields
-
AsTableIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.AsTableIdentifier$ AsTableIdentifier$module
-
bitmap$0
boolean bitmap$0
-
CatalogAndIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndIdentifier$ CatalogAndIdentifier$module
-
CatalogAndMultipartIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndMultipartIdentifier$ CatalogAndMultipartIdentifier$module
-
CatalogAndNamespace$module
org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndNamespace$ CatalogAndNamespace$module
-
catalogManager
org.apache.spark.sql.connector.catalog.CatalogManager catalogManager
-
NonSessionCatalogAndIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.NonSessionCatalogAndIdentifier$ NonSessionCatalogAndIdentifier$module
-
SessionCatalogAndIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.SessionCatalogAndIdentifier$ SessionCatalogAndIdentifier$module
-
spark
org.apache.spark.sql.SparkSession spark
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolveProcedures$
class ResolveProcedures$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.SparkSession,org.apache.spark.sql.catalyst.analysis.ResolveProcedures> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolveReferencesInUpdate$
class ResolveReferencesInUpdate$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
Serialized Fields
-
org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions
scala.collection.Seq<scala.Tuple3<String,
scala.Function0<org.apache.spark.sql.catalyst.expressions.Expression>, scala.Function1<org.apache.spark.sql.catalyst.expressions.Expression, String>>> org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolveViews
class ResolveViews extends org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> implements Serializable-
Serialized Fields
-
AsTableIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.AsTableIdentifier$ AsTableIdentifier$module
-
bitmap$0
boolean bitmap$0
-
CatalogAndIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndIdentifier$ CatalogAndIdentifier$module
-
CatalogAndMultipartIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndMultipartIdentifier$ CatalogAndMultipartIdentifier$module
-
CatalogAndNamespace$module
org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndNamespace$ CatalogAndNamespace$module
-
catalogManager
org.apache.spark.sql.connector.catalog.CatalogManager catalogManager
-
NonSessionCatalogAndIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.NonSessionCatalogAndIdentifier$ NonSessionCatalogAndIdentifier$module
-
SessionCatalogAndIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.SessionCatalogAndIdentifier$ SessionCatalogAndIdentifier$module
-
spark
org.apache.spark.sql.SparkSession spark
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolveViews$
class ResolveViews$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.SparkSession,org.apache.spark.sql.catalyst.analysis.ResolveViews> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.RewriteViewCommands
class RewriteViewCommands extends org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> implements Serializable-
Serialized Fields
-
AsTableIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.AsTableIdentifier$ AsTableIdentifier$module
-
bitmap$0
boolean bitmap$0
-
CatalogAndIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndIdentifier$ CatalogAndIdentifier$module
-
CatalogAndMultipartIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndMultipartIdentifier$ CatalogAndMultipartIdentifier$module
-
CatalogAndNamespace$module
org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndNamespace$ CatalogAndNamespace$module
-
catalogManager
org.apache.spark.sql.connector.catalog.CatalogManager catalogManager
-
NonSessionCatalogAndIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.NonSessionCatalogAndIdentifier$ NonSessionCatalogAndIdentifier$module
-
ResolvedIdent$module
org.apache.spark.sql.catalyst.analysis.RewriteViewCommands.ResolvedIdent$ ResolvedIdent$module
-
ResolvedView$module
org.apache.spark.sql.catalyst.analysis.RewriteViewCommands.ResolvedView$ ResolvedView$module
-
SessionCatalogAndIdentifier$module
org.apache.spark.sql.connector.catalog.LookupCatalog.SessionCatalogAndIdentifier$ SessionCatalogAndIdentifier$module
-
spark
org.apache.spark.sql.SparkSession spark
-
-
-
Class org.apache.spark.sql.catalyst.analysis.RewriteViewCommands$
class RewriteViewCommands$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.SparkSession,org.apache.spark.sql.catalyst.analysis.RewriteViewCommands> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.TableAlreadyExistsException
class TableAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.TableAlreadyExistsException$
class TableAlreadyExistsException$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TempResolvedColumn
class TempResolvedColumn extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable-
Serialized Fields
-
bitmap$0
byte bitmap$0
-
canonicalized
org.apache.spark.sql.catalyst.expressions.Expression canonicalized
-
child
org.apache.spark.sql.catalyst.expressions.Expression child
-
hasTried
boolean hasTried
-
nameParts
scala.collection.Seq<String> nameParts
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TempResolvedColumn$
class TempResolvedColumn$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.catalyst.expressions.Expression,scala.collection.Seq<String>, Object, org.apache.spark.sql.catalyst.analysis.TempResolvedColumn> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.TempTableAlreadyExistsException
class TempTableAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.TempTableAlreadyExistsException$
class TempTableAlreadyExistsException$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.DataTypeMismatch
class DataTypeMismatch extends Object implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.DataTypeMismatch$
class DataTypeMismatch$ extends scala.runtime.AbstractFunction2<String,scala.collection.immutable.Map<String, String>, org.apache.spark.sql.catalyst.analysis.TypeCheckResult.DataTypeMismatch> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.InvalidFormat
class InvalidFormat extends Object implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.InvalidFormat$
class InvalidFormat$ extends scala.runtime.AbstractFunction2<String,scala.collection.immutable.Map<String, String>, org.apache.spark.sql.catalyst.analysis.TypeCheckResult.InvalidFormat> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.TypeCheckFailure
class TypeCheckFailure extends Object implements Serializable-
Serialized Fields
-
message
String message
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.TypeCheckFailure$
class TypeCheckFailure$ extends scala.runtime.AbstractFunction1<String,org.apache.spark.sql.catalyst.analysis.TypeCheckResult.TypeCheckFailure> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedAlias
class UnresolvedAlias extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable-
Serialized Fields
-
aliasFunc
scala.Option<scala.Function1<org.apache.spark.sql.catalyst.expressions.Expression,
String>> aliasFunc -
bitmap$0
boolean bitmap$0
-
child
org.apache.spark.sql.catalyst.expressions.Expression child
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedAlias$
class UnresolvedAlias$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.Option<scala.Function1<org.apache.spark.sql.catalyst.expressions.Expression, String>>, org.apache.spark.sql.catalyst.analysis.UnresolvedAlias> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute
class UnresolvedAttribute extends org.apache.spark.sql.catalyst.expressions.Attribute implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
nameParts
scala.collection.Seq<String> nameParts
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute$
class UnresolvedAttribute$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedDeserializer
class UnresolvedDeserializer extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
deserializer
org.apache.spark.sql.catalyst.expressions.Expression deserializer
-
inputAttributes
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> inputAttributes
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedDeserializer$
class UnresolvedDeserializer$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>, org.apache.spark.sql.catalyst.analysis.UnresolvedDeserializer> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.UnresolvedException
class UnresolvedException extends org.apache.spark.sql.AnalysisException implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.UnresolvedExtractValue
class UnresolvedExtractValue extends org.apache.spark.sql.catalyst.expressions.BinaryExpression implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
child
org.apache.spark.sql.catalyst.expressions.Expression child
-
extraction
org.apache.spark.sql.catalyst.expressions.Expression extraction
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedExtractValue$
class UnresolvedExtractValue$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.expressions.Expression, org.apache.spark.sql.catalyst.analysis.UnresolvedExtractValue> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFieldName
class UnresolvedFieldName extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
name
scala.collection.Seq<String> name
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFieldName$
class UnresolvedFieldName$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<String>,org.apache.spark.sql.catalyst.analysis.UnresolvedFieldName> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFieldPosition
class UnresolvedFieldPosition extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
position
org.apache.spark.sql.connector.catalog.TableChange.ColumnPosition position
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFieldPosition$
class UnresolvedFieldPosition$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.connector.catalog.TableChange.ColumnPosition,org.apache.spark.sql.catalyst.analysis.UnresolvedFieldPosition> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFunction
class UnresolvedFunction extends org.apache.spark.sql.catalyst.expressions.Expression implements Serializable-
Serialized Fields
-
arguments
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> arguments
-
bitmap$0
boolean bitmap$0
-
filter
scala.Option<org.apache.spark.sql.catalyst.expressions.Expression> filter
-
ignoreNulls
boolean ignoreNulls
-
isDistinct
boolean isDistinct
-
nameParts
scala.collection.Seq<String> nameParts
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFunction$
class UnresolvedFunction$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFunctionName
class UnresolvedFunctionName extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
commandName
String commandName
-
funcTypeMismatchHint
scala.Option<String> funcTypeMismatchHint
-
multipartIdentifier
scala.collection.Seq<String> multipartIdentifier
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
possibleQualifiedName
scala.Option<scala.collection.Seq<String>> possibleQualifiedName
-
requirePersistent
boolean requirePersistent
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFunctionName$
class UnresolvedFunctionName$ extends scala.runtime.AbstractFunction5<scala.collection.Seq<String>,String, Object, scala.Option<String>, scala.Option<scala.collection.Seq<String>>, org.apache.spark.sql.catalyst.analysis.UnresolvedFunctionName> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedGenerator
class UnresolvedGenerator extends org.apache.spark.sql.catalyst.expressions.Expression implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
children
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> children
-
name
org.apache.spark.sql.catalyst.FunctionIdentifier name
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedGenerator$
class UnresolvedGenerator$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.FunctionIdentifier,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>, org.apache.spark.sql.catalyst.analysis.UnresolvedGenerator> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedHaving
class UnresolvedHaving extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
bitmap$0
byte bitmap$0
-
child
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child
-
havingCondition
org.apache.spark.sql.catalyst.expressions.Expression havingCondition
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
validConstraints
org.apache.spark.sql.catalyst.expressions.ExpressionSet validConstraints
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedHaving$
class UnresolvedHaving$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan, org.apache.spark.sql.catalyst.analysis.UnresolvedHaving> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedIdentifier
class UnresolvedIdentifier extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
allowTemp
boolean allowTemp
-
bitmap$0
boolean bitmap$0
-
nameParts
scala.collection.Seq<String> nameParts
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedIdentifier$
class UnresolvedIdentifier$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<String>,Object, org.apache.spark.sql.catalyst.analysis.UnresolvedIdentifier> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedInlineTable
class UnresolvedInlineTable extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
bitmap$0
byte bitmap$0
-
expressionsResolved
boolean expressionsResolved
-
names
scala.collection.Seq<String> names
-
resolved
boolean resolved
-
rows
scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>> rows
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedInlineTable$
class UnresolvedInlineTable$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<String>,scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>>, org.apache.spark.sql.catalyst.analysis.UnresolvedInlineTable> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedNamespace
class UnresolvedNamespace extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
multipartIdentifier
scala.collection.Seq<String> multipartIdentifier
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedNamespace$
class UnresolvedNamespace$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<String>,org.apache.spark.sql.catalyst.analysis.UnresolvedNamespace> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedOrdinal
class UnresolvedOrdinal extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
ordinal
int ordinal
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedOrdinal$
class UnresolvedOrdinal$ extends scala.runtime.AbstractFunction1<Object,org.apache.spark.sql.catalyst.analysis.UnresolvedOrdinal> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedPartitionSpec
class UnresolvedPartitionSpec extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.UnresolvedPartitionSpec$
class UnresolvedPartitionSpec$ extends scala.runtime.AbstractFunction2<scala.collection.immutable.Map<String,String>, scala.Option<String>, org.apache.spark.sql.catalyst.analysis.UnresolvedPartitionSpec> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedRegex
class UnresolvedRegex extends org.apache.spark.sql.catalyst.analysis.Star implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.UnresolvedRegex$
class UnresolvedRegex$ extends scala.runtime.AbstractFunction3<String,scala.Option<String>, Object, org.apache.spark.sql.catalyst.analysis.UnresolvedRegex> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedRelation
class UnresolvedRelation extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
isStreaming
boolean isStreaming
-
multipartIdentifier
scala.collection.Seq<String> multipartIdentifier
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
options
org.apache.spark.sql.util.CaseInsensitiveStringMap options
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedRelation$
class UnresolvedRelation$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedSeed$
class UnresolvedSeed$ extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable-
Serialization Methods
-
readResolve
-
-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedStar
class UnresolvedStar extends org.apache.spark.sql.catalyst.analysis.Star implements Serializable-
Serialized Fields
-
target
scala.Option<scala.collection.Seq<String>> target
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedStar$
class UnresolvedStar$ extends scala.runtime.AbstractFunction1<scala.Option<scala.collection.Seq<String>>,org.apache.spark.sql.catalyst.analysis.UnresolvedStar> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedSubqueryColumnAliases
class UnresolvedSubqueryColumnAliases extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
bitmap$0
byte bitmap$0
-
child
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
outputColumnNames
scala.collection.Seq<String> outputColumnNames
-
resolved
boolean resolved
-
validConstraints
org.apache.spark.sql.catalyst.expressions.ExpressionSet validConstraints
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedSubqueryColumnAliases$
class UnresolvedSubqueryColumnAliases$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<String>,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan, org.apache.spark.sql.catalyst.analysis.UnresolvedSubqueryColumnAliases> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTable
class UnresolvedTable extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTable$
class UnresolvedTable$ extends scala.runtime.AbstractFunction3<scala.collection.Seq<String>,String, scala.Option<String>, org.apache.spark.sql.catalyst.analysis.UnresolvedTable> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTableOrView
class UnresolvedTableOrView extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTableOrView$
class UnresolvedTableOrView$ extends scala.runtime.AbstractFunction3<scala.collection.Seq<String>,String, Object, org.apache.spark.sql.catalyst.analysis.UnresolvedTableOrView> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTableValuedFunction
class UnresolvedTableValuedFunction extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
functionArgs
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> functionArgs
-
name
scala.collection.Seq<String> name
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTableValuedFunction$
class UnresolvedTableValuedFunction$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTVFAliases
class UnresolvedTVFAliases extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable-
Serialized Fields
-
bitmap$0
byte bitmap$0
-
child
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child
-
name
scala.collection.Seq<String> name
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
outputNames
scala.collection.Seq<String> outputNames
-
resolved
boolean resolved
-
validConstraints
org.apache.spark.sql.catalyst.expressions.ExpressionSet validConstraints
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTVFAliases$
class UnresolvedTVFAliases$ extends Object implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedView
class UnresolvedView extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable -
Class org.apache.spark.sql.catalyst.analysis.UnresolvedView$
class UnresolvedView$ extends scala.runtime.AbstractFunction4<scala.collection.Seq<String>,String, Object, scala.Option<String>, org.apache.spark.sql.catalyst.analysis.UnresolvedView> implements Serializable -
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.analysis.ViewAlreadyExistsException
class ViewAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable
-
-
Package org.apache.spark.sql.catalyst.parser.extensions
-
Class org.apache.spark.sql.catalyst.parser.extensions.IcebergParseErrorListener$
class IcebergParseErrorListener$ extends org.antlr.v4.runtime.BaseErrorListener implements Serializable-
Serialization Methods
-
readResolve
-
-
-
Exception org.apache.spark.sql.catalyst.parser.extensions.IcebergParseException
class IcebergParseException extends org.apache.spark.sql.AnalysisException implements Serializable-
Serialized Fields
-
command
scala.Option<String> command
-
start
org.apache.spark.sql.catalyst.trees.Origin start
-
stop
org.apache.spark.sql.catalyst.trees.Origin stop
-
-
-
Class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsPostProcessor$
class IcebergSqlExtensionsPostProcessor$ extends IcebergSqlExtensionsBaseListener implements Serializable-
Serialization Methods
-
readResolve
-
-
-