Serialized Form

Package org.apache.iceberg

Class org.apache.iceberg.AllDataFilesTable

class AllDataFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable

Class org.apache.iceberg.AllDeleteFilesTable

class AllDeleteFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable

Class org.apache.iceberg.AllEntriesTable

class AllEntriesTable extends org.apache.iceberg.BaseEntriesTable implements Serializable

Class org.apache.iceberg.AllFilesTable

class AllFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable

Class org.apache.iceberg.AllManifestsTable

class AllManifestsTable extends BaseMetadataTable implements Serializable

Class org.apache.iceberg.BaseCombinedScanTask

class BaseCombinedScanTask extends Object implements Serializable

Serialized Fields

tasks

FileScanTask[] tasks

Class org.apache.iceberg.BaseFileScanTask

class BaseFileScanTask extends org.apache.iceberg.BaseContentScanTask<FileScanTask,DataFile> implements Serializable

Serialized Fields

deletes

DeleteFile[] deletes

Class org.apache.iceberg.BaseMetadataTable

class BaseMetadataTable extends org.apache.iceberg.BaseReadOnlyTable implements Serializable

Serialization Methods

writeReplace

final Object writeReplace()

Serialized Fields

name

String name

sortOrder

SortOrder sortOrder

spec

PartitionSpec spec

table

BaseTable table

uuid

UUID uuid

Class org.apache.iceberg.BaseScanTaskGroup

class BaseScanTaskGroup extends Object implements Serializable

Serialized Fields

groupingKey

StructLike groupingKey

tasks

Object[] tasks

Class org.apache.iceberg.BaseTable

class BaseTable extends Object implements Serializable

Serialization Methods

writeReplace

Object writeReplace()

Serialized Fields

name

String name

ops

TableOperations ops

reporter

MetricsReporter reporter

Class org.apache.iceberg.BaseTransaction.TransactionTable

class TransactionTable extends Object implements Serializable

Serialization Methods

writeReplace

Object writeReplace()

Class org.apache.iceberg.DataFilesTable

class DataFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable

Class org.apache.iceberg.DeleteFilesTable

class DeleteFilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable

Class org.apache.iceberg.FilesTable

class FilesTable extends org.apache.iceberg.BaseFilesTable implements Serializable

Class org.apache.iceberg.GenericManifestFile

class GenericManifestFile extends SupportsIndexProjection implements Serializable

Serialized Fields

addedFilesCount

Integer addedFilesCount

addedRowsCount

Long addedRowsCount

content

ManifestContent content

deletedFilesCount

Integer deletedFilesCount

deletedRowsCount

Long deletedRowsCount

existingFilesCount

Integer existingFilesCount

existingRowsCount

Long existingRowsCount

file

InputFile file

keyMetadata

byte[] keyMetadata

length

Long length

manifestPath

String manifestPath

minSequenceNumber

long minSequenceNumber

partitions

ManifestFile.PartitionFieldSummary[] partitions

sequenceNumber

long sequenceNumber

snapshotId

Long snapshotId

specId

int specId

Class org.apache.iceberg.GenericPartitionFieldSummary

class GenericPartitionFieldSummary extends Object implements Serializable

Serialized Fields

containsNaN

Boolean containsNaN

containsNull

boolean containsNull

fromProjectionPos

int[] fromProjectionPos

lowerBound

byte[] lowerBound

upperBound

byte[] upperBound

Class org.apache.iceberg.HistoryTable

class HistoryTable extends BaseMetadataTable implements Serializable

Class org.apache.iceberg.ManifestEntriesTable

class ManifestEntriesTable extends org.apache.iceberg.BaseEntriesTable implements Serializable

Exception org.apache.iceberg.ManifestFilterManager.DeleteException

class DeleteException extends ValidationException implements Serializable

Serialized Fields

partition

String partition

Class org.apache.iceberg.ManifestsTable

class ManifestsTable extends BaseMetadataTable implements Serializable

Class org.apache.iceberg.MetadataLogEntriesTable

class MetadataLogEntriesTable extends BaseMetadataTable implements Serializable

Class org.apache.iceberg.MetadataUpdate.AddPartitionSpec

class AddPartitionSpec extends Object implements Serializable

Serialized Fields

spec

UnboundPartitionSpec spec

Class org.apache.iceberg.MetadataUpdate.AddSchema

class AddSchema extends Object implements Serializable

Serialized Fields

lastColumnId

int lastColumnId

schema

Schema schema

Class org.apache.iceberg.MetadataUpdate.AddSnapshot

class AddSnapshot extends Object implements Serializable

Serialized Fields

snapshot

Snapshot snapshot

Class org.apache.iceberg.MetadataUpdate.AddSortOrder

class AddSortOrder extends Object implements Serializable

Serialized Fields

sortOrder

UnboundSortOrder sortOrder

Class org.apache.iceberg.MetadataUpdate.AddViewVersion

class AddViewVersion extends Object implements Serializable

Serialized Fields

viewVersion

ViewVersion viewVersion

Class org.apache.iceberg.MetadataUpdate.AssignUUID

class AssignUUID extends Object implements Serializable

Serialized Fields

uuid

String uuid

Class org.apache.iceberg.MetadataUpdate.EnableRowLineage

class EnableRowLineage extends Object implements Serializable

Class org.apache.iceberg.MetadataUpdate.RemovePartitionSpecs

class RemovePartitionSpecs extends Object implements Serializable

Serialized Fields

specIds

Set<Integer> specIds

Class org.apache.iceberg.MetadataUpdate.RemovePartitionStatistics

class RemovePartitionStatistics extends Object implements Serializable

Serialized Fields

snapshotId

long snapshotId

Class org.apache.iceberg.MetadataUpdate.RemoveProperties

class RemoveProperties extends Object implements Serializable

Serialized Fields

removed

Set<String> removed

Class org.apache.iceberg.MetadataUpdate.RemoveSnapshot

class RemoveSnapshot extends Object implements Serializable

Serialized Fields

snapshotId

long snapshotId

Class org.apache.iceberg.MetadataUpdate.RemoveSnapshotRef

class RemoveSnapshotRef extends Object implements Serializable

Serialized Fields

refName

String refName

Class org.apache.iceberg.MetadataUpdate.RemoveStatistics

class RemoveStatistics extends Object implements Serializable

Serialized Fields

snapshotId

long snapshotId

Class org.apache.iceberg.MetadataUpdate.SetCurrentSchema

class SetCurrentSchema extends Object implements Serializable

Serialized Fields

schemaId

int schemaId

Class org.apache.iceberg.MetadataUpdate.SetCurrentViewVersion

class SetCurrentViewVersion extends Object implements Serializable

Serialized Fields

versionId

int versionId

Class org.apache.iceberg.MetadataUpdate.SetDefaultPartitionSpec

class SetDefaultPartitionSpec extends Object implements Serializable

Serialized Fields

specId

int specId

Class org.apache.iceberg.MetadataUpdate.SetDefaultSortOrder

class SetDefaultSortOrder extends Object implements Serializable

Serialized Fields

sortOrderId

int sortOrderId

Class org.apache.iceberg.MetadataUpdate.SetLocation

class SetLocation extends Object implements Serializable

Serialized Fields

location

String location

Class org.apache.iceberg.MetadataUpdate.SetPartitionStatistics

class SetPartitionStatistics extends Object implements Serializable

Serialized Fields

partitionStatisticsFile

PartitionStatisticsFile partitionStatisticsFile

Class org.apache.iceberg.MetadataUpdate.SetProperties

class SetProperties extends Object implements Serializable

Serialized Fields

updated

Map<String,String> updated

Class org.apache.iceberg.MetadataUpdate.SetSnapshotRef

class SetSnapshotRef extends Object implements Serializable

Serialized Fields

maxRefAgeMs

Long maxRefAgeMs

maxSnapshotAgeMs

Long maxSnapshotAgeMs

minSnapshotsToKeep

Integer minSnapshotsToKeep

refName

String refName

snapshotId

Long snapshotId

type

org.apache.iceberg.SnapshotRefType type

Class org.apache.iceberg.MetadataUpdate.SetStatistics

class SetStatistics extends Object implements Serializable

Serialized Fields

statisticsFile

StatisticsFile statisticsFile

Class org.apache.iceberg.MetadataUpdate.UpgradeFormatVersion

class UpgradeFormatVersion extends Object implements Serializable

Serialized Fields

formatVersion

int formatVersion

Class org.apache.iceberg.Metrics

class Metrics extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
ClassNotFoundException

Implemented the method to enable deserialization of ByteBuffers.

Parameters:

in - The stream to read from

Throws:

IOException - On serialization error

ClassNotFoundException - If the class is not found

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Implemented the method to enable serialization of ByteBuffers.

Parameters:

out - The stream where to write

Throws:

IOException - On serialization error

Serialized Fields

columnSizes

Map<Integer,Long> columnSizes

lowerBounds

Map<Integer,ByteBuffer> lowerBounds

nanValueCounts

Map<Integer,Long> nanValueCounts

nullValueCounts

Map<Integer,Long> nullValueCounts

rowCount

Long rowCount

upperBounds

Map<Integer,ByteBuffer> upperBounds

valueCounts

Map<Integer,Long> valueCounts

Class org.apache.iceberg.MetricsConfig

class MetricsConfig extends Object implements Serializable

Serialized Fields

columnModes

Map<String,MetricsModes.MetricsMode> columnModes

defaultMode

MetricsModes.MetricsMode defaultMode

Class org.apache.iceberg.MetricsModes.Counts

class Counts extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable

Class org.apache.iceberg.MetricsModes.Full

class Full extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable

Class org.apache.iceberg.MetricsModes.None

class None extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable

Class org.apache.iceberg.MetricsModes.Truncate

class Truncate extends org.apache.iceberg.MetricsModes.ProxySerializableMetricsMode implements Serializable

Serialized Fields

length

int length

Class org.apache.iceberg.PartitionData

class PartitionData extends Object implements Serializable

Serialized Fields

data

Object[] data

partitionType

Types.StructType partitionType

size

int size

stringSchema

String stringSchema

Class org.apache.iceberg.PartitionField

class PartitionField extends Object implements Serializable

Serialized Fields

fieldId

int fieldId

name

String name

sourceId

int sourceId

transform

Transform<?,?> transform

Class org.apache.iceberg.PartitionKey

class PartitionKey extends org.apache.iceberg.StructTransform implements Serializable

Serialized Fields

inputSchema

Schema inputSchema

spec

PartitionSpec spec

Class org.apache.iceberg.PartitionSpec

class PartitionSpec extends Object implements Serializable

Serialized Fields

fields

PartitionField[] fields

lastAssignedFieldId

int lastAssignedFieldId

schema

Schema schema

specId

int specId

Class org.apache.iceberg.PartitionsTable

class PartitionsTable extends BaseMetadataTable implements Serializable

Serialized Fields

schema

Schema schema

unpartitionedTable

boolean unpartitionedTable

Class org.apache.iceberg.PositionDeletesTable

class PositionDeletesTable extends BaseMetadataTable implements Serializable

Serialized Fields

defaultSpecId

int defaultSpecId

schema

Schema schema

specs

Map<Integer,PartitionSpec> specs

Class org.apache.iceberg.RefsTable

class RefsTable extends BaseMetadataTable implements Serializable

Class org.apache.iceberg.RewriteTablePathUtil.RewriteResult

class RewriteResult extends Object implements Serializable

Serialized Fields

copyPlan

Set<Pair<String,String>> copyPlan

toRewrite

Set<T> toRewrite

Class org.apache.iceberg.Schema

class Schema extends Object implements Serializable

Serialized Fields

highestFieldId

int highestFieldId

identifierFieldIds

int[] identifierFieldIds

schemaId

int schemaId

struct

Types.StructType struct

Class org.apache.iceberg.SerializableTable

class SerializableTable extends Object implements Serializable

Serialized Fields

defaultSpecId

int defaultSpecId

encryption

EncryptionManager encryption

formatVersion

int formatVersion

io

FileIO io

location

String location

metadataFileLocation

String metadataFileLocation

name

String name

properties

Map<String,String> properties

refs

Map<String,SnapshotRef> refs

schemaAsJson

String schemaAsJson

sortOrderAsJson

String sortOrderAsJson

specAsJsonMap

Map<Integer,String> specAsJsonMap

uuid

UUID uuid

Class org.apache.iceberg.SerializableTable.SerializableMetadataTable

class SerializableMetadataTable extends SerializableTable implements Serializable

Serialized Fields

baseTableName

String baseTableName

type

MetadataTableType type

Class org.apache.iceberg.SnapshotRef

class SnapshotRef extends Object implements Serializable

Serialized Fields

maxRefAgeMs

Long maxRefAgeMs

maxSnapshotAgeMs

Long maxSnapshotAgeMs

minSnapshotsToKeep

