Serialized Form (Flink : Connectors : Files 2.2.0 API)

Package org.apache.flink.connector.file.sink

Class org.apache.flink.connector.file.sink.FileSink extends Object implements Serializable

Serialized Fields

bucketsBuilder

org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,? extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,?>> bucketsBuilder

Class org.apache.flink.connector.file.sink.FileSink.BulkFormatBuilder extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T extends FileSink.BulkFormatBuilder<IN,T>> implements Serializable

serialVersionUID:: 1L

Serialized Fields

basePath
```
org.apache.flink.core.fs.Path basePath
```

bucketAssigner

org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,String> bucketAssigner

bucketCheckInterval
```
long bucketCheckInterval
```

bucketFactory

FileWriterBucketFactory<IN> bucketFactory

compactStrategy
```
FileCompactStrategy compactStrategy
```
fileCompactor
```
FileCompactor fileCompactor
```
isCompactDisabledExplicitly
```
boolean isCompactDisabledExplicitly
```

outputFileConfig

org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig

rollingPolicy

org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy<IN,String> rollingPolicy

writerConfig
```
Map<String,String> writerConfig
```

writerFactory

org.apache.flink.api.common.serialization.BulkWriter.Factory<IN> writerFactory

Class org.apache.flink.connector.file.sink.FileSink.DefaultBulkFormatBuilder extends FileSink.BulkFormatBuilder<IN,FileSink.DefaultBulkFormatBuilder<IN>> implements Serializable

serialVersionUID:

7493169281036370228L
Class org.apache.flink.connector.file.sink.FileSink.DefaultRowFormatBuilder extends FileSink.RowFormatBuilder<IN,FileSink.DefaultRowFormatBuilder<IN>> implements Serializable

serialVersionUID:

-8503344257202146718L

Class org.apache.flink.connector.file.sink.FileSink.RowFormatBuilder extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T extends FileSink.RowFormatBuilder<IN,T>> implements Serializable

serialVersionUID:: 1L

Serialized Fields

basePath
```
org.apache.flink.core.fs.Path basePath
```

bucketAssigner

org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,String> bucketAssigner

bucketCheckInterval
```
long bucketCheckInterval
```

bucketFactory

FileWriterBucketFactory<IN> bucketFactory

compactStrategy
```
FileCompactStrategy compactStrategy
```

encoder

org.apache.flink.api.common.serialization.Encoder<IN> encoder

fileCompactor
```
FileCompactor fileCompactor
```
isCompactDisabledExplicitly
```
boolean isCompactDisabledExplicitly
```

outputFileConfig

org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig

rollingPolicy

org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicy<IN,String> rollingPolicy

Class org.apache.flink.connector.file.sink.FileSinkCommittable extends Object implements Serializable

Serialized Fields

bucketId
```
String bucketId
```

compactedFileToCleanup

org.apache.flink.core.fs.Path compactedFileToCleanup

inProgressFileToCleanup

org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.InProgressFileRecoverable inProgressFileToCleanup

pendingFile

org.apache.flink.streaming.api.functions.sink.filesystem.InProgressFileWriter.PendingFileRecoverable pendingFile

Package org.apache.flink.connector.file.sink.compactor
- Class org.apache.flink.connector.file.sink.compactor.ConcatFileCompactor extends OutputStreamBasedFileCompactor implements Serializable
  - Serialized Fields
    - fileDelimiter
      
      byte[] fileDelimiter
- Class org.apache.flink.connector.file.sink.compactor.DecoderBasedReader.Factory extends Object implements Serializable
  - Serialized Fields
    - decoderFactory
      
      DecoderBasedReader.Decoder.Factory<T> decoderFactory
- Class org.apache.flink.connector.file.sink.compactor.FileCompactStrategy extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numCheckpointsBeforeCompaction
      
      int numCheckpointsBeforeCompaction
    - numCompactThreads
      
      int numCompactThreads
    - sizeThreshold
      
      long sizeThreshold
- Class org.apache.flink.connector.file.sink.compactor.IdenticalFileCompactor extends ConcatFileCompactor implements Serializable
- Class org.apache.flink.connector.file.sink.compactor.InputFormatBasedReader.Factory extends Object implements Serializable
  - Serialized Fields
    - inputFormatFactory
      
      org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.api.common.io.FileInputFormat<T>,IOException> inputFormatFactory
