public abstract class DefaultEdgeOperation extends Object implements EdgeOperation
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultEdgeOperation.KeyBytes |
| Modifier and Type | Field and Description |
|---|---|
protected byte[] |
baseTypeQual |
protected static Charset |
charset |
protected org.plasma.sdo.PlasmaType |
collectionBaseType |
protected org.plasma.sdo.PlasmaType |
collectionDefaultSubType |
protected String |
collectionPath |
protected byte[] |
columnKeyFeildDelim |
protected String |
columnKeyFeildDelimRegexp |
protected byte[] |
countQual |
protected String |
countQualStr |
protected byte[] |
family |
protected DataGraphMapping |
graphConfig |
protected byte[] |
keysQual |
protected String |
keysQualStr |
protected byte[] |
pathQual |
protected String |
pathQualStr |
protected List<DefaultEdgeOperation.KeyBytes> |
rowKeys |
protected RowOperation |
rowOperation |
protected Set<Long> |
sequences |
protected byte[] |
sequencesQual |
protected String |
sequencesQualStr |
protected org.plasma.sdo.PlasmaProperty |
sourceProp |
protected org.plasma.sdo.PlasmaType |
sourceType |
protected byte[] |
subTypeQual |
protected TableMapping |
tableConfig |
protected static String |
TYPE_DELIM
internal delimiter for metadta values
|
protected static String |
TYPE_DELIM_REGEXP |
protected String |
typeQualStr |
| Modifier | Constructor and Description |
|---|---|
protected |
DefaultEdgeOperation(org.plasma.sdo.PlasmaType sourceType,
org.plasma.sdo.PlasmaProperty sourceProp,
TableMapping tableConfig,
DataGraphMapping graphConfig,
RowOperation rowOperation) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
decodeCollectionBaseType(byte[] typeBytes) |
protected void |
decodeDefaultSubType(byte[] typeBytes) |
protected void |
decodeRowKeys(byte[] rowKeys) |
protected void |
decodeSequences(byte[] sequenceBytes) |
static org.plasma.sdo.PlasmaType |
decodeType(byte[] typeBytes) |
protected byte[] |
encodeCollectionBaseType() |
protected byte[] |
encodeDefaultSubType() |
protected byte[] |
encodeRowKeys() |
protected byte[] |
encodeSequences() |
static byte[] |
encodeType(org.plasma.sdo.PlasmaType type) |
protected byte[] |
fetchValue(byte[] family,
byte[] qualifier,
CellValues row) |
protected byte[] |
fetchValue(byte[] family,
byte[] qualifier,
org.apache.hadoop.hbase.client.Put row) |
protected byte[] |
fetchValue(byte[] family,
byte[] qualifier,
org.apache.hadoop.hbase.client.Result row) |
protected byte[] |
findValue(byte[] family,
byte[] qualifier,
CellValues row) |
protected byte[] |
findValue(byte[] family,
byte[] qualifier,
org.apache.hadoop.hbase.client.Put row) |
protected byte[] |
findValue(byte[] family,
byte[] qualifier,
org.apache.hadoop.hbase.client.Result row) |
org.plasma.sdo.PlasmaType |
getBaseType()
Calculates and returns whether the edges are local.
|
long |
getCount()
Returns the (cached) count of members of the collection.
|
String |
getPath()
Returns the traversal path (in XPath syntax) for the location of the
collection relative to the root of the graph where the collection is
instantiated.
|
List<DefaultEdgeOperation.KeyBytes> |
getRowKeys()
Returns the row keys for entities of the collection.
|
Set<Long> |
getSequences()
Returns the sequence identifiers for entities of the collection.
|
org.plasma.sdo.PlasmaProperty |
getSourceProp() |
org.plasma.sdo.PlasmaType |
getSubType()
Returns the subtype or null if none exists
|
String |
getTable()
Returns the name of the table where the collection is instantiated.
|
org.plasma.sdo.PlasmaType |
getTargetType() |
boolean |
hasSequence(Long seq) |
boolean |
isExternal()
Returns true if the collection is external, that is if the type for the
collection is 'bound' to a physical table.
|
String |
toString() |
protected static String TYPE_DELIM
protected static String TYPE_DELIM_REGEXP
protected org.plasma.sdo.PlasmaType sourceType
protected org.plasma.sdo.PlasmaProperty sourceProp
protected TableMapping tableConfig
protected DataGraphMapping graphConfig
protected RowOperation rowOperation
protected static Charset charset
protected org.plasma.sdo.PlasmaType collectionBaseType
protected org.plasma.sdo.PlasmaType collectionDefaultSubType
protected String collectionPath
protected List<DefaultEdgeOperation.KeyBytes> rowKeys
protected byte[] family
protected byte[] columnKeyFeildDelim
protected String columnKeyFeildDelimRegexp
protected byte[] baseTypeQual
protected byte[] subTypeQual
protected byte[] pathQual
protected byte[] sequencesQual
protected byte[] keysQual
protected byte[] countQual
protected String typeQualStr
protected String pathQualStr
protected String sequencesQualStr
protected String keysQualStr
protected String countQualStr
protected DefaultEdgeOperation(org.plasma.sdo.PlasmaType sourceType,
org.plasma.sdo.PlasmaProperty sourceProp,
TableMapping tableConfig,
DataGraphMapping graphConfig,
RowOperation rowOperation)
throws IOException
IOExceptionpublic org.plasma.sdo.PlasmaType getTargetType()
public org.plasma.sdo.PlasmaProperty getSourceProp()
public org.plasma.sdo.PlasmaType getBaseType()
getBaseType in interface EdgeOperationpublic org.plasma.sdo.PlasmaType getSubType()
EdgeOperationgetSubType in interface EdgeOperationpublic String getPath()
EdgeOperationgetPath in interface EdgeOperationpublic Set<Long> getSequences()
EdgeOperationgetSequences in interface EdgeOperationpublic boolean hasSequence(Long seq)
hasSequence in interface EdgeOperationpublic String getTable()
EdgeOperationgetTable in interface EdgeOperationpublic List<DefaultEdgeOperation.KeyBytes> getRowKeys()
EdgeOperationgetRowKeys in interface EdgeOperationpublic boolean isExternal()
EdgeOperationisExternal in interface EdgeOperationpublic long getCount()
EdgeOperationgetCount in interface EdgeOperationprotected byte[] encodeRowKeys()
protected void decodeRowKeys(byte[] rowKeys)
protected byte[] encodeSequences()
protected void decodeSequences(byte[] sequenceBytes)
protected byte[] encodeDefaultSubType()
protected void decodeDefaultSubType(byte[] typeBytes)
protected byte[] encodeCollectionBaseType()
protected void decodeCollectionBaseType(byte[] typeBytes)
public static byte[] encodeType(org.plasma.sdo.PlasmaType type)
public static org.plasma.sdo.PlasmaType decodeType(byte[] typeBytes)
protected byte[] fetchValue(byte[] family,
byte[] qualifier,
CellValues row)
protected byte[] findValue(byte[] family,
byte[] qualifier,
CellValues row)
protected byte[] fetchValue(byte[] family,
byte[] qualifier,
org.apache.hadoop.hbase.client.Result row)
protected byte[] findValue(byte[] family,
byte[] qualifier,
org.apache.hadoop.hbase.client.Result row)
protected byte[] fetchValue(byte[] family,
byte[] qualifier,
org.apache.hadoop.hbase.client.Put row)
protected byte[] findValue(byte[] family,
byte[] qualifier,
org.apache.hadoop.hbase.client.Put row)
Copyright © 2021. All Rights Reserved.