MCPcopy Create free account

hub / github.com/dianping/wormhole / types & classes

Types & classes186 in github.com/dianping/wormhole

ClassAbstractPlugin
src/main/java/com/dp/nebula/wormhole/common/AbstractPlugin.java:9
ClassAbstractPluginManager
src/main/java/com/dp/nebula/wormhole/engine/core/AbstractPluginManager.java:23
ClassAbstractSplitter
src/main/java/com/dp/nebula/wormhole/common/AbstractSplitter.java:9
ClassAbstractStorage
src/main/java/com/dp/nebula/wormhole/engine/storage/AbstractStorage.java:3
ClassAbstractTransformer
src/main/java/com/dp/nebula/wormhole/common/AbstractTransformer.java:6
ClassAddAndFiltTransformer
src/main/java/com/dp/nebula/wormhole/transform/impls/AddAndFiltTransformer.java:10
ClassAddAndFiltTransformerTest
src/test/java/com/dp/nebula/wormhole/transform/impls/AddAndFiltTransformerTest.java:9
ClassBufferedLineExchanger
src/main/java/com/dp/nebula/wormhole/common/BufferedLineExchanger.java:10
ClassBufferedLineExchangerTest
src/test/java/com/dp/nebula/wormhole/common/BufferedLineExchangerTest.java:17
ClassBuilder
src/main/java/com/dp/nebula/wormhole/plugins/reader/hivereader/HiveJdbcClient.java:108
ClassClassMember
src/main/java/com/dp/nebula/wormhole/common/utils/ClassNode.java:52
ClassClassNode
src/main/java/com/dp/nebula/wormhole/common/utils/ClassNode.java:9
ClassColumn
src/main/java/com/dp/nebula/wormhole/plugins/common/MetaData.java:105
ClassCompletedMonitorInfo
src/main/java/com/dp/nebula/wormhole/engine/monitor/CompletedMonitorInfo.java:8
ClassDBResultSetReceiver
src/main/java/com/dp/nebula/wormhole/plugins/common/DBResultSetReceiver.java:8
ClassDBResultSetSender
src/main/java/com/dp/nebula/wormhole/plugins/common/DBResultSetSender.java:19
ClassDBSource
A tool class which wraps DataSource. It provides methods to create a DataSource, get data source, get database connection so that other plugins can us
src/main/java/com/dp/nebula/wormhole/plugins/common/DBSource.java:28
ClassDBUtils
src/main/java/com/dp/nebula/wormhole/plugins/common/DBUtils.java:16
ClassDFSUtils
src/main/java/com/dp/nebula/wormhole/plugins/common/DFSUtils.java:24
ClassDFSUtilsTest
src/test/java/com/dp/nebula/wormhole/plugins/common/DFSUtilsTest.java:13
ClassDefaultLine
src/main/java/com/dp/nebula/wormhole/common/DefaultLine.java:7
ClassDefaultLineExchanger
src/main/java/com/dp/nebula/wormhole/common/DefaultLineExchanger.java:8
ClassDefaultParam
src/main/java/com/dp/nebula/wormhole/common/DefaultParam.java:14
ClassDefaultParamTest
src/test/java/com/dp/nebula/wormhole/common/DefaultParamTest.java:16
ClassDefaultPluginMonitor
src/main/java/com/dp/nebula/wormhole/common/DefaultPluginMonitor.java:5
ClassDefaultReaderPeriphery
src/main/java/com/dp/nebula/wormhole/engine/core/DefaultReaderPeriphery.java:8
ClassDefaultSplitter
src/main/java/com/dp/nebula/wormhole/engine/core/DefaultSplitter.java:5
ClassDefaultWriterPeriphery
src/main/java/com/dp/nebula/wormhole/engine/core/DefaultWriterPeriphery.java:8
ClassDescribeRefObject
src/main/java/com/dp/nebula/wormhole/plugins/reader/salesforcereader/DescribeRefObject.java:7
ClassDfsReaderCompTextFileStrategy
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:383
InterfaceDfsReaderStrategy
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:223
ClassDfsReaderTextFileStrategy
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:237
InterfaceDfsWriterStrategy
src/main/java/com/dp/nebula/wormhole/plugins/writer/hdfswriter/HdfsWriter.java:164
ClassDfsWriterTextFileStrategy
src/main/java/com/dp/nebula/wormhole/plugins/writer/hdfswriter/HdfsWriter.java:172
ClassDoubleQueue
src/main/java/com/dp/nebula/wormhole/engine/storage/DoubleQueue.java:9
ClassDoubleQueueTest
src/test/java/com/dp/nebula/wormhole/engine/storage/DoubleQueueTest.java:13
ClassEncryptionUtil
src/main/java/com/dp/nebula/wormhole/plugins/reader/salesforcereader/EncryptionUtil.java:10
ClassEngine
src/main/java/com/dp/nebula/wormhole/engine/core/Engine.java:32
ClassEngineConfParamKey
src/main/java/com/dp/nebula/wormhole/engine/config/EngineConfParamKey.java:3
ClassEngineTest
src/test/java/com/dp/nebula/wormhole/engine/core/EngineTest.java:19
ClassEnvironment
src/main/java/com/dp/nebula/wormhole/common/utils/Environment.java:3
ClassErrorCodeUtils
src/main/java/com/dp/nebula/wormhole/plugins/common/ErrorCodeUtils.java:8
ClassFailedInfo
src/main/java/com/dp/nebula/wormhole/engine/monitor/FailedInfo.java:3
ClassFakeReader
src/test/java/com/dp/nebula/wormhole/engine/common/FakeReader.java:9
ClassFakeWriter
src/test/java/com/dp/nebula/wormhole/engine/common/FakeWriter.java:9
ClassFieldTransformUtils
src/main/java/com/dp/nebula/wormhole/transform/utils/FieldTransformUtils.java:6
ClassFieldTransformUtilsTest
src/test/java/com/dp/nebula/wormhole/transform/utils/FieldTransformUtilsTest.java:8
EnumFileType
src/main/java/com/dp/nebula/wormhole/plugins/common/SFTPUtils.java:15
ClassGreenplumReader
src/main/java/com/dp/nebula/wormhole/plugins/reader/greenplumreader/GreenplumReader.java:26
ClassGreenplumReaderPeriphery
src/main/java/com/dp/nebula/wormhole/plugins/reader/greenplumreader/GreenplumReaderPeriphery.java:21
ClassGreenplumReaderSplitter
src/main/java/com/dp/nebula/wormhole/plugins/reader/greenplumreader/GreenplumReaderSplitter.java:17
ClassGreenplumReaderTest
src/test/java/com/dp/nebula/wormhole/plugins/reader/greenplumreader/GreenplumReaderTest.java:24
ClassGreenplumWriter
src/main/java/com/dp/nebula/wormhole/plugins/writer/greenplumwriter/GreenplumWriter.java:24
ClassGreenplumWriterPeriphery
src/main/java/com/dp/nebula/wormhole/plugins/writer/greenplumwriter/GreenplumWriterPeriphery.java:21
ClassHBaseClient
src/main/java/com/dp/nebula/wormhole/plugins/common/HBaseClient.java:24
ClassHBaseProxy
src/main/java/com/dp/nebula/wormhole/plugins/reader/hbasereader/HBaseProxy.java:18
ClassHBaseReader
src/main/java/com/dp/nebula/wormhole/plugins/reader/hbasereader/HBaseReader.java:15
ClassHBaseReaderSplitter
src/main/java/com/dp/nebula/wormhole/plugins/reader/hbasereader/HBaseReaderSplitter.java:15
ClassHBaseSplitter
src/main/java/com/dp/nebula/wormhole/plugins/writer/hbasewriter/HBaseSplitter.java:12
ClassHBaseWriter
src/main/java/com/dp/nebula/wormhole/plugins/writer/hbasewriter/HBaseWriter.java:18
ClassHBaseWriterPeriphery
src/main/java/com/dp/nebula/wormhole/plugins/writer/hbasewriter/HBaseWriterPeriphery.java:16
ClassHdfsDirSplitter
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsDirSplitter.java:20
ClassHdfsDirSplitter
src/main/java/com/dp/nebula/wormhole/plugins/writer/hdfswriter/HdfsDirSplitter.java:14
EnumHdfsFileType
src/main/java/com/dp/nebula/wormhole/plugins/common/DFSUtils.java:66
ClassHdfsReader
src/main/java/com/dp/nebula/wormhole/plugins/reader/hdfsreader/HdfsReader.java:28
ClassHdfsWriter
src/main/java/com/dp/nebula/wormhole/plugins/writer/hdfswriter/HdfsWriter.java:28
ClassHdfsWriterPeriphery
src/main/java/com/dp/nebula/wormhole/plugins/writer/hdfswriter/HdfsWriterPeriphery.java:25
ClassHippoMongoToGPTransformer
src/main/java/com/dp/nebula/wormhole/transform/impls/HippoMongoToGPTransformer.java:12
ClassHiveJdbcClient
src/main/java/com/dp/nebula/wormhole/plugins/reader/hivereader/HiveJdbcClient.java:18
ClassHiveReader
src/main/java/com/dp/nebula/wormhole/plugins/reader/hivereader/HiveReader.java:28
EnumHiveReaderMode
src/main/java/com/dp/nebula/wormhole/plugins/reader/hivereader/HiveReaderMode.java:3
ClassHiveReaderPeriphery
src/main/java/com/dp/nebula/wormhole/plugins/reader/hivereader/HiveReaderPeriphery.java:22
ClassHiveReaderSplitter
src/main/java/com/dp/nebula/wormhole/plugins/reader/hivereader/HiveReaderSplitter.java:20
ClassHiveReaderTest
src/test/java/com/dp/nebula/wormhole/plugins/reader/hivereader/HiveReaderTest.java:33
InterfaceILine
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILine.java:4
InterfaceILineReceiver
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILineReceiver.java:3
InterfaceILineSender
src/main/java/com/dp/nebula/wormhole/common/interfaces/ILineSender.java:3
InterfaceIParam
src/main/java/com/dp/nebula/wormhole/common/interfaces/IParam.java:6
InterfaceIPlugin
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPlugin.java:5
InterfaceIPluginMonitor
src/main/java/com/dp/nebula/wormhole/common/interfaces/IPluginMonitor.java:3
InterfaceIReader
src/main/java/com/dp/nebula/wormhole/common/interfaces/IReader.java:3
InterfaceIReaderPeriphery
src/main/java/com/dp/nebula/wormhole/common/interfaces/IReaderPeriphery.java:3
InterfaceISourceCounter
src/main/java/com/dp/nebula/wormhole/common/interfaces/ISourceCounter.java:3
InterfaceISplitter
src/main/java/com/dp/nebula/wormhole/common/interfaces/ISplitter.java:5
InterfaceIStorage
A buffer where {@link IReader} and {@link IWriter} exchange data.
src/main/java/com/dp/nebula/wormhole/engine/storage/IStorage.java:9
InterfaceITargetCounter
src/main/java/com/dp/nebula/wormhole/common/interfaces/ITargetCounter.java:3
InterfaceITransformer
src/main/java/com/dp/nebula/wormhole/common/interfaces/ITransformer.java:3
InterfaceITransmissionPeriphery
src/main/java/com/dp/nebula/wormhole/common/interfaces/ITransmissionPeriphery.java:4
InterfaceIWriter
src/main/java/com/dp/nebula/wormhole/common/interfaces/IWriter.java:3
InterfaceIWriterPeriphery
src/main/java/com/dp/nebula/wormhole/common/interfaces/IWriterPeriphery.java:3
ClassJarLoader
src/main/java/com/dp/nebula/wormhole/engine/utils/JarLoader.java:15
ClassJarLoaderTest
src/test/java/com/dp/nebula/wormhole/engine/utils/JarLoaderTest.java:10
ClassJobConf
src/main/java/com/dp/nebula/wormhole/common/config/JobConf.java:5
ClassJobConfGenDriver
src/main/java/com/dp/nebula/wormhole/common/utils/JobConfGenDriver.java:27
ClassJobDBUtil
src/main/java/com/dp/nebula/wormhole/common/utils/JobDBUtil.java:18
ClassJobPluginConf
src/main/java/com/dp/nebula/wormhole/common/config/JobPluginConf.java:5
EnumJobStatus
src/main/java/com/dp/nebula/wormhole/common/JobStatus.java:3
ClassLineExchangerFactory
src/main/java/com/dp/nebula/wormhole/common/LineExchangerFactory.java:9
ClassMetaData
MetaData records a source or sink Database meta information.
src/main/java/com/dp/nebula/wormhole/plugins/common/MetaData.java:9
ClassMongoReader
src/main/java/com/dp/nebula/wormhole/plugins/reader/mongoreader/MongoReader.java:22
next →1–100 of 186, ranked by callers