Serialized Form

Package org.apache.flink.table.api.runtime.types

Class org.apache.flink.table.api.runtime.types.ScalaTupleSerialization$

class ScalaTupleSerialization$ extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()

Class org.apache.flink.table.api.runtime.types.Tuple10Serializer

class Tuple10Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple10<A,B,C,D,E,F,G,H,I,J>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple11Serializer

class Tuple11Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple11<A,B,C,D,E,F,G,H,I,J,K>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple12Serializer

class Tuple12Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple12<A,B,C,D,E,F,G,H,I,J,K,L>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple13Serializer

class Tuple13Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple13<A,B,C,D,E,F,G,H,I,J,K,L,M>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple14Serializer

class Tuple14Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple14<A,B,C,D,E,F,G,H,I,J,K,L,M,N>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple15Serializer

class Tuple15Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple15<A,B,C,D,E,F,G,H,I,J,K,L,M,N,O>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple16Serializer

class Tuple16Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple16<A,B,C,D,E,F,G,H,I,J,K,L,M,N,O,P>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple17Serializer

class Tuple17Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple17<A,B,C,D,E,F,G,H,I,J,K,L,M,N,O,P,Q>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple18Serializer

class Tuple18Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple18<A,B,C,D,E,F,G,H,I,J,K,L,M,N,O,P,Q,R>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple19Serializer

class Tuple19Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple19<A,B,C,D,E,F,G,H,I,J,K,L,M,N,O,P,Q,R,S>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple1DoubleSerializer

class Tuple1DoubleSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple1<Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple1IntSerializer

class Tuple1IntSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple1<Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple1LongSerializer

class Tuple1LongSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple1<Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple1Serializer

class Tuple1Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple1<A>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple20Serializer

class Tuple20Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple20<A,B,C,D,E,F,G,H,I,J,K,L,M,N,O,P,Q,R,S,T>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple21Serializer

class Tuple21Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple21<A,B,C,D,E,F,G,H,I,J,K,L,M,N,O,P,Q,R,S,T,U>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple22Serializer

class Tuple22Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple22<A,B,C,D,E,F,G,H,I,J,K,L,M,N,O,P,Q,R,S,T,U,V>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple2DoubleDoubleSerializer

class Tuple2DoubleDoubleSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple2<Object,Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple2DoubleIntSerializer

class Tuple2DoubleIntSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple2<Object,Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple2DoubleLongSerializer

class Tuple2DoubleLongSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple2<Object,Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple2IntDoubleSerializer

class Tuple2IntDoubleSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple2<Object,Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple2IntIntSerializer

class Tuple2IntIntSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple2<Object,Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple2IntLongSerializer

class Tuple2IntLongSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple2<Object,Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple2LongDoubleSerializer

class Tuple2LongDoubleSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple2<Object,Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple2LongIntSerializer

class Tuple2LongIntSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple2<Object,Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple2LongLongSerializer

class Tuple2LongLongSerializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple2<Object,Object>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple2Serializer

class Tuple2Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple2<A,B>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple3Serializer

class Tuple3Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple3<A,B,C>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple4Serializer

class Tuple4Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple4<A,B,C,D>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple5Serializer

class Tuple5Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple5<A,B,C,D,E>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple6Serializer

class Tuple6Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple6<A,B,C,D,E,F>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple7Serializer

class Tuple7Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple7<A,B,C,D,E,F,G>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple8Serializer

class Tuple8Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple8<A,B,C,D,E,F,G,H>> implements Serializable

Class org.apache.flink.table.api.runtime.types.Tuple9Serializer

class Tuple9Serializer extends com.esotericsoftware.kryo.Serializer<scala.Tuple9<A,B,C,D,E,F,G,H,I>> implements Serializable

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

firstRowId

Long firstRowId

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 Class 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.AddEncryptionKey

class AddEncryptionKey extends Object implements Serializable

Serialized Fields

key

EncryptedKey key

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

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.RemoveEncryptionKey