Integer minSnapshotsToKeep

snapshotId

long snapshotId

type

org.apache.iceberg.SnapshotRefType type

Class org.apache.iceberg.SnapshotsTable

class SnapshotsTable extends BaseMetadataTable implements Serializable

Class org.apache.iceberg.SortField

class SortField extends Object implements Serializable

Serialized Fields

direction

SortDirection direction

nullOrder

NullOrder nullOrder

sourceId

int sourceId

transform

Transform<?,?> transform

Class org.apache.iceberg.SortKey

class SortKey extends org.apache.iceberg.StructTransform implements Serializable

Serialized Fields

schema

Schema schema

sortOrder

SortOrder sortOrder

Class org.apache.iceberg.SortOrder

class SortOrder extends Object implements Serializable

Serialized Fields

fields

SortField[] fields

orderId

int orderId

schema

Schema schema

Class org.apache.iceberg.TableMetadata

class TableMetadata extends Object implements Serializable

Serialized Fields

changes

List<MetadataUpdate> changes

currentSchemaId

int currentSchemaId

currentSnapshotId

long currentSnapshotId

defaultSortOrderId

int defaultSortOrderId

defaultSpecId

int defaultSpecId

formatVersion

int formatVersion

lastAssignedPartitionId

int lastAssignedPartitionId

lastColumnId

int lastColumnId

lastSequenceNumber

long lastSequenceNumber

lastUpdatedMillis

long lastUpdatedMillis

location

String location

metadataFileLocation

String metadataFileLocation

nextRowId

long nextRowId

partitionStatisticsFiles

List<PartitionStatisticsFile> partitionStatisticsFiles

previousFiles

List<TableMetadata.MetadataLogEntry> previousFiles

properties

Map<String,String> properties

refs

Map<String,SnapshotRef> refs

rowLineageEnabled

Boolean rowLineageEnabled

schemas

List<Schema> schemas

schemasById

Map<Integer,Schema> schemasById

snapshotLog

List<HistoryEntry> snapshotLog

snapshots

List<Snapshot> snapshots

snapshotsById

Map<Long,Snapshot> snapshotsById

snapshotsLoaded

boolean snapshotsLoaded

snapshotsSupplier

SerializableSupplier<List<Snapshot>> snapshotsSupplier

sortOrders

List<SortOrder> sortOrders

sortOrdersById

Map<Integer,SortOrder> sortOrdersById

specs

List<PartitionSpec> specs

specsById

Map<Integer,PartitionSpec> specsById

statisticsFiles

List<StatisticsFile> statisticsFiles

uuid

String uuid

Class org.apache.iceberg.TableMetadata.SnapshotLogEntry

class SnapshotLogEntry extends Object implements Serializable

Serialized Fields

snapshotId

long snapshotId

timestampMillis

long timestampMillis

Package org.apache.iceberg.aliyun

Class org.apache.iceberg.aliyun.AliyunProperties

class AliyunProperties extends Object implements Serializable

Serialized Fields

accessKeyId

String accessKeyId

accessKeySecret

String accessKeySecret

ossEndpoint

String ossEndpoint

ossStagingDirectory

String ossStagingDirectory

securityToken

String securityToken

Package org.apache.iceberg.aliyun.oss

Class org.apache.iceberg.aliyun.oss.OSSFileIO

class OSSFileIO extends Object implements Serializable

Serialized Fields

aliyunProperties

AliyunProperties aliyunProperties

isResourceClosed

AtomicBoolean isResourceClosed

metrics

MetricsContext metrics

oss

SerializableSupplier<com.aliyun.oss.OSS> oss

Package org.apache.iceberg.avro

Class org.apache.iceberg.avro.SupportsIndexProjection

class SupportsIndexProjection extends Object implements Serializable

Serialized Fields

fromProjectionPos

int[] fromProjectionPos

Package org.apache.iceberg.aws

Class org.apache.iceberg.aws.AssumeRoleAwsClientFactory

class AssumeRoleAwsClientFactory extends Object implements Serializable

Serialized Fields

awsClientProperties

AwsClientProperties awsClientProperties

awsProperties

AwsProperties awsProperties

httpClientProperties

HttpClientProperties httpClientProperties

roleSessionName

String roleSessionName

s3FileIOProperties

S3FileIOProperties s3FileIOProperties

Class org.apache.iceberg.aws.AwsClientProperties

class AwsClientProperties extends Object implements Serializable

Serialized Fields

allProperties

Map<String,String> allProperties

clientCredentialsProvider

String clientCredentialsProvider

clientCredentialsProviderProperties

Map<String,String> clientCredentialsProviderProperties

clientRegion

String clientRegion

refreshCredentialsEnabled

boolean refreshCredentialsEnabled

refreshCredentialsEndpoint

String refreshCredentialsEndpoint

Class org.apache.iceberg.aws.AwsProperties

class AwsProperties extends Object implements Serializable

Serialized Fields

clientAssumeRoleArn

String clientAssumeRoleArn

clientAssumeRoleExternalId

String clientAssumeRoleExternalId

clientAssumeRoleRegion

String clientAssumeRoleRegion

clientAssumeRoleSessionName

String clientAssumeRoleSessionName

clientAssumeRoleTimeoutSec

int clientAssumeRoleTimeoutSec

clientCredentialsProvider

String clientCredentialsProvider

clientCredentialsProviderProperties

Map<String,String> clientCredentialsProviderProperties

dynamoDbEndpoint

String dynamoDbEndpoint

dynamoDbTableName

String dynamoDbTableName

glueCatalogId

String glueCatalogId

glueCatalogSkipArchive

boolean glueCatalogSkipArchive

glueCatalogSkipNameValidation

boolean glueCatalogSkipNameValidation

glueEndpoint

String glueEndpoint

glueLakeFormationEnabled

boolean glueLakeFormationEnabled

restAccessKeyId

String restAccessKeyId

restSecretAccessKey

String restSecretAccessKey

restSessionToken

String restSessionToken

restSigningName

String restSigningName

restSigningRegion

String restSigningRegion

stsClientAssumeRoleTags

Set<software.amazon.awssdk.services.sts.model.Tag> stsClientAssumeRoleTags

Class org.apache.iceberg.aws.HttpClientProperties

class HttpClientProperties extends Object implements Serializable

Serialized Fields

httpClientProperties

Map<String,String> httpClientProperties

httpClientType

String httpClientType

Package org.apache.iceberg.aws.lakeformation

Class org.apache.iceberg.aws.lakeformation.LakeFormationAwsClientFactory

class LakeFormationAwsClientFactory extends AssumeRoleAwsClientFactory implements Serializable

Serialized Fields

dbName

String dbName

glueAccountId

String glueAccountId

glueCatalogId

String glueCatalogId

tableName

String tableName

Package org.apache.iceberg.aws.s3

Class org.apache.iceberg.aws.s3.S3FileIO

class S3FileIO extends Object implements Serializable

Serialized Fields

credential

String credential

isResourceClosed

AtomicBoolean isResourceClosed

metrics

MetricsContext metrics

properties

SerializableMap<String,String> properties

s3

SerializableSupplier<software.amazon.awssdk.services.s3.S3Client> s3

s3FileIOProperties

S3FileIOProperties s3FileIOProperties

Class org.apache.iceberg.aws.s3.S3FileIOProperties

class S3FileIOProperties extends Object implements Serializable

Serialized Fields

accessKeyId

String accessKeyId

acl

software.amazon.awssdk.services.s3.model.ObjectCannedACL acl

allProperties

Map<String,String> allProperties

bucketToAccessPointMapping

Map<String,String> bucketToAccessPointMapping

deleteBatchSize

int deleteBatchSize

deleteTags

Set<software.amazon.awssdk.services.s3.model.Tag> deleteTags

deleteThreads

int deleteThreads

endpoint

String endpoint

isAccelerationEnabled

boolean isAccelerationEnabled

isChecksumEnabled

boolean isChecksumEnabled

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

String secretAccessKey

sessionToken

String sessionToken

sseKey

String sseKey

sseMd5

String sseMd5

sseType

String sseType

stagingDirectory

String stagingDirectory

writeStorageClass

String writeStorageClass

writeTags

Set<software.amazon.awssdk.services.s3.model.Tag> writeTags

Package org.apache.iceberg.azure

Class org.apache.iceberg.azure.AzureProperties

class AzureProperties extends Object implements Serializable

Serialized Fields

adlsConnectionStrings

Map<String,String> adlsConnectionStrings

adlsReadBlockSize

Integer adlsReadBlockSize

adlsSasTokens

Map<String,String> adlsSasTokens

adlsWriteBlockSize

Long adlsWriteBlockSize

namedKeyCreds

Map.Entry<String,String> namedKeyCreds

Package org.apache.iceberg.azure.adlsv2

Class org.apache.iceberg.azure.adlsv2.ADLSFileIO

class ADLSFileIO extends Object implements Serializable

Serialized Fields

azureProperties

AzureProperties azureProperties

metrics

MetricsContext metrics

properties

SerializableMap<String,String> properties

Package org.apache.iceberg.connect.channel

Exception org.apache.iceberg.connect.channel.NotRunningException

class NotRunningException extends RuntimeException implements Serializable

Package org.apache.iceberg.dell

Class org.apache.iceberg.dell.DellProperties

class DellProperties extends Object implements Serializable

Serialized Fields

ecsS3AccessKeyId

String ecsS3AccessKeyId

ecsS3Endpoint

String ecsS3Endpoint

ecsS3SecretAccessKey

String ecsS3SecretAccessKey

Package org.apache.iceberg.dell.ecs

Class org.apache.iceberg.dell.ecs.EcsFileIO

class EcsFileIO extends Object implements Serializable

Serialized Fields

dellClientFactory

DellClientFactory dellClientFactory

dellProperties

DellProperties dellProperties

isResourceClosed

AtomicBoolean isResourceClosed

metrics

MetricsContext metrics

s3

SerializableSupplier<com.emc.object.s3.S3Client> s3

Package org.apache.iceberg.encryption

Class org.apache.iceberg.encryption.EncryptingFileIO

class EncryptingFileIO extends Object implements Serializable

Serialized Fields

em

EncryptionManager em

io

FileIO io

Class org.apache.iceberg.encryption.PlaintextEncryptionManager

class PlaintextEncryptionManager extends Object implements Serializable

Class org.apache.iceberg.encryption.StandardEncryptionManager

class StandardEncryptionManager extends Object implements Serializable

Serialized Fields

dataKeyLength

int dataKeyLength

tableKeyId

String tableKeyId

Package org.apache.iceberg.exceptions

Exception org.apache.iceberg.exceptions.AlreadyExistsException

class AlreadyExistsException extends RuntimeException implements Serializable

Exception org.apache.iceberg.exceptions.BadRequestException

class BadRequestException extends RESTException implements Serializable

Exception org.apache.iceberg.exceptions.CherrypickAncestorCommitException

class CherrypickAncestorCommitException extends ValidationException implements Serializable

Exception org.apache.iceberg.exceptions.CommitFailedException

class CommitFailedException extends RuntimeException implements Serializable

Exception org.apache.iceberg.exceptions.CommitStateUnknownException

class CommitStateUnknownException extends RuntimeException implements Serializable

Exception org.apache.iceberg.exceptions.DuplicateWAPCommitException

class DuplicateWAPCommitException extends ValidationException implements Serializable

Exception org.apache.iceberg.exceptions.ForbiddenException

class ForbiddenException extends RESTException implements Serializable

Exception org.apache.iceberg.exceptions.NamespaceNotEmptyException

class NamespaceNotEmptyException extends RuntimeException implements Serializable

Exception org.apache.iceberg.exceptions.NoSuchIcebergTableException

class NoSuchIcebergTableException extends NoSuchTableException implements Serializable

Exception org.apache.iceberg.exceptions.NoSuchIcebergViewException

class NoSuchIcebergViewException extends NoSuchViewException implements Serializable

Exception org.apache.iceberg.exceptions.NoSuchNamespaceException

class NoSuchNamespaceException extends RuntimeException implements Serializable

Exception org.apache.iceberg.exceptions.NoSuchTableException

class NoSuchTableException extends RuntimeException implements Serializable

Exception org.apache.iceberg.exceptions.NoSuchViewException

class NoSuchViewException extends RuntimeException implements Serializable

Exception org.apache.iceberg.exceptions.NotAuthorizedException

class NotAuthorizedException extends RESTException implements Serializable

Exception org.apache.iceberg.exceptions.NotFoundException

class NotFoundException extends RuntimeException implements Serializable

Exception org.apache.iceberg.exceptions.RESTException

class RESTException extends RuntimeException implements Serializable

Exception org.apache.iceberg.exceptions.RuntimeIOException

class RuntimeIOException extends UncheckedIOException implements Serializable

Exception org.apache.iceberg.exceptions.ServiceFailureException