- Class org.apache.flink.connector.file.sink.compactor.OutputStreamBasedFileCompactor extends Object implements Serializable
- Class org.apache.flink.connector.file.sink.compactor.RecordWiseFileCompactor extends Object implements Serializable
  - Serialized Fields
    - readerFactory
      
      RecordWiseFileCompactor.Reader.Factory<IN> readerFactory
- Class org.apache.flink.connector.file.sink.compactor.SimpleStringDecoder extends Object implements Serializable
  - Serialized Fields
    - reader
      
      BufferedReader reader
Package org.apache.flink.connector.file.sink.compactor.operator
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<CompactorRequest> implements Serializable
  - Serialized Fields
    - committableSerializer
      
      org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer
    - packingRequests
      
      Map<String,CompactorRequest> packingRequests
    - remainingCommittableState
      
      org.apache.flink.api.common.state.ListState<FileSinkCommittable> remainingCommittableState
    - strategy
      
      FileCompactStrategy strategy
    - triggers
      
      Map<String,org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator.CompactTrigger> triggers
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorFactory extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<CompactorRequest> implements Serializable
  - Serialized Fields
    - committableSerializerSupplier
      
      org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier
    - strategy
      
      FileCompactStrategy strategy
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorStateHandler extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,CompactorRequest>> implements Serializable
  - Serialized Fields
    - committableSerializer
      
      org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorStateHandlerFactory extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<org.apache.flink.types.Either<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>,CompactorRequest>> implements Serializable
  - Serialized Fields
    - committableSerializerSupplier
      
      org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - bucketWriter
      
      org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String> bucketWriter
    - checkpointRequests
      
      TreeMap<Long,List<CompactorRequest>> checkpointRequests
    - collectingRequests
      
      List<CompactorRequest> collectingRequests
    - committableSerializer
      
      org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer
    - compactingRequests
      
      List<org.apache.flink.api.java.tuple.Tuple2<CompactorRequest,CompletableFuture<Iterable<FileSinkCommittable>>>> compactingRequests
    - fileCompactor
      
      FileCompactor fileCompactor
    - lastKnownCheckpointId
      
      long lastKnownCheckpointId
    - remainingRequestsState
      
      org.apache.flink.api.common.state.ListState<Map<Long,List<CompactorRequest>>> remainingRequestsState
    - strategy
      
      FileCompactStrategy strategy
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorFactory extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - bucketWriterProvider
      
      org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String>,IOException> bucketWriterProvider
    - committableSerializerSupplier
      
      org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier
    - fileCompactor
      
      FileCompactor fileCompactor
    - strategy
      
      FileCompactStrategy strategy
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandler extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - bucketWriter
      
      org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String> bucketWriter
    - committableSerializer
      
      org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable> committableSerializer
    - compactingRequests
      
      List<org.apache.flink.api.java.tuple.Tuple2<CompactorRequest,CompletableFuture<Iterable<FileSinkCommittable>>>> compactingRequests
    - remainingRequestsState
      
      org.apache.flink.streaming.api.operators.util.SimpleVersionedListState<Map<Long,List<CompactorRequest>>> remainingRequestsState
    - stateRemaining
      
      Iterable<Map<Long,List<CompactorRequest>>> stateRemaining
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperatorStateHandlerFactory extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> implements Serializable
  - Serialized Fields
    - bucketWriterProvider
      
      org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.streaming.api.functions.sink.filesystem.BucketWriter<?,String>,IOException> bucketWriterProvider
    - committableSerializerSupplier
      
      org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorRequest extends Object implements Serializable
  - Serialized Fields
    - bucketId
      
      String bucketId
    - committableToCompact
      
      List<FileSinkCommittable> committableToCompact
    - committableToPassthrough
      
      List<FileSinkCommittable> committableToPassthrough
- Class org.apache.flink.connector.file.sink.compactor.operator.CompactorRequestTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<CompactorRequest> implements Serializable
  - Serialized Fields
    - committableSerializerSupplier
      
      org.apache.flink.util.function.SerializableSupplierWithException<org.apache.flink.core.io.SimpleVersionedSerializer<FileSinkCommittable>,IOException> committableSerializerSupplier
Package org.apache.flink.connector.file.sink.writer
- Class org.apache.flink.connector.file.sink.writer.DefaultFileWriterBucketFactory extends Object implements Serializable
Package org.apache.flink.connector.file.src
- Class org.apache.flink.connector.file.src.AbstractFileSource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - assignerFactory
      
      FileSplitAssigner.Provider assignerFactory
    - continuousEnumerationSettings
      
      ContinuousEnumerationSettings continuousEnumerationSettings
    - enumeratorFactory
      
      FileEnumerator.Provider enumeratorFactory
    - inputPaths
      
      org.apache.flink.core.fs.Path[] inputPaths
    - readerFormat
      
      BulkFormat<T,SplitT extends FileSourceSplit> readerFormat
- Class org.apache.flink.connector.file.src.ContinuousEnumerationSettings extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - discoveryInterval
      
      Duration discoveryInterval
- Class org.apache.flink.connector.file.src.FileSource extends AbstractFileSource<T,FileSourceSplit> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.file.src.FileSourceSplit extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fileModificationTime
      
      long fileModificationTime
      
      The modification time of the file, from FileStatus.getModificationTime().
    - filePath
      
      org.apache.flink.core.fs.Path filePath
      
      The path of the file referenced by this split.
    - fileSize
      
      long fileSize
      
      The file size in bytes, from FileStatus.getLen().
    - hostnames
      
      String[] hostnames
      
      The names of the hosts storing this range of the file. Empty, if no host information is available.
    - id
      
      String id
      
      The unique ID of the split. Unique within the scope of this source.
    - length
      
      long length
      
      The number of bytes in the file to process.
    - offset
      
      long offset
      
      The position of the first byte in the file to process.
    - readerPosition
      
      CheckpointedPosition readerPosition
      
      The precise reader position in the split, to resume from.
Package org.apache.flink.connector.file.src.assigners
Package org.apache.flink.connector.file.src.enumerate
Package org.apache.flink.connector.file.src.impl
- Class org.apache.flink.connector.file.src.impl.StreamFormatAdapter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - streamFormat
      
      StreamFormat<T> streamFormat
Package org.apache.flink.connector.file.src.reader
- Class org.apache.flink.connector.file.src.reader.SimpleStreamFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.file.src.reader.TextLineInputFormat extends SimpleStreamFormat<String> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - charsetName
      
      String charsetName
Package org.apache.flink.connector.file.src.util
- Class org.apache.flink.connector.file.src.util.CheckpointedPosition extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - offset
      
      long offset
    - recordsAfterOffset
      
      long recordsAfterOffset
Package org.apache.flink.connector.file.table
- Class org.apache.flink.connector.file.table.DefaultPartTimeExtractor extends Object implements Serializable
  - Serialized Fields
    - extractorPattern
      
      String extractorPattern
    - formatterPattern
      
      String formatterPattern
- Class org.apache.flink.connector.file.table.DeserializationSchemaAdapter extends Object implements Serializable
  - Serialized Fields
    - deserializationSchema
      
      org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData> deserializationSchema
- Class org.apache.flink.connector.file.table.EmptyMetaStoreFactory extends Object implements Serializable
  - Serialized Fields
    - path
      
      org.apache.flink.core.fs.Path path
- Class org.apache.flink.connector.file.table.FileSystemOutputFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - computer
      
      PartitionComputer<T> computer
    - dynamicGrouped
      
      boolean dynamicGrouped
    - formatFactory
      
      OutputFormatFactory<T> formatFactory
    - fsFactory
      
      FileSystemFactory fsFactory
    - identifier
      
      org.apache.flink.table.catalog.ObjectIdentifier identifier
    - isToLocal
      
      boolean isToLocal
    - msFactory
      
      TableMetaStoreFactory msFactory
    - outputFileConfig
      
      org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig
    - overwrite
      
      boolean overwrite
    - partitionColumns
      
      String[] partitionColumns
    - partitionCommitPolicyFactory
      
      PartitionCommitPolicyFactory partitionCommitPolicyFactory
    - stagingPath
      
      org.apache.flink.core.fs.Path stagingPath
    - staticPartitions
      
      LinkedHashMap<String,String> staticPartitions
