MCPcopy Create free account

hub / github.com/dianping/wormhole / functions

Functions874 in github.com/dianping/wormhole

↓ 231 callersMethodgetValue
(String key)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:8
↓ 115 callersMethodinfo
Get information about {@link IStorage}. @return {@link IStorage} information.
src/main/java/com/dp/nebula/wormhole/engine/storage/IStorage.java:107
↓ 107 callersMethodgetParam
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:9
↓ 101 callersMethodgetStatus
()
src/main/java/com/dp/nebula/wormhole/common/JobStatus.java:39
↓ 90 callersMethodtoString
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 callersMethodgetIntValue
(String key)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:16
↓ 40 callersMethodclose
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:234
↓ 40 callersMethodsplit
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/ISplitter.java:9
↓ 36 callersMethodaddField
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 callersMethodlength
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 callersMethodputValue
(String key, String value)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:36
↓ 35 callersMethodsize
Get size of {@link IStorage} in bytes @return Storage size.
src/main/java/com/dp/nebula/wormhole/engine/storage/IStorage.java:89
↓ 32 callersMethodgetMonitor
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:13
↓ 29 callersMethodgetStatus
()
src/main/java/com/dp/nebula/wormhole/engine/core/ReaderManager.java:171
↓ 27 callersMethodaddField
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 callersMethodgetName
()
src/main/java/com/dp/nebula/wormhole/common/utils/ClassNode.java:34
↓ 24 callersMethodgetField
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 callersMethodgetStat
()
src/main/java/com/dp/nebula/wormhole/engine/storage/IStorage.java:110
↓ 23 callersMethodclose
()
src/main/java/com/dp/nebula/wormhole/plugins/writer/hdfswriter/HdfsWriter.java:169
↓ 23 callersMethodgetConnection
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 callersMethodequals
(Object obj)
src/main/java/com/dp/nebula/wormhole/common/DefaultLine.java:205
↓ 21 callersMethodinit
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 callersMethodwarn
(String oldStr, Object defStr)
src/main/java/com/dp/nebula/wormhole/common/DefaultParam.java:19
↓ 20 callersMethodnext
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:228
↓ 17 callersMethodclone
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:42
↓ 17 callersMethodsetStatusCode
(int statusCode)
src/main/java/com/dp/nebula/wormhole/common/WormholeException.java:16
↓ 15 callersMethodgetConf
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 callersMethodgetPath
()
src/main/java/com/dp/nebula/wormhole/plugins/common/PCInfo.java:44
↓ 14 callersMethodgetBooleanValue
(String key)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:20
↓ 14 callersMethodgetStatusCode
()
src/main/java/com/dp/nebula/wormhole/common/WormholeException.java:12
↓ 13 callersMethodclose
()
src/main/java/com/dp/nebula/wormhole/engine/storage/IStorage.java:81
↓ 13 callersMethodflush
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILineSender.java:9
↓ 13 callersMethodgetFieldNum
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 callersMethodcreate
(String name)
src/main/java/com/dp/nebula/wormhole/transform/common/TransformerFactory.java:12
↓ 12 callersMethodcreateInstanceByDefaultConstructor
(String className, Class<T> type, JarLoader jarLoader)
src/main/java/com/dp/nebula/wormhole/engine/utils/ReflectionUtil.java:10
↓ 12 callersMethodgetInstance
(String[] paths)
src/main/java/com/dp/nebula/wormhole/engine/utils/JarLoader.java:19
↓ 12 callersMethodquery
(Connection conn, String sql)
src/main/java/com/dp/nebula/wormhole/plugins/common/DBUtils.java:49
↓ 11 callersMethodgetCharValue
(String key)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:12
↓ 11 callersMethodgetPluginParam
()
src/main/java/com/dp/nebula/wormhole/common/config/JobPluginConf.java:25
↓ 11 callersMethodincreaseFailedLines
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPluginMonitor.java:13
↓ 11 callersMethodincreaseSuccessLines
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPluginMonitor.java:9
↓ 11 callersMethodupdate
(Connection conn, String sql)
src/main/java/com/dp/nebula/wormhole/plugins/common/DBUtils.java:55
↓ 10 callersMethodgetMode
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/hivereader/HiveReaderMode.java:11
↓ 9 callersMethodcreateFileSystem
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 callersMethodcreateNewLine
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILineSender.java:5
↓ 9 callersMethodsend
(ILine line)
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILineSender.java:7
↓ 9 callersMethodsetParam
(IParam param)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:7
↓ 9 callersMethodwrite
(ILineReceiver receiver,ITransformer transformer, String transformerParams)
src/main/java/com/dp/nebula/wormhole/plugins/writer/hdfswriter/HdfsWriter.java:167
↓ 8 callersMethodgetFailedLines
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPluginMonitor.java:7
↓ 8 callersMethodgetId
()
src/main/java/com/dp/nebula/wormhole/engine/storage/Statistics.java:65
↓ 8 callersMethodparse
(String name, String path)
src/main/java/com/dp/nebula/wormhole/common/utils/JobConfGenDriver.java:196
↓ 8 callersMethodreplace
@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 callersMethodcloseAll
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:213
↓ 7 callersMethodcloseAll
()
src/main/java/com/dp/nebula/wormhole/plugins/writer/hdfswriter/HdfsWriter.java:294
↓ 7 callersMethodcloseResultSet
(ResultSet rs)
src/main/java/com/dp/nebula/wormhole/plugins/common/DBUtils.java:64
↓ 7 callersMethodgetCollection
( MongoURI uri )
src/main/java/com/dp/nebula/wormhole/plugins/common/MongoUtils.java:21
↓ 7 callersMethodgetDestructLimit
()
src/main/java/com/dp/nebula/wormhole/engine/storage/StorageConf.java:46
↓ 7 callersMethodincreaseSuccessLine
(long lines)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPluginMonitor.java:11
↓ 7 callersMethodreceive
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILineReceiver.java:5
↓ 7 callersMethodsetMonitor
(IPluginMonitor monitor)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:11
↓ 7 callersMethodupdate
(String expression)
src/test/java/com/dp/nebula/wormhole/plugins/reader/sqlserverreader/SqlserverReaderTest.java:161
↓ 7 callersMethodupdate
(String expression)
src/test/java/com/dp/nebula/wormhole/plugins/reader/hivereader/HiveReaderTest.java:183
↓ 6 callersMethodclear
Clear
src/main/java/com/dp/nebula/wormhole/common/DefaultLine.java:26
↓ 6 callersMethodfinish
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:19
↓ 6 callersMethodgetInstance
()
src/main/java/com/dp/nebula/wormhole/plugins/common/HBaseClient.java:73
↓ 6 callersMethodgetPassword
()
src/main/java/com/dp/nebula/wormhole/plugins/common/PCInfo.java:57
↓ 6 callersMethodgetPutBuffer
()
src/main/java/com/dp/nebula/wormhole/plugins/common/HBaseClient.java:192
↓ 6 callersMethodgetTableName
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/salesforcereader/SOQLInfo.java:159
↓ 6 callersMethodinvalidSoql
(String msg)
src/main/java/com/dp/nebula/wormhole/plugins/reader/salesforcereader/SOQLInfo.java:151
↓ 6 callersMethodloadEngineConfig
Parse engine configuration file. @return {@link EngineConf}.
src/main/java/com/dp/nebula/wormhole/common/utils/ParseXMLUtil.java:149
↓ 6 callersMethodnewInstance
()
src/main/java/com/dp/nebula/wormhole/common/utils/ClassNode.java:14
↓ 6 callersMethodreceive
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 callersMethodsetPort
(int port)
src/main/java/com/dp/nebula/wormhole/plugins/common/PCInfo.java:24
↓ 5 callersMethodconnection
()
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:17
↓ 5 callersMethodgetColumnCount
()
src/main/java/com/dp/nebula/wormhole/plugins/common/DBResultSetReceiver.java:34
↓ 5 callersMethodgetFailedWriterID
()
src/main/java/com/dp/nebula/wormhole/engine/core/WriterManager.java:221
↓ 5 callersMethodgetLineRRefused
()
src/main/java/com/dp/nebula/wormhole/engine/storage/Statistics.java:109
↓ 5 callersMethodgetPort
()
src/main/java/com/dp/nebula/wormhole/plugins/common/PCInfo.java:20
↓ 5 callersMethodgetPushClosed
()
src/main/java/com/dp/nebula/wormhole/engine/storage/AbstractStorage.java:9
↓ 5 callersMethodgetTime
()
src/main/java/com/dp/nebula/wormhole/engine/monitor/WormHoleJobInfo.java:48
↓ 5 callersMethodopen
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:224
↓ 5 callersMethodprintUsage
()
src/main/java/com/dp/nebula/wormhole/plugins/reader/salesforcereader/EncryptionUtil.java:242
↓ 5 callersMethodpull
@param timeout appointed limit time @param unit time unit
src/main/java/com/dp/nebula/wormhole/engine/storage/DoubleQueue.java:378
↓ 5 callersMethodpush
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 callersMethodregister
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 callersMethodsetDestructLimit
(int destructLimit)
src/main/java/com/dp/nebula/wormhole/engine/storage/StorageConf.java:50
↓ 5 callersMethodsetPushClosed
(Boolean pushClosed)
src/main/java/com/dp/nebula/wormhole/engine/storage/AbstractStorage.java:12
↓ 4 callersMethodarrayTooSmall
@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 callersMethodconvertStringToDBObject
(String str)
src/main/java/com/dp/nebula/wormhole/plugins/common/MongoUtils.java:42
↓ 4 callersMethodcreateParamSplit
(IParam param, DBObject q, DBObject min, DBObject max)
src/main/java/com/dp/nebula/wormhole/plugins/reader/mongoreader/MongoReaderSplitter.java:135
↓ 4 callersMethoddeleteFile
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 callersMethodgetAttr
(String key)
src/main/java/com/dp/nebula/wormhole/common/utils/ClassNode.java:74
↓ 4 callersMethodgetHTable
()
src/main/java/com/dp/nebula/wormhole/plugins/common/HBaseClient.java:173
↓ 4 callersMethodgetLineExchanger
()
src/test/java/com/dp/nebula/wormhole/common/BufferedLineExchangerTest.java:18
↓ 4 callersMethodgetLongValue
(String key)
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:24
↓ 4 callersMethodgetParamMap
(Element rootElement)
src/main/java/com/dp/nebula/wormhole/common/utils/ParseXMLUtil.java:169
↓ 4 callersMethodgetPath
(String[] paths)
src/test/java/com/dp/nebula/wormhole/engine/utils/JarLoaderTest.java:42
↓ 4 callersMethodgetPluginName
()
src/main/java/com/dp/nebula/wormhole/common/config/JobPluginConf.java:21
↓ 4 callersMethodgetStorageForReader
()
src/main/java/com/dp/nebula/wormhole/engine/storage/StorageManager.java:32
↓ 4 callersMethodgetStorageForWriter
(String id)
src/main/java/com/dp/nebula/wormhole/engine/storage/StorageManager.java:40
next →1–100 of 874, ranked by callers