class ServiceFailureException extends RESTException implements Serializable

Exception org.apache.iceberg.exceptions.ServiceUnavailableException

class ServiceUnavailableException extends RESTException implements Serializable

Exception org.apache.iceberg.exceptions.UnprocessableEntityException

class UnprocessableEntityException extends RESTException implements Serializable

Exception org.apache.iceberg.exceptions.ValidationException

class ValidationException extends RuntimeException implements Serializable

Package org.apache.iceberg.expressions

Class org.apache.iceberg.expressions.Aggregate

class Aggregate extends Object implements Serializable

Serialized Fields

op

Expression.Operation op

term

C extends Term term

Class org.apache.iceberg.expressions.And

class And extends Object implements Serializable

Serialized Fields

left

Expression left

right

Expression right

Class org.apache.iceberg.expressions.BoundAggregate

class BoundAggregate extends Aggregate<BoundTerm<T>> implements Serializable

Class org.apache.iceberg.expressions.BoundLiteralPredicate

class BoundLiteralPredicate extends BoundPredicate<T> implements Serializable

Serialized Fields

literal

Literal<T> literal

Class org.apache.iceberg.expressions.BoundPredicate

class BoundPredicate extends Predicate<T,BoundTerm<T>> implements Serializable

Class org.apache.iceberg.expressions.BoundReference

class BoundReference extends Object implements Serializable

Serialized Fields

accessor

Accessor<StructLike> accessor

field

Types.NestedField field

name

String name

Class org.apache.iceberg.expressions.BoundSetPredicate

class BoundSetPredicate extends BoundPredicate<T> implements Serializable

Serialized Fields

literalSet

Set<T> literalSet

Class org.apache.iceberg.expressions.BoundTransform

class BoundTransform extends Object implements Serializable

Serialized Fields

func

SerializableFunction<S,T> func

ref

BoundReference<S> ref

transform

Transform<S,T> transform

Class org.apache.iceberg.expressions.BoundUnaryPredicate

class BoundUnaryPredicate extends BoundPredicate<T> implements Serializable

Class org.apache.iceberg.expressions.CountAggregate

class CountAggregate extends BoundAggregate<T,Long> implements Serializable

Class org.apache.iceberg.expressions.CountNonNull

class CountNonNull extends CountAggregate<T> implements Serializable

Serialized Fields

field

Types.NestedField field

fieldId

int fieldId

Class org.apache.iceberg.expressions.CountStar

class CountStar extends CountAggregate<T> implements Serializable

Class org.apache.iceberg.expressions.Evaluator

class Evaluator extends Object implements Serializable

Serialized Fields

expr

Expression expr

Class org.apache.iceberg.expressions.False

class False extends Object implements Serializable

Serialization Methods

writeReplace

Object writeReplace()
             throws ObjectStreamException

Throws:

ObjectStreamException

Class org.apache.iceberg.expressions.MaxAggregate

class MaxAggregate extends org.apache.iceberg.expressions.ValueAggregate<T> implements Serializable

Serialized Fields

comparator

Comparator<T> comparator

fieldId

int fieldId

type

Type.PrimitiveType type

Class org.apache.iceberg.expressions.MinAggregate

class MinAggregate extends org.apache.iceberg.expressions.ValueAggregate<T> implements Serializable

Serialized Fields

comparator

Comparator<T> comparator

fieldId

int fieldId

type

Type.PrimitiveType type

Class org.apache.iceberg.expressions.NamedReference

class NamedReference extends Object implements Serializable

Serialized Fields

name

String name

Class org.apache.iceberg.expressions.Not

class Not extends Object implements Serializable

Serialized Fields

child

Expression child

Class org.apache.iceberg.expressions.Or

class Or extends Object implements Serializable

Serialized Fields

left

Expression left

right

Expression right

Class org.apache.iceberg.expressions.Predicate

class Predicate extends Object implements Serializable

Serialized Fields

op

Expression.Operation op

term

C extends Term term

Class org.apache.iceberg.expressions.ResidualEvaluator

class ResidualEvaluator extends Object implements Serializable

Serialized Fields

caseSensitive

boolean caseSensitive

expr

Expression expr

spec

PartitionSpec spec

Class org.apache.iceberg.expressions.True

class True extends Object implements Serializable

Serialization Methods

writeReplace

Object writeReplace()
             throws ObjectStreamException

Throws:

ObjectStreamException

Class org.apache.iceberg.expressions.UnboundAggregate

class UnboundAggregate extends Aggregate<UnboundTerm<T>> implements Serializable

Class org.apache.iceberg.expressions.UnboundPredicate

class UnboundPredicate extends Predicate<T,UnboundTerm<T>> implements Serializable

Serialized Fields

literals

List<Literal<T>> literals

Class org.apache.iceberg.expressions.UnboundTransform

class UnboundTransform extends Object implements Serializable

Serialized Fields

ref

NamedReference<S> ref

transform

Transform<S,T> transform

Class org.apache.iceberg.expressions.Zorder

class Zorder extends Object implements Serializable

Serialized Fields

refs

NamedReference<?>[] refs

Package org.apache.iceberg.flink

Class org.apache.iceberg.flink.CatalogLoader.CustomCatalogLoader

class CustomCatalogLoader extends Object implements Serializable

Serialized Fields

hadoopConf

SerializableConfiguration hadoopConf

impl

String impl

name

String name

properties

Map<String,String> properties

Class org.apache.iceberg.flink.CatalogLoader.HadoopCatalogLoader

class HadoopCatalogLoader extends Object implements Serializable

Serialized Fields

catalogName

String catalogName

hadoopConf

SerializableConfiguration hadoopConf

properties

Map<String,String> properties

warehouseLocation

String warehouseLocation

Class org.apache.iceberg.flink.CatalogLoader.HiveCatalogLoader

class HiveCatalogLoader extends Object implements Serializable

Serialized Fields

catalogName

String catalogName

clientPoolSize

int clientPoolSize

hadoopConf

SerializableConfiguration hadoopConf

properties

Map<String,String> properties

uri

String uri

warehouse

String warehouse

Class org.apache.iceberg.flink.CatalogLoader.RESTCatalogLoader

class RESTCatalogLoader extends Object implements Serializable

Serialized Fields

catalogName

String catalogName

hadoopConf

SerializableConfiguration hadoopConf

properties

Map<String,String> properties

Class org.apache.iceberg.flink.FlinkSourceFilter

class FlinkSourceFilter extends Object implements Serializable

Serialized Fields

evaluator

Evaluator evaluator

rowType

org.apache.flink.table.types.logical.RowType rowType

struct

Types.StructType struct

wrapper

RowDataWrapper wrapper

Class org.apache.iceberg.flink.TableLoader.CatalogTableLoader

class CatalogTableLoader extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

catalogLoader

CatalogLoader catalogLoader

identifier

String identifier

Class org.apache.iceberg.flink.TableLoader.HadoopTableLoader

class HadoopTableLoader extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

hadoopConf

SerializableConfiguration hadoopConf

location

String location

Package org.apache.iceberg.flink.maintenance.api

Class org.apache.iceberg.flink.maintenance.api.JdbcLockFactory

class JdbcLockFactory extends Object implements Serializable

Serialized Fields

lockId

String lockId

properties

Map<String,String> properties

uri

String uri

Class org.apache.iceberg.flink.maintenance.api.TableMaintenance.PunctuatedWatermarkStrategy

class PunctuatedWatermarkStrategy extends Object implements Serializable

Class org.apache.iceberg.flink.maintenance.api.TaskResult

class TaskResult extends Object implements Serializable

Serialized Fields

exceptions

List<Exception> exceptions

startEpoch

long startEpoch

success

boolean success

taskIndex

int taskIndex

Package org.apache.iceberg.flink.maintenance.operator

Class org.apache.iceberg.flink.maintenance.operator.DeleteFilesProcessor

class DeleteFilesProcessor extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<Void> implements Serializable

Serialized Fields

batchSize

int batchSize

filesToDelete

Set<String> filesToDelete

io

SupportsBulkOperations io

tableName

String tableName

taskIndex

String taskIndex

taskName

String taskName

Class org.apache.iceberg.flink.maintenance.operator.ExpireSnapshotsProcessor

class ExpireSnapshotsProcessor extends org.apache.flink.streaming.api.functions.ProcessFunction<Trigger,TaskResult> implements Serializable

Serialized Fields

maxSnapshotAgeMs

Long maxSnapshotAgeMs

numSnapshots

Integer numSnapshots

plannerPoolSize

Integer plannerPoolSize

tableLoader

TableLoader tableLoader

Class org.apache.iceberg.flink.maintenance.operator.LockRemover

class LockRemover extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<Void> implements Serializable

Serialized Fields

lockFactory

TriggerLockFactory lockFactory

maintenanceTaskNames

List<String> maintenanceTaskNames

tableName

String tableName

Class org.apache.iceberg.flink.maintenance.operator.MonitorSource

class MonitorSource extends SingleThreadedIteratorSource<TableChange> implements Serializable

Serialized Fields

maxReadBack

long maxReadBack

rateLimiterStrategy

org.apache.flink.api.connector.source.util.ratelimit.RateLimiterStrategy rateLimiterStrategy

tableLoader

TableLoader tableLoader

Class org.apache.iceberg.flink.maintenance.operator.SingleThreadedIteratorSource

class SingleThreadedIteratorSource extends Object implements Serializable

Class org.apache.iceberg.flink.maintenance.operator.TriggerEvaluator

class TriggerEvaluator extends Object implements Serializable

Serialized Fields

predicates

List<org.apache.iceberg.flink.maintenance.operator.TriggerEvaluator.Predicate> predicates

Class org.apache.iceberg.flink.maintenance.operator.TriggerEvaluator.Builder

class Builder extends Object implements Serializable

Serialized Fields

commitCount

Integer commitCount

dataFileCount

Integer dataFileCount

dataFileSizeInBytes

Long dataFileSizeInBytes

eqDeleteFileCount

Integer eqDeleteFileCount

eqDeleteRecordCount

Long eqDeleteRecordCount

posDeleteFileCount

Integer posDeleteFileCount

posDeleteRecordCount

Long posDeleteRecordCount

timeout

Duration timeout

Class org.apache.iceberg.flink.maintenance.operator.TriggerManager

class TriggerManager extends org.apache.flink.streaming.api.functions.KeyedProcessFunction<Boolean,TableChange,Trigger> implements Serializable

Serialized Fields

evaluators

List<TriggerEvaluator> evaluators

lockCheckDelayMs

long lockCheckDelayMs

lockFactory

TriggerLockFactory lockFactory

maintenanceTaskNames

List<String> maintenanceTaskNames

minFireDelayMs

long minFireDelayMs

tableName

String tableName

Package org.apache.iceberg.flink.sink

Class org.apache.iceberg.flink.sink.AvroGenericRecordToRowDataMapper

class AvroGenericRecordToRowDataMapper extends Object implements Serializable

Serialized Fields

converter

org.apache.flink.formats.avro.AvroToRowDataConverters.AvroToRowDataConverter converter

Class org.apache.iceberg.flink.sink.FlinkAppenderFactory

class FlinkAppenderFactory extends Object implements Serializable

Serialized Fields

eqDeleteFlinkSchema

org.apache.flink.table.types.logical.RowType eqDeleteFlinkSchema

eqDeleteRowSchema

Schema eqDeleteRowSchema

equalityFieldIds

int[] equalityFieldIds

flinkSchema

org.apache.flink.table.types.logical.RowType flinkSchema

posDeleteFlinkSchema

org.apache.flink.table.types.logical.RowType posDeleteFlinkSchema

posDeleteRowSchema

Schema posDeleteRowSchema

props

Map<String,String> props

schema

Schema schema

spec

PartitionSpec spec

table

Table table

Class org.apache.iceberg.flink.sink.FlinkWriteResult

class FlinkWriteResult extends Object implements Serializable

Serialized Fields

checkpointId

long checkpointId

writeResult

WriteResult writeResult

Class org.apache.iceberg.flink.sink.IcebergSink

class IcebergSink extends Object implements Serializable

Serialized Fields

branch

String branch

dataFileFormat

FileFormat dataFileFormat

equalityFieldColumns

List<String> equalityFieldColumns

equalityFieldIds

List<Integer> equalityFieldIds

flinkRowType

org.apache.flink.table.types.logical.RowType flinkRowType

overwriteMode

boolean overwriteMode

sinkId

String sinkId

snapshotProperties

Map<String,String> snapshotProperties

table

Table table

tableLoader

TableLoader tableLoader

tableSupplier

SerializableSupplier<Table> tableSupplier

targetDataFileSize

long targetDataFileSize

uidSuffix

String uidSuffix

upsertMode

boolean upsertMode

workerPoolSize

int workerPoolSize

writeProperties

Map<String,String> writeProperties