class RemoveEncryptionKey extends Object implements Serializable

Serialized Fields

keyId

String keyId

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.RemoveSchemas

class RemoveSchemas extends Object implements Serializable

Serialized Fields

schemaIds

Set<Integer> schemaIds

Class org.apache.iceberg.MetadataUpdate.RemoveSnapshotRef

class RemoveSnapshotRef extends Object implements Serializable

Serialized Fields

refName

String refName

Class org.apache.iceberg.MetadataUpdate.RemoveSnapshots

class RemoveSnapshots extends Object implements Serializable

Serialized Fields

snapshotIds

Set<Long> snapshotIds

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

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

originalTypes

Map<Integer,Type> originalTypes

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

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

encryptionKeys

List<EncryptedKey> encryptionKeys

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

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

legacyMd5pluginEnabled

boolean legacyMd5pluginEnabled

refreshCredentialsEnabled

boolean refreshCredentialsEnabled

refreshCredentialsEndpoint

String refreshCredentialsEndpoint

Class org.apache.iceberg.aws.AwsKeyManagementClient

class AwsKeyManagementClient extends Object implements Serializable

Serialized Fields

dataKeySpec

software.amazon.awssdk.services.kms.model.DataKeySpec dataKeySpec

encryptionAlgorithmSpec

software.amazon.awssdk.services.kms.model.EncryptionAlgorithmSpec encryptionAlgorithmSpec

kmsClient

software.amazon.awssdk.services.kms.KmsClient kmsClient

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

kmsDataKeySpec

software.amazon.awssdk.services.kms.model.DataKeySpec kmsDataKeySpec

kmsEncryptionAlgorithmSpec

software.amazon.awssdk.services.kms.model.EncryptionAlgorithmSpec kmsEncryptionAlgorithmSpec

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

s3Async

SerializableSupplier<software.amazon.awssdk.services.s3.S3AsyncClient> s3Async

storageCredentials

List<StorageCredential> storageCredentials

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

isS3AnalyticsAcceleratorEnabled

boolean isS3AnalyticsAcceleratorEnabled

isS3CRTEnabled

boolean isS3CRTEnabled

isUseArnRegionEnabled

boolean isUseArnRegionEnabled

isWriteNamespaceTagEnabled

boolean isWriteNamespaceTagEnabled

isWriteTableTagEnabled

boolean isWriteTableTagEnabled

multiPartSize

int multiPartSize

multipartThresholdFactor

double multipartThresholdFactor

multipartUploadThreads

int multipartUploadThreads

s3AnalyticsacceleratorProperties

Map<String,String> s3AnalyticsacceleratorProperties

s3CrtMaxConcurrency

int s3CrtMaxConcurrency

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

adlsRefreshCredentialsEnabled

boolean adlsRefreshCredentialsEnabled

adlsRefreshCredentialsEndpoint

String adlsRefreshCredentialsEndpoint

adlsSasTokens

Map<String,String> adlsSasTokens

adlsWriteBlockSize

Long adlsWriteBlockSize

allProperties

Map<String,String> allProperties

namedKeyCreds

Map.Entry<String,String> namedKeyCreds

token

String token

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

vendedAdlsCredentialProvider

VendedAdlsCredentialProvider vendedAdlsCredentialProvider

Class org.apache.iceberg.azure.adlsv2.VendedAdlsCredentialProvider

class VendedAdlsCredentialProvider extends Object implements Serializable

Serialized Fields

catalogEndpoint

String catalogEndpoint

credentialsEndpoint

String credentialsEndpoint

properties

SerializableMap<String,String> properties

Package org.apache.iceberg.connect.channel

Exception Class 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 Class org.apache.iceberg.exceptions.AlreadyExistsException

class AlreadyExistsException extends RuntimeException implements Serializable

Exception Class org.apache.iceberg.exceptions.BadRequestException

class BadRequestException extends RESTException implements Serializable

Exception Class org.apache.iceberg.exceptions.CherrypickAncestorCommitException

class CherrypickAncestorCommitException extends ValidationException implements Serializable

