Struct rlink_connector_elasticsearch::elasticsearch_sink::ElasticsearchOutputFormat [−][src]
pub struct ElasticsearchOutputFormat { /* fields omitted */ }
Implementations
Trait Implementations
impl CheckpointFunction for ElasticsearchOutputFormat
[src]
impl CheckpointFunction for ElasticsearchOutputFormat
[src]pub fn consult_version(
&mut self,
context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
) -> CheckpointId
[src]
&mut self,
context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
) -> CheckpointId
pub fn initialize_state(
&mut self,
_context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
)
[src]
&mut self,
_context: &FunctionSnapshotContext,
_handle: &Option<CheckpointHandle>
)
pub fn snapshot_state(
&mut self,
_context: &FunctionSnapshotContext
) -> Option<CheckpointHandle>
[src]
&mut self,
_context: &FunctionSnapshotContext
) -> Option<CheckpointHandle>
Auto Trait Implementations
impl !RefUnwindSafe for ElasticsearchOutputFormat
impl !RefUnwindSafe for ElasticsearchOutputFormat
impl Send for ElasticsearchOutputFormat
impl Send for ElasticsearchOutputFormat
impl Sync for ElasticsearchOutputFormat
impl Sync for ElasticsearchOutputFormat
impl Unpin for ElasticsearchOutputFormat
impl Unpin for ElasticsearchOutputFormat
impl !UnwindSafe for ElasticsearchOutputFormat
impl !UnwindSafe for ElasticsearchOutputFormat
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T> UnsafeAny for T where
T: Any,
impl<T> UnsafeAny for T where
T: Any,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,