Serialized Form
-
Package org.apache.hadoop.hive.ql.exec.vector
-
Class org.apache.hadoop.hive.ql.exec.vector.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 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 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 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 extends org.apache.hadoop.hive.ql.exec.LimitOperator implements Serializable
- serialVersionUID:
- 1L
-
Class org.apache.hadoop.hive.ql.exec.vector.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 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 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 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 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 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 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 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 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 extends org.apache.iceberg.BaseFilesTable implements Serializable
-
Class org.apache.iceberg.AllDeleteFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable
-
Class org.apache.iceberg.AllEntriesTable extends org.apache.iceberg.BaseEntriesTable implements Serializable
-
Class org.apache.iceberg.AllFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable
-
Class org.apache.iceberg.AllManifestsTable extends BaseMetadataTable implements Serializable
-
Class org.apache.iceberg.BaseCombinedScanTask extends java.lang.Object implements Serializable
-
Serialized Fields
-
tasks
FileScanTask[] tasks
-
-
-
Class org.apache.iceberg.BaseFileScanTask extends org.apache.iceberg.BaseContentScanTask<FileScanTask,DataFile> implements Serializable
-
Serialized Fields
-
deletes
DeleteFile[] deletes
-
-
-
Class org.apache.iceberg.BaseMetadataTable extends org.apache.iceberg.BaseReadOnlyTable implements Serializable
-
Serialization Methods
-
writeReplace
final java.lang.Object writeReplace()
-
-
Serialized Fields
-
name
java.lang.String name
-
sortOrder
SortOrder sortOrder
-
spec
PartitionSpec spec
-
table
BaseTable table
-
uuid
java.util.UUID uuid
-
-
-
Class org.apache.iceberg.BaseScanTaskGroup extends java.lang.Object implements Serializable
-
Serialized Fields
-
groupingKey
StructLike groupingKey
-
tasks
java.lang.Object[] tasks
-
-
-
Class org.apache.iceberg.BaseTable extends java.lang.Object implements Serializable
-
Serialization Methods
-
writeReplace
java.lang.Object writeReplace()
-
-
Serialized Fields
-
name
java.lang.String name
-
ops
TableOperations ops
-
reporter
MetricsReporter reporter
-
-
-
Class org.apache.iceberg.BaseTransaction.TransactionTable extends java.lang.Object implements Serializable
-
Serialization Methods
-
writeReplace
java.lang.Object writeReplace()
-
-
-
Class org.apache.iceberg.DataFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable
-
Class org.apache.iceberg.DeleteFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable
-
Class org.apache.iceberg.FilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable
-
Class org.apache.iceberg.GenericManifestFile extends SupportsIndexProjection implements Serializable
-
Serialized Fields
-
addedFilesCount
java.lang.Integer addedFilesCount
-
addedRowsCount
java.lang.Long addedRowsCount
-
content
ManifestContent content
-
deletedFilesCount
java.lang.Integer deletedFilesCount
-
deletedRowsCount
java.lang.Long deletedRowsCount
-
existingFilesCount
java.lang.Integer existingFilesCount
-
existingRowsCount
java.lang.Long existingRowsCount
-
file
InputFile file
-
keyMetadata
byte[] keyMetadata
-
length
java.lang.Long length
-
manifestPath
java.lang.String manifestPath
-
minSequenceNumber
long minSequenceNumber
-
partitions
ManifestFile.PartitionFieldSummary[] partitions
-
sequenceNumber
long sequenceNumber
-
snapshotId
java.lang.Long snapshotId
-
specId
int specId
-
-
-
Class org.apache.iceberg.GenericPartitionFieldSummary extends java.lang.Object implements Serializable
-
Serialized Fields
-
containsNaN
java.lang.Boolean containsNaN
-
containsNull
boolean containsNull
-
fromProjectionPos
int[] fromProjectionPos
-
lowerBound
byte[] lowerBound
-
upperBound
byte[] upperBound
-
-
-
Class org.apache.iceberg.HistoryTable extends BaseMetadataTable implements Serializable
-
Class org.apache.iceberg.ManifestEntriesTable extends org.apache.iceberg.BaseEntriesTable implements Serializable
-
Class org.apache.iceberg.ManifestFilterManager.DeleteException extends ValidationException implements Serializable
-
Serialized Fields
-
partition
java.lang.String partition
-
-
-
Class org.apache.iceberg.ManifestsTable extends BaseMetadataTable implements Serializable
-
Class org.apache.iceberg.MetadataLogEntriesTable extends BaseMetadataTable implements Serializable
-
Class org.apache.iceberg.MetadataUpdate.AddPartitionSpec extends java.lang.Object implements Serializable
-
Serialized Fields
-
spec
UnboundPartitionSpec spec
-
-
-
Class org.apache.iceberg.MetadataUpdate.AddSchema extends java.lang.Object implements Serializable
-
Serialized Fields
-
lastColumnId
int lastColumnId
-
schema
Schema schema
-
-
-
Class org.apache.iceberg.MetadataUpdate.AddSnapshot extends java.lang.Object implements Serializable
-
Serialized Fields
-
snapshot
Snapshot snapshot
-
-
-
Class org.apache.iceberg.MetadataUpdate.AddSortOrder extends java.lang.Object implements Serializable
-
Serialized Fields
-
sortOrder
UnboundSortOrder sortOrder
-
-
-
Class org.apache.iceberg.MetadataUpdate.AddViewVersion extends java.lang.Object implements Serializable
-
Serialized Fields
-
viewVersion
ViewVersion viewVersion
-
-
-
Class org.apache.iceberg.MetadataUpdate.AssignUUID extends java.lang.Object implements Serializable
-
Serialized Fields
-
uuid
java.lang.String uuid
-
-
-
Class org.apache.iceberg.MetadataUpdate.RemovePartitionStatistics extends java.lang.Object implements Serializable
-
Serialized Fields
-
snapshotId
long snapshotId
-
-
-
Class org.apache.iceberg.MetadataUpdate.RemoveProperties extends java.lang.Object implements Serializable
-
Serialized Fields
-
removed
java.util.Set<java.lang.String> removed
-
-
-
Class org.apache.iceberg.MetadataUpdate.RemoveSnapshot extends java.lang.Object implements Serializable
-
Serialized Fields
-
snapshotId
long snapshotId
-
-
-
Class org.apache.iceberg.MetadataUpdate.RemoveSnapshotRef extends java.lang.Object implements Serializable
-
Serialized Fields
-
refName
java.lang.String refName
-
-
-
Class org.apache.iceberg.MetadataUpdate.RemoveStatistics extends java.lang.Object implements Serializable
-
Serialized Fields
-
snapshotId
long snapshotId
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetCurrentSchema extends java.lang.Object implements Serializable
-
Serialized Fields
-
schemaId
int schemaId
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetCurrentViewVersion extends java.lang.Object implements Serializable
-
Serialized Fields
-
versionId
int versionId
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetDefaultPartitionSpec extends java.lang.Object implements Serializable
-
Serialized Fields
-
specId
int specId
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetDefaultSortOrder extends java.lang.Object implements Serializable
-
Serialized Fields
-
sortOrderId
int sortOrderId
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetLocation extends java.lang.Object implements Serializable
-
Serialized Fields
-
location
java.lang.String location
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetPartitionStatistics extends java.lang.Object implements Serializable
-
Serialized Fields
-
partitionStatisticsFile
PartitionStatisticsFile partitionStatisticsFile
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetProperties extends java.lang.Object implements Serializable
-
Serialized Fields
-
updated
java.util.Map<java.lang.String,java.lang.String> updated
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetSnapshotRef extends java.lang.Object implements Serializable
-
Serialized Fields
-
maxRefAgeMs
java.lang.Long maxRefAgeMs
-
maxSnapshotAgeMs
java.lang.Long maxSnapshotAgeMs
-
minSnapshotsToKeep
java.lang.Integer minSnapshotsToKeep
-
refName
java.lang.String refName
-
snapshotId
java.lang.Long snapshotId
-
type
org.apache.iceberg.SnapshotRefType type
-
-
-
Class org.apache.iceberg.MetadataUpdate.SetStatistics extends java.lang.Object implements Serializable
-
Serialized Fields
-
snapshotId
long snapshotId
-
statisticsFile
StatisticsFile statisticsFile
-
-
-
Class org.apache.iceberg.MetadataUpdate.UpgradeFormatVersion extends java.lang.Object implements Serializable
-
Serialized Fields
-
formatVersion
int formatVersion
-
-
-
Class org.apache.iceberg.Metrics extends java.lang.Object implements Serializable
-
Serialization Methods
-
readObject
private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, java.lang.ClassNotFoundException
Implemented the method to enable deserialization of ByteBuffers.- Throws:
java.io.IOException
- On serialization errorjava.lang.ClassNotFoundException
- If the class is not found
-
writeObject
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException
Implemented the method to enable serialization of ByteBuffers.- Throws:
java.io.IOException
- On serialization error
-
-
Serialized Fields
-
columnSizes
java.util.Map<java.lang.Integer,java.lang.Long> columnSizes
-
lowerBounds
java.util.Map<java.lang.Integer,java.nio.ByteBuffer> lowerBounds
-
nanValueCounts
java.util.Map<java.lang.Integer,java.lang.Long> nanValueCounts
-
nullValueCounts
java.util.Map<java.lang.Integer,java.lang.Long> nullValueCounts
-
rowCount
java.lang.Long rowCount
-
upperBounds
java.util.Map<java.lang.Integer,java.nio.ByteBuffer> upperBounds
-
valueCounts
java.util.Map<java.lang.Integer,java.lang.Long> valueCounts
-
-
-
Class org.apache.iceberg.MetricsConfig extends java.lang.Object implements Serializable
-
Serialized Fields
-
columnModes
java.util.Map<java.lang.String,MetricsModes.MetricsMode> columnModes
-
defaultMode
MetricsModes.MetricsMode defaultMode
-
-
-
Class org.apache.iceberg.MetricsModes.Counts extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable
-
Class org.apache.iceberg.MetricsModes.Full extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable
-
Class org.apache.iceberg.MetricsModes.None extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable
-
Class org.apache.iceberg.MetricsModes.Truncate extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable
-
Serialized Fields
-
length
int length
-
-
-
Class org.apache.iceberg.PartitionData extends java.lang.Object implements Serializable
-
Serialized Fields
-
data
java.lang.Object[] data
-
partitionType
Types.StructType partitionType
-
size
int size
-
stringSchema
java.lang.String stringSchema
-
-
-
Class org.apache.iceberg.PartitionField extends java.lang.Object implements Serializable
-
Serialized Fields
-
fieldId
int fieldId
-
name
java.lang.String name
-
sourceId
int sourceId
-
transform
Transform<?,?> transform
-
-
-
Class org.apache.iceberg.PartitionKey extends org.apache.iceberg.StructTransform implements Serializable
-
Serialized Fields
-
inputSchema
Schema inputSchema
-
spec
PartitionSpec spec
-
-
-
Class org.apache.iceberg.PartitionSpec extends java.lang.Object implements Serializable
-
Serialized Fields
-
fields
PartitionField[] fields
-
lastAssignedFieldId
int lastAssignedFieldId
-
schema
Schema schema
-
specId
int specId
-
-
-
Class org.apache.iceberg.PartitionsTable extends BaseMetadataTable implements Serializable
-
Serialized Fields
-
schema
Schema schema
-
unpartitionedTable
boolean unpartitionedTable
-
-
-
Class org.apache.iceberg.PositionDeletesTable extends BaseMetadataTable implements Serializable
-
Serialized Fields
-
defaultSpecId
int defaultSpecId
-
schema
Schema schema
-
specs
java.util.Map<java.lang.Integer,PartitionSpec> specs
-
-
-
Class org.apache.iceberg.RefsTable extends BaseMetadataTable implements Serializable
-
Class org.apache.iceberg.Schema extends java.lang.Object implements Serializable
-
Serialized Fields
-
highestFieldId
int highestFieldId
-
identifierFieldIds
int[] identifierFieldIds
-
schemaId
int schemaId
-
struct
Types.StructType struct
-
-
-
Class org.apache.iceberg.SerializableTable extends java.lang.Object implements Serializable
-
Serialized Fields
-
defaultSpecId
int defaultSpecId
-
encryption
EncryptionManager encryption
-
io
FileIO io
-
location
java.lang.String location
-
metadataFileLocation
java.lang.String metadataFileLocation
-
name
java.lang.String name
-
properties
java.util.Map<java.lang.String,java.lang.String> properties
-
refs
java.util.Map<java.lang.String,SnapshotRef> refs
-
schemaAsJson
java.lang.String schemaAsJson
-
sortOrderAsJson
java.lang.String sortOrderAsJson
-
specAsJsonMap
java.util.Map<java.lang.Integer,java.lang.String> specAsJsonMap
-
uuid
java.util.UUID uuid
-
-
-
Class org.apache.iceberg.SerializableTable.SerializableMetadataTable extends SerializableTable implements Serializable
-
Serialized Fields
-
baseTableName
java.lang.String baseTableName
-
type
MetadataTableType type
-
-
-
Class org.apache.iceberg.SnapshotRef extends java.lang.Object implements Serializable
-
Serialized Fields
-
maxRefAgeMs
java.lang.Long maxRefAgeMs
-
maxSnapshotAgeMs
java.lang.Long maxSnapshotAgeMs
-
minSnapshotsToKeep
java.lang.Integer minSnapshotsToKeep
-
snapshotId
long snapshotId
-
type
org.apache.iceberg.SnapshotRefType type
-
-
-
Class org.apache.iceberg.SnapshotsTable extends BaseMetadataTable implements Serializable
-
Class org.apache.iceberg.SortField extends java.lang.Object implements Serializable
-
Serialized Fields
-
direction
SortDirection direction
-
nullOrder
NullOrder nullOrder
-
sourceId
int sourceId
-
transform
Transform<?,?> transform
-
-
-
Class org.apache.iceberg.SortKey extends org.apache.iceberg.StructTransform implements Serializable
-
Class org.apache.iceberg.SortOrder extends java.lang.Object implements Serializable
-
Class org.apache.iceberg.TableMetadata extends java.lang.Object implements Serializable
-
Serialized Fields
-
changes
java.util.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
java.lang.String location
-
metadataFileLocation
java.lang.String metadataFileLocation
-
partitionStatisticsFiles
java.util.List<PartitionStatisticsFile> partitionStatisticsFiles
-
previousFiles
java.util.List<TableMetadata.MetadataLogEntry> previousFiles
-
properties
java.util.Map<java.lang.String,java.lang.String> properties
-
refs
java.util.Map<java.lang.String,SnapshotRef> refs
-
schemas
java.util.List<Schema> schemas
-
schemasById
java.util.Map<java.lang.Integer,Schema> schemasById
-
snapshotLog
java.util.List<HistoryEntry> snapshotLog
-
snapshots
java.util.List<Snapshot> snapshots
-
snapshotsById
java.util.Map<java.lang.Long,Snapshot> snapshotsById
-
snapshotsLoaded
boolean snapshotsLoaded
-
snapshotsSupplier
SerializableSupplier<java.util.List<Snapshot>> snapshotsSupplier
-
sortOrders
java.util.List<SortOrder> sortOrders
-
sortOrdersById
java.util.Map<java.lang.Integer,SortOrder> sortOrdersById
-
specs
java.util.List<PartitionSpec> specs
-
specsById
java.util.Map<java.lang.Integer,PartitionSpec> specsById
-
statisticsFiles
java.util.List<StatisticsFile> statisticsFiles
-
uuid
java.lang.String uuid
-
-
-
Class org.apache.iceberg.TableMetadata.SnapshotLogEntry extends java.lang.Object implements Serializable
-
Serialized Fields
-
snapshotId
long snapshotId
-
timestampMillis
long timestampMillis
-
-
-
-
Package org.apache.iceberg.aliyun
-
Class org.apache.iceberg.aliyun.AliyunProperties extends java.lang.Object implements Serializable
-
Serialized Fields
-
accessKeyId
java.lang.String accessKeyId
-
accessKeySecret
java.lang.String accessKeySecret
-
ossEndpoint
java.lang.String ossEndpoint
-
ossStagingDirectory
java.lang.String ossStagingDirectory
-
securityToken
java.lang.String securityToken
-
-
-
-
Package org.apache.iceberg.aliyun.oss
-
Class org.apache.iceberg.aliyun.oss.OSSFileIO extends java.lang.Object implements Serializable
-
Serialized Fields
-
aliyunProperties
AliyunProperties aliyunProperties
-
isResourceClosed
java.util.concurrent.atomic.AtomicBoolean isResourceClosed
-
metrics
MetricsContext metrics
-
oss
SerializableSupplier<com.aliyun.oss.OSS> oss
-
-
-
-
Package org.apache.iceberg.avro
-
Class org.apache.iceberg.avro.SupportsIndexProjection extends java.lang.Object implements Serializable
-
Serialized Fields
-
fromProjectionPos
int[] fromProjectionPos
-
-
-
-
Package org.apache.iceberg.aws
-
Class org.apache.iceberg.aws.AssumeRoleAwsClientFactory extends java.lang.Object implements Serializable
-
Serialized Fields
-
awsProperties
AwsProperties awsProperties
-
httpClientProperties
HttpClientProperties httpClientProperties
-
roleSessionName
java.lang.String roleSessionName
-
s3FileIOProperties
S3FileIOProperties s3FileIOProperties
-
-
-
Class org.apache.iceberg.aws.AwsClientProperties extends java.lang.Object implements Serializable
-
Serialized Fields
-
clientCredentialsProvider
java.lang.String clientCredentialsProvider
-
clientCredentialsProviderProperties
java.util.Map<java.lang.String,java.lang.String> clientCredentialsProviderProperties
-
clientRegion
java.lang.String clientRegion
-
refreshCredentialsEnabled
boolean refreshCredentialsEnabled
-
refreshCredentialsEndpoint
java.lang.String refreshCredentialsEndpoint
-
-
-
Class org.apache.iceberg.aws.AwsProperties extends java.lang.Object implements Serializable
-
Serialized Fields
-
clientAssumeRoleArn
java.lang.String clientAssumeRoleArn
-
clientAssumeRoleExternalId
java.lang.String clientAssumeRoleExternalId
-
clientAssumeRoleRegion
java.lang.String clientAssumeRoleRegion
-
clientAssumeRoleSessionName
java.lang.String clientAssumeRoleSessionName
-
clientAssumeRoleTimeoutSec
int clientAssumeRoleTimeoutSec
-
clientCredentialsProvider
java.lang.String clientCredentialsProvider
-
clientCredentialsProviderProperties
java.util.Map<java.lang.String,java.lang.String> clientCredentialsProviderProperties
-
dynamoDbEndpoint
java.lang.String dynamoDbEndpoint
-
dynamoDbTableName
java.lang.String dynamoDbTableName
-
glueCatalogId
java.lang.String glueCatalogId
-
glueCatalogSkipArchive
boolean glueCatalogSkipArchive
-
glueCatalogSkipNameValidation
boolean glueCatalogSkipNameValidation
-
glueEndpoint
java.lang.String glueEndpoint
-
glueLakeFormationEnabled
boolean glueLakeFormationEnabled
-
restAccessKeyId
java.lang.String restAccessKeyId
-
restSecretAccessKey
java.lang.String restSecretAccessKey
-
restSessionToken
java.lang.String restSessionToken
-
restSigningName
java.lang.String restSigningName
-
restSigningRegion
java.lang.String restSigningRegion
-
stsClientAssumeRoleTags
java.util.Set<software.amazon.awssdk.services.sts.model.Tag> stsClientAssumeRoleTags
-
-
-
Class org.apache.iceberg.aws.HttpClientProperties extends java.lang.Object implements Serializable
-
Serialized Fields
-
httpClientProperties
java.util.Map<java.lang.String,java.lang.String> httpClientProperties
-
httpClientType
java.lang.String httpClientType
-
-
-
-
Package org.apache.iceberg.aws.lakeformation
-
Class org.apache.iceberg.aws.lakeformation.LakeFormationAwsClientFactory extends AssumeRoleAwsClientFactory implements Serializable
-
Serialized Fields
-
dbName
java.lang.String dbName
-
glueAccountId
java.lang.String glueAccountId
-
glueCatalogId
java.lang.String glueCatalogId
-
tableName
java.lang.String tableName
-
-
-
-
Package org.apache.iceberg.aws.s3
-
Class org.apache.iceberg.aws.s3.S3FileIO extends java.lang.Object implements Serializable
-
Serialized Fields
-
credential
java.lang.String credential
-
isResourceClosed
java.util.concurrent.atomic.AtomicBoolean isResourceClosed
-
metrics
MetricsContext metrics
-
properties
SerializableMap<java.lang.String,java.lang.String> properties
-
s3
SerializableSupplier<software.amazon.awssdk.services.s3.S3Client> s3
-
s3FileIOProperties
S3FileIOProperties s3FileIOProperties
-
-
-
Class org.apache.iceberg.aws.s3.S3FileIOProperties extends java.lang.Object implements Serializable
-
Serialized Fields
-
accessKeyId
java.lang.String accessKeyId
-
acl
software.amazon.awssdk.services.s3.model.ObjectCannedACL acl
-
allProperties
java.util.Map<java.lang.String,java.lang.String> allProperties
-
bucketToAccessPointMapping
java.util.Map<java.lang.String,java.lang.String> bucketToAccessPointMapping
-
deleteBatchSize
int deleteBatchSize
-
deleteTags
java.util.Set<software.amazon.awssdk.services.s3.model.Tag> deleteTags
-
deleteThreads
int deleteThreads
-
endpoint
java.lang.String endpoint
-
isAccelerationEnabled
boolean isAccelerationEnabled
-
isChecksumEnabled
boolean isChecksumEnabled
-
isCrossRegionAccessEnabled
boolean isCrossRegionAccessEnabled
-
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
-
s3DirectoryBucketListPrefixAsDirectory
boolean s3DirectoryBucketListPrefixAsDirectory
-
s3RetryMaxWaitMs
long s3RetryMaxWaitMs
-
s3RetryMinWaitMs
long s3RetryMinWaitMs
-
s3RetryNumRetries
int s3RetryNumRetries
-
secretAccessKey
java.lang.String secretAccessKey
-
sessionToken
java.lang.String sessionToken
-
sseKey
java.lang.String sseKey
-
sseMd5
java.lang.String sseMd5
-
sseType
java.lang.String sseType
-
stagingDirectory
java.lang.String stagingDirectory
-
writeStorageClass
java.lang.String writeStorageClass
-
writeTags
java.util.Set<software.amazon.awssdk.services.s3.model.Tag> writeTags
-
-
-
-
Package org.apache.iceberg.azure
-
Class org.apache.iceberg.azure.AzureProperties extends java.lang.Object implements Serializable
-
Serialized Fields
-
adlsConnectionStrings
java.util.Map<java.lang.String,java.lang.String> adlsConnectionStrings
-
adlsReadBlockSize
java.lang.Integer adlsReadBlockSize
-
adlsSasTokens
java.util.Map<java.lang.String,java.lang.String> adlsSasTokens
-
adlsWriteBlockSize
java.lang.Long adlsWriteBlockSize
-
namedKeyCreds
java.util.Map.Entry<java.lang.String,java.lang.String> namedKeyCreds
-
-
-
-
Package org.apache.iceberg.azure.adlsv2
-
Class org.apache.iceberg.azure.adlsv2.ADLSFileIO extends java.lang.Object implements Serializable
-
Serialized Fields
-
azureProperties
AzureProperties azureProperties
-
metrics
MetricsContext metrics
-
properties
SerializableMap<java.lang.String,java.lang.String> properties
-
-
-
-
Package org.apache.iceberg.connect.channel
-
Class org.apache.iceberg.connect.channel.NotRunningException extends java.lang.RuntimeException implements Serializable
-
-
Package org.apache.iceberg.dell
-
Class org.apache.iceberg.dell.DellProperties extends java.lang.Object implements Serializable
-
Serialized Fields
-
ecsS3AccessKeyId
java.lang.String ecsS3AccessKeyId
-
ecsS3Endpoint
java.lang.String ecsS3Endpoint
-
ecsS3SecretAccessKey
java.lang.String ecsS3SecretAccessKey
-
-
-
-
Package org.apache.iceberg.dell.ecs
-
Class org.apache.iceberg.dell.ecs.EcsFileIO extends java.lang.Object implements Serializable
-
Serialized Fields
-
dellClientFactory
DellClientFactory dellClientFactory
-
dellProperties
DellProperties dellProperties
-
isResourceClosed
java.util.concurrent.atomic.AtomicBoolean isResourceClosed
-
metrics
MetricsContext metrics
-
s3
SerializableSupplier<com.emc.object.s3.S3Client> s3
-
-
-
-
Package org.apache.iceberg.encryption
-
Class org.apache.iceberg.encryption.EncryptingFileIO extends java.lang.Object implements Serializable
-
Serialized Fields
-
em
EncryptionManager em
-
io
FileIO io
-
-
-
Class org.apache.iceberg.encryption.PlaintextEncryptionManager extends java.lang.Object implements Serializable
-
Class org.apache.iceberg.encryption.StandardEncryptionManager extends java.lang.Object implements Serializable
-
Serialized Fields
-
dataKeyLength
int dataKeyLength
-
tableKeyId
java.lang.String tableKeyId
-
-
-
-
Package org.apache.iceberg.exceptions
-
Class org.apache.iceberg.exceptions.AlreadyExistsException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.iceberg.exceptions.BadRequestException extends RESTException implements Serializable
-
Class org.apache.iceberg.exceptions.CherrypickAncestorCommitException extends ValidationException implements Serializable
-
Class org.apache.iceberg.exceptions.CommitFailedException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.iceberg.exceptions.CommitStateUnknownException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.iceberg.exceptions.DuplicateWAPCommitException extends ValidationException implements Serializable
-
Class org.apache.iceberg.exceptions.ForbiddenException extends RESTException implements Serializable
-
Class org.apache.iceberg.exceptions.NamespaceNotEmptyException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.iceberg.exceptions.NoSuchIcebergTableException extends NoSuchTableException implements Serializable
-
Class org.apache.iceberg.exceptions.NoSuchIcebergViewException extends NoSuchViewException implements Serializable
-
Class org.apache.iceberg.exceptions.NoSuchNamespaceException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.iceberg.exceptions.NoSuchTableException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.iceberg.exceptions.NoSuchViewException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.iceberg.exceptions.NotAuthorizedException extends RESTException implements Serializable
-
Class org.apache.iceberg.exceptions.NotFoundException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.iceberg.exceptions.RESTException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.iceberg.exceptions.RuntimeIOException extends java.io.UncheckedIOException implements Serializable
-
Class org.apache.iceberg.exceptions.ServiceFailureException extends RESTException implements Serializable
-
Class org.apache.iceberg.exceptions.ServiceUnavailableException extends RESTException implements Serializable
-
Class org.apache.iceberg.exceptions.UnprocessableEntityException extends RESTException implements Serializable
-
Class org.apache.iceberg.exceptions.ValidationException extends java.lang.RuntimeException implements Serializable
-
-
Package org.apache.iceberg.expressions
-
Class org.apache.iceberg.expressions.Aggregate extends java.lang.Object implements Serializable
-
Serialized Fields
-
op
Expression.Operation op
-
term
C extends Term term
-
-
-
Class org.apache.iceberg.expressions.And extends java.lang.Object implements Serializable
-
Serialized Fields
-
left
Expression left
-
right
Expression right
-
-
-
Class org.apache.iceberg.expressions.BoundAggregate extends Aggregate<BoundTerm<T>> implements Serializable
-
Class org.apache.iceberg.expressions.BoundLiteralPredicate extends BoundPredicate<T> implements Serializable
-
Class org.apache.iceberg.expressions.BoundPredicate extends Predicate<T,BoundTerm<T>> implements Serializable
-
Class org.apache.iceberg.expressions.BoundReference extends java.lang.Object implements Serializable
-
Serialized Fields
-
accessor
Accessor<StructLike> accessor
-
field
Types.NestedField field
-
name
java.lang.String name
-
-
-
Class org.apache.iceberg.expressions.BoundSetPredicate extends BoundPredicate<T> implements Serializable
-
Serialized Fields
-
literalSet
java.util.Set<T> literalSet
-
-
-
Class org.apache.iceberg.expressions.BoundTransform extends java.lang.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 extends BoundPredicate<T> implements Serializable
-
Class org.apache.iceberg.expressions.CountAggregate extends BoundAggregate<T,java.lang.Long> implements Serializable
-
Class org.apache.iceberg.expressions.CountNonNull extends CountAggregate<T> implements Serializable
-
Serialized Fields
-
field
Types.NestedField field
-
fieldId
int fieldId
-
-
-
Class org.apache.iceberg.expressions.CountStar extends CountAggregate<T> implements Serializable
-
Class org.apache.iceberg.expressions.Evaluator extends java.lang.Object implements Serializable
-
Serialized Fields
-
expr
Expression expr
-
-
-
Class org.apache.iceberg.expressions.False extends java.lang.Object implements Serializable
-
Serialization Methods
-
writeReplace
java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
-
Class org.apache.iceberg.expressions.MaxAggregate extends org.apache.iceberg.expressions.ValueAggregate<T> implements Serializable
-
Serialized Fields
-
comparator
java.util.Comparator<T> comparator
-
fieldId
int fieldId
-
type
Type.PrimitiveType type
-
-
-
Class org.apache.iceberg.expressions.MinAggregate extends org.apache.iceberg.expressions.ValueAggregate<T> implements Serializable
-
Serialized Fields
-
comparator
java.util.Comparator<T> comparator
-
fieldId
int fieldId
-
type
Type.PrimitiveType type
-
-
-
Class org.apache.iceberg.expressions.NamedReference extends java.lang.Object implements Serializable
-
Serialized Fields
-
name
java.lang.String name
-
-
-
Class org.apache.iceberg.expressions.Not extends java.lang.Object implements Serializable
-
Serialized Fields
-
child
Expression child
-
-
-
Class org.apache.iceberg.expressions.Or extends java.lang.Object implements Serializable
-
Serialized Fields
-
left
Expression left
-
right
Expression right
-
-
-
Class org.apache.iceberg.expressions.Predicate extends java.lang.Object implements Serializable
-
Serialized Fields
-
op
Expression.Operation op
-
term
C extends Term term
-
-
-
Class org.apache.iceberg.expressions.ResidualEvaluator extends java.lang.Object implements Serializable
-
Serialized Fields
-
caseSensitive
boolean caseSensitive
-
expr
Expression expr
-
spec
PartitionSpec spec
-
-
-
Class org.apache.iceberg.expressions.True extends java.lang.Object implements Serializable
-
Serialization Methods
-
writeReplace
java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
-
Class org.apache.iceberg.expressions.UnboundAggregate extends Aggregate<UnboundTerm<T>> implements Serializable
-
Class org.apache.iceberg.expressions.UnboundPredicate extends Predicate<T,UnboundTerm<T>> implements Serializable
-
Class org.apache.iceberg.expressions.UnboundTransform extends java.lang.Object implements Serializable
-
Serialized Fields
-
ref
NamedReference<S> ref
-
transform
Transform<S,T> transform
-
-
-
Class org.apache.iceberg.expressions.Zorder extends java.lang.Object implements Serializable
-
Serialized Fields
-
refs
NamedReference<?>[] refs
-
-
-
-
Package org.apache.iceberg.flink
-
Class org.apache.iceberg.flink.CatalogLoader.CustomCatalogLoader extends java.lang.Object implements Serializable
-
Serialized Fields
-
hadoopConf
SerializableConfiguration hadoopConf
-
impl
java.lang.String impl
-
name
java.lang.String name
-
properties
java.util.Map<java.lang.String,java.lang.String> properties
-
-
-
Class org.apache.iceberg.flink.CatalogLoader.HadoopCatalogLoader extends java.lang.Object implements Serializable
-
Serialized Fields
-
catalogName
java.lang.String catalogName
-
hadoopConf
SerializableConfiguration hadoopConf
-
properties
java.util.Map<java.lang.String,java.lang.String> properties
-
warehouseLocation
java.lang.String warehouseLocation
-
-
-
Class org.apache.iceberg.flink.CatalogLoader.HiveCatalogLoader extends java.lang.Object implements Serializable
-
Serialized Fields
-
catalogName
java.lang.String catalogName
-
clientPoolSize
int clientPoolSize
-
hadoopConf
SerializableConfiguration hadoopConf
-
properties
java.util.Map<java.lang.String,java.lang.String> properties
-
uri
java.lang.String uri
-
warehouse
java.lang.String warehouse
-
-
-
Class org.apache.iceberg.flink.CatalogLoader.RESTCatalogLoader extends java.lang.Object implements Serializable
-
Serialized Fields
-
catalogName
java.lang.String catalogName
-
hadoopConf
SerializableConfiguration hadoopConf
-
properties
java.util.Map<java.lang.String,java.lang.String> properties
-
-
-
Class org.apache.iceberg.flink.FlinkSourceFilter extends java.lang.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 extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
catalogLoader
CatalogLoader catalogLoader
-
identifier
java.lang.String identifier
-
-
Class org.apache.iceberg.flink.TableLoader.HadoopTableLoader extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
hadoopConf
SerializableConfiguration hadoopConf
-
location
java.lang.String location
-
-
-
Package org.apache.iceberg.flink.maintenance.operator
-
Class org.apache.iceberg.flink.maintenance.operator.JdbcLockFactory extends java.lang.Object implements Serializable
-
Serialized Fields
-
lockId
java.lang.String lockId
-
properties
java.util.Map<java.lang.String,java.lang.String> properties
-
uri
java.lang.String uri
-
-
-
Class org.apache.iceberg.flink.maintenance.operator.LockRemover extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<java.lang.Void> implements Serializable
-
Serialized Fields
-
lockFactory
TriggerLockFactory lockFactory
-
maintenanceTaskNames
java.util.List<java.lang.String> maintenanceTaskNames
-
-
-
Class org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource extends java.lang.Object implements Serializable
-
-
Package org.apache.iceberg.flink.sink
-
Class org.apache.iceberg.flink.sink.AvroGenericRecordToRowDataMapper extends java.lang.Object implements Serializable
-
Serialized Fields
-
converter
org.apache.flink.formats.avro.AvroToRowDataConverters.AvroToRowDataConverter converter
-
-
-
Class org.apache.iceberg.flink.sink.FlinkAppenderFactory extends java.lang.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
java.util.Map<java.lang.String,java.lang.String> props
-
schema
Schema schema
-
spec
PartitionSpec spec
-
table
Table table
-
-
-
Class org.apache.iceberg.flink.sink.FlinkWriteResult extends java.lang.Object implements Serializable
-
Serialized Fields
-
checkpointId
long checkpointId
-
writeResult
WriteResult writeResult
-
-
-
Class org.apache.iceberg.flink.sink.IcebergSink extends java.lang.Object implements Serializable
-
Serialized Fields
-
branch
java.lang.String branch
-
dataFileFormat
FileFormat dataFileFormat
-
equalityFieldColumns
java.util.List<java.lang.String> equalityFieldColumns
-
equalityFieldIds
java.util.List<java.lang.Integer> equalityFieldIds
-
flinkRowType
org.apache.flink.table.types.logical.RowType flinkRowType
-
overwriteMode
boolean overwriteMode
-
sinkId
java.lang.String sinkId
-
snapshotProperties
java.util.Map<java.lang.String,java.lang.String> snapshotProperties
-
table
Table table
-
tableLoader
TableLoader tableLoader
-
tableSupplier
SerializableSupplier<Table> tableSupplier
-
targetDataFileSize
long targetDataFileSize
-
uidSuffix
java.lang.String uidSuffix
-
upsertMode
boolean upsertMode
-
workerPoolSize
int workerPoolSize
-
writeProperties
java.util.Map<java.lang.String,java.lang.String> writeProperties
-
-
-
Class org.apache.iceberg.flink.sink.RowDataTaskWriterFactory extends java.lang.Object implements Serializable
-
Serialized Fields
-
appenderFactory
FileAppenderFactory<org.apache.flink.table.data.RowData> appenderFactory
-
equalityFieldIds
java.util.List<java.lang.Integer> equalityFieldIds
-
flinkSchema
org.apache.flink.table.types.logical.RowType flinkSchema
-
format
FileFormat format
-
schema
Schema schema
-
spec
PartitionSpec spec
-
tableSupplier
java.util.function.Supplier<Table> tableSupplier
-
targetFileSizeBytes
long targetFileSizeBytes
-
upsert
boolean upsert
-
-
-
-
Package org.apache.iceberg.flink.sink.shuffle
-
Class org.apache.iceberg.flink.sink.shuffle.DataStatisticsCoordinatorProvider extends org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.Provider implements Serializable
-
Serialized Fields
-
closeFileCostWeightPercentage
double closeFileCostWeightPercentage
-
downstreamParallelism
int downstreamParallelism
-
operatorName
java.lang.String operatorName
-
schema
Schema schema
-
sortOrder
SortOrder sortOrder
-
type
StatisticsType type
-
-
-
Class org.apache.iceberg.flink.sink.shuffle.DataStatisticsOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<StatisticsOrRecord> implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
downstreamParallelism
int downstreamParallelism
-
globalStatisticsSerializer
org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.iceberg.flink.sink.shuffle.GlobalStatistics> globalStatisticsSerializer
-
operatorEventGateway
org.apache.flink.runtime.operators.coordination.OperatorEventGateway operatorEventGateway
-
operatorName
java.lang.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.DataStatisticsOperatorFactory extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<StatisticsOrRecord> implements Serializable
-
Serialized Fields
-
closeFileCostWeightPercentage
double closeFileCostWeightPercentage
-
downstreamParallelism
int downstreamParallelism
-
schema
Schema schema
-
sortOrder
SortOrder sortOrder
-
type
StatisticsType type
-
-
-
Class org.apache.iceberg.flink.sink.shuffle.RangePartitioner extends java.lang.Object implements Serializable
-
Class org.apache.iceberg.flink.sink.shuffle.StatisticsOrRecord extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
record
org.apache.flink.table.data.RowData record
-
statistics
org.apache.iceberg.flink.sink.shuffle.GlobalStatistics statistics
-
-
-
Package org.apache.iceberg.flink.source
-
Class org.apache.iceberg.flink.source.AvroGenericRecordFileScanTaskReader extends java.lang.Object implements Serializable
-
Serialized Fields
-
converter
RowDataToAvroGenericRecordConverter converter
-
rowDataReader
RowDataFileScanTaskReader rowDataReader
-
-
-
Class org.apache.iceberg.flink.source.DataTaskReader extends java.lang.Object implements Serializable
-
Serialized Fields
-
readSchema
Schema readSchema
-
-
-
Class org.apache.iceberg.flink.source.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 extends org.apache.flink.core.io.LocatableInputSplit implements Serializable
-
Serialized Fields
-
task
CombinedScanTask task
-
-
-
Class org.apache.iceberg.flink.source.IcebergSource extends java.lang.Object implements Serializable
-
Serialized Fields
-
assignerFactory
SplitAssignerFactory assignerFactory
-
batchSplits
java.util.List<IcebergSourceSplit> batchSplits
-
emitter
SerializableRecordEmitter<T> emitter
-
readerFunction
ReaderFunction<T> readerFunction
-
scanContext
ScanContext scanContext
-
splitComparator
SerializableComparator<IcebergSourceSplit> splitComparator
-
tableLoader
TableLoader tableLoader
-
tableName
java.lang.String tableName
-
-
-
Class org.apache.iceberg.flink.source.RowDataFileScanTaskReader extends java.lang.Object implements Serializable
-
Serialized Fields
-
caseSensitive
boolean caseSensitive
-
nameMapping
java.lang.String nameMapping
-
projectedSchema
Schema projectedSchema
-
rowFilter
FlinkSourceFilter rowFilter
-
tableSchema
Schema tableSchema
-
-
-
Class org.apache.iceberg.flink.source.RowDataRewriter.RewriteMap extends org.apache.flink.api.common.functions.RichMapFunction<CombinedScanTask,java.util.List<DataFile>> implements Serializable
-
Serialized Fields
-
attemptId
int attemptId
-
encryptionManager
EncryptionManager encryptionManager
-
io
FileIO io
-
rowDataReader
RowDataFileScanTaskReader rowDataReader
-
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 extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
asOfTimestamp
java.lang.Long asOfTimestamp
-
branch
java.lang.String branch
-
caseSensitive
boolean caseSensitive
-
endSnapshotId
java.lang.Long endSnapshotId
-
endTag
java.lang.String endTag
-
exposeLocality
boolean exposeLocality
-
filters
java.util.List<Expression> filters
-
includeColumnStats
boolean includeColumnStats
-
includeStatsForColumns
java.util.Collection<java.lang.String> includeStatsForColumns
-
isStreaming
boolean isStreaming
-
limit
long limit
-
maxAllowedPlanningFailures
int maxAllowedPlanningFailures
-
maxPlanningSnapshotCount
int maxPlanningSnapshotCount
-
monitorInterval
java.time.Duration monitorInterval
-
nameMapping
java.lang.String nameMapping
-
planParallelism
java.lang.Integer planParallelism
-
schema
Schema schema
-
snapshotId
java.lang.Long snapshotId
-
splitLookback
java.lang.Integer splitLookback
-
splitOpenFileCost
java.lang.Long splitOpenFileCost
-
splitSize
java.lang.Long splitSize
-
startingStrategy
StreamingStartingStrategy startingStrategy
-
startSnapshotId
java.lang.Long startSnapshotId
-
startSnapshotTimestamp
java.lang.Long startSnapshotTimestamp
-
startTag
java.lang.String startTag
-
tag
java.lang.String tag
-
watermarkColumn
java.lang.String watermarkColumn
-
watermarkColumnTimeUnit
java.util.concurrent.TimeUnit watermarkColumnTimeUnit
-
-
Class org.apache.iceberg.flink.source.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 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 extends java.lang.Object implements Serializable
-
Serialized Fields
-
comparator
SerializableComparator<IcebergSourceSplit> comparator
-
-
-
Class org.apache.iceberg.flink.source.assigner.SimpleSplitAssignerFactory extends java.lang.Object implements Serializable
-
-
Package org.apache.iceberg.flink.source.enumerator
-
Class org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorState extends java.lang.Object implements Serializable
-
Serialized Fields
-
enumerationSplitCountHistory
int[] enumerationSplitCountHistory
-
lastEnumeratedPosition
org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastEnumeratedPosition
-
pendingSplits
java.util.Collection<IcebergSourceSplitState> pendingSplits
-
-
-
-
Package org.apache.iceberg.flink.source.reader
-
Class org.apache.iceberg.flink.source.reader.AvroGenericRecordConverter extends java.lang.Object implements Serializable
-
Serialized Fields
-
avroSchema
org.apache.avro.Schema avroSchema
-
flinkConverter
org.apache.flink.formats.avro.RowDataToAvroConverters.RowDataToAvroConverter flinkConverter
-
outputTypeInfo
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.avro.generic.GenericRecord> outputTypeInfo
-
-
-
Class org.apache.iceberg.flink.source.reader.AvroGenericRecordReaderFunction extends DataIteratorReaderFunction<org.apache.avro.generic.GenericRecord> implements Serializable
-
Serialized Fields
-
encryption
EncryptionManager encryption
Deprecated. -
io
FileIO io
Deprecated. -
readSchema
Schema readSchema
Deprecated. -
rowDataReader
RowDataFileScanTaskReader rowDataReader
Deprecated. -
tableName
java.lang.String tableName
Deprecated.
-
-
-
Class org.apache.iceberg.flink.source.reader.ColumnStatsWatermarkExtractor extends java.lang.Object implements Serializable
-
Serialized Fields
-
eventTimeFieldId
int eventTimeFieldId
-
eventTimeFieldName
java.lang.String eventTimeFieldName
-
timeUnit
java.util.concurrent.TimeUnit timeUnit
-
-
-
Class org.apache.iceberg.flink.source.reader.ConverterReaderFunction extends DataIteratorReaderFunction<T> implements Serializable
-
Serialized Fields
-
caseSensitive
boolean caseSensitive
-
converter
RowDataConverter<T> converter
-
encryption
EncryptionManager encryption
-
filters
java.util.List<Expression> filters
-
io
FileIO io
-
limit
long limit
-
nameMapping
java.lang.String nameMapping
-
readSchema
Schema readSchema
-
tableSchema
Schema tableSchema
-
-
-
Class org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction extends java.lang.Object implements Serializable
-
Serialized Fields
-
batcher
DataIteratorBatcher<T> batcher
-
-
-
Class org.apache.iceberg.flink.source.reader.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 extends DataIteratorReaderFunction<org.apache.flink.table.data.RowData> implements Serializable
-
Serialized Fields
-
caseSensitive
boolean caseSensitive
-
encryption
EncryptionManager encryption
-
filters
java.util.List<Expression> filters
-
io
FileIO io
-
limit
long limit
-
nameMapping
java.lang.String nameMapping
-
readSchema
Schema readSchema
-
tableSchema
Schema tableSchema
-
-
-
-
Package org.apache.iceberg.flink.source.split
-
Class org.apache.iceberg.flink.source.split.IcebergSourceSplit extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
fileOffset
int fileOffset
-
recordOffset
long recordOffset
-
task
CombinedScanTask task
-
-
Class org.apache.iceberg.flink.source.split.SplitRequestEvent extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
finishedSplitIds
java.util.Collection<java.lang.String> finishedSplitIds
-
requesterHostname
java.lang.String requesterHostname
-
-
-
Package org.apache.iceberg.gcp
-
Class org.apache.iceberg.gcp.GCPProperties extends java.lang.Object implements Serializable
-
Serialized Fields
-
clientLibToken
java.lang.String clientLibToken
-
gcsChannelReadChunkSize
java.lang.Integer gcsChannelReadChunkSize
-
gcsChannelWriteChunkSize
java.lang.Integer gcsChannelWriteChunkSize
-
gcsDecryptionKey
java.lang.String gcsDecryptionKey
-
gcsDeleteBatchSize
int gcsDeleteBatchSize
-
gcsEncryptionKey
java.lang.String gcsEncryptionKey
-
gcsNoAuth
boolean gcsNoAuth
-
gcsOauth2RefreshCredentialsEnabled
boolean gcsOauth2RefreshCredentialsEnabled
-
gcsOauth2RefreshCredentialsEndpoint
java.lang.String gcsOauth2RefreshCredentialsEndpoint
-
gcsOAuth2Token
java.lang.String gcsOAuth2Token
-
gcsOAuth2TokenExpiresAt
java.util.Date gcsOAuth2TokenExpiresAt
-
gcsUserProject
java.lang.String gcsUserProject
-
projectId
java.lang.String projectId
-
serviceHost
java.lang.String serviceHost
-
-
-
-
Package org.apache.iceberg.gcp.gcs
-
Class org.apache.iceberg.gcp.gcs.GCSFileIO extends java.lang.Object implements Serializable
-
Serialized Fields
-
gcpProperties
GCPProperties gcpProperties
-
isResourceClosed
java.util.concurrent.atomic.AtomicBoolean isResourceClosed
-
metrics
MetricsContext metrics
-
properties
SerializableMap<java.lang.String,java.lang.String> properties
-
storageSupplier
SerializableSupplier<com.google.cloud.storage.Storage> storageSupplier
-
-
-
-
Package org.apache.iceberg.hadoop
-
Class org.apache.iceberg.hadoop.HadoopFileIO extends java.lang.Object implements Serializable
-
Serialized Fields
-
hadoopConf
SerializableSupplier<org.apache.hadoop.conf.Configuration> hadoopConf
-
properties
SerializableMap<java.lang.String,java.lang.String> properties
-
-
-
Class org.apache.iceberg.hadoop.HadoopMetricsContext extends java.lang.Object implements Serializable
-
Serialized Fields
-
scheme
java.lang.String scheme
-
-
-
Class org.apache.iceberg.hadoop.HiddenPathFilter extends java.lang.Object implements Serializable
-
Class org.apache.iceberg.hadoop.SerializableConfiguration extends java.lang.Object implements Serializable
-
Serialization Methods
-
readObject
private void readObject(java.io.ObjectInputStream in) throws java.lang.ClassNotFoundException, java.io.IOException
- Throws:
java.lang.ClassNotFoundException
java.io.IOException
-
writeObject
private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException
- Throws:
java.io.IOException
-
-
-
-
Package org.apache.iceberg.hive
-
Class org.apache.iceberg.hive.RuntimeMetaException extends java.lang.RuntimeException implements Serializable
-
-
Package org.apache.iceberg.inmemory
-
Class org.apache.iceberg.inmemory.InMemoryFileIO extends java.lang.Object implements Serializable
-
Serialized Fields
-
closed
boolean closed
-
-
-
-
Package org.apache.iceberg.io
-
Class org.apache.iceberg.io.BulkDeletionFailureException extends java.lang.RuntimeException implements Serializable
-
Serialized Fields
-
numberFailedObjects
int numberFailedObjects
-
-
-
Class org.apache.iceberg.io.ResolvingFileIO extends java.lang.Object implements Serializable
-
Serialized Fields
-
hadoopConf
SerializableSupplier<org.apache.hadoop.conf.Configuration> hadoopConf
-
ioInstances
java.util.Map<java.lang.String,DelegateFileIO> ioInstances
-
isClosed
java.util.concurrent.atomic.AtomicBoolean isClosed
-
properties
SerializableMap<java.lang.String,java.lang.String> properties
-
-
-
Class org.apache.iceberg.io.WriteResult extends java.lang.Object implements Serializable
-
Serialized Fields
-
dataFiles
DataFile[] dataFiles
-
deleteFiles
DeleteFile[] deleteFiles
-
referencedDataFiles
java.lang.CharSequence[] referencedDataFiles
-
rewrittenDeleteFiles
DeleteFile[] rewrittenDeleteFiles
-
-
-
-
Package org.apache.iceberg.jdbc
-
Class org.apache.iceberg.jdbc.UncheckedInterruptedException extends java.lang.RuntimeException implements Serializable
-
Class org.apache.iceberg.jdbc.UncheckedSQLException extends java.lang.RuntimeException implements Serializable
-
-
Package org.apache.iceberg.mapping
-
Class org.apache.iceberg.mapping.MappedField extends java.lang.Object implements Serializable
-
Serialized Fields
-
id
java.lang.Integer id
-
names
java.util.Set<java.lang.String> names
-
nestedMapping
MappedFields nestedMapping
-
-
-
Class org.apache.iceberg.mapping.MappedFields extends java.lang.Object implements Serializable
-
Serialized Fields
-
fields
java.util.List<MappedField> fields
-
-
-
Class org.apache.iceberg.mapping.NameMapping extends java.lang.Object implements Serializable
-
Serialized Fields
-
mapping
MappedFields mapping
-
-
-
-
Package org.apache.iceberg.metrics
-
Class org.apache.iceberg.metrics.DefaultMetricsContext extends java.lang.Object implements Serializable
-
-
Package org.apache.iceberg.spark
-
Class org.apache.iceberg.spark.SparkTableUtil.SparkPartition extends java.lang.Object implements Serializable
-
Serialized Fields
-
format
java.lang.String format
-
uri
java.lang.String uri
-
values
java.util.Map<java.lang.String,java.lang.String> values
-
-
-
-
Package org.apache.iceberg.spark.actions
-
Class org.apache.iceberg.spark.actions.ManifestFileBean extends java.lang.Object implements Serializable
-
Serialized Fields
-
addedSnapshotId
java.lang.Long addedSnapshotId
-
content
java.lang.Integer content
-
length
java.lang.Long length
-
partitionSpecId
java.lang.Integer partitionSpecId
-
path
java.lang.String path
-
sequenceNumber
java.lang.Long sequenceNumber
-
-
-
Class org.apache.iceberg.spark.actions.SetAccumulator extends org.apache.spark.util.AccumulatorV2<T,java.util.Set<T>> implements Serializable
-
Serialized Fields
-
set
java.util.Set<T> set
-
-
-
-
Package org.apache.iceberg.spark.functions
-
Class org.apache.iceberg.spark.functions.BucketFunction extends java.lang.Object implements Serializable
-
Class org.apache.iceberg.spark.functions.BucketFunction.BucketBase extends org.apache.iceberg.spark.functions.BaseScalarFunction<java.lang.Integer> implements Serializable
-
Class org.apache.iceberg.spark.functions.BucketFunction.BucketBinary extends BucketFunction.BucketBase implements Serializable
-
Class org.apache.iceberg.spark.functions.BucketFunction.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 extends BucketFunction.BucketBase implements Serializable
-
Serialized Fields
-
sqlType
org.apache.spark.sql.types.DataType sqlType
-
-
-
Class org.apache.iceberg.spark.functions.BucketFunction.BucketLong extends BucketFunction.BucketBase implements Serializable
-
Serialized Fields
-
sqlType
org.apache.spark.sql.types.DataType sqlType
-
-
-
Class org.apache.iceberg.spark.functions.BucketFunction.BucketString extends BucketFunction.BucketBase implements Serializable
-
Class org.apache.iceberg.spark.functions.DaysFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.DaysFunction.DateToDaysFunction extends org.apache.iceberg.spark.functions.DaysFunction.BaseToDaysFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.DaysFunction.TimestampNtzToDaysFunction extends org.apache.iceberg.spark.functions.DaysFunction.BaseToDaysFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.DaysFunction.TimestampToDaysFunction extends org.apache.iceberg.spark.functions.DaysFunction.BaseToDaysFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.HoursFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.HoursFunction.TimestampNtzToHoursFunction extends org.apache.iceberg.spark.functions.BaseScalarFunction<java.lang.Integer> implements Serializable
-
Class org.apache.iceberg.spark.functions.HoursFunction.TimestampToHoursFunction extends org.apache.iceberg.spark.functions.BaseScalarFunction<java.lang.Integer> implements Serializable
-
Class org.apache.iceberg.spark.functions.IcebergVersionFunction extends java.lang.Object implements Serializable
-
Class org.apache.iceberg.spark.functions.MonthsFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.MonthsFunction.DateToMonthsFunction extends org.apache.iceberg.spark.functions.MonthsFunction.BaseToMonthsFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.MonthsFunction.TimestampNtzToMonthsFunction extends org.apache.iceberg.spark.functions.MonthsFunction.BaseToMonthsFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.MonthsFunction.TimestampToMonthsFunction extends org.apache.iceberg.spark.functions.MonthsFunction.BaseToMonthsFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.TruncateFunction extends java.lang.Object implements Serializable
-
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateBase extends org.apache.iceberg.spark.functions.BaseScalarFunction<T> implements Serializable
-
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateBigInt extends TruncateFunction.TruncateBase<java.lang.Long> implements Serializable
-
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateBinary extends TruncateFunction.TruncateBase<byte[]> implements Serializable
-
Class org.apache.iceberg.spark.functions.TruncateFunction.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 extends TruncateFunction.TruncateBase<java.lang.Integer> implements Serializable
-
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateSmallInt extends TruncateFunction.TruncateBase<java.lang.Short> implements Serializable
-
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateString extends TruncateFunction.TruncateBase<org.apache.spark.unsafe.types.UTF8String> implements Serializable
-
Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateTinyInt extends TruncateFunction.TruncateBase<java.lang.Byte> implements Serializable
-
Class org.apache.iceberg.spark.functions.YearsFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.YearsFunction.DateToYearsFunction extends org.apache.iceberg.spark.functions.YearsFunction.BaseToYearsFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.YearsFunction.TimestampNtzToYearsFunction extends org.apache.iceberg.spark.functions.YearsFunction.BaseToYearsFunction implements Serializable
-
Class org.apache.iceberg.spark.functions.YearsFunction.TimestampToYearsFunction extends org.apache.iceberg.spark.functions.YearsFunction.BaseToYearsFunction implements Serializable
-
-
Package org.apache.iceberg.spark.source
-
Class org.apache.iceberg.spark.source.SerializableTableWithSize extends SerializableTable implements Serializable
-
Class org.apache.iceberg.spark.source.SerializableTableWithSize.SerializableMetadataTableWithSize extends SerializableTable.SerializableMetadataTable implements Serializable
-
Class org.apache.iceberg.spark.source.SparkPositionDeletesRewrite.DeleteTaskCommit extends java.lang.Object implements Serializable
-
Serialized Fields
-
taskFiles
DeleteFile[] taskFiles
-
-
-
Class org.apache.iceberg.spark.source.SparkPositionDeltaWrite.DeltaTaskCommit extends java.lang.Object implements Serializable
-
Serialized Fields
-
dataFiles
DataFile[] dataFiles
-
deleteFiles
DeleteFile[] deleteFiles
-
referencedDataFiles
java.lang.CharSequence[] referencedDataFiles
-
-
-
Class org.apache.iceberg.spark.source.SparkWrite.TaskCommit extends java.lang.Object implements Serializable
-
Serialized Fields
-
taskFiles
DataFile[] taskFiles
-
-
-
-
Package org.apache.iceberg.transforms
-
Class org.apache.iceberg.transforms.Days extends org.apache.iceberg.transforms.TimeTransform<T> implements Serializable
-
Serialization Methods
-
writeReplace
java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
-
Class org.apache.iceberg.transforms.Hours extends org.apache.iceberg.transforms.TimeTransform<T> implements Serializable
-
Serialization Methods
-
writeReplace
java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
-
Class org.apache.iceberg.transforms.Months extends org.apache.iceberg.transforms.TimeTransform<T> implements Serializable
-
Serialization Methods
-
writeReplace
java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
-
Class org.apache.iceberg.transforms.UnknownTransform extends java.lang.Object implements Serializable
-
Serialized Fields
-
transform
java.lang.String transform
-
-
-
-
Package org.apache.iceberg.types
-
Class org.apache.iceberg.types.Type.NestedType extends java.lang.Object implements Serializable
-
Class org.apache.iceberg.types.Type.PrimitiveType extends java.lang.Object implements Serializable
-
Serialization Methods
-
writeReplace
java.lang.Object writeReplace() throws java.io.ObjectStreamException
- Throws:
java.io.ObjectStreamException
-
-
-
Class org.apache.iceberg.types.Types.BinaryType extends Type.PrimitiveType implements Serializable
-
Class org.apache.iceberg.types.Types.BooleanType extends Type.PrimitiveType implements Serializable
-
Class org.apache.iceberg.types.Types.DateType extends Type.PrimitiveType implements Serializable
-
Class org.apache.iceberg.types.Types.DecimalType extends Type.PrimitiveType implements Serializable
-
Serialized Fields
-
precision
int precision
-
scale
int scale
-
-
-
Class org.apache.iceberg.types.Types.DoubleType extends Type.PrimitiveType implements Serializable
-
Class org.apache.iceberg.types.Types.FixedType extends Type.PrimitiveType implements Serializable
-
Serialized Fields
-
length
int length
-
-
-
Class org.apache.iceberg.types.Types.FloatType extends Type.PrimitiveType implements Serializable
-
Class org.apache.iceberg.types.Types.IntegerType extends Type.PrimitiveType implements Serializable
-
Class org.apache.iceberg.types.Types.ListType extends Type.NestedType implements Serializable
-
Serialized Fields
-
elementField
Types.NestedField elementField
-
-
-
Class org.apache.iceberg.types.Types.LongType extends Type.PrimitiveType implements Serializable
-
Class org.apache.iceberg.types.Types.MapType extends Type.NestedType implements Serializable
-
Serialized Fields
-
keyField
Types.NestedField keyField
-
valueField
Types.NestedField valueField
-
-
-
Class org.apache.iceberg.types.Types.NestedField extends java.lang.Object implements Serializable
-
Serialized Fields
-
doc
java.lang.String doc
-
id
int id
-
initialDefault
java.lang.Object initialDefault
-
isOptional
boolean isOptional
-
name
java.lang.String name
-
type
Type type
-
writeDefault
java.lang.Object writeDefault
-
-
-
Class org.apache.iceberg.types.Types.StringType extends Type.PrimitiveType implements Serializable
-
Class org.apache.iceberg.types.Types.StructType extends Type.NestedType implements Serializable
-
Serialized Fields
-
fields
Types.NestedField[] fields
-
-
-
Class org.apache.iceberg.types.Types.TimestampNanoType extends Type.PrimitiveType implements Serializable
-
Serialized Fields
-
adjustToUTC
boolean adjustToUTC
-
-
-
Class org.apache.iceberg.types.Types.TimestampType extends Type.PrimitiveType implements Serializable
-
Serialized Fields
-
adjustToUTC
boolean adjustToUTC
-
-
-
Class org.apache.iceberg.types.Types.TimeType extends Type.PrimitiveType implements Serializable
-
Class org.apache.iceberg.types.Types.UUIDType extends Type.PrimitiveType implements Serializable
-
-
Package org.apache.iceberg.util
-
Class org.apache.iceberg.util.CharSequenceMap extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
wrapperMap
java.util.Map<CharSequenceWrapper,V> wrapperMap
-
-
Class org.apache.iceberg.util.CharSequenceSet extends java.lang.Object implements Serializable
-
Serialized Fields
-
wrapperSet
java.util.Set<CharSequenceWrapper> wrapperSet
-
-
-
Class org.apache.iceberg.util.CharSequenceWrapper extends java.lang.Object implements Serializable
-
Serialized Fields
-
wrapped
java.lang.CharSequence wrapped
-
-
-
Class org.apache.iceberg.util.DataFileSet extends org.apache.iceberg.util.WrapperSet<DataFile> implements Serializable
-
Class org.apache.iceberg.util.DeleteFileSet extends org.apache.iceberg.util.WrapperSet<DeleteFile> implements Serializable
-
Class org.apache.iceberg.util.Pair extends java.lang.Object implements Serializable
-
Class org.apache.iceberg.util.SerializableMap extends java.lang.Object implements Serializable
- serialVersionUID:
- -3377238354349859240L
-
Class org.apache.iceberg.util.Tasks.UnrecoverableException extends java.lang.RuntimeException implements Serializable
-
-
Package org.apache.iceberg.view
-
Class org.apache.iceberg.view.BaseView extends java.lang.Object implements Serializable
-
Serialized Fields
-
name
java.lang.String name
-
ops
ViewOperations ops
-
-
-
-
Package org.apache.spark.sql.catalyst.analysis
-
Class org.apache.spark.sql.catalyst.analysis.AnalysisContext extends java.lang.Object implements Serializable
-
Serialized Fields
-
catalogAndNamespace
scala.collection.Seq<java.lang.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<java.lang.String> referredTempFunctionNames
-
referredTempViewNames
scala.collection.Seq<scala.collection.Seq<java.lang.String>> referredTempViewNames
-
relationCache
scala.collection.mutable.Map<scala.Tuple2<scala.collection.Seq<java.lang.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$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
Serialized Fields
-
value
java.lang.ThreadLocal<org.apache.spark.sql.catalyst.analysis.AnalysisContext> value
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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 extends java.lang.Object implements Serializable
-
Serialized Fields
-
timestamp
long timestamp
-
-
-
Class org.apache.spark.sql.catalyst.analysis.AsOfTimestamp$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.sql.catalyst.analysis.AsOfTimestamp> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.AsOfVersion extends java.lang.Object implements Serializable
-
Serialized Fields
-
version
java.lang.String version
-
-
-
Class org.apache.spark.sql.catalyst.analysis.AsOfVersion$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.sql.catalyst.analysis.AsOfVersion> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.CannotReplaceMissingTableException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.CannotReplaceMissingTableException$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.DatabaseAlreadyExistsException extends org.apache.spark.sql.catalyst.analysis.NamespaceAlreadyExistsException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.ExpressionWithUnresolvedIdentifier extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable
-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
exprBuilder
scala.Function1<scala.collection.Seq<java.lang.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$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.Function1<scala.collection.Seq<java.lang.String>,org.apache.spark.sql.catalyst.expressions.Expression>,org.apache.spark.sql.catalyst.analysis.ExpressionWithUnresolvedIdentifier> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.FunctionAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.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$ extends scala.runtime.AbstractFunction2<java.lang.Object,org.apache.spark.sql.types.DataType,org.apache.spark.sql.catalyst.analysis.GetColumnByOrdinal> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.GetViewColumnByNameAndOrdinal extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable
-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
colName
java.lang.String colName
-
expectedNumCandidates
int expectedNumCandidates
-
ordinal
int ordinal
-
resolved
boolean resolved
-
viewDDL
scala.Option<java.lang.String> viewDDL
-
viewName
java.lang.String viewName
-
-
-
Class org.apache.spark.sql.catalyst.analysis.GetViewColumnByNameAndOrdinal$ extends scala.runtime.AbstractFunction5<java.lang.String,java.lang.String,java.lang.Object,java.lang.Object,scala.Option<java.lang.String>,org.apache.spark.sql.catalyst.analysis.GetViewColumnByNameAndOrdinal> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.IndexAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.IndexAlreadyExistsException$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.String> names
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.MultiAlias$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.collection.Seq<java.lang.String>,org.apache.spark.sql.catalyst.analysis.MultiAlias> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NamedParameter extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable
-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
name
java.lang.String name
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NamedParameter$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.sql.catalyst.analysis.NamedParameter> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NameParameterizedQuery extends org.apache.spark.sql.catalyst.analysis.ParameterizedQuery implements Serializable
-
Serialized Fields
-
args
scala.collection.immutable.Map<java.lang.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$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,scala.collection.immutable.Map<java.lang.String,org.apache.spark.sql.catalyst.expressions.Expression>,org.apache.spark.sql.catalyst.analysis.NameParameterizedQuery> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NamespaceAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.NonEmptyNamespaceException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Serialized Fields
-
cause
scala.Option<java.lang.Throwable> cause
-
message
java.lang.String message
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NonEmptyNamespaceException$ extends scala.runtime.AbstractFunction2<java.lang.String,scala.Option<java.lang.Throwable>,org.apache.spark.sql.catalyst.analysis.NonEmptyNamespaceException> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchDatabaseException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchFunctionException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchFunctionException$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchIndexException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchIndexException$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchPartitionException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchPartitionsException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchPermanentFunctionException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchProcedureException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchTableException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchTableException$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchTempFunctionException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.NoSuchViewException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.PartitionAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.PartitionsAlreadyExistException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.String>,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> planBuilder
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.PlanWithUnresolvedIdentifier$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.Function1<scala.collection.Seq<java.lang.String>,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>,org.apache.spark.sql.catalyst.analysis.PlanWithUnresolvedIdentifier> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.sql.catalyst.analysis.PosParameter> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ 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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.String> version
-
-
-
Class org.apache.spark.sql.catalyst.analysis.RelationTimeTravel$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,scala.Option<org.apache.spark.sql.catalyst.expressions.Expression>,scala.Option<java.lang.String>,org.apache.spark.sql.catalyst.analysis.RelationTimeTravel> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.RelationWrapper extends java.lang.Object implements Serializable
-
Serialized Fields
-
cls
java.lang.Class<?> cls
-
outputAttrIds
scala.collection.Seq<java.lang.Object> outputAttrIds
-
-
-
Class org.apache.spark.sql.catalyst.analysis.RelationWrapper$ extends scala.runtime.AbstractFunction2<java.lang.Class<?>,scala.collection.Seq<java.lang.Object>,org.apache.spark.sql.catalyst.analysis.RelationWrapper> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolveColumnDefaultInInsert$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
Serialized Fields
-
org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions
scala.collection.Seq<scala.Tuple3<java.lang.String,scala.Function0<org.apache.spark.sql.catalyst.expressions.Expression>,scala.Function1<org.apache.spark.sql.catalyst.expressions.Expression,java.lang.String>>> org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.String> path
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedFieldName$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<java.lang.String>,org.apache.spark.sql.types.StructField,org.apache.spark.sql.catalyst.analysis.ResolvedFieldName> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.connector.catalog.TableChange.ColumnPosition,org.apache.spark.sql.catalyst.analysis.ResolvedFieldPosition> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ 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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ 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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.String> namespace
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedNamespace$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.connector.catalog.CatalogPlugin,scala.collection.Seq<java.lang.String>,org.apache.spark.sql.catalyst.analysis.ResolvedNamespace> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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
java.lang.String name
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedNonPersistentFunc$ extends scala.runtime.AbstractFunction2<java.lang.String,org.apache.spark.sql.connector.catalog.functions.UnboundFunction,org.apache.spark.sql.catalyst.analysis.ResolvedNonPersistentFunc> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedPartitionSpec extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable
-
Serialized Fields
-
ident
org.apache.spark.sql.catalyst.InternalRow ident
-
location
scala.Option<java.lang.String> location
-
names
scala.collection.Seq<java.lang.String> names
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolvedPartitionSpec$ extends scala.runtime.AbstractFunction3<scala.collection.Seq<java.lang.String>,org.apache.spark.sql.catalyst.InternalRow,scala.Option<java.lang.String>,org.apache.spark.sql.catalyst.analysis.ResolvedPartitionSpec> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ 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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ 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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ 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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ 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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolveLateralColumnAliasReference.AliasEntry extends java.lang.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$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Alias,java.lang.Object,org.apache.spark.sql.catalyst.analysis.ResolveLateralColumnAliasReference.AliasEntry> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.SparkSession,org.apache.spark.sql.catalyst.analysis.ResolveProcedures> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.ResolveReferencesInUpdate$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
Serialized Fields
-
org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions
scala.collection.Seq<scala.Tuple3<java.lang.String,scala.Function0<org.apache.spark.sql.catalyst.expressions.Expression>,scala.Function1<org.apache.spark.sql.catalyst.expressions.Expression,java.lang.String>>> org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.SparkSession,org.apache.spark.sql.catalyst.analysis.ResolveViews> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.SparkSession,org.apache.spark.sql.catalyst.analysis.RewriteViewCommands> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TableAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.TableAlreadyExistsException$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.String> nameParts
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TempResolvedColumn$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.catalyst.expressions.Expression,scala.collection.Seq<java.lang.String>,java.lang.Object,org.apache.spark.sql.catalyst.analysis.TempResolvedColumn> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TempTableAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.TempTableAlreadyExistsException$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.DataTypeMismatch extends java.lang.Object implements Serializable
-
Serialized Fields
-
errorSubClass
java.lang.String errorSubClass
-
messageParameters
scala.collection.immutable.Map<java.lang.String,java.lang.String> messageParameters
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.DataTypeMismatch$ extends scala.runtime.AbstractFunction2<java.lang.String,scala.collection.immutable.Map<java.lang.String,java.lang.String>,org.apache.spark.sql.catalyst.analysis.TypeCheckResult.DataTypeMismatch> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.InvalidFormat extends java.lang.Object implements Serializable
-
Serialized Fields
-
errorSubClass
java.lang.String errorSubClass
-
messageParameters
scala.collection.immutable.Map<java.lang.String,java.lang.String> messageParameters
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.InvalidFormat$ extends scala.runtime.AbstractFunction2<java.lang.String,scala.collection.immutable.Map<java.lang.String,java.lang.String>,org.apache.spark.sql.catalyst.analysis.TypeCheckResult.InvalidFormat> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.TypeCheckFailure extends java.lang.Object implements Serializable
-
Serialized Fields
-
message
java.lang.String message
-
-
-
Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.TypeCheckFailure$ extends scala.runtime.AbstractFunction1<java.lang.String,org.apache.spark.sql.catalyst.analysis.TypeCheckResult.TypeCheckFailure> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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,java.lang.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$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.Option<scala.Function1<org.apache.spark.sql.catalyst.expressions.Expression,java.lang.String>>,org.apache.spark.sql.catalyst.analysis.UnresolvedAlias> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute extends org.apache.spark.sql.catalyst.expressions.Attribute implements Serializable
-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
nameParts
scala.collection.Seq<java.lang.String> nameParts
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ 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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Class org.apache.spark.sql.catalyst.analysis.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$ 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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFieldName extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable
-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
name
scala.collection.Seq<java.lang.String> name
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFieldName$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<java.lang.String>,org.apache.spark.sql.catalyst.analysis.UnresolvedFieldName> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.connector.catalog.TableChange.ColumnPosition,org.apache.spark.sql.catalyst.analysis.UnresolvedFieldPosition> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.String> nameParts
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFunction$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFunctionName extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable
-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
commandName
java.lang.String commandName
-
funcTypeMismatchHint
scala.Option<java.lang.String> funcTypeMismatchHint
-
multipartIdentifier
scala.collection.Seq<java.lang.String> multipartIdentifier
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
possibleQualifiedName
scala.Option<scala.collection.Seq<java.lang.String>> possibleQualifiedName
-
requirePersistent
boolean requirePersistent
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedFunctionName$ extends scala.runtime.AbstractFunction5<scala.collection.Seq<java.lang.String>,java.lang.String,java.lang.Object,scala.Option<java.lang.String>,scala.Option<scala.collection.Seq<java.lang.String>>,org.apache.spark.sql.catalyst.analysis.UnresolvedFunctionName> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ 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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ 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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.String> nameParts
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedIdentifier$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<java.lang.String>,java.lang.Object,org.apache.spark.sql.catalyst.analysis.UnresolvedIdentifier> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.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$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<java.lang.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
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedNamespace extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable
-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
multipartIdentifier
scala.collection.Seq<java.lang.String> multipartIdentifier
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedNamespace$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<java.lang.String>,org.apache.spark.sql.catalyst.analysis.UnresolvedNamespace> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ extends scala.runtime.AbstractFunction1<java.lang.Object,org.apache.spark.sql.catalyst.analysis.UnresolvedOrdinal> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedPartitionSpec extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable
-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
location
scala.Option<java.lang.String> location
-
resolved
boolean resolved
-
spec
scala.collection.immutable.Map<java.lang.String,java.lang.String> spec
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedPartitionSpec$ extends scala.runtime.AbstractFunction2<scala.collection.immutable.Map<java.lang.String,java.lang.String>,scala.Option<java.lang.String>,org.apache.spark.sql.catalyst.analysis.UnresolvedPartitionSpec> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedRegex extends org.apache.spark.sql.catalyst.analysis.Star implements Serializable
-
Serialized Fields
-
caseSensitive
boolean caseSensitive
-
regexPattern
java.lang.String regexPattern
-
table
scala.Option<java.lang.String> table
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedRegex$ extends scala.runtime.AbstractFunction3<java.lang.String,scala.Option<java.lang.String>,java.lang.Object,org.apache.spark.sql.catalyst.analysis.UnresolvedRegex> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.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$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedSeed$ extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedStar extends org.apache.spark.sql.catalyst.analysis.Star implements Serializable
-
Serialized Fields
-
target
scala.Option<scala.collection.Seq<java.lang.String>> target
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedStar$ extends scala.runtime.AbstractFunction1<scala.Option<scala.collection.Seq<java.lang.String>>,org.apache.spark.sql.catalyst.analysis.UnresolvedStar> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.String> outputColumnNames
-
resolved
boolean resolved
-
validConstraints
org.apache.spark.sql.catalyst.expressions.ExpressionSet validConstraints
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedSubqueryColumnAliases$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<java.lang.String>,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,org.apache.spark.sql.catalyst.analysis.UnresolvedSubqueryColumnAliases> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTable extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable
-
Serialized Fields
-
bitmap$0
boolean bitmap$0
-
commandName
java.lang.String commandName
-
multipartIdentifier
scala.collection.Seq<java.lang.String> multipartIdentifier
-
relationTypeMismatchHint
scala.Option<java.lang.String> relationTypeMismatchHint
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTable$ extends scala.runtime.AbstractFunction3<scala.collection.Seq<java.lang.String>,java.lang.String,scala.Option<java.lang.String>,org.apache.spark.sql.catalyst.analysis.UnresolvedTable> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTableOrView extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable
-
Serialized Fields
-
allowTempView
boolean allowTempView
-
bitmap$0
boolean bitmap$0
-
commandName
java.lang.String commandName
-
multipartIdentifier
scala.collection.Seq<java.lang.String> multipartIdentifier
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTableOrView$ extends scala.runtime.AbstractFunction3<scala.collection.Seq<java.lang.String>,java.lang.String,java.lang.Object,org.apache.spark.sql.catalyst.analysis.UnresolvedTableOrView> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.String> name
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTableValuedFunction$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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<java.lang.String> name
-
nodePatterns
scala.collection.Seq<scala.Enumeration.Value> nodePatterns
-
outputNames
scala.collection.Seq<java.lang.String> outputNames
-
resolved
boolean resolved
-
validConstraints
org.apache.spark.sql.catalyst.expressions.ExpressionSet validConstraints
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedTVFAliases$ extends java.lang.Object implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedView extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable
-
Serialized Fields
-
allowTemp
boolean allowTemp
-
bitmap$0
boolean bitmap$0
-
commandName
java.lang.String commandName
-
multipartIdentifier
scala.collection.Seq<java.lang.String> multipartIdentifier
-
relationTypeMismatchHint
scala.Option<java.lang.String> relationTypeMismatchHint
-
resolved
boolean resolved
-
-
-
Class org.apache.spark.sql.catalyst.analysis.UnresolvedView$ extends scala.runtime.AbstractFunction4<scala.collection.Seq<java.lang.String>,java.lang.String,java.lang.Object,scala.Option<java.lang.String>,org.apache.spark.sql.catalyst.analysis.UnresolvedView> implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.analysis.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$ extends org.antlr.v4.runtime.BaseErrorListener implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-
Class org.apache.spark.sql.catalyst.parser.extensions.IcebergParseException extends org.apache.spark.sql.AnalysisException implements Serializable
-
Serialized Fields
-
command
scala.Option<java.lang.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$ extends IcebergSqlExtensionsBaseListener implements Serializable
-
Serialization Methods
-
readResolve
private java.lang.Object readResolve()
-
-
-