public class SparkReadConf
extends java.lang.Object
If a config is set at multiple levels, the following order of precedence is used (top to bottom):
Note this class is NOT meant to be serialized and sent to executors.
Constructor and Description |
---|
SparkReadConf(org.apache.spark.sql.SparkSession spark,
Table table,
java.util.Map<java.lang.String,java.lang.String> readOptions) |
SparkReadConf(org.apache.spark.sql.SparkSession spark,
Table table,
java.lang.String branch,
java.util.Map<java.lang.String,java.lang.String> readOptions) |
Modifier and Type | Method and Description |
---|---|
boolean |
aggregatePushDownEnabled() |
java.lang.Long |
asOfTimestamp() |
java.lang.String |
branch() |
boolean |
caseSensitive() |
java.lang.Long |
endSnapshotId() |
java.lang.Long |
endTimestamp() |
boolean |
localityEnabled() |
int |
maxFilesPerMicroBatch() |
int |
maxRecordsPerMicroBatch() |
int |
orcBatchSize() |
boolean |
orcVectorizationEnabled() |
int |
parquetBatchSize() |
boolean |
parquetVectorizationEnabled() |
boolean |
preserveDataGrouping() |
java.lang.String |
scanTaskSetId() |
java.lang.Long |
snapshotId() |
int |
splitLookback() |
java.lang.Integer |
splitLookbackOption() |
long |
splitOpenFileCost() |
java.lang.Long |
splitOpenFileCostOption() |
long |
splitSize() |
java.lang.Long |
splitSizeOption() |
java.lang.Long |
startSnapshotId() |
java.lang.Long |
startTimestamp() |
long |
streamFromTimestamp() |
boolean |
streamingSkipDeleteSnapshots() |
boolean |
streamingSkipOverwriteSnapshots() |
java.lang.String |
tag() |
public SparkReadConf(org.apache.spark.sql.SparkSession spark, Table table, java.util.Map<java.lang.String,java.lang.String> readOptions)
public SparkReadConf(org.apache.spark.sql.SparkSession spark, Table table, java.lang.String branch, java.util.Map<java.lang.String,java.lang.String> readOptions)
public boolean caseSensitive()
public boolean localityEnabled()
public java.lang.Long snapshotId()
public java.lang.Long asOfTimestamp()
public java.lang.Long startSnapshotId()
public java.lang.Long endSnapshotId()
public java.lang.String branch()
public java.lang.String tag()
public java.lang.String scanTaskSetId()
public boolean streamingSkipDeleteSnapshots()
public boolean streamingSkipOverwriteSnapshots()
public boolean parquetVectorizationEnabled()
public int parquetBatchSize()
public boolean orcVectorizationEnabled()
public int orcBatchSize()
public java.lang.Long splitSizeOption()
public long splitSize()
public java.lang.Integer splitLookbackOption()
public int splitLookback()
public java.lang.Long splitOpenFileCostOption()
public long splitOpenFileCost()
public long streamFromTimestamp()
public java.lang.Long startTimestamp()
public java.lang.Long endTimestamp()
public int maxFilesPerMicroBatch()
public int maxRecordsPerMicroBatch()
public boolean preserveDataGrouping()
public boolean aggregatePushDownEnabled()