THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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
...