Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
public interface WriteStrategy extends SerializableSeriali
zable {

    void writer(BatchTableWrite batchTableWrite, String content, String columnSeparator)
            throws Exception;

    Schema retrieveSchema() throws Exception;

}



Code Block
/**
 * Establishes and manages connections.
 */
public interface ConnectionManager {

    /**
     * Retrieves a connection from a channel.
     *
     * @param channel The channel from which to get the connection.
     * @return The retrieved connection.
     */
    Connection get(Channel channel);

    /**
     * Removes and closes a connection from a channel.
     *
     * @param channel The channel from which to remove and close the connection.
     * @return The connection that was removed and closed.
     */
    Connection removeAndClose(Channel channel);

    /**
     * Adds a new connection.
     *
     * @param connection The connection to add.
     */
    void add(Connection connection);

    /**
     * Retrieves the number of connections.
     *
     * @return The number of active connections.
     */
    int getConnNum();

    /**
     * Initializes the connection manager.
     */
    void init();

    /**
     * Destroys the connection manager, releasing resources.
     */
    void destroy();
}




Compatibility, Deprecation, and Migration Plan

...