public class SelectObjectRequest extends GetObjectRequest
Modifier and Type | Class and Description |
---|---|
static class |
SelectObjectRequest.ExpressionType |
NOOP
Constructor and Description |
---|
SelectObjectRequest(String bucketName,
String key) |
Modifier and Type | Method and Description |
---|---|
String |
getExpression()
Get the expression which used to filter objects
|
SelectObjectRequest.ExpressionType |
getExpressionType()
Get the expression type, we only support SQL now.
|
InputSerialization |
getInputSerialization()
Get the input serialization, we use this to parse data
|
long[] |
getLineRange() |
long |
getMaxSkippedRecordsAllowed() |
OutputSerialization |
getOutputSerialization()
Get the output serialization, it defines the output format
|
ProgressListener |
getSelectProgressListener() |
long[] |
getSplitRange() |
boolean |
isSkipPartialDataRecord() |
String |
lineRangeToString(long[] range) |
String |
rangeToString(String rangePrefix,
long[] range) |
void |
setExpression(String expression)
Set the expression which used to filter objects
|
void |
setInputSerialization(InputSerialization inputSerialization)
Set the input serialization, we use this to parse data
|
void |
setLineRange(long startLine,
long endLine)
For text file, we can define line range for select operations.
|
void |
setMaxSkippedRecordsAllowed(long maxSkippedRecordsAllowed) |
void |
setOutputSerialization(OutputSerialization outputSerialization)
Set the output serialization, it defines the output format
|
void |
setSelectProgressListener(ProgressListener selectProgressListener) |
void |
setSkipPartialDataRecord(boolean skipPartialDataRecord) |
void |
setSplitRange(long startSplit,
long endSplit)
For text file, we can define split range for select operations.
|
String |
splitRangeToString(long[] range) |
SelectObjectRequest |
withExpression(String expression) |
SelectObjectRequest |
withInputSerialization(InputSerialization inputSerialization) |
SelectObjectRequest |
withLineRange(long startLine,
long endLine) |
SelectObjectRequest |
withMaxSkippedRecordsAllowed(long maxSkippedRecordsAllowed) |
SelectObjectRequest |
withOutputSerialization(OutputSerialization outputSerialization) |
SelectObjectRequest |
withSelectProgressListener(ProgressListener selectProgressListener) |
SelectObjectRequest |
withSkipPartialDataRecord(boolean skipPartialDataRecord) |
SelectObjectRequest |
withSplitRange(long startSplit,
long endSplit) |
clearMatchingETagConstraints, clearNonmatchingETagConstraints, getAbsoluteUri, getMatchingETagConstraints, getModifiedSinceConstraint, getNonmatchingETagConstraints, getProcess, getRange, getResponseHeaders, getTrafficLimit, getUnmodifiedSinceConstraint, isUseUrlSignature, setAbsoluteUri, setMatchingETagConstraints, setModifiedSinceConstraint, setNonmatchingETagConstraints, setProcess, setRange, setResponseHeaders, setTrafficLimit, setUnmodifiedSinceConstraint, setUseUrlSignature, withRange
getBucketName, getKey, getRequestPayer, getVersionId, setBucketName, setKey, setRequestPayer, setVersionId, withBucketName, withKey, withRequestPayer, withVersionId
addAdditionalHeaderName, addHeader, addParameter, getAdditionalHeaderNames, getHeaders, getParameters, getProgressListener, isLogEnabled, setAdditionalHeaderNames, setHeaders, setLogEnabled, setParameters, setProgressListener, withProgressListener
public long[] getLineRange()
public void setLineRange(long startLine, long endLine)
Start line number
When the start is non-negative, it means the starting line to select. When the start is -1, it means the range is determined by the end only and the end could not be -1. For example, when start is -1 and end is 100. It means the select line range will be the last 100 lines.
endLine
- End line number
When the end is non-negative, it means the ending line to select. When the end is -1, it means the range is determined by the start only and the start could not be -1. For example, when end is -1 and start is 100. It means the select range will be all exception first 100 lines.
public SelectObjectRequest withLineRange(long startLine, long endLine)
public long[] getSplitRange()
public void setSplitRange(long startSplit, long endSplit)
startSplit
- Start split number
When the start is non-negative, it means the starting split to select. When the start is -1, it means the range is determined by the end only and the end could not be -1. For example, when start is -1 and end is 100. It means the select split range will be the last 100 splits.
endSplit
- End split number
When the end is non-negative, it means the ending split to select. When the end is -1, it means the range is determined by the start only and the start could not be -1. For example, when end is -1 and start is 100. It means the select range will be all exception first 100 splits.
public SelectObjectRequest withSplitRange(long startSplit, long endSplit)
public String lineRangeToString(long[] range)
public String splitRangeToString(long[] range)
public String getExpression()
public void setExpression(String expression)
public SelectObjectRequest withExpression(String expression)
public boolean isSkipPartialDataRecord()
public void setSkipPartialDataRecord(boolean skipPartialDataRecord)
public SelectObjectRequest withSkipPartialDataRecord(boolean skipPartialDataRecord)
public long getMaxSkippedRecordsAllowed()
public void setMaxSkippedRecordsAllowed(long maxSkippedRecordsAllowed)
public SelectObjectRequest withMaxSkippedRecordsAllowed(long maxSkippedRecordsAllowed)
public SelectObjectRequest.ExpressionType getExpressionType()
public InputSerialization getInputSerialization()
InputSerialization
public void setInputSerialization(InputSerialization inputSerialization)
public SelectObjectRequest withInputSerialization(InputSerialization inputSerialization)
public OutputSerialization getOutputSerialization()
OutputSerialization
public void setOutputSerialization(OutputSerialization outputSerialization)
public SelectObjectRequest withOutputSerialization(OutputSerialization outputSerialization)
public ProgressListener getSelectProgressListener()
public void setSelectProgressListener(ProgressListener selectProgressListener)
public SelectObjectRequest withSelectProgressListener(ProgressListener selectProgressListener)
Copyright © 2021. All Rights Reserved.