@Internal public class SinkV1Adapter<InputT,CommT,WriterStateT,GlobalCommT> extends Object implements Sink<InputT>
Modifier and Type | Class and Description |
---|---|
class |
SinkV1Adapter.GlobalCommitterAdapter
Simulate the global committer behaviour with a committer.
|
Sink.InitContext
Modifier and Type | Method and Description |
---|---|
Sink<InputT> |
asSpecializedSink() |
org.apache.flink.streaming.api.transformations.SinkV1Adapter.SinkWriterV1Adapter<InputT,CommT,WriterStateT> |
createWriter(Sink.InitContext context)
Creates a
SinkWriter . |
static <InputT> Sink<InputT> |
wrap(Sink<InputT,?,?,?> sink) |
public org.apache.flink.streaming.api.transformations.SinkV1Adapter.SinkWriterV1Adapter<InputT,CommT,WriterStateT> createWriter(Sink.InitContext context) throws IOException
Sink
SinkWriter
.createWriter
in interface Sink<InputT>
context
- the runtime context.IOException
- for any failure during creation.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.