public final class ClassLoaderSafeConnectorRecordSinkProvider extends Object implements ConnectorRecordSinkProvider
| Constructor and Description |
|---|
ClassLoaderSafeConnectorRecordSinkProvider(ConnectorRecordSinkProvider delegate,
ClassLoader classLoader) |
| Modifier and Type | Method and Description |
|---|---|
RecordSink |
getRecordSink(ConnectorSession session,
ConnectorInsertTableHandle tableHandle) |
RecordSink |
getRecordSink(ConnectorSession session,
ConnectorOutputTableHandle tableHandle) |
public ClassLoaderSafeConnectorRecordSinkProvider(ConnectorRecordSinkProvider delegate, ClassLoader classLoader)
public RecordSink getRecordSink(ConnectorSession session, ConnectorOutputTableHandle tableHandle)
getRecordSink in interface ConnectorRecordSinkProviderpublic RecordSink getRecordSink(ConnectorSession session, ConnectorInsertTableHandle tableHandle)
getRecordSink in interface ConnectorRecordSinkProviderCopyright © 2012-2016. All Rights Reserved.