程序包 | 说明 |
---|---|
com.sh.javax | |
com.sh.javax.datastore | |
com.sh.wf.etl.base | |
com.sh.wf.etl.compontent | |
com.sh.wf.event | |
com.sh.wf.module.base |
限定符和类型 | 方法和说明 |
---|---|
void |
DataPages.forEachRow(java.util.function.Consumer<? super RowInfo> action)
循环输出每条记录
|
限定符和类型 | 方法和说明 |
---|---|
RowInfo |
DsIterator.getCurRowInfo() |
RowInfo |
DatastoreInterface.getRowInfo(int row)
获取指定行对象(拷贝) row : 行号 成功返回RowInfo对象,失败返回null.
|
RowInfo |
Datastore.getRowInfo(int row) |
RowInfo |
DatastoreInterface.getRowInfo(int row,
int buffer) |
RowInfo |
Datastore.getRowInfo(int row,
int buffer) |
RowInfo |
DsIterator.getRowInfoByRowNo(int rowNo) |
RowInfo |
DatastoreInterface.getRowInfoRef(int row)
获取指定行对象(引用) row : 行号
|
RowInfo |
Datastore.getRowInfoRef(int row)
获取指定行对象(引用) row : 行号 成功返回RowInfo对象,失败返回null.
|
RowInfo |
DatastoreInterface.getRowInfoRef(int row,
int buffer) |
RowInfo |
Datastore.getRowInfoRef(int row,
int buffer)
获取指定行对象(引用),和getRowInfo的区别是getRowInfo是通过行克隆后取得的数据,而getRowInfoRef是直接取行的引用
|
RowInfo |
DsIterator.next() |
RowInfo |
DsIterator.setRowNo(int rowNo)
修改当前的索引号
|
限定符和类型 | 方法和说明 |
---|---|
java.util.LinkedList<RowInfo> |
Datastore.getData()
获取主数据
|
限定符和类型 | 方法和说明 |
---|---|
Datastore |
Datastore.addRowData(RowInfo rowInfo) |
Datastore |
Datastore.addRowData(RowInfo rowInfo,
int rowNo)
添加行数据
|
java.util.ArrayList |
SyntaxAnalyze.replaceColNameWithValue(java.util.LinkedList header,
RowInfo rowinfo)
将类中表达式word的字段名用指定的行的值进行替换,同时标识出所有词的类型
|
限定符和类型 | 方法和说明 |
---|---|
DSStream |
DSStream.filter(java.util.function.Predicate<? super RowInfo> action) |
int |
Datastore.filter(java.util.function.Predicate<? super RowInfo> action)
过虑数据,实时生效
|
void |
DSStream.forEach(java.util.function.BiConsumer<? super RowInfo,? super DsIterator> action) |
void |
DsIterator.forEach(java.util.function.BiConsumer<? super RowInfo,? super DsIterator> action) |
void |
Datastore.forEach(java.util.function.BiConsumer<? super RowInfo,? super DsIterator> action) |
void |
DSStream.forEach(java.util.function.Consumer<? super RowInfo> action) |
void |
DsIterator.forEach(java.util.function.Consumer<? super RowInfo> action) |
void |
Datastore.forEach(java.util.function.Consumer<? super RowInfo> action) |
void |
Datastore.setData(java.util.LinkedList<RowInfo> data)
设置数据
|
DSStream |
DSStream.sort(java.util.Comparator<RowInfo> comparator) |
boolean |
Datastore.sort(java.util.Comparator<RowInfo> comparator)
数据集排序
|
限定符和类型 | 方法和说明 |
---|---|
void |
ETLColumnObj.processCheckExistSql(ETLContext etlContext,
SqlBuilder sb,
Datastore ds,
RowInfo rowInfo)
查询语句条件
|
java.lang.String |
ETLColumnObj.processExecuteBeforeSql(ETLContext etlContext,
java.lang.String sql,
DataCenter toDc,
Datastore ds,
RowInfo rowInfo)
处理执行前的SQL
|
限定符和类型 | 方法和说明 |
---|---|
void |
ETLBase.processCheckExistSql(ETLContext etlContext,
SqlBuilder sb,
Datastore ds,
RowInfo rowInfo) |
java.lang.String |
ETLBase.processExecuteBeforeSql(ETLContext etlContext,
java.lang.String sql,
DataCenter toDc,
Datastore ds,
RowInfo rowInfo)
处理执行前的SQL
|
限定符和类型 | 方法和说明 |
---|---|
RowInfo |
WFEventRet.getRowInfo() |
限定符和类型 | 方法和说明 |
---|---|
void |
WFEventRet.setRowInfo(RowInfo rowInfo) |
限定符和类型 | 方法和说明 |
---|---|
void |
DsInfoStructureTransferCol.addData_zong(ModuleContext context,
Datastore ds,
int rowNo,
java.lang.String typeValue,
int index,
RowInfo rowInfo) |
限定符和类型 | 方法和说明 |
---|---|
void |
DsInfoStructureTransferCol.addData_heng(ModuleContext context,
Datastore ds,
int rowNo,
java.util.List<RowInfo> rowList)
添加数据
|