pub trait Sink: TryFrom<SinkParam, Error = SinkError> {
type LogSinker: LogSinker;
type Coordinator: SinkCommitCoordinator;
const SINK_NAME: &'static str;
const SINK_ALTER_CONFIG_LIST: &'static [&'static str] = _;
// Required methods
async fn validate(&self) -> Result<()>;
async fn new_log_sinker(
&self,
writer_param: SinkWriterParam,
) -> Result<Self::LogSinker>;
// Provided methods
fn set_default_commit_checkpoint_interval(
desc: &mut SinkDesc,
user_specified: &SinkDecouple,
) -> Result<()> { ... }
fn is_sink_decouple(user_specified: &SinkDecouple) -> Result<bool> { ... }
fn validate_alter_config(_config: &BTreeMap<String, String>) -> Result<()> { ... }
fn is_coordinated_sink(&self) -> bool { ... }
async fn new_coordinator(
&self,
_db: DatabaseConnection,
_iceberg_compact_stat_sender: Option<UnboundedSender<IcebergSinkCompactionUpdate>>,
) -> Result<Self::Coordinator> { ... }
}Required Associated Constants§
Provided Associated Constants§
const SINK_ALTER_CONFIG_LIST: &'static [&'static str] = _
Required Associated Types§
Required Methods§
async fn validate(&self) -> Result<()>
async fn new_log_sinker( &self, writer_param: SinkWriterParam, ) -> Result<Self::LogSinker>
Provided Methods§
fn set_default_commit_checkpoint_interval( desc: &mut SinkDesc, user_specified: &SinkDecouple, ) -> Result<()>
Sourcefn is_sink_decouple(user_specified: &SinkDecouple) -> Result<bool>
fn is_sink_decouple(user_specified: &SinkDecouple) -> Result<bool>
user_specified is the value of sink_decouple config.
fn validate_alter_config(_config: &BTreeMap<String, String>) -> Result<()>
fn is_coordinated_sink(&self) -> bool
async fn new_coordinator( &self, _db: DatabaseConnection, _iceberg_compact_stat_sender: Option<UnboundedSender<IcebergSinkCompactionUpdate>>, ) -> Result<Self::Coordinator>
Dyn Compatibility§
This trait is not dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.