org.apache.paimon.partition.actions

Class HttpReportMarkDoneAction

java.lang.Object

org.apache.paimon.partition.actions.HttpReportMarkDoneAction

All Implemented Interfaces:

Closeable, AutoCloseable, PartitionMarkDoneAction

public class HttpReportMarkDoneAction
extends Object
implements PartitionMarkDoneAction

Report partition submission information to remote http server.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HttpReportMarkDoneAction.HttpReportMarkDoneRequest RestRequest only for HttpReportMarkDoneAction.
static class	HttpReportMarkDoneAction.HttpReportMarkDoneResponse Response only for HttpReportMarkDoneAction.

Constructor Summary

Constructors

Constructor and Description
HttpReportMarkDoneAction()

Method Summary

Modifier and Type	Method and Description
void	close()
void	markDone(String partition)
void	open(FileStoreTable fileStoreTable, CoreOptions options)
HttpReportMarkDoneAction.HttpReportMarkDoneResponse	post(HttpReportMarkDoneAction.HttpReportMarkDoneRequest body, Map<String,String> headers)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.partition.actions.PartitionMarkDoneAction

createActions, createPartitionHandler, generateCustomMarkDoneAction

Constructor Detail

HttpReportMarkDoneAction

public HttpReportMarkDoneAction()

Method Detail

open

public void open(FileStoreTable fileStoreTable,
                 CoreOptions options)

Specified by:

open in interface PartitionMarkDoneAction

markDone

public void markDone(String partition)
              throws Exception

Specified by:

markDone in interface PartitionMarkDoneAction

Throws:

Exception

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

post

public HttpReportMarkDoneAction.HttpReportMarkDoneResponse post(HttpReportMarkDoneAction.HttpReportMarkDoneRequest body,
                                                                Map<String,String> headers)
                                                         throws IOException

Throws:

IOException