org.apache.paimon.table.source

Class DataSplit.Builder

java.lang.Object

org.apache.paimon.table.source.DataSplit.Builder

Enclosing class:

DataSplit

public static class DataSplit.Builder
extends Object

Builder for DataSplit.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
DataSplit	build()
DataSplit.Builder	isStreaming(boolean isStreaming)
DataSplit.Builder	rawConvertible(boolean rawConvertible)
DataSplit.Builder	withBeforeDeletionFiles(List<DeletionFile> beforeDeletionFiles)
DataSplit.Builder	withBeforeFiles(List<DataFileMeta> beforeFiles)
DataSplit.Builder	withBucket(int bucket)
DataSplit.Builder	withBucketPath(String bucketPath)
DataSplit.Builder	withDataDeletionFiles(List<DeletionFile> dataDeletionFiles)
DataSplit.Builder	withDataFiles(List<DataFileMeta> dataFiles)
DataSplit.Builder	withPartition(BinaryRow partition)
DataSplit.Builder	withSnapshot(long snapshot)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder()

Method Detail

withSnapshot

public DataSplit.Builder withSnapshot(long snapshot)

withPartition

public DataSplit.Builder withPartition(BinaryRow partition)

withBucket

public DataSplit.Builder withBucket(int bucket)

withBucketPath

public DataSplit.Builder withBucketPath(String bucketPath)

withBeforeFiles

public DataSplit.Builder withBeforeFiles(List<DataFileMeta> beforeFiles)

withBeforeDeletionFiles

public DataSplit.Builder withBeforeDeletionFiles(List<DeletionFile> beforeDeletionFiles)

withDataFiles

public DataSplit.Builder withDataFiles(List<DataFileMeta> dataFiles)

withDataDeletionFiles

public DataSplit.Builder withDataDeletionFiles(List<DeletionFile> dataDeletionFiles)

isStreaming

public DataSplit.Builder isStreaming(boolean isStreaming)

rawConvertible

public DataSplit.Builder rawConvertible(boolean rawConvertible)

build

public DataSplit build()