Class org.apache.iceberg.flink.sink.RowDataTaskWriterFactory

class RowDataTaskWriterFactory extends Object implements Serializable

Serialized Fields

appenderFactory

FileAppenderFactory<org.apache.flink.table.data.RowData> appenderFactory

equalityFieldIds

List<Integer> equalityFieldIds

flinkSchema

org.apache.flink.table.types.logical.RowType flinkSchema

format

FileFormat format

schema

Schema schema

spec

PartitionSpec spec

tableSupplier

Supplier<Table> tableSupplier

targetFileSizeBytes

long targetFileSizeBytes

upsert

boolean upsert

Package org.apache.iceberg.flink.sink.shuffle

Class org.apache.iceberg.flink.sink.shuffle.DataStatisticsCoordinatorProvider

class DataStatisticsCoordinatorProvider extends org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator.Provider implements Serializable

Serialized Fields

closeFileCostWeightPercentage

double closeFileCostWeightPercentage

downstreamParallelism

int downstreamParallelism

operatorName

String operatorName

schema

Schema schema

sortOrder

SortOrder sortOrder

type

StatisticsType type

Class org.apache.iceberg.flink.sink.shuffle.DataStatisticsOperator

class DataStatisticsOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<StatisticsOrRecord> implements Serializable

serialVersionUID:

1L

Serialized Fields

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

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

class 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

class RangePartitioner extends Object implements Serializable

Serialized Fields

schema

Schema schema

sortOrder

SortOrder sortOrder

Class org.apache.iceberg.flink.sink.shuffle.StatisticsOrRecord

class StatisticsOrRecord extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

record

org.apache.flink.table.data.RowData record

statistics

org.apache.iceberg.flink.sink.shuffle.GlobalStatistics statistics

Class org.apache.iceberg.flink.sink.shuffle.StatisticsOrRecordTypeInformation

class StatisticsOrRecordTypeInformation extends org.apache.flink.api.common.typeinfo.TypeInformation<StatisticsOrRecord> implements Serializable

Serialized Fields

globalStatisticsSerializer

org.apache.iceberg.flink.sink.shuffle.GlobalStatisticsSerializer globalStatisticsSerializer

rowTypeInformation

org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> rowTypeInformation

sortOrder

SortOrder sortOrder

Package org.apache.iceberg.flink.source

Class org.apache.iceberg.flink.source.AvroGenericRecordFileScanTaskReader

class AvroGenericRecordFileScanTaskReader extends Object implements Serializable

Serialized Fields

converter

RowDataToAvroGenericRecordConverter converter

rowDataReader

RowDataFileScanTaskReader rowDataReader

Class org.apache.iceberg.flink.source.DataTaskReader

class DataTaskReader extends Object implements Serializable

Serialized Fields

readSchema

Schema readSchema

Class org.apache.iceberg.flink.source.FlinkInputFormat

class FlinkInputFormat extends org.apache.flink.api.common.io.RichInputFormat<org.apache.flink.table.data.RowData,FlinkInputSplit> implements Serializable

serialVersionUID:

1L

Serialized Fields

context

ScanContext context

encryption

EncryptionManager encryption

io

FileIO io

rowDataReader

FileScanTaskReader rowDataReader

tableLoader

TableLoader tableLoader

Class org.apache.iceberg.flink.source.FlinkInputSplit

class FlinkInputSplit extends org.apache.flink.core.io.LocatableInputSplit implements Serializable

Serialized Fields

task

CombinedScanTask task

Class org.apache.iceberg.flink.source.IcebergSource

class IcebergSource extends Object implements Serializable

Serialized Fields

assignerFactory

SplitAssignerFactory assignerFactory

batchSplits

List<IcebergSourceSplit> batchSplits

emitter

SerializableRecordEmitter<T> emitter

readerFunction

ReaderFunction<T> readerFunction

scanContext

ScanContext scanContext

splitComparator

SerializableComparator<IcebergSourceSplit> splitComparator

tableLoader

TableLoader tableLoader

tableName

String tableName

Class org.apache.iceberg.flink.source.RowDataFileScanTaskReader

class RowDataFileScanTaskReader extends Object implements Serializable

Serialized Fields

caseSensitive

boolean caseSensitive

nameMapping

String nameMapping

projectedSchema

Schema projectedSchema

rowFilter

FlinkSourceFilter rowFilter

tableSchema

Schema tableSchema

Class org.apache.iceberg.flink.source.RowDataRewriter.RewriteMap

class RewriteMap extends org.apache.flink.api.common.functions.RichMapFunction<CombinedScanTask,List<DataFile>> implements Serializable

Serialized Fields

attemptId

int attemptId

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

class ScanContext extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

asOfTimestamp

Long asOfTimestamp

branch

String branch

caseSensitive

boolean caseSensitive

endSnapshotId

Long endSnapshotId

endTag

String endTag

exposeLocality

boolean exposeLocality

filters

List<Expression> filters

includeColumnStats

boolean includeColumnStats

includeStatsForColumns

Collection<String> includeStatsForColumns

isStreaming

boolean isStreaming

limit

long limit

maxAllowedPlanningFailures

int maxAllowedPlanningFailures

maxPlanningSnapshotCount

int maxPlanningSnapshotCount

monitorInterval

Duration monitorInterval

nameMapping

String nameMapping

planParallelism

Integer planParallelism

schema

Schema schema

snapshotId

Long snapshotId

splitLookback

Integer splitLookback

splitOpenFileCost

Long splitOpenFileCost

splitSize

Long splitSize

startingStrategy

StreamingStartingStrategy startingStrategy

startSnapshotId

Long startSnapshotId

startSnapshotTimestamp

Long startSnapshotTimestamp

startTag

String startTag

tag

String tag

watermarkColumn

String watermarkColumn

watermarkColumnTimeUnit

TimeUnit watermarkColumnTimeUnit

Class org.apache.iceberg.flink.source.StreamingMonitorFunction

class StreamingMonitorFunction extends org.apache.flink.streaming.api.functions.source.RichSourceFunction<FlinkInputSplit> implements Serializable

Serialized Fields

isRunning

boolean isRunning

lastSnapshotId

long lastSnapshotId

scanContext

ScanContext scanContext

tableLoader

TableLoader tableLoader

Class org.apache.iceberg.flink.source.StreamingReaderOperator

class StreamingReaderOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.table.data.RowData> implements Serializable

Serialized Fields

executor

org.apache.flink.api.common.operators.MailboxExecutor executor

format

FlinkInputFormat format

Package org.apache.iceberg.flink.source.assigner

Class org.apache.iceberg.flink.source.assigner.OrderedSplitAssignerFactory

class OrderedSplitAssignerFactory extends Object implements Serializable

Serialized Fields

comparator

SerializableComparator<IcebergSourceSplit> comparator

Class org.apache.iceberg.flink.source.assigner.SimpleSplitAssignerFactory

class SimpleSplitAssignerFactory extends Object implements Serializable

Package org.apache.iceberg.flink.source.enumerator

Class org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorState

class IcebergEnumeratorState extends Object implements Serializable

Serialized Fields

enumerationSplitCountHistory

int[] enumerationSplitCountHistory

lastEnumeratedPosition

org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastEnumeratedPosition

pendingSplits

Collection<IcebergSourceSplitState> pendingSplits

Package org.apache.iceberg.flink.source.reader

Class org.apache.iceberg.flink.source.reader.AvroGenericRecordConverter

class AvroGenericRecordConverter extends 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

class 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

String tableName

Deprecated.

Class org.apache.iceberg.flink.source.reader.ColumnStatsWatermarkExtractor

class ColumnStatsWatermarkExtractor extends Object implements Serializable

Serialized Fields

eventTimeFieldId

int eventTimeFieldId

eventTimeFieldName

String eventTimeFieldName

timeUnit

TimeUnit timeUnit

Class org.apache.iceberg.flink.source.reader.ConverterReaderFunction

class ConverterReaderFunction extends DataIteratorReaderFunction<T> implements Serializable

Serialized Fields

caseSensitive

boolean caseSensitive

converter

RowDataConverter<T> converter

encryption

EncryptionManager encryption

filters

List<Expression> filters

io

FileIO io

limit

long limit

nameMapping

String nameMapping

readSchema

Schema readSchema

tableSchema

Schema tableSchema

Class org.apache.iceberg.flink.source.reader.DataIteratorReaderFunction

class DataIteratorReaderFunction extends Object implements Serializable

Serialized Fields

batcher

DataIteratorBatcher<T> batcher

Class org.apache.iceberg.flink.source.reader.MetaDataReaderFunction

class MetaDataReaderFunction extends DataIteratorReaderFunction<org.apache.flink.table.data.RowData> implements Serializable

Serialized Fields

encryption

EncryptionManager encryption

io

FileIO io

readSchema

Schema readSchema

Class org.apache.iceberg.flink.source.reader.RowConverter

class RowConverter extends Object implements Serializable

Serialized Fields

converter

org.apache.flink.table.data.conversion.DataStructureConverter<Object,Object> converter

outputTypeInfo

org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> outputTypeInfo

Class org.apache.iceberg.flink.source.reader.RowDataReaderFunction

class RowDataReaderFunction extends DataIteratorReaderFunction<org.apache.flink.table.data.RowData> implements Serializable

Serialized Fields

caseSensitive

boolean caseSensitive

encryption

EncryptionManager encryption

filters

List<Expression> filters

io

FileIO io

limit

long limit

nameMapping

String nameMapping

readSchema

Schema readSchema

tableSchema

Schema tableSchema

Package org.apache.iceberg.flink.source.split

Class org.apache.iceberg.flink.source.split.IcebergSourceSplit

class IcebergSourceSplit extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

fileOffset

int fileOffset

recordOffset

long recordOffset

task

CombinedScanTask task

Class org.apache.iceberg.flink.source.split.SplitRequestEvent

class SplitRequestEvent extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

finishedSplitIds

Collection<String> finishedSplitIds

requesterHostname

String requesterHostname

Package org.apache.iceberg.gcp

Class org.apache.iceberg.gcp.GCPProperties

class GCPProperties extends Object implements Serializable

Serialized Fields

clientLibToken

String clientLibToken

gcsChannelReadChunkSize

Integer gcsChannelReadChunkSize

gcsChannelWriteChunkSize

Integer gcsChannelWriteChunkSize

gcsDecryptionKey

String gcsDecryptionKey

gcsDeleteBatchSize

int gcsDeleteBatchSize

gcsEncryptionKey

String gcsEncryptionKey

gcsNoAuth

boolean gcsNoAuth

gcsOauth2RefreshCredentialsEnabled

boolean gcsOauth2RefreshCredentialsEnabled

gcsOauth2RefreshCredentialsEndpoint

String gcsOauth2RefreshCredentialsEndpoint

gcsOAuth2Token

String gcsOAuth2Token

gcsOAuth2TokenExpiresAt

Date gcsOAuth2TokenExpiresAt

gcsUserProject

String gcsUserProject

projectId

String projectId

serviceHost

String serviceHost

Package org.apache.iceberg.gcp.gcs

Class org.apache.iceberg.gcp.gcs.GCSFileIO

class GCSFileIO extends Object implements Serializable

Serialized Fields

gcpProperties

GCPProperties gcpProperties

isResourceClosed

AtomicBoolean isResourceClosed

metrics

MetricsContext metrics

properties

SerializableMap<String,String> properties

storageSupplier

SerializableSupplier<com.google.cloud.storage.Storage> storageSupplier

Package org.apache.iceberg.hadoop

Class org.apache.iceberg.hadoop.HadoopFileIO

class HadoopFileIO extends Object implements Serializable

Serialized Fields

hadoopConf

SerializableSupplier<org.apache.hadoop.conf.Configuration> hadoopConf

properties

SerializableMap<String,String> properties

Class org.apache.iceberg.hadoop.HadoopMetricsContext

class HadoopMetricsContext extends Object implements Serializable

Serialized Fields

scheme

String scheme

Class org.apache.iceberg.hadoop.HiddenPathFilter

class HiddenPathFilter extends Object implements Serializable

Class org.apache.iceberg.hadoop.SerializableConfiguration

class SerializableConfiguration extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws ClassNotFoundException,
IOException

Throws:

ClassNotFoundException

IOException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Package org.apache.iceberg.hive

Exception org.apache.iceberg.hive.RuntimeMetaException

class RuntimeMetaException extends RuntimeException implements Serializable

Package org.apache.iceberg.inmemory

Class org.apache.iceberg.inmemory.InMemoryFileIO

class InMemoryFileIO extends Object implements Serializable

Serialized Fields

closed

boolean closed

Package org.apache.iceberg.io

Exception org.apache.iceberg.io.BulkDeletionFailureException

class BulkDeletionFailureException extends RuntimeException implements Serializable

Serialized Fields