Exception Class org.apache.iceberg.exceptions.CommitFailedException

class CommitFailedException extends RuntimeException implements Serializable

Exception Class org.apache.iceberg.exceptions.CommitStateUnknownException

class CommitStateUnknownException extends RuntimeException implements Serializable

Exception Class org.apache.iceberg.exceptions.DuplicateWAPCommitException

class DuplicateWAPCommitException extends ValidationException implements Serializable

Exception Class org.apache.iceberg.exceptions.ForbiddenException

class ForbiddenException extends RESTException implements Serializable

Exception Class org.apache.iceberg.exceptions.NamespaceNotEmptyException

class NamespaceNotEmptyException extends RuntimeException implements Serializable

Exception Class org.apache.iceberg.exceptions.NoSuchIcebergTableException

class NoSuchIcebergTableException extends NoSuchTableException implements Serializable

Exception Class org.apache.iceberg.exceptions.NoSuchIcebergViewException

class NoSuchIcebergViewException extends NoSuchViewException implements Serializable

Exception Class org.apache.iceberg.exceptions.NoSuchNamespaceException

class NoSuchNamespaceException extends RuntimeException implements Serializable

Exception Class org.apache.iceberg.exceptions.NoSuchTableException

class NoSuchTableException extends RuntimeException implements Serializable

Exception Class org.apache.iceberg.exceptions.NoSuchViewException

class NoSuchViewException extends RuntimeException implements Serializable

Exception Class org.apache.iceberg.exceptions.NotAuthorizedException

class NotAuthorizedException extends RESTException implements Serializable

Exception Class org.apache.iceberg.exceptions.NotFoundException

class NotFoundException extends RuntimeException implements Serializable

Exception Class org.apache.iceberg.exceptions.RESTException

class RESTException extends RuntimeException implements Serializable

Exception Class org.apache.iceberg.exceptions.RuntimeIOException

class RuntimeIOException extends UncheckedIOException implements Serializable

Exception Class org.apache.iceberg.exceptions.ServiceFailureException

class ServiceFailureException extends RESTException implements Serializable

Exception Class org.apache.iceberg.exceptions.ServiceUnavailableException

class ServiceUnavailableException extends RESTException implements Serializable

Exception Class org.apache.iceberg.exceptions.UnprocessableEntityException

class UnprocessableEntityException extends RESTException implements Serializable

Exception Class 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.BoundExtract

class BoundExtract extends Object implements Serializable

Serialized Fields

path

String path

ref

BoundReference<?> ref

type

Type type

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.UnboundExtract

class UnboundExtract extends Object implements Serializable

Serialized Fields

path

String path

ref

NamedReference<?> ref

type

Type.PrimitiveType type

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

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

class ZkLockFactory extends Object implements Serializable

Serialized Fields

baseSleepTimeMs

int baseSleepTimeMs

connectionTimeoutMs

int connectionTimeoutMs

connectString

String connectString

isOpen

boolean isOpen

lockId

String lockId

maxRetries

int maxRetries

sessionTimeoutMs

int sessionTimeoutMs

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

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

class DataFileRewriteCommitter extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<Trigger> implements Serializable

Serialized Fields

tableLoader

TableLoader tableLoader

tableName

String tableName

taskIndex

int taskIndex

taskName

String taskName

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

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

Serialized Fields

filter

Expression filter

maxRewriteBytes

long maxRewriteBytes

partialProgressMaxCommits

int partialProgressMaxCommits

rewriterOptions

Map<String,String> rewriterOptions

tableLoader

TableLoader tableLoader

tableName

String tableName

taskIndex

int taskIndex

taskName

String taskName

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

class DataFileRewriteRunner extends org.apache.flink.streaming.api.functions.ProcessFunction<DataFileRewritePlanner.PlannedGroup,DataFileRewriteRunner.ExecutedGroup> implements Serializable

Serialized Fields

tableName

String tableName

taskIndex

int taskIndex

taskName

String taskName

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

int 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

cleanExpiredMetadata

Boolean cleanExpiredMetadata

