Package com.zendesk.maxwell.producer

Class MaxwellBigQueryProducer

java.lang.Object

com.zendesk.maxwell.producer.AbstractProducer

com.zendesk.maxwell.producer.MaxwellBigQueryProducer

public class MaxwellBigQueryProducer
extends AbstractProducer

Field Summary

Fields inherited from class com.zendesk.maxwell.producer.AbstractProducer

context, failedMessageCount, failedMessageMeter, messageLatencySloViolationCount, messageLatencyTimer, messagePublishTimer, outputConfig, succeededMessageCount, succeededMessageMeter

Constructor Summary

Constructors

Constructor	Description
MaxwellBigQueryProducer(MaxwellContext context, String bigQueryProjectId, String bigQueryDataset, String bigQueryTable)

Method Summary

Modifier and Type	Method	Description
void	push(RowMap r)

Methods inherited from class com.zendesk.maxwell.producer.AbstractProducer

getDiagnostic, getFailedMessageMeter, getStoppableTask

Methods inherited from class java.lang.Object

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

Constructor Detail

MaxwellBigQueryProducer

public MaxwellBigQueryProducer(MaxwellContext context,
                               String bigQueryProjectId,
                               String bigQueryDataset,
                               String bigQueryTable)
                        throws IOException

Throws:

IOException

Method Detail

push

public void push(RowMap r)
          throws Exception

Specified by:

push in class AbstractProducer

Throws:

Exception