- Class org.apache.flink.connector.file.table.FileSystemTableSink.ProjectionBulkFactory extends Object implements Serializable
  - Serialized Fields
    - computer
      
      RowDataPartitionComputer computer
    - factory
      
      org.apache.flink.api.common.serialization.BulkWriter.Factory<org.apache.flink.table.data.RowData> factory
- Class org.apache.flink.connector.file.table.FileSystemTableSink.TableBucketAssigner extends Object implements Serializable
  - Serialized Fields
    - computer
      
      PartitionComputer<org.apache.flink.table.data.RowData> computer
- Class org.apache.flink.connector.file.table.FileSystemTableSink.TableRollingPolicy extends org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.CheckpointRollingPolicy<org.apache.flink.table.data.RowData,String> implements Serializable
  - Serialized Fields
    - inactivityInterval
      
      long inactivityInterval
    - rollingFileSize
      
      long rollingFileSize
    - rollingTimeInterval
      
      long rollingTimeInterval
    - rollOnCheckpoint
      
      boolean rollOnCheckpoint
- Class org.apache.flink.connector.file.table.LimitableBulkFormat extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - format
      
      BulkFormat<T,SplitT extends FileSourceSplit> format
    - limit
      
      long limit
- Class org.apache.flink.connector.file.table.PartitionCommitPolicyFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - customClass
      
      String customClass
    - parameters
      
      List<String> parameters
    - policyKind
      
      String policyKind
    - successFileName
      
      String successFileName
- Class org.apache.flink.connector.file.table.RowDataPartitionComputer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - defaultPartValue
      
      String defaultPartValue
    - nonPartitionFieldGetters
      
      org.apache.flink.table.data.RowData.FieldGetter[] nonPartitionFieldGetters
    - nonPartitionIndexes
      
      int[] nonPartitionIndexes
    - nonPartitionTypes
      
      org.apache.flink.table.types.logical.LogicalType[] nonPartitionTypes
    - partitionColumns
      
      String[] partitionColumns
    - partitionFieldGetters
      
      org.apache.flink.table.data.RowData.FieldGetter[] partitionFieldGetters
    - partitionIndexes
      
      int[] partitionIndexes
    - partitionTypes
      
      org.apache.flink.table.types.logical.LogicalType[] partitionTypes
- Class org.apache.flink.connector.file.table.RowPartitionComputer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - defaultPartValue
      
      String defaultPartValue
    - nonPartitionIndexes
      
      int[] nonPartitionIndexes
    - partitionColumns
      
      String[] partitionColumns
    - partitionIndexes
      
      int[] partitionIndexes
- Class org.apache.flink.connector.file.table.SerializationSchemaAdapter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - serializationSchema
      
      org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> serializationSchema
Package org.apache.flink.connector.file.table.batch.compact
- Class org.apache.flink.connector.file.table.batch.compact.BatchCompactCoordinator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<CompactMessages.CoordinatorOutput> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - compactAverageSize
      
      long compactAverageSize
    - compactTargetSize
      
      long compactTargetSize
    - fsFactory
      
      org.apache.flink.util.function.SupplierWithException<org.apache.flink.core.fs.FileSystem,IOException> fsFactory
- Class org.apache.flink.connector.file.table.batch.compact.BatchCompactOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<CompactMessages.CompactOutput> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fsFactory
      
      org.apache.flink.util.function.SupplierWithException<org.apache.flink.core.fs.FileSystem,IOException> fsFactory
    - readerFactory
      
      CompactReader.Factory<T> readerFactory
    - writerFactory
      
      CompactWriter.Factory<T> writerFactory
- Class org.apache.flink.connector.file.table.batch.compact.BatchFileWriter extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<CompactMessages.CoordinatorInput> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - computer
      
      PartitionComputer<T> computer
    - dynamicGrouped
      
      boolean dynamicGrouped
    - formatFactory
      
      OutputFormatFactory<T> formatFactory
    - fsFactory
      
      FileSystemFactory fsFactory
    - outputFileConfig
      
      org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig outputFileConfig
    - partitionColumns
      
      String[] partitionColumns
    - staticPartitions
      
      LinkedHashMap<String,String> staticPartitions
    - tmpPath
      
      org.apache.flink.core.fs.Path tmpPath
