Package org.apache.iotdb.pipe.api

Interface PipeConnector

All Superinterfaces:

AutoCloseable, PipePlugin

All Known Subinterfaces:

PipeSink

@Deprecated
public interface PipeConnector
extends PipePlugin

Deprecated.

PipeConnector (Deprecated since v1.3.0, renamed to PipeSink)

PipeConnector is responsible for sending Events to sinks.

Various network protocols can be supported by implementing different PipeConnector classes.

The lifecycle of a PipeConnector is as follows:

• When a collaboration task is created, the KV pairs of `WITH CONNECTOR` clause in SQL are parsed and the validation method validate(PipeParameterValidator) will be called to validate the parameters.
• Before the collaboration task starts, the method customize(PipeParameters, PipeConnectorRuntimeConfiguration) will be called to config the runtime behavior of the PipeConnector and the method handshake() will be called to create a connection with sink.
• While the collaboration task is in progress:
  • PipeExtractor captures the Events and wraps them into three types of Event instances.
  • PipeProcessor processes the Event and then passes them to the PipeConnector.
  • PipeConnector serializes the Events into binaries and send them to sinks. The following 3 methods will be called: transfer(TabletInsertionEvent), transfer(TsFileInsertionEvent) and transfer(Event).
• When the collaboration task is cancelled (the `DROP PIPE` command is executed), the AutoCloseable.close() method will be called.

In addition, the method heartbeat() will be called periodically to check whether the connection with sink is still alive. The method handshake() will be called to create a new connection with the sink when the method heartbeat() throws exceptions.

Method Summary

Modifier and Type	Method	Description
void	customize(PipeParameters parameters, PipeConnectorRuntimeConfiguration configuration)	Deprecated. This method is mainly used to customize PipeConnector.
void	handshake()	Deprecated. This method is used to create a connection with sink.
void	heartbeat()	Deprecated. This method will be called periodically to check whether the connection with sink is still alive.
void	transfer(TabletInsertionEvent tabletInsertionEvent)	Deprecated. This method is used to transfer the TabletInsertionEvent.
default void	transfer(TsFileInsertionEvent tsFileInsertionEvent)	Deprecated. This method is used to transfer the TsFileInsertionEvent.
void	transfer(Event event)	Deprecated. This method is used to transfer generic Events.
void	validate(PipeParameterValidator validator)	Deprecated. This method is mainly used to validate PipeParameters and it is executed before customize(PipeParameters, PipeConnectorRuntimeConfiguration) is called.

Methods inherited from interface java.lang.AutoCloseable

close

Method Details

validate

void validate(PipeParameterValidator validator)
       throws Exception

Deprecated.

This method is mainly used to validate PipeParameters and it is executed before customize(PipeParameters, PipeConnectorRuntimeConfiguration) is called.

Parameters:

validator - the validator used to validate PipeParameters

Throws:

Exception - if any parameter is not valid

customize

void customize(PipeParameters parameters,
 PipeConnectorRuntimeConfiguration configuration)
        throws Exception

Deprecated.

This method is mainly used to customize PipeConnector. In this method, the user can do the following things:

• Use PipeParameters to parse key-value pair attributes entered by the user.
• Set the running configurations in PipeConnectorRuntimeConfiguration.

This method is called after the method validate(PipeParameterValidator) is called and before the method handshake() is called.

Parameters:

parameters - used to parse the input PipeParameters entered by the user

configuration - used to set the required properties of the running PipeConnector

Throws:

Exception - the user can throw errors if necessary

handshake

void handshake()
        throws Exception

Deprecated.

This method is used to create a connection with sink. This method will be called after the method customize(PipeParameters, PipeConnectorRuntimeConfiguration) is called or will be called when the method heartbeat() throws exceptions.

Throws:

Exception - if the connection is failed to be created

heartbeat

void heartbeat()
        throws Exception

Deprecated.

This method will be called periodically to check whether the connection with sink is still alive.

Throws:

Exception - if the connection dies

transfer

void transfer(TabletInsertionEvent tabletInsertionEvent)
       throws Exception

Deprecated.

This method is used to transfer the TabletInsertionEvent.

Parameters:

tabletInsertionEvent - TabletInsertionEvent to be transferred

Throws:

PipeConnectionException - if the connection is broken

Exception - the user can throw errors if necessary

transfer

default void transfer(TsFileInsertionEvent tsFileInsertionEvent)
               throws Exception

Deprecated.

This method is used to transfer the TsFileInsertionEvent.

Parameters:

tsFileInsertionEvent - TsFileInsertionEvent to be transferred

Throws:

PipeConnectionException - if the connection is broken

Exception - the user can throw errors if necessary

transfer

void transfer(Event event)
       throws Exception

Deprecated.

This method is used to transfer generic Events.

Parameters:

event - Event to be transferred

Throws:

PipeConnectionException - if the connection is broken

Exception - the user can throw errors if necessary