numberFailedObjects

int numberFailedObjects

Class org.apache.iceberg.io.ResolvingFileIO

class ResolvingFileIO extends Object implements Serializable

Serialized Fields

hadoopConf

SerializableSupplier<org.apache.hadoop.conf.Configuration> hadoopConf

ioInstances

Map<String,DelegateFileIO> ioInstances

isClosed

AtomicBoolean isClosed

properties

SerializableMap<String,String> properties

Class org.apache.iceberg.io.WriteResult

class WriteResult extends Object implements Serializable

Serialized Fields

dataFiles

DataFile[] dataFiles

deleteFiles

DeleteFile[] deleteFiles

referencedDataFiles

CharSequence[] referencedDataFiles

rewrittenDeleteFiles

DeleteFile[] rewrittenDeleteFiles

Package org.apache.iceberg.jdbc

Exception org.apache.iceberg.jdbc.UncheckedInterruptedException

class UncheckedInterruptedException extends RuntimeException implements Serializable

Exception org.apache.iceberg.jdbc.UncheckedSQLException

class UncheckedSQLException extends RuntimeException implements Serializable

Package org.apache.iceberg.mapping

Class org.apache.iceberg.mapping.MappedField

class MappedField extends Object implements Serializable

Serialized Fields

id

Integer id

names

Set<String> names

nestedMapping

MappedFields nestedMapping

Class org.apache.iceberg.mapping.MappedFields

class MappedFields extends Object implements Serializable

Serialized Fields

fields

List<MappedField> fields

Class org.apache.iceberg.mapping.NameMapping

class NameMapping extends Object implements Serializable

Serialized Fields

mapping

MappedFields mapping

Package org.apache.iceberg.metrics

Class org.apache.iceberg.metrics.DefaultMetricsContext

class DefaultMetricsContext extends Object implements Serializable

Package org.apache.iceberg.spark

Class org.apache.iceberg.spark.ImmutableOrcBatchReadConf

class ImmutableOrcBatchReadConf extends Object implements Serializable

Serialized Fields

batchSize

int batchSize

Class org.apache.iceberg.spark.ImmutableParquetBatchReadConf

class ImmutableParquetBatchReadConf extends Object implements Serializable

Serialized Fields

batchSize

int batchSize

readerType

ParquetReaderType readerType

Class org.apache.iceberg.spark.SparkTableUtil.SparkPartition

class SparkPartition extends Object implements Serializable

Serialized Fields

format

String format

uri

String uri

values

Map<String,String> values

Package org.apache.iceberg.spark.actions

Class org.apache.iceberg.spark.actions.ManifestFileBean

class ManifestFileBean extends Object implements Serializable

Serialized Fields

addedSnapshotId

Long addedSnapshotId

content

Integer content

length

Long length

partitionSpecId

Integer partitionSpecId

path

String path

sequenceNumber

Long sequenceNumber

Class org.apache.iceberg.spark.actions.RewriteTablePathSparkAction.RewriteContentFileResult

class RewriteContentFileResult extends RewriteTablePathUtil.RewriteResult<ContentFile<?>> implements Serializable

Class org.apache.iceberg.spark.actions.SetAccumulator

class SetAccumulator extends org.apache.spark.util.AccumulatorV2<T,Set<T>> implements Serializable

Serialized Fields

set

Set<T> set

Package org.apache.iceberg.spark.functions

Class org.apache.iceberg.spark.functions.BucketFunction

class BucketFunction extends Object implements Serializable

Class org.apache.iceberg.spark.functions.BucketFunction.BucketBase

class BucketBase extends org.apache.iceberg.spark.functions.BaseScalarFunction<Integer> implements Serializable

Class org.apache.iceberg.spark.functions.BucketFunction.BucketBinary

class BucketBinary extends BucketFunction.BucketBase implements Serializable

Class org.apache.iceberg.spark.functions.BucketFunction.BucketDecimal

class BucketDecimal extends BucketFunction.BucketBase implements Serializable

Serialized Fields

precision

int precision

scale

int scale

sqlType

org.apache.spark.sql.types.DataType sqlType

Class org.apache.iceberg.spark.functions.BucketFunction.BucketInt

class BucketInt extends BucketFunction.BucketBase implements Serializable

Serialized Fields

sqlType

org.apache.spark.sql.types.DataType sqlType

Class org.apache.iceberg.spark.functions.BucketFunction.BucketLong

class BucketLong extends BucketFunction.BucketBase implements Serializable

Serialized Fields

sqlType

org.apache.spark.sql.types.DataType sqlType

Class org.apache.iceberg.spark.functions.BucketFunction.BucketString

class BucketString extends BucketFunction.BucketBase implements Serializable

Class org.apache.iceberg.spark.functions.DaysFunction

class DaysFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable

Class org.apache.iceberg.spark.functions.DaysFunction.DateToDaysFunction

class DateToDaysFunction extends org.apache.iceberg.spark.functions.DaysFunction.BaseToDaysFunction implements Serializable

Class org.apache.iceberg.spark.functions.DaysFunction.TimestampNtzToDaysFunction

class TimestampNtzToDaysFunction extends org.apache.iceberg.spark.functions.DaysFunction.BaseToDaysFunction implements Serializable

Class org.apache.iceberg.spark.functions.DaysFunction.TimestampToDaysFunction

class TimestampToDaysFunction extends org.apache.iceberg.spark.functions.DaysFunction.BaseToDaysFunction implements Serializable

Class org.apache.iceberg.spark.functions.HoursFunction

class HoursFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable

Class org.apache.iceberg.spark.functions.HoursFunction.TimestampNtzToHoursFunction

class TimestampNtzToHoursFunction extends org.apache.iceberg.spark.functions.BaseScalarFunction<Integer> implements Serializable

Class org.apache.iceberg.spark.functions.HoursFunction.TimestampToHoursFunction

class TimestampToHoursFunction extends org.apache.iceberg.spark.functions.BaseScalarFunction<Integer> implements Serializable

Class org.apache.iceberg.spark.functions.IcebergVersionFunction

class IcebergVersionFunction extends Object implements Serializable

Class org.apache.iceberg.spark.functions.MonthsFunction

class MonthsFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable

Class org.apache.iceberg.spark.functions.MonthsFunction.DateToMonthsFunction

class DateToMonthsFunction extends org.apache.iceberg.spark.functions.MonthsFunction.BaseToMonthsFunction implements Serializable

Class org.apache.iceberg.spark.functions.MonthsFunction.TimestampNtzToMonthsFunction

class TimestampNtzToMonthsFunction extends org.apache.iceberg.spark.functions.MonthsFunction.BaseToMonthsFunction implements Serializable

Class org.apache.iceberg.spark.functions.MonthsFunction.TimestampToMonthsFunction

class TimestampToMonthsFunction extends org.apache.iceberg.spark.functions.MonthsFunction.BaseToMonthsFunction implements Serializable

Class org.apache.iceberg.spark.functions.TruncateFunction

class TruncateFunction extends Object implements Serializable

Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateBase

class TruncateBase extends org.apache.iceberg.spark.functions.BaseScalarFunction<T> implements Serializable

Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateBigInt

class TruncateBigInt extends TruncateFunction.TruncateBase<Long> implements Serializable

Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateBinary

class TruncateBinary extends TruncateFunction.TruncateBase<byte[]> implements Serializable

Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateDecimal

class TruncateDecimal extends TruncateFunction.TruncateBase<org.apache.spark.sql.types.Decimal> implements Serializable

Serialized Fields

precision

int precision

scale

int scale

Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateInt

class TruncateInt extends TruncateFunction.TruncateBase<Integer> implements Serializable

Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateSmallInt

class TruncateSmallInt extends TruncateFunction.TruncateBase<Short> implements Serializable

Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateString

class TruncateString extends TruncateFunction.TruncateBase<org.apache.spark.unsafe.types.UTF8String> implements Serializable

Class org.apache.iceberg.spark.functions.TruncateFunction.TruncateTinyInt

class TruncateTinyInt extends TruncateFunction.TruncateBase<Byte> implements Serializable

Class org.apache.iceberg.spark.functions.YearsFunction

class YearsFunction extends org.apache.iceberg.spark.functions.UnaryUnboundFunction implements Serializable

Class org.apache.iceberg.spark.functions.YearsFunction.DateToYearsFunction

class DateToYearsFunction extends org.apache.iceberg.spark.functions.YearsFunction.BaseToYearsFunction implements Serializable

Class org.apache.iceberg.spark.functions.YearsFunction.TimestampNtzToYearsFunction

class TimestampNtzToYearsFunction extends org.apache.iceberg.spark.functions.YearsFunction.BaseToYearsFunction implements Serializable

Class org.apache.iceberg.spark.functions.YearsFunction.TimestampToYearsFunction

class TimestampToYearsFunction extends org.apache.iceberg.spark.functions.YearsFunction.BaseToYearsFunction implements Serializable

Package org.apache.iceberg.spark.source

Class org.apache.iceberg.spark.source.SerializableTableWithSize

class SerializableTableWithSize extends SerializableTable implements Serializable

Class org.apache.iceberg.spark.source.SerializableTableWithSize.SerializableMetadataTableWithSize

class SerializableMetadataTableWithSize extends SerializableTable.SerializableMetadataTable implements Serializable

Class org.apache.iceberg.spark.source.SparkPositionDeletesRewrite.DeleteTaskCommit

class DeleteTaskCommit extends Object implements Serializable

Serialized Fields

taskFiles

DeleteFile[] taskFiles

Class org.apache.iceberg.spark.source.SparkPositionDeltaWrite.DeltaTaskCommit

class DeltaTaskCommit extends Object implements Serializable

Serialized Fields

dataFiles

DataFile[] dataFiles

deleteFiles

DeleteFile[] deleteFiles

referencedDataFiles

CharSequence[] referencedDataFiles

rewrittenDeleteFiles

DeleteFile[] rewrittenDeleteFiles

Class org.apache.iceberg.spark.source.SparkWrite.TaskCommit

class TaskCommit extends Object implements Serializable

Serialized Fields

taskFiles

DataFile[] taskFiles

Package org.apache.iceberg.transforms

Class org.apache.iceberg.transforms.Days

class Days extends org.apache.iceberg.transforms.TimeTransform<T> implements Serializable

Serialization Methods

writeReplace

Object writeReplace()
             throws ObjectStreamException

Throws:

ObjectStreamException

Class org.apache.iceberg.transforms.Hours

class Hours extends org.apache.iceberg.transforms.TimeTransform<T> implements Serializable

Serialization Methods

writeReplace

Object writeReplace()
             throws ObjectStreamException

Throws:

ObjectStreamException

Class org.apache.iceberg.transforms.Months

class Months extends org.apache.iceberg.transforms.TimeTransform<T> implements Serializable

Serialization Methods

writeReplace

Object writeReplace()
             throws ObjectStreamException

Throws:

ObjectStreamException

Class org.apache.iceberg.transforms.UnknownTransform

class UnknownTransform extends Object implements Serializable

Serialized Fields

transform

String transform

Package org.apache.iceberg.types

Class org.apache.iceberg.types.Type.NestedType

class NestedType extends Object implements Serializable

Class org.apache.iceberg.types.Type.PrimitiveType

class PrimitiveType extends Object implements Serializable

Serialization Methods

writeReplace

Object writeReplace()
             throws ObjectStreamException

Throws:

ObjectStreamException

Class org.apache.iceberg.types.Types.BinaryType

class BinaryType extends Type.PrimitiveType implements Serializable

Class org.apache.iceberg.types.Types.BooleanType

class BooleanType extends Type.PrimitiveType implements Serializable

Class org.apache.iceberg.types.Types.DateType

class DateType extends Type.PrimitiveType implements Serializable

Class org.apache.iceberg.types.Types.DecimalType

class DecimalType extends Type.PrimitiveType implements Serializable

Serialized Fields

precision

int precision

scale

int scale

Class org.apache.iceberg.types.Types.DoubleType

class DoubleType extends Type.PrimitiveType implements Serializable

Class org.apache.iceberg.types.Types.FixedType

class FixedType extends Type.PrimitiveType implements Serializable

Serialized Fields

length

int length

Class org.apache.iceberg.types.Types.FloatType

class FloatType extends Type.PrimitiveType implements Serializable

Class org.apache.iceberg.types.Types.IntegerType

class IntegerType extends Type.PrimitiveType implements Serializable

Class org.apache.iceberg.types.Types.ListType

class ListType extends Type.NestedType implements Serializable

Serialized Fields

elementField

Types.NestedField elementField

Class org.apache.iceberg.types.Types.LongType

class LongType extends Type.PrimitiveType implements Serializable

Class org.apache.iceberg.types.Types.MapType

class MapType extends Type.NestedType implements Serializable

Serialized Fields

keyField

Types.NestedField keyField

valueField

Types.NestedField valueField