- Class org.apache.flink.connector.file.table.batch.compact.BatchPartitionCommitterSink extends org.apache.flink.streaming.api.functions.sink.legacy.RichSinkFunction<CompactMessages.CompactOutput> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fsFactory
      
      FileSystemFactory fsFactory
    - identifier
      
      org.apache.flink.table.catalog.ObjectIdentifier identifier
    - isToLocal
      
      boolean isToLocal
    - msFactory
      
      TableMetaStoreFactory msFactory
    - overwrite
      
      boolean overwrite
    - partitionColumns
      
      String[] partitionColumns
    - partitionCommitPolicyFactory
      
      PartitionCommitPolicyFactory partitionCommitPolicyFactory
    - staticPartitions
      
      LinkedHashMap<String,String> staticPartitions
    - tmpPath
      
      org.apache.flink.core.fs.Path tmpPath
Package org.apache.flink.connector.file.table.stream
- Class org.apache.flink.connector.file.table.stream.AbstractStreamingWriter extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bucketCheckInterval
      
      long bucketCheckInterval
    - bucketsBuilder
      
      org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink.BucketsBuilder<IN,String,? extends org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink.BucketsBuilder<IN,String,?>> bucketsBuilder
    - endOfInput
      
      boolean endOfInput
    - endOfInputState
      
      org.apache.flink.api.common.state.ListState<Boolean> endOfInputState
- Class org.apache.flink.connector.file.table.stream.PartitionCommitInfo extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointId
      
      long checkpointId
    - numberOfTasks
      
      int numberOfTasks
    - partitions
      
      String[] partitions
    - taskId
      
      int taskId
- Class org.apache.flink.connector.file.table.stream.PartitionCommitter extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<Void> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - conf
      
      org.apache.flink.configuration.Configuration conf
    - fsFactory
      
      FileSystemFactory fsFactory
    - locationPath
      
      org.apache.flink.core.fs.Path locationPath
    - metaStoreFactory
      
      TableMetaStoreFactory metaStoreFactory
    - partitionKeys
      
      List<String> partitionKeys
    - tableIdentifier
      
      org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier
- Class org.apache.flink.connector.file.table.stream.StreamingFileWriter extends AbstractStreamingWriter<IN,PartitionCommitInfo> implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - conf
      
      org.apache.flink.configuration.Configuration conf
    - partitionKeys
      
      List<String> partitionKeys
Package org.apache.flink.connector.file.table.stream.compact
- Class org.apache.flink.connector.file.table.stream.compact.CompactCoordinator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<CompactMessages.CoordinatorOutput> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fsFactory
      
      org.apache.flink.util.function.SupplierWithException<org.apache.flink.core.fs.FileSystem,IOException> fsFactory
    - targetFileSize
      
      long targetFileSize
- Class org.apache.flink.connector.file.table.stream.compact.CompactFileWriter extends AbstractStreamingWriter<T,CompactMessages.CoordinatorInput> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.CompactionUnit extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partition
      
      String partition
    - pathStrings
      
      String[] pathStrings
    - unitId
      
      int unitId
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.CompactOutput extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - compactedFiles
      
      Map<String,List<org.apache.flink.core.fs.Path>> compactedFiles
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.EndCheckpoint extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointId
      
      long checkpointId
    - numberOfTasks
      
      int numberOfTasks
    - taskId
      
      int taskId
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.EndCompaction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointId
      
      long checkpointId
- Class org.apache.flink.connector.file.table.stream.compact.CompactMessages.InputFile extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - file
      
      org.apache.flink.core.fs.Path file
    - partition
      
      String partition
- Class org.apache.flink.connector.file.table.stream.compact.CompactOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<PartitionCommitInfo> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fsFactory
      
      org.apache.flink.util.function.SupplierWithException<org.apache.flink.core.fs.FileSystem,IOException> fsFactory
    - readerFactory
      
      CompactReader.Factory<T> readerFactory
    - writerFactory
      
      CompactWriter.Factory<T> writerFactory

Serialized Form

Package org.apache.flink.connector.file.sink

Class org.apache.flink.connector.file.sink.FileSink extends Object implements Serializable

Serialized Fields

bucketsBuilder

Class org.apache.flink.connector.file.sink.FileSink.BulkFormatBuilder extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,​T extends FileSink.BulkFormatBuilder<IN,​T>> implements Serializable

