Package org.apache.flink.cdc.connectors.maxcompute.writer

Class BatchUpsertWriter

java.lang.Object

org.apache.flink.cdc.connectors.maxcompute.writer.BatchUpsertWriter

All Implemented Interfaces:

MaxComputeWriter

public class BatchUpsertWriter
extends Object
implements MaxComputeWriter

MaxCompute upsert writer, use UpsertSessionImpl and UpsertStream to write data. Each session corresponds to a stream.

Constructor Summary

Constructors

Constructor	Description
BatchUpsertWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, SessionIdentifier sessionIdentifier)

Method Summary

Modifier and Type	Method	Description
void	commit()
void	delete(com.aliyun.odps.data.ArrayRecord record)
void	flush()
String	getId()
SessionIdentifier	getSessionIdentifier()
com.aliyun.odps.data.ArrayRecord	newElement()
void	write(com.aliyun.odps.data.ArrayRecord record)

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchUpsertWriter

public BatchUpsertWriter(MaxComputeOptions options,
                         MaxComputeWriteOptions writeOptions,
                         SessionIdentifier sessionIdentifier)
                  throws IOException

Throws:

IOException

Method Detail

getSessionIdentifier

public SessionIdentifier getSessionIdentifier()

Specified by:

getSessionIdentifier in interface MaxComputeWriter

newElement

public com.aliyun.odps.data.ArrayRecord newElement()

Specified by:

newElement in interface MaxComputeWriter

write

public void write(com.aliyun.odps.data.ArrayRecord record)
           throws IOException

Specified by:

write in interface MaxComputeWriter

Throws:

IOException

delete

public void delete(com.aliyun.odps.data.ArrayRecord record)
            throws IOException

Specified by:

delete in interface MaxComputeWriter

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface MaxComputeWriter

Throws:

IOException

getId

public String getId()

Specified by:

getId in interface MaxComputeWriter

commit

public void commit()
            throws IOException

Specified by:

commit in interface MaxComputeWriter

Throws:

IOException