Package org.apache.pinot.tools.admin.command

Class StreamAvroIntoKafkaCommand

java.lang.Object

org.apache.pinot.tools.AbstractBaseCommand

org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand

org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

All Implemented Interfaces:

Callable<Integer>, Command

public class StreamAvroIntoKafkaCommand
extends AbstractBaseAdminCommand
implements Command

Class for command to stream Avro data into Kafka.

Field Summary

Fields inherited from class org.apache.pinot.tools.AbstractBaseCommand

DEFAULT_CLUSTER_NAME, DEFAULT_ZK_ADDRESS

Constructor Summary

Constructors

Constructor	Description
StreamAvroIntoKafkaCommand()

Method Summary

Modifier and Type	Method	Description
String	description()
boolean	execute()
boolean	getHelp()
String	getName()
StreamAvroIntoKafkaCommand	setAvroFile(String avroFile)
StreamAvroIntoKafkaCommand	setKafkaBrokerList(String kafkaBrokerList)
StreamAvroIntoKafkaCommand	setKafkaTopic(String kafkaTopic)
StreamAvroIntoKafkaCommand	setOutputFormat(String outputFormat)
StreamAvroIntoKafkaCommand	setZkAddress(String zkAddress)
String	toString()

Methods inherited from class org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand

getPID, savePID, sendDeleteRequest, sendPostRequest, sendRequest, sendRequest

Methods inherited from class org.apache.pinot.tools.AbstractBaseCommand

cleanup, printExamples, printUsage

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.pinot.tools.Command

call, printUsage

Constructor Detail

StreamAvroIntoKafkaCommand

public StreamAvroIntoKafkaCommand()

Method Detail

getHelp

public boolean getHelp()

Specified by:

getHelp in interface Command

getName

public String getName()

Overrides:

getName in class AbstractBaseCommand

toString

public String toString()

Overrides:

toString in class Object

description

public String description()

Specified by:

description in interface Command

execute

public boolean execute()
                throws IOException

Specified by:

execute in interface Command

Throws:

IOException

setAvroFile

public StreamAvroIntoKafkaCommand setAvroFile(String avroFile)

setKafkaBrokerList

public StreamAvroIntoKafkaCommand setKafkaBrokerList(String kafkaBrokerList)

setKafkaTopic

public StreamAvroIntoKafkaCommand setKafkaTopic(String kafkaTopic)

setZkAddress

public StreamAvroIntoKafkaCommand setZkAddress(String zkAddress)

setOutputFormat

public StreamAvroIntoKafkaCommand setOutputFormat(String outputFormat)