Struct rlink_connector_elasticsearch::elasticsearch_sink::ElasticsearchOutputFormat

pub struct ElasticsearchOutputFormat { /* fields omitted */ }

Implementations

impl ElasticsearchOutputFormat

pub fn new(
    address: &str,
    headers: HashMap<String, String>,
    builder: Box<dyn ElasticsearchConverter>
) -> Self

Trait Implementations

impl CheckpointFunction for ElasticsearchOutputFormat

fn consult_version(
    &mut self,
    context: &FunctionSnapshotContext,
    _handle: &Option<CheckpointHandle>
) -> CheckpointId

fn initialize_state(
    &mut self,
    _context: &FunctionSnapshotContext,
    _handle: &Option<CheckpointHandle>
)

trigger the method when a operator initialization

fn snapshot_state(
    &mut self,
    _context: &FunctionSnapshotContext
) -> Option<CheckpointHandle>

trigger the method when the operator operate a Barrier event

impl Debug for ElasticsearchOutputFormat

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl NamedFunction for ElasticsearchOutputFormat

fn name(&self) -> &str

impl OutputFormat for ElasticsearchOutputFormat

fn open(&mut self, context: &Context) -> Result<()>

Opens a parallel instance of the output format to store the result of its parallel instance.

fn write_record(&mut self, record: Record)

fn close(&mut self) -> Result<()>

fn schema(&self, _input_schema: FnSchema) -> FnSchema

fn write_element(&mut self, element: Element)