|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.crunch.io.impl.FileSourceImpl<T> org.apache.crunch.contrib.io.jdbc.DataBaseSource<T>
T
- The input type of this sourcepublic class DataBaseSource<T extends org.apache.hadoop.mapreduce.lib.db.DBWritable & org.apache.hadoop.io.Writable>
Source from reading from a database via a JDBC connection. Underlying
database reading is provided by DBInputFormat
.
A type that is input via this class must be a Writable that also implements
DBWritable. On the DBWritable.readFields(java.sql.ResultSet)
method
needs to be fully implemented form DBWritable
.
Method Summary | |
---|---|
long |
getLastModifiedAt(org.apache.hadoop.conf.Configuration configuration)
Returns the time (in milliseconds) that this Source was most recently
modified (e.g., because an input file was edited or new files were added to
a directory.) |
long |
getSize(org.apache.hadoop.conf.Configuration configuration)
Returns the number of bytes in this Source . |
Methods inherited from class org.apache.crunch.io.impl.FileSourceImpl |
---|
configureSource, equals, getBundle, getConverter, getPath, getPaths, getType, hashCode, inputConf, toString |
Methods inherited from class java.lang.Object |
---|
getClass, notify, notifyAll, wait, wait, wait |
Method Detail |
---|
public long getSize(org.apache.hadoop.conf.Configuration configuration)
Source
Source
.
getSize
in interface Source<T extends org.apache.hadoop.mapreduce.lib.db.DBWritable & org.apache.hadoop.io.Writable>
getSize
in class org.apache.crunch.io.impl.FileSourceImpl<T extends org.apache.hadoop.mapreduce.lib.db.DBWritable & org.apache.hadoop.io.Writable>
public long getLastModifiedAt(org.apache.hadoop.conf.Configuration configuration)
Source
Source
was most recently
modified (e.g., because an input file was edited or new files were added to
a directory.)
getLastModifiedAt
in interface Source<T extends org.apache.hadoop.mapreduce.lib.db.DBWritable & org.apache.hadoop.io.Writable>
getLastModifiedAt
in class org.apache.crunch.io.impl.FileSourceImpl<T extends org.apache.hadoop.mapreduce.lib.db.DBWritable & org.apache.hadoop.io.Writable>
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |