A C D E G K M O P Q R S T W 

A

AvroKafkaStorage - Class in kafka.bridge.pig
 
AvroKafkaStorage(String) - Constructor for class kafka.bridge.pig.AvroKafkaStorage
 
avroSchema - Variable in class kafka.bridge.pig.AvroKafkaStorage
 

C

checkOutputSpecs(JobContext) - Method in class kafka.bridge.hadoop.KafkaOutputFormat
 
checkSchema(ResourceSchema) - Method in class kafka.bridge.pig.AvroKafkaStorage
 
cleanupOnFailure(String, Job) - Method in class kafka.bridge.pig.AvroKafkaStorage
 
close(TaskAttemptContext) - Method in class kafka.bridge.hadoop.KafkaRecordWriter
 

D

datumWriter - Variable in class kafka.bridge.pig.AvroKafkaStorage
 

E

encoder - Variable in class kafka.bridge.pig.AvroKafkaStorage
 

G

getOutputCommitter(TaskAttemptContext) - Method in class kafka.bridge.hadoop.KafkaOutputFormat
 
getOutputFormat() - Method in class kafka.bridge.pig.AvroKafkaStorage
 
getOutputPath(JobContext) - Static method in class kafka.bridge.hadoop.KafkaOutputFormat
 
getRecordWriter(TaskAttemptContext) - Method in class kafka.bridge.hadoop.KafkaOutputFormat
 

K

kafka.bridge.examples - package kafka.bridge.examples
 
kafka.bridge.hadoop - package kafka.bridge.hadoop
 
kafka.bridge.pig - package kafka.bridge.pig
 
KAFKA_CONFIG_PREFIX - Static variable in class kafka.bridge.hadoop.KafkaOutputFormat
 
KAFKA_QUEUE_BYTES - Static variable in class kafka.bridge.hadoop.KafkaOutputFormat
Bytes to buffer before the OutputFormat does a send (i.e., the amortization window): We set the default to a million bytes so that the server will not reject the batch of messages with a MessageSizeTooLargeException.
KAFKA_URL - Static variable in class kafka.bridge.hadoop.KafkaOutputFormat
 
KafkaOutputFormat<K,V> - Class in kafka.bridge.hadoop
 
KafkaOutputFormat() - Constructor for class kafka.bridge.hadoop.KafkaOutputFormat
 
KafkaRecordWriter<K,V> - Class in kafka.bridge.hadoop
 
KafkaRecordWriter(Producer<Object, byte[]>, String, int) - Constructor for class kafka.bridge.hadoop.KafkaRecordWriter
 

M

main(String[]) - Static method in class kafka.bridge.examples.TextPublisher
 
map(Object, Text, Mapper<Object, Text, Object, Object>.Context) - Method in class kafka.bridge.examples.TextPublisher.TheMapper
 
msgList - Variable in class kafka.bridge.hadoop.KafkaRecordWriter
 

O

os - Variable in class kafka.bridge.pig.AvroKafkaStorage
 

P

prepareToWrite(RecordWriter) - Method in class kafka.bridge.pig.AvroKafkaStorage
 
producer - Variable in class kafka.bridge.hadoop.KafkaRecordWriter
 
putNext(Tuple) - Method in class kafka.bridge.pig.AvroKafkaStorage
 

Q

queueBytes - Variable in class kafka.bridge.hadoop.KafkaRecordWriter
 

R

relToAbsPathForStoreLocation(String, Path) - Method in class kafka.bridge.pig.AvroKafkaStorage
 

S

sendMsgList() - Method in class kafka.bridge.hadoop.KafkaRecordWriter
 
setOutputPath(Job, Path) - Static method in class kafka.bridge.hadoop.KafkaOutputFormat
 
setStoreFuncUDFContextSignature(String) - Method in class kafka.bridge.pig.AvroKafkaStorage
 
setStoreLocation(String, Job) - Method in class kafka.bridge.pig.AvroKafkaStorage
 

T

TextPublisher - Class in kafka.bridge.examples
Publish a text file line by line to a Kafka topic
TextPublisher() - Constructor for class kafka.bridge.examples.TextPublisher
 
TextPublisher.TheMapper - Class in kafka.bridge.examples
 
TextPublisher.TheMapper() - Constructor for class kafka.bridge.examples.TextPublisher.TheMapper
 
topic - Variable in class kafka.bridge.hadoop.KafkaRecordWriter
 
totalBytes - Variable in class kafka.bridge.hadoop.KafkaRecordWriter
 

W

write(K, V) - Method in class kafka.bridge.hadoop.KafkaRecordWriter
 
writeEnvelope(OutputStream, Encoder) - Method in class kafka.bridge.pig.AvroKafkaStorage
 
writer - Variable in class kafka.bridge.pig.AvroKafkaStorage
 
A C D E G K M O P Q R S T W