maxSnapshotAgeMs

Long maxSnapshotAgeMs

numSnapshots

Integer numSnapshots

plannerPoolSize

Integer plannerPoolSize

tableLoader

TableLoader tableLoader

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

class FileNameReader extends org.apache.iceberg.flink.maintenance.operator.TableReader<String> implements Serializable

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

class FileUriKeySelector extends Object implements Serializable

Serialized Fields

equalAuthorities

Map<String,String> equalAuthorities

equalSchemes

Map<String,String> equalSchemes

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

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

Serialized Fields

io

FileIO io

location

String location

minAgeMs

long minAgeMs

specs

Map<Integer,PartitionSpec> specs

tableLoader

TableLoader tableLoader

taskIndex

int taskIndex

taskName

String taskName

usePrefixListing

boolean usePrefixListing

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

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

Serialized Fields

tableLoader

TableLoader tableLoader

taskIndex

int taskIndex

taskName

String taskName

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.MetadataTablePlanner

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

Serialized Fields

metadataTableType

MetadataTableType metadataTableType

scanContext

ScanContext scanContext

tableLoader

TableLoader tableLoader

taskIndex

int taskIndex

taskName

String taskName

workerPoolSize

int workerPoolSize

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.OrphanFilesDetector

class OrphanFilesDetector extends org.apache.flink.streaming.api.functions.co.KeyedCoProcessFunction<String,String,String,String> implements Serializable

Serialized Fields

equalAuthorities

Map<String,String> equalAuthorities

equalSchemes

Map<String,String> equalSchemes

prefixMismatchMode

DeleteOrphanFiles.PrefixMismatchMode prefixMismatchMode

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

class SingleThreadedIteratorSource extends Object implements Serializable

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

class SkipOnError extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<String> implements Serializable

Serialized Fields

hasErrorFlag

boolean hasErrorFlag

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

class TaskResultAggregator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<TaskResult> implements Serializable

Serialized Fields

exceptions

List<Exception> exceptions

tableName

String tableName

taskIndex

int taskIndex

taskName

String taskName

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.CommittableToTableChangeConverter

class CommittableToTableChangeConverter extends org.apache.flink.streaming.api.functions.ProcessFunction<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<org.apache.iceberg.flink.sink.IcebergCommittable>,TableChange> implements Serializable

Serialized Fields

io

FileIO io

specs

Map<Integer,PartitionSpec> specs

tableName

String tableName

Class org.apache.iceberg.flink.sink.EqualityFieldKeySelector

class EqualityFieldKeySelector extends Object implements Serializable

Serialized Fields

deleteSchema

Schema deleteSchema

flinkSchema

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

schema

Schema schema

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

compactMode

boolean compactMode

dataFileFormat

FileFormat dataFileFormat

equalityFieldColumns

Set<String> equalityFieldColumns

equalityFieldIds

Set<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.PartitionKeySelector

class PartitionKeySelector extends Object implements Serializable

Serialized Fields

flinkSchema

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

partitionKey

PartitionKey partitionKey

schema

Schema schema

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

Set<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.dynamic

Class org.apache.iceberg.flink.sink.dynamic.DynamicIcebergSink

class DynamicIcebergSink extends Object implements Serializable

Serialized Fields

cacheMaximumSize

int cacheMaximumSize

catalogLoader

CatalogLoader catalogLoader

dataFileFormat

FileFormat dataFileFormat

overwriteMode

boolean overwriteMode

sinkId

String sinkId

snapshotProperties

Map<String,String> snapshotProperties

targetDataFileSize

long targetDataFileSize

uidPrefix

String uidPrefix

workerPoolSize

int workerPoolSize

writeProperties

Map<String,String> writeProperties

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.legacy.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.GcpKeyManagementClient

class GcpKeyManagementClient extends Object implements Serializable

Serialized Fields

closeableGroup

CloseableGroup closeableGroup

kmsClient

com.google.cloud.kms.v1.KeyManagementServiceClient kmsClient

Class org.apache.iceberg.gcp.GCPProperties

class GCPProperties extends Object implements Serializable

Serialized Fields

allProperties

Map<String,String> allProperties

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

isResourceClosed

AtomicBoolean isResourceClosed

metrics

MetricsContext metrics

properties

SerializableMap<String,String> properties

storageCredentials

List<StorageCredential> storageCredentials

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 Class 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 Class org.apache.iceberg.io.BulkDeletionFailureException

class BulkDeletionFailureException extends RuntimeException implements Serializable

Serialized Fields

numberFailedObjects

int numberFailedObjects

Class org.apache.iceberg.io.ImmutableStorageCredential

class ImmutableStorageCredential extends Object implements Serializable

Serialization Methods

readResolve

private Object readResolve()
                    throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

config

Map<String,String> config

prefix

String prefix

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

storageCredentials

List<StorageCredential> storageCredentials

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 Class org.apache.iceberg.jdbc.UncheckedInterruptedException

class UncheckedInterruptedException extends RuntimeException implements Serializable

Exception Class 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

firstRowId

Long firstRowId

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.BaseToDaysFunction

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

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

class DateToDaysFunction extends DaysFunction.BaseToDaysFunction implements Serializable

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

class TimestampNtzToDaysFunction extends DaysFunction.BaseToDaysFunction implements Serializable

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

class TimestampToDaysFunction extends 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.BaseToHourFunction

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

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

class HourToDaysReducer extends Object implements Serializable

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

class TimestampNtzToHoursFunction extends HoursFunction.BaseToHourFunction implements Serializable

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

class TimestampToHoursFunction extends HoursFunction.BaseToHourFunction 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.GeographyType

class GeographyType extends Type.PrimitiveType implements Serializable

Serialized Fields

algorithm

EdgeAlgorithm algorithm

crs

String crs

Class org.apache.iceberg.types.Types.GeometryType

class GeometryType extends Type.PrimitiveType implements Serializable

Serialized Fields

crs

String crs

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

Literal<?> initialDefault

isOptional

boolean isOptional

name

String name

type

Type type

writeDefault

Literal<?> 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

Serialization Methods

writeReplace

Object writeReplace()
             throws ObjectStreamException

Throws:

ObjectStreamException

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 Class 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.immutable.Seq<String> catalogAndNamespace

collation

scala.Option<String> collation

isExecuteImmediate

boolean isExecuteImmediate

maxNestedViewDepth

int maxNestedViewDepth

nestedViewDepth

int nestedViewDepth

org$apache$spark$sql$catalyst$analysis$AnalysisContext$$singlePassResolverBridgeState

scala.Option<org.apache.spark.sql.catalyst.analysis.resolver.AnalyzerBridgeState> org$apache$spark$sql$catalyst$analysis$AnalysisContext$$singlePassResolverBridgeState

outerPlan

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

referredTempFunctionNames

scala.collection.mutable.Set<String> referredTempFunctionNames

referredTempVariableNames

scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> referredTempVariableNames

referredTempViewNames

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

relationCache

scala.collection.mutable.Map<scala.Tuple2<scala.collection.immutable.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

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

Exception Class 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

writeReplace

private Object writeReplace()

Class org.apache.spark.sql.catalyst.analysis.CollationStrength.Default$

class Default$ extends Object implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

Class org.apache.spark.sql.catalyst.analysis.CollationStrength.Explicit$

class Explicit$ extends Object implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

Class org.apache.spark.sql.catalyst.analysis.CollationStrength.Implicit$

class Implicit$ extends Object implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

Class org.apache.spark.sql.catalyst.analysis.CollationStrength.Indeterminate$

class Indeterminate$ extends Object implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialization Methods

writeReplace

private Object writeReplace()

Exception Class 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.ExecuteImmediateQuery

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

Serialized Fields

args

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

bitmap$0

boolean bitmap$0

nodePatterns

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

query

scala.util.Either<String,org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute> query

resolved

boolean resolved

targetVariables

scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute> targetVariables

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

class ExecuteImmediateQuery$ extends scala.runtime.AbstractFunction3<scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,scala.util.Either<String,org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute>,scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute>,org.apache.spark.sql.catalyst.analysis.ExecuteImmediateQuery> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

bitmap$0

boolean bitmap$0

exprBuilder

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

identifierExpr

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

nodePatterns

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

otherExprs

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

resolved

boolean resolved

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

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

Serialization Methods

writeReplace

private Object writeReplace()

Exception Class 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

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

Exception Class org.apache.spark.sql.catalyst.analysis.IcebergAnalysisException

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

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

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

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

class LazyExpression 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

nodePatterns

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

resolved

boolean resolved

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.Seq<String> names

nodePatterns

scala.collection.immutable.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.immutable.Seq<String>,org.apache.spark.sql.catalyst.analysis.MultiAlias> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.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

writeReplace

private Object writeReplace()

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

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

Serialized Fields

argNames

scala.collection.immutable.Seq<String> argNames

argValues

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

child

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

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

class NameParameterizedQuery$ extends Object implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

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

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

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

Serialized Fields

cause

scala.Option<Throwable> cause

details

String details

namespace

String[] namespace

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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

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

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

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

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

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

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

class NoSuchNamespaceException extends org.apache.spark.sql.catalyst.analysis.NoSuchDatabaseException implements Serializable

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

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

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

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

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

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

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

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

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

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

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

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

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

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

Exception Class 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.immutable.Seq<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan> children

identifierExpr

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

nodePatterns

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

planBuilder

scala.Function2<scala.collection.immutable.Seq<String>,scala.collection.immutable.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.immutable.Seq<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>,scala.Function2<scala.collection.immutable.Seq<String>,scala.collection.immutable.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

writeReplace

private Object writeReplace()

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.immutable.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

writeReplace

private Object writeReplace()

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

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

Serialized Fields

args

scala.collection.immutable.Seq<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,scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,org.apache.spark.sql.catalyst.analysis.PosParameterizedQuery> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

Class org.apache.spark.sql.catalyst.analysis.PreemptedError.ErrorWithPriority

class ErrorWithPriority extends Object implements Serializable

Serialized Fields

error

Exception error

priority

int priority

Class org.apache.spark.sql.catalyst.analysis.PreemptedError.ErrorWithPriority$

class ErrorWithPriority$ extends scala.runtime.AbstractFunction2<Exception,Object,org.apache.spark.sql.catalyst.analysis.PreemptedError.ErrorWithPriority> implements Serializable

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.immutable.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

writeReplace

private Object writeReplace()

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.immutable.Seq<String> path

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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.immutable.Seq<scala.Enumeration.Value> nodePatterns

output

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

rows

scala.collection.immutable.Seq<scala.collection.immutable.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.immutable.Seq<scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Expression>>,scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>,org.apache.spark.sql.catalyst.analysis.ResolvedInlineTable> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

metadata

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

namespace

scala.collection.immutable.Seq<String> namespace

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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.immutable.Seq<String> names

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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

metadata

org.apache.spark.sql.catalyst.catalog.CatalogTable metadata

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.catalyst.catalog.CatalogTable,org.apache.spark.sql.catalyst.analysis.ResolvedPersistentView> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

catalog

org.apache.spark.sql.connector.catalog.ProcedureCatalog catalog

ident

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

procedure

org.apache.spark.sql.connector.catalog.procedures.Procedure procedure

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

class ResolvedProcedure$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.connector.catalog.ProcedureCatalog,org.apache.spark.sql.connector.catalog.Identifier,org.apache.spark.sql.connector.catalog.procedures.Procedure,org.apache.spark.sql.catalyst.analysis.ResolvedProcedure> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

bitmap$0

boolean bitmap$0

expressions

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

resolved

boolean resolved

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.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

writeReplace

private Object writeReplace()

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

metadata

org.apache.spark.sql.catalyst.catalog.CatalogTable metadata

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.catalyst.catalog.CatalogTable,org.apache.spark.sql.catalyst.analysis.ResolvedTempView> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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

