com.bangdb

Class BangDBStreamManager

java.lang.Object

com.bangdb.BangDBStreamManager

public class BangDBStreamManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
long	ptsmgr

Constructor Summary

Constructors

Constructor and Description
BangDBStreamManager(BangDBEnv bdbenv)

Method Summary

Modifier and Type	Method and Description
String	addStreams(long schemaid, String streams)
String	addUdfs(long schema_id, String udfs)
void	closeBangdbStreamManager(CloseType closetype)
String	compileUdf(String code)
long	count(long schemaid, long streamid)
long	count(long schemaid, long streamid, long psk, long pek, String filter_json, ScanFilter sf)
long	countProc(long schemaid, long streamid, String attr_names_json, ScanFilter sf)
String	deleteStreams(long schemaid, String streams)
String	delUdfs(long schema_id, String udfs)
String	deregisterSchema(String schema_name)
String	deregisterSchema(String schema_name, boolean cleanclose)
long	getGpbyId(long schemaid, long streamid, String gpby_attr_list)
String	getGpbyName(long schemaid, long streamid, String gpby_attr_list)
int	getSchemaDDLState(long schemaid)
String	getSchemaDepGraph(long schema_id, boolean bfs)
long	getSchemaid(String schema_name, boolean check_valid)
String	getSchemaList()
String	getSchemaStr(String schemaName, short from_meta)
String	getStreamDepGraph(long schema_id, long stream_id, boolean only_dep)
long	getStreamid(String schema_name, String stream_name, boolean check_valid)
int	getStreamState(String schema_name, String stream_name)
String	getUDFList()
String	put(long schemaid, long streamid, long k, String v)
String	put(long schemaid, long streamid, String doc) CRUD API for streams
String	registerSchema(String schema_json)
void	resetMlHelper(BangDBMLHelper bmlh)
ResultSet	scanDoc(long schemaid, long streamid, ResultSet prev_rs, long k1, long k2, String idx_filter_json, ScanFilter sf)
ResultSet	scanProcDoc(long schemaid, long streamid, String attr_names_json, ResultSet prev_rs, ScanFilter sf)
ResultSet	scanRegisteredNotif(ResultSet prev_rs, long k1, long k2, String idx_filter_json, ScanFilter sf)
ResultSet	scanUsage(ResultSet prev_rs, long fromts, long tots, int rollup, ScanFilter sf)
String	setStreamState(String schema_name, String stream_name, short state)

Methods inherited from class java.lang.Object

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

Field Detail

ptsmgr

public long ptsmgr

Constructor Detail

BangDBStreamManager

public BangDBStreamManager(BangDBEnv bdbenv)

Method Detail

registerSchema

public String registerSchema(String schema_json)

deregisterSchema

public String deregisterSchema(String schema_name)

deregisterSchema

public String deregisterSchema(String schema_name,
                               boolean cleanclose)

addStreams

public String addStreams(long schemaid,
                         String streams)

deleteStreams

public String deleteStreams(long schemaid,
                            String streams)

getSchemaDDLState

public int getSchemaDDLState(long schemaid)

getSchemaid

public long getSchemaid(String schema_name,
                        boolean check_valid)

getStreamid

public long getStreamid(String schema_name,
                        String stream_name,
                        boolean check_valid)

setStreamState

public String setStreamState(String schema_name,
                             String stream_name,
                             short state)

getStreamState

public int getStreamState(String schema_name,
                          String stream_name)

put

public String put(long schemaid,
                  long streamid,
                  String doc)

CRUD API for streams

put

public String put(long schemaid,
                  long streamid,
                  long k,
                  String v)

scanDoc

public ResultSet scanDoc(long schemaid,
                         long streamid,
                         ResultSet prev_rs,
                         long k1,
                         long k2,
                         String idx_filter_json,
                         ScanFilter sf)

scanProcDoc

public ResultSet scanProcDoc(long schemaid,
                             long streamid,
                             String attr_names_json,
                             ResultSet prev_rs,
                             ScanFilter sf)

scanRegisteredNotif

public ResultSet scanRegisteredNotif(ResultSet prev_rs,
                                     long k1,
                                     long k2,
                                     String idx_filter_json,
                                     ScanFilter sf)

scanUsage

public ResultSet scanUsage(ResultSet prev_rs,
                           long fromts,
                           long tots,
                           int rollup,
                           ScanFilter sf)

countProc

public long countProc(long schemaid,
                      long streamid,
                      String attr_names_json,
                      ScanFilter sf)

getGpbyName

public String getGpbyName(long schemaid,
                          long streamid,
                          String gpby_attr_list)

getGpbyId

public long getGpbyId(long schemaid,
                      long streamid,
                      String gpby_attr_list)

count

public long count(long schemaid,
                  long streamid)

count

public long count(long schemaid,
                  long streamid,
                  long psk,
                  long pek,
                  String filter_json,
                  ScanFilter sf)

addUdfs

public String addUdfs(long schema_id,
                      String udfs)

delUdfs

public String delUdfs(long schema_id,
                      String udfs)

compileUdf

public String compileUdf(String code)

getUDFList

public String getUDFList()

getSchemaList

public String getSchemaList()

getSchemaDepGraph

public String getSchemaDepGraph(long schema_id,
                                boolean bfs)

getSchemaStr

public String getSchemaStr(String schemaName,
                           short from_meta)

getStreamDepGraph

public String getStreamDepGraph(long schema_id,
                                long stream_id,
                                boolean only_dep)

resetMlHelper

public void resetMlHelper(BangDBMLHelper bmlh)

closeBangdbStreamManager

public void closeBangdbStreamManager(CloseType closetype)