public class InputData
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
accessor |
protected int |
dataFragment |
protected java.lang.String |
dataSource |
protected java.lang.String |
filterString |
protected boolean |
filterStringValid |
protected java.lang.String |
fragmenter |
protected byte[] |
fragmentMetadata |
static int |
INVALID_SPLIT_IDX |
protected java.lang.String |
metadata |
protected ColumnDescriptor |
recordkeyColumn
The name of the recordkey column.
|
protected java.lang.String |
remoteLogin |
protected java.lang.String |
remoteSecret |
protected java.util.Map<java.lang.String,java.lang.String> |
requestParametersMap |
protected java.lang.String |
resolver |
protected int |
segmentId |
protected boolean |
threadSafe
When false the bridge has to run in synchronized mode.
|
protected int |
totalSegments |
protected java.util.ArrayList<ColumnDescriptor> |
tupleDescription |
protected byte[] |
userData |
Constructor and Description |
---|
InputData()
Constructs an empty InputData
|
InputData(InputData copy)
Constructs an InputData from a copy.
|
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getAccessor()
Returns the ClassName for the java class that was defined as Accessor.
|
ColumnDescriptor |
getColumn(int index)
Returns column index from tuple description.
|
int |
getColumns()
Returns the number of columns in tuple description.
|
int |
getDataFragment()
Returns a data fragment index.
|
java.lang.String |
getDataSource()
Returns the data source of the required resource (i.e a file path or a
table name).
|
java.lang.String |
getFilterString()
Returns the filter string, null if #hasFilter is false.
|
java.lang.String |
getFragmenter()
Returns the ClassName for the java class that was defined as Fragmenter
or null if no fragmenter was defined.
|
byte[] |
getFragmentMetadata()
The byte serialization of a data fragment.
|
byte[] |
getFragmentUserData()
Gets any custom user data that may have been passed from the fragmenter.
|
java.lang.String |
getLogin()
Returns the contents of pxf_remote_service_login set in Hawq.
|
java.lang.String |
getMetadata()
Returns the ClassName for the java class that was defined as Metadata
or null if no metadata was defined.
|
ColumnDescriptor |
getRecordkeyColumn()
Returns the column descriptor of the recordkey column.
|
java.lang.String |
getResolver()
Returns the ClassName for the java class that was defined as Resolver.
|
java.lang.String |
getSecret()
Returns the contents of pxf_remote_service_secret set in Hawq.
|
int |
getSegmentId()
Returns the current segment ID in HAWQ.
|
int |
getTotalSegments()
Returns the number of segments in HAWQ.
|
java.util.ArrayList<ColumnDescriptor> |
getTupleDescription()
Returns tuple description.
|
java.lang.String |
getUserProperty(java.lang.String userProp)
Returns a user defined property.
|
boolean |
hasFilter()
Returns true if there is a filter string to parse.
|
boolean |
isThreadSafe()
Returns whether this request is thread safe.
|
void |
setDataSource(java.lang.String dataSource)
Sets the data source for the required resource.
|
void |
setFragmentMetadata(byte[] location)
Sets the byte serialization of a fragment meta data.
|
void |
setFragmentUserData(byte[] userData)
Sets any custom user data that needs to be shared across plugins.
|
public static final int INVALID_SPLIT_IDX
protected java.util.Map<java.lang.String,java.lang.String> requestParametersMap
protected java.util.ArrayList<ColumnDescriptor> tupleDescription
protected int segmentId
protected int totalSegments
protected byte[] fragmentMetadata
protected byte[] userData
protected boolean filterStringValid
protected java.lang.String filterString
protected java.lang.String dataSource
protected java.lang.String accessor
protected java.lang.String resolver
protected java.lang.String fragmenter
protected java.lang.String metadata
protected java.lang.String remoteLogin
protected java.lang.String remoteSecret
protected int dataFragment
protected boolean threadSafe
protected ColumnDescriptor recordkeyColumn
public InputData()
public InputData(InputData copy)
copy
- the input data to copypublic java.lang.String getUserProperty(java.lang.String userProp)
userProp
- the lookup user propertypublic void setFragmentMetadata(byte[] location)
location
- start, len, and location of the fragmentpublic byte[] getFragmentMetadata()
public byte[] getFragmentUserData()
public void setFragmentUserData(byte[] userData)
userData
- user datapublic int getTotalSegments()
public int getSegmentId()
public boolean hasFilter()
public java.lang.String getFilterString()
public java.util.ArrayList<ColumnDescriptor> getTupleDescription()
public int getColumns()
public ColumnDescriptor getColumn(int index)
index
- index of columnpublic ColumnDescriptor getRecordkeyColumn()
public java.lang.String getDataSource()
public void setDataSource(java.lang.String dataSource)
dataSource
- data source to be setpublic java.lang.String getAccessor()
public java.lang.String getResolver()
public java.lang.String getFragmenter()
public java.lang.String getMetadata()
public java.lang.String getLogin()
public java.lang.String getSecret()
public boolean isThreadSafe()
public int getDataFragment()