Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/dianping/wormhole
/ functions
Functions
874 in github.com/dianping/wormhole
⨍
Functions
874
◇
Types & classes
186
↓ 231 callers
Method
getValue
(String key)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:8
↓ 115 callers
Method
info
Get information about {@link IStorage}. @return {@link IStorage} information.
src/main/java/com/dp/nebula/wormhole/engine/storage/IStorage.java:107
↓ 107 callers
Method
getParam
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:9
↓ 101 callers
Method
getStatus
()
src/main/java/com/dp/nebula/wormhole/common/JobStatus.java:39
↓ 90 callers
Method
toString
Use param as separator of field, translate the {@link ILine} into {@link String}. @param separator field separator. @return {@link ILine} in
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILine.java:94
↓ 59 callers
Method
getIntValue
(String key)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:16
↓ 40 callers
Method
close
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:234
↓ 40 callers
Method
split
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/ISplitter.java:9
↓ 36 callers
Method
addField
Add a field into the {@link ILine}. @param field Field added into {@link ILine}. @return true for OK, false for failure.
src/main/java/com/dp/nebula/wormhole/common/DefaultLine.java:53
↓ 35 callers
Method
length
Get length of all fields, exclude separate. @return length of all fields.
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILine.java:118
↓ 35 callers
Method
putValue
(String key, String value)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:36
↓ 35 callers
Method
size
Get size of {@link IStorage} in bytes @return Storage size.
src/main/java/com/dp/nebula/wormhole/engine/storage/IStorage.java:89
↓ 32 callers
Method
getMonitor
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:13
↓ 29 callers
Method
getStatus
()
src/main/java/com/dp/nebula/wormhole/engine/core/ReaderManager.java:171
↓ 27 callers
Method
addField
Add a field into the {@link ILine}. @param field Field added into {@link ILine}. @return true for OK, false for failure.
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILine.java:15
↓ 25 callers
Method
getName
()
src/main/java/com/dp/nebula/wormhole/common/utils/ClassNode.java:34
↓ 24 callers
Method
getField
Get one field of the {@link ILine} indexed by the param. NOTE: if index specifed by user beyond field number of {@link ILine} it may throw runtime ex
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILine.java:47
↓ 24 callers
Method
getStat
()
src/main/java/com/dp/nebula/wormhole/engine/storage/IStorage.java:110
↓ 23 callers
Method
close
()
src/main/java/com/dp/nebula/wormhole/plugins/writer/hdfswriter/HdfsWriter.java:169
↓ 23 callers
Method
getConnection
A synchronized static method which gets database connection by the identification. @param clazz {@link Pluginable} class @param ip
src/main/java/com/dp/nebula/wormhole/plugins/common/DBSource.java:185
↓ 21 callers
Method
equals
(Object obj)
src/main/java/com/dp/nebula/wormhole/common/DefaultLine.java:205
↓ 21 callers
Method
init
Initialization for {@link IStorage}. @param id {@link IWriter} id. @param lineLimit Limit of the line number the {@link IStorage}
src/main/java/com/dp/nebula/wormhole/engine/storage/IStorage.java:30
↓ 21 callers
Method
warn
(String oldStr, Object defStr)
src/main/java/com/dp/nebula/wormhole/common/DefaultParam.java:19
↓ 20 callers
Method
next
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:228
↓ 17 callers
Method
clone
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:42
↓ 17 callers
Method
setStatusCode
(int statusCode)
src/main/java/com/dp/nebula/wormhole/common/WormholeException.java:16
↓ 15 callers
Method
getConf
Get {@link Configuration}. @param dir directory path in hdfs @param conf hadoop-site.xml path @return {@link Configuration}
src/main/java/com/dp/nebula/wormhole/plugins/common/DFSUtils.java:86
↓ 15 callers
Method
getPath
()
src/main/java/com/dp/nebula/wormhole/plugins/common/PCInfo.java:44
↓ 14 callers
Method
getBooleanValue
(String key)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:20
↓ 14 callers
Method
getStatusCode
()
src/main/java/com/dp/nebula/wormhole/common/WormholeException.java:12
↓ 13 callers
Method
close
()
src/main/java/com/dp/nebula/wormhole/engine/storage/IStorage.java:81
↓ 13 callers
Method
flush
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILineSender.java:9
↓ 13 callers
Method
getFieldNum
Get number of total fields in the {@link ILine}. @return number of total fields in {@link ILine}.
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILine.java:70
↓ 12 callers
Method
create
(String name)
src/main/java/com/dp/nebula/wormhole/transform/common/TransformerFactory.java:12
↓ 12 callers
Method
createInstanceByDefaultConstructor
(String className, Class<T> type, JarLoader jarLoader)
src/main/java/com/dp/nebula/wormhole/engine/utils/ReflectionUtil.java:10
↓ 12 callers
Method
getInstance
(String[] paths)
src/main/java/com/dp/nebula/wormhole/engine/utils/JarLoader.java:19
↓ 12 callers
Method
query
(Connection conn, String sql)
src/main/java/com/dp/nebula/wormhole/plugins/common/DBUtils.java:49
↓ 11 callers
Method
getCharValue
(String key)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:12
↓ 11 callers
Method
getPluginParam
()
src/main/java/com/dp/nebula/wormhole/common/config/JobPluginConf.java:25
↓ 11 callers
Method
increaseFailedLines
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPluginMonitor.java:13
↓ 11 callers
Method
increaseSuccessLines
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPluginMonitor.java:9
↓ 11 callers
Method
update
(Connection conn, String sql)
src/main/java/com/dp/nebula/wormhole/plugins/common/DBUtils.java:55
↓ 10 callers
Method
getMode
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/hivereader/HiveReaderMode.java:11
↓ 9 callers
Method
createFileSystem
Initialize handle of {@link FileSystem}. @param uri URI @param conf {@link Configuration} @return an FileSystem instance
src/main/java/com/dp/nebula/wormhole/plugins/common/DFSUtils.java:329
↓ 9 callers
Method
createNewLine
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILineSender.java:5
↓ 9 callers
Method
send
(ILine line)
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILineSender.java:7
↓ 9 callers
Method
setParam
(IParam param)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:7
↓ 9 callers
Method
write
(ILineReceiver receiver,ITransformer transformer, String transformerParams)
src/main/java/com/dp/nebula/wormhole/plugins/writer/hdfswriter/HdfsWriter.java:167
↓ 8 callers
Method
getFailedLines
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPluginMonitor.java:7
↓ 8 callers
Method
getId
()
src/main/java/com/dp/nebula/wormhole/engine/storage/Statistics.java:65
↓ 8 callers
Method
parse
(String name, String path)
src/main/java/com/dp/nebula/wormhole/common/utils/JobConfGenDriver.java:196
↓ 8 callers
Method
replace
@param string field string @return if the field string is equal to specified nullString, it return null
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:374
↓ 7 callers
Method
closeAll
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:213
↓ 7 callers
Method
closeAll
()
src/main/java/com/dp/nebula/wormhole/plugins/writer/hdfswriter/HdfsWriter.java:294
↓ 7 callers
Method
closeResultSet
(ResultSet rs)
src/main/java/com/dp/nebula/wormhole/plugins/common/DBUtils.java:64
↓ 7 callers
Method
getCollection
( MongoURI uri )
src/main/java/com/dp/nebula/wormhole/plugins/common/MongoUtils.java:21
↓ 7 callers
Method
getDestructLimit
()
src/main/java/com/dp/nebula/wormhole/engine/storage/StorageConf.java:46
↓ 7 callers
Method
increaseSuccessLine
(long lines)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPluginMonitor.java:11
↓ 7 callers
Method
receive
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILineReceiver.java:5
↓ 7 callers
Method
setMonitor
(IPluginMonitor monitor)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:11
↓ 7 callers
Method
update
(String expression)
src/test/java/com/dp/nebula/wormhole/plugins/reader/sqlserverreader/SqlserverReaderTest.java:161
↓ 7 callers
Method
update
(String expression)
src/test/java/com/dp/nebula/wormhole/plugins/reader/hivereader/HiveReaderTest.java:183
↓ 6 callers
Method
clear
Clear
src/main/java/com/dp/nebula/wormhole/common/DefaultLine.java:26
↓ 6 callers
Method
finish
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:19
↓ 6 callers
Method
getInstance
()
src/main/java/com/dp/nebula/wormhole/plugins/common/HBaseClient.java:73
↓ 6 callers
Method
getPassword
()
src/main/java/com/dp/nebula/wormhole/plugins/common/PCInfo.java:57
↓ 6 callers
Method
getPutBuffer
()
src/main/java/com/dp/nebula/wormhole/plugins/common/HBaseClient.java:192
↓ 6 callers
Method
getTableName
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/salesforcereader/SOQLInfo.java:159
↓ 6 callers
Method
invalidSoql
(String msg)
src/main/java/com/dp/nebula/wormhole/plugins/reader/salesforcereader/SOQLInfo.java:151
↓ 6 callers
Method
loadEngineConfig
Parse engine configuration file. @return {@link EngineConf}.
src/main/java/com/dp/nebula/wormhole/common/utils/ParseXMLUtil.java:149
↓ 6 callers
Method
newInstance
()
src/main/java/com/dp/nebula/wormhole/common/utils/ClassNode.java:14
↓ 6 callers
Method
receive
Get next line of data which dumped to data destination. @return next {@link ILine}.
src/main/java/com/dp/nebula/wormhole/common/BufferedLineExchanger.java:70
↓ 6 callers
Method
setPort
(int port)
src/main/java/com/dp/nebula/wormhole/plugins/common/PCInfo.java:24
↓ 5 callers
Method
connection
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:17
↓ 5 callers
Method
getColumnCount
()
src/main/java/com/dp/nebula/wormhole/plugins/common/DBResultSetReceiver.java:34
↓ 5 callers
Method
getFailedWriterID
()
src/main/java/com/dp/nebula/wormhole/engine/core/WriterManager.java:221
↓ 5 callers
Method
getLineRRefused
()
src/main/java/com/dp/nebula/wormhole/engine/storage/Statistics.java:109
↓ 5 callers
Method
getPort
()
src/main/java/com/dp/nebula/wormhole/plugins/common/PCInfo.java:20
↓ 5 callers
Method
getPushClosed
()
src/main/java/com/dp/nebula/wormhole/engine/storage/AbstractStorage.java:9
↓ 5 callers
Method
getTime
()
src/main/java/com/dp/nebula/wormhole/engine/monitor/WormHoleJobInfo.java:48
↓ 5 callers
Method
open
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:224
↓ 5 callers
Method
printUsage
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/salesforcereader/EncryptionUtil.java:242
↓ 5 callers
Method
pull
@param timeout appointed limit time @param unit time unit
src/main/java/com/dp/nebula/wormhole/engine/storage/DoubleQueue.java:378
↓ 5 callers
Method
push
If exists write space, it will return true, and write one line to the space. otherwise, it will try to do that in a appointed time,when time is out if
src/main/java/com/dp/nebula/wormhole/engine/storage/DoubleQueue.java:263
↓ 5 callers
Method
register
A synchronized static method which create {@link DataSource}. @param clazz {@link Pluginable} class @param ip database host ip
src/main/java/com/dp/nebula/wormhole/plugins/common/DBSource.java:60
↓ 5 callers
Method
setDestructLimit
(int destructLimit)
src/main/java/com/dp/nebula/wormhole/engine/storage/StorageConf.java:50
↓ 5 callers
Method
setPushClosed
(Boolean pushClosed)
src/main/java/com/dp/nebula/wormhole/engine/storage/AbstractStorage.java:12
↓ 4 callers
Method
arrayTooSmall
@param array @param index @return true if array is too small to increment the index
src/main/java/com/dp/nebula/wormhole/plugins/reader/salesforcereader/EncryptionUtil.java:360
↓ 4 callers
Method
convertStringToDBObject
(String str)
src/main/java/com/dp/nebula/wormhole/plugins/common/MongoUtils.java:42
↓ 4 callers
Method
createParamSplit
(IParam param, DBObject q, DBObject min, DBObject max)
src/main/java/com/dp/nebula/wormhole/plugins/reader/mongoreader/MongoReaderSplitter.java:135
↓ 4 callers
Method
deleteFile
Delete file specified by path. @param path {@link Path} in hadoop @param flag need to do delete recursively @throws IOExceptio
src/main/java/com/dp/nebula/wormhole/plugins/common/DFSUtils.java:292
↓ 4 callers
Method
getAttr
(String key)
src/main/java/com/dp/nebula/wormhole/common/utils/ClassNode.java:74
↓ 4 callers
Method
getHTable
()
src/main/java/com/dp/nebula/wormhole/plugins/common/HBaseClient.java:173
↓ 4 callers
Method
getLineExchanger
()
src/test/java/com/dp/nebula/wormhole/common/BufferedLineExchangerTest.java:18
↓ 4 callers
Method
getLongValue
(String key)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:24
↓ 4 callers
Method
getParamMap
(Element rootElement)
src/main/java/com/dp/nebula/wormhole/common/utils/ParseXMLUtil.java:169
↓ 4 callers
Method
getPath
(String[] paths)
src/test/java/com/dp/nebula/wormhole/engine/utils/JarLoaderTest.java:42
↓ 4 callers
Method
getPluginName
()
src/main/java/com/dp/nebula/wormhole/common/config/JobPluginConf.java:21
↓ 4 callers
Method
getStorageForReader
()
src/main/java/com/dp/nebula/wormhole/engine/storage/StorageManager.java:32
↓ 4 callers
Method
getStorageForWriter
(String id)
src/main/java/com/dp/nebula/wormhole/engine/storage/StorageManager.java:40
next →
1–100 of 874, ranked by callers