JavaScript is disabled on your browser.
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
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
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes