public class StreamDeserializer extends Object
| Constructor and Description |
|---|
StreamDeserializer(HashMap<String,List<Entity.DATA_TYPE>> filters) |
StreamDeserializer(Map<String,BasicDictionary> filters) |
StreamDeserializer(Map<String,org.javatuples.Pair<String,String>> tableNames,
DBConnection conn) |
| Modifier and Type | Method and Description |
|---|---|
void |
checkSchema(BasicDictionary schema) |
void |
init(DBConnection conn) |
void |
init(Map<String,BasicDictionary> filters) |
boolean |
isInited() |
BasicMessage |
parse(IMessage message) |
public StreamDeserializer(HashMap<String,List<Entity.DATA_TYPE>> filters)
public StreamDeserializer(Map<String,BasicDictionary> filters)
public StreamDeserializer(Map<String,org.javatuples.Pair<String,String>> tableNames, DBConnection conn)
public BasicMessage parse(IMessage message) throws Exception
Exceptionpublic void init(DBConnection conn)
public void init(Map<String,BasicDictionary> filters)
public boolean isInited()
public void checkSchema(BasicDictionary schema) throws RuntimeException
RuntimeExceptionCopyright © 2026 DolphinDB. All rights reserved.