com.bangdb

Class BangDBTable

java.lang.Object

com.bangdb.BangDBTable

public class BangDBTable
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
long	pttbl
long	pttenv

Constructor Summary

Constructors

Constructor and Description
BangDBTable()

Method Summary

Modifier and Type	Method and Description
int	addIndex_num(String idxName, boolean allowDuplicates)
int	addIndex_str(String idxName, int idx_size, boolean allowDuplicates)
int	addIndex(String idxName, TableEnv tenv)
int	closeTable(CloseType closeType, boolean force)
long	count()
long	count(long pk_skey, long pk_ekey, String idx_filter_json, ScanFilter sf)
long	count(String pk_skey, String pk_ekey, String idx_filter_json, ScanFilter sf)
long	countLargeData()
int	countSliceLargeData(String key)
long	del(long key, Transaction txn)
long	del(String key, Transaction txn)
int	delLargeData(String key)
int	dropIndex(String idxName)
int	dumpData()
long	expCount(long skey, long ekey)
long	expCount(String skey, String ekey)
byte[]	get(long key, Transaction txn)
byte[]	get(String key, Transaction txn)
long	getFile(String key, String fname, String fpath)
IndexType	getIndexType()
byte[]	getLargeData(String key)
String	getName()
String	getStats(boolean verbose)
String	getTableDir()
TableType	getTableType()
boolean	hasIndex(String idxName)
boolean	isSameAs(BangDBTable tbl)
String	listLargeDataKeys(String skey, int list_size_mb)
long	put(long key, byte[] val, InsertOptions flag, Transaction txn)
long	put(long key, String val, InsertOptions flag, Transaction txn)
long	put(String key, byte[] val, InsertOptions flag, Transaction txn)
long	put(String key, String val, InsertOptions flag, Transaction txn)
long	putDoc(String doc, byte[] pk, String rev_idx_fields_json, InsertOptions flag)
long	putDoc(String doc, long pk, String rev_idx_fields_json, InsertOptions flag)
long	putDoc(String doc, String pk, String rev_idx_fields_json, InsertOptions flag)
long	putFile(String key, String file_path, InsertOptions iop)
long	putLargeData(String key, byte[] val, InsertOptions iop)
long	putText(String str, long k, InsertOptions flag)
long	putText(String str, String k, InsertOptions flag)
ResultSet	scan(ResultSet prev_rs, byte[] pk_skey, byte[] pk_ekey, ScanFilter sf, Transaction txn)
ResultSet	scan(ResultSet prev_rs, long pk_skey, long pk_ekey, ScanFilter sf, Transaction txn)
ResultSet	scan(ResultSet prev_rs, String pk_skey, String pk_ekey, ScanFilter sf, Transaction txn)
ResultSet	scanDoc(ResultSet prev_rs, byte[] pk_skey, byte[] pk_ekey, String idx_filter_json, ScanFilter sf)
ResultSet	scanDoc(ResultSet prev_rs, long pk_skey, long pk_ekey, String idx_filter_json, ScanFilter sf)
ResultSet	scanDoc(ResultSet prev_rs, String pk_skey, String pk_ekey, String idx_filter_json, ScanFilter sf)
ResultSet	scanText(String[] wlist, boolean intersect)
void	setAutoCommit(boolean flag)

Methods inherited from class java.lang.Object

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

Field Detail

pttbl

public long pttbl

pttenv

public long pttenv

Constructor Detail

BangDBTable

public BangDBTable()

Method Detail

closeTable

public int closeTable(CloseType closeType,
                      boolean force)

addIndex

public int addIndex(String idxName,
                    TableEnv tenv)

addIndex_str

public int addIndex_str(String idxName,
                        int idx_size,
                        boolean allowDuplicates)

addIndex_num

public int addIndex_num(String idxName,
                        boolean allowDuplicates)

dropIndex

public int dropIndex(String idxName)

hasIndex

public boolean hasIndex(String idxName)

dumpData

public int dumpData()

getName

public String getName()

getTableDir

public String getTableDir()

getIndexType

public IndexType getIndexType()

getStats

public String getStats(boolean verbose)

putFile

public long putFile(String key,
                    String file_path,
                    InsertOptions iop)

getFile

public long getFile(String key,
                    String fname,
                    String fpath)

putLargeData

public long putLargeData(String key,
                         byte[] val,
                         InsertOptions iop)

getLargeData

public byte[] getLargeData(String key)

listLargeDataKeys

public String listLargeDataKeys(String skey,
                                int list_size_mb)

countSliceLargeData

public int countSliceLargeData(String key)

countLargeData

public long countLargeData()

delLargeData

public int delLargeData(String key)

put

public long put(String key,
                byte[] val,
                InsertOptions flag,
                Transaction txn)

put

public long put(long key,
                byte[] val,
                InsertOptions flag,
                Transaction txn)

put

public long put(String key,
                String val,
                InsertOptions flag,
                Transaction txn)

put

public long put(long key,
                String val,
                InsertOptions flag,
                Transaction txn)

scan

public ResultSet scan(ResultSet prev_rs,
                      String pk_skey,
                      String pk_ekey,
                      ScanFilter sf,
                      Transaction txn)

scan

public ResultSet scan(ResultSet prev_rs,
                      long pk_skey,
                      long pk_ekey,
                      ScanFilter sf,
                      Transaction txn)

scan

public ResultSet scan(ResultSet prev_rs,
                      byte[] pk_skey,
                      byte[] pk_ekey,
                      ScanFilter sf,
                      Transaction txn)

putText

public long putText(String str,
                    String k,
                    InsertOptions flag)

putText

public long putText(String str,
                    long k,
                    InsertOptions flag)

scanText

public ResultSet scanText(String[] wlist,
                          boolean intersect)

putDoc

public long putDoc(String doc,
                   String pk,
                   String rev_idx_fields_json,
                   InsertOptions flag)

putDoc

public long putDoc(String doc,
                   byte[] pk,
                   String rev_idx_fields_json,
                   InsertOptions flag)

putDoc

public long putDoc(String doc,
                   long pk,
                   String rev_idx_fields_json,
                   InsertOptions flag)

scanDoc

public ResultSet scanDoc(ResultSet prev_rs,
                         String pk_skey,
                         String pk_ekey,
                         String idx_filter_json,
                         ScanFilter sf)

scanDoc

public ResultSet scanDoc(ResultSet prev_rs,
                         long pk_skey,
                         long pk_ekey,
                         String idx_filter_json,
                         ScanFilter sf)

scanDoc

public ResultSet scanDoc(ResultSet prev_rs,
                         byte[] pk_skey,
                         byte[] pk_ekey,
                         String idx_filter_json,
                         ScanFilter sf)

get

public byte[] get(String key,
                  Transaction txn)

get

public byte[] get(long key,
                  Transaction txn)

del

public long del(String key,
                Transaction txn)

del

public long del(long key,
                Transaction txn)

count

public long count(String pk_skey,
                  String pk_ekey,
                  String idx_filter_json,
                  ScanFilter sf)

count

public long count(long pk_skey,
                  long pk_ekey,
                  String idx_filter_json,
                  ScanFilter sf)

expCount

public long expCount(String skey,
                     String ekey)

expCount

public long expCount(long skey,
                     long ekey)

count

public long count()

setAutoCommit

public void setAutoCommit(boolean flag)

isSameAs

public boolean isSameAs(BangDBTable tbl)

getTableType

public TableType getTableType()