Class org.apache.iceberg.types.Types.NestedField

class NestedField extends Object implements Serializable

Serialized Fields

doc

String doc

id

int id

initialDefault

Object initialDefault

isOptional

boolean isOptional

name

String name

type

Type type

writeDefault

Object writeDefault

Class org.apache.iceberg.types.Types.StringType

class StringType extends Type.PrimitiveType implements Serializable

Class org.apache.iceberg.types.Types.StructType

class StructType extends Type.NestedType implements Serializable

Serialized Fields

fields

Types.NestedField[] fields

Class org.apache.iceberg.types.Types.TimestampNanoType

class TimestampNanoType extends Type.PrimitiveType implements Serializable

Serialized Fields

adjustToUTC

boolean adjustToUTC

Class org.apache.iceberg.types.Types.TimestampType

class TimestampType extends Type.PrimitiveType implements Serializable

Serialized Fields

adjustToUTC

boolean adjustToUTC

Class org.apache.iceberg.types.Types.TimeType

class TimeType extends Type.PrimitiveType implements Serializable

Class org.apache.iceberg.types.Types.UnknownType

class UnknownType extends Type.PrimitiveType implements Serializable

Class org.apache.iceberg.types.Types.UUIDType

class UUIDType extends Type.PrimitiveType implements Serializable

Class org.apache.iceberg.types.Types.VariantType

class VariantType extends Object implements Serializable

Package org.apache.iceberg.util

Class org.apache.iceberg.util.CharSequenceMap

class CharSequenceMap extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

wrapperMap

Map<CharSequenceWrapper,V> wrapperMap

Class org.apache.iceberg.util.CharSequenceSet

class CharSequenceSet extends Object implements Serializable

Serialized Fields

wrapperSet

Set<CharSequenceWrapper> wrapperSet

Class org.apache.iceberg.util.CharSequenceWrapper

class CharSequenceWrapper extends Object implements Serializable

Serialized Fields

wrapped

CharSequence wrapped

Class org.apache.iceberg.util.DataFileSet

class DataFileSet extends org.apache.iceberg.util.WrapperSet<DataFile> implements Serializable

Class org.apache.iceberg.util.DeleteFileSet

class DeleteFileSet extends org.apache.iceberg.util.WrapperSet<DeleteFile> implements Serializable

Class org.apache.iceberg.util.Pair

class Pair extends Object implements Serializable

Serialized Fields

first

X first

schema

org.apache.avro.Schema schema

second

Y second

Class org.apache.iceberg.util.SerializableMap

class SerializableMap extends Object implements Serializable

serialVersionUID:

-3377238354349859240L

Serialized Fields

copiedMap

Map<K,V> copiedMap

Exception org.apache.iceberg.util.Tasks.UnrecoverableException

class UnrecoverableException extends RuntimeException implements Serializable

Package org.apache.iceberg.view

Class org.apache.iceberg.view.BaseView

class BaseView extends Object implements Serializable

Serialized Fields

name

String name

ops

ViewOperations ops

Package org.apache.spark.sql.catalyst.analysis

Class org.apache.spark.sql.catalyst.analysis.AnalysisContext

class AnalysisContext extends Object implements Serializable

Serialized Fields

catalogAndNamespace

scala.collection.Seq<String> catalogAndNamespace

maxNestedViewDepth

int maxNestedViewDepth

nestedViewDepth

int nestedViewDepth

outerPlan

scala.Option<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> outerPlan

referredTempFunctionNames

scala.collection.mutable.Set<String> referredTempFunctionNames

referredTempViewNames

scala.collection.Seq<scala.collection.Seq<String>> referredTempViewNames

relationCache

scala.collection.mutable.Map<scala.Tuple2<scala.collection.Seq<String>,scala.Option<org.apache.spark.sql.catalyst.analysis.TimeTravelSpec>>,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> relationCache

Class org.apache.spark.sql.catalyst.analysis.AnalysisContext$

class AnalysisContext$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Serialized Fields

value

ThreadLocal<org.apache.spark.sql.catalyst.analysis.AnalysisContext> value

Class org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveReferences$MergeResolvePolicy$

class Analyzer$ResolveReferences$MergeResolvePolicy$ extends scala.Enumeration implements Serializable

Serialized Fields

BOTH

scala.Enumeration.Value BOTH

SOURCE

scala.Enumeration.Value SOURCE

TARGET

scala.Enumeration.Value TARGET

Class org.apache.spark.sql.catalyst.analysis.AsOfTimestamp

class AsOfTimestamp extends Object implements Serializable

Serialized Fields

timestamp

long timestamp

Class org.apache.spark.sql.catalyst.analysis.AsOfTimestamp$

class AsOfTimestamp$ extends scala.runtime.AbstractFunction1<Object,org.apache.spark.sql.catalyst.analysis.AsOfTimestamp> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.AsOfVersion

class AsOfVersion extends Object implements Serializable

Serialized Fields

version

String version

Class org.apache.spark.sql.catalyst.analysis.AsOfVersion$

class AsOfVersion$ extends scala.runtime.AbstractFunction1<String,org.apache.spark.sql.catalyst.analysis.AsOfVersion> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.CannotReplaceMissingTableException

class CannotReplaceMissingTableException extends org.apache.spark.sql.AnalysisException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.CannotReplaceMissingTableException$

class CannotReplaceMissingTableException$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.DatabaseAlreadyExistsException

class DatabaseAlreadyExistsException extends org.apache.spark.sql.catalyst.analysis.NamespaceAlreadyExistsException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.ExpressionWithUnresolvedIdentifier

class ExpressionWithUnresolvedIdentifier extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

exprBuilder

scala.Function1<scala.collection.Seq<String>,org.apache.spark.sql.catalyst.expressions.Expression> exprBuilder

identifierExpr

org.apache.spark.sql.catalyst.expressions.Expression identifierExpr

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.ExpressionWithUnresolvedIdentifier$

class ExpressionWithUnresolvedIdentifier$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.Function1<scala.collection.Seq<String>,org.apache.spark.sql.catalyst.expressions.Expression>,org.apache.spark.sql.catalyst.analysis.ExpressionWithUnresolvedIdentifier> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.FunctionAlreadyExistsException

class FunctionAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.GetColumnByOrdinal

class GetColumnByOrdinal extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

dataType

org.apache.spark.sql.types.DataType dataType

ordinal

int ordinal

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.GetColumnByOrdinal$

class GetColumnByOrdinal$ extends scala.runtime.AbstractFunction2<Object,org.apache.spark.sql.types.DataType,org.apache.spark.sql.catalyst.analysis.GetColumnByOrdinal> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.GetViewColumnByNameAndOrdinal

class GetViewColumnByNameAndOrdinal extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

colName

String colName

expectedNumCandidates

int expectedNumCandidates

ordinal

int ordinal

resolved

boolean resolved

viewDDL

scala.Option<String> viewDDL

viewName

String viewName

Class org.apache.spark.sql.catalyst.analysis.GetViewColumnByNameAndOrdinal$

class GetViewColumnByNameAndOrdinal$ extends scala.runtime.AbstractFunction5<String,String,Object,Object,scala.Option<String>,org.apache.spark.sql.catalyst.analysis.GetViewColumnByNameAndOrdinal> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.IndexAlreadyExistsException

class IndexAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.IndexAlreadyExistsException$

class IndexAlreadyExistsException$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.MultiAlias

class MultiAlias extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

child

org.apache.spark.sql.catalyst.expressions.Expression child

names

scala.collection.Seq<String> names

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.MultiAlias$

class MultiAlias$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.collection.Seq<String>,org.apache.spark.sql.catalyst.analysis.MultiAlias> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.NamedParameter

class NamedParameter extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

name

String name

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.NamedParameter$

class NamedParameter$ extends scala.runtime.AbstractFunction1<String,org.apache.spark.sql.catalyst.analysis.NamedParameter> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.NameParameterizedQuery

class NameParameterizedQuery extends org.apache.spark.sql.catalyst.analysis.ParameterizedQuery implements Serializable

Serialized Fields

args

scala.collection.immutable.Map<String,org.apache.spark.sql.catalyst.expressions.Expression> args

child

org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child

Class org.apache.spark.sql.catalyst.analysis.NameParameterizedQuery$

class NameParameterizedQuery$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,scala.collection.immutable.Map<String,org.apache.spark.sql.catalyst.expressions.Expression>,org.apache.spark.sql.catalyst.analysis.NameParameterizedQuery> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.NamespaceAlreadyExistsException

class NamespaceAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable

Exception org.apache.spark.sql.catalyst.analysis.NonEmptyNamespaceException

class NonEmptyNamespaceException extends org.apache.spark.sql.AnalysisException implements Serializable

Serialized Fields

cause

scala.Option<Throwable> cause

message

String message

Class org.apache.spark.sql.catalyst.analysis.NonEmptyNamespaceException$

class NonEmptyNamespaceException$ extends scala.runtime.AbstractFunction2<String,scala.Option<Throwable>,org.apache.spark.sql.catalyst.analysis.NonEmptyNamespaceException> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.NoSuchDatabaseException

class NoSuchDatabaseException extends org.apache.spark.sql.AnalysisException implements Serializable

Exception org.apache.spark.sql.catalyst.analysis.NoSuchFunctionException

class NoSuchFunctionException extends org.apache.spark.sql.AnalysisException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.NoSuchFunctionException$

class NoSuchFunctionException$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.NoSuchIndexException

class NoSuchIndexException extends org.apache.spark.sql.AnalysisException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.NoSuchIndexException$

class NoSuchIndexException$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException

class NoSuchNamespaceException extends org.apache.spark.sql.AnalysisException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.NoSuchNamespaceException$

class NoSuchNamespaceException$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.NoSuchPartitionException

class NoSuchPartitionException extends org.apache.spark.sql.AnalysisException implements Serializable

Exception org.apache.spark.sql.catalyst.analysis.NoSuchPartitionsException

class NoSuchPartitionsException extends org.apache.spark.sql.AnalysisException implements Serializable

Exception org.apache.spark.sql.catalyst.analysis.NoSuchPermanentFunctionException

class NoSuchPermanentFunctionException extends org.apache.spark.sql.AnalysisException implements Serializable

Exception org.apache.spark.sql.catalyst.analysis.NoSuchProcedureException

class NoSuchProcedureException extends org.apache.spark.sql.AnalysisException implements Serializable

Exception org.apache.spark.sql.catalyst.analysis.NoSuchTableException

class NoSuchTableException extends org.apache.spark.sql.AnalysisException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.NoSuchTableException$

class NoSuchTableException$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.NoSuchTempFunctionException

class NoSuchTempFunctionException extends org.apache.spark.sql.AnalysisException implements Serializable

Exception org.apache.spark.sql.catalyst.analysis.NoSuchViewException

class NoSuchViewException extends org.apache.spark.sql.AnalysisException implements Serializable

Exception org.apache.spark.sql.catalyst.analysis.PartitionAlreadyExistsException

class PartitionAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable

Exception org.apache.spark.sql.catalyst.analysis.PartitionsAlreadyExistException

class PartitionsAlreadyExistException extends org.apache.spark.sql.AnalysisException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.PlanWithUnresolvedIdentifier

class PlanWithUnresolvedIdentifier extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

children

scala.collection.Seq<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> children

identifierExpr

org.apache.spark.sql.catalyst.expressions.Expression identifierExpr

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

planBuilder

scala.Function2<scala.collection.Seq<String>,scala.collection.Seq<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> planBuilder

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.PlanWithUnresolvedIdentifier$

class PlanWithUnresolvedIdentifier$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.catalyst.expressions.Expression,scala.collection.Seq<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>,scala.Function2<scala.collection.Seq<String>,scala.collection.Seq<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>,org.apache.spark.sql.catalyst.analysis.PlanWithUnresolvedIdentifier> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.PosParameter

class PosParameter extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

pos

int pos

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.PosParameter$

class PosParameter$ extends scala.runtime.AbstractFunction1<Object,org.apache.spark.sql.catalyst.analysis.PosParameter> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.PosParameterizedQuery

class PosParameterizedQuery extends org.apache.spark.sql.catalyst.analysis.ParameterizedQuery implements Serializable

Serialized Fields

args

org.apache.spark.sql.catalyst.expressions.Expression[] args

child

org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child

Class org.apache.spark.sql.catalyst.analysis.PosParameterizedQuery$

class PosParameterizedQuery$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,org.apache.spark.sql.catalyst.expressions.Expression[],org.apache.spark.sql.catalyst.analysis.PosParameterizedQuery> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.RelationTimeTravel

class RelationTimeTravel extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

relation

org.apache.spark.sql.catalyst.plans.logical.LogicalPlan relation

resolved

boolean resolved

timestamp

scala.Option<org.apache.spark.sql.catalyst.expressions.Expression> timestamp

