|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Package com.datasalt.pangool |
---|
Class com.datasalt.pangool.PangoolRuntimeException extends RuntimeException implements Serializable |
---|
Package com.datasalt.pangool.io |
---|
Class com.datasalt.pangool.io.Schema extends Object implements Serializable |
---|
Serialized Fields |
---|
List<E> fields
String name
Map<K,V> indexByFieldName
List<E> nullableFields
int[] nullablePositionByIndex
Class com.datasalt.pangool.io.Schema.Field extends Object implements Serializable |
---|
Serialized Fields |
---|
String name
Schema.Field.Type type
boolean nullable
com.datasalt.pangool.io.Schema.Field.Props props
Class<T> objectClass
Class<T> serializationClass
Object cachedDefaultValue
Class com.datasalt.pangool.io.Schema.SchemaParseException extends PangoolRuntimeException implements Serializable |
---|
Class com.datasalt.pangool.io.Tuple extends Object implements Serializable |
---|
Serialized Fields |
---|
Object[] array
Schema schema
Class com.datasalt.pangool.io.Tuple.IDontKnowHowToCopyThisStuff extends RuntimeException implements Serializable |
---|
Class com.datasalt.pangool.io.Utf8 extends org.apache.hadoop.io.Text implements Serializable |
---|
Package com.datasalt.pangool.solr |
---|
Class com.datasalt.pangool.solr.DefaultTupleDocumentConverter extends Object implements Serializable |
---|
Class com.datasalt.pangool.solr.TupleSolrOutputFormat extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<ITuple,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Serialized Fields |
---|
int batchSize
int threadCount
int queueSize
boolean outputZipFile
String zipName
String localSolrHome
TupleDocumentConverter converter
DefaultTupleDocumentConverter
, but users may implement custom ones for
boosting, etc.
Package com.datasalt.pangool.tuplemr |
---|
Class com.datasalt.pangool.tuplemr.IdentityTupleMapper extends TupleMapper<ITuple,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Class com.datasalt.pangool.tuplemr.IdentityTupleReducer extends TupleReducer<ITuple,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Class com.datasalt.pangool.tuplemr.TupleMapper extends org.apache.hadoop.mapreduce.Mapper<INPUT_KEY,INPUT_VALUE,DatumWrapper<ITuple>,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Serialized Fields |
---|
TupleMapper.Collector collector
TupleMapper.TupleMRContext context
Class com.datasalt.pangool.tuplemr.TupleMRException extends Exception implements Serializable |
---|
serialVersionUID: 1L
Class com.datasalt.pangool.tuplemr.TupleReducer extends Object implements Serializable |
---|
Class com.datasalt.pangool.tuplemr.TupleRollupReducer extends TupleReducer<OUTPUT_KEY,OUTPUT_VALUE> implements Serializable |
---|
Package com.datasalt.pangool.tuplemr.avro |
---|
Class com.datasalt.pangool.tuplemr.avro.AvroInputFormat extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<org.apache.avro.mapred.AvroWrapper<T>,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Serialized Fields |
---|
String schemaStr
boolean isReflect
Class com.datasalt.pangool.tuplemr.avro.AvroOutputFormat extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<org.apache.avro.mapred.AvroWrapper<T>,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Serialized Fields |
---|
String schemaStr
int deflateLevel
String codecName
Package com.datasalt.pangool.tuplemr.mapred |
---|
Class com.datasalt.pangool.tuplemr.mapred.MapOnlyMapper extends org.apache.hadoop.mapreduce.Mapper<I1,I2,O1,O2> implements Serializable |
---|
Serialized Fields |
---|
MultipleOutputsCollector collector
Class com.datasalt.pangool.tuplemr.mapred.SerializerComparator extends Object implements Serializable |
---|
Package com.datasalt.pangool.tuplemr.mapred.lib.input |
---|
Class com.datasalt.pangool.tuplemr.mapred.lib.input.CascadingTupleInputFormat extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<ITuple,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Serialized Fields |
---|
String schemaName
String[] fieldNames
Class com.datasalt.pangool.tuplemr.mapred.lib.input.HadoopInputFormat extends org.apache.hadoop.mapreduce.InputFormat implements Serializable |
---|
Serialized Fields |
---|
Class<T> clazz
org.apache.hadoop.mapreduce.InputFormat<K,V> instance
Class com.datasalt.pangool.tuplemr.mapred.lib.input.HCatTupleInputFormat extends org.apache.hadoop.mapreduce.InputFormat<ITuple,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Serialized Fields |
---|
org.apache.hcatalog.data.schema.HCatSchema schema
Schema pangoolSchema
Class com.datasalt.pangool.tuplemr.mapred.lib.input.InvalidInputException extends IOException implements Serializable |
---|
serialVersionUID: -380668190578456802L
Serialized Fields |
---|
List<E> problems
Class com.datasalt.pangool.tuplemr.mapred.lib.input.TupleInputFormat extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<ITuple,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Serialized Fields |
---|
Schema targetSchema
Class com.datasalt.pangool.tuplemr.mapred.lib.input.TupleTextInputFormat extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat<ITuple,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Serialized Fields |
---|
com.datasalt.pangool.tuplemr.mapred.lib.input.TupleTextInputFormat.InputType type
Schema schema
boolean hasHeader
boolean strictQuotes
char separatorCharacter
char quoteCharacter
char escapeCharacter
TupleTextInputFormat.FieldSelector fieldSelector
String nullString
int[] fixedWidthFieldsPositions
Class com.datasalt.pangool.tuplemr.mapred.lib.input.TupleTextInputFormat.FieldSelector extends Object implements Serializable |
---|
Serialized Fields |
---|
Integer[] fieldIndexesToSelect
Package com.datasalt.pangool.tuplemr.mapred.lib.output |
---|
Class com.datasalt.pangool.tuplemr.mapred.lib.output.HadoopOutputFormat extends org.apache.hadoop.mapreduce.OutputFormat implements Serializable |
---|
Serialized Fields |
---|
Class<T> clazz
org.apache.hadoop.mapreduce.OutputFormat<K,V> instance
Class com.datasalt.pangool.tuplemr.mapred.lib.output.PangoolMultipleOutputs.InvalidNamedOutputException extends IOException implements Serializable |
---|
Class com.datasalt.pangool.tuplemr.mapred.lib.output.TupleOutputFormat extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<ITuple,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Serialized Fields |
---|
Schema outputSchema
Class com.datasalt.pangool.tuplemr.mapred.lib.output.TupleTextOutputFormat extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<ITuple,org.apache.hadoop.io.NullWritable> implements Serializable |
---|
Serialized Fields |
---|
Schema schema
char separatorCharacter
char quoteCharacter
char escapeCharacter
boolean addHeader
String nullString
Package com.datasalt.pangool.tuplemr.serialization |
---|
Class com.datasalt.pangool.tuplemr.serialization.SimpleTupleSerializer.CustomObjectSerializationException extends Exception implements Serializable |
---|
Package com.datasalt.pangool.utils |
---|
Class com.datasalt.pangool.utils.AvroBinaryComparator extends Object implements Serializable |
---|
Serialized Fields |
---|
String schemaStr
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |