- generateOffsets() - Method in class kafka.etl.impl.DataGenerator
-
- get(KafkaETLKey, BytesWritable) - Method in class kafka.etl.KafkaETLContext
-
- getBoolean(String, Boolean) - Method in class kafka.etl.Props
-
get boolean value with default value
- getBoolean(String) - Method in class kafka.etl.Props
-
get boolean value
- getBytes(BytesWritable) - Static method in class kafka.etl.KafkaETLUtils
-
- getChecksum() - Method in class kafka.etl.KafkaETLKey
-
- getClientBufferSize(Props) - Static method in class kafka.etl.KafkaETLContext
-
- getClientTimeout(Props) - Static method in class kafka.etl.KafkaETLContext
-
- getContext() - Method in class kafka.etl.KafkaETLRecordReader
-
- getCount() - Method in class kafka.etl.KafkaETLContext
-
- getData(Message) - Method in class kafka.etl.impl.SimpleKafkaETLMapper
-
- getDouble(String, double) - Method in class kafka.etl.Props
-
get double value with default value
- getDouble(String) - Method in class kafka.etl.Props
-
get double value
- getFileName(Path) - Static method in class kafka.etl.KafkaETLUtils
-
- getIndex() - Method in class kafka.etl.KafkaETLKey
-
- getInt(String, Integer) - Method in class kafka.etl.Props
-
get integer value with default value
- getInt(String) - Method in class kafka.etl.Props
-
get integer value
- getJobConf(String, Props, Class) - Static method in class kafka.etl.KafkaETLJob
-
Helper function to initialize a job configuration
- getKeySet() - Method in class kafka.etl.Props
-
get all property names
- getLastPath(Path, FileSystem) - Static method in class kafka.etl.KafkaETLUtils
-
- getLong(String, Long) - Method in class kafka.etl.Props
-
get long value with default value
- getLong(String) - Method in class kafka.etl.Props
-
get long value
- getMapByPrefix(String) - Method in class kafka.etl.Props
-
Get a map of all properties by string prefix
- getNext(KafkaETLKey, BytesWritable) - Method in class kafka.etl.KafkaETLContext
-
- getOffset() - Method in class kafka.etl.KafkaETLKey
-
- getOffset() - Method in class kafka.etl.KafkaETLRequest
-
- getOffsetRange() - Method in class kafka.etl.KafkaETLContext
-
Get offset ranges
- getPartition() - Method in class kafka.etl.KafkaETLRequest
-
- getProgress() - Method in class kafka.etl.KafkaETLRecordReader
-
- getPropsFromJob(Configuration) - Static method in class kafka.etl.KafkaETLUtils
-
- getReadBytes() - Method in class kafka.etl.KafkaETLContext
-
- getRecordReader(InputSplit, JobConf, Reporter) - Method in class kafka.etl.KafkaETLInputFormat
-
- getSplits(JobConf, int) - Method in class kafka.etl.KafkaETLInputFormat
-
- getStringList(String) - Method in class kafka.etl.Props
-
get property of "key" and split the value by " ,"
- getStringList(String, String) - Method in class kafka.etl.Props
-
get property of "key" and split the value by "sep"
- getStringList(String, List<String>) - Method in class kafka.etl.Props
-
get string list with default value.
- getStringList(String, List<String>, String) - Method in class kafka.etl.Props
-
get string list with default value
- getTopic() - Method in class kafka.etl.KafkaETLRequest
-
- getTotalBytes() - Method in class kafka.etl.KafkaETLContext
-
- getURI() - Method in class kafka.etl.KafkaETLRequest
-
- getUri(String, URI) - Method in class kafka.etl.Props
-
get URI value with default value
- getUri(String, String) - Method in class kafka.etl.Props
-
get URI value
- getUri(String) - Method in class kafka.etl.Props
-
get URI value
- getValue(String, T) - Method in class kafka.etl.Props
-
- getValue(String, Class<T>) - Method in class kafka.etl.Props
-