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

Interface MaxComputeWriter

All Known Implementing Classes:

BatchAppendWriter, BatchUpsertWriter

public interface MaxComputeWriter

the interface of all writer to write ArrayRecord to maxcompute.

Method Summary

Modifier and Type	Method	Description
static MaxComputeWriter	batchWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, SessionIdentifier sessionIdentifier)
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)

Method Detail

batchWriter

static MaxComputeWriter batchWriter(MaxComputeOptions options,
                                    MaxComputeWriteOptions writeOptions,
                                    SessionIdentifier sessionIdentifier)
                             throws IOException

Throws:

IOException

getSessionIdentifier

SessionIdentifier getSessionIdentifier()

newElement

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

write

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

Throws:

IOException

delete

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

Throws:

IOException

flush

void flush()
    throws IOException

Throws:

IOException

commit

void commit()
     throws IOException

Throws:

IOException

getId

String getId()