org.apache.iceberg.connect.data

Class NoOpWriter

java.lang.Object

org.apache.iceberg.connect.data.NoOpWriter

All Implemented Interfaces:

java.lang.Cloneable, RecordWriter

public class NoOpWriter
extends java.lang.Object
implements RecordWriter

Constructor Summary

Constructors

Constructor and Description
NoOpWriter()

Method Summary

Modifier and Type	Method and Description
void	close()
java.util.List<WriterResult>	complete()
void	write(org.apache.kafka.connect.sink.SinkRecord record)

Methods inherited from class java.lang.Object

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

Constructor Detail

NoOpWriter

public NoOpWriter()

Method Detail

write

public void write(org.apache.kafka.connect.sink.SinkRecord record)

Specified by:

write in interface RecordWriter

complete

public java.util.List<WriterResult> complete()

Specified by:

complete in interface RecordWriter

close

public void close()

Specified by:

close in interface RecordWriter