org.apache.flink.configuration.Configuration options
TableSchema schema
Deque<E> inputs
boolean streamingCheckpointEnabled
CommitterOperator.endInput
.
Remaining data will be committed in CommitterOperator.notifyCheckpointComplete(long)
. If
checkpoint is not enabled we need to commit remaining data in CommitterOperator.endInput
.String initialCommitUser
NavigableMap<K,V> committablesPerCheckpoint
org.apache.flink.util.function.SerializableFunction<T,R> committerFactory
CommittableStateManager committableStateManager
Committer committer
boolean endInput
Lock.Factory lockFactory
Lock.Factory lockFactory
Map<K,V> overwritePartition
LogSinkFunction logSinkFunction
FileStoreTable table
boolean isOverwrite
org.apache.flink.table.types.logical.RowType offsetRowType
int offset
boolean endOfInput
org.apache.flink.util.function.SerializableSupplier<T> committableSerializer
org.apache.flink.api.common.state.ListState<T> streamingCommitterState
FileStoreTable table
StoreSinkWrite.Provider storeSinkWriteProvider
boolean isStreaming
FileStoreTable table
LogSinkFunction logSinkFunction
StoreSinkWrite.Provider storeSinkWriteProvider
long currentWatermark
InternalTimerService
.DataTable table
ContinuousDataFileSnapshotEnumerator.Factory enumeratorFactory
LogSourceProvider provider
DataTable table
StaticDataFileSnapshotEnumerator.Factory enumeratorFactory
SchemaManager schemaManager
long schemaId
CoreOptions options
org.apache.flink.table.types.logical.RowType partitionType
org.apache.flink.table.types.logical.RowType bucketKeyType
org.apache.flink.table.types.logical.RowType rowType
org.apache.flink.table.types.logical.RowType bucketKeyType
org.apache.flink.table.types.logical.RowType keyType
org.apache.flink.table.types.logical.RowType valueType
KeyValueFieldsExtractor keyValueFieldsExtractor
java.util.function.Supplier<T> keyComparatorSupplier
MergeFunctionFactory<T> mfFactory
int keyArity
org.apache.flink.table.data.GenericRowData reusedMeta
org.apache.flink.table.data.utils.JoinedRowData reusedKeyWithMeta
org.apache.flink.table.data.utils.JoinedRowData reusedRow
OffsetRowData reusedKey
OffsetRowData reusedValue
KeyValue reusedKv
String database
String database
String database
org.apache.flink.table.catalog.ObjectPath tablePath
org.apache.flink.table.catalog.ObjectPath tablePath
DataFileMetaSerializer dataFileMetaSerializer
FieldAggregator[] fieldAggregators
org.apache.flink.table.types.logical.LogicalType fieldType
FieldAggregator aggregator
CatalogLock.Factory lockFactory
org.apache.flink.table.catalog.ObjectPath tablePath
CompoundPredicate.Function function
List<E> children
int index
String name
org.apache.flink.table.types.logical.LogicalType type
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
LeafFunction function
org.apache.flink.table.types.logical.LogicalType type
int fieldIndex
String fieldName
DataType elementType
org.apache.flink.table.types.logical.LogicalType logicalType
DataType elementType
org.apache.flink.core.fs.Path tableRoot
GeneratedClass<T> genRecordComparator
org.apache.flink.table.runtime.typeutils.RowDataSerializer rowSerializer
org.apache.avro.Schema readerSchema
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
org.apache.flink.api.common.typeinfo.TypeInformation<T> producedType
int fieldCount
int[] primaryKey
org.apache.flink.api.common.serialization.DeserializationSchema<T> primaryKeyDeserializer
org.apache.flink.api.common.serialization.DeserializationSchema<T> valueDeserializer
org.apache.flink.table.data.RowData.FieldGetter[] keyFieldGetters
int[][] projectFields
String topic
org.apache.flink.api.common.serialization.SerializationSchema<T> primaryKeySerializer
org.apache.flink.api.common.serialization.SerializationSchema<T> valueSerializer
CoreOptions.LogChangelogMode changelogMode
String topic
Properties properties
org.apache.flink.api.common.serialization.SerializationSchema<T> primaryKeySerializer
org.apache.flink.api.common.serialization.SerializationSchema<T> valueSerializer
CoreOptions.LogConsistency consistency
CoreOptions.LogChangelogMode changelogMode
String topic
Properties properties
org.apache.flink.table.types.DataType physicalType
int[] primaryKey
org.apache.flink.api.common.serialization.DeserializationSchema<T> primaryKeyDeserializer
org.apache.flink.api.common.serialization.DeserializationSchema<T> valueDeserializer
int[][] projectFields
CoreOptions.LogConsistency consistency
CoreOptions.StartupMode scanMode
Long timestampMills
LogSinkFunction.WriteCallback writeCallback
org.apache.flink.table.types.logical.LogicalType elementType
org.apache.flink.table.data.ArrayData array
Split split
org.apache.flink.table.types.logical.RowType rowType
org.apache.flink.table.data.RowData row
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
org.apache.flink.core.fs.Path path
TableSchema tableSchema
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
IOException
ClassNotFoundException
private void writeObject(ObjectOutputStream out) throws IOException
IOException
FileStoreTable dataTable
FileStoreTable wrapped
boolean isContinuous
org.apache.flink.core.fs.Path location
org.apache.flink.core.fs.Path location
org.apache.flink.core.fs.Path location
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.