Serialized Fields

basePath

bucketAssigner

bucketCheckInterval

bucketFactory

compactStrategy

fileCompactor

isCompactDisabledExplicitly

outputFileConfig

rollingPolicy

writerConfig

writerFactory

Class org.apache.flink.connector.file.sink.FileSink.DefaultBulkFormatBuilder extends FileSink.BulkFormatBuilder<IN,​FileSink.DefaultBulkFormatBuilder<IN>> implements Serializable

Class org.apache.flink.connector.file.sink.FileSink.DefaultRowFormatBuilder extends FileSink.RowFormatBuilder<IN,​FileSink.DefaultRowFormatBuilder<IN>> implements Serializable

Class org.apache.flink.connector.file.sink.FileSink.RowFormatBuilder extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,​T extends FileSink.RowFormatBuilder<IN,​T>> implements Serializable

Serialized Fields

basePath

bucketAssigner

bucketCheckInterval

bucketFactory

compactStrategy

encoder

fileCompactor

isCompactDisabledExplicitly

outputFileConfig

rollingPolicy

Class org.apache.flink.connector.file.sink.FileSinkCommittable extends Object implements Serializable

Serialized Fields

bucketId

compactedFileToCleanup

inProgressFileToCleanup

pendingFile

Package org.apache.flink.connector.file.sink.compactor

Class org.apache.flink.connector.file.sink.compactor.ConcatFileCompactor extends OutputStreamBasedFileCompactor implements Serializable

Serialized Fields

fileDelimiter

Class org.apache.flink.connector.file.sink.compactor.DecoderBasedReader.Factory extends Object implements Serializable

Serialized Fields

decoderFactory

Class org.apache.flink.connector.file.sink.compactor.FileCompactStrategy extends Object implements Serializable

Serialized Fields

numCheckpointsBeforeCompaction

numCompactThreads

sizeThreshold

Class org.apache.flink.connector.file.sink.compactor.IdenticalFileCompactor extends ConcatFileCompactor implements Serializable

Class org.apache.flink.connector.file.sink.compactor.InputFormatBasedReader.Factory extends Object implements Serializable

Serialized Fields

inputFormatFactory

Class org.apache.flink.connector.file.sink.compactor.OutputStreamBasedFileCompactor extends Object implements Serializable

Class org.apache.flink.connector.file.sink.compactor.RecordWiseFileCompactor extends Object implements Serializable

Serialized Fields

readerFactory

Class org.apache.flink.connector.file.sink.compactor.SimpleStringDecoder extends Object implements Serializable

Serialized Fields

reader

Package org.apache.flink.connector.file.sink.compactor.operator

Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<CompactorRequest> implements Serializable

Serialized Fields

committableSerializer

packingRequests

remainingCommittableState

strategy

triggers

Class org.apache.flink.connector.file.sink.compactor.operator.CompactCoordinatorFactory extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<CompactorRequest> implements Serializable

Serialized Fields

committableSerializerSupplier

strategy

Serialized Fields

committableSerializer

Serialized Fields

committableSerializerSupplier

Class org.apache.flink.connector.file.sink.compactor.operator.CompactorOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<FileSinkCommittable>> implements Serializable

Serialized Fields

bucketWriter

Class org.apache.flink.connector.file.sink.FileSink.BulkFormatBuilder extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T extends FileSink.BulkFormatBuilder<IN,T>> implements Serializable

Class org.apache.flink.connector.file.sink.FileSink.DefaultBulkFormatBuilder extends FileSink.BulkFormatBuilder<IN,FileSink.DefaultBulkFormatBuilder<IN>> implements Serializable

Class org.apache.flink.connector.file.sink.FileSink.DefaultRowFormatBuilder extends FileSink.RowFormatBuilder<IN,FileSink.DefaultRowFormatBuilder<IN>> implements Serializable

Class org.apache.flink.connector.file.sink.FileSink.RowFormatBuilder extends org.apache.flink.connector.file.sink.FileSink.BucketsBuilder<IN,T extends FileSink.RowFormatBuilder<IN,T>> implements Serializable

Class org.apache.flink.connector.file.src.FileSource extends AbstractFileSource<T,FileSourceSplit> implements Serializable