class SQLFunctionContext extends Object implements Serializable

Serialized Fields

nestedSQLFunctionDepth

int nestedSQLFunctionDepth

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

class SQLFunctionContext$ extends Object implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

function

org.apache.spark.sql.catalyst.catalog.SQLFunction function

inputs

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

name

String name

nodePatterns

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

returnType

scala.Option<org.apache.spark.sql.types.DataType> returnType

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

class SQLFunctionExpression$ extends scala.runtime.AbstractFunction4<String,org.apache.spark.sql.catalyst.catalog.SQLFunction,scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,scala.Option<org.apache.spark.sql.types.DataType>,org.apache.spark.sql.catalyst.analysis.SQLFunctionExpression> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

bitmap$0

boolean bitmap$0

child

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

function

org.apache.spark.sql.catalyst.catalog.SQLFunction function

validConstraints

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

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

class SQLFunctionNode$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.catalyst.catalog.SQLFunction,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,org.apache.spark.sql.catalyst.analysis.SQLFunctionNode> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

class SQLScalarFunction 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

deterministic

boolean deterministic

function

org.apache.spark.sql.catalyst.catalog.SQLFunction function

inputs

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

nodePatterns

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

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

class SQLScalarFunction$ extends scala.runtime.AbstractFunction3<org.apache.spark.sql.catalyst.catalog.SQLFunction,scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,org.apache.spark.sql.catalyst.expressions.Expression,org.apache.spark.sql.catalyst.analysis.SQLScalarFunction> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

function

org.apache.spark.sql.catalyst.catalog.SQLFunction function

inputs

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

name

String name

nodePatterns

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

output

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

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

class SQLTableFunction$ extends scala.runtime.AbstractFunction4<String,org.apache.spark.sql.catalyst.catalog.SQLFunction,scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>,org.apache.spark.sql.catalyst.analysis.SQLTableFunction> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

class StringTypeWithContext extends org.apache.spark.sql.types.DataType implements Serializable

Serialized Fields

strength

org.apache.spark.sql.catalyst.analysis.CollationStrength strength

stringType

org.apache.spark.sql.types.StringType stringType

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

class StringTypeWithContext$ extends scala.runtime.AbstractFunction2<org.apache.spark.sql.types.StringType,org.apache.spark.sql.catalyst.analysis.CollationStrength,org.apache.spark.sql.catalyst.analysis.StringTypeWithContext> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

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

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.immutable.Seq<String> nameParts

nodePatterns

scala.collection.immutable.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.immutable.Seq<String>,Object,org.apache.spark.sql.catalyst.analysis.TempResolvedColumn> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

Exception Class 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

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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.immutable.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

writeReplace

private Object writeReplace()

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.immutable.Seq<String> nameParts

nodePatterns

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

resolved

boolean resolved

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

class UnresolvedAttribute$ extends Object implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

bitmap$0

boolean bitmap$0

nodePatterns

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

planId

long planId

resolved

boolean resolved

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> inputAttributes

nodePatterns

scala.collection.immutable.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.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>,org.apache.spark.sql.catalyst.analysis.UnresolvedDeserializer> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

class UnresolvedException extends org.apache.spark.SparkException 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

writeReplace

private Object writeReplace()

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.immutable.Seq<String> name

resolved

boolean resolved

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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.immutable.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

isInternal

boolean isInternal

nameParts

scala.collection.immutable.Seq<String> nameParts

nodePatterns

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

orderingWithinGroup

scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.expressions.SortOrder> orderingWithinGroup

resolved

boolean resolved

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

class UnresolvedFunction$ extends Object implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.Seq<String> multipartIdentifier

nodePatterns

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

possibleQualifiedName

scala.Option<scala.collection.immutable.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.immutable.Seq<String>,String,Object,scala.Option<String>,scala.Option<scala.collection.immutable.Seq<String>>,org.apache.spark.sql.catalyst.analysis.UnresolvedFunctionName> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Expression> children

name

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

nodePatterns