version

scala.Option<String> version

Class org.apache.spark.sql.catalyst.analysis.RelationTimeTravel$

class RelationTimeTravel$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,scala.Option<org.apache.spark.sql.catalyst.expressions.Expression>,scala.Option<String>,org.apache.spark.sql.catalyst.analysis.RelationTimeTravel> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.RelationWrapper

class RelationWrapper extends Object implements Serializable

Serialized Fields

cls

Class<?> cls

outputAttrIds

scala.collection.Seq<Object> outputAttrIds

Class org.apache.spark.sql.catalyst.analysis.RelationWrapper$

class RelationWrapper$ extends scala.runtime.AbstractFunction2<Class<?>,scala.collection.Seq<Object>,org.apache.spark.sql.catalyst.analysis.RelationWrapper> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolveColumnDefaultInInsert$

class ResolveColumnDefaultInInsert$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Serialized Fields

org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions

scala.collection.Seq<scala.Tuple3<String,scala.Function0<org.apache.spark.sql.catalyst.expressions.Expression>,scala.Function1<org.apache.spark.sql.catalyst.expressions.Expression,String>>> org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions

Class org.apache.spark.sql.catalyst.analysis.ResolvedFieldName

class ResolvedFieldName extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialized Fields

field

org.apache.spark.sql.types.StructField field

path

scala.collection.Seq<String> path

Class org.apache.spark.sql.catalyst.analysis.ResolvedFieldName$

class ResolvedFieldName$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<String>,org.apache.spark.sql.types.StructField,org.apache.spark.sql.catalyst.analysis.ResolvedFieldName> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolvedFieldPosition

class ResolvedFieldPosition extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialized Fields

position

org.apache.spark.sql.connector.catalog.TableChange.ColumnPosition position

Class org.apache.spark.sql.catalyst.analysis.ResolvedFieldPosition$

class ResolvedFieldPosition$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.connector.catalog.TableChange.ColumnPosition,org.apache.spark.sql.catalyst.analysis.ResolvedFieldPosition> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolvedIdentifier

class ResolvedIdentifier extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

catalog

org.apache.spark.sql.connector.catalog.CatalogPlugin catalog

identifier

org.apache.spark.sql.connector.catalog.Identifier identifier

Class org.apache.spark.sql.catalyst.analysis.ResolvedIdentifier$

class ResolvedIdentifier$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.connector.catalog.CatalogPlugin,org.apache.spark.sql.connector.catalog.Identifier,org.apache.spark.sql.catalyst.analysis.ResolvedIdentifier> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolvedInlineTable

class ResolvedInlineTable extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

output

scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output

rows

scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>> rows

Class org.apache.spark.sql.catalyst.analysis.ResolvedInlineTable$

class ResolvedInlineTable$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>>,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>,org.apache.spark.sql.catalyst.analysis.ResolvedInlineTable> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolvedNamespace

class ResolvedNamespace extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

catalog

org.apache.spark.sql.connector.catalog.CatalogPlugin catalog

namespace

scala.collection.Seq<String> namespace

Class org.apache.spark.sql.catalyst.analysis.ResolvedNamespace$

class ResolvedNamespace$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.connector.catalog.CatalogPlugin,scala.collection.Seq<String>,org.apache.spark.sql.catalyst.analysis.ResolvedNamespace> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolvedNonPersistentFunc

class ResolvedNonPersistentFunc extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

func

org.apache.spark.sql.connector.catalog.functions.UnboundFunction func

name

String name

Class org.apache.spark.sql.catalyst.analysis.ResolvedNonPersistentFunc$

class ResolvedNonPersistentFunc$ extends scala.runtime.AbstractFunction2<String,org.apache.spark.sql.connector.catalog.functions.UnboundFunction,org.apache.spark.sql.catalyst.analysis.ResolvedNonPersistentFunc> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolvedPartitionSpec

class ResolvedPartitionSpec extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialized Fields

ident

org.apache.spark.sql.catalyst.InternalRow ident

location

scala.Option<String> location

names

scala.collection.Seq<String> names

Class org.apache.spark.sql.catalyst.analysis.ResolvedPartitionSpec$

class ResolvedPartitionSpec$ extends scala.runtime.AbstractFunction3<scala.collection.Seq<String>,org.apache.spark.sql.catalyst.InternalRow,scala.Option<String>,org.apache.spark.sql.catalyst.analysis.ResolvedPartitionSpec> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolvedPersistentFunc

class ResolvedPersistentFunc extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

catalog

org.apache.spark.sql.connector.catalog.FunctionCatalog catalog

func

org.apache.spark.sql.connector.catalog.functions.UnboundFunction func

identifier

org.apache.spark.sql.connector.catalog.Identifier identifier

Class org.apache.spark.sql.catalyst.analysis.ResolvedPersistentFunc$

class ResolvedPersistentFunc$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.connector.catalog.FunctionCatalog,org.apache.spark.sql.connector.catalog.Identifier,org.apache.spark.sql.connector.catalog.functions.UnboundFunction,org.apache.spark.sql.catalyst.analysis.ResolvedPersistentFunc> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolvedPersistentView

class ResolvedPersistentView extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

catalog

org.apache.spark.sql.connector.catalog.CatalogPlugin catalog

identifier

org.apache.spark.sql.connector.catalog.Identifier identifier

viewSchema

org.apache.spark.sql.types.StructType viewSchema

Class org.apache.spark.sql.catalyst.analysis.ResolvedPersistentView$

class ResolvedPersistentView$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.connector.catalog.CatalogPlugin,org.apache.spark.sql.connector.catalog.Identifier,org.apache.spark.sql.types.StructType,org.apache.spark.sql.catalyst.analysis.ResolvedPersistentView> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolvedStar

class ResolvedStar extends org.apache.spark.sql.catalyst.analysis.Star implements Serializable

Serialized Fields

expressions

scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression> expressions

Class org.apache.spark.sql.catalyst.analysis.ResolvedStar$

class ResolvedStar$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.NamedExpression>,org.apache.spark.sql.catalyst.analysis.ResolvedStar> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolvedTable

class ResolvedTable extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

catalog

org.apache.spark.sql.connector.catalog.TableCatalog catalog

identifier

org.apache.spark.sql.connector.catalog.Identifier identifier

outputAttributes

scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> outputAttributes

table

org.apache.spark.sql.connector.catalog.Table table

Class org.apache.spark.sql.catalyst.analysis.ResolvedTable$

class ResolvedTable$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolvedTempView

class ResolvedTempView extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

identifier

org.apache.spark.sql.connector.catalog.Identifier identifier

viewSchema

org.apache.spark.sql.types.StructType viewSchema

Class org.apache.spark.sql.catalyst.analysis.ResolvedTempView$

class ResolvedTempView$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.connector.catalog.Identifier,org.apache.spark.sql.types.StructType,org.apache.spark.sql.catalyst.analysis.ResolvedTempView> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolveLateralColumnAliasReference.AliasEntry

class AliasEntry extends Object implements Serializable

Serialized Fields

alias

org.apache.spark.sql.catalyst.expressions.Alias alias

index

int index

Class org.apache.spark.sql.catalyst.analysis.ResolveLateralColumnAliasReference.AliasEntry$

class AliasEntry$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Alias,Object,org.apache.spark.sql.catalyst.analysis.ResolveLateralColumnAliasReference.AliasEntry> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolveProcedures

class ResolveProcedures extends org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> implements Serializable

Serialized Fields

AsTableIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.AsTableIdentifier$ AsTableIdentifier$module

bitmap$0

boolean bitmap$0

CatalogAndIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndIdentifier$ CatalogAndIdentifier$module

CatalogAndMultipartIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndMultipartIdentifier$ CatalogAndMultipartIdentifier$module

CatalogAndNamespace$module

org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndNamespace$ CatalogAndNamespace$module

catalogManager

org.apache.spark.sql.connector.catalog.CatalogManager catalogManager

NonSessionCatalogAndIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.NonSessionCatalogAndIdentifier$ NonSessionCatalogAndIdentifier$module

SessionCatalogAndIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.SessionCatalogAndIdentifier$ SessionCatalogAndIdentifier$module

spark

org.apache.spark.sql.SparkSession spark

Class org.apache.spark.sql.catalyst.analysis.ResolveProcedures$

class ResolveProcedures$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.SparkSession,org.apache.spark.sql.catalyst.analysis.ResolveProcedures> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.ResolveReferencesInUpdate$

class ResolveReferencesInUpdate$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Serialized Fields

org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions

scala.collection.Seq<scala.Tuple3<String,scala.Function0<org.apache.spark.sql.catalyst.expressions.Expression>,scala.Function1<org.apache.spark.sql.catalyst.expressions.Expression,String>>> org$apache$spark$sql$catalyst$analysis$ColumnResolutionHelper$$literalFunctions

Class org.apache.spark.sql.catalyst.analysis.ResolveViews

class ResolveViews extends org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> implements Serializable

Serialized Fields

AsTableIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.AsTableIdentifier$ AsTableIdentifier$module

bitmap$0

boolean bitmap$0

CatalogAndIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndIdentifier$ CatalogAndIdentifier$module

CatalogAndMultipartIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndMultipartIdentifier$ CatalogAndMultipartIdentifier$module

CatalogAndNamespace$module

org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndNamespace$ CatalogAndNamespace$module

catalogManager

org.apache.spark.sql.connector.catalog.CatalogManager catalogManager

NonSessionCatalogAndIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.NonSessionCatalogAndIdentifier$ NonSessionCatalogAndIdentifier$module

SessionCatalogAndIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.SessionCatalogAndIdentifier$ SessionCatalogAndIdentifier$module

spark

org.apache.spark.sql.SparkSession spark

Class org.apache.spark.sql.catalyst.analysis.ResolveViews$

class ResolveViews$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.SparkSession,org.apache.spark.sql.catalyst.analysis.ResolveViews> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.RewriteViewCommands

class RewriteViewCommands extends org.apache.spark.sql.catalyst.rules.Rule<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> implements Serializable

Serialized Fields

AsTableIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.AsTableIdentifier$ AsTableIdentifier$module

bitmap$0

boolean bitmap$0

CatalogAndIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndIdentifier$ CatalogAndIdentifier$module

CatalogAndMultipartIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndMultipartIdentifier$ CatalogAndMultipartIdentifier$module

CatalogAndNamespace$module

org.apache.spark.sql.connector.catalog.LookupCatalog.CatalogAndNamespace$ CatalogAndNamespace$module

catalogManager

org.apache.spark.sql.connector.catalog.CatalogManager catalogManager

NonSessionCatalogAndIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.NonSessionCatalogAndIdentifier$ NonSessionCatalogAndIdentifier$module

ResolvedIdent$module

org.apache.spark.sql.catalyst.analysis.RewriteViewCommands.ResolvedIdent$ ResolvedIdent$module

ResolvedView$module

org.apache.spark.sql.catalyst.analysis.RewriteViewCommands.ResolvedView$ ResolvedView$module

SessionCatalogAndIdentifier$module

org.apache.spark.sql.connector.catalog.LookupCatalog.SessionCatalogAndIdentifier$ SessionCatalogAndIdentifier$module

spark

org.apache.spark.sql.SparkSession spark

Class org.apache.spark.sql.catalyst.analysis.RewriteViewCommands$

class RewriteViewCommands$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.SparkSession,org.apache.spark.sql.catalyst.analysis.RewriteViewCommands> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.TableAlreadyExistsException

class TableAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.TableAlreadyExistsException$

class TableAlreadyExistsException$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.TempResolvedColumn

class TempResolvedColumn extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable

Serialized Fields

bitmap$0

byte bitmap$0

canonicalized

org.apache.spark.sql.catalyst.expressions.Expression canonicalized

child

org.apache.spark.sql.catalyst.expressions.Expression child

hasTried

boolean hasTried

nameParts

scala.collection.Seq<String> nameParts

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.TempResolvedColumn$

class TempResolvedColumn$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.catalyst.expressions.Expression,scala.collection.Seq<String>,Object,org.apache.spark.sql.catalyst.analysis.TempResolvedColumn> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.TempTableAlreadyExistsException

class TempTableAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.TempTableAlreadyExistsException$

class TempTableAlreadyExistsException$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.DataTypeMismatch

class DataTypeMismatch extends Object implements Serializable

Serialized Fields

errorSubClass

String errorSubClass

messageParameters

scala.collection.immutable.Map<String,String> messageParameters

Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.DataTypeMismatch$

class DataTypeMismatch$ extends scala.runtime.AbstractFunction2<String,scala.collection.immutable.Map<String,String>,org.apache.spark.sql.catalyst.analysis.TypeCheckResult.DataTypeMismatch> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.InvalidFormat

class InvalidFormat extends Object implements Serializable