scala.collection.immutable.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.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,org.apache.spark.sql.catalyst.analysis.UnresolvedGenerator> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.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

writeReplace

private Object writeReplace()

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.immutable.Seq<String> nameParts

resolved

boolean resolved

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.Seq<String> names

resolved

boolean resolved

rows

scala.collection.immutable.Seq<scala.collection.immutable.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.immutable.Seq<String>,scala.collection.immutable.Seq<scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Expression>>,org.apache.spark.sql.catalyst.analysis.UnresolvedInlineTable> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

fetchMetadata

boolean fetchMetadata

multipartIdentifier

scala.collection.immutable.Seq<String> multipartIdentifier

resolved

boolean resolved

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.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

writeReplace

private Object writeReplace()

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

writeReplace

private Object writeReplace()

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

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

Serialized Fields

bitmap$0

boolean bitmap$0

ordinal

int ordinal

resolved

boolean resolved

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

bitmap$0

boolean bitmap$0

nameParts

scala.collection.immutable.Seq<String> nameParts

nodePatterns

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

resolved

boolean resolved

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

bitmap$0

boolean bitmap$0

caseSensitive

boolean caseSensitive

regexPattern

String regexPattern

resolved

boolean resolved

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

writeReplace

private Object writeReplace()

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.immutable.Seq<String> multipartIdentifier

nodePatterns

scala.collection.immutable.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

writeReplace

private Object writeReplace()

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

bitmap$0

boolean bitmap$0

resolved

boolean resolved

target

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

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

bitmap$0

boolean bitmap$0

excepts

scala.collection.immutable.Seq<scala.collection.immutable.Seq<String>> excepts

replacements

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

resolved

boolean resolved

target

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

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

bitmap$0

boolean bitmap$0

colNames

scala.collection.immutable.Seq<String> colNames

explicitMetadata

scala.Option<scala.collection.immutable.Seq<org.apache.spark.sql.types.Metadata>> explicitMetadata

exprs

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

resolved

boolean resolved

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

class UnresolvedStarWithColumns$ extends scala.runtime.AbstractFunction3<scala.collection.immutable.Seq<String>,scala.collection.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Expression>,scala.Option<scala.collection.immutable.Seq<org.apache.spark.sql.types.Metadata>>,org.apache.spark.sql.catalyst.analysis.UnresolvedStarWithColumns> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialized Fields

bitmap$0

boolean bitmap$0

existingNames

scala.collection.immutable.Seq<String> existingNames

newNames

scala.collection.immutable.Seq<String> newNames

resolved

boolean resolved

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.Seq<scala.Enumeration.Value> nodePatterns

outputColumnNames

scala.collection.immutable.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.immutable.Seq<String>,org.apache.spark.sql.catalyst.plans.logical.LogicalPlan,org.apache.spark.sql.catalyst.analysis.UnresolvedSubqueryColumnAliases> implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.Seq<String> multipartIdentifier

resolved

boolean resolved

suggestAlternative

boolean suggestAlternative

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.Seq<String> multipartIdentifier

resolved

boolean resolved

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.Seq<org.apache.spark.sql.catalyst.expressions.Expression> functionArgs

isStreaming

boolean isStreaming

name

scala.collection.immutable.Seq<String> name

nodePatterns

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

resolved

boolean resolved

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

class UnresolvedTableValuedFunction$ extends Object implements Serializable

Serialization Methods

writeReplace

private Object writeReplace()

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

class UnresolvedTranspose 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

indices

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

nodePatterns

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

resolved

boolean resolved

validConstraints

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

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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.immutable.Seq<String> name

nodePatterns

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

outputNames

scala.collection.immutable.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

writeReplace

private Object writeReplace()

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.immutable.Seq<String> multipartIdentifier

resolved

boolean resolved

suggestAlternative

boolean suggestAlternative

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

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

Serialization Methods

writeReplace

private Object writeReplace()

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

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

Serialization Methods

writeReplace

private Object writeReplace()

Exception Class 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

writeReplace

private Object writeReplace()

Exception Class 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

writeReplace

private Object writeReplace()