Serialized Fields

errorSubClass

String errorSubClass

messageParameters

scala.collection.immutable.Map<String,String> messageParameters

Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.InvalidFormat$

class InvalidFormat$ extends scala.runtime.AbstractFunction2<String,scala.collection.immutable.Map<String,String>,org.apache.spark.sql.catalyst.analysis.TypeCheckResult.InvalidFormat> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.TypeCheckFailure

class TypeCheckFailure extends Object implements Serializable

Serialized Fields

message

String message

Class org.apache.spark.sql.catalyst.analysis.TypeCheckResult.TypeCheckFailure$

class TypeCheckFailure$ extends scala.runtime.AbstractFunction1<String,org.apache.spark.sql.catalyst.analysis.TypeCheckResult.TypeCheckFailure> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedAlias

class UnresolvedAlias extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable

Serialized Fields

aliasFunc

scala.Option<scala.Function1<org.apache.spark.sql.catalyst.expressions.Expression,String>> aliasFunc

bitmap$0

boolean bitmap$0

child

org.apache.spark.sql.catalyst.expressions.Expression child

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedAlias$

class UnresolvedAlias$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.Option<scala.Function1<org.apache.spark.sql.catalyst.expressions.Expression,String>>,org.apache.spark.sql.catalyst.analysis.UnresolvedAlias> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute

class UnresolvedAttribute extends org.apache.spark.sql.catalyst.expressions.Attribute implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

nameParts

scala.collection.Seq<String> nameParts

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute$

class UnresolvedAttribute$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedDeserializer

class UnresolvedDeserializer extends org.apache.spark.sql.catalyst.expressions.UnaryExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

deserializer

org.apache.spark.sql.catalyst.expressions.Expression deserializer

inputAttributes

scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> inputAttributes

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedDeserializer$

class UnresolvedDeserializer$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>,org.apache.spark.sql.catalyst.analysis.UnresolvedDeserializer> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.UnresolvedException

class UnresolvedException extends org.apache.spark.sql.AnalysisException implements Serializable

Class org.apache.spark.sql.catalyst.analysis.UnresolvedExtractValue

class UnresolvedExtractValue extends org.apache.spark.sql.catalyst.expressions.BinaryExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

child

org.apache.spark.sql.catalyst.expressions.Expression child

extraction

org.apache.spark.sql.catalyst.expressions.Expression extraction

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedExtractValue$

class UnresolvedExtractValue$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.analysis.UnresolvedExtractValue> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedFieldName

class UnresolvedFieldName extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

name

scala.collection.Seq<String> name

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedFieldName$

class UnresolvedFieldName$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<String>,org.apache.spark.sql.catalyst.analysis.UnresolvedFieldName> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedFieldPosition

class UnresolvedFieldPosition extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

position

org.apache.spark.sql.connector.catalog.TableChange.ColumnPosition position

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedFieldPosition$

class UnresolvedFieldPosition$ extends scala.runtime.AbstractFunction1<org.apache.spark.sql.connector.catalog.TableChange.ColumnPosition,org.apache.spark.sql.catalyst.analysis.UnresolvedFieldPosition> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedFunction

class UnresolvedFunction extends org.apache.spark.sql.catalyst.expressions.Expression implements Serializable

Serialized Fields

arguments

scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> arguments

bitmap$0

boolean bitmap$0

filter

scala.Option<org.apache.spark.sql.catalyst.expressions.Expression> filter

ignoreNulls

boolean ignoreNulls

isDistinct

boolean isDistinct

nameParts

scala.collection.Seq<String> nameParts

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedFunction$

class UnresolvedFunction$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedFunctionName

class UnresolvedFunctionName extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

commandName

String commandName

funcTypeMismatchHint

scala.Option<String> funcTypeMismatchHint

multipartIdentifier

scala.collection.Seq<String> multipartIdentifier

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

possibleQualifiedName

scala.Option<scala.collection.Seq<String>> possibleQualifiedName

requirePersistent

boolean requirePersistent

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedFunctionName$

class UnresolvedFunctionName$ extends scala.runtime.AbstractFunction5<scala.collection.Seq<String>,String,Object,scala.Option<String>,scala.Option<scala.collection.Seq<String>>,org.apache.spark.sql.catalyst.analysis.UnresolvedFunctionName> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedGenerator

class UnresolvedGenerator extends org.apache.spark.sql.catalyst.expressions.Expression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

children

scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> children

name

org.apache.spark.sql.catalyst.FunctionIdentifier name

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedGenerator$

class UnresolvedGenerator$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.FunctionIdentifier,scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,org.apache.spark.sql.catalyst.analysis.UnresolvedGenerator> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedHaving

class UnresolvedHaving extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

bitmap$0

byte bitmap$0

child

org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child

havingCondition

org.apache.spark.sql.catalyst.expressions.Expression havingCondition

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

resolved

boolean resolved

validConstraints

org.apache.spark.sql.catalyst.expressions.ExpressionSet validConstraints

Class org.apache.spark.sql.catalyst.analysis.UnresolvedHaving$

class UnresolvedHaving$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,org.apache.spark.sql.catalyst.analysis.UnresolvedHaving> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedIdentifier

class UnresolvedIdentifier extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

allowTemp

boolean allowTemp

bitmap$0

boolean bitmap$0

nameParts

scala.collection.Seq<String> nameParts

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedIdentifier$

class UnresolvedIdentifier$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<String>,Object,org.apache.spark.sql.catalyst.analysis.UnresolvedIdentifier> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedInlineTable

class UnresolvedInlineTable extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

bitmap$0

byte bitmap$0

expressionsResolved

boolean expressionsResolved

names

scala.collection.Seq<String> names

resolved

boolean resolved

rows

scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>> rows

Class org.apache.spark.sql.catalyst.analysis.UnresolvedInlineTable$

class UnresolvedInlineTable$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<String>,scala.collection.Seq<scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression>>,org.apache.spark.sql.catalyst.analysis.UnresolvedInlineTable> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedNamespace

class UnresolvedNamespace extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

multipartIdentifier

scala.collection.Seq<String> multipartIdentifier

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedNamespace$

class UnresolvedNamespace$ extends scala.runtime.AbstractFunction1<scala.collection.Seq<String>,org.apache.spark.sql.catalyst.analysis.UnresolvedNamespace> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedOrdinal

class UnresolvedOrdinal extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

ordinal

int ordinal

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedOrdinal$

class UnresolvedOrdinal$ extends scala.runtime.AbstractFunction1<Object,org.apache.spark.sql.catalyst.analysis.UnresolvedOrdinal> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedPartitionSpec

class UnresolvedPartitionSpec extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

location

scala.Option<String> location

resolved

boolean resolved

spec

scala.collection.immutable.Map<String,String> spec

Class org.apache.spark.sql.catalyst.analysis.UnresolvedPartitionSpec$

class UnresolvedPartitionSpec$ extends scala.runtime.AbstractFunction2<scala.collection.immutable.Map<String,String>,scala.Option<String>,org.apache.spark.sql.catalyst.analysis.UnresolvedPartitionSpec> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedRegex

class UnresolvedRegex extends org.apache.spark.sql.catalyst.analysis.Star implements Serializable

Serialized Fields

caseSensitive

boolean caseSensitive

regexPattern

String regexPattern

table

scala.Option<String> table

Class org.apache.spark.sql.catalyst.analysis.UnresolvedRegex$

class UnresolvedRegex$ extends scala.runtime.AbstractFunction3<String,scala.Option<String>,Object,org.apache.spark.sql.catalyst.analysis.UnresolvedRegex> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedRelation

class UnresolvedRelation extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

isStreaming

boolean isStreaming

multipartIdentifier

scala.collection.Seq<String> multipartIdentifier

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

options

org.apache.spark.sql.util.CaseInsensitiveStringMap options

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedRelation$

class UnresolvedRelation$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Serialized Fields

REQUIRED_WRITE_PRIVILEGES

String REQUIRED_WRITE_PRIVILEGES

Class org.apache.spark.sql.catalyst.analysis.UnresolvedSeed$

class UnresolvedSeed$ extends org.apache.spark.sql.catalyst.expressions.LeafExpression implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Serialized Fields

bitmap$0

boolean bitmap$0

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedStar

class UnresolvedStar extends org.apache.spark.sql.catalyst.analysis.Star implements Serializable

Serialized Fields

target

scala.Option<scala.collection.Seq<String>> target

Class org.apache.spark.sql.catalyst.analysis.UnresolvedStar$

class UnresolvedStar$ extends scala.runtime.AbstractFunction1<scala.Option<scala.collection.Seq<String>>,org.apache.spark.sql.catalyst.analysis.UnresolvedStar> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedSubqueryColumnAliases

class UnresolvedSubqueryColumnAliases extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

bitmap$0

byte bitmap$0

child

org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

outputColumnNames

scala.collection.Seq<String> outputColumnNames

resolved

boolean resolved

validConstraints

org.apache.spark.sql.catalyst.expressions.ExpressionSet validConstraints

Class org.apache.spark.sql.catalyst.analysis.UnresolvedSubqueryColumnAliases$

class UnresolvedSubqueryColumnAliases$ extends scala.runtime.AbstractFunction2<scala.collection.Seq<String>,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,org.apache.spark.sql.catalyst.analysis.UnresolvedSubqueryColumnAliases> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedTable

class UnresolvedTable extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

commandName

String commandName

multipartIdentifier

scala.collection.Seq<String> multipartIdentifier

relationTypeMismatchHint

scala.Option<String> relationTypeMismatchHint

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedTable$

class UnresolvedTable$ extends scala.runtime.AbstractFunction3<scala.collection.Seq<String>,String,scala.Option<String>,org.apache.spark.sql.catalyst.analysis.UnresolvedTable> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedTableOrView

class UnresolvedTableOrView extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

allowTempView

boolean allowTempView

bitmap$0

boolean bitmap$0

commandName

String commandName

multipartIdentifier

scala.collection.Seq<String> multipartIdentifier

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedTableOrView$

class UnresolvedTableOrView$ extends scala.runtime.AbstractFunction3<scala.collection.Seq<String>,String,Object,org.apache.spark.sql.catalyst.analysis.UnresolvedTableOrView> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedTableValuedFunction

class UnresolvedTableValuedFunction extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

bitmap$0

boolean bitmap$0

functionArgs

scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Expression> functionArgs

name

scala.collection.Seq<String> name

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedTableValuedFunction$

class UnresolvedTableValuedFunction$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedTVFAliases

class UnresolvedTVFAliases extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

bitmap$0

byte bitmap$0

child

org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child

name

scala.collection.Seq<String> name

nodePatterns

scala.collection.Seq<scala.Enumeration.Value> nodePatterns

outputNames

scala.collection.Seq<String> outputNames

resolved

boolean resolved

validConstraints

org.apache.spark.sql.catalyst.expressions.ExpressionSet validConstraints

Class org.apache.spark.sql.catalyst.analysis.UnresolvedTVFAliases$

class UnresolvedTVFAliases$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.spark.sql.catalyst.analysis.UnresolvedView

class UnresolvedView extends org.apache.spark.sql.catalyst.plans.logical.LogicalPlan implements Serializable

Serialized Fields

allowTemp

boolean allowTemp

bitmap$0

boolean bitmap$0

commandName

String commandName

multipartIdentifier

scala.collection.Seq<String> multipartIdentifier

relationTypeMismatchHint

scala.Option<String> relationTypeMismatchHint

resolved

boolean resolved

Class org.apache.spark.sql.catalyst.analysis.UnresolvedView$

class UnresolvedView$ extends scala.runtime.AbstractFunction4<scala.collection.Seq<String>,String,Object,scala.Option<String>,org.apache.spark.sql.catalyst.analysis.UnresolvedView> implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.analysis.ViewAlreadyExistsException

class ViewAlreadyExistsException extends org.apache.spark.sql.AnalysisException implements Serializable

Package org.apache.spark.sql.catalyst.parser.extensions

Class org.apache.spark.sql.catalyst.parser.extensions.IcebergParseErrorListener$

class IcebergParseErrorListener$ extends org.antlr.v4.runtime.BaseErrorListener implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Exception org.apache.spark.sql.catalyst.parser.extensions.IcebergParseException

class IcebergParseException extends org.apache.spark.sql.AnalysisException implements Serializable

Serialized Fields

command

scala.Option<String> command

start

org.apache.spark.sql.catalyst.trees.Origin start

stop

org.apache.spark.sql.catalyst.trees.Origin stop

Class org.apache.spark.sql.catalyst.parser.extensions.IcebergSqlExtensionsPostProcessor$

class IcebergSqlExtensionsPostProcessor$ extends IcebergSqlExtensionsBaseListener implements Serializable

Serialization Methods

readResolve

private Object readResolve()